datastore

type AfterGetInterceptor[T any] interface {
	AfterGet(ctx context.Context, dt *Datatype[T], item *T) (*T, error)
}

type AfterSaveInterceptor[T any] interface {
	AfterSave(ctx context.Context, dt *Datatype[T], item *T) (*T, error)
}

type BeforeGetInterceptor[T any] interface {
	BeforeGet(ctx context.Context, dt *Datatype[T], ID string) (string, error)
}

type BeforeSaveInterceptor[T any] interface {
	BeforeSave(ctx context.Context, dt *Datatype[T], item *T) (*T, error)
}

type BinaryDataStore interface {
	Open(ctx context.Context, config interface{}) error
	Close(ctx context.Context) error

	Save(ctx context.Context, data []byte, key string) error
	SaveStream(ctx context.Context, data io.ReadCloser, key string) (int64, error)
	Get(ctx context.Context, key string) ([]byte, error)
	Delete(ctx context.Context, key string) error
	Exists(ctx context.Context, key string) (bool, error)
}

type Datatype[T any] struct {
	Name      string
	Prefix    string
	IDField   string
	GetIDFunc func(dt *Datatype[T], item *T) string
	SetIDFunc func(dt *Datatype[T], item *T, id string) string

	DataStore JsonDataStore[T]
	Indexer   Indexer[T]
	ItemType  interface{}

	BeforeSave []BeforeSaveInterceptor[T]
	AfterSave  []AfterSaveInterceptor[T]
	BeforeGet  []BeforeGetInterceptor[T]
	AfterGet   []AfterGetInterceptor[T]
	// contains filtered or unexported fields
}

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

type FilesystemStore struct {
	Dir   string
	Ext   string
	Perms os.FileMode
}

type FilesystemStoreConfig struct {
	Dir   string
	Ext   string
	Perms os.FileMode
}

type FilesystemStoreFactory struct{}

type Filetype struct {
}

type IdGenerator[T any] struct{}

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

type InMemoryStoreFactory struct{}

type Indexer[T any] interface {
	Open(ctx context.Context, config interface{}) error
	Close(ctx context.Context) error

	Index(ctx context.Context, id string, data []byte) error
	Remove(ctx context.Context, id string) error
	Search(ctx context.Context, query interface{}) ([]T, error)
}

type JsonDataStore[T any] interface {

	// Open will open the datastore for usage. This should
	// only be done once per datastore
	Open(ctx context.Context, config interface{}) error

	// Close should be called to cleannly close the datastore
	Close(ctx context.Context) error

	// Save stores an item in the datastore. There is no difference
	// between an insert and an update.
	Save(ctx context.Context, item *T, key string) error

	// Get retrieves an item by it's unique id
	Get(ctx context.Context, key string) (*T, error)

	// Gets all the items in the store.
	GetAll(ctx context.Context) ([]*T, error)

	// Deletes an item
	Delete(ctx context.Context, key string) error

	// Checks to see if a key exists
	Exists(ctx context.Context, key string) (bool, error)

	// Sends a simple Query
	Query(ctx context.Context, query *SimpleQuery) ([]*T, error)
}

type JsonDataStoreAdapter[T any] struct {
	DS    BinaryDataStore
	Model T
}

type JsonDataStoreFactory interface {
	Create(cfg interface{}) (UntypedJsonDataStore, error)
	ToConfig(cfgMap map[string]interface{}) (interface{}, error)
}

type LoadInput struct {
	Ctx  context.Context
	Id   string
	User string
}

type LoadOutput struct {
	Ctx  context.Context
	Id   string
	User string
	Item interface{}
}

type NativeQuerable[T any] interface {
	NativeQuery(ctx context.Context, query interface{}) (interface{}, error)
}

type SimpleQuery struct {
	Size       int
	Offset     int
	Colums     []string
	Conditions *SimpleQueryConditionGroup
	SortBy     []*SortBy
}

type SimpleQueryCondition struct {
	Type    string
	Data    []string
	DataMap map[string]interface{}
}

type SimpleQueryConditionGroup struct {
	Operator   string //and, or, no
	Conditions []*SimpleQueryCondition
	Groups     []*SimpleQueryConditionGroup
}

type SortBy struct {
	Field      string
	Descending bool
}

type TestItem struct {
	ID   string
	Name string
}

type TestQueryItem struct {
	ID     string
	Name   string
	Val1   int
	Val2   int
	Date1  time.Time
	Date2  time.Time
	StrArr []string
	ObjArr []*TestQueryItemChild
}

type TestQueryItemChild struct {
	Name string
}

type TypedJsonStore[T any] struct {
	// contains filtered or unexported fields
}

type UntypedJsonDataStore interface {

	// Open will open the datastore for usage. This should
	// only be done once per datastore
	Open(ctx context.Context, config interface{}) error

	// Close should be called to cleannly close the datastore
	Close(ctx context.Context) error

	// Save stores an item in the datastore. There is no difference
	// between an insert and an update.
	Save(ctx context.Context, item interface{}, key string) error

	// Get retrieves an item by it's unique id
	Get(ctx context.Context, key string) (interface{}, error)

	// Gets all the items in the store.
	GetAll(ctx context.Context) ([]interface{}, error)

	// Deletes an item
	Delete(ctx context.Context, key string) error

	// Checks to see if a key exists
	Exists(ctx context.Context, key string) (bool, error)

	// Sends a simple Query
	Query(ctx context.Context, query *SimpleQuery) ([]interface{}, error)
}