mirror/rogueserver
1
0
Fork 0
mirror of https://github.com/pagefaultgames/rogueserver.git synced 2025-04-02 02:57:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove isInLocalDb flag, start dumping saves into S3

Browse Source
This commit is contained in:
Pancakes 2024-10-29 21:26:10 -04:00
parent ad8fa03503
commit 5480c2ee72
No known key found for this signature in database
GPG Key ID: 5792877BFA27DC8F
3 changed files with 11 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
api/daily/common.go
View File

@ -132,7 +132,7 @@ func S3SaveMigration() error {
} }
// retrieve accounts from db // retrieve accounts from db
accounts, err := db.GetLocalAccounts() accounts, err := db.GetLocalSystemAccounts()
if err != nil { if err != nil {
return fmt.Errorf("failed to retrieve old accounts: %s", err) return fmt.Errorf("failed to retrieve old accounts: %s", err)
} }
@ -163,9 +163,9 @@ func S3SaveMigration() error {
continue continue
} }
err = db.UpdateSystemSaveLocation(user) err = db.DeleteSystemSaveData(user)
if err != nil { if err != nil {
log.Printf("failed to update location for user %s: %s", username, err) log.Printf("failed to delete old save for user %s: %s", username, err)
continue continue
} }

5
db/db.go
View File

@ -108,6 +108,11 @@ func setupDb(tx *sql.Tx) error {
// MIGRATION 004 // MIGRATION 004
`ALTER TABLE accounts ADD COLUMN IF NOT EXISTS isInLocalDb TINYINT(1) NOT NULL DEFAULT 1`, `ALTER TABLE accounts ADD COLUMN IF NOT EXISTS isInLocalDb TINYINT(1) NOT NULL DEFAULT 1`,
// ----------------------------------
// MIGRATION 005
`ALTER TABLE accounts DROP COLUMN IF EXISTS isInLocalDb`,
} }
for _, q := range queries { for _, q := range queries {

20
db/savedata.go
View File

@ -98,7 +98,7 @@ func ReadSystemSaveData(uuid []byte) (defs.SystemSaveData, error) {
} }
// delete the one in db // delete the one in db
err = UpdateSystemSaveLocation(uuid) err = DeleteSystemSaveData(uuid)
if err != nil { if err != nil {
return system, err return system, err
} }
@ -259,9 +259,9 @@ func GetSystemSaveFromS3(uuid []byte) (defs.SystemSaveData, error) {
return session, nil return session, nil
} }
func GetLocalAccounts() ([][]byte, error) { func GetLocalSystemAccounts() ([][]byte, error) {
var users [][]byte var users [][]byte
rows, err := handle.Query("SELECT uuid FROM accounts WHERE isInLocalDb = 1) LIMIT 3000") rows, err := handle.Query("SELECT uuid FROM systemSaveData LIMIT 3000")
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -280,17 +280,3 @@ func GetLocalAccounts() ([][]byte, error) {
return users, nil return users, nil
} }
func UpdateSystemSaveLocation(uuid []byte) error {
_, err := handle.Exec("UPDATE accounts SET isInLocalDb = 0 WHERE uuid = ?", uuid)
if err != nil {
return err
}
err = DeleteSystemSaveData(uuid)
if err != nil {
return err
}
return nil
}