pkg/database/client.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"embed"
 	"fmt"
+	"time"
 
 	"git.anthrove.art/Anthrove/otter-space-sdk/v4/internal/utils"
 	otterError "git.anthrove.art/Anthrove/otter-space-sdk/v4/pkg/error"
@@ -65,6 +66,9 @@ func Connect(ctx context.Context, config models.DatabaseConfig) error {
 	dsn := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%d sslmode=%s TimeZone=%s", config.Endpoint, config.Username, config.Password, config.Database, config.Port, localSSL, config.Timezone)
 	sqlDB, err := gorm.Open(postgres.Open(dsn), &gorm.Config{
 		TranslateError: true,
+		NowFunc: func() time.Time {
+			return time.Now().UTC()
+		},
 	})
 	if err != nil {
 		return utils.HandleError(ctx, span, localLogger, err)

pkg/database/migrations/001_inital_database.sql

@@ -91,7 +91,7 @@ CREATE TABLE "UserSource"
     scrape_time_interval   TEXT,
     account_username       TEXT,
     account_id             TEXT,
-    last_scrape_time       TIMESTAMP WITH TIME ZONE,
+    last_scrape_time       TIMESTAMP,
     account_validate       BOOL DEFAULT FALSE,
     account_validation_key CHAR(25),
     UNIQUE (source_id, account_username, account_id)