Leahnaya/super-mario-maker
1
0
Fork 0
mirror of https://github.com/PretendoNetwork/super-mario-maker.git synced 2026-08-26 02:34:05 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

switched ratings to counter type

Browse Source
This commit is contained in:
Jonathan Barrow
2021-10-02 22:00:35 -04:00
parent 7062297bb5
commit 435a3d83b3
3 changed files with 52 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
database.go
View File

@@ -59,15 +59,11 @@ func connectCassandra() {
size int,
creation_date bigint,
update_date bigint,
stars int,
world_record_first_pid int,
world_record_pid int,
world_record_creation_date bigint,
world_record_update_date bigint,
world_record int,
attempts int,
failures int,
completions int,
meta_binary blob,
flag int,
extra_data list<text>,
@@ -77,6 +73,16 @@ func connectCassandra() {
log.Fatal(err)
}
if err := cassandraClusterSession.Query(`CREATE TABLE IF NOT EXISTS pretendo_smm.ratings (
data_id bigint PRIMARY KEY,
stars counter,
attempts counter,
failures counter,
completions int
)`).Exec(); err != nil {
log.Fatal(err)
}
if err := cassandraClusterSession.Query(`CREATE TABLE IF NOT EXISTS pretendo_smm.buffer_queues (
id uuid PRIMARY KEY,
data_id bigint,
@@ -162,7 +168,7 @@ func setDataStoreIDGeneratorLastID(nodeID int, value uint32) {
}
}
func insertCourseDataRow(courseID uint64, ownerPID uint32, size uint32, name string, flag uint32, extraData []string, dataType uint16, period uint16) {
func initializeCourseData(courseID uint64, ownerPID uint32, size uint32, name string, flag uint32, extraData []string, dataType uint16, period uint16) {
if err := cassandraClusterSession.Query(`INSERT INTO pretendo_smm.courses(
data_id,
owner_pid,
@@ -173,13 +179,11 @@ func insertCourseDataRow(courseID uint64, ownerPID uint32, size uint32, name str
playable,
creation_date,
update_date,
stars,
world_record_first_pid,
world_record_pid,
world_record_creation_date,
world_record_update_date,
attempts,
failures,
completions,
world_record,
data_type,
period
)
@@ -198,14 +202,16 @@ func insertCourseDataRow(courseID uint64, ownerPID uint32, size uint32, name str
0,
0,
0,
0,
0,
?,
?
) IF NOT EXISTS`,
courseID, ownerPID, size, name, flag, extraData, dataType, period).Exec(); err != nil {
log.Fatal(err)
}
if err := cassandraClusterSession.Query(`UPDATE pretendo_smm.ratings SET stars=stars+0, attempts=attempts+0, failures=failures+0, completions=completions+0 WHERE data_id=?`, courseID).Exec(); err != nil {
log.Fatal(err)
}
}
func updateCourseMetaBinary(courseID uint64, metaBinary []byte) {
@@ -224,23 +230,35 @@ func getCourseMetadatasByLimit(limit uint32) []*CourseMetadata {
var sliceMap []map[string]interface{}
var err error
if sliceMap, err = cassandraClusterSession.Query(`SELECT stars, data_id, owner_pid, size, name, meta_binary, flag, data_type, period FROM pretendo_smm.courses LIMIT ?`, limit).Iter().SliceMap(); err != nil {
if sliceMap, err = cassandraClusterSession.Query(`SELECT data_id, owner_pid, size, name, meta_binary, flag, data_type, period FROM pretendo_smm.courses LIMIT ?`, limit).Iter().SliceMap(); err != nil {
log.Fatal(err)
}
courseMetadatas := make([]*CourseMetadata, 0)
for i := 0; i < len(sliceMap); i++ {
dataID := uint64(sliceMap[i]["data_id"].(int64))
var stars uint32
var attempts uint32
var failures uint32
var completions uint32
_ = cassandraClusterSession.Query(`SELECT stars, attempts, failures, completions FROM pretendo_smm.ratings WHERE data_id=?`, dataID).Scan(&stars, &attempts, &failures, &completions)
courseMetadata := &CourseMetadata{
Stars: uint32(sliceMap[i]["stars"].(int)),
DataID: uint64(sliceMap[i]["data_id"].(int64)),
OwnerPID: uint32(sliceMap[i]["owner_pid"].(int)),
Size: uint32(sliceMap[i]["size"].(int)),
Name: sliceMap[i]["name"].(string),
MetaBinary: sliceMap[i]["meta_binary"].([]byte),
Flag: uint32(sliceMap[i]["flag"].(int)),
DataType: uint16(sliceMap[i]["data_type"].(int16)),
Period: uint16(sliceMap[i]["period"].(int16)),
DataID: dataID,
OwnerPID: uint32(sliceMap[i]["owner_pid"].(int)),
Size: uint32(sliceMap[i]["size"].(int)),
Name: sliceMap[i]["name"].(string),
MetaBinary: sliceMap[i]["meta_binary"].([]byte),
Stars: stars,
Attempts: attempts,
Failures: failures,
Completions: completions,
Flag: uint32(sliceMap[i]["flag"].(int)),
DataType: uint16(sliceMap[i]["data_type"].(int16)),
Period: uint16(sliceMap[i]["period"].(int16)),
}
courseMetadatas = append(courseMetadatas, courseMetadata)

2
prepare_post_object.go
View File

@@ -28,7 +28,7 @@ func preparePostObject(err error, client *nex.Client, callID uint32, param *nexp
dataID := dataStoreIDGenerator.Next()
setDataStoreIDGeneratorLastID(nodeID, dataStoreIDGenerator.Value)
insertCourseDataRow(dataID, client.PID(), param.Size, param.Name, param.Flag, param.ExtraData, param.DataType, param.Period)
initializeCourseData(dataID, client.PID(), param.Size, param.Name, param.Flag, param.ExtraData, param.DataType, param.Period)
if param.DataType != 1 { // 1 is Mii data, assume other values are course meta data
updateCourseMetaBinary(dataID, param.MetaBinary)

21
types.go
View File

@@ -3,15 +3,18 @@ package main
import "github.com/PretendoNetwork/nex-go"
type CourseMetadata struct {
Stars uint32
DataID uint64
OwnerPID uint32
Size uint32
Name string
MetaBinary []byte
Flag uint32
DataType uint16
Period uint16
DataID uint64
OwnerPID uint32
Size uint32
Name string
MetaBinary []byte
Stars uint32
Attempts uint32
Failures uint32
Completions uint32
Flag uint32
DataType uint16
Period uint16
}
type CourseWorldRecord struct {