From fe9dbb871d613d6a55873bd317d0d1af13a50ad8 Mon Sep 17 00:00:00 2001
From: Tyler Schicke <tyler_schicke@brown.edu>
Date: Wed, 22 May 2019 13:34:59 -0400
Subject: Tried script

---
 src/server/remapUrl.ts | 59 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 src/server/remapUrl.ts

(limited to 'src')

diff --git a/src/server/remapUrl.ts b/src/server/remapUrl.ts
new file mode 100644
index 000000000..90044738f
--- /dev/null
+++ b/src/server/remapUrl.ts
@@ -0,0 +1,59 @@
+import { Database } from "./database";
+import { Search } from "./Search";
+import * as path from 'path';
+
+const suffixMap: { [type: string]: true } = {
+    "video": true,
+    "pdf": true,
+    "audio": true,
+    "web": true
+};
+
+async function update() {
+    await new Promise(res => setTimeout(res, 10));
+    console.log("update");
+    const cursor = await Database.Instance.query({});
+    console.log("Cleared");
+    const updates: [string, any][] = [];
+    function updateDoc(doc: any) {
+        if (doc.__type !== "Doc") {
+            return;
+        }
+        const fields = doc.fields;
+        if (!fields) {
+            return;
+        }
+        const update: any = {
+        };
+        let dynfield = false;
+        for (const key in fields) {
+            const value = fields[key];
+            if (value && value.__type && suffixMap[value.__type]) {
+                const url = new URL(value.url);
+                if (url.href.includes("azure")) {
+                    dynfield = true;
+
+                    update.$set = { ["fields." + key]: { url: `${url.protocol}//localhost:1050${url.pathname}`, __type: "image" } };
+                }
+            }
+        }
+        if (dynfield) {
+            updates.push([doc._id, update]);
+        }
+    }
+    await cursor.forEach(updateDoc);
+    await Promise.all(updates.map(doc => {
+        console.log(doc[0], doc[1]);
+        return new Promise(res => Database.Instance.update(doc[0], doc[1], () => {
+            console.log("wrote " + JSON.stringify(doc[1]));
+            res();
+        }));
+    }));
+    console.log("Done");
+    // await Promise.all(updates.map(update => {
+    //     return limit(() => Search.Instance.updateDocument(update));
+    // }));
+    cursor.close();
+}
+
+update();
-- 
cgit v1.2.3-70-g09d2