api

README

api

• Project README
• Release/Build Status
• Changelog
• License
• Contribution Guidelines
• Code of Conduct
• Secure Coding Guidelines

Specification

Description

The api package contains all API functionality of Device Management Service (DMS). DMS exposes various endpoints through which its different functionalities can be accessed.

Structure and Organisation

Here is quick overview of the contents of this directory:

• README: Current file which is aimed towards developers who wish to use and modify the api functionality.

• api.go: This file contains router setup using Gin framework. It also applies Cross-Origin Resource Sharing (CORS) middleware and OpenTelemetry middleware for tracing. Further it lists down the endpoint URLs and the associated handler functions.

• actor.go: Contains endpoints for actor interaction.

Functionality

Configuration

The REST server by default binds to 127.0.0.1 on port 9999. The configuration file dms_config.json can be used to change to a different address and port.

The parameters rest.port and rest.addr define the port and the address respectively.

You can use the following format to construct the URL for accessing API endpoints

http://localhost:<port>/api/v1/<endpoint>

Currently, all endpoints are under the /actor path

/actor/handle

Retrieve actor handle with ID, DID, and inbox address

Item	Value
endpoint:	/actor/handle
method:	HTTP GET
output:	Actor Handle

Response:

{
    "id": <actor_id>,
    "did" : <actor_did>,
    "addr" : <inbox_address>
}

/actor/send

Send a message to actor

Item	Value
endpoint:	/actor/handle
method:	HTTP POST
output:	{"message": "message sent"}

The request should be an enveloped message

{
    "to": {
        "id": <actor_id>,
        "did" : <actor_did>,
        "addr" : <inbox_address>
    },
    "be": <behavior>,
    "from": {
        "id": <actor_id>,
        "did" : <actor_did>,
        "addr" : <inbox_address>
    },
    "nonce": <nonce>,
    "opt": {
        "cont": <topic_to_publish_to>,
        "exp": <time_to_expire>
    },
    "msg": <message>,
    "cap": <capability>,
    "sig": <signature>
}

/actor/invoke

Invoke actor with message

Item	Value
endpoint:	/actor/invoke
method:	HTTP POST
output:	Enveloped Response or if error {"error": "<error message>"}

The request should be an enveloped message

{
    "to": {
        "id": <actor_id>,
        "did" : <actor_did>,
        "addr" : <inbox_address>
    },
    "be": <behavior>,
    "from": {
        "id": <actor_id>,
        "did" : <actor_did>,
        "addr" : <inbox_address>
    },
    "nonce": <nonce>,
    "opt": {
        "cont": <topic_to_publish_to>,     // needs to be specified for invoke
        "exp": <time_to_expire>
    },
    "msg": <message>,
    "cap": <capability>,
    "sig": <signature>
}

/actor/broadcast

Broadcast message to actors

Item	Value
endpoint:	/actor/broadcast
method:	HTTP POST
output:	Enveloped Response or if error {"error": "<error message>"}

The request should be an enveloped message

{
    "to": {},                                 // should be empty for broadcast
    "be": <behavior>,
    "from": {
        "id": <actor_id>,
        "did" : <actor_did>,
        "addr" : <inbox_address>
    },
    "nonce": <nonce>,
    "opt": {
        "topic": <topic_to_publish_to>,
        "exp": <time_to_expire>
    },
    "msg": <message>,
    "cap": <capability>,
    "sig": <signature>
}

For more details on these Actor API endpoints, refer to the cmd/actor package on how the they are used.

Documentation

Index

• func SendMessage(ctx context.Context, net *libp2p.Libp2p, msg actor.Envelope) (err error)
• type RESTServer
  • func NewRESTServer(config *RESTServerConfig) *RESTServer
  • func (rs RESTServer) ActorBroadcast(c *gin.Context)
  • func (rs RESTServer) ActorHandle(c *gin.Context)
  • func (rs RESTServer) ActorInvoke(c *gin.Context)
  • func (rs RESTServer) ActorSendMessage(c *gin.Context)
  • func (rs *RESTServer) InitializeRoutes()
  • func (rs *RESTServer) Run() error
• type RESTServerConfig

Functions

func SendMessage

func SendMessage(ctx context.Context, net *libp2p.Libp2p, msg actor.Envelope) (err error)

Types

type RESTServer

type RESTServer struct {
	// contains filtered or unexported fields
}

RESTServer represents a HTTP server

func NewRESTServer

func NewRESTServer(config *RESTServerConfig) *RESTServer

NewRESTServer is a constructor function for RESTServer It returns a pointer to RESTServer

func (RESTServer) ActorBroadcast

func (rs RESTServer) ActorBroadcast(c *gin.Context)

ActorBroadcast godoc

     @Summary		Broadcast message to actors
			@Description	Broadcast message to actors
			@Tags			actor
			@Accept			json
			@Produce		json
		  @Param			message	body	actor.Envelope	true	"Message to send"
			@Success		200	{object}	object	"received responses"
	   @Failure		400	{object}	object	"invalid request data"
			@Failure		500	{object}	object	"host node hasn't yet been initialized"
			@Failure		500	{object}	object	"failed to marshal message"
			@Failure		500	{object}	object	"failed to publish message"
			@Router			/actor/broadcast [post]

func (RESTServer) ActorHandle

func (rs RESTServer) ActorHandle(c *gin.Context)

ActorHandle godoc

@Summary		Retrieve actor handle
@Description	Retrieve actor handle with ID, DID, and inbox address
@Tags			actor
@Produce		json
@Success		200	{object}	actor.Handle
@Failure		500	{object}	object	"host node hasn't yet been initialized"
@Failure		500	{object}	object	"handle id is invalid"
@Router			/actor/handle [get]

func (RESTServer) ActorInvoke

func (rs RESTServer) ActorInvoke(c *gin.Context)

ActorInvoke godoc

	@Summary		Invoke actor
	@Description	Invoke actor with message
	@Tags			actor
	@Accept			json
	@Produce		json
 @Param			message	body	actor.Envelope	true	"Message to send"
	@Success		200	{object}	object	"response message"
 @Failure		400	{object}	object	"invalid request data"
	@Failure		500	{object}	object	"host node hasn't yet been initialized"
	@Failure		500	{object}	object	"failed to marshal message"
	@Failure		500	{object}	object	"destination address can't be resolved"
	@Failure		500	{object}	object	"failed to send message to destination"
	@Router			/actor/invoke [post]

func (RESTServer) ActorSendMessage

func (rs RESTServer) ActorSendMessage(c *gin.Context)

ActorSendMessage godoc

	@Summary		Send message to actor
	@Description	Send message to actor
	@Tags			actor
	@Accept			json
	@Produce		json
 @Param			message	body	actor.Envelope	true	"Message to send"
	@Success		200	{object}	object	"message sent"
 @Failure		400	{object}	object	"invalid request data"
	@Failure		500	{object}	object	"host node hasn't yet been initialized"
	@Failure		500	{object}	object	"failed to marshal message"
	@Failure		500	{object}	object	"destination address can't be resolved"
	@Failure		500	{object}	object	"failed to send message to destination"
	@Router			/actor/send [post]

func (*RESTServer) InitializeRoutes

func (rs *RESTServer) InitializeRoutes()

InitializeRoutes sets up all the endpoint routes

func (*RESTServer) Run

func (rs *RESTServer) Run() error

Run starts the server on the specified port

type RESTServerConfig

type RESTServerConfig struct {
	P2P        *libp2p.Libp2p
	Onboarding *onboarding.Onboarding
	Resource   types.ResourceManager
	MidW       []gin.HandlerFunc
	Port       uint32
	Addr       string
}