crud

type Client interface {
	Create(interface{}) (interface{}, error)
	CreateContext(context.Context, interface{}) (interface{}, error)

	Read(string) (interface{}, error)
	ReadContext(context.Context, string) (interface{}, error)

	Update(string, interface{}) (interface{}, error)
	UpdateContext(context.Context, string, interface{}) (interface{}, error)

	Delete(string) (interface{}, error)
	DeleteContext(context.Context, string) (interface{}, error)

	List(query.Query) (*query.QueryResult, error)
	ListContext(context.Context, query.Query) (*query.QueryResult, error)
}

type CreateCommand struct {
	Entity interface{}
}

type CreateFunc func(leikari.ActorContext, interface{}) (string, interface{}, error)

type CreateHandler interface {
	Create(leikari.ActorContext, CreateCommand) (*CreatedEvent, error)
}

type CreateRouteHandler interface {
	HandleCreate(CrudRef) func(route.Request) route.Response
}

type CreatedEvent struct {
	Id        string      `json:"id"`
	Entity    interface{} `json:"entity"`
	Timestamp time.Time   `json:"timestamp,omitempty"`
	Took      int64       `json:"millis,omitempty"`
}

type Crud interface {
	CreateHandler
	ReadHandler
	UpdateHandler
	DeleteHandler
	repository.QueryHandler
}

type CrudEncoding interface {
}

type CrudHandler struct {
	OnCreate    CreateFunc
	OnRead      ReadFunc
	OnUpdate    UpdateFunc
	OnDelete    DeleteFunc
	OnQuery     QueryFunc
	OnReceive   func(leikari.ActorContext, leikari.Message)
	OnStart     func(leikari.ActorContext) error
	OnStop      func(leikari.ActorContext) error
	OnUnmarshal func([]byte) (interface{}, error)
	Sync        bool
}

type CrudRef interface {
	leikari.Ref
	Create(interface{}) (*CreatedEvent, error)
	CreateContext(context.Context, interface{}) (*CreatedEvent, error)

	Read(string) (*ReadEvent, error)
	ReadContext(context.Context, string) (*ReadEvent, error)

	Update(string, interface{}) (*UpdatedEvent, error)
	UpdateContext(context.Context, string, interface{}) (*UpdatedEvent, error)

	Delete(string) (*DeletedEvent, error)
	DeleteContext(context.Context, string) (*DeletedEvent, error)

	List(query.Query) (*query.QueryResult, error)
	ListContext(context.Context, query.Query) (*query.QueryResult, error)
}

type DeleteCommand struct {
	Id string
}

type DeleteFunc func(leikari.ActorContext, string) (interface{}, error)

type DeleteHandler interface {
	Delete(leikari.ActorContext, DeleteCommand) (*DeletedEvent, error)
}

type DeleteRouteHandler interface {
	HandleDelete(CrudRef) func(route.Request) route.Response
}

type DeletedEvent struct {
	Id        string      `json:"id"`
	Entity    interface{} `json:"entity"`
	Timestamp time.Time   `json:"timestamp"`
	Took      int64       `json:"millis,omitempty"`
}

type PostQueryRouteHandler interface {
	HandlePostQuery(CrudRef) func(route.Request) route.Response
}

type QueryFunc func(leikari.ActorContext, query.Query) (*query.QueryResult, error)

type QueryRouteHandler interface {
	HandleQuery(CrudRef) func(route.Request) route.Response
}

type ReadCommand struct {
	Id string
}

type ReadEvent struct {
	Id        string      `json:"id"`
	Entity    interface{} `json:"entity"`
	Timestamp time.Time   `json:"timestamp,omitempty"`
	Took      int64       `json:"millis,omitempty"`
}

type ReadFunc func(leikari.ActorContext, string) (interface{}, error)

type ReadHandler interface {
	Read(leikari.ActorContext, ReadCommand) (*ReadEvent, error)
}

type ReadRouteHandler interface {
	HandleRead(CrudRef) func(route.Request) route.Response
}

type UnmarshalHandler interface {
	HandleUnmarshal([]byte) (interface{}, error)
}

type UpdateCommand struct {
	Id     string
	Entity interface{}
}

type UpdateFunc func(leikari.ActorContext, string, interface{}) error

type UpdateHandler interface {
	Update(leikari.ActorContext, UpdateCommand) (*UpdatedEvent, error)
}

type UpdateRouteHandler interface {
	HandleUpdate(CrudRef) func(route.Request) route.Response
}

type UpdatedEvent struct {
	Id        string      `json:"id"`
	Entity    interface{} `json:"entity"`
	Timestamp time.Time   `json:"timestamp,omitempty"`
	Took      int64       `json:"millis,omitempty"`
}