same timezone everywhere

internal/api/live_activities.go

@@ -30,7 +30,7 @@ func (a *api) createLiveActivityHandler(w http.ResponseWriter, r *http.Request)
 	}
 
 	la.RefreshToken = rtr.RefreshToken
-	la.TokenExpiresAt = time.Now().Add(1 * time.Hour).UTC()
+	la.TokenExpiresAt = time.Now().Add(1 * time.Hour)
 
 	if err := a.liveActivityRepo.Create(ctx, la); err != nil {
 		a.errorResponse(w, r, 500, err)

internal/cmd/scheduler.go

@@ -149,7 +149,7 @@ func enqueueLiveActivities(ctx context.Context, logger *zap.Logger, pool *pgxpoo
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()
 
-	now := time.Now().UTC()
+	now := time.Now()
 	next := now.Add(domain.LiveActivityCheckInterval)
 
 	stmt := `UPDATE live_activities

internal/repository/postgres_live_activity.go

@@ -87,8 +87,8 @@ func (p *postgresLiveActivityRepository) Create(ctx context.Context, la *domain.
 		la.TokenExpiresAt,
 		la.ThreadID,
 		la.Subreddit,
-		time.Now().UTC(),
-		time.Now().Add(domain.LiveActivityDuration).UTC(),
+		time.Now(),
+		time.Now().Add(domain.LiveActivityDuration),
 	).Scan(&la.ID)
 }
 

internal/worker/live_activities.go

@@ -138,7 +138,7 @@ func (lac *liveActivitiesConsumer) Consume(delivery rmq.Delivery) {
 	ctx, cancel := context.WithCancel(lac)
 	defer cancel()
 
-	now := time.Now().UTC()
+	now := time.Now()
 	defer func() {
 		elapsed := time.Now().Sub(now).Milliseconds()
 		_ = lac.statsd.Histogram("apollo.consumer.runtime", float64(elapsed), []string{"queue:live_activities"}, 0.1)