comm

Documentation

Index

• Variables
• func SendPL(sendPipe sec.Pipe, task Task, opl didcomm.Payload) (err error)
• type Continuator
• type Creator
• type Handler
• type HandlerFunc
• type Packet
• type ProtHandler
• type ProtProc
  • func (p ProtProc) Process(packet Packet) (err error)
• type Receiver
• type Receivers
  • func (rs *Receivers) Add(DID string, r Receiver)
  • func (rs *Receivers) Get(DID string) Receiver
• type SeedHandler
• type Starter
• type Status
• type Task
• type TaskBase
  • func (t *TaskBase) ConnectionID() string
  • func (t *TaskBase) ID() string
  • func (t *TaskBase) ReceiverEndp() service.Addr
  • func (t *TaskBase) Role() pb.Protocol_Role
  • func (t *TaskBase) SetReceiverEndp(r service.Addr)
  • func (t *TaskBase) Type() string
• type TaskHeader
  • func (t *TaskHeader) SwitchDirection()

Variables

var ActiveRcvrs = Receivers{
	Rcvrs: make(map[string]Receiver),
}

var FileDownload = downloadFile

FileDownload is proxy function to route actual call to http or pseudo http in tests.

var Proc = &processor{}

var SendAndWaitReq = sendAndWaitHTTPRequest

SendAndWaitReq is proxy function to route actual call to http or pseudo http in tests.

Functions

func SendPL

func SendPL(sendPipe sec.Pipe, task Task, opl didcomm.Payload) (err error)

SendPL is helper function to send a protocol messages to receiver which is defined in the Task.ReceiverEndp. Function will encrypt messages before sending. It doesn't resend PL in case of failure. The recovering in done at PSM level.

Types

type Continuator

type Continuator func(ca Receiver, im didcomm.Msg)

type Creator

type Creator func(header *TaskHeader, protocol *pb.Protocol) (Task, error)

type Handler

type Handler interface {
}

Handler can be Agency or Agent. They can input Payloads.

type HandlerFunc

type HandlerFunc func(packet Packet) (err error)

HandlerFunc is func type for protocol message handlers. We add them to protocol processors with the associated message type. See Payload.Type

type Packet

type Packet struct {
	Payload  didcomm.Payload
	Address  *endp.Addr
	Receiver Receiver
}

type ProtHandler

type ProtHandler interface {
	Process(packet Packet) (err error)
}

ProtHandler is an interface for whole protocol. Where HandlerFunc is handler for protocol message, the protocol handler is whole protocol group, all of the same message family.

type ProtProc

type ProtProc struct {
	Creator
	Starter
	Handlers map[string]HandlerFunc
	Continuator
	Status
}

ProtProc is a protocol processor. It is struct for protocol handlers. Instances of it are the actual protocol handlers. Just declare var and the needed msg handlers (HandlerFunc) and register it to the processor.

func (ProtProc) Process

func (p ProtProc) Process(packet Packet) (err error)

Process delivers the protocol message inside the packet to correct protocol function.

type Receiver

type Receiver interface {
	Trans() txp.Trans
	MyCA() Receiver
	WorkerEA() Receiver
	ExportWallet(key string, exportPath string) (url string)
	RootDid() *ssi.DID
	SendNYM(targetDid *ssi.DID, submitterDid, alias, role string) (err error)
	LoadDID(did string) *ssi.DID
	WDID() string
	PwPipe(pw string) (cp sec.Pipe, err error)
	Wallet() int
	Pool() int
	FindPW(my string) (their string, pwname string, err error)
	CallEA(plType string, im didcomm.Msg) (om didcomm.Msg, err error)
	AttachAPIEndp(endp service.Addr) error
	AttachSAImpl(implID string, persistent bool)
	AddToPWMap(me, you *ssi.DID, name string) sec.Pipe
	SaveTheirDID(did, vk string, writeNYM bool) (err error)
	CAEndp(wantWorker bool) (endP *endp.Addr)
	AddPipeToPWMap(p sec.Pipe, name string)
	MasterSecret() (string, error)
	AutoPermission() bool
}

type Receivers

type Receivers struct {
	Rcvrs map[string]Receiver
	Lk    sync.Mutex
}

func (*Receivers) Add

func (rs *Receivers) Add(DID string, r Receiver)

func (*Receivers) Get

func (rs *Receivers) Get(DID string) Receiver

type SeedHandler

type SeedHandler interface {
	Prepare() (Handler, error)
}

SeedHandler is preloaded cloud agent which is not initialized yet.

type Starter

type Starter func(ca Receiver, t Task)

type Status

type Status func(workerDID string, taskID string) interface{}

type Task

type Task interface {
	ID() string
	Type() string
	Role() pb.Protocol_Role
	ConnectionID() string
	ReceiverEndp() service.Addr
	SetReceiverEndp(r service.Addr)
}

type TaskBase

type TaskBase struct {
	Task
	TaskHeader
}

func (*TaskBase) ConnectionID

func (t *TaskBase) ConnectionID() string

func (*TaskBase) ID

func (t *TaskBase) ID() string

func (*TaskBase) ReceiverEndp

func (t *TaskBase) ReceiverEndp() service.Addr

func (*TaskBase) Role

func (t *TaskBase) Role() pb.Protocol_Role

func (*TaskBase) SetReceiverEndp

func (t *TaskBase) SetReceiverEndp(r service.Addr)

func (*TaskBase) Type

func (t *TaskBase) Type() string

type TaskHeader

type TaskHeader struct {
	TaskID         string
	TypeID         string
	ProtocolTypeID string
	ProtocolRole   pb.Protocol_Role
	ConnID         string

	Sender   service.Addr
	Receiver service.Addr
}

func (*TaskHeader) SwitchDirection

func (t *TaskHeader) SwitchDirection()

SwitchDirection changes SenderEndp and ReceiverEndp data