mirror of
https://github.com/pagefaultgames/rogueserver.git
synced 2025-04-02 02:57:15 +08:00
Server Side code for Run History
This commit is contained in:
parent
50d93a737f
commit
7e30d640c3
@ -565,6 +565,52 @@ func legacyHandleSaveData(w http.ResponseWriter, r *http.Request) {
|
||||
writeJSON(w, r, save)
|
||||
}
|
||||
|
||||
//functions for run history
|
||||
func handleGetRunHistory(w http.ResponseWriter, r *http.Request) {
|
||||
uuid, err := uuidFromRequest(r)
|
||||
if err != nil {
|
||||
httpError(w, r, err, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
var runHistory any
|
||||
runHistory, err = db.GetRunHistoryData(uuid);
|
||||
|
||||
if errors.Is(err, sql.ErrNoRows) {
|
||||
http.Error(w, err.Error(), http.StatusNotFound)
|
||||
return
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
httpError(w, r, err, http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
|
||||
writeJSON(w, r, runHistory)
|
||||
}
|
||||
|
||||
func handleRunHistory(w http.ResponseWriter, r *http.Request) {
|
||||
uuid, err := uuidFromRequest(r)
|
||||
if err != nil {
|
||||
httpError(w, r, err, http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
var data defs.RunHistoryData
|
||||
err = json.NewDecoder(r.Body).Decode(&data)
|
||||
if err != nil {
|
||||
httpError(w, r, fmt.Errorf("failed to decode request body: %s", err), http.StatusBadRequest)
|
||||
return
|
||||
}
|
||||
|
||||
err = db.UpdateRunHistoryData(uuid, data)
|
||||
if err != nil {
|
||||
httpError(w, r, err, http.StatusInternalServerError)
|
||||
return
|
||||
}
|
||||
w.WriteHeader(http.StatusOK)
|
||||
}
|
||||
|
||||
type CombinedSaveData struct {
|
||||
System defs.SystemSaveData `json:"system"`
|
||||
Session defs.SessionSaveData `json:"session"`
|
||||
|
5
db/db.go
5
db/db.go
@ -92,6 +92,11 @@ func setupDb(tx *sql.Tx) error {
|
||||
|
||||
`ALTER TABLE sessions DROP COLUMN IF EXISTS active`,
|
||||
`CREATE TABLE IF NOT EXISTS activeClientSessions (uuid BINARY(16) NOT NULL PRIMARY KEY, clientSessionId VARCHAR(32) NOT NULL, FOREIGN KEY (uuid) REFERENCES accounts (uuid) ON DELETE CASCADE ON UPDATE CASCADE)`,
|
||||
|
||||
|
||||
// ----------------------------------
|
||||
//Migration 002
|
||||
`CREATE TABLE IF NOT EXISTS runHistoryData (uuid BINARY(16) PRIMARY KEY, data LONGBLOB, timestamp TIMESTAMP, FOREIGN KEY (uuid) REFERENCES accounts (uuid) ON DELETE CASCADE ON UPDATE CASCADE)`,
|
||||
}
|
||||
|
||||
for _, q := range queries {
|
||||
|
@ -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
|
||||
}
|
@ -139,3 +139,5 @@ type SessionHistoryData struct {
|
||||
}
|
||||
|
||||
type SessionHistoryResult int
|
||||
|
||||
type RunHistoryData map[string]interface{}
|
||||
|
Loading…
x
Reference in New Issue
Block a user