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

Functions for Database interactions

Browse Source
This commit is contained in:
Frutescens 2024-06-04 15:40:02 -07:00
parent 1f05a7bda5
commit 8577d7978b
3 changed files with 40 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
api/endpoints.go
View File

@ -30,6 +30,8 @@ import (
"github.com/pagefaultgames/rogueserver/api/savedata"
"github.com/pagefaultgames/rogueserver/db"
"github.com/pagefaultgames/rogueserver/defs"
"/api/savedata"
)
/*
@ -574,7 +576,7 @@ func handleGetRunHistory(w http.ResponseWriter, r *http.Request) {
}
var runHistory any
runHistory, err = savadata.Get(uuid,1);
runHistory, err = savedata.GetRunHistoryData(uuid);
if errors.Is(err, sql.ErrNoRows) {
http.Error(w, err.Error(), http.StatusNotFound)
@ -585,6 +587,7 @@ func handleGetRunHistory(w http.ResponseWriter, r *http.Request) {
httpError(w, r, err, http.StatusInternalServerError)
return
}
writeJSON(w, r, runHistory)
}
@ -602,7 +605,7 @@ func handleRunHistory(w http.ResponseWriter, r *http.Request) {
return
}
err = db.UpdateRunHistory(uuid, data)
err = savedata.UpdateRunHistoryData(uuid, data)
if err != nil {
httpError(w, r, err, http.StatusInternalServerError)
return

33
db/savedata.go
View File

@ -153,3 +153,36 @@ func DeleteSessionSaveData(uuid []byte, slot int) error {
return nil
}
func GetRunHistoryData(uuid []byte) (defs.RunHistoryData, error) {
var runHistory defs.RunHistoryData
var err error
var data []byte
err = handle.QueryRow("SELECT data FROM runHistoryData WHERE uuid = ?", uuid).Scan(&data)
if err != nil {
return runHistory, err
}
err = gob.NewDecoder(bytes.NewReader(data)).Decode(&runHistory)
if err != nil {
return runHistory, err
}
return runHistory, err
}
func UpdateRunHistoryData(uuid []byte, data defs.RunHistoryData) error {
var buf bytes.Buffer
var err error
err = gob.NewEncoder(&buf).Encode(data)
if err != nil {
return err
}
_, err = handle.Exec("INSERT INTO runHistoryData (uuid, data, timestamp) VALUES (?, ?, UTC_TIMESTAMP()) ON DUPLICATE KEY UPDATE data = ?, timestamp = UTC_TIMESTAMP()", uuid, buf.Bytes(), buf.Bytes())
if err != nil {
return err
}
return nil
}

2
defs/savedata.go
View File

@ -139,3 +139,5 @@ type SessionHistoryData struct {
}
type SessionHistoryResult int
type RunHistoryData map[int]interface{}