shylie/serra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redo update

Browse Source
This commit is contained in:
Florian Baumann 2022-01-07 12:36:48 +01:00
parent 3ee4f5451d
commit b15db42f55
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/serra/root.go
View File

@ -196,37 +196,32 @@ func Update() error {
setscoll := &Collection{client.Database("serra").Collection("sets")} setscoll := &Collection{client.Database("serra").Collection("sets")}
sets, _ := fetch_sets() sets, _ := fetch_sets()
for _, set := range sets.Data { for i, set := range sets.Data {
// setscoll.storage_remove(bson.M{"_id": ""}) fmt.Printf("Updating (%d/%d): %s...\n", i+1, len(sets.Data), set.Name)
// TODO: lol, no errorhandling, no dup key handling. but its fine. for now. // TODO: lol, no errorhandling, no dup key handling. but its fine. for now.
setscoll.storage_add_set(&set) setscoll.storage_add_set(&set)
} }
return nil
// update cards // update cards
coll := &Collection{client.Database("serra").Collection("cards")} coll := &Collection{client.Database("serra").Collection("cards")}
sort := bson.D{{"_id", 1}} cards, _ := coll.storage_find(bson.D{{}}, bson.D{{"_id", 1}})
filter := bson.D{{}}
cards, _ := coll.storage_find(filter, sort)
for i, card := range cards { for i, card := range cards {
fmt.Printf("Updating (%d/%d): %s (%s)...\n", i+1, len(cards), card.Name, card.SetName) fmt.Printf("Updating (%d/%d): %s (%s)...\n", i+1, len(cards), card.Name, card.SetName)
updated_card, err := fetch_card(fmt.Sprintf("%s/%d", card.Set, card.CollectorNumber)) updated_card, err := fetch_card(fmt.Sprintf("%s/%s", card.Set, card.CollectorNumber))
if err != nil { if err != nil {
LogMessage(fmt.Sprintf("%v", err), "red") LogMessage(fmt.Sprintf("%v", err), "red")
continue continue
} }
filter := bson.M{"_id": bson.M{"$eq": card.ID}}
update := bson.M{ update := bson.M{
"$set": bson.M{"serra_updated": primitive.NewDateTimeFromTime(time.Now()), "prices": updated_card.Prices, "collectornumber": updated_card.CollectorNumber}, "$set": bson.M{"serra_updated": primitive.NewDateTimeFromTime(time.Now()), "prices": updated_card.Prices, "collectornumber": updated_card.CollectorNumber},
"$push": bson.M{"serra_prices": bson.M{"date": primitive.NewDateTimeFromTime(time.Now()), "$push": bson.M{"serra_prices": bson.M{"date": primitive.NewDateTimeFromTime(time.Now()),
"value": updated_card.Prices.Eur}}} "value": updated_card.Prices.Eur}},
}
coll.storage_update(filter, update) coll.storage_update(bson.M{"_id": bson.M{"$eq": card.ID}}, update)
} }
return nil return nil
} }