event

type AccessEvent struct {
	ID              string    `mysql:"id" postgres:"id" sqlite:"id"`
	Type            string    `mysql:"type" postgres:"type" sqlite:"type"`
	Source          string    `mysql:"source" postgres:"source" sqlite:"source"`
	ObjectType      string    `mysql:"objectType" postgres:"object_type" sqlite:"objectType"`
	ObjectId        string    `mysql:"objectId" postgres:"object_id" sqlite:"objectId"`
	Relation        string    `mysql:"relation" postgres:"relation" sqlite:"relation"`
	SubjectType     string    `mysql:"subjectType" postgres:"subject_type" sqlite:"subjectType"`
	SubjectId       string    `mysql:"subjectId" postgres:"subject_id" sqlite:"subjectId"`
	SubjectRelation string    `mysql:"subjectRelation" postgres:"subject_relation" sqlite:"subjectRelation"`
	Meta            *string   `mysql:"meta" postgres:"meta" sqlite:"meta"`
	CreatedAt       time.Time `mysql:"createdAt" postgres:"created_at" sqlite:"createdAt"`
}

type AccessEventFilterParams struct {
	Type            string
	Source          string
	ObjectType      string
	ObjectId        string
	Relation        string
	SubjectType     string
	SubjectId       string
	SubjectRelation string
	Since           time.Time
	Until           time.Time
}

type AccessEventListParamParser struct{}

type AccessEventModel interface {
	GetID() string
	GetType() string
	GetSource() string
	GetObjectType() string
	GetObjectId() string
	GetRelation() string
	GetSubjectType() string
	GetSubjectId() string
	GetSubjectRelation() string
	GetMeta() *string
	GetCreatedAt() time.Time
	ToAccessEventSpec() (*AccessEventSpec, error)
}

type AccessEventSpec struct {
	ID              string      `json:"id"`
	Type            string      `json:"type"`
	Source          string      `json:"source"`
	ObjectType      string      `json:"objectType"`
	ObjectId        string      `json:"objectId"`
	Relation        string      `json:"relation"`
	SubjectType     string      `json:"subjectType"`
	SubjectId       string      `json:"subjectId"`
	SubjectRelation string      `json:"subjectRelation,omitempty"`
	Meta            interface{} `json:"meta,omitempty"`
	CreatedAt       time.Time   `json:"createdAt"`
}

type CreateAccessEventSpec struct {
	Type            string      `json:"type"`
	Source          string      `json:"source"`
	ObjectType      string      `json:"objectType"`
	ObjectId        string      `json:"objectId"`
	Relation        string      `json:"relation"`
	SubjectType     string      `json:"subjectType"`
	SubjectId       string      `json:"subjectId"`
	SubjectRelation string      `json:"subjectRelation"`
	Meta            interface{} `json:"meta"`
}

type CreateResourceEventSpec struct {
	Type         string      `json:"type"`
	Source       string      `json:"source"`
	ResourceType string      `json:"resourceType"`
	ResourceId   string      `json:"resourceId"`
	Meta         interface{} `json:"meta"`
}

type EventContextFunc func(ctx context.Context, synchronizeEvents bool) (context.Context, error)

type EventRepository interface {
	TrackResourceEvent(ctx context.Context, resourceEvent ResourceEventModel) error
	TrackResourceEvents(ctx context.Context, resourceEvents []ResourceEventModel) error
	ListResourceEvents(ctx context.Context, filterParams ResourceEventFilterParams, listParams service.ListParams) ([]ResourceEventModel, *service.Cursor, *service.Cursor, error)
	TrackAccessEvent(ctx context.Context, accessEvent AccessEventModel) error
	TrackAccessEvents(ctx context.Context, accessEvents []AccessEventModel) error
	ListAccessEvents(ctx context.Context, filterParams AccessEventFilterParams, listParams service.ListParams) ([]AccessEventModel, *service.Cursor, *service.Cursor, error)
}

type EventService struct {
	service.BaseService
	Repository         EventRepository
	SynchronizeEvents  bool
	CreateEventContext EventContextFunc
}

