bytengine

type Authentication interface {
	Start(config string) error
	ClearAll() error
	Authenticate(usr, pw string) bool
	NewUser(usr, pw string, root bool) error
	ChangeUserPassword(usr, pw string) error
	ChangeUserStatus(usr string, isactive bool) error
	ListUser(rgx string) ([]string, error)
	ChangeUserDbAccess(usr, db string, grant bool) error
	HasDbAccess(usr, db string) bool
	RemoveUser(usr string) error
	UserInfo(u string) (*User, error)
}

type ByteStore interface {
	Start(config string) error
	Add(db string, file *os.File) (map[string]interface{}, error)
	Update(db, id string, file *os.File) (map[string]interface{}, error)
	Delete(db, id string) error
	Read(db, filename string, file io.Writer) error
	DropDatabase(db string) error
}

type Command struct {
	Name     string
	Database string
	Args     map[string]interface{}
	Options  map[string]interface{}
	Filter   string // name of filter to apply to result
	IsAdmin  bool   // is it an admin command
}

type CommandHandler func(cmd Command, user *User, eng *Engine) (interface{}, error)

type Config struct {
	Authentication struct{ Plugin string }
	ByteStore      struct{ Plugin string }
	FileSystem     struct{ Plugin string }
	StateStore     struct{ Plugin string }
	DataFilter     struct{ Plugin string }
	Parser         struct{ Plugin string }
}

type ConfigData struct {
	Authentication json.RawMessage
	ByteStore      json.RawMessage
	FileSystem     json.RawMessage
	StateStore     json.RawMessage
	DataFilter     json.RawMessage
	Parser         json.RawMessage
}

type DataFilter func(r interface{}, eng *Engine) (interface{}, error)

type Engine struct {
	Authentication Authentication
	FileSystem     FileSystem
	ByteStore      ByteStore
	StateStore     StateStore
	Parser         Parser
}

type FileSystem interface {
	Start(config string, b *ByteStore) error
	ClearAll() ([]string, error)
	ListDatabase(filter string) ([]string, error)
	CreateDatabase(db string) error
	DropDatabase(db string) error
	NewDir(p, db string) error
	NewFile(p, db string, jsondata map[string]interface{}) error
	ListDir(p, filter, db string) (map[string][]string, error)
	ReadJson(p, db string, fields []string) (interface{}, error)
	Delete(p, db string) error
	Rename(p, newname, db string) error
	Move(from, to, db string) error
	Copy(from, to, db string) error
	Info(p, db string) (map[string]interface{}, error)
	FileAccess(p, db string, protect bool) error
	SetCounter(counter, action string, value int64, db string) (int64, error)
	ListCounter(filter, db string) (map[string]int64, error)
	WriteBytes(p, ap, db string) (int64, error)
	ReadBytes(fp, db string) (string, error)
	DirectAccess(fp, db, layer string) (map[string]interface{}, string, error)
	DeleteBytes(p, db string) error
	UpdateJson(p, db string, j map[string]interface{}) error
	BQLSearch(db string, query map[string]interface{}) (interface{}, error)
	BQLSet(db string, query map[string]interface{}) (int, error)
	BQLUnset(db string, query map[string]interface{}) (int, error)
}

type Parser interface {
	Parse(s string) (c []Command, err error)
}

type StateStore interface {
	TokenSet(token, user string, timeout int64) error
	TokenGet(token string) (string, error)
	CacheSet(id, value string, timeout int64) error
	CacheGet(id string) (string, error)
	ClearAll() error
	Start(config string) error
}

type User struct {
	Username  string   `json:"username"`
	Active    bool     `json:"active"`
	Databases []string `json:"databases"`
	Root      bool     `json:"root"`
}