Delete archive if stream is ended but Twitch API is slow to update

.devcontainer/Dockerfile

@@ -13,7 +13,7 @@ WORKDIR /tmp
 
 RUN wget https://github.com/rsms/inter/releases/download/v4.0-beta7/Inter-4.0-beta7.zip && unzip Inter-4.0-beta7.zip && mkdir -p /usr/share/fonts/opentype/inter/ && cp /tmp/Desktop/Inter-*.otf /usr/share/fonts/opentype/inter/ && fc-cache -f -v
 
-RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.0/TwitchDownloaderCLI-1.54.0-Linux-x64.zip && unzip TwitchDownloaderCLI-1.54.0-Linux-x64.zip && mv TwitchDownloaderCLI /usr/local/bin/ && chmod +x /usr/local/bin/TwitchDownloaderCLI && rm TwitchDownloaderCLI-1.54.0-Linux-x64.zip
+RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.1/TwitchDownloaderCLI-1.54.1-Linux-x64.zip && unzip TwitchDownloaderCLI-1.54.1-Linux-x64.zip && mv TwitchDownloaderCLI /usr/local/bin/ && chmod +x /usr/local/bin/TwitchDownloaderCLI && rm TwitchDownloaderCLI-1.54.1-Linux-x64.zip
 
 #RUN wget https://github.com/xenova/chat-downloader/archive/refs/tags/v${CHAT_DOWNLOADER_VER}.tar.gz
 #RUN tar -xvf v${CHAT_DOWNLOADER_VER}.tar.gz && cd chat-downloader-${CHAT_DOWNLOADER_VER} && python3 setup.py install && cd .. && rm -f v${CHAT_DOWNLOADER_VER}.tar.gz && rm -rf chat-downloader-${CHAT_DOWNLOADER_VER}

.gitignore

@@ -26,3 +26,4 @@ go.work
 dev
 tmp
 **/__debug
+__debug*

Dockerfile

@@ -12,7 +12,7 @@ FROM debian:bookworm-slim AS build-stage-02
 RUN apt update && apt install -y git wget unzip
 
 WORKDIR /tmp
-RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.0/TwitchDownloaderCLI-1.54.0-Linux-x64.zip && unzip TwitchDownloaderCLI-1.54.0-Linux-x64.zip 
+RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.1/TwitchDownloaderCLI-1.54.1-Linux-x64.zip && unzip TwitchDownloaderCLI-1.54.1-Linux-x64.zip 
 
 RUN git clone https://github.com/xenova/chat-downloader.git
 

Dockerfile.aarch64

@@ -14,7 +14,7 @@ RUN apt-get install unzip wget git -y
 
 WORKDIR /tmp
 RUN wget https://github.com/rsms/inter/releases/download/v3.19/Inter-3.19.zip && unzip Inter-3.19.zip
-RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.0/TwitchDownloaderCLI-1.54.0-LinuxArm.zip && unzip TwitchDownloaderCLI-1.54.0-LinuxArm.zip
+RUN wget https://github.com/lay295/TwitchDownloader/releases/download/1.54.1/TwitchDownloaderCLI-1.54.1-LinuxArm.zip && unzip TwitchDownloaderCLI-1.54.1-LinuxArm.zip
 
 RUN git clone https://github.com/xenova/chat-downloader.git
 

cmd/server/main.go

@@ -73,11 +73,6 @@ func Run() error {
 		zerolog.SetGlobalLevel(zerolog.InfoLevel)
 	}
 
-	//store, err := database.NewDatabase()
-	//if err != nil {
-	//	log.Error().Err(err).Msg("failed to create database connection")
-	//	return err
-	//}
 	database.InitializeDatabase(false)
 	store := database.DB()
 

cmd/worker/main.go

@@ -9,6 +9,7 @@ import (
 	"github.com/zibbp/ganymede/internal/activities"
 	serverConfig "github.com/zibbp/ganymede/internal/config"
 	"github.com/zibbp/ganymede/internal/database"
+	"github.com/zibbp/ganymede/internal/temporal"
 	"github.com/zibbp/ganymede/internal/twitch"
 	"github.com/zibbp/ganymede/internal/workflows"
 
@@ -108,7 +109,7 @@ func main() {
 	// this needs to be removed in the future to decouple the worker from the server
 	serverConfig.NewConfig(false)
 
-	logger := zerolog.New(os.Stdout).With().Timestamp().Logger()
+	logger := zerolog.New(os.Stdout).With().Timestamp().Logger().With().Str("service", "worker").Logger()
 
 	clientOptions := client.Options{
 		HostPort: config.TEMPORAL_URL,
@@ -129,6 +130,9 @@ func main() {
 
 	database.InitializeDatabase(true)
 
+	// Initialize the temporal client for the worker
+	temporal.InitializeTemporalClient()
+
 	taskQueues := map[string]int{
 		"archive":        100,
 		"chat-download":  config.MAX_CHAT_DOWNLOAD_EXECUTIONS,