sys

type ArticleActions struct {
	*action.ListAction[*entity.Article, any]
	*action.TakeAction[*entity.Article, any]
	*action.UpdateAction[*UpdateArticleDTO, *entity.Article]
	*action.DeleteAction[*entity.Article]
}

type AuthActions struct {
	AuthService AuthService
	// contains filtered or unexported fields
}

type AuthDTO struct {
	ClientID string `json:"client_id,omitempty" validate:"required,uuid4"`
}

type AuthService interface {
	SignInByCredentials(ctx context.Context, username, password string) (Session, error)
	SignInByOTP(ctx context.Context, username, password string) (Session, error)
	SignInByRefreshToken(ctx context.Context, refreshToken string) (Session, error)
}

type CreateChatDTO struct {
	TelegramID int64           `json:"telegram_id,omitempty" validate:"required"`
	Type       entity.ChatType `json:"type,omitempty" validate:"required,oneof=private group supergroup channel"`
	Title      string          `json:"title,omitempty" validate:"omitempty,max=254"`
	Username   string          `json:"username,omitempty" validate:"omitempty,max=254"`
	FirstName  string          `json:"first_name,omitempty" validate:"omitempty,max=254"`
	LastName   string          `json:"last_name,omitempty" validate:"omitempty,max=254"`
	Broadcast  []string        `json:"broadcast,omitempty" validate:"omitempty,dive,uuid4"`
	Blocked    bool            `json:"blocked,omitempty"`
	Deleted    bool            `json:"deleted,omitempty"`
}

type CreateJobDTO struct {
	CronExpr string         `json:"cron_expr,omitempty" validate:"required,min=9,max=254"`
	Name     entity.JobName `json:"name,omitempty" validate:"required,max=254"`
	Payload  any            `json:"payload,omitempty" validate:"required,dive"`
	Options  []JobOptionDTO `json:"options,omitempty" validate:"omitempty,dive"`
	Enabled  bool           `json:"enabled,omitempty"`
}

type CreateSiteDTO struct {
	Domain    string   `json:"domain,omitempty" validate:"required,fqdn"`
	Favicon   string   `json:"favicon,omitempty" validate:"required,url"`
	Languages []string `json:"languages,omitempty" validate:"required,min=1,dive,bcp47_language_tag"`
	Title     string   `json:"title,omitempty" validate:"required,max=254"`
	Enabled   bool     `json:"enabled,omitempty"`
}

type DailyStats struct {
	Queue     string `json:"queue"`
	Processed int    `json:"processed"`
	Succeeded int    `json:"succeeded"`
	Failed    int    `json:"failed"`
	Date      string `json:"date"`
}

type FeedPayloadDTO struct {
	SiteID string `json:"site_id,omitempty" validate:"required,uuid4"`
	Link   string `json:"link,omitempty" validate:"required,url"`
}

type JobOptionDTO struct {
	Type  entity.JobOptionType `json:"type,omitempty" validate:"required,max=50"`
	Value string               `json:"value,omitempty" validate:"required"`
}

type MediaDTO struct {
	URL  string           `json:"url,omitempty" validate:"required,url"`
	Type entity.MediaType `json:"type,omitempty" validate:"required,max=10"`
	Meta map[string]any   `json:"meta,omitempty"`
}

type OtpDTO struct {
	Password string `json:"password,omitempty" validate:"required,numeric,len=6"`
}

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

type QueueInfo struct {
	// Name of the queue.
	Queue string `json:"queue"`
	// Total number of bytes the queue and its tasks require to be stored in redis.
	MemoryUsage int64 `json:"memory_usage_bytes"`
	// Total number of tasks in the queue.
	Size int `json:"size"`
	// Totoal number of groups in the queue.
	Groups int `json:"groups"`
	// Latency of the queue in milliseconds.
	LatencyMillisec int64 `json:"latency_msec"`
	// Latency duration string for display purpose.
	DisplayLatency string `json:"display_latency"`

	// Number of tasks in each state.
	Active      int `json:"active"`
	Pending     int `json:"pending"`
	Aggregating int `json:"aggregating"`
	Scheduled   int `json:"scheduled"`
	Retry       int `json:"retry"`
	Archived    int `json:"archived"`
	Completed   int `json:"completed"`

	// Total number of tasks processed during the given date.
	// The number includes both succeeded and failed tasks.
	Processed int `json:"processed"`
	// Breakdown of processed tasks.
	Succeeded int `json:"succeeded"`
	Failed    int `json:"failed"`
	// Paused indicates whether the queue is paused.
	// If true, tasks in the queue will not be processed.
	Paused bool `json:"paused"`
	// Time when this snapshot was taken.
	Timestamp time.Time `json:"timestamp"`
}

