2021-04-25 18:14:21 +00:00
|
|
|
package tasks
|
2020-06-20 18:16:27 +00:00
|
|
|
|
|
|
|
import (
|
|
|
|
"github.com/go-pg/pg/v10"
|
|
|
|
"github.com/pkg/errors"
|
|
|
|
"github.com/tribalwarshelp/shared/models"
|
2021-04-25 18:14:21 +00:00
|
|
|
"time"
|
2020-06-20 18:16:27 +00:00
|
|
|
)
|
|
|
|
|
2021-04-25 18:14:21 +00:00
|
|
|
type taskUpdateServerStats struct {
|
|
|
|
*task
|
|
|
|
}
|
|
|
|
|
|
|
|
func (t *taskUpdateServerStats) execute(timezone string, server *models.Server) error {
|
|
|
|
if err := t.validatePayload(server); err != nil {
|
|
|
|
log.Debug(err)
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
location, err := t.loadLocation(timezone)
|
|
|
|
if err != nil {
|
|
|
|
err = errors.Wrap(err, "taskUpdateServerStats.execute")
|
|
|
|
log.Error(err)
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
entry := log.WithField("key", server.Key)
|
|
|
|
entry.Infof("%s: update of the stats has started...", server.Key)
|
|
|
|
err = (&workerUpdateServerStats{
|
|
|
|
db: t.db.WithParam("SERVER", pg.Safe(server.Key)),
|
|
|
|
server: server,
|
|
|
|
location: location,
|
|
|
|
}).update()
|
|
|
|
if err != nil {
|
|
|
|
err = errors.Wrap(err, "taskUpdateServerStats.execute")
|
|
|
|
entry.Error(err)
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
entry.Infof("%s: stats have been updated", server.Key)
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (t *taskUpdateServerStats) validatePayload(server *models.Server) error {
|
|
|
|
if server == nil {
|
|
|
|
return errors.Errorf("taskUpdateServerStats.validatePayload: Expected *models.Server, got nil")
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
type workerUpdateServerStats struct {
|
2020-12-31 13:33:56 +00:00
|
|
|
db *pg.DB
|
|
|
|
server *models.Server
|
|
|
|
location *time.Location
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
|
2021-04-25 18:14:21 +00:00
|
|
|
func (w *workerUpdateServerStats) prepare() (*models.ServerStats, error) {
|
2021-01-15 17:25:13 +00:00
|
|
|
activePlayers, err := w.db.Model(&models.Player{}).Where("exists = true").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count active players")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
2021-01-15 17:25:13 +00:00
|
|
|
inactivePlayers, err := w.db.Model(&models.Player{}).Where("exists = false").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count inactive players")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
players := activePlayers + inactivePlayers
|
|
|
|
|
2021-01-15 17:25:13 +00:00
|
|
|
activeTribes, err := w.db.Model(&models.Tribe{}).Where("exists = true").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count active tribes")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
2021-01-15 17:25:13 +00:00
|
|
|
inactiveTribes, err := w.db.Model(&models.Tribe{}).Where("exists = false").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count inactive tribes")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
tribes := activeTribes + inactiveTribes
|
|
|
|
|
2021-01-15 17:25:13 +00:00
|
|
|
barbarianVillages, err := w.db.Model(&models.Village{}).Where("player_id = 0").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count barbarian villages")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
2021-01-15 17:25:13 +00:00
|
|
|
bonusVillages, err := w.db.Model(&models.Village{}).Where("bonus <> 0").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count bonus villages")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
2021-01-15 17:25:13 +00:00
|
|
|
playerVillages, err := w.db.Model(&models.Village{}).Where("player_id <> 0").Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count player villages")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
2021-01-15 17:25:13 +00:00
|
|
|
villages, err := w.db.Model(&models.Village{}).Count()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return nil, errors.Wrap(err, "cannot count villages")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
|
2021-01-15 17:25:13 +00:00
|
|
|
now := time.Now().In(w.location)
|
2020-12-31 13:33:56 +00:00
|
|
|
createDate := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, time.UTC)
|
2020-06-20 18:16:27 +00:00
|
|
|
return &models.ServerStats{
|
|
|
|
ActivePlayers: activePlayers,
|
|
|
|
InactivePlayers: inactivePlayers,
|
|
|
|
Players: players,
|
|
|
|
|
|
|
|
ActiveTribes: activeTribes,
|
|
|
|
InactiveTribes: inactiveTribes,
|
|
|
|
Tribes: tribes,
|
|
|
|
|
|
|
|
BarbarianVillages: barbarianVillages,
|
|
|
|
BonusVillages: bonusVillages,
|
|
|
|
PlayerVillages: playerVillages,
|
|
|
|
Villages: villages,
|
2020-12-31 13:33:56 +00:00
|
|
|
CreateDate: createDate,
|
2020-06-20 18:16:27 +00:00
|
|
|
}, nil
|
|
|
|
}
|
|
|
|
|
2021-04-25 18:14:21 +00:00
|
|
|
func (w *workerUpdateServerStats) update() error {
|
2021-01-15 17:25:13 +00:00
|
|
|
stats, err := w.prepare()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2021-01-15 17:25:13 +00:00
|
|
|
tx, err := w.db.Begin()
|
2020-06-20 18:16:27 +00:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer tx.Close()
|
|
|
|
|
2020-10-24 10:24:05 +00:00
|
|
|
if _, err := tx.Model(stats).Insert(); err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return errors.Wrap(err, "cannot insert server stats")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
|
2021-01-15 17:25:13 +00:00
|
|
|
_, err = tx.Model(w.server).
|
2020-06-20 18:16:27 +00:00
|
|
|
Set("stats_updated_at = ?", time.Now()).
|
|
|
|
WherePK().
|
|
|
|
Returning("*").
|
|
|
|
Update()
|
|
|
|
if err != nil {
|
2021-01-13 19:27:20 +00:00
|
|
|
return errors.Wrap(err, "cannot update server")
|
2020-06-20 18:16:27 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return tx.Commit()
|
|
|
|
}
|