Compare commits
32 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
106797de32
|
|||
|
1a56ba986d
|
|||
|
703f531cd3
|
|||
|
0ed22f20b9
|
|||
|
733b0a2ceb
|
|||
|
8f60816c78
|
|||
|
cd7b51d86a
|
|||
|
6c9cd1505d
|
|||
|
db5ee8ba29
|
|||
|
a6b9ca4315
|
|||
|
d4910aba8c
|
|||
|
e695c76490
|
|||
|
2a54fa7590
|
|||
|
6d5cac65e8
|
|||
|
3ee074b11c
|
|||
|
59a1e63396
|
|||
|
317d1552ce
|
|||
|
78439b19e9
|
|||
|
ef217b1c40
|
|||
|
7499b80789
|
|||
|
a5b663f6fc
|
|||
|
05506704bf
|
|||
|
63188e57fd
|
|||
|
4572d30005
|
|||
|
ccc376d158
|
|||
|
7e432e9033
|
|||
|
01f58377c2
|
|||
|
6ef5dc28ed
|
|||
|
3450d70047
|
|||
|
731b9e9b1e
|
|||
|
72f07d0a50
|
|||
|
a56e8f445e
|
@@ -0,0 +1,28 @@
|
|||||||
|
name: Setup
|
||||||
|
description: Restore caches and install pnpm dependencies (run after checkout)
|
||||||
|
|
||||||
|
runs:
|
||||||
|
using: composite
|
||||||
|
steps:
|
||||||
|
- name: 💾 Setup pnpm Cache
|
||||||
|
uses: actions/cache@v4
|
||||||
|
with:
|
||||||
|
path: .pnpm-store
|
||||||
|
key: ${{ runner.os }}-pnpm-${{ hashFiles('**/pnpm-lock.yaml') }}
|
||||||
|
restore-keys: |
|
||||||
|
${{ runner.os }}-pnpm-
|
||||||
|
|
||||||
|
- name: 🦀 Cache Cargo
|
||||||
|
uses: actions/cache@v4
|
||||||
|
with:
|
||||||
|
path: |
|
||||||
|
~/.cargo/registry
|
||||||
|
~/.cargo/git
|
||||||
|
target
|
||||||
|
key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
|
||||||
|
restore-keys: |
|
||||||
|
${{ runner.os }}-cargo-
|
||||||
|
|
||||||
|
- name: 📦 Install Dependencies
|
||||||
|
shell: bash
|
||||||
|
run: pnpm install --frozen-lockfile --store-dir .pnpm-store
|
||||||
@@ -12,9 +12,9 @@ env:
|
|||||||
CARGO_TARGET_DIR: target
|
CARGO_TARGET_DIR: target
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
release:
|
benchmark:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
container: git.max-richter.dev/max/nodarium-ci:bce06da456e3c008851ac006033cfff256015a47
|
container: git.max-richter.dev/max/nodarium-ci:a56e8f445edb6064ae7a7b3b783fb7445f1b4e69
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: 📑 Checkout Code
|
- name: 📑 Checkout Code
|
||||||
@@ -23,27 +23,8 @@ jobs:
|
|||||||
fetch-depth: 0
|
fetch-depth: 0
|
||||||
token: ${{ secrets.GITEA_TOKEN }}
|
token: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
|
||||||
- name: 💾 Setup pnpm Cache
|
- name: 🔧 Setup
|
||||||
uses: actions/cache@v4
|
uses: ./.gitea/actions/setup
|
||||||
with:
|
|
||||||
path: ${{ env.PNPM_CACHE_FOLDER }}
|
|
||||||
key: ${{ runner.os }}-pnpm-${{ hashFiles('**/pnpm-lock.yaml') }}
|
|
||||||
restore-keys: |
|
|
||||||
${{ runner.os }}-pnpm-
|
|
||||||
|
|
||||||
- name: 🦀 Cache Cargo
|
|
||||||
uses: actions/cache@v4
|
|
||||||
with:
|
|
||||||
path: |
|
|
||||||
~/.cargo/registry
|
|
||||||
~/.cargo/git
|
|
||||||
target
|
|
||||||
key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
|
|
||||||
restore-keys: |
|
|
||||||
${{ runner.os }}-cargo-
|
|
||||||
|
|
||||||
- name: 📦 Install Dependencies
|
|
||||||
run: pnpm install --frozen-lockfile --store-dir ${{ env.PNPM_CACHE_FOLDER }}
|
|
||||||
|
|
||||||
- name: 🛠️ Build Nodes
|
- name: 🛠️ Build Nodes
|
||||||
run: pnpm build:nodes
|
run: pnpm build:nodes
|
||||||
@@ -51,9 +32,36 @@ jobs:
|
|||||||
- name: 🏃 Execute Runtime
|
- name: 🏃 Execute Runtime
|
||||||
run: pnpm run --filter @nodarium/app bench
|
run: pnpm run --filter @nodarium/app bench
|
||||||
|
|
||||||
- name: 📤 Upload Benchmark Results
|
- name: 🔑 Setup SSH key
|
||||||
uses: actions/upload-artifact@v3
|
run: |
|
||||||
with:
|
mkdir -p ~/.ssh
|
||||||
name: benchmark-data
|
echo "${{ secrets.GIT_SSH_PRIVATE_KEY }}" > ~/.ssh/id_ed25519
|
||||||
path: app/benchmark/out/
|
chmod 600 ~/.ssh/id_ed25519
|
||||||
compression: 9
|
cat >> ~/.ssh/config <<'EOF'
|
||||||
|
Host git.max-richter.dev
|
||||||
|
Port 2222
|
||||||
|
IdentityFile ~/.ssh/id_ed25519
|
||||||
|
IdentitiesOnly yes
|
||||||
|
EOF
|
||||||
|
ssh-keyscan -p 2222 -H git.max-richter.dev >> ~/.ssh/known_hosts
|
||||||
|
|
||||||
|
- name: 📤 Push Results
|
||||||
|
env:
|
||||||
|
BENCH_REPO: "git@git.max-richter.dev:max/nodarium-benchmarks.git"
|
||||||
|
run: |
|
||||||
|
git config --global user.name "nodarium-bot"
|
||||||
|
git config --global user.email "nodarium-bot@max-richter.dev"
|
||||||
|
|
||||||
|
git clone git@git.max-richter.dev:max/nodarium-benchmarks.git target_bench_repo
|
||||||
|
|
||||||
|
BRANCH="${GITHUB_HEAD_REF:-$GITHUB_REF_NAME}"
|
||||||
|
SAFE_PR_NAME=$(printf "%s" "$BRANCH" | tr '/' '-')
|
||||||
|
DEST_DIR="target_bench_repo/data/$SAFE_PR_NAME/$(date +%s)"
|
||||||
|
mkdir -p "$DEST_DIR"
|
||||||
|
|
||||||
|
cp app/benchmark/out/*.json "$DEST_DIR/"
|
||||||
|
|
||||||
|
cd target_bench_repo
|
||||||
|
git add .
|
||||||
|
git commit -m "Update benchmarks for $SAFE_PR_NAME: ${{ gitea.sha }}"
|
||||||
|
git push origin main
|
||||||
|
|||||||
@@ -13,9 +13,9 @@ env:
|
|||||||
CARGO_TARGET_DIR: target
|
CARGO_TARGET_DIR: target
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
release:
|
quality:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
container: git.max-richter.dev/max/nodarium-ci:bce06da456e3c008851ac006033cfff256015a47
|
container: git.max-richter.dev/max/nodarium-ci:a56e8f445edb6064ae7a7b3b783fb7445f1b4e69
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: 📑 Checkout Code
|
- name: 📑 Checkout Code
|
||||||
@@ -24,27 +24,8 @@ jobs:
|
|||||||
fetch-depth: 0
|
fetch-depth: 0
|
||||||
token: ${{ secrets.GITEA_TOKEN }}
|
token: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
|
||||||
- name: 💾 Setup pnpm Cache
|
- name: 🔧 Setup
|
||||||
uses: actions/cache@v4
|
uses: ./.gitea/actions/setup
|
||||||
with:
|
|
||||||
path: ${{ env.PNPM_CACHE_FOLDER }}
|
|
||||||
key: ${{ runner.os }}-pnpm-${{ hashFiles('**/pnpm-lock.yaml') }}
|
|
||||||
restore-keys: |
|
|
||||||
${{ runner.os }}-pnpm-
|
|
||||||
|
|
||||||
- name: 🦀 Cache Cargo
|
|
||||||
uses: actions/cache@v4
|
|
||||||
with:
|
|
||||||
path: |
|
|
||||||
~/.cargo/registry
|
|
||||||
~/.cargo/git
|
|
||||||
target
|
|
||||||
key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
|
|
||||||
restore-keys: |
|
|
||||||
${{ runner.os }}-cargo-
|
|
||||||
|
|
||||||
- name: 📦 Install Dependencies
|
|
||||||
run: pnpm install --frozen-lockfile --store-dir ${{ env.PNPM_CACHE_FOLDER }}
|
|
||||||
|
|
||||||
- name: 🧹 Quality Control
|
- name: 🧹 Quality Control
|
||||||
run: |
|
run: |
|
||||||
@@ -52,7 +33,61 @@ jobs:
|
|||||||
pnpm format:check
|
pnpm format:check
|
||||||
pnpm check
|
pnpm check
|
||||||
pnpm build
|
pnpm build
|
||||||
xvfb-run --auto-servernum --server-args="-screen 0 1280x1024x24" pnpm test
|
|
||||||
|
test-unit:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
container: git.max-richter.dev/max/nodarium-ci:a56e8f445edb6064ae7a7b3b783fb7445f1b4e69
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: 📑 Checkout Code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
with:
|
||||||
|
fetch-depth: 0
|
||||||
|
token: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
|
||||||
|
- name: 🔧 Setup
|
||||||
|
uses: ./.gitea/actions/setup
|
||||||
|
|
||||||
|
- name: 🧪 Run Tests
|
||||||
|
run: xvfb-run --auto-servernum --server-args="-screen 0 1280x1024x24" pnpm test:unit
|
||||||
|
|
||||||
|
test-e2e:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
container: git.max-richter.dev/max/nodarium-ci:a56e8f445edb6064ae7a7b3b783fb7445f1b4e69
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: 📑 Checkout Code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
with:
|
||||||
|
fetch-depth: 0
|
||||||
|
token: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
|
||||||
|
- name: 🔧 Setup
|
||||||
|
uses: ./.gitea/actions/setup
|
||||||
|
|
||||||
|
- name: 🏗️ Build Web Assets
|
||||||
|
run: pnpm build
|
||||||
|
|
||||||
|
- name: 🧪 Run Tests
|
||||||
|
run: xvfb-run --auto-servernum --server-args="-screen 0 1280x1024x24" pnpm test:e2e
|
||||||
|
|
||||||
|
deploy:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
needs: [quality, test-e2e, test-unit]
|
||||||
|
container: git.max-richter.dev/max/nodarium-ci:a56e8f445edb6064ae7a7b3b783fb7445f1b4e69
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: 📑 Checkout Code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
with:
|
||||||
|
fetch-depth: 0
|
||||||
|
token: ${{ secrets.GITEA_TOKEN }}
|
||||||
|
|
||||||
|
- name: 🔧 Setup
|
||||||
|
uses: ./.gitea/actions/setup
|
||||||
|
|
||||||
|
- name: 🏗️ Build Web Assets
|
||||||
|
run: pnpm build
|
||||||
|
|
||||||
- name: 🚀 Create Release Commit
|
- name: 🚀 Create Release Commit
|
||||||
if: gitea.ref_type == 'tag'
|
if: gitea.ref_type == 'tag'
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ ENV RUSTUP_HOME=/usr/local/rustup \
|
|||||||
PATH=/usr/local/cargo/bin:$PATH
|
PATH=/usr/local/cargo/bin:$PATH
|
||||||
|
|
||||||
RUN apt-get update && apt-get install -y \
|
RUN apt-get update && apt-get install -y \
|
||||||
|
openssh-client \
|
||||||
ca-certificates=20230311+deb12u1 \
|
ca-certificates=20230311+deb12u1 \
|
||||||
gpg=2.2.40-1.1+deb12u2 \
|
gpg=2.2.40-1.1+deb12u2 \
|
||||||
gpg-agent=2.2.40-1.1+deb12u2 \
|
gpg-agent=2.2.40-1.1+deb12u2 \
|
||||||
|
|||||||
+159
-9
@@ -1,54 +1,204 @@
|
|||||||
import type { Graph, Graph as GraphType, NodeId } from '@nodarium/types';
|
import type { Graph, Graph as GraphType, NodeId } from '@nodarium/types';
|
||||||
import { createLogger, createPerformanceStore } from '@nodarium/utils';
|
import { createLogger, createPerformanceStore, splitNestedArray } from '@nodarium/utils';
|
||||||
|
|
||||||
import { mkdir, writeFile } from 'node:fs/promises';
|
import { mkdir, writeFile } from 'node:fs/promises';
|
||||||
|
import { freemem, loadavg, totalmem } from 'node:os';
|
||||||
import { resolve } from 'node:path';
|
import { resolve } from 'node:path';
|
||||||
|
|
||||||
import { MemoryRuntimeExecutor } from '../src/lib/runtime/runtime-executor.ts';
|
import { MemoryRuntimeExecutor } from '../src/lib/runtime/runtime-executor.ts';
|
||||||
import { BenchmarkRegistry } from './benchmarkRegistry.ts';
|
import { BenchmarkRegistry } from './benchmarkRegistry.ts';
|
||||||
|
|
||||||
|
import {
|
||||||
|
getMachineInfo,
|
||||||
|
measureCpuUsage,
|
||||||
|
readCgroupCpuStat,
|
||||||
|
readCpuSnapshot,
|
||||||
|
readProcMemInfo,
|
||||||
|
SystemSample
|
||||||
|
} from './systemStats.ts';
|
||||||
import defaultPlantTemplate from './templates/default.json' assert { type: 'json' };
|
import defaultPlantTemplate from './templates/default.json' assert { type: 'json' };
|
||||||
import lottaFacesTemplate from './templates/lotta-faces.json' assert { type: 'json' };
|
import lottaFacesTemplate from './templates/lotta-faces.json' assert { type: 'json' };
|
||||||
import plantTemplate from './templates/plant.json' assert { type: 'json' };
|
import plantTemplate from './templates/plant.json' assert { type: 'json' };
|
||||||
|
|
||||||
const registry = new BenchmarkRegistry();
|
const registry = new BenchmarkRegistry();
|
||||||
const r = new MemoryRuntimeExecutor(registry);
|
const r = new MemoryRuntimeExecutor(registry);
|
||||||
const perfStore = createPerformanceStore();
|
|
||||||
|
|
||||||
const log = createLogger('bench');
|
const log = createLogger('bench');
|
||||||
|
|
||||||
const templates: Record<string, Graph> = {
|
const templates: Record<string, Graph> = {
|
||||||
'plant': plantTemplate as unknown as GraphType,
|
plant: plantTemplate as unknown as GraphType,
|
||||||
'lotta-faces': lottaFacesTemplate as unknown as GraphType,
|
'lotta-faces': lottaFacesTemplate as unknown as GraphType,
|
||||||
'default': defaultPlantTemplate as unknown as GraphType
|
default: defaultPlantTemplate as unknown as GraphType
|
||||||
};
|
};
|
||||||
|
|
||||||
|
function average(values: number[]) {
|
||||||
|
if (values.length === 0) return 0;
|
||||||
|
return values.reduce((a, b) => a + b, 0) / values.length;
|
||||||
|
}
|
||||||
|
|
||||||
|
function countGeometry(result: Int32Array): {
|
||||||
|
totalVertices: number;
|
||||||
|
totalFaces: number;
|
||||||
|
} {
|
||||||
|
const parts = splitNestedArray(result);
|
||||||
|
|
||||||
|
let totalVertices = 0;
|
||||||
|
let totalFaces = 0;
|
||||||
|
|
||||||
|
for (const part of parts) {
|
||||||
|
const type = part[0];
|
||||||
|
|
||||||
|
const vertexCount = part[1] >>> 0;
|
||||||
|
const faceCount = part[2] >>> 0;
|
||||||
|
|
||||||
|
if (type === 2) {
|
||||||
|
const instanceCount = part[3] >>> 0;
|
||||||
|
|
||||||
|
totalVertices += vertexCount * instanceCount;
|
||||||
|
totalFaces += faceCount * instanceCount;
|
||||||
|
} else {
|
||||||
|
totalVertices += vertexCount;
|
||||||
|
totalFaces += faceCount;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
totalVertices,
|
||||||
|
totalFaces
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
async function run(g: GraphType, amount: number) {
|
async function run(g: GraphType, amount: number) {
|
||||||
await registry.load(plantTemplate.nodes.map(n => n.type) as NodeId[]);
|
await registry.load(g.nodes.map(n => n.type) as NodeId[]);
|
||||||
|
|
||||||
log.log('loaded ' + g.nodes.length + ' nodes');
|
log.log('loaded ' + g.nodes.length + ' nodes');
|
||||||
|
|
||||||
log.log('warming up');
|
log.log('warming up');
|
||||||
|
|
||||||
// Warm up the runtime? maybe this does something?
|
|
||||||
for (let index = 0; index < 10; index++) {
|
for (let index = 0; index < 10; index++) {
|
||||||
await r.execute(g, { randomSeed: true });
|
await r.execute(g, { randomSeed: true });
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const systemSamples: SystemSample[] = [];
|
||||||
|
|
||||||
|
let previousCpuSnapshot = await readCpuSnapshot();
|
||||||
|
|
||||||
|
const sampler = setInterval(async () => {
|
||||||
|
try {
|
||||||
|
const cpu = await measureCpuUsage(previousCpuSnapshot);
|
||||||
|
|
||||||
|
previousCpuSnapshot = cpu.snapshot;
|
||||||
|
|
||||||
|
const [l1, l5, l15] = loadavg();
|
||||||
|
|
||||||
|
systemSamples.push({
|
||||||
|
timestamp: Date.now(),
|
||||||
|
|
||||||
|
cpuUsagePercent: cpu.usagePercent,
|
||||||
|
cpuStealPercent: cpu.stealPercent,
|
||||||
|
|
||||||
|
load1: l1,
|
||||||
|
load5: l5,
|
||||||
|
load15: l15,
|
||||||
|
|
||||||
|
freeMemory: freemem(),
|
||||||
|
totalMemory: totalmem()
|
||||||
|
});
|
||||||
|
} catch (err) {
|
||||||
|
console.error(err);
|
||||||
|
}
|
||||||
|
}, 1000);
|
||||||
|
|
||||||
log.log('executing');
|
log.log('executing');
|
||||||
|
|
||||||
|
const perfStore = createPerformanceStore();
|
||||||
|
|
||||||
r.perf = perfStore;
|
r.perf = perfStore;
|
||||||
|
|
||||||
|
let res: Int32Array | undefined;
|
||||||
|
|
||||||
|
const cgroupBefore = await readCgroupCpuStat();
|
||||||
|
|
||||||
for (let i = 0; i < amount; i++) {
|
for (let i = 0; i < amount; i++) {
|
||||||
r.perf?.startRun();
|
r.perf?.startRun();
|
||||||
await r.execute(g, { randomSeed: true });
|
|
||||||
|
res = await r.execute(g, { randomSeed: true });
|
||||||
|
|
||||||
r.perf?.stopRun();
|
r.perf?.stopRun();
|
||||||
|
|
||||||
|
const { totalVertices, totalFaces } = countGeometry(res!);
|
||||||
|
|
||||||
|
r.perf?.addToLastRun('total-vertices', totalVertices);
|
||||||
|
r.perf?.addToLastRun('total-faces', totalFaces);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const cgroupAfter = await readCgroupCpuStat();
|
||||||
|
|
||||||
|
clearInterval(sampler);
|
||||||
|
|
||||||
log.log('finished');
|
log.log('finished');
|
||||||
return r.perf.get();
|
|
||||||
|
return {
|
||||||
|
data: r.perf.get(),
|
||||||
|
metadata: {
|
||||||
|
timestamp: new Date().toISOString(),
|
||||||
|
|
||||||
|
machine: getMachineInfo(),
|
||||||
|
|
||||||
|
process: {
|
||||||
|
pid: process.pid,
|
||||||
|
uptime: process.uptime(),
|
||||||
|
|
||||||
|
memoryUsage: process.memoryUsage()
|
||||||
|
},
|
||||||
|
|
||||||
|
system: {
|
||||||
|
averages: {
|
||||||
|
cpuUsagePercent: average(
|
||||||
|
systemSamples.map(s => s.cpuUsagePercent)
|
||||||
|
),
|
||||||
|
|
||||||
|
cpuStealPercent: average(
|
||||||
|
systemSamples.map(s => s.cpuStealPercent)
|
||||||
|
),
|
||||||
|
|
||||||
|
load1: average(systemSamples.map(s => s.load1)),
|
||||||
|
load5: average(systemSamples.map(s => s.load5)),
|
||||||
|
load15: average(systemSamples.map(s => s.load15)),
|
||||||
|
|
||||||
|
freeMemory: average(
|
||||||
|
systemSamples.map(s => s.freeMemory)
|
||||||
|
)
|
||||||
|
},
|
||||||
|
|
||||||
|
samples: systemSamples,
|
||||||
|
|
||||||
|
meminfo: await readProcMemInfo()
|
||||||
|
},
|
||||||
|
|
||||||
|
cgroup: {
|
||||||
|
before: cgroupBefore,
|
||||||
|
after: cgroupAfter
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
async function main() {
|
async function main() {
|
||||||
const outPath = resolve('benchmark/out/');
|
const outPath = resolve('benchmark/out/');
|
||||||
|
|
||||||
await mkdir(outPath, { recursive: true });
|
await mkdir(outPath, { recursive: true });
|
||||||
|
|
||||||
for (const key in templates) {
|
for (const key in templates) {
|
||||||
log.log('executing ' + key);
|
log.log('executing ' + key);
|
||||||
|
|
||||||
const perfData = await run(templates[key], 100);
|
const perfData = await run(templates[key], 100);
|
||||||
await writeFile(resolve(outPath, key + '.json'), JSON.stringify(perfData));
|
|
||||||
|
await writeFile(
|
||||||
|
resolve(outPath, key + '.json'),
|
||||||
|
JSON.stringify(perfData, null, 2)
|
||||||
|
);
|
||||||
|
|
||||||
await new Promise(res => setTimeout(res, 200));
|
await new Promise(res => setTimeout(res, 200));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,129 @@
|
|||||||
|
import { readFile } from 'node:fs/promises';
|
||||||
|
import { cpus, totalmem } from 'node:os';
|
||||||
|
|
||||||
|
export type CpuSnapshot = {
|
||||||
|
idle: number;
|
||||||
|
total: number;
|
||||||
|
steal: number;
|
||||||
|
};
|
||||||
|
|
||||||
|
export type SystemSample = {
|
||||||
|
timestamp: number;
|
||||||
|
cpuUsagePercent: number;
|
||||||
|
cpuStealPercent: number;
|
||||||
|
load1: number;
|
||||||
|
load5: number;
|
||||||
|
load15: number;
|
||||||
|
freeMemory: number;
|
||||||
|
totalMemory: number;
|
||||||
|
};
|
||||||
|
|
||||||
|
export async function readCpuSnapshot(): Promise<CpuSnapshot> {
|
||||||
|
const stat = await readFile('/proc/stat', 'utf8');
|
||||||
|
const line = stat.split('\n')[0];
|
||||||
|
|
||||||
|
const parts: number[] = line
|
||||||
|
.trim()
|
||||||
|
.split(/\s+/)
|
||||||
|
.slice(1)
|
||||||
|
.map((v: unknown) => Number(v));
|
||||||
|
|
||||||
|
const idle = parts[3];
|
||||||
|
const iowait = parts[4];
|
||||||
|
const steal = parts[7];
|
||||||
|
|
||||||
|
return {
|
||||||
|
idle: idle + iowait,
|
||||||
|
total: parts.reduce((a, b) => a + b, 0),
|
||||||
|
steal: steal ?? 0
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function measureCpuUsage(
|
||||||
|
previous: CpuSnapshot
|
||||||
|
): Promise<{
|
||||||
|
snapshot: CpuSnapshot;
|
||||||
|
usagePercent: number;
|
||||||
|
stealPercent: number;
|
||||||
|
}> {
|
||||||
|
const current = await readCpuSnapshot();
|
||||||
|
|
||||||
|
const idle = current.idle - previous.idle;
|
||||||
|
const total = current.total - previous.total;
|
||||||
|
const steal = current.steal - previous.steal;
|
||||||
|
|
||||||
|
return {
|
||||||
|
snapshot: current,
|
||||||
|
usagePercent: total === 0 ? 0 : 100 * (1 - idle / total),
|
||||||
|
stealPercent: total === 0 ? 0 : 100 * (steal / total)
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function readCgroupCpuStat() {
|
||||||
|
const possiblePaths = [
|
||||||
|
'/sys/fs/cgroup/cpu.stat',
|
||||||
|
'/sys/fs/cgroup/cpu/cpu.stat'
|
||||||
|
];
|
||||||
|
|
||||||
|
for (const path of possiblePaths) {
|
||||||
|
try {
|
||||||
|
const txt: string = await readFile(path, 'utf8');
|
||||||
|
|
||||||
|
return Object.fromEntries(
|
||||||
|
txt
|
||||||
|
.trim()
|
||||||
|
.split('\n')
|
||||||
|
.map(line => {
|
||||||
|
const [k, v] = line.trim().split(/\s+/);
|
||||||
|
return [k, Number(v)];
|
||||||
|
})
|
||||||
|
);
|
||||||
|
} catch {
|
||||||
|
// continue
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function readProcMemInfo() {
|
||||||
|
try {
|
||||||
|
const txt = await readFile('/proc/meminfo', 'utf8');
|
||||||
|
|
||||||
|
const result: Record<string, number> = {};
|
||||||
|
|
||||||
|
for (const line of txt.split('\n')) {
|
||||||
|
const match = line.match(/^(\w+):\s+(\d+)/);
|
||||||
|
|
||||||
|
if (!match) continue;
|
||||||
|
|
||||||
|
result[match[1]] = Number(match[2]);
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
} catch {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getMachineInfo() {
|
||||||
|
const cpuInfo = cpus();
|
||||||
|
|
||||||
|
return {
|
||||||
|
platform: process.platform,
|
||||||
|
arch: process.arch,
|
||||||
|
nodeVersion: process.version,
|
||||||
|
|
||||||
|
cpuModel: cpuInfo[0]?.model ?? 'unknown',
|
||||||
|
cpuCount: cpuInfo.length,
|
||||||
|
|
||||||
|
totalMemory: totalmem(),
|
||||||
|
|
||||||
|
ci: {
|
||||||
|
githubActions: process.env.GITHUB_ACTIONS ?? false,
|
||||||
|
runnerName: process.env.RUNNER_NAME ?? null,
|
||||||
|
runnerOs: process.env.RUNNER_OS ?? null,
|
||||||
|
runnerArch: process.env.RUNNER_ARCH ?? null
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
Binary file not shown.
|
Before Width: | Height: | Size: 43 KiB After Width: | Height: | Size: 47 KiB |
+30
-30
@@ -7,7 +7,7 @@
|
|||||||
"dev": "vite dev",
|
"dev": "vite dev",
|
||||||
"predev": "rm static/CHANGELOG.md && ln -s ../../CHANGELOG.md static/CHANGELOG.md",
|
"predev": "rm static/CHANGELOG.md && ln -s ../../CHANGELOG.md static/CHANGELOG.md",
|
||||||
"build": "svelte-kit sync && vite build",
|
"build": "svelte-kit sync && vite build",
|
||||||
"test:unit": "vitest",
|
"test:unit": "vitest --browser=false",
|
||||||
"test": "npm run test:unit -- --run && npm run test:e2e",
|
"test": "npm run test:unit -- --run && npm run test:e2e",
|
||||||
"test:e2e": "playwright test",
|
"test:e2e": "playwright test",
|
||||||
"preview": "vite preview",
|
"preview": "vite preview",
|
||||||
@@ -18,49 +18,49 @@
|
|||||||
"bench": "tsx ./benchmark/index.ts"
|
"bench": "tsx ./benchmark/index.ts"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"@nodarium/planty": "workspace:*",
|
||||||
"@nodarium/ui": "workspace:*",
|
"@nodarium/ui": "workspace:*",
|
||||||
"@nodarium/utils": "workspace:*",
|
"@nodarium/utils": "workspace:*",
|
||||||
"@nodarium/planty": "workspace:*",
|
"@sveltejs/kit": "^2.59.0",
|
||||||
"@sveltejs/kit": "^2.50.2",
|
"@tailwindcss/vite": "^4.2.4",
|
||||||
"@tailwindcss/vite": "^4.1.18",
|
"@threlte/core": "8.5.11",
|
||||||
"@threlte/core": "8.3.1",
|
"@threlte/extras": "9.15.1",
|
||||||
"@threlte/extras": "9.7.1",
|
|
||||||
"comlink": "^4.4.2",
|
"comlink": "^4.4.2",
|
||||||
"file-saver": "^2.0.5",
|
"file-saver": "^2.0.5",
|
||||||
"idb": "^8.0.3",
|
"idb": "^8.0.3",
|
||||||
"jsondiffpatch": "^0.7.3",
|
"jsondiffpatch": "^0.7.3",
|
||||||
"micromark": "^4.0.2",
|
"micromark": "^4.0.2",
|
||||||
"tailwindcss": "^4.1.18",
|
"tailwindcss": "^4.2.4",
|
||||||
"three": "^0.182.0"
|
"three": "^0.184.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@eslint/compat": "^2.0.2",
|
"@eslint/compat": "^2.0.5",
|
||||||
"@eslint/js": "^9.39.2",
|
"@eslint/js": "^10.0.1",
|
||||||
"@iconify-json/tabler": "^1.2.26",
|
"@iconify-json/tabler": "^1.2.33",
|
||||||
"@iconify/tailwind4": "^1.2.1",
|
"@iconify/tailwind4": "^1.2.3",
|
||||||
"@nodarium/types": "workspace:^",
|
"@nodarium/types": "workspace:^",
|
||||||
"@playwright/test": "^1.58.1",
|
"@playwright/test": "^1.59.1",
|
||||||
"@sveltejs/adapter-static": "^3.0.10",
|
"@sveltejs/adapter-static": "^3.0.10",
|
||||||
"@sveltejs/vite-plugin-svelte": "^6.2.4",
|
"@sveltejs/vite-plugin-svelte": "^7.0.0",
|
||||||
"@tsconfig/svelte": "^5.0.7",
|
"@tsconfig/svelte": "^5.0.8",
|
||||||
"@types/file-saver": "^2.0.7",
|
"@types/file-saver": "^2.0.7",
|
||||||
"@types/three": "^0.182.0",
|
"@types/three": "^0.184.0",
|
||||||
"@vitest/browser-playwright": "^4.0.18",
|
"@vitest/browser-playwright": "^4.1.5",
|
||||||
"dprint": "^0.51.1",
|
"dprint": "^0.54.0",
|
||||||
"eslint": "^9.39.2",
|
"eslint": "^10.3.0",
|
||||||
"eslint-plugin-svelte": "^3.14.0",
|
"eslint-plugin-svelte": "^3.17.1",
|
||||||
"globals": "^17.3.0",
|
"globals": "^17.6.0",
|
||||||
"svelte": "^5.49.2",
|
"svelte": "^5.55.5",
|
||||||
"svelte-check": "^4.3.6",
|
"svelte-check": "^4.4.7",
|
||||||
"tslib": "^2.8.1",
|
"tslib": "^2.8.1",
|
||||||
"tsx": "^4.21.0",
|
"tsx": "^4.21.0",
|
||||||
"typescript": "^5.9.3",
|
"typescript": "^6.0.3",
|
||||||
"typescript-eslint": "^8.54.0",
|
"typescript-eslint": "^8.59.1",
|
||||||
"vite": "^7.3.1",
|
"vite": "^8.0.10",
|
||||||
"vite-plugin-comlink": "^5.3.0",
|
"vite-plugin-comlink": "^5.3.0",
|
||||||
"vite-plugin-glsl": "^1.5.5",
|
"vite-plugin-glsl": "^1.6.0",
|
||||||
"vite-plugin-wasm": "^3.5.0",
|
"vite-plugin-wasm": "^3.6.0",
|
||||||
"vitest": "^4.0.18",
|
"vitest": "^4.1.5",
|
||||||
"vitest-browser-svelte": "^2.0.2"
|
"vitest-browser-svelte": "^2.1.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -183,7 +183,7 @@
|
|||||||
activeNodeId = node.id;
|
activeNodeId = node.id;
|
||||||
}}
|
}}
|
||||||
>
|
>
|
||||||
{node.id.split('/').at(-1)}
|
{node.meta?.title ?? node.id.split('/').at(-1)}
|
||||||
</div>
|
</div>
|
||||||
{/each}
|
{/each}
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { describe, expect, it } from 'vitest';
|
import { assert, describe, expect, it } from 'vitest';
|
||||||
import { GraphManager } from './graph-manager.svelte';
|
import { GraphManager } from './graph-manager.svelte';
|
||||||
import {
|
import {
|
||||||
createMockNodeRegistry,
|
createMockNodeRegistry,
|
||||||
@@ -9,7 +9,150 @@ import {
|
|||||||
mockVec3OutputNode
|
mockVec3OutputNode
|
||||||
} from './test-utils';
|
} from './test-utils';
|
||||||
|
|
||||||
describe('GraphManager', () => {
|
describe('groupNodes', () => {
|
||||||
|
it('should not do anything if no nodes are selected', () => {
|
||||||
|
const registry = createMockNodeRegistry([
|
||||||
|
mockFloatOutputNode,
|
||||||
|
mockFloatInputNode,
|
||||||
|
mockGeometryOutputNode,
|
||||||
|
mockPathInputNode
|
||||||
|
]);
|
||||||
|
|
||||||
|
const manager = new GraphManager(registry);
|
||||||
|
|
||||||
|
const floatInputNode = manager.createNode({
|
||||||
|
type: 'test/node/input',
|
||||||
|
position: [100, 100],
|
||||||
|
props: {}
|
||||||
|
});
|
||||||
|
|
||||||
|
assert.isDefined(floatInputNode);
|
||||||
|
|
||||||
|
const floatOutputNode = manager.createNode({
|
||||||
|
type: 'test/node/output',
|
||||||
|
position: [0, 0],
|
||||||
|
props: {}
|
||||||
|
});
|
||||||
|
assert.isDefined(floatOutputNode);
|
||||||
|
|
||||||
|
const edge = manager.createEdge(floatInputNode, 0, floatOutputNode, 'input');
|
||||||
|
assert.isDefined(edge);
|
||||||
|
manager.save();
|
||||||
|
|
||||||
|
manager.groupNodes([]);
|
||||||
|
|
||||||
|
const graph = manager.serialize();
|
||||||
|
expect(graph.nodes.length).toBe(2);
|
||||||
|
expect(graph.edges.length).toBe(1);
|
||||||
|
expect(graph.groups.length).toBe(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should group selected nodes and create a group node', () => {
|
||||||
|
const registry = createMockNodeRegistry([
|
||||||
|
mockFloatOutputNode,
|
||||||
|
mockFloatInputNode,
|
||||||
|
mockGeometryOutputNode,
|
||||||
|
mockPathInputNode
|
||||||
|
]);
|
||||||
|
|
||||||
|
const manager = new GraphManager(registry);
|
||||||
|
|
||||||
|
const floatInputNode = manager.createNode({
|
||||||
|
type: 'test/node/input',
|
||||||
|
position: [100, 100],
|
||||||
|
props: {}
|
||||||
|
});
|
||||||
|
|
||||||
|
assert.isDefined(floatInputNode);
|
||||||
|
|
||||||
|
const floatOutputNode = manager.createNode({
|
||||||
|
type: 'test/node/output',
|
||||||
|
position: [0, 0],
|
||||||
|
props: {}
|
||||||
|
});
|
||||||
|
assert.isDefined(floatOutputNode);
|
||||||
|
|
||||||
|
const edge = manager.createEdge(floatInputNode, 0, floatOutputNode, 'input');
|
||||||
|
assert.isDefined(edge);
|
||||||
|
manager.save();
|
||||||
|
|
||||||
|
const groupNode = manager.groupNodes([floatInputNode.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
const graph = manager.serialize();
|
||||||
|
|
||||||
|
expect(graph.nodes.map(n => n.id), 'graph to contain group node').to.contain(groupNode.id);
|
||||||
|
expect(graph.groups[0].nodes.map(n => n.id), 'group graph to contain float node').to.contain(
|
||||||
|
floatInputNode.id
|
||||||
|
);
|
||||||
|
expect(graph.nodes.map(n => n.id)).not.to.contain(floatInputNode.id);
|
||||||
|
|
||||||
|
expect(graph.nodes.length).toBe(2);
|
||||||
|
expect(graph.edges.length).toBe(1);
|
||||||
|
expect(graph.groups.length).toBe(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('should rewire external edges when grouping a middle node in a chain', () => {
|
||||||
|
const registry = createMockNodeRegistry([mockFloatOutputNode, mockFloatInputNode]);
|
||||||
|
const manager = new GraphManager(registry);
|
||||||
|
|
||||||
|
// A → B → C (float chain: output → middle → input)
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
const nodeB = manager.createNode({ type: 'test/node/output', position: [100, 0], props: {} });
|
||||||
|
const nodeC = manager.createNode({ type: 'test/node/input', position: [200, 0], props: {} });
|
||||||
|
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
assert.isDefined(nodeB);
|
||||||
|
assert.isDefined(nodeC);
|
||||||
|
|
||||||
|
manager.createEdge(nodeA, 0, nodeB, 'input');
|
||||||
|
manager.createEdge(nodeB, 0, nodeC, 'value');
|
||||||
|
|
||||||
|
const groupNode = manager.groupNodes([nodeB.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
const graph = manager.serialize();
|
||||||
|
|
||||||
|
// Top-level: A, C, groupNode — B is gone
|
||||||
|
expect(graph.nodes.length, 'top-level node count').toBe(3);
|
||||||
|
const topLevelIds = graph.nodes.map(n => n.id);
|
||||||
|
expect(topLevelIds).toContain(nodeA.id);
|
||||||
|
expect(topLevelIds).toContain(nodeC.id);
|
||||||
|
expect(topLevelIds).toContain(groupNode.id);
|
||||||
|
expect(topLevelIds).not.toContain(nodeB.id);
|
||||||
|
|
||||||
|
// Both original edges survive, now routing through the group node
|
||||||
|
expect(graph.edges.length, 'edge count unchanged').toBe(2);
|
||||||
|
const edgeSources = graph.edges.map(e => e[0]);
|
||||||
|
const edgeTargets = graph.edges.map(e => e[2]);
|
||||||
|
expect(edgeTargets).toContain(groupNode.id); // A → groupNode
|
||||||
|
expect(edgeSources).toContain(groupNode.id); // groupNode → C
|
||||||
|
|
||||||
|
// One group definition was created
|
||||||
|
expect(graph.groups.length).toBe(1);
|
||||||
|
const group = graph.groups[0];
|
||||||
|
|
||||||
|
// Group contains B plus the two boundary nodes
|
||||||
|
const groupNodeIds = group.nodes.map(n => n.id);
|
||||||
|
expect(groupNodeIds).toContain(nodeB.id);
|
||||||
|
const inputBoundary = group.nodes.find(n => n.type === '__internal/group/input');
|
||||||
|
const outputBoundary = group.nodes.find(n => n.type === '__internal/group/output');
|
||||||
|
expect(inputBoundary, 'group input boundary node').toBeDefined();
|
||||||
|
expect(outputBoundary, 'group output boundary node').toBeDefined();
|
||||||
|
|
||||||
|
// Group declares one input slot and one output slot
|
||||||
|
expect(Object.keys(group.inputs ?? {}).length, 'group input count').toBe(1);
|
||||||
|
expect(group.outputs?.length, 'group output count').toBe(1);
|
||||||
|
|
||||||
|
// Internal edges wire: inputBoundary → B → outputBoundary
|
||||||
|
expect(group.edges.length, 'internal edge count').toBe(2);
|
||||||
|
const internalSources = group.edges.map(e => e[0]);
|
||||||
|
const internalTargets = group.edges.map(e => e[2]);
|
||||||
|
expect(internalTargets).toContain(nodeB.id);
|
||||||
|
expect(internalSources).toContain(nodeB.id);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
describe('getPossibleSockets', () => {
|
describe('getPossibleSockets', () => {
|
||||||
describe('when dragging an output socket', () => {
|
describe('when dragging an output socket', () => {
|
||||||
it('should return compatible input sockets based on type', () => {
|
it('should return compatible input sockets based on type', () => {
|
||||||
@@ -262,4 +405,3 @@ describe('GraphManager', () => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
|
||||||
|
|||||||
@@ -1,8 +1,10 @@
|
|||||||
import throttle from '$lib/helpers/throttle';
|
import throttle from '$lib/helpers/throttle';
|
||||||
import { RemoteNodeRegistry } from '$lib/node-registry/index';
|
import { RemoteNodeRegistry } from '$lib/node-registry/index';
|
||||||
import type {
|
import type {
|
||||||
|
Box,
|
||||||
Edge,
|
Edge,
|
||||||
Graph,
|
Graph,
|
||||||
|
GroupDefinition,
|
||||||
NodeDefinition,
|
NodeDefinition,
|
||||||
NodeId,
|
NodeId,
|
||||||
NodeInput,
|
NodeInput,
|
||||||
@@ -21,8 +23,8 @@ logger.mute();
|
|||||||
|
|
||||||
const remoteRegistry = new RemoteNodeRegistry('');
|
const remoteRegistry = new RemoteNodeRegistry('');
|
||||||
|
|
||||||
const clone = 'structuredClone' in self
|
const clone = 'structuredClone' in globalThis
|
||||||
? self.structuredClone
|
? globalThis.structuredClone
|
||||||
: (args: unknown) => JSON.parse(JSON.stringify(args));
|
: (args: unknown) => JSON.parse(JSON.stringify(args));
|
||||||
|
|
||||||
function areSocketsCompatible(
|
function areSocketsCompatible(
|
||||||
@@ -67,13 +69,26 @@ export class GraphManager extends EventEmitter<{
|
|||||||
status = $state<'loading' | 'idle' | 'error'>();
|
status = $state<'loading' | 'idle' | 'error'>();
|
||||||
loaded = false;
|
loaded = false;
|
||||||
|
|
||||||
graph: Graph = { id: 0, nodes: [], edges: [] };
|
graph: Graph = $state({ id: 0, nodes: [], edges: [], groups: [] });
|
||||||
id = $state(0);
|
id = $state(0);
|
||||||
|
|
||||||
nodes = new SvelteMap<number, NodeInstance>();
|
nodes = new SvelteMap<number, NodeInstance>();
|
||||||
|
nodeArray = $derived(Array.from(this.nodes.values()));
|
||||||
|
|
||||||
edges = $state<Edge[]>([]);
|
edges = $state<Edge[]>([]);
|
||||||
|
|
||||||
|
// Plain array — NOT $state. rootGraph items are plain-serialized (safe for structuredClone).
|
||||||
|
// savedNodes/savedEdges hold live reactive references so reactivity is preserved on exit.
|
||||||
|
graphStack: {
|
||||||
|
rootGraph: Graph;
|
||||||
|
savedNodes: Map<number, NodeInstance>;
|
||||||
|
savedEdges: Edge[];
|
||||||
|
outerGraph: Graph;
|
||||||
|
groupId: number;
|
||||||
|
nodeId: number;
|
||||||
|
cameraPosition: [number, number, number];
|
||||||
|
}[] = [];
|
||||||
|
|
||||||
settingTypes: Record<string, NodeInput> = {};
|
settingTypes: Record<string, NodeInput> = {};
|
||||||
settings = $state<Record<string, unknown>>();
|
settings = $state<Record<string, unknown>>();
|
||||||
|
|
||||||
@@ -88,9 +103,25 @@ export class GraphManager extends EventEmitter<{
|
|||||||
});
|
});
|
||||||
|
|
||||||
history: HistoryManager = new HistoryManager();
|
history: HistoryManager = new HistoryManager();
|
||||||
|
|
||||||
|
public serializeFullGraph(): Graph {
|
||||||
|
if (this.graphStack.length === 0) return this.serialize();
|
||||||
|
let merged = this.serialize();
|
||||||
|
for (let i = this.graphStack.length - 1; i >= 0; i--) {
|
||||||
|
const { rootGraph, groupId } = this.graphStack[i];
|
||||||
|
merged = {
|
||||||
|
...rootGraph,
|
||||||
|
groups: rootGraph.groups.map(g =>
|
||||||
|
g.id === groupId ? { ...g, nodes: merged.nodes, edges: merged.edges } : g
|
||||||
|
)
|
||||||
|
};
|
||||||
|
}
|
||||||
|
return merged;
|
||||||
|
}
|
||||||
|
|
||||||
execute = throttle(() => {
|
execute = throttle(() => {
|
||||||
if (this.loaded === false) return;
|
if (this.loaded === false) return;
|
||||||
this.emit('result', this.serialize());
|
this.emit('result', this.serializeFullGraph());
|
||||||
}, 10);
|
}, 10);
|
||||||
|
|
||||||
constructor(public registry: NodeRegistry) {
|
constructor(public registry: NodeRegistry) {
|
||||||
@@ -110,10 +141,30 @@ export class GraphManager extends EventEmitter<{
|
|||||||
edge[2].id,
|
edge[2].id,
|
||||||
edge[3]
|
edge[3]
|
||||||
]) as Graph['edges'];
|
]) as Graph['edges'];
|
||||||
|
|
||||||
|
const groups = this.graph.groups?.map((group) => {
|
||||||
|
const groupNodes = group.nodes.map((node) => ({
|
||||||
|
id: node.id,
|
||||||
|
position: [...node.position],
|
||||||
|
type: node.type,
|
||||||
|
props: node.props
|
||||||
|
})) as NodeInstance[];
|
||||||
|
|
||||||
|
return {
|
||||||
|
id: group.id,
|
||||||
|
name: group.name,
|
||||||
|
inputs: group.inputs,
|
||||||
|
outputs: group.outputs,
|
||||||
|
nodes: groupNodes,
|
||||||
|
edges: group.edges
|
||||||
|
};
|
||||||
|
});
|
||||||
|
|
||||||
const serialized = {
|
const serialized = {
|
||||||
id: this.graph.id,
|
id: this.graph.id,
|
||||||
settings: $state.snapshot(this.settings),
|
settings: $state.snapshot(this.settings),
|
||||||
meta: $state.snapshot(this.graph.meta),
|
meta: $state.snapshot(this.graph.meta),
|
||||||
|
groups,
|
||||||
nodes,
|
nodes,
|
||||||
edges
|
edges
|
||||||
};
|
};
|
||||||
@@ -242,6 +293,28 @@ export class GraphManager extends EventEmitter<{
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
tryConnectToDebugNode(nodeId: number) {
|
||||||
|
const node = this.nodes.get(nodeId);
|
||||||
|
if (!node) return;
|
||||||
|
if (node.type.endsWith('/debug')) return;
|
||||||
|
if (!node.state.type?.outputs?.length) return;
|
||||||
|
let debugNode = this.nodes.values().find(n => n.type.endsWith('/debug'));
|
||||||
|
|
||||||
|
if (!debugNode) {
|
||||||
|
debugNode = this.createNode({
|
||||||
|
type: '__internal/node/debug',
|
||||||
|
position: [node.position[0] + 30, node.position[1]],
|
||||||
|
props: {}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if (debugNode) {
|
||||||
|
this.createEdge(node, 0, debugNode, 'input');
|
||||||
|
}
|
||||||
|
|
||||||
|
return debugNode;
|
||||||
|
}
|
||||||
|
|
||||||
getEdgesBetweenNodes(nodes: NodeInstance[]): [number, number, number, string][] {
|
getEdgesBetweenNodes(nodes: NodeInstance[]): [number, number, number, string][] {
|
||||||
const edges = [];
|
const edges = [];
|
||||||
for (const node of nodes) {
|
for (const node of nodes) {
|
||||||
@@ -269,13 +342,11 @@ export class GraphManager extends EventEmitter<{
|
|||||||
private _init(graph: Graph) {
|
private _init(graph: Graph) {
|
||||||
const nodes = new SvelteMap(
|
const nodes = new SvelteMap(
|
||||||
graph.nodes.map((node) => {
|
graph.nodes.map((node) => {
|
||||||
const nodeType = this.registry.getNode(node.type);
|
|
||||||
const n = node as NodeInstance;
|
const n = node as NodeInstance;
|
||||||
if (nodeType) {
|
const registryType = this.registry.getNode(node.type);
|
||||||
n.state = {
|
n.state = registryType ? { type: registryType } : {};
|
||||||
type: nodeType
|
const resolvedType = this.getNodeType(n);
|
||||||
};
|
if (resolvedType) n.state = { type: resolvedType };
|
||||||
}
|
|
||||||
return [node.id, n];
|
return [node.id, n];
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
@@ -305,19 +376,36 @@ export class GraphManager extends EventEmitter<{
|
|||||||
const a = performance.now();
|
const a = performance.now();
|
||||||
|
|
||||||
this.loaded = false;
|
this.loaded = false;
|
||||||
|
graph.groups ??= [];
|
||||||
this.graph = graph;
|
this.graph = graph;
|
||||||
this.status = 'loading';
|
this.status = 'loading';
|
||||||
this.id = graph.id;
|
this.id = graph.id;
|
||||||
|
|
||||||
logger.info('loading graph', { nodes: graph.nodes, edges: graph.edges, id: graph.id });
|
logger.info(
|
||||||
|
'loading graph',
|
||||||
|
{ nodes: graph.nodes, edges: graph.edges, id: graph.id }
|
||||||
|
);
|
||||||
|
|
||||||
|
const nodeIds = Array
|
||||||
|
.from(
|
||||||
|
new SvelteSet(
|
||||||
|
[
|
||||||
|
...graph.nodes,
|
||||||
|
graph?.groups?.map(g => g.nodes).flat()
|
||||||
|
]
|
||||||
|
.filter(n => n && 'type' in n)
|
||||||
|
.map((n) => n.type)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
.filter(n => !n.startsWith('__internal/'));
|
||||||
|
|
||||||
const nodeIds = Array.from(new SvelteSet([...graph.nodes.map((n) => n.type)]));
|
|
||||||
await this.registry.load(nodeIds);
|
await this.registry.load(nodeIds);
|
||||||
|
|
||||||
// Fetch all nodes from all collections of the loaded nodes
|
// Fetch all nodes from all collections of the loaded nodes
|
||||||
const allCollections = new SvelteSet<`${string}/${string}`>();
|
const allCollections = new SvelteSet<`${string}/${string}`>();
|
||||||
for (const id of nodeIds) {
|
for (const id of nodeIds) {
|
||||||
const [user, collection] = id.split('/');
|
const [user, collection] = id.split('/');
|
||||||
|
if (user === '__internal') continue;
|
||||||
allCollections.add(`${user}/${collection}`);
|
allCollections.add(`${user}/${collection}`);
|
||||||
}
|
}
|
||||||
for (const collection of allCollections) {
|
for (const collection of allCollections) {
|
||||||
@@ -333,7 +421,7 @@ export class GraphManager extends EventEmitter<{
|
|||||||
|
|
||||||
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);
|
||||||
if (!nodeType) {
|
if (!nodeType && !node.type.startsWith('__internal/')) {
|
||||||
logger.error(`Node type not found: ${node.type}`);
|
logger.error(`Node type not found: ${node.type}`);
|
||||||
this.status = 'error';
|
this.status = 'error';
|
||||||
return;
|
return;
|
||||||
@@ -389,15 +477,110 @@ export class GraphManager extends EventEmitter<{
|
|||||||
}
|
}
|
||||||
|
|
||||||
getAllNodes() {
|
getAllNodes() {
|
||||||
return Array.from(this.nodes.values());
|
return Array
|
||||||
|
.from(this.nodes.values());
|
||||||
}
|
}
|
||||||
|
|
||||||
getNode(id: number) {
|
getNode(id: number) {
|
||||||
return this.nodes.get(id);
|
return this.nodes.get(id);
|
||||||
}
|
}
|
||||||
|
|
||||||
getNodeType(id: string) {
|
getNodeType(node: NodeInstance) {
|
||||||
return this.registry.getNode(id);
|
if (!node) {
|
||||||
|
console.trace('failed to get node type', { node });
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (node.type === '__internal/group/input') {
|
||||||
|
const groupId = this.graphStack.at(-1)?.groupId;
|
||||||
|
const group = groupId !== undefined ? this.getGroup(groupId) : undefined;
|
||||||
|
if (!group) return node.state.type;
|
||||||
|
|
||||||
|
const groupInputs: NodeDefinition['inputs'] = Object.fromEntries(
|
||||||
|
Object.values(group?.inputs || {}).map((o, i) => {
|
||||||
|
return [
|
||||||
|
`in_${i}`,
|
||||||
|
{
|
||||||
|
...o,
|
||||||
|
external: true
|
||||||
|
}
|
||||||
|
];
|
||||||
|
}) || []
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
id: '__internal/group/input' as NodeId,
|
||||||
|
meta: {
|
||||||
|
title: 'Group Input'
|
||||||
|
},
|
||||||
|
inputs: groupInputs,
|
||||||
|
execute: (x: Int32Array) => x
|
||||||
|
} as NodeDefinition;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (node.type === '__internal/group/output') {
|
||||||
|
const groupId = this.graphStack.at(-1)?.groupId;
|
||||||
|
const group = groupId !== undefined ? this.getGroup(groupId) : undefined;
|
||||||
|
if (!group) return node.state.type;
|
||||||
|
return {
|
||||||
|
id: '__internal/group/output' as NodeId,
|
||||||
|
inputs: Object.fromEntries(
|
||||||
|
(group.outputs ?? []).map((
|
||||||
|
o,
|
||||||
|
i
|
||||||
|
) => [`out_${i}`, { type: o.type, label: o.label, external: true }])
|
||||||
|
),
|
||||||
|
meta: {
|
||||||
|
title: 'Group Output'
|
||||||
|
},
|
||||||
|
outputs: [],
|
||||||
|
execute: (x: Int32Array) => x
|
||||||
|
} as NodeDefinition;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Construct the group inputs on the fly
|
||||||
|
if (node.type === '__internal/group/instance') {
|
||||||
|
const groupDefinition = this.getGroup(node.props?.groupId as number);
|
||||||
|
|
||||||
|
if (!groupDefinition) {
|
||||||
|
logger.error(`Group not found: ${node.props?.groupId}`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const defaultInputs = {
|
||||||
|
...(node.state.type?.inputs || {}),
|
||||||
|
...groupDefinition?.inputs
|
||||||
|
};
|
||||||
|
|
||||||
|
// This is to make sure the the groupId is always first
|
||||||
|
delete defaultInputs['groupId'];
|
||||||
|
const inputs = {
|
||||||
|
'groupId': {
|
||||||
|
type: 'select',
|
||||||
|
label: 'Group',
|
||||||
|
value: node.props?.groupId,
|
||||||
|
internal: true,
|
||||||
|
options: this.graph.groups.map((g, i) => ({
|
||||||
|
value: g.id,
|
||||||
|
label: g.name || `Group ${i + 1}`
|
||||||
|
}))
|
||||||
|
},
|
||||||
|
...defaultInputs
|
||||||
|
};
|
||||||
|
|
||||||
|
const groupType = {
|
||||||
|
...node.state.type,
|
||||||
|
meta: {
|
||||||
|
title: 'Group',
|
||||||
|
...node?.state?.type?.meta || {}
|
||||||
|
},
|
||||||
|
inputs,
|
||||||
|
outputs: groupDefinition?.outputs?.map(o => o.type)
|
||||||
|
} as NodeDefinition;
|
||||||
|
|
||||||
|
return groupType;
|
||||||
|
}
|
||||||
|
|
||||||
|
return node.state.type;
|
||||||
}
|
}
|
||||||
|
|
||||||
async loadNodeType(id: NodeId) {
|
async loadNodeType(id: NodeId) {
|
||||||
@@ -502,8 +685,90 @@ export class GraphManager extends EventEmitter<{
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
getGroup(id: number) {
|
||||||
|
return this.graph.groups.find(g => g.id === id);
|
||||||
|
}
|
||||||
|
|
||||||
|
renameGroup(groupId: number, name: string) {
|
||||||
|
const group = this.getGroup(groupId);
|
||||||
|
if (!group) return;
|
||||||
|
group.name = name;
|
||||||
|
this.save();
|
||||||
|
}
|
||||||
|
|
||||||
|
isInsideGroup = $state(false);
|
||||||
|
|
||||||
|
enterGroup(nodeId: number, cameraPosition: [number, number, number]): boolean {
|
||||||
|
const groupNode = this.getNode(nodeId);
|
||||||
|
if (!groupNode || groupNode.type !== '__internal/group/instance') return false;
|
||||||
|
const groupId = groupNode.props?.groupId as number;
|
||||||
|
const group = this.getGroup(groupId);
|
||||||
|
if (!group) return false;
|
||||||
|
|
||||||
|
this.graphStack.push({
|
||||||
|
rootGraph: this.serialize(),
|
||||||
|
savedNodes: new SvelteMap(this.nodes),
|
||||||
|
savedEdges: [...this.edges],
|
||||||
|
outerGraph: this.graph,
|
||||||
|
groupId,
|
||||||
|
nodeId,
|
||||||
|
cameraPosition
|
||||||
|
});
|
||||||
|
this.graph = { ...this.graph, nodes: group.nodes, edges: group.edges };
|
||||||
|
this._init(this.graph);
|
||||||
|
this.history.reset();
|
||||||
|
this.isInsideGroup = true;
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
exitGroup(): { camera: [number, number, number]; nodeId: number } | false {
|
||||||
|
if (!this.graphStack.length) return false;
|
||||||
|
const { savedNodes, savedEdges, outerGraph, groupId, nodeId, cameraPosition } = this.graphStack
|
||||||
|
.pop()!;
|
||||||
|
const internalState = this.serialize();
|
||||||
|
|
||||||
|
// Clear stale DOM/mesh refs so the remounting components register fresh ones.
|
||||||
|
// The $effect guards in NodeHTML/Node only set these when undefined, so without
|
||||||
|
// this clear they'd keep pointing to the detached elements from before group entry.
|
||||||
|
for (const node of savedNodes.values()) {
|
||||||
|
node.state.ref = undefined;
|
||||||
|
node.state.mesh = undefined;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Restore live reactive nodes and edges so drag-reactivity is preserved
|
||||||
|
this.nodes.clear();
|
||||||
|
for (const [id, node] of savedNodes) {
|
||||||
|
this.nodes.set(id, node);
|
||||||
|
}
|
||||||
|
this.edges = savedEdges;
|
||||||
|
|
||||||
|
// Patch the group definition with the edited internal graph
|
||||||
|
this.graph = {
|
||||||
|
...outerGraph,
|
||||||
|
groups: (outerGraph.groups ?? []).map(g =>
|
||||||
|
g.id === groupId ? { ...g, nodes: internalState.nodes, edges: internalState.edges } : g
|
||||||
|
)
|
||||||
|
};
|
||||||
|
|
||||||
|
this.history.reset();
|
||||||
|
this.isInsideGroup = this.graphStack.length > 0;
|
||||||
|
this.execute();
|
||||||
|
this.save();
|
||||||
|
return { camera: cameraPosition, nodeId };
|
||||||
|
}
|
||||||
|
|
||||||
createNodeId() {
|
createNodeId() {
|
||||||
return Math.max(0, ...this.nodes.keys()) + 1;
|
const ids = [
|
||||||
|
...this.nodes.keys(),
|
||||||
|
...this.graph.groups.map(g => g.id),
|
||||||
|
...this.graph.groups.flatMap(g => g.nodes.map(n => n.id))
|
||||||
|
];
|
||||||
|
|
||||||
|
let id = 0;
|
||||||
|
while (ids.includes(id)) {
|
||||||
|
id++;
|
||||||
|
}
|
||||||
|
return id;
|
||||||
}
|
}
|
||||||
|
|
||||||
createGraph(nodes: NodeInstance[], edges: [number, number, number, string][]) {
|
createGraph(nodes: NodeInstance[], edges: [number, number, number, string][]) {
|
||||||
@@ -516,7 +781,7 @@ export class GraphManager extends EventEmitter<{
|
|||||||
const id = startId++;
|
const id = startId++;
|
||||||
idMap.set(node.id, id);
|
idMap.set(node.id, id);
|
||||||
const type = this.registry.getNode(node.type);
|
const type = this.registry.getNode(node.type);
|
||||||
if (!type) {
|
if (!type && !node.type.startsWith('__internal/')) {
|
||||||
throw new Error(`Node type not found: ${node.type}`);
|
throw new Error(`Node type not found: ${node.type}`);
|
||||||
}
|
}
|
||||||
return { ...node, id, tmp: { type } };
|
return { ...node, id, tmp: { type } };
|
||||||
@@ -549,6 +814,165 @@ export class GraphManager extends EventEmitter<{
|
|||||||
return nodes;
|
return nodes;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
removeUnusedGroups() {
|
||||||
|
const usedGroups = new SvelteSet(this.getAllNodes().map(n => n.props?.groupId));
|
||||||
|
const unusedGroupAmount = this.graph.groups.length - usedGroups.size;
|
||||||
|
this.graph.groups = this.graph.groups.filter(g => usedGroups.has(g.id));
|
||||||
|
this.save();
|
||||||
|
return unusedGroupAmount;
|
||||||
|
}
|
||||||
|
|
||||||
|
groupNodes(nodeIds: number[]) {
|
||||||
|
this.startUndoGroup();
|
||||||
|
this.removeUnusedGroups();
|
||||||
|
|
||||||
|
const nodes = [
|
||||||
|
...new SvelteSet(nodeIds).values().map(id => this.getNode(id)).filter(Boolean)
|
||||||
|
] as NodeInstance[];
|
||||||
|
|
||||||
|
if (!nodes.length) return;
|
||||||
|
|
||||||
|
logger.log(`Grouping ${nodes.length} nodes`, { nodes });
|
||||||
|
|
||||||
|
const ids = new SvelteSet(nodes.map(n => n.id));
|
||||||
|
|
||||||
|
// We use the map to dedupe when one external node is connected to multiple internal nodes
|
||||||
|
// ┌──internal_a
|
||||||
|
// external──┤
|
||||||
|
// └──internal_b
|
||||||
|
// This should only result in one group input not two
|
||||||
|
const incomingEdges = this.edges.filter((edge) => ids.has(edge[2].id) && !ids.has(edge[0].id));
|
||||||
|
const groupInputs = new SvelteMap<string, Edge>();
|
||||||
|
for (const edge of incomingEdges) {
|
||||||
|
groupInputs.set(`${edge[0].id}-${edge[1]}`, edge);
|
||||||
|
}
|
||||||
|
|
||||||
|
// And the same for the outputs
|
||||||
|
const outgoingEdges = this.edges.filter((edge) => ids.has(edge[0].id) && !ids.has(edge[2].id));
|
||||||
|
const groupOutputs = new SvelteMap<string, Edge>();
|
||||||
|
for (const edge of outgoingEdges) {
|
||||||
|
groupOutputs.set(`${edge[2].id}-${edge[3]}`, edge);
|
||||||
|
}
|
||||||
|
|
||||||
|
const inputs: Record<string, NodeInput> = {};
|
||||||
|
[...groupInputs.values()].forEach((edge, i) => {
|
||||||
|
const input = {
|
||||||
|
label: `Input ${i}`,
|
||||||
|
type: edge[0].state.type?.outputs?.[edge[1]] || '*'
|
||||||
|
};
|
||||||
|
inputs[`input_${i}`] = input as NodeInput;
|
||||||
|
});
|
||||||
|
|
||||||
|
const outputs = [...groupOutputs.values()].map((edge, i) => ({
|
||||||
|
label: `Output ${i}`,
|
||||||
|
type: edge[2].state.type?.inputs?.[edge[3]].type || '*'
|
||||||
|
}));
|
||||||
|
|
||||||
|
const groupPosition = [0, 0] as [number, number];
|
||||||
|
const bounds: Box = { minX: Infinity, maxX: -Infinity, minY: Infinity, maxY: -Infinity };
|
||||||
|
for (const node of nodes) {
|
||||||
|
groupPosition[0] += node.position[0];
|
||||||
|
groupPosition[1] += node.position[1];
|
||||||
|
bounds.minX = Math.min(bounds.minX, node.position[0]);
|
||||||
|
bounds.maxX = Math.max(bounds.maxX, node.position[0]);
|
||||||
|
bounds.minY = Math.min(bounds.minY, node.position[1]);
|
||||||
|
bounds.maxY = Math.max(bounds.maxY, node.position[1]);
|
||||||
|
}
|
||||||
|
groupPosition[0] /= nodes.length;
|
||||||
|
groupPosition[1] /= nodes.length;
|
||||||
|
|
||||||
|
// Map from deduped edge source key → group input index, used for both
|
||||||
|
// internal edge wiring and external edge socket naming.
|
||||||
|
const inputIndexByEdgeKey = new SvelteMap<string, number>();
|
||||||
|
[...groupInputs.keys()].forEach((key, i) => inputIndexByEdgeKey.set(key, i));
|
||||||
|
|
||||||
|
// Allocate all needed IDs up front so sequential calls never collide.
|
||||||
|
const usedIds = new SvelteSet<number>([
|
||||||
|
...this.nodes.keys(),
|
||||||
|
...this.graph.groups.map(g => g.id),
|
||||||
|
...this.graph.groups.flatMap(g => g.nodes.map(n => n.id))
|
||||||
|
]);
|
||||||
|
const nextId = () => {
|
||||||
|
let id = 0;
|
||||||
|
while (usedIds.has(id)) id++;
|
||||||
|
usedIds.add(id);
|
||||||
|
return id;
|
||||||
|
};
|
||||||
|
|
||||||
|
const groupInputNode: NodeInstance = {
|
||||||
|
id: nextId(),
|
||||||
|
type: '__internal/group/input',
|
||||||
|
position: [bounds.minX - 50, (bounds.minY + bounds.maxY) / 2],
|
||||||
|
state: {}
|
||||||
|
};
|
||||||
|
|
||||||
|
const groupOutputNode: NodeInstance = {
|
||||||
|
id: nextId(),
|
||||||
|
type: '__internal/group/output',
|
||||||
|
position: [bounds.maxX + 25, (bounds.minY + bounds.maxY) / 2],
|
||||||
|
state: {}
|
||||||
|
};
|
||||||
|
|
||||||
|
// Edges that are inside the group, routed through boundary nodes at
|
||||||
|
// the correct input/output index for each unique external connection.
|
||||||
|
const internalEdges = this.edges.filter((edge) => {
|
||||||
|
return ids.has(edge[0].id) || ids.has(edge[2].id);
|
||||||
|
}).map((edge) => {
|
||||||
|
if (!ids.has(edge[0].id)) {
|
||||||
|
const idx = inputIndexByEdgeKey.get(`${edge[0].id}-${edge[1]}`) ?? 0;
|
||||||
|
return [groupInputNode.id, idx, edge[2].id, edge[3]];
|
||||||
|
} else if (!ids.has(edge[2].id)) {
|
||||||
|
return [edge[0].id, edge[1], groupOutputNode.id, 'out_0'];
|
||||||
|
}
|
||||||
|
return [edge[0].id, edge[1], edge[2].id, edge[3]];
|
||||||
|
}) as [number, number, number, string][];
|
||||||
|
|
||||||
|
const groupId = nextId();
|
||||||
|
const groupDefinition: GroupDefinition = {
|
||||||
|
id: groupId,
|
||||||
|
inputs: inputs,
|
||||||
|
outputs: outputs,
|
||||||
|
edges: internalEdges,
|
||||||
|
nodes: [groupInputNode, ...nodes, groupOutputNode]
|
||||||
|
};
|
||||||
|
|
||||||
|
// Push before createNode so createNodeId() inside sees the allocated IDs.
|
||||||
|
this.graph.groups.push(groupDefinition);
|
||||||
|
|
||||||
|
const groupNode = this.createNode({
|
||||||
|
type: '__internal/group/instance',
|
||||||
|
position: [groupPosition[0], groupPosition[1]],
|
||||||
|
props: {
|
||||||
|
groupId: groupId
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!groupNode) throw new Error('Failed to create group node');
|
||||||
|
|
||||||
|
// Rewire external edges to/from the group node using the correct input socket.
|
||||||
|
const externalEdges = this.edges.map((edge) => {
|
||||||
|
if (ids.has(edge[2].id)) {
|
||||||
|
const idx = inputIndexByEdgeKey.get(`${edge[0].id}-${edge[1]}`) ?? 0;
|
||||||
|
return [edge[0], edge[1], groupNode, `input_${idx}`] as Edge;
|
||||||
|
} else if (ids.has(edge[0].id)) {
|
||||||
|
return [groupNode, 0, edge[2], edge[3]] as Edge;
|
||||||
|
}
|
||||||
|
return edge;
|
||||||
|
});
|
||||||
|
|
||||||
|
this.nodes.set(groupNode.id, groupNode);
|
||||||
|
this.edges = externalEdges;
|
||||||
|
|
||||||
|
// Remove nodes from graph which are not part of the group
|
||||||
|
for (const node of nodes) {
|
||||||
|
this.removeNode(node);
|
||||||
|
}
|
||||||
|
|
||||||
|
this.saveUndoGroup();
|
||||||
|
|
||||||
|
return groupNode;
|
||||||
|
}
|
||||||
|
|
||||||
createNode({
|
createNode({
|
||||||
type,
|
type,
|
||||||
position,
|
position,
|
||||||
@@ -559,7 +983,7 @@ export class GraphManager extends EventEmitter<{
|
|||||||
props: NodeInstance['props'];
|
props: NodeInstance['props'];
|
||||||
}) {
|
}) {
|
||||||
const nodeType = this.registry.getNode(type);
|
const nodeType = this.registry.getNode(type);
|
||||||
if (!nodeType) {
|
if (!nodeType && !type.startsWith('__internal/')) {
|
||||||
logger.error(`Node type not found: ${type}`);
|
logger.error(`Node type not found: ${type}`);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -597,11 +1021,16 @@ export class GraphManager extends EventEmitter<{
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const fromType = this.getNodeType(from);
|
||||||
|
const toType = this.getNodeType(to);
|
||||||
|
|
||||||
// check if socket types match
|
// check if socket types match
|
||||||
const fromSocketType = from.state?.type?.outputs?.[fromSocket];
|
const fromSocketType = from.type === '__internal/group/input'
|
||||||
const toSocketType = [to.state?.type?.inputs?.[toSocket]?.type];
|
? fromType?.inputs?.[Object.keys(fromType?.inputs || {})[fromSocket]].type
|
||||||
if (to.state?.type?.inputs?.[toSocket]?.accepts) {
|
: fromType?.outputs?.[fromSocket];
|
||||||
toSocketType.push(...(to?.state?.type?.inputs?.[toSocket]?.accepts || []));
|
const toSocketType = [toType?.inputs?.[toSocket]?.type];
|
||||||
|
if (toType?.inputs?.[toSocket]?.accepts) {
|
||||||
|
toSocketType.push(...(toType?.inputs?.[toSocket]?.accepts || []));
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!areSocketsCompatible(fromSocketType, toSocketType)) {
|
if (!areSocketsCompatible(fromSocketType, toSocketType)) {
|
||||||
@@ -671,8 +1100,9 @@ export class GraphManager extends EventEmitter<{
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
this.emit('save', state);
|
const fullState = this.graphStack.length > 0 ? this.serializeFullGraph() : state;
|
||||||
logger.log('saving graphs', state);
|
this.emit('save', fullState);
|
||||||
|
logger.log('saving graphs', fullState);
|
||||||
}
|
}
|
||||||
|
|
||||||
getParentsOfNode(node: NodeInstance) {
|
getParentsOfNode(node: NodeInstance) {
|
||||||
@@ -724,7 +1154,7 @@ export class GraphManager extends EventEmitter<{
|
|||||||
}
|
}
|
||||||
|
|
||||||
getPossibleSockets({ node, index }: Socket): [NodeInstance, string | number][] {
|
getPossibleSockets({ node, index }: Socket): [NodeInstance, string | number][] {
|
||||||
const nodeType = node?.state?.type;
|
const nodeType = this.getNodeType(node);
|
||||||
if (!nodeType) return [];
|
if (!nodeType) return [];
|
||||||
|
|
||||||
const sockets: [NodeInstance, string | number][] = [];
|
const sockets: [NodeInstance, string | number][] = [];
|
||||||
@@ -740,7 +1170,7 @@ export class GraphManager extends EventEmitter<{
|
|||||||
const ownType = nodeType?.inputs?.[index].type;
|
const ownType = nodeType?.inputs?.[index].type;
|
||||||
|
|
||||||
for (const node of nodes) {
|
for (const node of nodes) {
|
||||||
const nodeType = node?.state?.type;
|
const nodeType = this.getNodeType(node);
|
||||||
const inputs = nodeType?.outputs;
|
const inputs = nodeType?.outputs;
|
||||||
if (!inputs) continue;
|
if (!inputs) continue;
|
||||||
for (let index = 0; index < inputs.length; index++) {
|
for (let index = 0; index < inputs.length; index++) {
|
||||||
@@ -769,10 +1199,12 @@ export class GraphManager extends EventEmitter<{
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
const ownType = nodeType.outputs?.[index];
|
const ownType = node.type === '__internal/group/input'
|
||||||
|
? nodeType.inputs?.[Object.keys(nodeType?.inputs || {})[index]].type
|
||||||
|
: nodeType.outputs?.[index];
|
||||||
|
|
||||||
for (const node of nodes) {
|
for (const node of nodes) {
|
||||||
const inputs = node?.state?.type?.inputs;
|
const inputs = this.getNodeType(node)?.inputs;
|
||||||
if (!inputs) continue;
|
if (!inputs) continue;
|
||||||
for (const key in inputs) {
|
for (const key in inputs) {
|
||||||
const otherType = [inputs[key].type];
|
const otherType = [inputs[key].type];
|
||||||
|
|||||||
@@ -0,0 +1,282 @@
|
|||||||
|
import { assert, describe, expect, it } from 'vitest';
|
||||||
|
import { GraphManager } from './graph-manager.svelte';
|
||||||
|
import { GraphState } from './graph-state.svelte';
|
||||||
|
import { createMockNodeRegistry, mockFloatInputNode, mockFloatOutputNode } from './test-utils';
|
||||||
|
|
||||||
|
// GraphState constructor reads localStorage synchronously — mock before any instantiation
|
||||||
|
Object.defineProperty(globalThis, 'localStorage', {
|
||||||
|
value: {
|
||||||
|
getItem: () => null,
|
||||||
|
setItem: () => {},
|
||||||
|
removeItem: () => {},
|
||||||
|
clear: () => {},
|
||||||
|
length: 0,
|
||||||
|
key: () => null
|
||||||
|
} as Storage,
|
||||||
|
writable: true,
|
||||||
|
configurable: true
|
||||||
|
});
|
||||||
|
|
||||||
|
function createFixture() {
|
||||||
|
const registry = createMockNodeRegistry([mockFloatOutputNode, mockFloatInputNode]);
|
||||||
|
const manager = new GraphManager(registry);
|
||||||
|
const state = new GraphState(manager);
|
||||||
|
return { manager, state };
|
||||||
|
}
|
||||||
|
|
||||||
|
describe('clearSelection', () => {
|
||||||
|
it('empties selectedNodes', () => {
|
||||||
|
const { state } = createFixture();
|
||||||
|
state.selectedNodes.add(1);
|
||||||
|
state.selectedNodes.add(2);
|
||||||
|
state.clearSelection();
|
||||||
|
expect(state.selectedNodes.size).toBe(0);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('projectScreenToWorld', () => {
|
||||||
|
it('maps the viewport centre to the camera position', () => {
|
||||||
|
const { state } = createFixture();
|
||||||
|
// cameraPosition default: [140, 100, 3.5], width=100, height=100
|
||||||
|
state.width = 100;
|
||||||
|
state.height = 100;
|
||||||
|
state.cameraPosition = [140, 100, 3.5];
|
||||||
|
const [wx, wy] = state.projectScreenToWorld(50, 50);
|
||||||
|
expect(wx).toBeCloseTo(140);
|
||||||
|
expect(wy).toBeCloseTo(100);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('offsets correctly for a point not at centre', () => {
|
||||||
|
const { state } = createFixture();
|
||||||
|
state.width = 100;
|
||||||
|
state.height = 100;
|
||||||
|
state.cameraPosition = [0, 0, 2];
|
||||||
|
const [wx, wy] = state.projectScreenToWorld(100, 50);
|
||||||
|
// x: 0 + (100 - 50) / 2 = 25
|
||||||
|
expect(wx).toBeCloseTo(25);
|
||||||
|
expect(wy).toBeCloseTo(0);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('groupSelectedNodes', () => {
|
||||||
|
it('delegates to graph.groupNodes with selected IDs and activeNodeId', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
const nodeB = manager.createNode({ type: 'test/node/input', position: [100, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
assert.isDefined(nodeB);
|
||||||
|
|
||||||
|
state.selectedNodes.add(nodeA!.id);
|
||||||
|
state.activeNodeId = nodeB!.id;
|
||||||
|
|
||||||
|
const groupNode = state.groupSelectedNodes();
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
const graph = manager.serialize();
|
||||||
|
expect(graph.groups.length).toBe(1);
|
||||||
|
expect(graph.nodes.map(n => n.id)).toContain(groupNode!.id);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('works when only activeNodeId is set with no extra selection', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
|
||||||
|
state.activeNodeId = nodeA!.id;
|
||||||
|
const groupNode = state.groupSelectedNodes();
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
expect(manager.graph.groups.length).toBe(1);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('enterGroupNode', () => {
|
||||||
|
it('does nothing when activeNodeId is -1', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
state.activeNodeId = -1;
|
||||||
|
state.enterGroupNode();
|
||||||
|
expect(manager.graphStack.length).toBe(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('does nothing when the active node is not a group instance', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
const node = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(node);
|
||||||
|
state.activeNodeId = node!.id;
|
||||||
|
state.enterGroupNode();
|
||||||
|
expect(manager.graphStack.length).toBe(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('enters the group, pushes graphStack, and clears UI state', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
const groupNode = manager.groupNodes([nodeA!.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
state.selectedNodes.add(nodeA!.id);
|
||||||
|
state.activeNodeId = groupNode!.id;
|
||||||
|
state.cameraPosition = [10, 20, 5];
|
||||||
|
|
||||||
|
state.enterGroupNode();
|
||||||
|
|
||||||
|
expect(manager.graphStack.length).toBe(1);
|
||||||
|
expect(state.activeNodeId).toBe(-1);
|
||||||
|
expect(state.selectedNodes.size).toBe(0);
|
||||||
|
expect(manager.isInsideGroup).toBe(true);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('exitGroupNode', () => {
|
||||||
|
it('does nothing when not inside a group', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
const before = [...state.cameraPosition];
|
||||||
|
state.exitGroupNode();
|
||||||
|
expect(manager.graphStack.length).toBe(0);
|
||||||
|
expect(state.cameraPosition).toEqual(before);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('restores the camera position from before entry', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
const groupNode = manager.groupNodes([nodeA!.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
state.activeNodeId = groupNode!.id;
|
||||||
|
state.cameraPosition = [77, 88, 4];
|
||||||
|
|
||||||
|
state.enterGroupNode();
|
||||||
|
// Simulate camera moving inside the group
|
||||||
|
state.cameraPosition = [0, 0, 1];
|
||||||
|
|
||||||
|
state.exitGroupNode();
|
||||||
|
|
||||||
|
expect(state.cameraPosition).toEqual([77, 88, 4]);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('clears activeNodeId and selection after exit', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
const groupNode = manager.groupNodes([nodeA!.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
state.activeNodeId = groupNode!.id;
|
||||||
|
state.enterGroupNode();
|
||||||
|
state.activeNodeId = 99;
|
||||||
|
state.selectedNodes.add(99);
|
||||||
|
|
||||||
|
state.exitGroupNode();
|
||||||
|
|
||||||
|
// Group instance node is re-selected on exit; internal selection is cleared
|
||||||
|
expect(state.activeNodeId).toBe(groupNode!.id);
|
||||||
|
expect(state.selectedNodes.size).toBe(0);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('restores outer nodes to manager after exit', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
const nodeB = manager.createNode({ type: 'test/node/input', position: [100, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
assert.isDefined(nodeB);
|
||||||
|
|
||||||
|
manager.createEdge(nodeA!, 0, nodeB!, 'value');
|
||||||
|
const groupNode = manager.groupNodes([nodeA!.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
state.activeNodeId = groupNode!.id;
|
||||||
|
state.enterGroupNode();
|
||||||
|
|
||||||
|
// Inside the group: nodeA is an internal node so it IS active; the outer
|
||||||
|
// nodes (nodeB, groupNode) are saved and no longer in the active Map.
|
||||||
|
expect(manager.nodes.has(nodeA!.id)).toBe(true);
|
||||||
|
expect(manager.nodes.has(nodeB!.id)).toBe(false);
|
||||||
|
|
||||||
|
state.exitGroupNode();
|
||||||
|
|
||||||
|
// After exit: outer nodes are restored
|
||||||
|
expect(manager.nodes.has(nodeB!.id)).toBe(true);
|
||||||
|
expect(manager.nodes.has(groupNode!.id)).toBe(true);
|
||||||
|
expect(manager.isInsideGroup).toBe(false);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('isInsideGroup is false after exiting the only group level', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
const groupNode = manager.groupNodes([nodeA!.id]);
|
||||||
|
assert.isDefined(groupNode);
|
||||||
|
|
||||||
|
state.activeNodeId = groupNode!.id;
|
||||||
|
state.enterGroupNode();
|
||||||
|
expect(manager.isInsideGroup).toBe(true);
|
||||||
|
|
||||||
|
state.exitGroupNode();
|
||||||
|
expect(manager.isInsideGroup).toBe(false);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('copyNodes / pasteNodes', () => {
|
||||||
|
it('copies the active node into the clipboard', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
const node = manager.createNode({ type: 'test/node/output', position: [10, 20], props: {} });
|
||||||
|
assert.isDefined(node);
|
||||||
|
|
||||||
|
state.activeNodeId = node!.id;
|
||||||
|
state.mousePosition = [0, 0];
|
||||||
|
state.copyNodes();
|
||||||
|
|
||||||
|
assert.isNotNull(state.clipboard);
|
||||||
|
expect(state.clipboard!.nodes.map(n => n.id)).toContain(node!.id);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('includes edges between copied nodes', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
const nodeA = manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
const nodeB = manager.createNode({ type: 'test/node/input', position: [100, 0], props: {} });
|
||||||
|
assert.isDefined(nodeA);
|
||||||
|
assert.isDefined(nodeB);
|
||||||
|
|
||||||
|
manager.createEdge(nodeA!, 0, nodeB!, 'value');
|
||||||
|
|
||||||
|
state.activeNodeId = nodeA!.id;
|
||||||
|
state.selectedNodes.add(nodeB!.id);
|
||||||
|
state.mousePosition = [0, 0];
|
||||||
|
state.copyNodes();
|
||||||
|
|
||||||
|
assert.isNotNull(state.clipboard);
|
||||||
|
expect(state.clipboard!.edges.length).toBe(1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('pastes nodes and adds them to the graph', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
const node = manager.createNode({ type: 'test/node/output', position: [10, 20], props: {} });
|
||||||
|
assert.isDefined(node);
|
||||||
|
|
||||||
|
state.activeNodeId = node!.id;
|
||||||
|
state.mousePosition = [0, 0];
|
||||||
|
state.copyNodes();
|
||||||
|
|
||||||
|
const countBefore = manager.nodes.size;
|
||||||
|
state.mousePosition = [50, 50];
|
||||||
|
state.pasteNodes();
|
||||||
|
|
||||||
|
expect(manager.nodes.size).toBe(countBefore + 1);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('does nothing when clipboard is empty', () => {
|
||||||
|
const { manager, state } = createFixture();
|
||||||
|
manager.createNode({ type: 'test/node/output', position: [0, 0], props: {} });
|
||||||
|
const countBefore = manager.nodes.size;
|
||||||
|
state.pasteNodes();
|
||||||
|
expect(manager.nodes.size).toBe(countBefore);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -5,7 +5,7 @@ import { SvelteMap, SvelteSet } from 'svelte/reactivity';
|
|||||||
import type { OrthographicCamera, Vector3 } from 'three';
|
import type { OrthographicCamera, Vector3 } from 'three';
|
||||||
import type { GraphManager } from './graph-manager.svelte';
|
import type { GraphManager } from './graph-manager.svelte';
|
||||||
import { ColorGenerator } from './graph/colors';
|
import { ColorGenerator } from './graph/colors';
|
||||||
import { getNodeHeight, getSocketPosition } from './helpers/nodeHelpers';
|
import { getNodeHeight, getParameterHeight } from './helpers/nodeHelpers';
|
||||||
|
|
||||||
const graphStateKey = Symbol('graph-state');
|
const graphStateKey = Symbol('graph-state');
|
||||||
export function getGraphState() {
|
export function getGraphState() {
|
||||||
@@ -152,10 +152,6 @@ export class GraphState {
|
|||||||
this.edges.delete(edgeId);
|
this.edges.delete(edgeId);
|
||||||
}
|
}
|
||||||
|
|
||||||
getEdgeData() {
|
|
||||||
return this.edges;
|
|
||||||
}
|
|
||||||
|
|
||||||
updateNodePosition(node: NodeInstance) {
|
updateNodePosition(node: NodeInstance) {
|
||||||
if (
|
if (
|
||||||
node.state.x === node.position[0]
|
node.state.x === node.position[0]
|
||||||
@@ -190,29 +186,6 @@ export class GraphState {
|
|||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
tryConnectToDebugNode(nodeId: number) {
|
|
||||||
const node = this.graph.nodes.get(nodeId);
|
|
||||||
if (!node) return;
|
|
||||||
if (node.type.endsWith('/debug')) return;
|
|
||||||
if (!node.state.type?.outputs?.length) return;
|
|
||||||
for (const _node of this.graph.nodes.values()) {
|
|
||||||
if (_node.type.endsWith('/debug')) {
|
|
||||||
this.graph.createEdge(node, 0, _node, 'input');
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const debugNode = this.graph.createNode({
|
|
||||||
type: 'max/plantarium/debug',
|
|
||||||
position: [node.position[0] + 30, node.position[1]],
|
|
||||||
props: {}
|
|
||||||
});
|
|
||||||
|
|
||||||
if (debugNode) {
|
|
||||||
this.graph.createEdge(node, 0, debugNode, 'input');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
copyNodes() {
|
copyNodes() {
|
||||||
if (this.activeNodeId === -1 && !this.selectedNodes?.size) {
|
if (this.activeNodeId === -1 && !this.selectedNodes?.size) {
|
||||||
return;
|
return;
|
||||||
@@ -240,6 +213,10 @@ export class GraphState {
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
groupSelectedNodes() {
|
||||||
|
return this.graph.groupNodes([...this.selectedNodes.keys(), this.activeNodeId]);
|
||||||
|
}
|
||||||
|
|
||||||
centerNode(node?: NodeInstance) {
|
centerNode(node?: NodeInstance) {
|
||||||
const average = [0, 0, 4];
|
const average = [0, 0, 4];
|
||||||
if (node) {
|
if (node) {
|
||||||
@@ -301,7 +278,7 @@ export class GraphState {
|
|||||||
if (edge[3] === index) {
|
if (edge[3] === index) {
|
||||||
node = edge[0];
|
node = edge[0];
|
||||||
index = edge[1];
|
index = edge[1];
|
||||||
position = getSocketPosition(node, index);
|
position = this.getSocketPosition(node, index);
|
||||||
this.graph.removeEdge(edge);
|
this.graph.removeEdge(edge);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
@@ -321,7 +298,7 @@ export class GraphState {
|
|||||||
return {
|
return {
|
||||||
node,
|
node,
|
||||||
index,
|
index,
|
||||||
position: getSocketPosition(node, index)
|
position: this.getSocketPosition(node, index)
|
||||||
};
|
};
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
@@ -358,7 +335,8 @@ export class GraphState {
|
|||||||
for (const node of this.graph.nodes.values()) {
|
for (const node of this.graph.nodes.values()) {
|
||||||
const x = node.position[0];
|
const x = node.position[0];
|
||||||
const y = node.position[1];
|
const y = node.position[1];
|
||||||
const height = getNodeHeight(node.state.type!);
|
const nodeType = this.graph.getNodeType(node);
|
||||||
|
const height = nodeType ? getNodeHeight(nodeType) : 20;
|
||||||
if (downX > x && downX < x + 20 && downY > y && downY < y + height) {
|
if (downX > x && downX < x + 20 && downY > y && downY < y + height) {
|
||||||
clickedNodeId = node.id;
|
clickedNodeId = node.id;
|
||||||
break;
|
break;
|
||||||
@@ -370,7 +348,8 @@ export class GraphState {
|
|||||||
}
|
}
|
||||||
|
|
||||||
isNodeInView(node: NodeInstance) {
|
isNodeInView(node: NodeInstance) {
|
||||||
const height = getNodeHeight(node.state.type!);
|
if (!node) return false;
|
||||||
|
const height = getNodeHeight(this.graph.getNodeType(node)!);
|
||||||
const width = 20;
|
const width = 20;
|
||||||
return node.position[0] > this.cameraBounds[0] - width
|
return node.position[0] > this.cameraBounds[0] - width
|
||||||
&& node.position[0] < this.cameraBounds[1]
|
&& node.position[0] < this.cameraBounds[1]
|
||||||
@@ -381,4 +360,58 @@ export class GraphState {
|
|||||||
openNodePalette() {
|
openNodePalette() {
|
||||||
this.addMenuPosition = [this.mousePosition[0], this.mousePosition[1]];
|
this.addMenuPosition = [this.mousePosition[0], this.mousePosition[1]];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
enterGroupNode() {
|
||||||
|
if (this.activeNodeId === -1) return;
|
||||||
|
const node = this.graph.getNode(this.activeNodeId);
|
||||||
|
if (!node || node.type !== '__internal/group/instance') return;
|
||||||
|
const ok = this.graph.enterGroup(this.activeNodeId, [...this.cameraPosition]);
|
||||||
|
if (ok) {
|
||||||
|
this.activeNodeId = -1;
|
||||||
|
this.clearSelection();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
exitGroupNode() {
|
||||||
|
const result = this.graph.exitGroup();
|
||||||
|
if (!result) return;
|
||||||
|
this.cameraPosition = result.camera;
|
||||||
|
this.activeNodeId = result.nodeId;
|
||||||
|
this.clearSelection();
|
||||||
|
}
|
||||||
|
|
||||||
|
getSocketPosition(
|
||||||
|
node: NodeInstance,
|
||||||
|
index: string | number
|
||||||
|
): [number, number] {
|
||||||
|
if (node.type === '__internal/group/input' && typeof index === 'number') {
|
||||||
|
return [
|
||||||
|
(node?.state?.x ?? node.position[0]) + 20,
|
||||||
|
(node?.state?.y ?? node.position[1]) + 2.5 + 5 * index + 5
|
||||||
|
];
|
||||||
|
}
|
||||||
|
|
||||||
|
if (typeof index === 'number') {
|
||||||
|
return [
|
||||||
|
(node?.state?.x ?? node.position[0]) + 20,
|
||||||
|
(node?.state?.y ?? node.position[1]) + 2.5 + 10 * index
|
||||||
|
];
|
||||||
|
} else {
|
||||||
|
let height = 5;
|
||||||
|
const nodeType = this.graph.getNodeType(node)!;
|
||||||
|
const inputs = nodeType.inputs || {};
|
||||||
|
for (const inputKey in inputs) {
|
||||||
|
const h = getParameterHeight(nodeType, inputKey) / 10;
|
||||||
|
if (inputKey === index) {
|
||||||
|
height += h / 2;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
height += h;
|
||||||
|
}
|
||||||
|
return [
|
||||||
|
node?.state?.x ?? node.position[0],
|
||||||
|
(node?.state?.y ?? node.position[1]) + height
|
||||||
|
];
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,7 +11,6 @@
|
|||||||
import Debug from '../debug/Debug.svelte';
|
import Debug from '../debug/Debug.svelte';
|
||||||
import EdgeEl from '../edges/Edge.svelte';
|
import EdgeEl from '../edges/Edge.svelte';
|
||||||
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
||||||
import { getSocketPosition } from '../helpers/nodeHelpers';
|
|
||||||
import NodeEl from '../node/Node.svelte';
|
import NodeEl from '../node/Node.svelte';
|
||||||
import { maxZoom, minZoom } from './constants';
|
import { maxZoom, minZoom } from './constants';
|
||||||
import { FileDropEventManager } from './drop.events';
|
import { FileDropEventManager } from './drop.events';
|
||||||
@@ -39,8 +38,8 @@
|
|||||||
return [0, 0, 0, 0];
|
return [0, 0, 0, 0];
|
||||||
}
|
}
|
||||||
|
|
||||||
const pos1 = getSocketPosition(fromNode, edge[1]);
|
const pos1 = graphState.getSocketPosition(fromNode, edge[1]);
|
||||||
const pos2 = getSocketPosition(toNode, edge[3]);
|
const pos2 = graphState.getSocketPosition(toNode, edge[3]);
|
||||||
return [pos1[0], pos1[1], pos2[0], pos2[1]];
|
return [pos1[0], pos1[1], pos2[0], pos2[1]];
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -97,10 +96,25 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
function getSocketType(node: NodeInstance, index: number | string): string {
|
function getSocketType(node: NodeInstance, index: number | string): string {
|
||||||
|
const nodeType = graph.getNodeType(node);
|
||||||
if (typeof index === 'string') {
|
if (typeof index === 'string') {
|
||||||
return node.state.type?.inputs?.[index].type || 'unknown';
|
return nodeType?.inputs?.[index].type || 'unknown';
|
||||||
|
}
|
||||||
|
|
||||||
|
if (node.type === '__internal/group/input') {
|
||||||
|
const key = Object.keys(nodeType?.inputs || {})[index];
|
||||||
|
return nodeType?.inputs?.[key].type || 'unknown';
|
||||||
|
}
|
||||||
|
|
||||||
|
return nodeType?.outputs?.[index] || 'unknown';
|
||||||
|
}
|
||||||
|
|
||||||
|
function getGroupName() {
|
||||||
|
const groupId = graph.graphStack.at(-1)?.groupId;
|
||||||
|
if (groupId !== undefined) {
|
||||||
|
const group = graph.getGroup(groupId);
|
||||||
|
return group?.name || `Group#${groupId}`;
|
||||||
}
|
}
|
||||||
return node.state.type?.outputs?.[index] || 'unknown';
|
|
||||||
}
|
}
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
@@ -114,6 +128,7 @@
|
|||||||
bind:this={graphState.wrapper}
|
bind:this={graphState.wrapper}
|
||||||
class="graph-wrapper"
|
class="graph-wrapper"
|
||||||
style="height: 100%"
|
style="height: 100%"
|
||||||
|
class:is-inside-group={graph.isInsideGroup}
|
||||||
class:is-panning={graphState.isPanning}
|
class:is-panning={graphState.isPanning}
|
||||||
class:is-hovering={graphState.hoveredNodeId !== -1}
|
class:is-hovering={graphState.hoveredNodeId !== -1}
|
||||||
aria-label="Graph"
|
aria-label="Graph"
|
||||||
@@ -121,11 +136,13 @@
|
|||||||
tabindex="0"
|
tabindex="0"
|
||||||
bind:clientWidth={graphState.width}
|
bind:clientWidth={graphState.width}
|
||||||
bind:clientHeight={graphState.height}
|
bind:clientHeight={graphState.height}
|
||||||
|
style:--padding-right="{safePadding?.right || 0}px"
|
||||||
onkeydown={(ev) => keymap.handleKeyboardEvent(ev)}
|
onkeydown={(ev) => keymap.handleKeyboardEvent(ev)}
|
||||||
onmousedown={(ev) => mouseEvents.handleMouseDown(ev)}
|
onmousedown={(ev) => mouseEvents.handleMouseDown(ev)}
|
||||||
oncontextmenu={(ev) => mouseEvents.handleContextMenu(ev)}
|
oncontextmenu={(ev) => mouseEvents.handleContextMenu(ev)}
|
||||||
{...fileDropEvents.getEventListenerProps()}
|
{...fileDropEvents.getEventListenerProps()}
|
||||||
>
|
>
|
||||||
|
<div class="shadow"></div>
|
||||||
<input
|
<input
|
||||||
type="file"
|
type="file"
|
||||||
accept="application/wasm,application/json"
|
accept="application/wasm,application/json"
|
||||||
@@ -136,6 +153,15 @@
|
|||||||
/>
|
/>
|
||||||
<label for="drop-zone"></label>
|
<label for="drop-zone"></label>
|
||||||
|
|
||||||
|
{#if graph.isInsideGroup}
|
||||||
|
<button class="exit-group" onclick={() => graphState.exitGroupNode()}>
|
||||||
|
↑ Exit Group
|
||||||
|
</button>
|
||||||
|
<p class="group-name absolute">
|
||||||
|
Group <b>{getGroupName()}</b>
|
||||||
|
</p>
|
||||||
|
{/if}
|
||||||
|
|
||||||
<Canvas shadows={false} renderMode="on-demand" colorManagementEnabled={false}>
|
<Canvas shadows={false} renderMode="on-demand" colorManagementEnabled={false}>
|
||||||
<Camera
|
<Camera
|
||||||
bind:camera={graphState.camera}
|
bind:camera={graphState.camera}
|
||||||
@@ -216,10 +242,10 @@
|
|||||||
style:transform={`scale(${graphState.cameraPosition[2] * 0.1})`}
|
style:transform={`scale(${graphState.cameraPosition[2] * 0.1})`}
|
||||||
class:hovering-sockets={graphState.activeSocket}
|
class:hovering-sockets={graphState.activeSocket}
|
||||||
>
|
>
|
||||||
{#each graph.nodes.values() as node (node.id)}
|
{#each graph.nodeArray as node, index (node.id)}
|
||||||
<NodeEl
|
<NodeEl
|
||||||
{node}
|
bind:node={graph.nodeArray[index]}
|
||||||
inView={graphState.isNodeInView(node)}
|
inView={node ? graphState.isNodeInView(node) : false}
|
||||||
/>
|
/>
|
||||||
{/each}
|
{/each}
|
||||||
</div>
|
</div>
|
||||||
@@ -244,6 +270,34 @@
|
|||||||
height: 100%;
|
height: 100%;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.group-name {
|
||||||
|
position: absolute;
|
||||||
|
left: calc(50% - var(--padding-right) / 2);
|
||||||
|
transition: left 0.3s ease;
|
||||||
|
top: 12px;
|
||||||
|
transform: translateX(-50%);
|
||||||
|
z-index: 1000;
|
||||||
|
}
|
||||||
|
|
||||||
|
.exit-group {
|
||||||
|
position: absolute;
|
||||||
|
top: 12px;
|
||||||
|
left: 12px;
|
||||||
|
z-index: 1000;
|
||||||
|
padding: 4px 12px;
|
||||||
|
background: var(--color-layer-2);
|
||||||
|
border: 1px solid var(--stroke);
|
||||||
|
border-radius: 4px;
|
||||||
|
color: inherit;
|
||||||
|
font-size: 0.85em;
|
||||||
|
cursor: pointer;
|
||||||
|
opacity: 0.85;
|
||||||
|
}
|
||||||
|
|
||||||
|
.exit-group:hover {
|
||||||
|
opacity: 1;
|
||||||
|
}
|
||||||
|
|
||||||
.wrapper {
|
.wrapper {
|
||||||
position: absolute;
|
position: absolute;
|
||||||
z-index: 100;
|
z-index: 100;
|
||||||
@@ -255,6 +309,22 @@
|
|||||||
cursor: pointer;
|
cursor: pointer;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.shadow {
|
||||||
|
position: absolute;
|
||||||
|
top: -5px;
|
||||||
|
left: -5px;
|
||||||
|
right: calc(var(--padding-right) - 5px);
|
||||||
|
bottom: -5px;
|
||||||
|
z-index: 1;
|
||||||
|
transition: box-shadow 0.3s ease;
|
||||||
|
box-shadow: 0 0 0px 0px var(--color-layer-2) inset;
|
||||||
|
pointer-events: none;
|
||||||
|
}
|
||||||
|
|
||||||
|
.is-inside-group .shadow {
|
||||||
|
box-shadow: 0 0 0px 8px var(--color-layer-2) inset;
|
||||||
|
}
|
||||||
|
|
||||||
.is-panning {
|
.is-panning {
|
||||||
cursor: grab;
|
cursor: grab;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -28,6 +28,7 @@
|
|||||||
graph,
|
graph,
|
||||||
registry,
|
registry,
|
||||||
safePadding,
|
safePadding,
|
||||||
|
// eslint-disable-next-line no-useless-assignment
|
||||||
settings = $bindable(),
|
settings = $bindable(),
|
||||||
activeNode = $bindable(),
|
activeNode = $bindable(),
|
||||||
backgroundType = $bindable('grid'),
|
backgroundType = $bindable('grid'),
|
||||||
@@ -83,7 +84,7 @@
|
|||||||
manager.on('save', (save) => onsave?.(save));
|
manager.on('save', (save) => onsave?.(save));
|
||||||
|
|
||||||
$effect(() => {
|
$effect(() => {
|
||||||
if (graph) {
|
if (graph && (manager.status !== 'idle' || manager.graph.id !== graph.id)) {
|
||||||
manager.load(graph);
|
manager.load(graph);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -190,7 +190,7 @@ export class MouseEventManager {
|
|||||||
// if we clicked on a node
|
// if we clicked on a node
|
||||||
if (clickedNodeId !== -1) {
|
if (clickedNodeId !== -1) {
|
||||||
if (event.ctrlKey && event.shiftKey) {
|
if (event.ctrlKey && event.shiftKey) {
|
||||||
this.state.tryConnectToDebugNode(clickedNodeId);
|
this.graph.tryConnectToDebugNode(clickedNodeId);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
if (this.state.activeNodeId === -1) {
|
if (this.state.activeNodeId === -1) {
|
||||||
|
|||||||
@@ -1,6 +1,10 @@
|
|||||||
import type { NodeDefinition, NodeInstance } from '@nodarium/types';
|
import type { NodeDefinition } from '@nodarium/types';
|
||||||
|
|
||||||
export function getParameterHeight(node: NodeDefinition, inputKey: string) {
|
export function getParameterHeight(node: NodeDefinition, inputKey: string) {
|
||||||
|
if (node.id === '__internal/group/input') {
|
||||||
|
return 50;
|
||||||
|
}
|
||||||
|
|
||||||
const input = node.inputs?.[inputKey];
|
const input = node.inputs?.[inputKey];
|
||||||
if (!input) {
|
if (!input) {
|
||||||
return 0;
|
return 0;
|
||||||
@@ -23,42 +27,14 @@ export function getParameterHeight(node: NodeDefinition, inputKey: string) {
|
|||||||
return 50;
|
return 50;
|
||||||
}
|
}
|
||||||
|
|
||||||
export function getSocketPosition(
|
|
||||||
node: NodeInstance,
|
|
||||||
index: string | number
|
|
||||||
): [number, number] {
|
|
||||||
if (typeof index === 'number') {
|
|
||||||
return [
|
|
||||||
(node?.state?.x ?? node.position[0]) + 20,
|
|
||||||
(node?.state?.y ?? node.position[1]) + 2.5 + 10 * index
|
|
||||||
];
|
|
||||||
} else {
|
|
||||||
let height = 5;
|
|
||||||
const nodeType = node.state.type!;
|
|
||||||
const inputs = nodeType.inputs || {};
|
|
||||||
for (const inputKey in inputs) {
|
|
||||||
const h = getParameterHeight(nodeType, inputKey) / 10;
|
|
||||||
if (inputKey === index) {
|
|
||||||
height += h / 2;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
height += h;
|
|
||||||
}
|
|
||||||
return [
|
|
||||||
node?.state?.x ?? node.position[0],
|
|
||||||
(node?.state?.y ?? node.position[1]) + height
|
|
||||||
];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const nodeHeightCache: Record<string, number> = {};
|
const nodeHeightCache: Record<string, number> = {};
|
||||||
export function getNodeHeight(node: NodeDefinition) {
|
export function getNodeHeight(node: NodeDefinition) {
|
||||||
|
if (!node || !('inputs' in node)) {
|
||||||
|
return 5;
|
||||||
|
}
|
||||||
if (node.id in nodeHeightCache) {
|
if (node.id in nodeHeightCache) {
|
||||||
return nodeHeightCache[node.id];
|
return nodeHeightCache[node.id];
|
||||||
}
|
}
|
||||||
if (!node?.inputs) {
|
|
||||||
return 5;
|
|
||||||
}
|
|
||||||
let height = 5;
|
let height = 5;
|
||||||
|
|
||||||
for (const key in node.inputs) {
|
for (const key in node.inputs) {
|
||||||
|
|||||||
@@ -47,6 +47,10 @@ export function setupKeymaps(keymap: Keymap, graph: GraphManager, graphState: Gr
|
|||||||
key: 'Escape',
|
key: 'Escape',
|
||||||
description: 'Deselect nodes',
|
description: 'Deselect nodes',
|
||||||
callback: () => {
|
callback: () => {
|
||||||
|
if (graph.isInsideGroup) {
|
||||||
|
graphState.exitGroupNode();
|
||||||
|
return;
|
||||||
|
}
|
||||||
graphState.activeNodeId = -1;
|
graphState.activeNodeId = -1;
|
||||||
graphState.clearSelection();
|
graphState.clearSelection();
|
||||||
graphState.edgeEndPosition = null;
|
graphState.edgeEndPosition = null;
|
||||||
@@ -54,6 +58,21 @@ export function setupKeymaps(keymap: Keymap, graph: GraphManager, graphState: Gr
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
keymap.addShortcut({
|
||||||
|
key: 'g',
|
||||||
|
ctrl: true,
|
||||||
|
preventDefault: true,
|
||||||
|
description: 'Group selected nodes',
|
||||||
|
callback: () => graphState.groupSelectedNodes()
|
||||||
|
});
|
||||||
|
|
||||||
|
keymap.addShortcut({
|
||||||
|
key: 'Tab',
|
||||||
|
preventDefault: true,
|
||||||
|
description: 'Enter selected node group',
|
||||||
|
callback: () => graphState.enterGroupNode()
|
||||||
|
});
|
||||||
|
|
||||||
keymap.addShortcut({
|
keymap.addShortcut({
|
||||||
key: 'A',
|
key: 'A',
|
||||||
shift: true,
|
shift: true,
|
||||||
|
|||||||
@@ -3,13 +3,14 @@
|
|||||||
import type { NodeInstance } from '@nodarium/types';
|
import type { NodeInstance } from '@nodarium/types';
|
||||||
import { T } from '@threlte/core';
|
import { T } from '@threlte/core';
|
||||||
import { type Mesh } from 'three';
|
import { type Mesh } from 'three';
|
||||||
import { getGraphState } from '../graph-state.svelte';
|
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
||||||
import { colors } from '../graph/colors.svelte';
|
import { colors } from '../graph/colors.svelte';
|
||||||
import { getNodeHeight, getParameterHeight } from '../helpers/nodeHelpers';
|
import { getNodeHeight, getParameterHeight } from '../helpers/nodeHelpers';
|
||||||
import NodeFrag from './Node.frag';
|
import NodeFrag from './Node.frag';
|
||||||
import NodeVert from './Node.vert';
|
import NodeVert from './Node.vert';
|
||||||
import NodeHtml from './NodeHTML.svelte';
|
import NodeHtml from './NodeHTML.svelte';
|
||||||
|
|
||||||
|
const graph = getGraphManager();
|
||||||
const graphState = getGraphState();
|
const graphState = getGraphState();
|
||||||
|
|
||||||
type Props = {
|
type Props = {
|
||||||
@@ -18,7 +19,7 @@
|
|||||||
};
|
};
|
||||||
let { node = $bindable(), inView }: Props = $props();
|
let { node = $bindable(), inView }: Props = $props();
|
||||||
|
|
||||||
const nodeType = $derived(node.state.type!);
|
const nodeType = $derived(node ? graph.getNodeType(node) : undefined);
|
||||||
|
|
||||||
const isActive = $derived(graphState.activeNodeId === node.id);
|
const isActive = $derived(graphState.activeNodeId === node.id);
|
||||||
const isSelected = $derived(graphState.selectedNodes.has(node.id));
|
const isSelected = $derived(graphState.selectedNodes.has(node.id));
|
||||||
@@ -32,15 +33,17 @@
|
|||||||
);
|
);
|
||||||
|
|
||||||
const sectionHeights = $derived(
|
const sectionHeights = $derived(
|
||||||
Object
|
nodeType
|
||||||
.keys(nodeType.inputs || {})
|
? Object
|
||||||
|
.keys(nodeType?.inputs || {})
|
||||||
.map(key => getParameterHeight(nodeType, key) / 10)
|
.map(key => getParameterHeight(nodeType, key) / 10)
|
||||||
.filter(b => !!b)
|
.filter(b => !!b)
|
||||||
|
: [5]
|
||||||
);
|
);
|
||||||
|
|
||||||
let meshRef: Mesh | undefined = $state();
|
let meshRef: Mesh | undefined = $state();
|
||||||
|
|
||||||
const height = getNodeHeight(node.state.type!);
|
const height = $derived(nodeType ? getNodeHeight(nodeType) : 20);
|
||||||
|
|
||||||
const zoom = $derived(graphState.cameraPosition[2]);
|
const zoom = $derived(graphState.cameraPosition[2]);
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +1,12 @@
|
|||||||
<script lang="ts">
|
<script lang="ts">
|
||||||
import type { NodeInstance } from '@nodarium/types';
|
import type { NodeInstance } from '@nodarium/types';
|
||||||
import { getGraphState } from '../graph-state.svelte';
|
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
||||||
import NodeHeader from './NodeHeader.svelte';
|
import NodeHeader from './NodeHeader.svelte';
|
||||||
import NodeParameter from './NodeParameter.svelte';
|
import NodeParameter from './NodeParameter.svelte';
|
||||||
|
|
||||||
let ref: HTMLDivElement;
|
let ref: HTMLDivElement;
|
||||||
|
|
||||||
|
const graph = getGraphManager();
|
||||||
const graphState = getGraphState();
|
const graphState = getGraphState();
|
||||||
|
|
||||||
type Props = {
|
type Props = {
|
||||||
@@ -30,8 +31,12 @@
|
|||||||
const zOffset = Math.random() - 0.5;
|
const zOffset = Math.random() - 0.5;
|
||||||
const zLimit = 2 - zOffset;
|
const zLimit = 2 - zOffset;
|
||||||
|
|
||||||
const parameters = Object.entries(node.state?.type?.inputs || {}).filter(
|
const nodeType = $derived(graph.getNodeType(node));
|
||||||
|
|
||||||
|
const parameters = $derived(
|
||||||
|
Object.entries(nodeType?.inputs || {}).filter(
|
||||||
(p) => p[1].type !== 'seed' && !('setting' in p[1]) && p[1]?.hidden !== true
|
(p) => p[1].type !== 'seed' && !('setting' in p[1]) && p[1]?.hidden !== true
|
||||||
|
) || {}
|
||||||
);
|
);
|
||||||
|
|
||||||
$effect(() => {
|
$effect(() => {
|
||||||
|
|||||||
@@ -1,11 +1,11 @@
|
|||||||
<script lang="ts">
|
<script lang="ts">
|
||||||
import { appSettings } from '$lib/settings/app-settings.svelte';
|
import { appSettings } from '$lib/settings/app-settings.svelte';
|
||||||
import type { NodeInstance, Socket } from '@nodarium/types';
|
import type { NodeInstance, Socket } from '@nodarium/types';
|
||||||
import { getGraphState } from '../graph-state.svelte';
|
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
||||||
import { createNodePath } from '../helpers/index.js';
|
import { createNodePath } from '../helpers/index.js';
|
||||||
import { getSocketPosition } from '../helpers/nodeHelpers';
|
|
||||||
|
|
||||||
const graphState = getGraphState();
|
const graphState = getGraphState();
|
||||||
|
const graph = getGraphManager();
|
||||||
|
|
||||||
const { node }: { node: NodeInstance } = $props();
|
const { node }: { node: NodeInstance } = $props();
|
||||||
|
|
||||||
@@ -16,13 +16,17 @@
|
|||||||
graphState.setDownSocket?.({
|
graphState.setDownSocket?.({
|
||||||
node,
|
node,
|
||||||
index: 0,
|
index: 0,
|
||||||
position: getSocketPosition?.(node, 0)
|
position: graphState.getSocketPosition?.(node, 0)
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const cornerTop = 10;
|
const cornerTop = 10;
|
||||||
const rightBump = $derived(!!node?.state?.type?.outputs?.length);
|
const nodeType = $derived(graph.getNodeType(node));
|
||||||
|
const rightBump = $derived(
|
||||||
|
!!nodeType?.outputs?.length && node.type !== '__internal/group/input'
|
||||||
|
);
|
||||||
|
|
||||||
const aspectRatio = 0.25;
|
const aspectRatio = 0.25;
|
||||||
|
|
||||||
const path = $derived(
|
const path = $derived(
|
||||||
@@ -70,8 +74,9 @@
|
|||||||
{#if appSettings.value.debug.advancedMode}
|
{#if appSettings.value.debug.advancedMode}
|
||||||
<span class="bg-white text-black! mr-2 px-1 rounded-sm opacity-30">{node.id}</span>
|
<span class="bg-white text-black! mr-2 px-1 rounded-sm opacity-30">{node.id}</span>
|
||||||
{/if}
|
{/if}
|
||||||
{node.type.split('/').pop()}
|
{nodeType?.meta?.title || node.type?.split('/').pop()}
|
||||||
</div>
|
</div>
|
||||||
|
{#if rightBump}
|
||||||
<div
|
<div
|
||||||
class="target"
|
class="target"
|
||||||
role="button"
|
role="button"
|
||||||
@@ -79,6 +84,7 @@
|
|||||||
onmousedown={handleMouseDown}
|
onmousedown={handleMouseDown}
|
||||||
>
|
>
|
||||||
</div>
|
</div>
|
||||||
|
{/if}
|
||||||
<svg
|
<svg
|
||||||
xmlns="http://www.w3.org/2000/svg"
|
xmlns="http://www.w3.org/2000/svg"
|
||||||
viewBox="0 0 100 100"
|
viewBox="0 0 100 100"
|
||||||
|
|||||||
@@ -2,7 +2,7 @@
|
|||||||
import type { NodeInput, NodeInstance, Socket } from '@nodarium/types';
|
import type { NodeInput, NodeInstance, Socket } from '@nodarium/types';
|
||||||
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
import { getGraphManager, getGraphState } from '../graph-state.svelte';
|
||||||
import { createNodePath } from '../helpers';
|
import { createNodePath } from '../helpers';
|
||||||
import { getParameterHeight, getSocketPosition } from '../helpers/nodeHelpers';
|
import { getParameterHeight } from '../helpers/nodeHelpers';
|
||||||
import NodeInputEl from './NodeInput.svelte';
|
import NodeInputEl from './NodeInput.svelte';
|
||||||
|
|
||||||
type Props = {
|
type Props = {
|
||||||
@@ -19,7 +19,7 @@
|
|||||||
|
|
||||||
let { node = $bindable(), input, id, isLast }: Props = $props();
|
let { node = $bindable(), input, id, isLast }: Props = $props();
|
||||||
|
|
||||||
const nodeType = $derived(node.state.type!);
|
let nodeType = $derived(graph.getNodeType(node)!);
|
||||||
|
|
||||||
const inputType = $derived(nodeType.inputs?.[id]);
|
const inputType = $derived(nodeType.inputs?.[id]);
|
||||||
|
|
||||||
@@ -29,14 +29,27 @@
|
|||||||
function handleMouseDown(ev: MouseEvent) {
|
function handleMouseDown(ev: MouseEvent) {
|
||||||
ev.preventDefault();
|
ev.preventDefault();
|
||||||
ev.stopPropagation();
|
ev.stopPropagation();
|
||||||
|
|
||||||
|
if (node.type === '__internal/group/input') {
|
||||||
|
const outputIndex = Object.entries(nodeType?.inputs ?? {}).findIndex(([key]) => key === id);
|
||||||
|
graphState.setDownSocket({
|
||||||
|
node,
|
||||||
|
index: outputIndex,
|
||||||
|
position: graphState.getSocketPosition(node, outputIndex)
|
||||||
|
});
|
||||||
|
} else {
|
||||||
graphState.setDownSocket({
|
graphState.setDownSocket({
|
||||||
node,
|
node,
|
||||||
index: id,
|
index: id,
|
||||||
position: getSocketPosition(node, id)
|
position: graphState.getSocketPosition(node, id)
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
const leftBump = $derived(nodeType.inputs?.[id].internal !== true);
|
const leftBump = $derived(
|
||||||
|
nodeType.inputs?.[id].internal !== true && node.type !== '__internal/group/input'
|
||||||
|
);
|
||||||
|
const rightBump = $derived(node.type === '__internal/group/input');
|
||||||
const cornerBottom = $derived(isLast ? 5 : 0);
|
const cornerBottom = $derived(isLast ? 5 : 0);
|
||||||
const aspectRatio = 0.5;
|
const aspectRatio = 0.5;
|
||||||
|
|
||||||
@@ -46,6 +59,7 @@
|
|||||||
height: 2000 / height,
|
height: 2000 / height,
|
||||||
y: 50.5,
|
y: 50.5,
|
||||||
cornerBottom,
|
cornerBottom,
|
||||||
|
rightBump,
|
||||||
leftBump,
|
leftBump,
|
||||||
aspectRatio
|
aspectRatio
|
||||||
})
|
})
|
||||||
@@ -55,6 +69,7 @@
|
|||||||
depth: 7,
|
depth: 7,
|
||||||
height: 2200 / height,
|
height: 2200 / height,
|
||||||
y: 50.5,
|
y: 50.5,
|
||||||
|
rightBump,
|
||||||
cornerBottom,
|
cornerBottom,
|
||||||
leftBump,
|
leftBump,
|
||||||
aspectRatio
|
aspectRatio
|
||||||
@@ -76,6 +91,7 @@
|
|||||||
<div
|
<div
|
||||||
class="wrapper"
|
class="wrapper"
|
||||||
data-node-type={node.type}
|
data-node-type={node.type}
|
||||||
|
class:is-group-input={node.type === '__internal/group/input'}
|
||||||
data-node-input={id}
|
data-node-input={id}
|
||||||
style:height="{height}px"
|
style:height="{height}px"
|
||||||
style:--socket-color={hoverColor}
|
style:--socket-color={hoverColor}
|
||||||
@@ -130,6 +146,11 @@
|
|||||||
transform: translateY(-50%) translateX(-50%);
|
transform: translateY(-50%) translateX(-50%);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.is-group-input .target {
|
||||||
|
right: 0px;
|
||||||
|
transform: translateY(-50%) translateX(50%);
|
||||||
|
}
|
||||||
|
|
||||||
.possible-socket .target::before {
|
.possible-socket .target::before {
|
||||||
content: "";
|
content: "";
|
||||||
position: absolute;
|
position: absolute;
|
||||||
|
|||||||
@@ -23,7 +23,11 @@ export function createMockNodeRegistry(nodes: NodeDefinition[]): NodeRegistry {
|
|||||||
|
|
||||||
export const mockFloatOutputNode: NodeDefinition = {
|
export const mockFloatOutputNode: NodeDefinition = {
|
||||||
id: 'test/node/output',
|
id: 'test/node/output',
|
||||||
inputs: {},
|
inputs: {
|
||||||
|
'input': {
|
||||||
|
type: 'float'
|
||||||
|
}
|
||||||
|
},
|
||||||
outputs: ['float'],
|
outputs: ['float'],
|
||||||
meta: { title: 'Float Output' },
|
meta: { title: 'Float Output' },
|
||||||
execute: () => new Int32Array()
|
execute: () => new Int32Array()
|
||||||
@@ -32,7 +36,7 @@ export const mockFloatOutputNode: NodeDefinition = {
|
|||||||
export const mockFloatInputNode: NodeDefinition = {
|
export const mockFloatInputNode: NodeDefinition = {
|
||||||
id: 'test/node/input',
|
id: 'test/node/input',
|
||||||
inputs: { value: { type: 'float' } },
|
inputs: { value: { type: 'float' } },
|
||||||
outputs: [],
|
outputs: ['float'],
|
||||||
meta: { title: 'Float Input' },
|
meta: { title: 'Float Input' },
|
||||||
execute: () => new Int32Array()
|
execute: () => new Int32Array()
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ export function grid(width: number, height: number) {
|
|||||||
const graph: Graph = {
|
const graph: Graph = {
|
||||||
id: Math.floor(Math.random() * 100000),
|
id: Math.floor(Math.random() * 100000),
|
||||||
edges: [],
|
edges: [],
|
||||||
nodes: []
|
nodes: [],
|
||||||
|
groups: []
|
||||||
};
|
};
|
||||||
|
|
||||||
const amount = width * height;
|
const amount = width * height;
|
||||||
|
|||||||
@@ -47,6 +47,7 @@ export function tree(depth: number): Graph {
|
|||||||
return {
|
return {
|
||||||
id: Math.floor(Math.random() * 100000),
|
id: Math.floor(Math.random() * 100000),
|
||||||
nodes,
|
nodes,
|
||||||
edges
|
edges,
|
||||||
|
groups: []
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
export const debugNode = {
|
export const debugNode = {
|
||||||
id: 'max/plantarium/debug',
|
id: '__internal/debug/instance',
|
||||||
|
meta: {
|
||||||
|
title: 'Debug'
|
||||||
|
},
|
||||||
inputs: {
|
inputs: {
|
||||||
input: {
|
input: {
|
||||||
type: '*'
|
type: '*'
|
||||||
|
|||||||
@@ -0,0 +1,13 @@
|
|||||||
|
export const groupNode = {
|
||||||
|
id: '__internal/group/instance',
|
||||||
|
meta: { title: 'Group' },
|
||||||
|
inputs: {
|
||||||
|
input: {
|
||||||
|
type: 'select',
|
||||||
|
values: []
|
||||||
|
}
|
||||||
|
},
|
||||||
|
execute(_data: Int32Array): Int32Array {
|
||||||
|
return _data;
|
||||||
|
}
|
||||||
|
} as const;
|
||||||
@@ -88,6 +88,7 @@ export class RemoteNodeRegistry implements NodeRegistry {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async fetchNodeDefinition(nodeId: `${string}/${string}/${string}`) {
|
async fetchNodeDefinition(nodeId: `${string}/${string}/${string}`) {
|
||||||
|
if (nodeId.startsWith('__internal/')) return;
|
||||||
return this.fetchJson(`nodes/${nodeId}.json`);
|
return this.fetchJson(`nodes/${nodeId}.json`);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -109,6 +110,8 @@ export class RemoteNodeRegistry implements NodeRegistry {
|
|||||||
return this.nodes.get(id)!;
|
return this.nodes.get(id)!;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (id.startsWith('__internal/')) return;
|
||||||
|
|
||||||
const wasmBuffer = await this.fetchNodeWasm(id);
|
const wasmBuffer = await this.fetchNodeWasm(id);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|||||||
@@ -80,7 +80,6 @@ export function createGeometryPool(parentScene: Group, material: Material) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const normals = new Float32Array(data.buffer, index * 4, vertexCount * 3);
|
const normals = new Float32Array(data.buffer, index * 4, vertexCount * 3);
|
||||||
index = index + vertexCount * 3;
|
|
||||||
|
|
||||||
if (
|
if (
|
||||||
geometry.userData?.faceCount !== faceCount
|
geometry.userData?.faceCount !== faceCount
|
||||||
|
|||||||
@@ -0,0 +1,164 @@
|
|||||||
|
import type { Graph } from '@nodarium/types';
|
||||||
|
import { describe, expect, it } from 'vitest';
|
||||||
|
import { expandGroups } from './runtime-executor';
|
||||||
|
|
||||||
|
// Helpers to build minimal serialized nodes/edges
|
||||||
|
function node(id: number, type: string, props?: Record<string, number>) {
|
||||||
|
return {
|
||||||
|
id,
|
||||||
|
type: type as Graph['nodes'][0]['type'],
|
||||||
|
position: [0, 0] as [number, number],
|
||||||
|
...(props ? { props } : {})
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
function edge(
|
||||||
|
from: number,
|
||||||
|
fromSocket: number,
|
||||||
|
to: number,
|
||||||
|
toSocket: string
|
||||||
|
): [number, number, number, string] {
|
||||||
|
return [from, fromSocket, to, toSocket];
|
||||||
|
}
|
||||||
|
|
||||||
|
describe('expandGroups', () => {
|
||||||
|
it('returns graph unchanged when there are no groups', () => {
|
||||||
|
const graph: Graph = {
|
||||||
|
id: 1,
|
||||||
|
nodes: [node(0, 'test/node/output'), node(1, 'test/node/input')],
|
||||||
|
edges: [edge(0, 0, 1, 'value')],
|
||||||
|
groups: []
|
||||||
|
};
|
||||||
|
|
||||||
|
const result = expandGroups(graph);
|
||||||
|
|
||||||
|
expect(result.nodes.length).toBe(2);
|
||||||
|
expect(result.edges.length).toBe(1);
|
||||||
|
expect(result).toBe(graph); // same reference — no copy needed
|
||||||
|
});
|
||||||
|
|
||||||
|
it('expands a simple group: A → [B] → C rewires to A → B → C', () => {
|
||||||
|
// IDs: A=1, B=2, C=3, groupNode=4, group.id=5, inputBoundary=6, outputBoundary=7
|
||||||
|
const groupId = 5;
|
||||||
|
const groupNodeId = 4;
|
||||||
|
const remappedB = (groupNodeId + 1) * 1_000_000 + 2; // 5_000_002
|
||||||
|
|
||||||
|
const graph: Graph = {
|
||||||
|
id: 1,
|
||||||
|
nodes: [
|
||||||
|
node(1, 'test/node/output'),
|
||||||
|
node(groupNodeId, '__internal/group/instance', { groupId }),
|
||||||
|
node(3, 'test/node/input')
|
||||||
|
],
|
||||||
|
edges: [
|
||||||
|
edge(1, 0, groupNodeId, 'input_0'), // A → group
|
||||||
|
edge(groupNodeId, 0, 3, 'value') // group → C
|
||||||
|
],
|
||||||
|
groups: [{
|
||||||
|
id: groupId,
|
||||||
|
nodes: [
|
||||||
|
node(6, '__internal/group/input'),
|
||||||
|
node(2, 'test/node/output'),
|
||||||
|
node(7, '__internal/group/output')
|
||||||
|
],
|
||||||
|
edges: [
|
||||||
|
edge(6, 0, 2, 'input'), // inputBoundary → B
|
||||||
|
edge(2, 0, 7, 'Out') // B → outputBoundary
|
||||||
|
],
|
||||||
|
inputs: { input_0: { type: 'float' } },
|
||||||
|
outputs: [{ type: 'float', label: 'Output 0' }]
|
||||||
|
}]
|
||||||
|
};
|
||||||
|
|
||||||
|
const result = expandGroups(graph);
|
||||||
|
|
||||||
|
const ids = result.nodes.map(n => n.id);
|
||||||
|
expect(ids).not.toContain(groupNodeId);
|
||||||
|
expect(ids).toContain(remappedB);
|
||||||
|
expect(ids).toContain(1); // A
|
||||||
|
expect(ids).toContain(3); // C
|
||||||
|
expect(result.nodes.length).toBe(3); // A, B(remapped), C
|
||||||
|
|
||||||
|
expect(result.edges).toContainEqual(edge(1, 0, remappedB, 'input')); // A → B
|
||||||
|
expect(result.edges).toContainEqual(edge(remappedB, 0, 3, 'value')); // B → C
|
||||||
|
expect(result.edges.length).toBe(2);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('expands a group with two internal nodes (B→D) and preserves the internal edge', () => {
|
||||||
|
// A → [B → D] → C
|
||||||
|
const groupId = 10;
|
||||||
|
const groupNodeId = 5;
|
||||||
|
const remappedB = (groupNodeId + 1) * 1_000_000 + 1; // 6_000_001
|
||||||
|
const remappedD = (groupNodeId + 1) * 1_000_000 + 2; // 6_000_002
|
||||||
|
|
||||||
|
const graph: Graph = {
|
||||||
|
id: 1,
|
||||||
|
nodes: [
|
||||||
|
node(0, 'test/node/output'),
|
||||||
|
node(groupNodeId, '__internal/group/instance', { groupId }),
|
||||||
|
node(9, 'test/node/input')
|
||||||
|
],
|
||||||
|
edges: [
|
||||||
|
edge(0, 0, groupNodeId, 'input_0'),
|
||||||
|
edge(groupNodeId, 0, 9, 'value')
|
||||||
|
],
|
||||||
|
groups: [{
|
||||||
|
id: groupId,
|
||||||
|
nodes: [
|
||||||
|
node(3, '__internal/group/input'),
|
||||||
|
node(1, 'test/node/output'), // B
|
||||||
|
node(2, 'test/node/output'), // D
|
||||||
|
node(4, '__internal/group/output')
|
||||||
|
],
|
||||||
|
edges: [
|
||||||
|
edge(3, 0, 1, 'input'), // inputBoundary → B
|
||||||
|
edge(1, 0, 2, 'input'), // B → D (internal)
|
||||||
|
edge(2, 0, 4, 'Out') // D → outputBoundary
|
||||||
|
],
|
||||||
|
inputs: { input_0: { type: 'float' } },
|
||||||
|
outputs: [{ type: 'float' }]
|
||||||
|
}]
|
||||||
|
};
|
||||||
|
|
||||||
|
const result = expandGroups(graph);
|
||||||
|
|
||||||
|
expect(result.nodes.map(n => n.id)).not.toContain(groupNodeId);
|
||||||
|
expect(result.nodes.map(n => n.id)).toContain(remappedB);
|
||||||
|
expect(result.nodes.map(n => n.id)).toContain(remappedD);
|
||||||
|
|
||||||
|
expect(result.edges).toContainEqual(edge(0, 0, remappedB, 'input')); // A → B
|
||||||
|
expect(result.edges).toContainEqual(edge(remappedB, 0, remappedD, 'input')); // B → D (internal)
|
||||||
|
expect(result.edges).toContainEqual(edge(remappedD, 0, 9, 'value')); // D → C
|
||||||
|
expect(result.edges.length).toBe(3);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('expands a group with no external connections (isolated)', () => {
|
||||||
|
const groupId = 20;
|
||||||
|
const groupNodeId = 1;
|
||||||
|
const remappedB = (groupNodeId + 1) * 1_000_000 + 2; // 2_000_002
|
||||||
|
|
||||||
|
const graph: Graph = {
|
||||||
|
id: 1,
|
||||||
|
nodes: [node(groupNodeId, '__internal/group/instance', { groupId })],
|
||||||
|
edges: [],
|
||||||
|
groups: [{
|
||||||
|
id: groupId,
|
||||||
|
nodes: [
|
||||||
|
node(3, '__internal/group/input'),
|
||||||
|
node(2, 'test/node/output'),
|
||||||
|
node(4, '__internal/group/output')
|
||||||
|
],
|
||||||
|
edges: [
|
||||||
|
edge(3, 0, 2, 'input'),
|
||||||
|
edge(2, 0, 4, 'Out')
|
||||||
|
]
|
||||||
|
}]
|
||||||
|
};
|
||||||
|
|
||||||
|
const result = expandGroups(graph);
|
||||||
|
|
||||||
|
expect(result.nodes.map(n => n.id)).not.toContain(groupNodeId);
|
||||||
|
expect(result.nodes.map(n => n.id)).toContain(remappedB);
|
||||||
|
expect(result.edges.length).toBe(0);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -18,6 +18,87 @@ import type { RuntimeNode } from './types';
|
|||||||
const log = createLogger('runtime-executor');
|
const log = createLogger('runtime-executor');
|
||||||
log.mute();
|
log.mute();
|
||||||
|
|
||||||
|
export function expandGroups(graph: Graph): Graph {
|
||||||
|
if (!graph.groups || graph.groups.length === 0) return graph;
|
||||||
|
|
||||||
|
const nodes = [...graph.nodes];
|
||||||
|
let edges = [...graph.edges];
|
||||||
|
|
||||||
|
let changed = true;
|
||||||
|
while (changed) {
|
||||||
|
changed = false;
|
||||||
|
|
||||||
|
for (let i = 0; i < nodes.length; i++) {
|
||||||
|
const node = nodes[i];
|
||||||
|
if (node.type !== '__internal/group/instance') continue;
|
||||||
|
|
||||||
|
const groupId = node.props?.groupId as number | undefined;
|
||||||
|
if (groupId === undefined) continue;
|
||||||
|
|
||||||
|
const group = graph.groups.find(g => g.id === groupId);
|
||||||
|
if (!group) continue;
|
||||||
|
|
||||||
|
changed = true;
|
||||||
|
|
||||||
|
const ID_OFFSET = (node.id + 1) * 1_000_000;
|
||||||
|
const idMap = new Map<number, number>();
|
||||||
|
|
||||||
|
const inputBoundary = group.nodes.find(n => n.type === '__internal/group/input');
|
||||||
|
const outputBoundary = group.nodes.find(n => n.type === '__internal/group/output');
|
||||||
|
|
||||||
|
const realNodes = group.nodes.filter(
|
||||||
|
n => n.type !== '__internal/group/input' && n.type !== '__internal/group/output'
|
||||||
|
);
|
||||||
|
|
||||||
|
for (const n of realNodes) idMap.set(n.id, ID_OFFSET + n.id);
|
||||||
|
|
||||||
|
const incomingExternal = edges.filter(e => e[2] === node.id);
|
||||||
|
const outgoingExternal = edges.filter(e => e[0] === node.id);
|
||||||
|
const newEdges: Graph['edges'] = [];
|
||||||
|
|
||||||
|
// external_source → [inputBoundary →] internal_target
|
||||||
|
if (inputBoundary) {
|
||||||
|
const fromInput = group.edges.filter(e => e[0] === inputBoundary.id);
|
||||||
|
for (const extEdge of incomingExternal) {
|
||||||
|
for (const intEdge of fromInput) {
|
||||||
|
const toId = idMap.get(intEdge[2]);
|
||||||
|
if (toId !== undefined) newEdges.push([extEdge[0], extEdge[1], toId, intEdge[3]]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// internal_source → [outputBoundary →] external_target
|
||||||
|
if (outputBoundary) {
|
||||||
|
const toOutput = group.edges.filter(e => e[2] === outputBoundary.id);
|
||||||
|
for (const extEdge of outgoingExternal) {
|
||||||
|
for (const intEdge of toOutput) {
|
||||||
|
const fromId = idMap.get(intEdge[0]);
|
||||||
|
if (fromId !== undefined) newEdges.push([fromId, intEdge[1], extEdge[2], extEdge[3]]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// internal-to-internal edges (skip boundary edges)
|
||||||
|
for (const e of group.edges) {
|
||||||
|
if (e[0] === inputBoundary?.id || e[2] === outputBoundary?.id) continue;
|
||||||
|
const fromId = idMap.get(e[0]);
|
||||||
|
const toId = idMap.get(e[2]);
|
||||||
|
if (fromId !== undefined && toId !== undefined) newEdges.push([fromId, e[1], toId, e[3]]);
|
||||||
|
}
|
||||||
|
|
||||||
|
nodes.splice(i, 1);
|
||||||
|
for (const n of realNodes) nodes.push({ ...n, id: idMap.get(n.id)! });
|
||||||
|
|
||||||
|
edges = edges.filter(e => e[0] !== node.id && e[2] !== node.id);
|
||||||
|
edges.push(...newEdges);
|
||||||
|
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return { ...graph, nodes, edges };
|
||||||
|
}
|
||||||
|
|
||||||
function getValue(input: NodeInput, value?: unknown) {
|
function getValue(input: NodeInput, value?: unknown) {
|
||||||
if (value === undefined && 'value' in input) {
|
if (value === undefined && 'value' in input) {
|
||||||
value = input.value;
|
value = input.value;
|
||||||
@@ -75,7 +156,11 @@ export class MemoryRuntimeExecutor implements RuntimeExecutor {
|
|||||||
throw new Error('Node registry is not ready');
|
throw new Error('Node registry is not ready');
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.registry.load(graph.nodes.map((node) => node.type));
|
// Only load non-virtual types (virtual nodes are resolved locally)
|
||||||
|
const nonVirtualTypes = graph.nodes
|
||||||
|
.map(node => node.type)
|
||||||
|
.filter(t => !t.startsWith('__internal/'));
|
||||||
|
await this.registry.load(nonVirtualTypes);
|
||||||
|
|
||||||
const typeMap = new Map<string, NodeDefinition>();
|
const typeMap = new Map<string, NodeDefinition>();
|
||||||
for (const node of graph.nodes) {
|
for (const node of graph.nodes) {
|
||||||
@@ -163,6 +248,9 @@ export class MemoryRuntimeExecutor implements RuntimeExecutor {
|
|||||||
let a = performance.now();
|
let a = performance.now();
|
||||||
this.debugData = {};
|
this.debugData = {};
|
||||||
|
|
||||||
|
// Expand group nodes into a flat graph before execution
|
||||||
|
graph = expandGroups(graph);
|
||||||
|
|
||||||
// Then we add some metadata to the graph
|
// Then we add some metadata to the graph
|
||||||
const [outputNode, nodes] = await this.addMetaData(graph);
|
const [outputNode, nodes] = await this.addMetaData(graph);
|
||||||
let b = performance.now();
|
let b = performance.now();
|
||||||
@@ -219,7 +307,7 @@ export class MemoryRuntimeExecutor implements RuntimeExecutor {
|
|||||||
if (inputNode) {
|
if (inputNode) {
|
||||||
if (results[inputNode.id] === undefined) {
|
if (results[inputNode.id] === undefined) {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
`Node ${node.type} is missing input from node ${inputNode.type}`
|
`Node ${node.type} is missing input from node ${inputNode.type}#${inputNode.id}`
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
return results[inputNode.id];
|
return results[inputNode.id];
|
||||||
|
|||||||
@@ -2,6 +2,7 @@
|
|||||||
import { type Snippet } from 'svelte';
|
import { type Snippet } from 'svelte';
|
||||||
import { panelState as state } from './PanelState.svelte';
|
import { panelState as state } from './PanelState.svelte';
|
||||||
|
|
||||||
|
// eslint-disable-next-line no-useless-assignment
|
||||||
let { children, open = $bindable(false) } = $props<{ children?: Snippet; open?: boolean }>();
|
let { children, open = $bindable(false) } = $props<{ children?: Snippet; open?: boolean }>();
|
||||||
|
|
||||||
$effect(() => {
|
$effect(() => {
|
||||||
|
|||||||
@@ -96,6 +96,4 @@
|
|||||||
bind:value={store}
|
bind:value={store}
|
||||||
type={nodeDefinition}
|
type={nodeDefinition}
|
||||||
/>
|
/>
|
||||||
{:else}
|
|
||||||
<p class="mx-4 mt-4">Node has no settings</p>
|
|
||||||
{/if}
|
{/if}
|
||||||
|
|||||||
@@ -9,18 +9,13 @@
|
|||||||
};
|
};
|
||||||
|
|
||||||
let { manager, node = $bindable() }: Props = $props();
|
let { manager, node = $bindable() }: Props = $props();
|
||||||
|
|
||||||
|
const isGroupInstance = $derived(node?.type === '__internal/group/instance');
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
|
{#if node && !isGroupInstance}
|
||||||
<div class='{node?"border-l-2 pl-3.5!":""} bg-layer-2 flex items-center h-[70px] border-b-1 border-l-selected border-b-outline pl-4'>
|
<div class='{node?"border-l-2 pl-3.5!":""} bg-layer-2 flex items-center h-[70px] border-b-1 border-l-selected border-b-outline pl-4'>
|
||||||
<h3>Node Settings</h3>
|
<h3>Node Settings</h3>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
{#if node}
|
|
||||||
{#key node.id}
|
|
||||||
{#if node}
|
|
||||||
<ActiveNodeSelected {manager} bind:node />
|
<ActiveNodeSelected {manager} bind:node />
|
||||||
{/if}
|
{/if}
|
||||||
{/key}
|
|
||||||
{:else}
|
|
||||||
<p class="mx-4 mt-4">No node selected</p>
|
|
||||||
{/if}
|
|
||||||
|
|||||||
@@ -1,20 +1,23 @@
|
|||||||
<script lang="ts">
|
<script lang="ts">
|
||||||
import type { Graph } from '$lib/types';
|
import type { Graph } from '$lib/types';
|
||||||
|
import { JsonViewer } from '@nodarium/ui';
|
||||||
|
|
||||||
const { graph }: { graph?: Graph } = $props();
|
const { graph }: { graph?: Graph } = $props();
|
||||||
|
|
||||||
function convert(g: Graph): string {
|
const data = $derived(
|
||||||
return JSON.stringify(
|
graph
|
||||||
{
|
? {
|
||||||
...g,
|
...graph,
|
||||||
nodes: g.nodes.map((n: object) => ({ ...n, tmp: undefined, state: undefined }))
|
nodes: graph.nodes.map((n: object) => ({ ...n, tmp: undefined, state: undefined }))
|
||||||
},
|
|
||||||
null,
|
|
||||||
2
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
: null
|
||||||
|
);
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<pre>
|
<div class="overflow-auto p-2">
|
||||||
{graph ? convert(graph) : "No graph loaded"}
|
{#if data}
|
||||||
</pre>
|
<JsonViewer value={data} path="graph" />
|
||||||
|
{:else}
|
||||||
|
<span class="font-mono text-xs text-neutral-500">No graph loaded</span>
|
||||||
|
{/if}
|
||||||
|
</div>
|
||||||
|
|||||||
@@ -0,0 +1,120 @@
|
|||||||
|
<script lang="ts">
|
||||||
|
import type { GraphManager } from '$lib/graph-interface/graph-manager.svelte';
|
||||||
|
import type { NodeInstance } from '@nodarium/types';
|
||||||
|
|
||||||
|
type Props = {
|
||||||
|
manager: GraphManager;
|
||||||
|
node?: NodeInstance;
|
||||||
|
};
|
||||||
|
|
||||||
|
const { manager, node = $bindable() }: Props = $props();
|
||||||
|
|
||||||
|
const activeGroup = $derived.by(() => {
|
||||||
|
console.log('isInsideGroup', manager?.isInsideGroup);
|
||||||
|
if (manager?.isInsideGroup) {
|
||||||
|
const activeGroupId = manager.graphStack?.at(-1)?.groupId;
|
||||||
|
console.log('activeGroupId', activeGroupId);
|
||||||
|
if (activeGroupId !== undefined) {
|
||||||
|
return manager.getGroup(activeGroupId);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (node?.type === '__internal/group/instance') {
|
||||||
|
return manager.getGroup(node.props?.groupId as number);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
const groupName = $derived(activeGroup?.name ?? '');
|
||||||
|
function handleRename(e: Event) {
|
||||||
|
const name = (e.target as HTMLInputElement).value;
|
||||||
|
if (activeGroup) manager.renameGroup(activeGroup.id, name);
|
||||||
|
}
|
||||||
|
|
||||||
|
const hasUnusedGroups = $derived.by(() => {
|
||||||
|
if (!manager) return false;
|
||||||
|
if (manager.isInsideGroup) return false;
|
||||||
|
if (manager.graph.groups.length === 0) return false;
|
||||||
|
return manager.graph.groups.filter(g => {
|
||||||
|
return !manager.graph.nodes.find(n => n.props?.groupId === g.id);
|
||||||
|
}).length;
|
||||||
|
});
|
||||||
|
</script>
|
||||||
|
|
||||||
|
{#if activeGroup || hasUnusedGroups}
|
||||||
|
<div class='{node?"border-l-2 pl-3.5!":""} bg-layer-2 flex items-center h-[70px] border-b-1 border-l-selected border-b-outline pl-4'>
|
||||||
|
<h3>Group Settings</h3>
|
||||||
|
</div>
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
{#if activeGroup}
|
||||||
|
{#key activeGroup.id}
|
||||||
|
<div class="group-settings">
|
||||||
|
<label for="group-name">Group name</label>
|
||||||
|
<input
|
||||||
|
id="group-name"
|
||||||
|
type="text"
|
||||||
|
placeholder="Group {activeGroup.id}"
|
||||||
|
value={groupName}
|
||||||
|
oninput={handleRename}
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
{/key}
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
{#if hasUnusedGroups}
|
||||||
|
<div class="group-actions">
|
||||||
|
<button onclick={() => manager.removeUnusedGroups()}>
|
||||||
|
Remove ({hasUnusedGroups}) orphaned groups
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
<style>
|
||||||
|
.group-settings {
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
gap: 0.4em;
|
||||||
|
padding: 1em;
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-settings label {
|
||||||
|
font-size: 0.8em;
|
||||||
|
opacity: 0.7;
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-settings input {
|
||||||
|
background: var(--color-layer-1);
|
||||||
|
border: 1px solid var(--color-outline);
|
||||||
|
border-radius: 4px;
|
||||||
|
color: var(--color-text);
|
||||||
|
font-family: var(--font-family);
|
||||||
|
font-size: 0.9em;
|
||||||
|
padding: 0.4em 0.6em;
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-settings input:focus {
|
||||||
|
outline: 1px solid var(--color-active);
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-actions {
|
||||||
|
padding: 0.75em 1em;
|
||||||
|
border-bottom: 1px solid var(--color-outline);
|
||||||
|
margin-top: auto;
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-actions button {
|
||||||
|
width: 100%;
|
||||||
|
padding: 0.4em 0.8em;
|
||||||
|
background: var(--color-layer-1);
|
||||||
|
border: 1px solid var(--color-outline);
|
||||||
|
border-radius: 4px;
|
||||||
|
color: var(--color-text);
|
||||||
|
font-family: var(--font-family);
|
||||||
|
font-size: 0.85em;
|
||||||
|
cursor: pointer;
|
||||||
|
}
|
||||||
|
|
||||||
|
.group-actions button:hover {
|
||||||
|
border-color: var(--color-active);
|
||||||
|
}
|
||||||
|
</style>
|
||||||
@@ -4,7 +4,7 @@
|
|||||||
import Grid from '$lib/grid';
|
import Grid from '$lib/grid';
|
||||||
import { debounceAsyncFunction } from '$lib/helpers';
|
import { debounceAsyncFunction } from '$lib/helpers';
|
||||||
import { createKeyMap } from '$lib/helpers/createKeyMap';
|
import { createKeyMap } from '$lib/helpers/createKeyMap';
|
||||||
import { debugNode } from '$lib/node-registry/debugNode.js';
|
import { debugNode } from '$lib/node-registry/debugNode';
|
||||||
import { IndexDBCache, RemoteNodeRegistry } from '$lib/node-registry/index';
|
import { IndexDBCache, RemoteNodeRegistry } from '$lib/node-registry/index';
|
||||||
import NodeStore from '$lib/node-store/NodeStore.svelte';
|
import NodeStore from '$lib/node-store/NodeStore.svelte';
|
||||||
import PerformanceViewer from '$lib/performance/PerformanceViewer.svelte';
|
import PerformanceViewer from '$lib/performance/PerformanceViewer.svelte';
|
||||||
@@ -21,6 +21,7 @@
|
|||||||
import Changelog from '$lib/sidebar/panels/Changelog.svelte';
|
import Changelog from '$lib/sidebar/panels/Changelog.svelte';
|
||||||
import ExportSettings from '$lib/sidebar/panels/ExportSettings.svelte';
|
import ExportSettings from '$lib/sidebar/panels/ExportSettings.svelte';
|
||||||
import GraphSource from '$lib/sidebar/panels/GraphSource.svelte';
|
import GraphSource from '$lib/sidebar/panels/GraphSource.svelte';
|
||||||
|
import GroupSettings from '$lib/sidebar/panels/GroupSettings.svelte';
|
||||||
import Keymap from '$lib/sidebar/panels/Keymap.svelte';
|
import Keymap from '$lib/sidebar/panels/Keymap.svelte';
|
||||||
import { panelState } from '$lib/sidebar/PanelState.svelte';
|
import { panelState } from '$lib/sidebar/PanelState.svelte';
|
||||||
import Sidebar from '$lib/sidebar/Sidebar.svelte';
|
import Sidebar from '$lib/sidebar/Sidebar.svelte';
|
||||||
@@ -258,7 +259,7 @@
|
|||||||
graph={pm.graph}
|
graph={pm.graph}
|
||||||
bind:this={graphInterface}
|
bind:this={graphInterface}
|
||||||
registry={nodeRegistry}
|
registry={nodeRegistry}
|
||||||
safePadding={{ right: sidebarOpen ? 330 : undefined }}
|
safePadding={{ right: sidebarOpen ? 320 : undefined }}
|
||||||
backgroundType={appSettings.value.nodeInterface.backgroundType}
|
backgroundType={appSettings.value.nodeInterface.backgroundType}
|
||||||
snapToGrid={appSettings.value.nodeInterface.snapToGrid}
|
snapToGrid={appSettings.value.nodeInterface.snapToGrid}
|
||||||
bind:activeNode
|
bind:activeNode
|
||||||
@@ -321,7 +322,7 @@
|
|||||||
hidden={!appSettings.value.debug.advancedMode}
|
hidden={!appSettings.value.debug.advancedMode}
|
||||||
icon="i-[tabler--code]"
|
icon="i-[tabler--code]"
|
||||||
>
|
>
|
||||||
<GraphSource graph={pm.graph ?? manager?.serialize()} />
|
<GraphSource graph={manager?.serializeFullGraph()} />
|
||||||
</Panel>
|
</Panel>
|
||||||
<Panel
|
<Panel
|
||||||
id="benchmark"
|
id="benchmark"
|
||||||
@@ -336,12 +337,14 @@
|
|||||||
title="Graph Settings"
|
title="Graph Settings"
|
||||||
icon="i-[custom--graph] bg-blue-400"
|
icon="i-[custom--graph] bg-blue-400"
|
||||||
>
|
>
|
||||||
|
<span class="block h-[1px]"></span>
|
||||||
<NestedSettings
|
<NestedSettings
|
||||||
id="graph-settings"
|
id="graph-settings"
|
||||||
type={graphSettingTypes}
|
type={graphSettingTypes}
|
||||||
bind:value={graphSettings}
|
bind:value={graphSettings}
|
||||||
/>
|
/>
|
||||||
<ActiveNodeSettings {manager} bind:node={activeNode} />
|
<ActiveNodeSettings {manager} bind:node={activeNode} />
|
||||||
|
<GroupSettings {manager} bind:node={activeNode} />
|
||||||
</Panel>
|
</Panel>
|
||||||
<Panel
|
<Panel
|
||||||
id="changelog"
|
id="changelog"
|
||||||
|
|||||||
+216
@@ -0,0 +1,216 @@
|
|||||||
|
# Nodarium — LLM Reference
|
||||||
|
|
||||||
|
## What It Is
|
||||||
|
|
||||||
|
Nodarium is a **node-based visual programming editor**. Users wire together nodes on a 2D canvas; each node is a WebAssembly module that receives typed inputs and produces typed outputs. A live Three.js viewer renders the resulting 3D geometry/paths/instances.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Repository Layout
|
||||||
|
|
||||||
|
```
|
||||||
|
/
|
||||||
|
├── app/ # SvelteKit web app
|
||||||
|
│ └── src/
|
||||||
|
│ ├── routes/+page.svelte # App entry point
|
||||||
|
│ └── lib/
|
||||||
|
│ ├── graph-interface/ # Canvas editor (UI + state)
|
||||||
|
│ ├── runtime/ # WASM execution engine
|
||||||
|
│ ├── node-registry/ # Fetch & cache node definitions
|
||||||
|
│ ├── project-manager/ # IndexDB persistence
|
||||||
|
│ ├── result-viewer/ # Three.js 3D output
|
||||||
|
│ ├── sidebar/ # UI panels
|
||||||
|
│ └── settings/ # App + graph settings
|
||||||
|
├── packages/
|
||||||
|
│ ├── types/ # Shared TypeScript types + Zod schemas
|
||||||
|
│ ├── utils/ # Logging, hashing, WASM wrapping, perf
|
||||||
|
│ ├── ui/ # Reusable Svelte UI components
|
||||||
|
│ ├── planty/ # Tutorial system
|
||||||
|
│ └── macros/ # Build-time macros
|
||||||
|
└── docs/
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Core Architecture
|
||||||
|
|
||||||
|
```
|
||||||
|
User Interaction
|
||||||
|
└── GraphInterface
|
||||||
|
├── GraphState ← UI: selection, camera, mouse, clipboard
|
||||||
|
└── GraphManager ← Logic: nodes, edges, history, serialization
|
||||||
|
├── NodeRegistry ← fetches WASM definitions (remote API + IndexDB cache)
|
||||||
|
├── HistoryManager ← undo/redo (jsondiffpatch deltas)
|
||||||
|
└── emit('result') → RuntimeExecutor
|
||||||
|
└── node.execute(Int32Array) per node
|
||||||
|
└── ResultViewer (Three.js/Threlte)
|
||||||
|
```
|
||||||
|
|
||||||
|
**Event flow:**
|
||||||
|
|
||||||
|
1. User edits graph → GraphManager mutates state
|
||||||
|
2. GraphManager emits `save` → ProjectManager persists to IndexDB
|
||||||
|
3. GraphManager emits `result` → Runtime executes graph → Viewer updates
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Critical Files
|
||||||
|
|
||||||
|
| File | Role |
|
||||||
|
| ------------------------------------------------------ | --------------------------------------------------------------------- |
|
||||||
|
| `app/src/routes/+page.svelte` | Wires all systems; creates GraphManager, runtime, registry |
|
||||||
|
| `app/src/lib/graph-interface/graph-manager.svelte.ts` | Central graph logic: createNode, createEdge, serialize, load, history |
|
||||||
|
| `app/src/lib/graph-interface/graph-state.svelte.ts` | UI state: camera, selection, mouse, clipboard, groupSelectedNodes |
|
||||||
|
| `app/src/lib/graph-interface/graph/Graph.svelte` | Canvas renderer |
|
||||||
|
| `app/src/lib/graph-interface/node/Node.svelte` | 3D mesh node (Three.js shader) |
|
||||||
|
| `app/src/lib/graph-interface/node/NodeHTML.svelte` | HTML overlay: labels + parameters |
|
||||||
|
| `app/src/lib/graph-interface/node/NodeHeader.svelte` | Node title bar |
|
||||||
|
| `app/src/lib/graph-interface/keymaps.ts` | Keyboard shortcuts |
|
||||||
|
| `app/src/lib/graph-interface/helpers/nodeHelpers.ts` | Node height calculations |
|
||||||
|
| `app/src/lib/graph-interface/graph/colors.svelte.ts` | Socket type → color mapping |
|
||||||
|
| `app/src/lib/runtime/runtime-executor.ts` | Executes nodes in DAG order; expandGroups() |
|
||||||
|
| `app/src/lib/node-registry/index.ts` | RemoteNodeRegistry entry |
|
||||||
|
| `app/src/lib/node-registry/groupNode.ts` | Built-in group node definition |
|
||||||
|
| `app/src/lib/node-registry/debugNode.ts` | Built-in debug node |
|
||||||
|
| `app/src/lib/sidebar/panels/ActiveNodeSettings.svelte` | Per-node settings panel |
|
||||||
|
| `packages/types/src/types.ts` | Graph, NodeInstance, NodeDefinition, Edge, GroupDefinition |
|
||||||
|
| `packages/types/src/inputs.ts` | NodeInput union types (float, vec3, geometry, path, …) |
|
||||||
|
| `packages/utils/src/wasm.ts` | createWasmWrapper() — wraps WASM bytes into a NodeDefinition |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Key Types
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
// packages/types/src/types.ts
|
||||||
|
|
||||||
|
type NodeId = `${string}/${string}/${string}`; // e.g. "max/plantarium/stem"
|
||||||
|
|
||||||
|
type NodeInstance = {
|
||||||
|
id: number;
|
||||||
|
type: NodeId;
|
||||||
|
position: [number, number];
|
||||||
|
props?: Record<string, number | number[]>; // current parameter values
|
||||||
|
meta?: { title?: string; lastModified?: string };
|
||||||
|
state: NodeRuntimeState; // runtime-only, NOT serialized
|
||||||
|
};
|
||||||
|
|
||||||
|
type NodeRuntimeState = {
|
||||||
|
type?: NodeDefinition; // resolved definition
|
||||||
|
parents?: NodeInstance[];
|
||||||
|
children?: NodeInstance[];
|
||||||
|
x?: number;
|
||||||
|
y?: number; // interpolated position
|
||||||
|
mesh?: Mesh; // Three.js mesh reference
|
||||||
|
ref?: HTMLElement;
|
||||||
|
};
|
||||||
|
|
||||||
|
type NodeDefinition = {
|
||||||
|
id: NodeId;
|
||||||
|
inputs?: Record<string, NodeInput>;
|
||||||
|
outputs?: string[]; // output type names
|
||||||
|
meta?: { title?: string; description?: string };
|
||||||
|
execute(input: Int32Array): Int32Array; // WASM function
|
||||||
|
};
|
||||||
|
|
||||||
|
// Edge: [fromNode, outputIndex, toNode, inputSocketName]
|
||||||
|
type Edge = [NodeInstance, number, NodeInstance, string];
|
||||||
|
|
||||||
|
type Graph = {
|
||||||
|
nodes: NodeInstance[];
|
||||||
|
edges: [number, number, number, string][]; // serialized (IDs, not refs)
|
||||||
|
settings: Record<string, unknown>;
|
||||||
|
groups: GroupDefinition[];
|
||||||
|
};
|
||||||
|
|
||||||
|
type GroupDefinition = {
|
||||||
|
id: number;
|
||||||
|
nodes: NodeInstance[];
|
||||||
|
edges: Edge[];
|
||||||
|
inputs?: Record<string, NodeInput>;
|
||||||
|
outputs?: string[];
|
||||||
|
};
|
||||||
|
```
|
||||||
|
|
||||||
|
### NodeInput socket types
|
||||||
|
|
||||||
|
`float` | `integer` | `boolean` | `select` | `seed` | `vec3` | `geometry` | `path` | `shape` | `color` | `*` (wildcard)
|
||||||
|
|
||||||
|
Each input can have: `value` (default), `label`, `hidden`, `external`, `setting` (link to graph setting), `accepts` (extra compatible types).
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Patterns & Conventions
|
||||||
|
|
||||||
|
### Svelte 5 reactivity
|
||||||
|
|
||||||
|
The codebase uses Svelte 5 runes throughout — `$state`, `$derived`, `$effect`. Collections use `SvelteMap<K,V>` and `SvelteSet<T>` (from `svelte/reactivity`) instead of plain Map/Set so that mutations trigger reactive updates.
|
||||||
|
|
||||||
|
### Context API
|
||||||
|
|
||||||
|
`GraphManager` and `GraphState` are provided via Svelte context (`setContext` / `getContext`) inside `GraphInterface`. All child components (Node, Edge, etc.) consume them via context rather than props.
|
||||||
|
|
||||||
|
### Edge representation
|
||||||
|
|
||||||
|
In memory, edges are `[NodeInstance, outputIndex, NodeInstance, inputSocketName]` — direct object references for fast traversal. On serialization (`Graph.edges`), they become `[nodeId, outputIndex, nodeId, inputSocketName]` (plain IDs).
|
||||||
|
|
||||||
|
### Socket compatibility
|
||||||
|
|
||||||
|
```typescript
|
||||||
|
areSocketsCompatible(outputType: string, inputType: string | string[]): boolean
|
||||||
|
// '*' wildcard matches any type; 'geometry' accepts ['geometry', 'instances']
|
||||||
|
```
|
||||||
|
|
||||||
|
### WASM execution interface
|
||||||
|
|
||||||
|
Every node exposes a single function: `execute(input: Int32Array): Int32Array`.
|
||||||
|
Data encoding (Plantarium):
|
||||||
|
|
||||||
|
- `[0, stemDepth, ...x,y,z,thickness]` — path
|
||||||
|
- `[1, vertexCount, faceCount, ...faces, ...vertices, ...normals]` — geometry
|
||||||
|
- `[2, vertexCount, faceCount, instanceCount, stemDepth, ...]` — instances
|
||||||
|
|
||||||
|
### Event emitter
|
||||||
|
|
||||||
|
`GraphManager extends EventEmitter<{ save, result, settings }>`. Subscribe with `manager.on('result', cb)`. Used to decouple the editor UI from runtime execution and persistence.
|
||||||
|
|
||||||
|
### History
|
||||||
|
|
||||||
|
Every mutation goes through `HistoryManager`. Call `this.history.save(this.serialize())` before mutations; undo/redo replays jsondiffpatch deltas.
|
||||||
|
|
||||||
|
### Internal node IDs
|
||||||
|
|
||||||
|
Built-in nodes use the `__internal/` namespace: `__internal/group/instance`, `__internal/node/debug`. Virtual boundary nodes use `__virtual/`: `__virtual/group/input`, `__virtual/group/output`.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## In-Progress: Node Groups (`feat/group-node-own`)
|
||||||
|
|
||||||
|
Group selected nodes with **Ctrl+G**. A `GroupDefinition` is stored in `Graph.groups[]`; a group instance node (`__internal/group/instance`) referencing it by `props.groupId` replaces the selected nodes.
|
||||||
|
|
||||||
|
**Known gaps as of 2026-05-03:**
|
||||||
|
|
||||||
|
| Issue | Location |
|
||||||
|
| ----------------------------------------------------------------------------------------- | ------------------------------------------------------------------ |
|
||||||
|
| `createGroupNode()` called but not defined | `graph-state.svelte.ts:334` → missing in `graph-manager.svelte.ts` |
|
||||||
|
| Runtime expects `group.graph.nodes/edges`; schema has flat `nodes/edges` | `runtime-executor.ts` vs `types.ts` |
|
||||||
|
| Runtime expects `group.inputs` as array; schema defines it as `Record<string, NodeInput>` | Same mismatch |
|
||||||
|
| `enterGroupNode()` is a stub — no group navigation | `graph-state.svelte.ts` |
|
||||||
|
| `serialize()` writes parent-graph edges into group instead of group-internal edges | `graph-manager.svelte.ts` |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Dev Commands
|
||||||
|
|
||||||
|
Run from `app/`:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
npm run dev # start dev server (Vite)
|
||||||
|
npm run build # production build
|
||||||
|
npm run check # svelte-check + tsc
|
||||||
|
npm run lint # eslint
|
||||||
|
npm run test # unit (vitest) + e2e (playwright)
|
||||||
|
npm run test:unit # vitest only
|
||||||
|
npm run test:e2e # playwright only
|
||||||
|
npm run bench # benchmark runner
|
||||||
|
```
|
||||||
+3
-2
@@ -6,7 +6,8 @@
|
|||||||
"qa": "pnpm lint && pnpm check && pnpm test",
|
"qa": "pnpm lint && pnpm check && pnpm test",
|
||||||
"format": "pnpm dprint fmt",
|
"format": "pnpm dprint fmt",
|
||||||
"format:check": "pnpm dprint check",
|
"format:check": "pnpm dprint check",
|
||||||
"test": "pnpm run -r --parallel test",
|
"test:e2e": "pnpm run -r --parallel test:e2e",
|
||||||
|
"test:unit": "pnpm run -r --parallel test:unit",
|
||||||
"check": "pnpm run -r --parallel check",
|
"check": "pnpm run -r --parallel check",
|
||||||
"build": "pnpm build:nodes && pnpm build:app",
|
"build": "pnpm build:nodes && pnpm build:app",
|
||||||
"build:app": "BASE_PATH=/ui pnpm -r --filter 'ui' build && pnpm -r --filter 'app'... build",
|
"build:app": "BASE_PATH=/ui pnpm -r --filter 'ui' build && pnpm -r --filter 'app'... build",
|
||||||
@@ -19,6 +20,6 @@
|
|||||||
"packageManager": "pnpm@10.28.1+sha512.7d7dbbca9e99447b7c3bf7a73286afaaf6be99251eb9498baefa7d406892f67b879adb3a1d7e687fc4ccc1a388c7175fbaae567a26ab44d1067b54fcb0d6a316",
|
"packageManager": "pnpm@10.28.1+sha512.7d7dbbca9e99447b7c3bf7a73286afaaf6be99251eb9498baefa7d406892f67b879adb3a1d7e687fc4ccc1a388c7175fbaae567a26ab44d1067b54fcb0d6a316",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"chokidar-cli": "catalog:",
|
"chokidar-cli": "catalog:",
|
||||||
"dprint": "^0.51.1"
|
"dprint": "^0.54.0"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -34,29 +34,29 @@
|
|||||||
"svelte": "^5.0.0"
|
"svelte": "^5.0.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@nodarium/ui": "workspace:*",
|
"@eslint/compat": "^2.0.5",
|
||||||
"@eslint/compat": "^2.0.4",
|
|
||||||
"@eslint/js": "^10.0.1",
|
"@eslint/js": "^10.0.1",
|
||||||
|
"@nodarium/ui": "workspace:*",
|
||||||
"@sveltejs/adapter-auto": "^7.0.1",
|
"@sveltejs/adapter-auto": "^7.0.1",
|
||||||
"@sveltejs/kit": "^2.57.0",
|
"@sveltejs/kit": "^2.59.0",
|
||||||
"@sveltejs/package": "^2.5.7",
|
"@sveltejs/package": "^2.5.7",
|
||||||
"@sveltejs/vite-plugin-svelte": "^7.0.0",
|
"@sveltejs/vite-plugin-svelte": "^7.0.0",
|
||||||
"@tailwindcss/vite": "^4.2.2",
|
"@tailwindcss/vite": "^4.2.4",
|
||||||
"@types/node": "^24",
|
"@types/node": "^25.6.0",
|
||||||
"eslint": "^10.2.0",
|
"eslint": "^10.3.0",
|
||||||
"eslint-config-prettier": "^10.1.8",
|
"eslint-config-prettier": "^10.1.8",
|
||||||
"eslint-plugin-svelte": "^3.17.0",
|
"eslint-plugin-svelte": "^3.17.1",
|
||||||
"globals": "^17.4.0",
|
"globals": "^17.6.0",
|
||||||
"prettier": "^3.8.1",
|
"prettier": "^3.8.3",
|
||||||
"prettier-plugin-svelte": "^3.5.1",
|
"prettier-plugin-svelte": "^3.5.1",
|
||||||
"prettier-plugin-tailwindcss": "^0.7.2",
|
"prettier-plugin-tailwindcss": "^0.8.0",
|
||||||
"publint": "^0.3.18",
|
"publint": "^0.3.18",
|
||||||
"svelte": "^5.55.2",
|
"svelte": "^5.55.5",
|
||||||
"svelte-check": "^4.4.6",
|
"svelte-check": "^4.4.7",
|
||||||
"tailwindcss": "^4.2.2",
|
"tailwindcss": "^4.2.4",
|
||||||
"typescript": "^6.0.2",
|
"typescript": "^6.0.3",
|
||||||
"typescript-eslint": "^8.58.1",
|
"typescript-eslint": "^8.59.1",
|
||||||
"vite": "^8.0.7"
|
"vite": "^8.0.10"
|
||||||
},
|
},
|
||||||
"keywords": [
|
"keywords": [
|
||||||
"svelte"
|
"svelte"
|
||||||
|
|||||||
@@ -18,9 +18,9 @@
|
|||||||
"author": "",
|
"author": "",
|
||||||
"license": "ISC",
|
"license": "ISC",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"zod": "^4.3.6"
|
"zod": "^4.4.3"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"dprint": "^0.51.1"
|
"dprint": "^0.54.0"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,11 +4,12 @@ export type {
|
|||||||
Box,
|
Box,
|
||||||
Edge,
|
Edge,
|
||||||
Graph,
|
Graph,
|
||||||
|
GroupDefinition,
|
||||||
NodeDefinition,
|
NodeDefinition,
|
||||||
NodeId,
|
NodeId,
|
||||||
NodeInstance,
|
NodeInstance,
|
||||||
SerializedNode,
|
SerializedNode,
|
||||||
Socket
|
Socket
|
||||||
} from './types';
|
} from './types';
|
||||||
export { GraphSchema, NodeSchema } from './types';
|
export { GraphSchema, GroupSchema, NodeSchema } from './types';
|
||||||
export { NodeDefinitionSchema } from './types';
|
export { NodeDefinitionSchema } from './types';
|
||||||
|
|||||||
@@ -61,8 +61,10 @@ export const NodeInputBooleanSchema = z.object({
|
|||||||
export const NodeInputSelectSchema = z.object({
|
export const NodeInputSelectSchema = z.object({
|
||||||
...DefaultOptionsSchema.shape,
|
...DefaultOptionsSchema.shape,
|
||||||
type: z.literal('select'),
|
type: z.literal('select'),
|
||||||
options: z.array(z.string()).optional(),
|
options: z.array(
|
||||||
value: z.string().optional()
|
z.union([z.string(), z.object({ value: z.number(), label: z.string() })])
|
||||||
|
).optional(),
|
||||||
|
value: z.union([z.string(), z.number()]).optional()
|
||||||
});
|
});
|
||||||
|
|
||||||
export const NodeInputSeedSchema = z.object({
|
export const NodeInputSeedSchema = z.object({
|
||||||
|
|||||||
@@ -76,6 +76,20 @@ export type Socket = {
|
|||||||
|
|
||||||
export type Edge = [NodeInstance, number, NodeInstance, string];
|
export type Edge = [NodeInstance, number, NodeInstance, string];
|
||||||
|
|
||||||
|
export const GroupSchema = z.object({
|
||||||
|
id: z.number(),
|
||||||
|
name: z.string().optional(),
|
||||||
|
nodes: z.array(NodeSchema),
|
||||||
|
edges: z.array(z.tuple([z.number(), z.number(), z.number(), z.string()])),
|
||||||
|
inputs: z.record(z.string(), NodeInputSchema).optional(),
|
||||||
|
outputs: z.array(z.object({
|
||||||
|
type: z.string(),
|
||||||
|
label: z.string().optional()
|
||||||
|
})).optional()
|
||||||
|
});
|
||||||
|
|
||||||
|
export type GroupDefinition = z.infer<typeof GroupSchema>;
|
||||||
|
|
||||||
export const GraphSchema = z.object({
|
export const GraphSchema = z.object({
|
||||||
id: z.number(),
|
id: z.number(),
|
||||||
meta: z
|
meta: z
|
||||||
@@ -86,7 +100,8 @@ export const GraphSchema = z.object({
|
|||||||
.optional(),
|
.optional(),
|
||||||
settings: z.record(z.string(), z.any()).optional(),
|
settings: z.record(z.string(), z.any()).optional(),
|
||||||
nodes: z.array(NodeSchema),
|
nodes: z.array(NodeSchema),
|
||||||
edges: z.array(z.tuple([z.number(), z.number(), z.number(), z.string()]))
|
edges: z.array(z.tuple([z.number(), z.number(), z.number(), z.string()])),
|
||||||
|
groups: z.array(GroupSchema)
|
||||||
});
|
});
|
||||||
|
|
||||||
export type Graph = z.infer<typeof GraphSchema>;
|
export type Graph = z.infer<typeof GraphSchema>;
|
||||||
|
|||||||
+29
-29
@@ -30,46 +30,46 @@
|
|||||||
"svelte": "^4.0.0"
|
"svelte": "^4.0.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@eslint/compat": "^2.0.2",
|
"@eslint/compat": "^2.0.5",
|
||||||
"@eslint/eslintrc": "^3.3.3",
|
"@eslint/eslintrc": "^3.3.5",
|
||||||
"@eslint/js": "^9.39.2",
|
"@eslint/js": "^10.0.1",
|
||||||
"@nodarium/types": "workspace:^",
|
"@nodarium/types": "workspace:^",
|
||||||
"@playwright/test": "^1.58.1",
|
"@playwright/test": "^1.59.1",
|
||||||
"@sveltejs/adapter-static": "^3.0.10",
|
"@sveltejs/adapter-static": "^3.0.10",
|
||||||
"@sveltejs/kit": "^2.50.2",
|
"@sveltejs/kit": "^2.59.0",
|
||||||
"@sveltejs/package": "^2.5.7",
|
"@sveltejs/package": "^2.5.7",
|
||||||
"@sveltejs/vite-plugin-svelte": "^6.2.4",
|
"@sveltejs/vite-plugin-svelte": "^7.0.0",
|
||||||
"@testing-library/svelte": "^5.3.1",
|
"@testing-library/svelte": "^5.3.1",
|
||||||
"@types/eslint": "^9.6.1",
|
"@types/eslint": "^9.6.1",
|
||||||
"@types/three": "^0.182.0",
|
"@types/three": "^0.184.0",
|
||||||
"@typescript-eslint/eslint-plugin": "^8.54.0",
|
"@typescript-eslint/eslint-plugin": "^8.59.1",
|
||||||
"@typescript-eslint/parser": "^8.54.0",
|
"@typescript-eslint/parser": "^8.59.1",
|
||||||
"@vitest/browser-playwright": "^4.0.18",
|
"@vitest/browser-playwright": "^4.1.5",
|
||||||
"dprint": "^0.51.1",
|
"dprint": "^0.54.0",
|
||||||
"eslint": "^9.39.2",
|
"eslint": "^10.3.0",
|
||||||
"eslint-plugin-svelte": "^3.14.0",
|
"eslint-plugin-svelte": "^3.17.1",
|
||||||
"globals": "^17.3.0",
|
"globals": "^17.6.0",
|
||||||
"publint": "^0.3.17",
|
"publint": "^0.3.18",
|
||||||
"svelte": "^5.49.2",
|
"svelte": "^5.55.5",
|
||||||
"svelte-check": "^4.3.6",
|
"svelte-check": "^4.4.7",
|
||||||
"svelte-eslint-parser": "^1.4.1",
|
"svelte-eslint-parser": "^1.6.0",
|
||||||
"tslib": "^2.8.1",
|
"tslib": "^2.8.1",
|
||||||
"typescript": "^5.9.3",
|
"typescript": "^6.0.3",
|
||||||
"typescript-eslint": "^8.54.0",
|
"typescript-eslint": "^8.59.1",
|
||||||
"vite": "^7.3.1",
|
"vite": "^8.0.10",
|
||||||
"vitest": "^4.0.18",
|
"vitest": "^4.1.5",
|
||||||
"vitest-browser-svelte": "^2.0.2"
|
"vitest-browser-svelte": "^2.1.1"
|
||||||
},
|
},
|
||||||
"svelte": "./dist/index.js",
|
"svelte": "./dist/index.js",
|
||||||
"types": "./dist/index.d.ts",
|
"types": "./dist/index.d.ts",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"@iconify-json/tabler": "^1.2.33",
|
||||||
|
"@iconify/tailwind4": "^1.2.3",
|
||||||
"@nodarium/ui": "workspace:*",
|
"@nodarium/ui": "workspace:*",
|
||||||
"@iconify-json/tabler": "^1.2.26",
|
"@tailwindcss/vite": "^4.2.4",
|
||||||
"@iconify/tailwind4": "^1.2.1",
|
"@threlte/core": "^8.5.11",
|
||||||
"@tailwindcss/vite": "^4.1.18",
|
"@threlte/extras": "^9.15.1",
|
||||||
"@threlte/core": "^8.3.1",
|
"tailwindcss": "^4.2.4"
|
||||||
"@threlte/extras": "^9.7.1",
|
|
||||||
"tailwindcss": "^4.1.18"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,144 @@
|
|||||||
|
<script module lang="ts">
|
||||||
|
// eslint-disable-next-line svelte/prefer-svelte-reactivity
|
||||||
|
const cache = new Map<string, Record<string, boolean>>();
|
||||||
|
|
||||||
|
function getStore(root: string): Record<string, boolean> {
|
||||||
|
if (!cache.has(root)) {
|
||||||
|
try {
|
||||||
|
const raw = localStorage.getItem(`json_viewer:${root}`);
|
||||||
|
cache.set(root, raw ? JSON.parse(raw) : {});
|
||||||
|
} catch {
|
||||||
|
cache.set(root, {});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return cache.get(root)!;
|
||||||
|
}
|
||||||
|
|
||||||
|
function readOpen(path: string, fallback: boolean): boolean {
|
||||||
|
const root = path.split('/')[0];
|
||||||
|
const store = getStore(root);
|
||||||
|
return path in store ? store[path] : fallback;
|
||||||
|
}
|
||||||
|
|
||||||
|
function writeOpen(path: string, value: boolean) {
|
||||||
|
const root = path.split('/')[0];
|
||||||
|
const store = getStore(root);
|
||||||
|
store[path] = value;
|
||||||
|
try {
|
||||||
|
localStorage.setItem(`json_viewer:${root}`, JSON.stringify(store));
|
||||||
|
} catch { /* quota exceeded etc */ }
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<script lang="ts">
|
||||||
|
import { browser } from '$app/environment';
|
||||||
|
import JsonViewer from './JsonViewer.svelte';
|
||||||
|
|
||||||
|
let {
|
||||||
|
value,
|
||||||
|
key,
|
||||||
|
depth = 0,
|
||||||
|
path = ''
|
||||||
|
}: { value: unknown; key?: string; depth?: number; path?: string } = $props();
|
||||||
|
|
||||||
|
const defaultOpen = $derived(depth < 4);
|
||||||
|
let open = $derived(browser && path ? readOpen(path, defaultOpen) : defaultOpen);
|
||||||
|
let flashing = $state(false);
|
||||||
|
|
||||||
|
const isArr = $derived(Array.isArray(value));
|
||||||
|
const isExpandable = $derived(value !== null && typeof value === 'object');
|
||||||
|
const open_bracket = $derived(isArr ? '[' : '{');
|
||||||
|
const close_bracket = $derived(isArr ? ']' : '}');
|
||||||
|
const items = $derived.by(() => {
|
||||||
|
if (isArr) {
|
||||||
|
return (value as unknown[]).map((v, i) => [String(i), v] as [string, unknown]);
|
||||||
|
}
|
||||||
|
if (value !== null && typeof value === 'object') {
|
||||||
|
return Object.entries(value as Record<string, unknown>).filter(
|
||||||
|
([, v]) => v !== undefined
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return [] as [string, unknown][];
|
||||||
|
});
|
||||||
|
const showKeys = $derived(!isArr || typeof items[0]?.[1] === 'object');
|
||||||
|
|
||||||
|
function toggle(next: boolean) {
|
||||||
|
open = next;
|
||||||
|
if (browser && path) writeOpen(path, next);
|
||||||
|
}
|
||||||
|
|
||||||
|
let prevJson = '';
|
||||||
|
let flashTimeout: ReturnType<typeof setTimeout> | null = null;
|
||||||
|
|
||||||
|
$effect(() => {
|
||||||
|
const json = JSON.stringify(value);
|
||||||
|
if (prevJson && json !== prevJson) {
|
||||||
|
if (flashTimeout) clearTimeout(flashTimeout);
|
||||||
|
flashing = true;
|
||||||
|
flashTimeout = setTimeout(() => {
|
||||||
|
flashing = false;
|
||||||
|
flashTimeout = null;
|
||||||
|
}, 500);
|
||||||
|
}
|
||||||
|
prevJson = json;
|
||||||
|
});
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<span
|
||||||
|
class="font-mono text-xs leading-[1.6] rounded transition-[background-color] duration-500"
|
||||||
|
class:bg-layer-3={flashing}
|
||||||
|
>
|
||||||
|
{#if key !== undefined}
|
||||||
|
<button
|
||||||
|
class="text-text hover:bg-layer-3 cursor-pointer"
|
||||||
|
title="Copy value"
|
||||||
|
onclick={() => navigator.clipboard.writeText(JSON.stringify({ [key]: value }, null, 2))}
|
||||||
|
>
|
||||||
|
{key}
|
||||||
|
</button><span class="text-text/40">: </span>
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
{#if isExpandable}
|
||||||
|
{#if items.length === 0}
|
||||||
|
<span class="text-text/50">{open_bracket}{close_bracket}</span>
|
||||||
|
{:else if open}
|
||||||
|
{#if depth > 0}
|
||||||
|
<button class="w-3 text-text/50 hover:text-text" onclick={() => toggle(false)}>
|
||||||
|
▼
|
||||||
|
</button>
|
||||||
|
{/if}
|
||||||
|
<span class="text-text/50">{open_bracket}</span>
|
||||||
|
<div class="pl-4 border-l border-outline">
|
||||||
|
{#each items as [k, v], i (k)}
|
||||||
|
<div>
|
||||||
|
<JsonViewer
|
||||||
|
value={v}
|
||||||
|
key={showKeys ? k : undefined}
|
||||||
|
depth={depth + 1}
|
||||||
|
path={path ? `${path}/${k}` : k}
|
||||||
|
/>{#if i < items.length - 1}<span class="text-text/20">,</span>{/if}
|
||||||
|
</div>
|
||||||
|
{/each}
|
||||||
|
</div>
|
||||||
|
<span class="text-text/50">{close_bracket}</span>
|
||||||
|
{:else}
|
||||||
|
<button
|
||||||
|
class="inline text-text/50 hover:text-text"
|
||||||
|
onclick={() => toggle(true)}
|
||||||
|
>
|
||||||
|
<span class="w-3 inline-block">▶</span>
|
||||||
|
{open_bracket}<span class="text-text/40 mx-1">{items.length}</span>{close_bracket}
|
||||||
|
</button>
|
||||||
|
{/if}
|
||||||
|
{:else if value === null}
|
||||||
|
<span class="text-emerald-500!">null</span>
|
||||||
|
{:else if typeof value === 'boolean'}
|
||||||
|
<span class="text-blue-500!">{value}</span>
|
||||||
|
{:else if typeof value === 'number'}
|
||||||
|
<span class="text-orange-400!">{value}</span>
|
||||||
|
{:else if typeof value === 'string'}
|
||||||
|
<span class="text-emerald-500!">"{value}"</span>
|
||||||
|
{:else}
|
||||||
|
<span class="text-text/70">{String(value)}</span>
|
||||||
|
{/if}
|
||||||
|
</span>
|
||||||
@@ -7,6 +7,7 @@ export { default as InputShape } from './inputs/InputShape.svelte';
|
|||||||
export { default as InputVec3 } from './inputs/InputVec3.svelte';
|
export { default as InputVec3 } from './inputs/InputVec3.svelte';
|
||||||
|
|
||||||
export { default as Details } from './Details.svelte';
|
export { default as Details } from './Details.svelte';
|
||||||
|
export { default as JsonViewer } from './JsonViewer.svelte';
|
||||||
export { default as ShortCut } from './ShortCut.svelte';
|
export { default as ShortCut } from './ShortCut.svelte';
|
||||||
|
|
||||||
import Input from './Input.svelte';
|
import Input from './Input.svelte';
|
||||||
|
|||||||
@@ -1,16 +1,22 @@
|
|||||||
<script lang="ts">
|
<script lang="ts">
|
||||||
|
type SelectOption = string | { value: number; label: string };
|
||||||
|
|
||||||
interface Props {
|
interface Props {
|
||||||
options?: string[];
|
options?: SelectOption[];
|
||||||
value?: number;
|
value?: number;
|
||||||
id?: string;
|
id?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
let { options = [], value = $bindable(0), id = '' }: Props = $props();
|
let { options = [], value = $bindable(0), id = '' }: Props = $props();
|
||||||
|
|
||||||
|
const normalized = $derived(
|
||||||
|
options.map((opt, i) => typeof opt === 'string' ? { value: i, label: opt } : opt)
|
||||||
|
);
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<select {id} bind:value class="bg-layer-2 text-text">
|
<select {id} bind:value class="bg-layer-2 text-text">
|
||||||
{#each options as label, i (label)}
|
{#each normalized as opt (opt.value)}
|
||||||
<option value={i}>{label}</option>
|
<option value={opt.value}>{opt.label}</option>
|
||||||
{/each}
|
{/each}
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
|||||||
@@ -8,6 +8,7 @@
|
|||||||
InputSelect,
|
InputSelect,
|
||||||
InputShape,
|
InputShape,
|
||||||
InputVec3,
|
InputVec3,
|
||||||
|
JsonViewer,
|
||||||
ShortCut
|
ShortCut
|
||||||
} from '$lib';
|
} from '$lib';
|
||||||
import Section from './Section.svelte';
|
import Section from './Section.svelte';
|
||||||
@@ -20,11 +21,37 @@
|
|||||||
let vecValue = $state([0.2, 0.3, 0.4]);
|
let vecValue = $state([0.2, 0.3, 0.4]);
|
||||||
const options = ['strawberry', 'raspberry', 'chickpeas'];
|
const options = ['strawberry', 'raspberry', 'chickpeas'];
|
||||||
let selectValue = $state(0);
|
let selectValue = $state(0);
|
||||||
const d = $derived(options[selectValue]);
|
let selectValue2 = $state(0);
|
||||||
let checked = $state(false);
|
let checked = $state(false);
|
||||||
let colorValue = $state<[number, number, number]>([59, 130, 246]);
|
let colorValue = $state<[number, number, number]>([59, 130, 246]);
|
||||||
let mirrorShape = $state(true);
|
let mirrorShape = $state(true);
|
||||||
let detailsOpen = $state(false);
|
let detailsOpen = $state(false);
|
||||||
|
let jsonValue = $state({
|
||||||
|
id: 1,
|
||||||
|
nodes: [{ id: 0, type: 'max/test/node', position: [0, 0] }, {
|
||||||
|
id: 1,
|
||||||
|
type: 'max/test/other',
|
||||||
|
position: [100, 50]
|
||||||
|
}],
|
||||||
|
edges: [[0, 0, 1, 'input']],
|
||||||
|
groups: [],
|
||||||
|
settings: { seed: 42, enabled: true }
|
||||||
|
});
|
||||||
|
|
||||||
|
function randomlyUpdateJson() {
|
||||||
|
const rand = Math.floor(Math.random() * 5);
|
||||||
|
if (rand === 0) {
|
||||||
|
jsonValue.nodes[0].position[0] += 1;
|
||||||
|
} else if (rand === 1) {
|
||||||
|
jsonValue.nodes[0].position[1] += 1;
|
||||||
|
} else if (rand === 2) {
|
||||||
|
jsonValue.settings.seed += 1;
|
||||||
|
} else if (rand === 3) {
|
||||||
|
jsonValue.settings.enabled = !jsonValue.settings.enabled;
|
||||||
|
} else if (rand === 4) {
|
||||||
|
jsonValue.id += Math.floor(Math.random() * 10 - 5);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
let points = $state([]);
|
let points = $state([]);
|
||||||
let theme = $state('dark');
|
let theme = $state('dark');
|
||||||
@@ -55,8 +82,28 @@
|
|||||||
<InputVec3 bind:value={vecValue} />
|
<InputVec3 bind:value={vecValue} />
|
||||||
</Section>
|
</Section>
|
||||||
|
|
||||||
<Section title="Select" value={d}>
|
<Section title="Select">
|
||||||
|
<p>
|
||||||
|
Select with simple values
|
||||||
|
<br>
|
||||||
|
<b>value={options[selectValue]}</b>
|
||||||
|
</p>
|
||||||
<InputSelect bind:value={selectValue} {options} />
|
<InputSelect bind:value={selectValue} {options} />
|
||||||
|
<br>
|
||||||
|
<br>
|
||||||
|
<p>
|
||||||
|
Select with <i>{option: number, label: string}[]</i>
|
||||||
|
<br>
|
||||||
|
<b>value={selectValue2}</b>
|
||||||
|
</p>
|
||||||
|
<InputSelect
|
||||||
|
bind:value={selectValue2}
|
||||||
|
options={[
|
||||||
|
{ value: 0, label: 'Zero' },
|
||||||
|
{ value: 1, label: 'One' },
|
||||||
|
{ value: 2, label: 'Two' }
|
||||||
|
]}
|
||||||
|
/>
|
||||||
</Section>
|
</Section>
|
||||||
|
|
||||||
<Section title="Checkbox" value={checked}>
|
<Section title="Checkbox" value={checked}>
|
||||||
@@ -86,6 +133,23 @@
|
|||||||
</Details>
|
</Details>
|
||||||
</Section>
|
</Section>
|
||||||
|
|
||||||
|
<Section title="JsonViewer">
|
||||||
|
{#snippet header()}
|
||||||
|
<button
|
||||||
|
onclick={() => randomlyUpdateJson()}
|
||||||
|
class="-mt-1 bg-layer-2 p-1 px-2 rounded-sm cursor-pointer"
|
||||||
|
>
|
||||||
|
update
|
||||||
|
</button>
|
||||||
|
{/snippet}
|
||||||
|
<div class="w-64 bg-layer-1 p-2 rounded">
|
||||||
|
<JsonViewer
|
||||||
|
value={jsonValue}
|
||||||
|
path="demo"
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
</Section>
|
||||||
|
|
||||||
<Section title="Shortcut">
|
<Section title="Shortcut">
|
||||||
<div class="flex gap-4">
|
<div class="flex gap-4">
|
||||||
<ShortCut ctrl key="S" />
|
<ShortCut ctrl key="S" />
|
||||||
|
|||||||
@@ -12,6 +12,7 @@
|
|||||||
'custom'
|
'custom'
|
||||||
];
|
];
|
||||||
|
|
||||||
|
// eslint-disable-next-line no-useless-assignment
|
||||||
let { theme = $bindable() } = $props();
|
let { theme = $bindable() } = $props();
|
||||||
|
|
||||||
let themeIndex = $state(0);
|
let themeIndex = $state(0);
|
||||||
|
|||||||
@@ -16,8 +16,8 @@
|
|||||||
"@nodarium/types": "workspace:^"
|
"@nodarium/types": "workspace:^"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"dprint": "^0.51.1",
|
"dprint": "^0.54.0",
|
||||||
"vite": "^7.3.1",
|
"vite": "^8.0.10",
|
||||||
"vitest": "^4.0.18"
|
"vitest": "^4.1.5"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ export interface PerformanceStore {
|
|||||||
startRun(): void;
|
startRun(): void;
|
||||||
stopRun(): void;
|
stopRun(): void;
|
||||||
addPoint(name: string, value?: number): void;
|
addPoint(name: string, value?: number): void;
|
||||||
|
addToLastRun(name: string, value: number): void;
|
||||||
endPoint(name?: string): void;
|
endPoint(name?: string): void;
|
||||||
mergeData(data: PerformanceData[number]): void;
|
mergeData(data: PerformanceData[number]): void;
|
||||||
get: () => PerformanceData;
|
get: () => PerformanceData;
|
||||||
@@ -63,6 +64,13 @@ export function createPerformanceStore(): PerformanceStore {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function addToLastRun(name: string, value: number) {
|
||||||
|
const last = data[data.length - 1];
|
||||||
|
if (!last) return;
|
||||||
|
last[name] = last[name] || [];
|
||||||
|
last[name].push(value);
|
||||||
|
}
|
||||||
|
|
||||||
function get() {
|
function get() {
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
@@ -94,6 +102,7 @@ export function createPerformanceStore(): PerformanceStore {
|
|||||||
startRun,
|
startRun,
|
||||||
stopRun,
|
stopRun,
|
||||||
addPoint,
|
addPoint,
|
||||||
|
addToLastRun,
|
||||||
endPoint,
|
endPoint,
|
||||||
mergeData,
|
mergeData,
|
||||||
get
|
get
|
||||||
|
|||||||
Generated
+1021
-2034
File diff suppressed because it is too large
Load Diff
@@ -7,6 +7,7 @@ packages:
|
|||||||
|
|
||||||
catalog:
|
catalog:
|
||||||
chokidar-cli: github:open-cli-tools/chokidar-cli#semver:v4.0.0
|
chokidar-cli: github:open-cli-tools/chokidar-cli#semver:v4.0.0
|
||||||
|
|
||||||
onlyBuiltDependencies:
|
onlyBuiltDependencies:
|
||||||
- "@tailwindcss/oxide"
|
- "@tailwindcss/oxide"
|
||||||
- esbuild
|
- esbuild
|
||||||
|
|||||||
Reference in New Issue
Block a user