comm

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

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

type FillStatus func(workerDID string, taskID string, ps *pb.ProtocolStatus) *pb.ProtocolStatus

type Handler interface {
}

type HandlerFunc func(packet Packet) (err error)

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

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

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

type Receiver interface {
	MyDID() core.DID
	MyCA() Receiver
	WorkerEA() Receiver
	ExportWallet(key string, exportPath string) (url string)
	RootDid() core.DID
	SendNYM(targetDid *ssi.DID, submitterDid, alias, role string) (err error)
	LoadDID(did string) core.DID
	LoadTheirDID(connection storage.Connection) core.DID
	WDID() string
	PwPipe(pw string) (cp sec.Pipe, err error)
	NewOutDID(didInfo ...string) (id core.DID, err error)
	Wallet() int
	ManagedWallet() (managed.Wallet, managed.Wallet)
	Pool() int
	FindPWByID(id string) (pw *storage.Connection, err error)
	AttachSAImpl(implID string)
	AddToPWMap(me, you core.DID, name string) sec.Pipe
	SaveTheirDID(did, vk string) (err error)
	CAEndp(connID string) (endP *endp.Addr)
	AddPipeToPWMap(p sec.Pipe, name string)
	MasterSecret() (string, error)
	AutoPermission() bool
	ID() string
}

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

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

type Starter func(ca Receiver, t Task)

type Task interface {
	ID() string                     // Unique uid: API Protocol ID/Protocol thread ID
	Type() string                   // Our internal payload type
	ProtocolType() pb.Protocol_Type // Aries protocol
	UserActionType() string         // Internal payload type when waiting for user action
	Role() pb.Protocol_Role         // Agent role in Aries protocol
	ConnectionID() string           // Pairwise id
	ReceiverEndp() service.Addr     // Pairwise receiver endpoint
	SetReceiverEndp(r service.Addr)
	DIDMethod() method.Type
}

type TaskBase struct {
	Task
	TaskHeader
}

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

	Sender   service.Addr
	Receiver service.Addr

	Method method.Type
}