54 lines
1.1 KiB
Go
54 lines
1.1 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
"os"
|
|
"os/signal"
|
|
"syscall"
|
|
|
|
"ai-service/internal/config"
|
|
"ai-service/internal/llm"
|
|
"ai-service/internal/migrate"
|
|
"ai-service/internal/store"
|
|
"ai-service/internal/worker"
|
|
)
|
|
|
|
func main() {
|
|
cfg := config.Load()
|
|
slog.SetDefault(slog.New(slog.NewJSONHandler(os.Stdout, nil)))
|
|
|
|
ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
|
|
defer stop()
|
|
|
|
db, err := store.Open(ctx, cfg.DatabaseURL)
|
|
if err != nil {
|
|
slog.Error("db_open_failed", "error", err)
|
|
os.Exit(1)
|
|
}
|
|
defer db.Close()
|
|
|
|
if cfg.MigrateOnStart {
|
|
if err := migrate.Up(ctx, db); err != nil {
|
|
slog.Error("migrate_failed", "error", err)
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
|
|
if cfg.LLMBaseURL == "" {
|
|
slog.Error("llm_not_configured")
|
|
os.Exit(1)
|
|
}
|
|
|
|
llmClient := llm.New(cfg.LLMBaseURL, cfg.LLMAPIKey, cfg.LLMModel, cfg.LLMTimeout)
|
|
w := worker.New(db, llmClient, cfg.WorkerID, cfg.LLMModel, cfg.WorkerPollInterval, cfg.WorkerClaimLimit)
|
|
|
|
slog.Info("ai_worker_started",
|
|
"worker_id", cfg.WorkerID,
|
|
"model", cfg.LLMModel,
|
|
"poll_interval", cfg.WorkerPollInterval.String(),
|
|
"claim_limit", cfg.WorkerClaimLimit,
|
|
)
|
|
w.Run(ctx)
|
|
}
|