Merge pull request #61 from radical-data/45-add-camera-source-node

Sketchy version of camera nodes :)

Author: jokroese

src/lib/engine/HydraEngine.ts

@@ -40,6 +40,8 @@ const trimUndefTail = (xs: unknown[]) => {
 	return a;
 };
 
+const CAMERA_SOURCE_INDEX = 0;
+
 function makeIssueKey(kind: IssueKind, parts: Array<string | number | undefined>): string {
 	return [kind, ...parts.map((p) => (p ?? '').toString())].join(':');
 }
@@ -70,6 +72,9 @@ export class HydraEngine {
 	private typeByName = new Map<string, TransformType>();
 	private inputsByName = new Map<string, string[]>();
 
+	private isCameraInitialised = false;
+	private cameraInitError: string | null = null;
+
 	private onWindowResize(): void {
 		if (!this.canvas) return;
 
@@ -84,6 +89,28 @@ export class HydraEngine {
 		}
 	}
 
+	private initCameraSource(): void {
+		if (this.isCameraInitialised || this.cameraInitError || !this.hydra) return;
+
+		this.isCameraInitialised = true;
+
+		try {
+			// eslint-disable-next-line @typescript-eslint/no-explicit-any
+			const hydraAny = this.hydra as any;
+			const source = hydraAny.sources?.[CAMERA_SOURCE_INDEX];
+
+			if (!source || typeof source.initCam !== 'function') {
+				throw new Error('Hydra camera source not available');
+			}
+
+			source.initCam();
+		} catch (error) {
+			this.cameraInitError =
+				error instanceof Error ? error.message : 'Unknown error initialising camera source';
+			console.warn('Camera initialisation failed:', error);
+		}
+	}
+
 	async init(canvas: HTMLCanvasElement): Promise<void> {
 		this.canvas = canvas;
 		this.canvas.style.backgroundColor = '#000000';
@@ -211,6 +238,55 @@ export class HydraEngine {
 			return result;
 		}
 
+		if (node.type === 'camera') {
+			if (!this.hydra) {
+				const result: BuildResult = {
+					ok: false,
+					issues: [
+						{
+							key: makeIssueKey('RUNTIME_EXECUTION_ERROR', [node.id]),
+							kind: 'RUNTIME_EXECUTION_ERROR',
+							severity: 'error',
+							message: 'Hydra is not initialised; cannot use camera source',
+							nodeId: node.id
+						}
+					]
+				};
+				memo.set(nodeId, result);
+				return result;
+			}
+
+			this.initCameraSource();
+
+			if (this.cameraInitError) {
+				const result: BuildResult = {
+					ok: false,
+					issues: [
+						{
+							key: makeIssueKey('RUNTIME_EXECUTION_ERROR', [node.id]),
+							kind: 'RUNTIME_EXECUTION_ERROR',
+							severity: 'error',
+							message: this.cameraInitError,
+							nodeId: node.id
+						}
+					]
+				};
+				memo.set(nodeId, result);
+				return result;
+			}
+
+			// eslint-disable-next-line @typescript-eslint/no-explicit-any
+			const gens = this.generators as any;
+			// eslint-disable-next-line @typescript-eslint/no-explicit-any
+			const hydraAny = this.hydra as any;
+			const source = hydraAny.sources?.[CAMERA_SOURCE_INDEX];
+			const chain = typeof gens.src === 'function' ? gens.src(source) : gens.solid?.(0, 0, 0, 1);
+
+			const result: BuildResult = { ok: true, chain };
+			memo.set(nodeId, result);
+			return result;
+		}
+
 		// Validate transform exists
 		const tType = this.typeByName.get(node.type);
 		if (!tType) {

src/lib/nodes/definitions/camera.ts

@@ -0,0 +1,19 @@
+import type { NodeDefinition } from '../../types.js';
+
+export const cameraDefinition: NodeDefinition = {
+	id: 'camera',
+	label: 'Camera',
+	category: 'source',
+	inputs: [],
+	outputs: [
+		{
+			id: 'color',
+			type: 'color'
+		}
+	],
+	build: (ctx) => {
+		// eslint-disable-next-line @typescript-eslint/no-explicit-any
+		const gens = ctx.generators as any;
+		return gens.src?.(0) ?? null;
+	}
+};

src/lib/nodes/registry.ts

@@ -1,7 +1,7 @@
 import type { NodeDefinition } from '../types.js';
 import { generateAllDefinitions, overrideDefinition } from './auto-definitions.js';
+import { cameraDefinition } from './definitions/camera.js';
 import { outDefinition } from './definitions/out.js';
-
 let nodeDefinitions: Map<string, NodeDefinition> | null = null;
 let initPromise: Promise<void> | null = null;
 
@@ -11,6 +11,7 @@ async function initializeRegistry(): Promise<void> {
 	const autoDefinitions = await generateAllDefinitions();
 	nodeDefinitions = new Map<string, NodeDefinition>(autoDefinitions);
 
+	nodeDefinitions.set('camera', cameraDefinition);
 	// Override nodes with custom UX
 	nodeDefinitions.set(
 		'osc',

src/lib/types.ts

@@ -32,6 +32,7 @@ export interface HydraBuildCtx {
 }
 
 export type HydraChain = unknown; // TODO: Fix when hydra-ts types are resolved
+
 export interface IRNode {
 	id: string;
 	type: string;