main.go

package main

import (
	"fmt"
	"os"
	"sync"
	"time"

	"github.com/riltech/centurion/core"
	"github.com/riltech/centurion/core/bus"
	"github.com/riltech/centurion/core/combat"
	"github.com/riltech/centurion/core/config"
	"github.com/riltech/centurion/core/player"
	"github.com/riltech/centurion/core/scoreboard"
	"github.com/riltech/centurion/example"
	"github.com/sirupsen/logrus"
)

func main() {
	file, err := os.Create("logs")
	if err != nil {
		logrus.Fatal(err)
	}
	defer func() {
		file.Close()
	}()
	logrus.SetOutput(file)
	logrus.SetFormatter(&logrus.TextFormatter{
		DisableQuote: true,
	})
	logrus.Info("Centurion is starting")
	spec, err := config.Init()
	if err != nil {
		logrus.Fatal(err)
	}
	exitHandler := core.NewExitHandler()
	bus := bus.NewBus()
	playerRepo := player.NewRepository()
	playerService := player.NewService(playerRepo)
	scoreRepository := scoreboard.NewRepository()
	scoreService := scoreboard.NewService(scoreRepository, playerService)
	combatRepository := combat.NewRepository()
	combatService := combat.NewService(combatRepository)
	engine := core.NewEngine(
		spec.Port,
		bus,
		scoreService,
		combatService,
		playerService,
	)
	dashboard := core.NewDashboard(
		bus,
		scoreService,
		combatService,
		playerService,
	)
	wg := &sync.WaitGroup{}
	wg.Add(1)
	var exampleAttacker example.IAttacker
	var exampleDefender example.IDefender
	exitHandler.On(func() {
		logrus.Info("Running exit handler")
		engine.Stop()
		bus.Stop()
		if exampleAttacker != nil {
			exampleAttacker.Stop()
		}
		if exampleDefender != nil {
			exampleDefender.Stop()
		}
		// Let's be really graceful
		<-time.After(2 * time.Second)
		wg.Done()
	})
	go engine.Start()
	if spec.ExampleEnabled {
		exampleAttacker = example.NewAttacker("localhost:8080")
		go func() {
			// Wait a bit before startup
			<-time.After(2 * time.Second)
			exampleAttacker.Start()
		}()
		exampleDefender = example.NewDefender("localhost:8080")
		go func() {
			// Wait a bit less before startup
			// as the defender has to install the module
			<-time.After(1 * time.Second)
			exampleDefender.Start()
		}()
	}
	dashboard.Start()
	if !exitHandler.IsRunning() {
		exitHandler.Trigger()
	}
	wg.Wait()
	fmt.Println("Final score")
	attackers, defenders := scoreService.GetBoards()
	fmt.Printf("Attackers %d - %d Defenders\n", attackers.OverallScore, defenders.OverallScore)
	fmt.Println("Congratulations!")
}