type RefreshTokenDTO struct {
	RefreshToken string `json:"refresh_token" validate:"required,uuid4"`
}

type SSE struct {
	*sse.Event
	// contains filtered or unexported fields
}

type SchedulerEntry struct {
	ID            string          `json:"id"`
	Spec          string          `json:"spec"`
	JobName       string          `json:"job_name"`
	JobPayload    json.RawMessage `json:"job_payload"`
	Opts          []string        `json:"options"`
	NextEnqueueAt time.Time       `json:"next_enqueue_at"`
	// This field is omitted if there were no previous enqueue events.
	PrevEnqueueAt *time.Time `json:"prev_enqueue_at,omitempty"`
}

type Session struct {
	AccessToken  string `json:"access_token"`
	RefreshToken string `json:"refresh_token"`
}

type SignInDTO struct {
	Username string `json:"username,omitempty" validate:"required,min=3,max=254"`
	Password string `json:"password,omitempty" validate:"required,min=8,max=64"`
}

type SitemapPayloadDTO struct {
	SiteID     string  `json:"site_id,omitempty" validate:"required,uuid4"`
	Link       string  `json:"link,omitempty" validate:"required,url"`
	Lang       *string `json:"lang,omitempty" validate:"omitempty,bcp47_language_tag"`
	MatchLoc   *string `json:"match_loc,omitempty" validate:"omitempty,max=500"`
	SearchLoc  *string `json:"search_loc,omitempty" validate:"omitempty,max=500"`
	SearchLink *string `json:"search_link,omitempty" validate:"omitempty,max=500"`
	Index      *bool   `json:"index,omitempty"`
	StopOnDup  *bool   `json:"stop_on_dup,omitempty"`
}

type StatsResponse struct {
	Queues           []*QueueInfo             `json:"queues,omitempty"`
	DailyStats       map[string][]*DailyStats `json:"daily_stats,omitempty"`
	SchedulerEntries []*SchedulerEntry        `json:"scheduler_entries,omitempty"`
}

type Sys struct {
	Logger         *slog.Logger
	CfgJWT         *jwt.Config
	SSE            *SSE
	AuthActions    *AuthActions
	QueueActions   *QueueActions
	ArticleActions *ArticleActions
	SiteCRUD       action.CRUD
	ChatCRUD       action.CRUD
	JobCRUD        action.CRUD
	DirUI          string
}

type UpdateArticleDTO struct {
	Lang  string      `json:"lang,omitempty" validate:"omitempty,bcp47_language_tag"`
	Title string      `json:"title,omitempty" validate:"omitempty,max=254"`
	Desc  *string     `json:"desc,omitempty" validate:"omitempty,max=500"`
	Media *[]MediaDTO `json:"media,omitempty" validate:"omitempty,dive"`
}

type UpdateChatDTO struct {
	Broadcast *[]string `json:"broadcast,omitempty" validate:"omitempty,dive,uuid4"`
	Blocked   *bool     `json:"blocked,omitempty"`
}

type UpdateJobDTO struct {
	CronExpr string          `json:"cron_expr,omitempty" validate:"omitempty,min=9,max=254"`
	Name     entity.JobName  `json:"name,omitempty" validate:"omitempty,max=254"`
	Payload  any             `json:"payload,omitempty" validate:"omitempty,dive"`
	Options  *[]JobOptionDTO `json:"options,omitempty" validate:"omitempty,dive"`
	Enabled  *bool           `json:"enabled,omitempty"`
}

type UpdateSiteDTO struct {
	Domain    string   `json:"domain,omitempty" validate:"omitempty,fqdn"`
	Favicon   string   `json:"favicon,omitempty" validate:"required,url"`
	Languages []string `json:"languages,omitempty" validate:"omitempty,dive,bcp47_language_tag"`
	Title     string   `json:"title,omitempty" validate:"omitempty,max=254"`
	Enabled   *bool    `json:"enabled,omitempty"`
}

type UserClaims struct {
	jwt.UserClaims
}