Belac/darkstorm-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed crash insertion

Browse Source
This commit is contained in:
Caleb Gardner
2024-06-27 03:10:18 -05:00
parent b58fb76b67
commit 5db8692ec8
1 changed files with 34 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/backend/db/mongo_crash.go
+34 -38
View File
@@ -2,11 +2,10 @@ package db
import (
"context"
"errors"
"fmt"
"strings"
"github.com/CalebQ42/darkstorm-server/internal/backend"
"github.com/google/uuid"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
)
@@ -40,42 +39,39 @@ func (m *MongoCrashTable) IsArchived(ind backend.IndividualCrash) bool {
func (m *MongoCrashTable) InsertCrash(ind backend.IndividualCrash) error {
first, _, _ := strings.Cut(ind.Stack, "\n")
findRes := m.col.FindOne(context.Background(),
res, err := m.col.UpdateOne(context.Background(),
bson.M{"error": ind.Error, "firstLine": first, //filter main report
"individual.stack": ind.Stack, "individual.platform": ind.Platform}, //filter individual
// bson.M{"$inc": bson.M{"individual.count": 1}}, //increment count
"individual": bson.M{"$elemMatch": bson.M{"stack": ind.Stack, "platform": ind.Platform}}}, //filter individual
bson.M{"$inc": bson.M{"individual.$.count": 1}}, //increment count
)
var out map[string]any
findRes.Decode(&out)
fmt.Println(out)
return errors.New("STUFF")
// if err != nil && err != mongo.ErrNoDocuments {
// return err
// }
// if err == mongo.ErrNoDocuments || res.MatchedCount == 0 {
// ind.Count = 1
// res, err = m.col.UpdateMany(context.Background(),
// bson.M{"error": ind.Error, "firstLine": first}, //filter
// bson.M{"$push": bson.M{"individual": ind}}, //Add new individual report
// )
// if err != nil && err != mongo.ErrNoDocuments {
// return err
// }
// if err == mongo.ErrNoDocuments || res.MatchedCount == 0 {
// var id uuid.UUID
// id, err = uuid.NewV7()
// if err != nil {
// return err
// }
// _, err = m.col.InsertOne(context.Background(),
// backend.CrashReport{
// ID: id.String(),
// Error: ind.Error,
// FirstLine: first,
// Individual: []backend.IndividualCrash{ind},
// },
// )
// }
// }
// return err
if err != nil && err != mongo.ErrNoDocuments {
return err
}
if err == mongo.ErrNoDocuments || res.MatchedCount == 0 {
ind.Count = 1
res, err = m.col.UpdateMany(context.Background(),
bson.M{"error": ind.Error, "firstLine": first}, //filter
bson.M{"$push": bson.M{"individual": ind}}, //Add new individual report
)
if err != nil && err != mongo.ErrNoDocuments {
return err
}
if err == mongo.ErrNoDocuments || res.MatchedCount == 0 {
var id uuid.UUID
id, err = uuid.NewV7()
if err != nil {
return err
}
ind.Count = 1
_, err = m.col.InsertOne(context.Background(),
backend.CrashReport{
ID: id.String(),
Error: ind.Error,
FirstLine: first,
Individual: []backend.IndividualCrash{ind},
},
)
}
}
return err
}