privatemessaging

type GroupManager interface {
	GetGroupByID(ctx context.Context, id string) (*fftypes.Group, error)
	GetGroupsNS(ctx context.Context, ns string, filter database.AndFilter) ([]*fftypes.Group, *database.FilterResult, error)
	ResolveInitGroup(ctx context.Context, msg *fftypes.Message) (*fftypes.Group, error)
	EnsureLocalGroup(ctx context.Context, group *fftypes.Group) (ok bool, err error)
}

type Manager interface {
	fftypes.Named
	GroupManager

	Start() error
	NewMessage(ns string, msg *fftypes.MessageInOut) sysmessaging.MessageSender
	SendMessage(ctx context.Context, ns string, in *fftypes.MessageInOut, waitConfirm bool) (out *fftypes.Message, err error)
	RequestReply(ctx context.Context, ns string, request *fftypes.MessageInOut) (reply *fftypes.MessageInOut, err error)

	// From operations.OperationHandler
	PrepareOperation(ctx context.Context, op *fftypes.Operation) (*fftypes.PreparedOperation, error)
	RunOperation(ctx context.Context, op *fftypes.PreparedOperation) (outputs fftypes.JSONObject, complete bool, err error)
}