gocqrs

type APPDocs struct {
	Name      string              `json:"name"`
	Version   string              `json:"version"`
	Entities  map[string][]string `json:"entities"`
	Endpoints []Endpoint          `json:"endpoints"`
}

type Aggregator interface {
	Aggregate(id string, entity interface{})
}

type App struct {
	Version string `json:"version"`
	Name    string `json:"name"`
	Port    string `json:"port"`

	// main log stream
	MainLog string `json:"mlog"`

	// Documentations
	BaseURL   string     `json:"baseURL"`
	Endpoints []Endpoint `json:"endpoints"`

	// user roles for auth
	Roles map[string]Role `json:"roles"`

	Entities map[string]*EntityConf `json:"entities"`
	Store    EventStore             `json:"-"`

	// Gin router
	Router *gin.Engine

	// turn off auth service check
	FirstRun        bool   `json:"firtRun"`
	AuthOff         bool   `json:"authOff"`
	Secret          string `json:"-"`
	SessionValidity string `json:"sessionValidity"`

	Domain        string   `json:"sessionDomain"`
	LoginReferers []string `json:"loginReferers"`
	// contains filtered or unexported fields
}

type BaseEvent struct {
	EventID        string    `json:"eid"`
	EventTimestamp time.Time `json:"timestamp"`
	EventStream    string    `json:"stream,omitempty"`
	EventType      string    `json:"type"`
	EventVersion   uint64    `json:"version"`
}

type BasicEntity struct {
	AccountID string    `json:"accID"`
	CreatedBy string    `json:"createBy"`
	Created   time.Time `json:"created,omitempty"`

	UpdatedBy string    `json:"createBy"`
	Updated   time.Time `json:"updated,omitempty"`
}

type CRUDHandler struct {
	EntityName   string `json:"entityName"`
	CheckVersion bool   `json:"checkVersion"`
}

type Endpoint struct {
	Path        string `json:"path"`
	Method      string `json:"method"`
	Description string `json:"description,omitempty"`
	ExampleBody string `json:"exampleBody,omitempty"`
}

type Entity struct {
	ID      string                 `json:"id"`
	Group   string                 `json:"group"`
	Version uint64                 `json:"version"`
	Deleted bool                   `json:"deleted"`
	Data    map[string]interface{} `json:"data"`
}

type EntityConf struct {
	Name string `json:"name"`

	CRUD bool `json:"crud"`

	Description string `json:"desc"`
	// basic entity prefix
	StreamPrefix      string `json:"stream_prefix"`
	CorrelationStream string `json:"correlation_stream"`

	// Entity ID references
	EntityReferences []EntityReference `json:"references"`

	// Event Handlers/Aggregators
	EventHandlers map[string]EventHandler `json:"handlers"`

	Validators map[string]Validator `json:"validators"`
	BaseStruct interface{}          `json:"base,omitempty"`
	BaseSeted  bool

	ReadRoles []string `json:"roles,omitempty"`
}

type EntityProperty struct {
	Name        string
	Validations []func(interface{}) error
}

type EntityReference struct {
	Entity string `json:"entity"`
	Key    string `json:"key"`
	Null   bool   `json:"null"`
}

type Event struct {
	BaseEvent
	Group             string                 `json:"group,omitempty"`
	Entity            string                 `json:"ent,omitepty"`
	CorrelationStream string                 `json:"cid,omitempty"`
	EntityID          string                 `json:"id,omitempty"`
	StreamPrefix      string                 `json:"streamPre,omitempty"`
	EventData         map[string]interface{} `json:"data,omitempty"`
}

type EventHandler interface {
	EventName() []string
	Handle(id, accid, userid, role string, e Eventer, entity *Entity, replay bool) (StoreOptions, error)
	CheckBase(e Eventer) bool
}

type EventStore interface {
	Store(e Eventer, opt StoreOptions) (uint64, error)
	Range(streamid string) (chan Eventer, uint64)
	Version(streamid string) (uint64, error)
	Scan(streamid string, from, to uint64) chan Event
}

type Eventer interface {
	GetId() string
	GetStream() string
	GetVersion() uint64
	GetType() string
	GetData() map[string]interface{}
	SetData(k string, i interface{})
	ClearData()
	GetLinks() []string
	Has(string) bool
}

type Group struct {
	BasicEntity
	ID   string            `json:"id"`
	Data map[string]string `json:"data"`
}

type Reader interface {
	Sync(entity, id string) error
}

type Role struct {
	Name string `json:"name"`

	// Access to entities
	Entities []string
	// events and read cmd that can be executed ,default ALL
	Allowed []string `json:"allowed"`

	NotAllowed []string `json:"noAllowed"`
}

type SessionClaims struct {
	Username string `json:"use"`
	Role     string `json:"rol"`
	jwt.StandardClaims
}

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

type StoreOptions struct {
	LockVersion uint64 `json:"lockversion"`
	Retry       bool   `json:"retry"`
	Create      bool   `json:"create"`
}

type User struct {
	Username string    `json:"username"`
	Password string    `json:"password"`
	Role     string    `json:"role"`
	Created  time.Time `json:"created`

	AccountID string `json:"accid"`

	ActiveToken bool   `json:"activeToken"`
	Token       string `json:"token"`

	Groups []string               `json:"groups"`
	Data   map[string]interface{} `json:"data"`
}

type UserEventHandler struct {
}

type Validator interface {
	GetName() string
	Validate(e Entity) error
}

type View struct {
	Name string `json:"view"`

	All     bool `json:"all"`
	CatchUp bool `json:"catchup"`

	V     Viewer
	Store EventStore
	// contains filtered or unexported fields
}

type Viewer interface {
	Init(params map[string]string, dev bool)
	Purge() error
	Status() (uint64, error)
	Stream() string
	Rebuild() error
	Apply(event Event) error
}