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 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(context.Context, ResourceEventModel) error
	TrackResourceEvents(context.Context, []ResourceEventModel) error
	ListResourceEvents(context.Context, ListResourceEventParams) ([]ResourceEventModel, string, error)
	TrackAccessEvent(context.Context, AccessEventModel) error
	TrackAccessEvents(context.Context, []AccessEventModel) error
	ListAccessEvents(context.Context, ListAccessEventParams) ([]AccessEventModel, string, error)
}

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

type LastIdSpec struct {
	ID        string    `json:"id"`
	CreatedAt time.Time `json:"createdAt"`
}

type ListAccessEventParams struct {
	Type            string
	Source          string
	ObjectType      string
	ObjectId        string
	Relation        string
	SubjectType     string
	SubjectId       string
	SubjectRelation string
	LastId          string
	Since           time.Time
	Until           time.Time
	Limit           int64
}

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

type ListResourceEventParams struct {
	Type         string
	Source       string
	ResourceType string
	ResourceId   string
	LastId       string
	Since        time.Time
	Until        time.Time
	Limit        int64
}

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 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, listParams ListResourceEventParams) ([]ResourceEventSpec, string, 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, listParams ListAccessEventParams) ([]AccessEventSpec, string, error)
}