Complete code - PR

.gitignore

@@ -1 +1,28 @@
-local.yaml
+local.yaml
+.env
+
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+dist
+dist-ssr
+*.local
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+.DS_Store
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?
+

backend/cmd/main.go

@@ -0,0 +1,152 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log/slog"
+	"net/http"
+	"os"
+
+	"os/signal"
+	"syscall"
+	"time"
+
+	"github.com/joshsoftware/code-curiosity-2025/internal/app"
+	"github.com/joshsoftware/code-curiosity-2025/internal/app/cronJob"
+	"github.com/joshsoftware/code-curiosity-2025/internal/config"
+	"github.com/joshsoftware/code-curiosity-2025/internal/db"
+	"github.com/rs/cors"
+	"github.com/urfave/cli"
+)
+
+func main() {
+	cfg, err := config.LoadAppConfig()
+	if err != nil {
+		slog.Error("error loading app config", "error", err)
+		return
+	}
+
+	cliApp := cli.NewApp()
+	cliApp.Name = cfg.AppName
+	cliApp.Version = "1.0.0"
+	cliApp.Commands = []cli.Command{
+		{
+			Name:  "start",
+			Usage: "Start HTTP server",
+			Action: func(c *cli.Context) error {
+				return startApp(cfg)
+			},
+		},
+		{
+			Name:  "migrate",
+			Usage: "Database migrations",
+			Subcommands: []cli.Command{
+				{
+					Name:  "up",
+					Usage: "Apply migrations",
+					Action: func(c *cli.Context) error {
+						m, _ := db.InitMainDBMigrations(cfg)
+						m.MigrationsUp(c.Args().First())
+						return nil
+					},
+				},
+				{
+					Name:  "down",
+					Usage: "Rollback migrations",
+					Action: func(c *cli.Context) error {
+						m, _ := db.InitMainDBMigrations(cfg)
+						m.MigrationsDown(c.Args().First())
+						return nil
+					},
+				},
+				{
+					Name:  "create",
+					Usage: "Create a new migration file",
+					Action: func(c *cli.Context) error {
+						m, _ := db.InitMainDBMigrations(cfg)
+						return m.CreateMigrationFile(c.Args().First())
+					},
+				},
+			},
+		},
+	}
+
+	if err := cliApp.Run(os.Args); err != nil {
+		panic(err)
+	}
+}
+
+func startApp(cfg config.AppConfig) error {
+	ctx := context.Background()
+
+	slog.Info("Starting CodeCuriosity Application...")
+
+	db, err := config.InitDataStore(cfg)
+	if err != nil {
+		slog.Error("error initializing database", "error", err)
+		return err
+	}
+	defer db.Close()
+
+	bigqueryInstance, err := config.BigqueryInit(ctx, cfg)
+	if err != nil {
+		slog.Error("error initializing bigquery", "error", err)
+		return err
+	}
+
+	httpClient := &http.Client{}
+
+	dependencies := app.InitDependencies(db, cfg, bigqueryInstance, httpClient)
+
+	router := app.NewRouter(dependencies)
+
+	newCronSchedular := cronJob.NewCronSchedular()
+	newCronSchedular.InitCronJobs(dependencies.ContributionService, dependencies.UserService)
+
+	c := cors.New(cors.Options{
+		AllowedOrigins:   []string{"*"},
+		AllowCredentials: true,
+		AllowedMethods:   []string{http.MethodGet, http.MethodPost, http.MethodPut, http.MethodPatch, http.MethodDelete, http.MethodOptions},
+		AllowedHeaders:   []string{"*"},
+	})
+
+	server := http.Server{
+		Addr:    fmt.Sprintf(":%s", cfg.HTTPServer.Port),
+		Handler: router,
+	}
+
+	server.Handler = c.Handler(server.Handler)
+
+	serverRunning := make(chan os.Signal, 1)
+
+	signal.Notify(
+		serverRunning,
+		syscall.SIGABRT,
+		syscall.SIGALRM,
+		syscall.SIGBUS,
+		syscall.SIGINT,
+		syscall.SIGTERM,
+	)
+
+	go func() {
+		slog.Info("server listening at", "port", cfg.HTTPServer.Port)
+
+		if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+			slog.Error("server error", "error", err)
+			serverRunning <- syscall.SIGINT
+		}
+	}()
+
+	<-serverRunning
+
+	slog.Info("shutting down the server")
+	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
+	defer cancel()
+
+	if err := server.Shutdown(ctx); err != nil {
+		slog.Error("cannot shut HTTP server down gracefully", "error", err)
+	}
+
+	slog.Info("server shutdown successfully")
+	return nil
+}

