sdk

type Collection struct {
	Name   string
	Parent *Key
}

type Document struct {
	Content map[string]interface{}
}

type DocumentService interface {
	Get(*Key) (*Document, error)
	Set(*Key, map[string]interface{}) error
	Delete(*Key) error
	Query(*Collection, []QueryExpression, int, map[string]string) (*QueryResult, error)
}

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 Key struct {
	Collection *Collection
	Id         string
}

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 QueryExpression struct {
	Operand  string
	Operator string
	Value    interface{}
}

type QueryResult struct {
	Documents   []Document
	PagingToken map[string]string
}

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 {
	NewDocumentService() (DocumentService, 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 UnimplementedDocumentPlugin struct {
	DocumentService
}

type UnimplementedEventingPlugin struct {
	EventService
}

type UnimplementedGatewayPlugin struct {
	GatewayService
}

type UnimplementedQueuePlugin struct {
	QueueService
}

type UnimplementedServiceFactory struct {
}

type UnimplementedStoragePlugin struct{}