From b56d46b5b29be3c7ee87310f737d0e72071e2eef Mon Sep 17 00:00:00 2001
From: Meta Vens <rwvens@hotmail.com>
Date: Wed, 15 Jul 2026 21:52:06 +0100
Subject: [PATCH] Load worker transport from packaged CultLib organs

---
 apps/worker/src/index.ts | 24 +++++++++++++++++++++---
 1 file changed, 21 insertions(+), 3 deletions(-)

diff --git a/apps/worker/src/index.ts b/apps/worker/src/index.ts
index c541627..3c5e07e 100644
--- a/apps/worker/src/index.ts
+++ b/apps/worker/src/index.ts
@@ -1927,10 +1927,28 @@ function loadBifrostCultMeshRuntime(): {
   }> };
   defineDocumentType: (definition: Record<string, unknown>) => unknown;
 } {
+  if (process.env.VOIDBOT_CULTLIB_ROOT) {
+    try {
+      const cultMeshPackage = resolve(process.env.VOIDBOT_CULTLIB_ROOT, "packages", "cultmesh-ts", "package.json");
+      const cultCachePackage = resolve(process.env.VOIDBOT_CULTLIB_ROOT, "packages", "cultcache-ts", "package.json");
+      const { CultMesh } = createRequire(cultMeshPackage)("./dist/index.js") as {
+        CultMesh?: { createNode: (storePath: string, options: unknown) => Promise<{
+          put: (definition: unknown, key: string, value: unknown) => Promise<void>;
+          get: (definition: unknown, key: string) => unknown;
+          flush?: () => Promise<void>;
+          cache?: { pullAllBackingStores?: () => Promise<void> };
+        }> };
+      };
+      const { defineDocumentType } = createRequire(cultCachePackage)("./dist/index.js") as {
+        defineDocumentType?: (definition: Record<string, unknown>) => unknown;
+      };
+      if (CultMesh && defineDocumentType) {
+        return { CultMesh, defineDocumentType };
+      }
+    } catch {
+    }
+  }
   const candidates = [
-    ...(process.env.VOIDBOT_CULTLIB_ROOT
-      ? [resolve(process.env.VOIDBOT_CULTLIB_ROOT, "packages", "cultmesh-ts", "package.json")]
-      : []),
     resolve(config.bifrostRoot, "..", "CultLib", "packages", "cultmesh-ts", "package.json"),
     resolve(config.bifrostRoot, "..", "CultMeshTS", "package.json"),
   ];