utils

package

v1.0.2 Latest Latest Go to latest Published: Jun 18, 2025 License: GPL-3.0 Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var Ctx = context.Background()

View Source

var RedisClient *redis.Client

View Source

var Upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}

func CleanupDownloads(maxSizeMB int64)

func GetRedisClient() *redis.Client

func InitRedis(address, password string, db int)

func KeepWebSocketAlive(ws *websocket.Conn, id string)

func MonitorStatusAndNotify(ws *websocket.Conn, id, initialStatus string, ctx *gin.Context) <-chan struct{}

func ProcessDownload(url, format, id string)

func SetProcessingStatus(id string)

type StatusInfo struct {
	Status                 string
	ShouldStartProcessing  bool
	CurrentStatusForClient string
}

func GetDownloadStatus(id string) StatusInfo

type WebSocketMessage struct {
	Status  string `json:"status"`
	ID      string `json:"id"`
	Message string `json:"message,omitempty"`
}

func CreateWebSocketMessages(status, id string) WebSocketMessage