david
a0141019b4
- Implement GetHabitStatsHandler with streak calculations
- Calculate current streak, longest streak, and completion rate
- Track completions this week and this month
- Add stats HTTP handler and route at /api/v1/stats/habits/{id}
- Add Swagger documentation for stats endpoint
95 lines
3.1 KiB
Go
95 lines
3.1 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"apocapoc-api/internal/application/commands"
|
|
"apocapoc-api/internal/application/queries"
|
|
"apocapoc-api/internal/infrastructure/auth"
|
|
"apocapoc-api/internal/infrastructure/config"
|
|
httpInfra "apocapoc-api/internal/infrastructure/http"
|
|
"apocapoc-api/internal/infrastructure/persistence/sqlite"
|
|
)
|
|
|
|
// @title Apocapoc API
|
|
// @version 1.0
|
|
// @description Self-hosted habit tracking service
|
|
// @termsOfService http://swagger.io/terms/
|
|
|
|
// @contact.name API Support
|
|
// @contact.url https://github.com/davidfolch/apocapoc-api
|
|
|
|
// @license.name MIT
|
|
// @license.url https://opensource.org/licenses/MIT
|
|
|
|
// @host localhost:8080
|
|
// @BasePath /api/v1
|
|
|
|
// @securityDefinitions.apikey BearerAuth
|
|
// @in header
|
|
// @name Authorization
|
|
// @description Type "Bearer" followed by a space and JWT token.
|
|
|
|
func main() {
|
|
cfg, err := config.Load()
|
|
if err != nil {
|
|
log.Fatalf("Failed to load config: %v", err)
|
|
}
|
|
|
|
db, err := sqlite.NewDatabase(cfg.DBPath)
|
|
if err != nil {
|
|
log.Fatalf("Failed to connect to database: %v", err)
|
|
}
|
|
defer db.Close()
|
|
|
|
jwtExpiryHours, err := parseJWTExpiry(cfg.JWTExpiry)
|
|
if err != nil {
|
|
log.Fatalf("Invalid JWT_EXPIRY: %v", err)
|
|
}
|
|
|
|
jwtService := auth.NewJWTService(cfg.JWTSecret, jwtExpiryHours)
|
|
|
|
userRepo := sqlite.NewUserRepository(db.Conn())
|
|
habitRepo := sqlite.NewHabitRepository(db.Conn())
|
|
entryRepo := sqlite.NewHabitEntryRepository(db.Conn())
|
|
|
|
registerHandler := commands.NewRegisterUserHandler(userRepo)
|
|
loginHandler := queries.NewLoginUserHandler(userRepo)
|
|
createHandler := commands.NewCreateHabitHandler(habitRepo)
|
|
getTodaysHandler := queries.NewGetTodaysHabitsHandler(habitRepo, entryRepo)
|
|
getUserHabitsHandler := queries.NewGetUserHabitsHandler(habitRepo)
|
|
getHabitByIDHandler := queries.NewGetHabitByIDHandler(habitRepo)
|
|
getHabitEntriesHandler := queries.NewGetHabitEntriesHandler(habitRepo, entryRepo)
|
|
getHabitStatsHandler := queries.NewGetHabitStatsHandler(habitRepo, entryRepo)
|
|
updateHandler := commands.NewUpdateHabitHandler(habitRepo)
|
|
archiveHandler := commands.NewArchiveHabitHandler(habitRepo)
|
|
markHandler := commands.NewMarkHabitHandler(entryRepo, habitRepo)
|
|
unmarkHandler := commands.NewUnmarkHabitHandler(habitRepo, entryRepo)
|
|
|
|
authHandlers := httpInfra.NewAuthHandlers(registerHandler, loginHandler, jwtService)
|
|
habitHandlers := httpInfra.NewHabitHandlers(createHandler, getTodaysHandler, getUserHabitsHandler, getHabitByIDHandler, getHabitEntriesHandler, updateHandler, archiveHandler, markHandler, unmarkHandler)
|
|
statsHandlers := httpInfra.NewStatsHandlers(getHabitStatsHandler)
|
|
|
|
router := httpInfra.NewRouter(cfg.CORSOrigins, habitHandlers, authHandlers, statsHandlers, jwtService)
|
|
|
|
addr := fmt.Sprintf("%s:%s", cfg.Host, cfg.Port)
|
|
log.Printf("Server starting on %s", addr)
|
|
|
|
if err := http.ListenAndServe(addr, router); err != nil {
|
|
log.Fatalf("Server failed: %v", err)
|
|
}
|
|
}
|
|
|
|
func parseJWTExpiry(expiry string) (int, error) {
|
|
expiry = strings.TrimSpace(expiry)
|
|
if strings.HasSuffix(expiry, "h") {
|
|
hours := strings.TrimSuffix(expiry, "h")
|
|
return strconv.Atoi(hours)
|
|
}
|
|
return 0, fmt.Errorf("invalid format, expected format like '24h'")
|
|
}
|