lib

type Agent struct {
	Name        string `json:"name"`
	ID          string `json:"id"`
	BLSSeed     []byte `json:"bls_seed"`
	AccountCode string `json:"account_code,omitempty"`
	ZKPID       []byte `json:"zkpid,omitempty"`
	ZKPToken    []byte `json:"zkptoken,omitempty"`
	Pending     bool   `json:"pending"`
}

type ErrHandler func(err error)

type Handler func(message []byte)

type MockSigningAgentClient struct {
	GetSystemAgentIDCalled     bool
	GetAgentZKPOnePassCalled   bool
	ClientRegisterCalled       bool
	ClientInitCalled           bool
	ClientRegisterFinishCalled bool
	ActionApproveCalled        bool
	GetAgentIDCalled           bool
	GetAgentNameCalled         bool
	ActionRejectCalled         bool
	Counter                    int
	NextError                  error
	NextClientInitError        error
	NextRegisterError          error
	NextRegisterFinishError    error
	NextZKPOnePass             []byte
	NextAgentID                string
	NextAgentName              string
	LastRegisteredName         string
	NextClientRegisterResponse *api.ClientRegisterResponse
	NextRegisterInitResponse   *api.QredoRegisterInitResponse
	NextRegisterFinishResponse *api.ClientRegisterFinishResponse
	LastRegisterRequest        *api.QredoRegisterInitRequest
	LastRegisterFinishRequest  *api.ClientRegisterFinishRequest
	LastRef                    string
	LastApiKey                 string
	Last64PrivateKey           string
	LastActionId               string
	LastRejectActionId         string
	LastAgentID                string
}

type Request struct {
	Uri       string
	Body      []byte
	ApiKey    string
	Timestamp string
	Signature string
	RsaKey    *rsa.PrivateKey
}

type ServeCB func(string, Handler, ErrHandler) (chan struct{}, chan struct{}, error)

type SigningAgentClient interface {
	// ClientInit starts the agent registration process
	ClientInit(register *api.QredoRegisterInitRequest, ref, apikey, b64PrivateKey string) (*api.QredoRegisterInitResponse, error)
	// ClientRegister starts the simplified agent registration procedure
	// by generating BLS and EC key pairs and returns the public keys
	ClientRegister(name string) (*api.ClientRegisterResponse, error)
	// ClientRegisterFinish concludes the agent registration process
	ClientRegisterFinish(req *api.ClientRegisterFinishRequest, ref string) (*api.ClientRegisterFinishResponse, error)
	// GetAgentID returns the agent id if registered
	GetAgentID() string
	// GetAgentName returns the agent name if registered
	GetAgentName(agentID string) string

	// ActionApprove signs actionID and sends it for approval to the Qredo backend
	ActionApprove(actionID string) error
	// ActionReject sends a rejection to the Qredo backend for actionID
	ActionReject(actionID string) error

	// SetSystemAgentID function to collect agent ID to storage, so the system will default to a single agent ID (AgentID)
	SetSystemAgentID(agetID string) error
	// GetSystemAgentID function to get agent ID that was stored during registration process.
	GetSystemAgentID() string
	// GetAgentZKPOnePass function to generate Zero Knowladge Proof one password (for auth header).
	GetAgentZKPOnePass() ([]byte, error)

	// ReadAction connect to qredo web socket stream by given feed url and return Feed object
	ReadAction(string, ServeCB) *feed
}

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

type WsActionInfoEvent struct {
	ID         string `json:"id"`
	AgentID    string `json:"coreClientID"`
	Type       string `json:"type"`
	Status     string `json:"status"`
	Timestamp  int64  `json:"timestamp"`
	ExpireTime int64  `json:"expireTime"`
}

type WsActionInfoHandler func(event *WsActionInfoEvent)