From 47a7750caeedc8cb209ad65d6e85e4743ac67f83 Mon Sep 17 00:00:00 2001
From: Steven Vandevelde <steven@tokono.ma>
Date: Sat, 12 Jul 2025 10:08:45 +0200
Subject: [PATCH] =?UTF-8?q?chore:=20=F0=9F=A7=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/pages/configurator/input/_applet.astro    |  2 --
 .../orchestrator/input-cache/_applet.astro    |  4 ----
 src/pages/processor/artwork/_applet.astro     | 19 ++++++++++++++++++-
 src/scripts/common.ts                         |  2 --
 src/scripts/processor/artwork/worker.ts       |  5 ++++-
 5 files changed, 22 insertions(+), 10 deletions(-)

diff --git a/src/pages/configurator/input/_applet.astro b/src/pages/configurator/input/_applet.astro
index fc701a1..2c9e6ae 100644
--- a/src/pages/configurator/input/_applet.astro
+++ b/src/pages/configurator/input/_applet.astro
@@ -32,8 +32,6 @@
 </style>
 
 <script>
-  import type { Applet } from "@web-applets/sdk";
-
   import type { Track } from "@applets/core/types";
   import type { Tasks } from "@scripts/configurator/input/worker";
   import { applet, register, tunnel } from "@scripts/applet/common";
diff --git a/src/pages/orchestrator/input-cache/_applet.astro b/src/pages/orchestrator/input-cache/_applet.astro
index a6412c2..aa6dd08 100644
--- a/src/pages/orchestrator/input-cache/_applet.astro
+++ b/src/pages/orchestrator/input-cache/_applet.astro
@@ -50,15 +50,11 @@
       worker: true,
     });
 
-    console.log("CONTEXTUALIZED");
-
     const tracks = await input.sendAction<Track[]>("list", cachedTracks, {
       timeoutDuration: 60000 * 60 * 24,
       worker: true,
     });
 
-    console.log("LISTED", tracks);
-
     // Process
     const tracksWithMetadata = await tracks.reduce(
       async (promise: Promise<Track[]>, track: Track) => {
diff --git a/src/pages/processor/artwork/_applet.astro b/src/pages/processor/artwork/_applet.astro
index 5b7e1dc..ea2cb73 100644
--- a/src/pages/processor/artwork/_applet.astro
+++ b/src/pages/processor/artwork/_applet.astro
@@ -1,4 +1,6 @@
 <script>
+  import type { Tasks } from "@scripts/processor/artwork/worker";
+  import type { ArtworkRequest } from "./types";
   import { register } from "@scripts/applet/common";
   import { endpoint, SharedWorker } from "@scripts/common";
   import manifest from "./_manifest.json";
@@ -6,7 +8,7 @@
   ////////////////////////////////////////////
   // SETUP
   ////////////////////////////////////////////
-  const worker = endpoint(
+  const worker = endpoint<Tasks>(
     new SharedWorker(new URL("../../../scripts/processor/artwork/worker", import.meta.url), {
       type: "module",
       name: manifest.name,
@@ -15,4 +17,19 @@
 
   // Register
   const context = register({ worker });
+
+  ////////////////////////////////////////////
+  // ACTIONS
+  ////////////////////////////////////////////
+
+  async function artwork(request: ArtworkRequest) {
+    return await worker.artwork(request);
+  }
+
+  async function supply(items: ArtworkRequest[]) {
+    return await worker.supply(items);
+  }
+
+  context.setActionHandler("artwork", artwork);
+  context.setActionHandler("supply", supply);
 </script>
diff --git a/src/scripts/common.ts b/src/scripts/common.ts
index 2ed4ed6..4723004 100644
--- a/src/scripts/common.ts
+++ b/src/scripts/common.ts
@@ -198,8 +198,6 @@ function _listen<A extends Record<string, any>>(actions: A) {
 function _manage<C extends Record<string, any>>(
   connections: Record<string, PromiseWithResolvers<Comlink.Remote<C>>>,
 ) {
-  console.log(connections);
-
   return (connectionId: string, workerPort: MessagePort) => {
     let conn = connections[connectionId];
     const remote = endpoint<C>(workerPort);
diff --git a/src/scripts/processor/artwork/worker.ts b/src/scripts/processor/artwork/worker.ts
index 6637b52..73637a2 100644
--- a/src/scripts/processor/artwork/worker.ts
+++ b/src/scripts/processor/artwork/worker.ts
@@ -18,7 +18,10 @@ const actions = {
   supply,
 };
 
-provide({ actions });
+const { tasks } = provide({ actions, tasks: actions });
+
+export type Actions = typeof actions;
+export type Tasks = typeof tasks;
 
 ////////////////////////////////////////////
 // ACTIONS
-- 
2.51.2