From c2fe3007e5c7ec3ef96b77e9b6ab3cf40c6477d8 Mon Sep 17 00:00:00 2001
From: kitt <catgirl@catgirlin.space>
Date: Wed, 1 Mar 2023 09:07:45 -0500
Subject: [PATCH] add mongodb migrations for older battles

---
 scripts/convert-old-mongodb-battles.ts | 47 ++++++++++++++++++++++++++
 1 file changed, 47 insertions(+)
 create mode 100644 scripts/convert-old-mongodb-battles.ts

diff --git a/scripts/convert-old-mongodb-battles.ts b/scripts/convert-old-mongodb-battles.ts
new file mode 100644
index 0000000..4c95bbe
--- /dev/null
+++ b/scripts/convert-old-mongodb-battles.ts
@@ -0,0 +1,47 @@
+import { MongoDB } from "../deps.ts";
+import { DEFAULT_ENV } from "../src/env.ts";
+import { MongoDBExporter } from "../src/exporters/mongodb.ts";
+import { FileStateBackend, Profile } from "../src/state.ts";
+
+const OLD_BATTLES_END_DATE = new Date('2023-02-28T03:42:47.000+00:00');
+
+const env = DEFAULT_ENV;
+const stateBackend = new FileStateBackend("./profile.json");
+const profile = new Profile({ stateBackend, env });
+await profile.readState();
+
+if (!profile.state.mongoDbUri) {
+	console.error("MongoDB URI not set");
+	Deno.exit(1);
+}
+
+const mongoDbClient = new MongoDB.MongoClient(profile.state.mongoDbUri);
+const battlesCollection = mongoDbClient.db("splashcat").collection("battles");
+
+const filter = {
+	"exportDate": {
+		"$lte": OLD_BATTLES_END_DATE,
+	},
+	"gameId": undefined,
+};
+
+const cursor = battlesCollection.find(filter);
+
+const oldDocuments = await battlesCollection.countDocuments(filter);
+
+console.log(`Found ${oldDocuments} old battles to update...`);
+
+for await (const doc of cursor) {
+	const { splatNetData, _id } = doc;
+
+	const splatNetId = splatNetData.id;
+	const uniqueId = MongoDBExporter.getGameId(splatNetId);
+
+	await battlesCollection.updateOne({ _id }, { "$set": {
+		gameId: uniqueId,
+	}});
+
+	console.log(`Updated ${splatNetId} to ${uniqueId}`);
+}
+
+console.log("Done!")
\ No newline at end of file