application.go

package service

import (
	"context"
	"os"
	
	"cloud.google.com/go/firestore"
	"github.com/sirupsen/logrus"
	
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/common/metrics"
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/trainer/adapters"
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/trainer/app"
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/trainer/app/command"
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/trainer/app/query"
	"github.com/ThreeDotsLabs/wild-workouts-go-ddd-example/internal/trainer/domain/hour"
)

func NewApplication(ctx context.Context) app.Application {
	firestoreClient, err := firestore.NewClient(ctx, os.Getenv("GCP_PROJECT"))
	if err != nil {
		panic(err)
	}
	
	factoryConfig := hour.FactoryConfig{
		MaxWeeksInTheFutureToSet: 6,
		MinUtcHour:               12,
		MaxUtcHour:               20,
	}
	
	hourFactory, err := hour.NewFactory(factoryConfig)
	if err != nil {
		panic(err)
	}
	
	hourRepository := adapters.NewFirestoreHourRepository(firestoreClient, hourFactory)
	
	logger := logrus.NewEntry(logrus.StandardLogger())
	metricsClient := metrics.NoOp{}
	
	return app.Application{
		Commands: app.Commands{
			CancelTraining:       command.NewCancelTrainingHandler(hourRepository, logger, metricsClient),
			ScheduleTraining:     command.NewScheduleTrainingHandler(hourRepository, logger, metricsClient),
			MakeHoursAvailable:   command.NewMakeHoursAvailableHandler(hourRepository, logger, metricsClient),
			MakeHoursUnavailable: command.NewMakeHoursUnavailableHandler(hourRepository, logger, metricsClient),
		},
		Queries: app.Queries{
			HourAvailability: query.NewHourAvailabilityHandler(hourRepository, logger, metricsClient),
		},
	}
}