bulk import source urls

package.json

@@ -11,7 +11,8 @@
     "start_dev": "cross-env NODE_ENV=development node dist/server/index.js",
     "import_images": "cross-env NODE_ENV=development node dist/server/bulk_import_images/bulk_import_images.js",
     "import_tags": "cross-env NODE_ENV=development node dist/server/bulk_import_images/bulk_import_tags.js",
-    "import_captions": "cross-env NODE_ENV=development node dist/server/bulk_import_images/bulk_import_captions.js"
+    "import_captions": "cross-env NODE_ENV=development node dist/server/bulk_import_images/bulk_import_captions.js",
+    "import_source_urls": "cross-env NODE_ENV=development node dist/server/bulk_import_images/bulk_import_source_urls.js"
   },
   "dependencies": {
     "@emotion/cache": "^11.10.1",

src/server/bulk_import_images/bulk_import_source_urls.ts

@@ -0,0 +1,18 @@
+import fs from 'fs'
+import path from 'path'
+import db_ops from "../helpers/db_ops"
+import config from "../../config/config"
+import cliProgress from "cli-progress"
+const fsPromises = fs.promises;
+const bar1 = new cliProgress.SingleBar({}, cliProgress.Presets.shades_classic)
+
+async function import_source_urls() {
+    const img_source_urls = JSON.parse(await fsPromises.readFile(path.join(config.root_path,"import","id_source_url.txt"),'utf8'))
+    bar1.start(img_source_urls.length, 0)
+    for (const img of img_source_urls) {
+       await db_ops.image_ops.set_source_url_to_image_by_id(img.id,img.source_url)
+       bar1.increment()
+    }
+    process.exit()
+}
+import_source_urls()

src/server/helpers/db_ops.ts

@@ -109,6 +109,10 @@ async function set_caption_to_image_by_id(id: number, caption: string) {
     await IMAGES_COLLECTION.updateOne({ id: id },  { $set: { caption: caption } })
 }
 
+async function set_source_url_to_image_by_id(id: number, source_url: string) {
+    await IMAGES_COLLECTION.updateOne({ id: id },  { $set: { source_url: source_url } })
+}
+
 async function update_image_data_by_id(id: number, update: Record<string, unknown>) {
     return IMAGES_COLLECTION.updateOne({ id: id }, { $set: update })
 }
@@ -338,7 +342,8 @@ export default {
         check_if_image_exists_by_id,
         update_image_data_by_id,
         add_tags_to_image_by_id,
-        set_caption_to_image_by_id
+        set_caption_to_image_by_id,
+        set_source_url_to_image_by_id
     },
     password_recovery: {
         update_user_password_by_id,