From 9e3fe1dbff50c2be328fb61fb86b4ecd5457cd31 Mon Sep 17 00:00:00 2001
From: Steven Vandevelde <steven@tokono.ma>
Date: Sat, 21 Jun 2025 16:22:16 +0200
Subject: [PATCH] refactor: only load input applets when needed

---
 src/pages/configurator/input/_applet.astro | 111 ++++++++-------------
 1 file changed, 44 insertions(+), 67 deletions(-)

diff --git a/src/pages/configurator/input/_applet.astro b/src/pages/configurator/input/_applet.astro
index b91762a..cf35b17 100644
--- a/src/pages/configurator/input/_applet.astro
+++ b/src/pages/configurator/input/_applet.astro
@@ -37,70 +37,63 @@
 <script>
   import type { Track } from "@applets/core/types.d.ts";
   import { applet, register } from "@scripts/applet/common";
+  import type { Applet } from "@web-applets/sdk";
 
   ////////////////////////////////////////////
   // SETUP
   ////////////////////////////////////////////
   const context = register();
 
-  // Applet connections
-  const input = {
-    nativeFs: applet("../../input/native-fs"),
-    opensubsonic: applet("../../input/opensubsonic"),
-    s3: applet("../../input/s3"),
+  ////////////////////////////////////////////
+  // CONNECTIONS
+  ////////////////////////////////////////////// Applet connections
+  const CONNECTIONS = {
+    "file+local": "../../input/native-fs",
+    opensubsonic: "../../input/opensubsonic",
+    s3: "../../input/s3",
   };
 
+  type Scheme = keyof typeof CONNECTIONS;
+
+  const connections: Record<Scheme, Promise<Applet> | undefined> = {
+    "file+local": undefined,
+    opensubsonic: undefined,
+    s3: undefined,
+  };
+
+  async function connection(scheme: Scheme) {
+    connections[scheme] = connections[scheme] ?? applet(CONNECTIONS[scheme]);
+    return connections[scheme];
+  }
+
+  function isSupportedScheme(scheme: string): scheme is Scheme {
+    return !!CONNECTIONS[scheme as Scheme];
+  }
+
   ////////////////////////////////////////////
   // ACTIONS
   ////////////////////////////////////////////
   const contextualize = async (tracks: Track[]) => {
-    const opensubsonic = await input.opensubsonic;
-    const s3 = await input.s3;
-
     const groups = await groupTracksPerScheme(tracks);
+    const promises = Object.keys(groups).map(async (scheme: string) => {
+      if (!isSupportedScheme(scheme)) return;
+      const conn = await connection(scheme);
+      await conn.sendAction("contextualize", groups[scheme], { timeoutDuration: 60000 * 5 });
+    });
 
-    await Promise.all([
-      opensubsonic.sendAction(
-        "contextualize",
-        groups[opensubsonic.manifest.input_properties.scheme],
-        { timeoutDuration: 60000 * 5 },
-      ),
-      s3.sendAction("contextualize", groups[s3.manifest.input_properties.scheme], {
-        timeoutDuration: 60000 * 5,
-      }),
-    ]);
+    await Promise.all(promises);
   };
 
   const list = async (cachedTracks: Track[] = []) => {
-    const [nativeFs, opensubsonic, s3] = [
-      await input.nativeFs,
-      await input.opensubsonic,
-      await input.s3,
-    ];
-
     const groups = await groupTracksPerScheme(cachedTracks);
 
     const promises = Object.entries(groups).map(
       async ([scheme, cachedTracksGroup]: [string, Track[]]) => {
-        switch (scheme) {
-          case nativeFs.manifest.input_properties.scheme:
-            return await nativeFs.sendAction("list", cachedTracksGroup, {
-              timeoutDuration: 60000 * 60 * 24,
-            });
-
-          case opensubsonic.manifest.input_properties.scheme:
-            return await opensubsonic.sendAction("list", cachedTracksGroup, {
-              timeoutDuration: 60000 * 60 * 24,
-            });
-
-          case s3.manifest.input_properties.scheme:
-            return await s3.sendAction("list", cachedTracksGroup, {
-              timeoutDuration: 60000 * 60 * 24,
-            });
-
-          default:
-            return cachedTracks;
-        }
+        if (!isSupportedScheme(scheme)) return cachedTracksGroup;
+        const conn = await connection(scheme);
+        return await conn.sendAction("list", cachedTracksGroup, {
+          timeoutDuration: 60000 * 60 * 24,
+        });
       },
     );
 
@@ -112,25 +105,9 @@
 
   const resolve = async (args: { method: string; uri: string }) => {
     const scheme = args.uri.split(":", 1)[0];
-    const [nativeFs, opensubsonic, s3] = [
-      await input.nativeFs,
-      await input.opensubsonic,
-      await input.s3,
-    ];
-
-    switch (scheme) {
-      case nativeFs.manifest.input_properties.scheme:
-        return await nativeFs.sendAction("resolve", args);
-
-      case opensubsonic.manifest.input_properties.scheme:
-        return await opensubsonic.sendAction("resolve", args);
-
-      case s3.manifest.input_properties.scheme:
-        return await s3.sendAction("resolve", args);
-
-      default:
-        return undefined;
-    }
+    if (!isSupportedScheme(scheme)) return undefined;
+    const conn = await connection(scheme);
+    return await conn.sendAction("resolve", args);
   };
 
   context.setActionHandler("contextualize", contextualize);
@@ -146,11 +123,11 @@
         const scheme = track.uri.split(":", 1)[0];
         return { ...acc, [scheme]: [...(acc[scheme] || []), track] };
       },
-      {
-        [(await input.nativeFs).manifest.input_properties.scheme]: [],
-        [(await input.opensubsonic).manifest.input_properties.scheme]: [],
-        [(await input.s3).manifest.input_properties.scheme]: [],
-      },
+      Object.fromEntries(
+        Object.entries(CONNECTIONS).map(([k, _v]) => {
+          return [k, []];
+        }),
+      ),
     );
   }
 </script>
-- 
2.51.2