From 9ad04cd33fd6616079b2b9de7e38396d3cd730f9 Mon Sep 17 00:00:00 2001
From: KernelDeimos <eric.alex.dube@gmail.com>
Date: Fri, 28 Jun 2024 17:39:55 -0400
Subject: [PATCH] prereq: make it possible to access storage without context
 init

---
 packages/backend/src/CoreModule.js            |  3 ++
 .../src/filesystem/ll_operations/ll_write.js  |  3 +-
 packages/backend/src/helpers.js               |  4 ++-
 .../src/services/LocalDiskStorageService.js   |  3 ++
 .../backend/src/services/MountpointService.js | 32 +++++++++++++++++++
 5 files changed, 43 insertions(+), 2 deletions(-)
 create mode 100644 packages/backend/src/services/MountpointService.js

diff --git a/packages/backend/src/CoreModule.js b/packages/backend/src/CoreModule.js
index dc8fbb9ea..c04d6ae68 100644
--- a/packages/backend/src/CoreModule.js
+++ b/packages/backend/src/CoreModule.js
@@ -292,6 +292,9 @@ const install = async ({ services, app, useapi }) => {
     
     const { PermissionAPIService } = require('./services/PermissionAPIService');
     services.registerService('__permission-api', PermissionAPIService);
+
+    const { MountpointService } = require('./services/MountpointService');
+    services.registerService('mountpoint', MountpointService);
 }
 
 const install_legacy = async ({ services }) => {
diff --git a/packages/backend/src/filesystem/ll_operations/ll_write.js b/packages/backend/src/filesystem/ll_operations/ll_write.js
index fc4359a21..cc83a7f15 100644
--- a/packages/backend/src/filesystem/ll_operations/ll_write.js
+++ b/packages/backend/src/filesystem/ll_operations/ll_write.js
@@ -49,7 +49,8 @@ class LLWriteBase extends LLFilesystemOperation {
         const errors = svc.get('error-service').create(log);
         const svc_event = svc.get('event');
 
-        const storage = Context.get('storage');
+        const svc_mountpoint = svc.get('mountpoint');
+        const storage = svc_mountpoint.get_storage();
 
         bucket        ??= config.s3_bucket;
         bucket_region ??= config.s3_region;
diff --git a/packages/backend/src/helpers.js b/packages/backend/src/helpers.js
index 575632ff3..8205bb14a 100644
--- a/packages/backend/src/helpers.js
+++ b/packages/backend/src/helpers.js
@@ -1057,7 +1057,9 @@ async function deleteUser(user_id){
         for(let i=0; i<files.length; i++){
             // init S3 SDK
             const svc_fs = Context.get('services').get('filesystem');
-            const storage = Context.get('storage');
+            const svc_mountpoint =
+                Context.get('services').get('mountpoint');
+            const storage = svc_mountpoint.get_storage();
             const op_delete = storage.create_delete();
             await op_delete.run({
                 node: await svc_fs.node(new NodeUIDSelector(files[i].uuid))
diff --git a/packages/backend/src/services/LocalDiskStorageService.js b/packages/backend/src/services/LocalDiskStorageService.js
index 0004fbcbb..5b9213838 100644
--- a/packages/backend/src/services/LocalDiskStorageService.js
+++ b/packages/backend/src/services/LocalDiskStorageService.js
@@ -31,6 +31,9 @@ class LocalDiskStorageService extends BaseService {
         const svc_contextInit = this.services.get('context-init');
         const storage = new LocalDiskStorageStrategy({ services: this.services });
         svc_contextInit.register_value('storage', storage);
+        
+        const svc_mountpoint = this.services.get('mountpoint');
+        svc_mountpoint.set_storage(storage);
     }
 
     async _init () {
diff --git a/packages/backend/src/services/MountpointService.js b/packages/backend/src/services/MountpointService.js
new file mode 100644
index 000000000..a8a24b5bb
--- /dev/null
+++ b/packages/backend/src/services/MountpointService.js
@@ -0,0 +1,32 @@
+// const Mountpoint = o => ({ ...o });
+
+const BaseService = require("./BaseService");
+
+/**
+ * This will eventually be a service which manages the storage
+ * backends for mountpoints.
+ * 
+ * For the moment, this is a way to access the storage backend
+ * in situations where ContextInitService isn't able to
+ * initialize a context.
+ */
+class MountpointService extends BaseService {
+    async _init () {
+        // this.mountpoints_ = {};
+        
+        // Temporary solution - we'll develop this incrementally
+        this.storage_ = null;
+    }
+    
+    // Temporary solution - we'll develop this incrementally
+    set_storage (storage) {
+        this.storage_ = storage;
+    }
+    get_storage () {
+        return this.storage_;
+    }
+}
+
+module.exports = {
+    MountpointService,
+};