type ListEventsSpecV1[T ResourceEventSpec | AccessEventSpec] struct {
	Events []T    `json:"events"`
	LastId string `json:"lastId,omitempty"`
}

type ListEventsSpecV2[T ResourceEventSpec | AccessEventSpec] struct {
	Results    []T             `json:"results"`
	PrevCursor *service.Cursor `json:"prevCursor,omitempty"`
	NextCursor *service.Cursor `json:"nextCursor,omitempty"`
}

type MySQLRepository struct {
	database.SQLRepository
}

type PostgresRepository struct {
	database.SQLRepository
}

type ResourceEvent struct {
	ID           string    `mysql:"id" postgres:"id" sqlite:"id"`
	Type         string    `mysql:"type" postgres:"type" sqlite:"type"`
	Source       string    `mysql:"source" postgres:"source" sqlite:"source"`
	ResourceType string    `mysql:"resourceType" postgres:"resource_type" sqlite:"resourceType"`
	ResourceId   string    `mysql:"resourceId" postgres:"resource_id" sqlite:"resourceId"`
	Meta         *string   `mysql:"meta" postgres:"meta" sqlite:"meta"`
	CreatedAt    time.Time `mysql:"createdAt" postgres:"created_at" sqlite:"createdAt"`
}

type ResourceEventFilterParams struct {
	Type         string
	Source       string
	ResourceType string
	ResourceId   string
	Since        time.Time
	Until        time.Time
}

type ResourceEventListParamParser struct{}

type ResourceEventModel interface {
	GetID() string
	GetType() string
	GetSource() string
	GetResourceType() string
	GetResourceId() string
	GetMeta() *string
	GetCreatedAt() time.Time
	ToResourceEventSpec() (*ResourceEventSpec, error)
}

type ResourceEventSpec struct {
	ID           string      `json:"id"`
	Type         string      `json:"type"`
	Source       string      `json:"source"`
	ResourceType string      `json:"resourceType"`
	ResourceId   string      `json:"resourceId"`
	Meta         interface{} `json:"meta,omitempty"`
	CreatedAt    time.Time   `json:"createdAt"`
}

type SQLiteRepository struct {
	database.SQLRepository
}

type Service interface {
	TrackResourceCreated(ctx context.Context, resourceType string, resourceId string, meta interface{}) error
	TrackResourceUpdated(ctx context.Context, resourceType string, resourceId string, meta interface{}) error
	TrackResourceDeleted(ctx context.Context, resourceType string, resourceId string, meta interface{}) error
	TrackResourceEvent(ctx context.Context, resourceEventSpec CreateResourceEventSpec) error
	TrackResourceEvents(ctx context.Context, resourceEventSpecs []CreateResourceEventSpec) error
	ListResourceEvents(ctx context.Context, filterParams ResourceEventFilterParams, listParams service.ListParams) ([]ResourceEventSpec, *service.Cursor, *service.Cursor, error)
	TrackAccessGrantedEvent(ctx context.Context, objectType string, objectId string, relation string, subjectType string, subjectId string, subjectRelation string, meta interface{}) error
	TrackAccessRevokedEvent(ctx context.Context, objectType string, objectId string, relation string, subjectType string, subjectId string, subjectRelation string, meta interface{}) error
	TrackAccessAllowedEvent(ctx context.Context, objectType string, objectId string, relation string, subjectType string, subjectId string, subjectRelation string, meta interface{}) error
	TrackAccessDeniedEvent(ctx context.Context, objectType string, objectId string, relation string, subjectType string, subjectId string, subjectRelation string, meta interface{}) error
	TrackAccessEvent(ctx context.Context, accessEventSpec CreateAccessEventSpec) error
	TrackAccessEvents(ctx context.Context, accessEventSpecs []CreateAccessEventSpec) error
	ListAccessEvents(ctx context.Context, filterParams AccessEventFilterParams, listParams service.ListParams) ([]AccessEventSpec, *service.Cursor, *service.Cursor, error)
}