feat: repurpose metadata parser as article transcoder for saya.uz andmain

telegram

1 files changed, 55 insertions, 9 deletions

diff --git a/config/config.go b/config/config.go
index 543413f..64d2e76 100644
--- a/config/config.go
+++ b/config/config.go
@@ -10,17 +10,63 @@ import (
 )
 
 type Config struct {
-	LogLevel          slog.Level      `json:"LogLevel" validate:"required"`
-	MaxConcurrentJobs int             `json:"MaxConcurrentJobs" validate:"required,min=1"`
-	DraftMode         DraftModeConfig `json:"DraftMode"`
-	Storage           StorageConfig   `json:"Storage" validate:"required"`
+	LogLevel          slog.Level         `json:"LogLevel" validate:"required"`
+	MaxConcurrentJobs int                `json:"MaxConcurrentJobs" validate:"required,min=1"`
+	DraftDir          string             `json:"DraftDir" validate:"required"`
+	DraftSuffix       string             `json:"DraftSuffix" validate:"required"`
+	Transcoders       []TranscoderConfig `json:"Transcoders" validate:"required,min=1,dive"`
 }
 
-type DraftModeConfig struct {
-	Enabled      bool   `json:"Enabled" validate:"required"`
-	DraftSuffix  string `json:"DraftSuffix" validate:"required_if=Enabled true"`
-	ProdSuffix   string `json:"ProdSuffix" validate:"required_if=Enabled true"`
-	UpdateAlways bool   `json:"UpdateAlways"`
+type TranscoderConfig struct {
+	Type   string `json:"Type" validate:"required,oneof=sayauz telegram"`
+	Config any    `json:"Config" validate:"required"`
+}
+
+func (tc *TranscoderConfig) UnmarshalJSON(data []byte) error {
+	var tmp struct {
+		Type   string          `json:"Type"`
+		Config json.RawMessage `json:"Config"`
+	}
+
+	if err := json.Unmarshal(data, &tmp); err != nil {
+		return err
+	}
+
+	tc.Type = tmp.Type
+
+	switch tmp.Type {
+	case "sayauz":
+		var sayauzConfig SayauzConfig
+		if err := json.Unmarshal(tmp.Config, &sayauzConfig); err != nil {
+			return fmt.Errorf("unmarshal SayauzConfig: %w", err)
+		}
+		tc.Config = &sayauzConfig
+	case "telegram":
+		var telegramConfig TelegramConfig
+		if err := json.Unmarshal(tmp.Config, &telegramConfig); err != nil {
+			return fmt.Errorf("unmarshal TelegramConfig: %w", err)
+		}
+		tc.Config = &telegramConfig
+	default:
+		return fmt.Errorf("unsupported transcoder type: %s", tmp.Type)
+	}
+
+	return nil
+}
+
+type SayauzConfig struct {
+	Category string        `json:"Category" validate:"required,min=1"`
+	Storage  StorageConfig `json:"Storage" validate:"required"`
+}
+
+type TelegramConfig struct {
+	BotToken         string `json:"BotToken" validate:"required,min=1"`
+	ChannelID        int    `json:"ChannelID" validate:"required,ne=0"`
+	GroupID          int    `json:"GroupID"`
+	ImageBaseURL     string `json:"ImageBaseURL" validate:"required,min=1"`
+	PreviewBaseURL   string `json:"PreviewBaseURL"`
+	PreviewExtension string `json:"PreviewExtension"`
+	StateDir         string `json:"StateDir" validate:"required,min=1"`
 }
 
 type StorageConfig struct {