backend/go.mod

@@ -0,0 +1,72 @@
+module github.com/joshsoftware/code-curiosity-2025
+
+go 1.23.4
+
+require (
+	cloud.google.com/go/bigquery v1.68.0
+	github.com/golang-jwt/jwt/v4 v4.5.2
+	github.com/golang-migrate/migrate/v4 v4.18.3
+	github.com/ilyakaznacheev/cleanenv v1.5.0
+	github.com/jmoiron/sqlx v1.4.0
+	github.com/lib/pq v1.10.9
+	github.com/robfig/cron/v3 v3.0.1
+	golang.org/x/crypto v0.37.0
+	golang.org/x/oauth2 v0.29.0
+	google.golang.org/api v0.231.0
+)
+
+require (
+	github.com/cpuguy83/go-md2man/v2 v2.0.7 // indirect
+	github.com/russross/blackfriday/v2 v2.1.0 // indirect
+	github.com/urfave/cli v1.22.17 // indirect
+)
+
+require (
+	cloud.google.com/go v0.121.0 // indirect
+	cloud.google.com/go/auth v0.16.1 // indirect
+	cloud.google.com/go/auth/oauth2adapt v0.2.8 // indirect
+	cloud.google.com/go/compute/metadata v0.6.0 // indirect
+	cloud.google.com/go/iam v1.5.2 // indirect
+	github.com/BurntSushi/toml v1.5.0 // indirect
+	github.com/apache/arrow/go/v15 v15.0.2 // indirect
+	github.com/felixge/httpsnoop v1.0.4 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/goccy/go-json v0.10.2 // indirect
+	github.com/google/flatbuffers v23.5.26+incompatible // indirect
+	github.com/google/s2a-go v0.1.9 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/googleapis/enterprise-certificate-proxy v0.3.6 // indirect
+	github.com/googleapis/gax-go/v2 v2.14.1 // indirect
+	github.com/hashicorp/errwrap v1.1.0 // indirect
+	github.com/hashicorp/go-multierror v1.1.1 // indirect
+	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/klauspost/compress v1.16.7 // indirect
+	github.com/klauspost/cpuid/v2 v2.2.5 // indirect
+	github.com/pierrec/lz4/v4 v4.1.18 // indirect
+	github.com/rs/cors v1.11.1
+	github.com/zeebo/xxh3 v1.0.2 // indirect
+	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
+	go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.60.0 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.60.0 // indirect
+	go.opentelemetry.io/otel v1.35.0 // indirect
+	go.opentelemetry.io/otel/metric v1.35.0 // indirect
+	go.opentelemetry.io/otel/trace v1.35.0 // indirect
+	go.uber.org/atomic v1.11.0 // indirect
+	golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 // indirect
+	golang.org/x/mod v0.23.0 // indirect
+	golang.org/x/net v0.39.0 // indirect
+	golang.org/x/sync v0.14.0 // indirect
+	golang.org/x/sys v0.32.0 // indirect
+	golang.org/x/text v0.24.0 // indirect
+	golang.org/x/time v0.11.0 // indirect
+	golang.org/x/tools v0.30.0 // indirect
+	golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da // indirect
+	google.golang.org/genproto v0.0.0-20250303144028-a0af3efb3deb // indirect
+	google.golang.org/genproto/googleapis/api v0.0.0-20250428153025-10db94c68c34 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20250428153025-10db94c68c34 // indirect
+	google.golang.org/grpc v1.72.0 // indirect
+	google.golang.org/protobuf v1.36.6 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+	olympos.io/encoding/edn v0.0.0-20201019073823-d3554ca0b0a3 // indirect
+)