npm install noclick socket.io-client

import { init, nodes, execution, state } from 'noclick';

await init({
  apiKey: 'nk_live_...',
  workflowId: '...',  // optional — scope operations to a workflow
});

// List all nodes
const allNodes = await nodes.list();

// Read a node's last output
const output = await nodes.getOutput('gmail-node-id');
console.log(output.emails);

// Read a node's config
const config = await nodes.getConfig('http-node-id');

// Fire and forget
execution.runNodesInBackground(['data-fetcher']);

// With temporary config overrides (doesn't save to the node)
execution.runNodesInBackground([
  { id: 'http-node', config: { url: 'https://api.example.com/data' } }
]);

// Run and stream output
const stream = execution.runNodesAndGetOutput(
  ['data-fetcher'],        // nodes to execute
  ['formatter', 'chart']   // nodes whose output we want
);

stream.on('output', (nodeId, data) => {
  console.log(`${nodeId} completed:`, data);
});

stream.on('done', () => {
  console.log('All targets completed');
});

// Or await all results at once
const results = await stream.all();
// { 'formatter': {...}, 'chart': {...} }

await state.set('counter', 0);
const val = await state.get('counter');  // 0

await state.update('counter', n => (n || 0) + 1);
await state.del('counter');

const keys = await state.keys();  // ['counter', ...]

// React to new data from a cron-triggered node
execution.onNodeOutput('data-fetcher', (output) => {
  console.log('New data:', output);
});

// Track execution state
execution.onNodeState('data-fetcher', (state) => {
  console.log('State:', state);  // 'running' | 'completed' | 'error'
});

pip install noclick

cd sdk/python
pip install -e .

import asyncio
import noclick

async def main():
    sdk = noclick.Client(
        api_key="nk_live_...",
        workflow_id="...",
    )
    await sdk.connect()

    # ... use the SDK ...

    await sdk.disconnect()

asyncio.run(main())

# List all nodes
nodes = await sdk.nodes.list()
for node in nodes:
    print(f"{node['id']} ({node['type']}) — {node['label']}")

# Read a node's last output
output = await sdk.nodes.get_output("gmail-node-id")
for email in output.get("emails", []):
    print(f"{email['subject']} — {email['from']}")

# Read a node's config
config = await sdk.nodes.get_config("http-node-id")

# Fire and forget
await sdk.execution.run_nodes_in_background(["data-fetcher"])

# Run and wait for specific output
results = await sdk.execution.run_nodes_and_get_output(
    ["data-fetcher"],       # nodes to execute
    ["formatter", "chart"], # nodes whose output we want
    timeout=30,
)
print(results["formatter"])
print(results["chart"])

await sdk.state.set("counter", 0)
val = await sdk.state.get("counter")  # 0

await sdk.state.update("counter", lambda n: (n or 0) + 1)
await sdk.state.delete("counter")

keys = await sdk.state.keys()  # ["counter", ...]

# List credentials
creds = await sdk.auth.list_credentials()
for c in creds:
    print(f"{c['name']} ({c['type']})")

# Check if a credential exists
has_gmail = await sdk.auth.has_credential("google_gmail_oauth")

# Create an API key credential
cred = await sdk.auth.create_credential(
    "telegram_bot_token",
    {"token": "..."},
    name="My Bot"
)

import aiohttp

# Upload a file
result = await sdk.resources.upload("report.pdf", "application/pdf", file_size)
async with aiohttp.ClientSession() as session:
    with open("report.pdf", "rb") as f:
        await session.put(result["upload_url"], data=f)

# Get download URL
url = await sdk.resources.get_url(result["resource_id"])

# List resources
files = await sdk.resources.list("file")

# Create a dataset
ds_id = await sdk.dataset.create("User Submissions")

# Append rows
count = await sdk.dataset.append_rows(ds_id, [
    {"name": "Alice", "score": 95},
    {"name": "Bob", "score": 87},
])

# Read rows (paginated)
page = await sdk.dataset.get_rows(ds_id, limit=100)
for row in page["rows"]:
    print(f"{row['id']}: {row['data']}")

# Update a row
await sdk.dataset.update_row(ds_id, row_id, {"score": 98})

# Delete rows
await sdk.dataset.delete_rows(ds_id, [row_id])

# List datasets
datasets = await sdk.dataset.list()

# Subscribe to node output changes
def on_output(node_id, output):
    print(f"New output from {node_id}")

sdk.execution.on_node_output("data-fetcher", on_output)