sdk

type EventService interface {
	Publish(topic string, event *NitricEvent) error
	ListTopics() ([]string, error)
}

type FailedTask struct {
	Task    *NitricTask
	Message string
}

type GatewayService interface {
	// Start the Gateway
	Start(pool worker.WorkerPool) error
	// Stops the Gateway
	Stop() error
}

type KeyValueService interface {
	Put(string, string, map[string]interface{}) error
	Get(string, string) (map[string]interface{}, error)
	Delete(string, string) error
}

type NitricContext struct {
	RequestId   string
	PayloadType string
	Trigger     string
	TriggerType triggers.TriggerType
}

type NitricEvent struct {
	ID          string                 `json:"id,omitempty"`
	PayloadType string                 `json:"payloadType,omitempty"`
	Payload     map[string]interface{} `json:"payload,omitempty"`
}

type NitricRequest struct {
	Context     *NitricContext
	ContentType string
	Payload     []byte
}

type NitricResponse struct {
	Headers map[string]string
	Status  int
	Body    []byte
}

type NitricTask struct {
	ID          string                 `json:"id,omitempty"`
	LeaseID     string                 `json:"leaseId,omitempty"`
	PayloadType string                 `json:"payloadType,omitempty"`
	Payload     map[string]interface{} `json:"payload,omitempty"`
}

type QueueService interface {
	// Send - Send a single task to a queue
	Send(queue string, task NitricTask) error
	// SendBatch - sends multiple tasks to a queue
	SendBatch(queue string, tasks []NitricTask) (*SendBatchResponse, error)
	// Receive - Receives one or more tasks(s) off a queue
	Receive(options ReceiveOptions) ([]NitricTask, error)
	// Complete - Marks a received task as completed
	Complete(queue string, leaseId string) error
}

type ReceiveOptions struct {
	// Nitric name for the queue.
	//
	// queueName is a required field
	QueueName string `type:"string" required:"true"`

	// Max depth of queue messages to receive from the queue.
	//
	// If nil or 0, defaults to depth 1.
	Depth *uint32 `type:"int" required:"false"`
}

type SendBatchResponse struct {
	FailedTasks []*FailedTask
}

type ServiceFactory interface {
	NewAuthService() (UserService, error)
	NewKeyValueService() (KeyValueService, error)
	NewEventService() (EventService, error)
	NewGatewayService() (GatewayService, error)
	NewQueueService() (QueueService, error)
	NewStorageService() (StorageService, error)
}

type StorageService interface {
	Read(bucket string, key string) ([]byte, error)
	Write(bucket string, key string, object []byte) error
	Delete(bucket string, key string) error
}

type UnimplementedAuthPlugin struct {
	UserService
}

type UnimplementedEventingPlugin struct {
	EventService
}

type UnimplementedGatewayPlugin struct {
	GatewayService
}

type UnimplementedKeyValuePlugin struct {
	KeyValueService
}

type UnimplementedQueuePlugin struct {
	QueueService
}

type UnimplementedServiceFactory struct {
}

type UnimplementedStoragePlugin struct{}

type UserService interface {
	Create(tenant string, id string, email string, password string) error
}