mirror of https://git.sr.ht/~ashkeel/strimertul
Compare commits
2 Commits
2b7f332d88
...
06f7e9be98
Author | SHA1 | Date |
---|---|---|
Ash Keel | 06f7e9be98 | |
Ash Keel | bba0bce1ec |
|
@ -16,7 +16,7 @@ jobs:
|
||||||
release:
|
release:
|
||||||
runs-on: docker
|
runs-on: docker
|
||||||
container:
|
container:
|
||||||
image: ghcr.io/ashkeel/cross-wails:v2.8.1@sha256:f40cd11894cb7b4bdacf72830337a0b2c81bc49becdba7ca3a6c7c39238de888
|
image: ghcr.io/ashkeel/cross-wails:v2.8.1@sha256:205e8cd7128765972de385919a0d9b389dc20541569d7c7b2251b964ed1110fe
|
||||||
credentials:
|
credentials:
|
||||||
username: ${{ secrets.GHCR_USERNAME }}
|
username: ${{ secrets.GHCR_USERNAME }}
|
||||||
password: ${{ secrets.GHCR_PASSWORD }}
|
password: ${{ secrets.GHCR_PASSWORD }}
|
||||||
|
@ -38,5 +38,5 @@ jobs:
|
||||||
secret_key: ${{ secrets.MINIO_SECRET }}
|
secret_key: ${{ secrets.MINIO_SECRET }}
|
||||||
bucket: strimertul-builds
|
bucket: strimertul-builds
|
||||||
source: ./${{ github.ref_name }}/
|
source: ./${{ github.ref_name }}/
|
||||||
target: /
|
target: /${{ github.ref_name }}/
|
||||||
recursive: true
|
recursive: true
|
|
@ -2,6 +2,8 @@ package migrations
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
|
|
||||||
"git.sr.ht/~ashkeel/strimertul/twitch/eventsub"
|
"git.sr.ht/~ashkeel/strimertul/twitch/eventsub"
|
||||||
|
@ -23,7 +25,7 @@ func migrateToV4(db database.Database, logger *slog.Logger) error {
|
||||||
"twitch/bot-custom-commands": chat.CustomCommandsKey,
|
"twitch/bot-custom-commands": chat.CustomCommandsKey,
|
||||||
} {
|
} {
|
||||||
if err := renameKey(db, oldKey, newKey, true); err != nil {
|
if err := renameKey(db, oldKey, newKey, true); err != nil {
|
||||||
return err
|
return fmt.Errorf("failed to rename key '%s' to '%s': %w", oldKey, newKey, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -37,7 +39,7 @@ func migrateToV4(db database.Database, logger *slog.Logger) error {
|
||||||
"twitch/ev/eventsub-event",
|
"twitch/ev/eventsub-event",
|
||||||
} {
|
} {
|
||||||
if err := db.RemoveKey(key); err != nil {
|
if err := db.RemoveKey(key); err != nil {
|
||||||
return err
|
return fmt.Errorf("failed to remove key '%s': %w", key, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -46,12 +48,16 @@ func migrateToV4(db database.Database, logger *slog.Logger) error {
|
||||||
CommandCooldown int `json:"command_cooldown"`
|
CommandCooldown int `json:"command_cooldown"`
|
||||||
}
|
}
|
||||||
if err := db.GetJSON("twitch/bot-config", &botConfig); err != nil {
|
if err := db.GetJSON("twitch/bot-config", &botConfig); err != nil {
|
||||||
return err
|
if errors.Is(err, database.ErrEmptyKey) {
|
||||||
|
botConfig.CommandCooldown = 0
|
||||||
|
} else {
|
||||||
|
return fmt.Errorf("failed to get bot config: %w", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if err := db.PutJSON(chat.ConfigKey, chat.Config{
|
if err := db.PutJSON(chat.ConfigKey, chat.Config{
|
||||||
CommandCooldown: botConfig.CommandCooldown,
|
CommandCooldown: botConfig.CommandCooldown,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
return err
|
return fmt.Errorf("failed to put chat config to new key: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Migrate eventsub history to their new keys
|
// Migrate eventsub history to their new keys
|
||||||
|
@ -61,7 +67,10 @@ func migrateToV4(db database.Database, logger *slog.Logger) error {
|
||||||
}
|
}
|
||||||
var eventsubHistory []eventSubNotification
|
var eventsubHistory []eventSubNotification
|
||||||
if err := db.GetJSON("twitch/eventsub-history", &eventsubHistory); err != nil {
|
if err := db.GetJSON("twitch/eventsub-history", &eventsubHistory); err != nil {
|
||||||
return err
|
if !errors.Is(err, database.ErrEmptyKey) {
|
||||||
|
return fmt.Errorf("failed to get eventsub history: %w", err)
|
||||||
|
}
|
||||||
|
eventsubHistory = []eventSubNotification{}
|
||||||
}
|
}
|
||||||
eventsubHistoryMap := make(map[string][]eventSubNotification)
|
eventsubHistoryMap := make(map[string][]eventSubNotification)
|
||||||
for _, notification := range eventsubHistory {
|
for _, notification := range eventsubHistory {
|
||||||
|
@ -70,12 +79,12 @@ func migrateToV4(db database.Database, logger *slog.Logger) error {
|
||||||
}
|
}
|
||||||
for key, notifications := range eventsubHistoryMap {
|
for key, notifications := range eventsubHistoryMap {
|
||||||
if err := db.PutJSON(key, notifications); err != nil {
|
if err := db.PutJSON(key, notifications); err != nil {
|
||||||
return err
|
return fmt.Errorf("failed to put eventsub history to new key '%s': %w", key, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
// Clear old eventsub history key
|
// Clear old eventsub history key
|
||||||
if err := db.RemoveKey("twitch/eventsub-history"); err != nil {
|
if err := db.RemoveKey("twitch/eventsub-history"); err != nil {
|
||||||
return err
|
return fmt.Errorf("failed to remove key 'twitch/eventsub-history': %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|
Loading…
Reference in New Issue