Merging staging to master

chore: release version v0.1.4

Author: ImDoubD-datazip

Dockerfile

@@ -35,7 +35,7 @@ COPY ui/ ./
 RUN pnpm build
 
 # Stage 3: Final Runtime Image
-FROM alpine:latest
+FROM alpine:3.18
 
 # Install docker-cli
 RUN apk update && apk add --no-cache docker-cli

server/internal/handlers/auth.go

@@ -1,6 +1,7 @@
 package handlers
 
 import (
+	"context"
 	"encoding/json"
 	"net/http"
 	"strings"
@@ -52,7 +53,7 @@ func (c *AuthHandler) Login() {
 		_ = c.SetSession(constants.SessionUserID, user.ID)
 	}
 
-	telemetry.TrackUserLogin(c.Ctx.Request.Context(), user)
+	telemetry.TrackUserLogin(context.Background(), user)
 
 	utils.SuccessResponse(&c.Controller, map[string]interface{}{
 		"username": user.Username,

server/internal/handlers/destination.go

@@ -1,6 +1,7 @@
 package handlers
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 	"net/http"
@@ -104,7 +105,7 @@ func (c *DestHandler) CreateDestination() {
 	}
 
 	// Track destination creation event
-	telemetry.TrackDestinationCreation(c.Ctx.Request.Context(), destination)
+	telemetry.TrackDestinationCreation(context.Background(), destination)
 	utils.SuccessResponse(&c.Controller, req)
 }
 
@@ -145,7 +146,7 @@ func (c *DestHandler) UpdateDestination() {
 	}
 
 	// Track destinations status after update
-	telemetry.TrackDestinationsStatus(c.Ctx.Request.Context())
+	telemetry.TrackDestinationsStatus(context.Background())
 
 	utils.SuccessResponse(&c.Controller, req)
 }
@@ -178,7 +179,7 @@ func (c *DestHandler) DeleteDestination() {
 	}
 
 	// Track destinations status after deletion
-	telemetry.TrackDestinationsStatus(c.Ctx.Request.Context())
+	telemetry.TrackDestinationsStatus(context.Background())
 
 	utils.SuccessResponse(&c.Controller, &models.DeleteDestinationResponse{
 		Name: dest.Name,

server/internal/handlers/job.go

@@ -175,7 +175,7 @@ func (c *JobHandler) CreateJob() {
 	}
 
 	// telemetry events
-	telemetry.TrackJobCreation(c.Ctx.Request.Context(), job)
+	telemetry.TrackJobCreation(context.Background(), job)
 
 	if c.tempClient != nil {
 		fmt.Println("Using Temporal workflow for sync job")
@@ -252,7 +252,7 @@ func (c *JobHandler) UpdateJob() {
 	}
 
 	// Track sources and destinations status after job update
-	telemetry.TrackJobEntity(c.Ctx.Request.Context())
+	telemetry.TrackJobEntity(context.Background())
 
 	if c.tempClient != nil {
 		logs.Info("Using Temporal workflow for sync job")
@@ -311,7 +311,7 @@ func (c *JobHandler) DeleteJob() {
 	}
 
 	// Track sources and destinations status after job deletion
-	telemetry.TrackJobEntity(c.Ctx.Request.Context())
+	telemetry.TrackJobEntity(context.Background())
 
 	utils.SuccessResponse(&c.Controller, models.DeleteDestinationResponse{
 		Name: jobName,

server/internal/handlers/source.go

@@ -112,7 +112,7 @@ func (c *SourceHandler) CreateSource() {
 	}
 
 	// Track source creation event
-	telemetry.TrackSourceCreation(c.Ctx.Request.Context(), source)
+	telemetry.TrackSourceCreation(context.Background(), source)
 
 	utils.SuccessResponse(&c.Controller, req)
 }
@@ -151,7 +151,7 @@ func (c *SourceHandler) UpdateSource() {
 	}
 
 	// Track sources status after update
-	telemetry.TrackSourcesStatus(c.Ctx.Request.Context())
+	telemetry.TrackSourcesStatus(context.Background())
 	utils.SuccessResponse(&c.Controller, req)
 }
 
@@ -186,7 +186,7 @@ func (c *SourceHandler) DeleteSource() {
 		return
 	}
 
-	telemetry.TrackSourcesStatus(c.Ctx.Request.Context())
+	telemetry.TrackSourcesStatus(context.Background())
 	utils.SuccessResponse(&c.Controller, &models.DeleteSourceResponse{
 		Name: source.Name,
 	})

server/internal/temporal/activities.go

@@ -64,7 +64,7 @@ func SyncActivity(ctx context.Context, params *SyncParams) (map[string]interface
 		"workflowID", params.WorkflowID)
 
 	// Track sync start event
-	telemetry.TrackSyncStart(ctx, params.JobID, params.WorkflowID)
+	telemetry.TrackSyncStart(context.Background(), params.JobID, params.WorkflowID)
 
 	// Create a Docker runner with the default config directory
 	runner := docker.NewRunner(docker.GetDefaultConfigDir())

worker.Dockerfile

@@ -14,7 +14,7 @@ COPY server/ ./
 RUN go build -o temporal-worker ./cmd/temporal-worker
 
 # Runtime stage
-FROM alpine:latest
+FROM alpine:3.18
 WORKDIR /app
 COPY --from=builder /app/worker/temporal-worker .
 RUN mkdir -p ./conf