max/nodarium
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

chore: log some more stuff during registry
All checks were successful
Deploy to GitHub Pages / build_site (push) Successful in 2m31s
Details

Browse Source
This commit is contained in:
Max Richter
2025-11-24 22:42:08 +01:00
parent 67a104ff84
commit 9c4554a1f0
2 changed files with 30 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/lib/graph-interface/graph-manager.svelte.ts
View File

@@ -197,12 +197,12 @@ export class GraphManager extends EventEmitter<{
this.status = "loading"; this.status = "loading";
this.id = graph.id; this.id = graph.id;
logger.info("loading graph", graph); logger.info("loading graph", $state.snapshot(graph));
const nodeIds = Array.from(new Set([...graph.nodes.map((n) => n.type)])); const nodeIds = Array.from(new Set([...graph.nodes.map((n) => n.type)]));
await this.registry.load(nodeIds); await this.registry.load(nodeIds);
logger.info("loaded node types", this.registry.status); logger.info("loaded node types", this.registry.getAllNodes());
for (const node of this.graph.nodes) { for (const node of this.graph.nodes) {
const nodeType = this.registry.getNode(node.type); const nodeType = this.registry.getNode(node.type);

57
packages/registry/src/node-registry-client.ts
View File

@@ -13,7 +13,26 @@ export class RemoteNodeRegistry implements NodeRegistry {
status: "loading" | "ready" | "error" = "loading"; status: "loading" | "ready" | "error" = "loading";
private nodes: Map<string, NodeDefinition> = new Map(); private nodes: Map<string, NodeDefinition> = new Map();
fetch: typeof fetch = globalThis.fetch.bind(globalThis); async fetchJson(url: string) {
const response = await fetch(`${this.url}/${url}`);
if (!response.ok) {
log.error(`Failed to load ${url}`, { response, url, host: this.url });
throw new Error(`Failed to load ${url}`);
}
return response.json();
}
async fetchArrayBuffer(url: string) {
const response = await fetch(`${this.url}/${url}`);
if (!response.ok) {
log.error(`Failed to load ${url}`, { response, url, host: this.url });
throw new Error(`Failed to load ${url}`);
}
return response.arrayBuffer();
}
constructor( constructor(
private url: string, private url: string,
@@ -21,46 +40,26 @@ export class RemoteNodeRegistry implements NodeRegistry {
) {} ) {}
async fetchUsers() { async fetchUsers() {
const response = await this.fetch(`${this.url}/nodes/users.json`); return this.fetchJson(`nodes/users.json`);
if (!response.ok) {
throw new Error(`Failed to load users`);
}
return response.json();
} }
async fetchUser(userId: `${string}`) { async fetchUser(userId: `${string}`) {
const response = await this.fetch(`${this.url}/user/${userId}.json`); return this.fetchJson(`user/${userId}.json`);
if (!response.ok) {
throw new Error(`Failed to load user ${userId}`);
}
return response.json();
} }
async fetchCollection(userCollectionId: `${string}/${string}`) { async fetchCollection(userCollectionId: `${string}/${string}`) {
const response = await this.fetch( return this.fetchJson(`nodes/${userCollectionId}.json`);
`${this.url}/nodes/${userCollectionId}.json`,
);
if (!response.ok) {
throw new Error(`Failed to load collection ${userCollectionId}`);
}
return response.json();
} }
async fetchNodeDefinition(nodeId: `${string}/${string}/${string}`) { async fetchNodeDefinition(nodeId: `${string}/${string}/${string}`) {
const response = await this.fetch(`${this.url}/nodes/${nodeId}.json`); return this.fetchJson(`nodes/${nodeId}.json`);
if (!response.ok) {
throw new Error(`Failed to load node definition ${nodeId}`);
}
return response.json();
} }
private async fetchNodeWasm(nodeId: `${string}/${string}/${string}`) { private async fetchNodeWasm(nodeId: `${string}/${string}/${string}`) {
const fetchNode = async () => { const res = await Promise.race([
const response = await this.fetch(`${this.url}/nodes/${nodeId}.wasm`); this.fetchArrayBuffer(`nodes/${nodeId}.wasm`),
return response.arrayBuffer(); this.cache?.get(nodeId),
}; ]);
const res = await Promise.race([fetchNode(), this.cache?.get(nodeId)]);
if (!res) { if (!res) {
throw new Error(`Failed to load node wasm ${nodeId}`); throw new Error(`Failed to load node wasm ${nodeId}`);