releaseb stop permacharupdates for a sec

Sammers21 · Sep 21, 2023 · a4242da · a4242da
1 parent 72adca9
commit a4242da
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 3 deletions.
diff --git a/.gitignore b/.gitignore
@@ -5,3 +5,4 @@ bin/
 .vscode/
 out/
 src/io/github/sammers/.DS_Store
+docker-compose.yml
diff --git a/src/io/github/sammers/pla/db/DB.java b/src/io/github/sammers/pla/db/DB.java
@@ -66,8 +66,15 @@ private Maybe<Snapshot> find(String bracket, FindOptions fopts, JsonObject opts)
 
     public Maybe<MongoClientBulkWriteResult> bulkUpdateChars(List<WowAPICharacter> characters) {
         List<BulkOperation> operations = characters.stream()
-                .map(character -> BulkOperation.createUpdate(new JsonObject().put("id", character.id()), character.toJson()))
-                .toList();
+            .map(character -> {
+                    BulkOperation op = BulkOperation.createUpdate(
+                        new JsonObject().put("id", character.id()),
+                        new JsonObject().put("$set", character.toJson())
+                    );
+                    op.setUpsert(true);
+                    return op;
+                }
+            ).toList();
         return mongoClient.rxBulkWrite("profile", operations);
     }
 

diff --git a/src/io/github/sammers/pla/logic/Ladder.java b/src/io/github/sammers/pla/logic/Ladder.java
@@ -580,7 +580,7 @@ public Completable loadWowCharApiData(String region) {
                             charSearchIndex.insertNickNames(new SearchResult(character.fullName(), character.region(), character.clazz()));
                         });
                         log.info("Character data size={} for region={} has been loaded to cache in {} ms", characters.size(), region, (System.nanoTime() - tick) / 1000000);
-                        VTHREAD_SCHEDULER.schedulePeriodicallyDirect(() -> charUpdater.updateCharsInfinite(region).subscribe(), 0, 24, TimeUnit.HOURS);
+//                        VTHREAD_SCHEDULER.schedulePeriodicallyDirect(() -> charUpdater.updateCharsInfinite(region).subscribe(), 0, 24, TimeUnit.HOURS);
                         emitter.onComplete();
                     });
                 }));