Utilities

import { defineNode } from '@jam-nodes/core';
import { z } from 'zod';

export const myNode = defineNode({
  type: 'my_node',
  name: 'My Node',
  description: 'Does something useful',
  category: 'action',
  inputSchema: z.object({ message: z.string() }),
  outputSchema: z.object({ result: z.string() }),
  estimatedDuration: 5,
  capabilities: {
    supportsRerun: true,
  },
  executor: async (input) => ({
    success: true,
    output: { result: `Processed: ${input.message}` },
  }),
});

import { prepareNodeInput, ExecutionContext } from '@jam-nodes/core';

const ctx = new ExecutionContext({
  apiUrl: 'https://api.example.com',
  token: 'abc123',
});

const resolvedInput = prepareNodeInput(
  {
    url: '{{apiUrl}}/users',
    headers: { Authorization: 'Bearer {{token}}' },
  },
  ctx
);
// { url: 'https://api.example.com/users', headers: { Authorization: 'Bearer abc123' } }