main.go

package main

import (
	"context"
	"github.com/golang/protobuf/jsonpb"
	"github.com/jinzhu/configor"
	"log"
	"os"
	"os/signal"
	"spaceship/game"
	"spaceship/server"
	"syscall"
)

var (
	jsonProtoMarshaler = &jsonpb.Marshaler{
		EnumsAsInts: true,
		EmitDefaults: true,
		Indent: "",
		OrigName: true,
	}
	jsonProtoUnmarshler = &jsonpb.Unmarshaler{
		AllowUnknownFields: false,
	}
)

func main() {

	appContext, appContextCancel := context.WithCancel(context.Background())

	config := &server.Config{}
	err := configor.Load(config, "config.yml")
	if err != nil {
		log.Panicln("Error while reading configurations from config.yml")
	}

	logger := server.NewLogger(config)
	defer logger.Sync()

	redis := server.ConnectRedis(config, logger)
	db := server.ConnectDB(config, logger)
	notification := server.NewNotificationService(db, config, logger)
	leaderboard := server.NewLeaderboard(db, logger)
	stats := server.NewStatsHolder(logger)
	sessionHolder := server.NewSessionHolder(config)
	gameHolder := server.NewGameHolder(redis, jsonProtoMarshaler, jsonProtoUnmarshler, leaderboard, notification)
	leaderboard.SetGameHolder(gameHolder)
	pubsub := server.NewPubSub(config, sessionHolder, jsonProtoMarshaler, jsonProtoUnmarshler, logger, appContext)
	matchmaker := server.NewLocalMatchMaker(redis, gameHolder, sessionHolder, notification, logger, config, pubsub, appContext)
	pipeline := server.NewPipeline(config, jsonProtoMarshaler, jsonProtoUnmarshler, gameHolder, sessionHolder, matchmaker, db, redis, notification, logger, pubsub)
	matchmaker.SetPipeline(pipeline)

	sessionHolder.SetLeaveListener(matchmaker.LeaveActiveGames)

	//Games should be attached to game holder
	initGames(gameHolder)

	server := server.StartServer(sessionHolder, gameHolder, config, jsonProtoMarshaler, jsonProtoUnmarshler, pipeline, db, leaderboard, stats, logger)

	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)

	logger.Info("Startup was completed")

	<-c

	logger.Info("Shutdown was started")
	appContextCancel()
	server.Stop()
	logger.Info("Shutdown was completed")

	os.Exit(1)

}

func initGames(holder *server.GameHolder) {
	holder.Add(&game.ExampleGame{})
	holder.Add(&game.ExampleATGame{})
	holder.Add(&game.RTGame{})
}