mirror of
https://github.com/SamyRai/tercul-backend.git
synced 2025-12-27 05:11:34 +00:00
a8dfb727a1
This commit addresses several high-priority tasks from the TASKS.md file, including: - **Fix Background Job Panic:** Replaced `log.Fatalf` with `log.Printf` in the `asynq` server to prevent crashes. - **Refactor API Server Setup:** Consolidated the GraphQL Playground and Prometheus metrics endpoints into the main API server. - **Implement `DeleteUser` Mutation:** Implemented the `DeleteUser` resolver. - **Implement `CreateContribution` Mutation:** Implemented the `CreateContribution` resolver and its required application service. Additionally, this commit includes a major refactoring of the configuration management system to fix a broken build. The global `config.Cfg` variable has been removed and replaced with a dependency injection approach, where the configuration object is passed to all components that require it. This change has been applied across the entire codebase, including the test suite, to ensure a stable and testable application.
72 lines
1.8 KiB
Go
72 lines
1.8 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"flag"
|
|
"fmt"
|
|
"os"
|
|
"strconv"
|
|
"tercul/internal/data/sql"
|
|
"tercul/internal/enrichment"
|
|
"tercul/internal/platform/config"
|
|
"tercul/internal/platform/db"
|
|
"tercul/internal/platform/log"
|
|
)
|
|
|
|
func main() {
|
|
// 1. Parse command-line arguments
|
|
entityType := flag.String("type", "", "The type of entity to enrich (e.g., 'author')")
|
|
entityIDStr := flag.String("id", "", "The ID of the entity to enrich")
|
|
flag.Parse()
|
|
|
|
if *entityType == "" || *entityIDStr == "" {
|
|
fmt.Println("Usage: go run cmd/tools/enrich/main.go --type <entity_type> --id <entity_id>")
|
|
os.Exit(1)
|
|
}
|
|
|
|
entityID, err := strconv.ParseUint(*entityIDStr, 10, 64)
|
|
if err != nil {
|
|
fmt.Printf("Invalid entity ID: %v\n", err)
|
|
os.Exit(1)
|
|
}
|
|
|
|
// 2. Initialize dependencies
|
|
cfg, err := config.LoadConfig()
|
|
if err != nil {
|
|
log.Fatal(err, "Failed to load config")
|
|
}
|
|
log.Init("enrich-tool", "development")
|
|
database, err := db.InitDB(cfg, nil) // No metrics needed for this tool
|
|
if err != nil {
|
|
log.Fatal(err, "Failed to initialize database")
|
|
}
|
|
defer db.Close(database)
|
|
|
|
repos := sql.NewRepositories(database, cfg)
|
|
enrichmentSvc := enrichment.NewService()
|
|
|
|
// 3. Fetch, enrich, and save the entity
|
|
ctx := context.Background()
|
|
log.Info(fmt.Sprintf("Enriching %s with ID %d", *entityType, entityID))
|
|
|
|
switch *entityType {
|
|
case "author":
|
|
author, err := repos.Author.GetByID(ctx, uint(entityID))
|
|
if err != nil {
|
|
log.Fatal(err, "Failed to get author")
|
|
}
|
|
|
|
if err := enrichmentSvc.EnrichAuthor(ctx, author); err != nil {
|
|
log.Fatal(err, "Failed to enrich author")
|
|
}
|
|
|
|
if err := repos.Author.Update(ctx, author); err != nil {
|
|
log.Fatal(err, "Failed to save enriched author")
|
|
}
|
|
|
|
log.Info("Successfully enriched and saved author")
|
|
|
|
default:
|
|
log.Fatal(fmt.Errorf("unknown entity type: %s", *entityType), "Enrichment failed")
|
|
}
|
|
} |