emdb/cmd/api-service/service.go

package main

import (
	"flag"
	"fmt"
	"log/slog"
	"net/http"
	"os"
	"os/signal"
	"syscall"

	"ewintr.nl/emdb/client"
	"ewintr.nl/emdb/cmd/api-service/handler"
	"ewintr.nl/emdb/cmd/api-service/job"
	"ewintr.nl/emdb/cmd/api-service/moviestore"
)

var (
	port   = flag.Int("port", 8085, "port to listen on")
	dbPath = flag.String("dbpath", "test.db", "path to sqlite db")
	apiKey = flag.String("apikey", "hoi", "api key to use")
)

func main() {
	flag.Parse()
	logger := slog.New(slog.NewJSONHandler(os.Stdout, nil))
	logger.Info("starting server", "port", *port, "dbPath", *dbPath, "apiKey", *apiKey)

	db, err := moviestore.NewSQLite(*dbPath)
	if err != nil {
		fmt.Printf("could not create new sqlite repo: %s", err.Error())
		os.Exit(1)
	}

	jobQueue := job.NewJobQueue(db, logger)
	worker := job.NewWorker(jobQueue, moviestore.NewMovieRepository(db), moviestore.NewReviewRepository(db), client.NewIMDB(), logger)
	go worker.Run()

	apis := handler.APIIndex{
		"job": handler.NewJobAPI(jobQueue, logger),
		"movie": handler.NewMovieAPI(handler.APIIndex{
			"review": handler.NewMovieReviewAPI(moviestore.NewReviewRepository(db), logger),
		}, moviestore.NewMovieRepository(db), jobQueue, logger),
		"review": handler.NewReviewAPI(moviestore.NewReviewRepository(db), logger),
	}

	go http.ListenAndServe(fmt.Sprintf(":%d", *port), handler.NewServer(*apiKey, apis, logger))
	logger.Info("server started")

	c := make(chan os.Signal, 1)
	signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
	<-c

	logger.Info("server stopped")
}