birthdaybot/server/server.go

package server

import (
	"fmt"
	"os"

	"git.ctrlz.es/mgdelacroix/birthdaybot/model"
	"git.ctrlz.es/mgdelacroix/birthdaybot/parser"
	"github.com/charmbracelet/log"
)

type Server struct {
	Logger    *log.Logger
	config    *model.Config
	workers   []*Worker
	birthdays []*model.Birthday
}

func New(config *model.Config) (*Server, error) {
	logger := log.New(os.Stderr)

	logger.Info("Parsing CSV file", "birthdayFile", config.BirthdayFile)

	birthdays, err := parser.ParseCSV(config.BirthdayFile)
	if err != nil {
		logger.Error("cannot parse CSV file", "birthdayFile", config.BirthdayFile, "error", err)
		return nil, fmt.Errorf("cannot parse CSV file %s: %w", config.BirthdayFile, err)
	}

	logger.Info("creating server")

	server := &Server{
		Logger:    logger,
		config:    config,
		birthdays: birthdays,
		workers:   []*Worker{NewWorker(logger)},
	}

	return server, nil
}

func (s *Server) Start() {
	s.Logger.Info("starting server")
	for _, worker := range s.workers {
		worker.Start()
	}
	s.Logger.Info("server started", "workers", len(s.workers))
}

func (s *Server) Stop() {
	s.Logger.Info("stopping server")
	for _, worker := range s.workers {
		worker.Stop()
	}
	s.Logger.Info("server stopped", "workers", len(s.workers))
}