Merge branch 'main' into refactor/config-command
This commit is contained in:
commit
bbfaaaf04b
5 changed files with 30 additions and 40 deletions
1
.gitignore
vendored
1
.gitignore
vendored
|
@ -26,3 +26,4 @@ go.work
|
||||||
tmp
|
tmp
|
||||||
config/**.toml
|
config/**.toml
|
||||||
data
|
data
|
||||||
|
docker-compose.yml
|
||||||
|
|
|
@ -1,22 +0,0 @@
|
||||||
services:
|
|
||||||
bot:
|
|
||||||
build: .
|
|
||||||
restart: always
|
|
||||||
env_file:
|
|
||||||
- .env
|
|
||||||
volumes:
|
|
||||||
- ./config:/app/config
|
|
||||||
depends_on:
|
|
||||||
- postgres
|
|
||||||
postgres:
|
|
||||||
image: postgres:alpine
|
|
||||||
env_file:
|
|
||||||
- .env
|
|
||||||
volumes:
|
|
||||||
- ./data:/var/lib/postgresql/data
|
|
||||||
adminer:
|
|
||||||
image: docker.io/adminer
|
|
||||||
ports:
|
|
||||||
- "8080:8080"
|
|
||||||
depends_on:
|
|
||||||
- postgres
|
|
|
@ -2,12 +2,13 @@ package exp
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/anhgelus/gokord"
|
|
||||||
"math"
|
"math"
|
||||||
"regexp"
|
"regexp"
|
||||||
"slices"
|
"slices"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/anhgelus/gokord"
|
||||||
)
|
)
|
||||||
|
|
||||||
func MessageXP(length uint, diversity uint) uint {
|
func MessageXP(length uint, diversity uint) uint {
|
||||||
|
@ -50,14 +51,14 @@ func LevelXP(level uint) uint {
|
||||||
|
|
||||||
// TimeStampNDaysBefore returns the timestamp (year-month-day) n days before today
|
// TimeStampNDaysBefore returns the timestamp (year-month-day) n days before today
|
||||||
func TimeStampNDaysBefore(n uint) string {
|
func TimeStampNDaysBefore(n uint) string {
|
||||||
var y, d int
|
var unix time.Time
|
||||||
var m time.Month
|
|
||||||
if gokord.Debug {
|
if gokord.Debug {
|
||||||
y, m, d = time.Unix(time.Now().Unix()-int64(24*60*60), 0).Date() // reduce time for debug
|
unix = time.Unix(time.Now().Unix()-int64(n), 0) // reduce time for debug
|
||||||
} else {
|
} else {
|
||||||
y, m, d = time.Unix(time.Now().Unix()-int64(n*24*60*60), 0).Date()
|
unix = time.Unix(time.Now().Unix()-int64(n*24*60*60), 0)
|
||||||
}
|
}
|
||||||
return fmt.Sprintf("%d-%d-%d", y, m, d)
|
unix = unix.UTC()
|
||||||
|
return fmt.Sprintf("%d-%d-%d %d:%d:%d UTC", unix.Year(), unix.Month(), unix.Day(), unix.Hour(), unix.Minute(), unix.Second())
|
||||||
}
|
}
|
||||||
|
|
||||||
func TrimMessage(s string) string {
|
func TrimMessage(s string) string {
|
||||||
|
|
17
main.go
17
main.go
|
@ -4,16 +4,17 @@ import (
|
||||||
_ "embed"
|
_ "embed"
|
||||||
"errors"
|
"errors"
|
||||||
"flag"
|
"flag"
|
||||||
|
"os"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/anhgelus/gokord"
|
"github.com/anhgelus/gokord"
|
||||||
cmd "github.com/anhgelus/gokord/cmd"
|
"github.com/anhgelus/gokord/cmd"
|
||||||
"github.com/anhgelus/gokord/logger"
|
"github.com/anhgelus/gokord/logger"
|
||||||
"github.com/anhgelus/les-copaings-bot/commands"
|
"github.com/anhgelus/les-copaings-bot/commands"
|
||||||
"github.com/anhgelus/les-copaings-bot/config"
|
"github.com/anhgelus/les-copaings-bot/config"
|
||||||
"github.com/anhgelus/les-copaings-bot/user"
|
"github.com/anhgelus/les-copaings-bot/user"
|
||||||
"github.com/bwmarrin/discordgo"
|
"github.com/bwmarrin/discordgo"
|
||||||
"github.com/joho/godotenv"
|
"github.com/joho/godotenv"
|
||||||
"os"
|
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -117,7 +118,15 @@ func main() {
|
||||||
creditsCmd,
|
creditsCmd,
|
||||||
},
|
},
|
||||||
AfterInit: func(dg *discordgo.Session) {
|
AfterInit: func(dg *discordgo.Session) {
|
||||||
stopPeriodicReducer = gokord.NewTimer(24*time.Hour, func(stop chan<- interface{}) {
|
d := 24 * time.Hour
|
||||||
|
if gokord.Debug {
|
||||||
|
d = 24 * time.Second
|
||||||
|
}
|
||||||
|
|
||||||
|
user.PeriodicReducer(dg)
|
||||||
|
|
||||||
|
stopPeriodicReducer = gokord.NewTimer(d, func(stop chan<- interface{}) {
|
||||||
|
logger.Debug("Periodic reducer")
|
||||||
user.PeriodicReducer(dg)
|
user.PeriodicReducer(dg)
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
|
|
|
@ -1,14 +1,15 @@
|
||||||
package user
|
package user
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"slices"
|
||||||
|
"sync"
|
||||||
|
"time"
|
||||||
|
|
||||||
"github.com/anhgelus/gokord"
|
"github.com/anhgelus/gokord"
|
||||||
"github.com/anhgelus/gokord/logger"
|
"github.com/anhgelus/gokord/logger"
|
||||||
"github.com/anhgelus/les-copaings-bot/config"
|
"github.com/anhgelus/les-copaings-bot/config"
|
||||||
"github.com/anhgelus/les-copaings-bot/exp"
|
"github.com/anhgelus/les-copaings-bot/exp"
|
||||||
"github.com/bwmarrin/discordgo"
|
"github.com/bwmarrin/discordgo"
|
||||||
"slices"
|
|
||||||
"sync"
|
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func onNewLevel(dg *discordgo.Session, m *discordgo.Member, level uint) {
|
func onNewLevel(dg *discordgo.Session, m *discordgo.Member, level uint) {
|
||||||
|
@ -86,14 +87,14 @@ func PeriodicReducer(dg *discordgo.Session) {
|
||||||
go func() {
|
go func() {
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
cfg := config.GetGuildConfig(g.ID)
|
cfg := config.GetGuildConfig(g.ID)
|
||||||
err := gokord.DB.
|
res := gokord.DB.
|
||||||
Model(&CopaingXP{}).
|
Model(&CopaingXP{}).
|
||||||
Where("guild_id = ? and created_at < ?", g.ID, exp.TimeStampNDaysBefore(cfg.DaysXPRemains)).
|
Where("guild_id = ? and created_at < ?", g.ID, exp.TimeStampNDaysBefore(cfg.DaysXPRemains)).
|
||||||
Delete(&CopaingXP{}).
|
Delete(&CopaingXP{})
|
||||||
Error
|
if res.Error != nil {
|
||||||
if err != nil {
|
logger.Alert("user/level.go - Removing old XP", res.Error.Error(), "guild_id", g.ID)
|
||||||
logger.Alert("user/level.go - Removing old XP", err.Error(), "guild_id", g.ID)
|
|
||||||
}
|
}
|
||||||
|
logger.Debug("Guild cleaned", "guild", g.Name, "rows affected", res.RowsAffected)
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue