SDK & Integration Examples

// K0nsult Node.js Client
const K0NSULT_URL = 'https://k0nsult.fly.dev';

// Pre-check before running workflow
async function preCheck(workflowId, dataClass, actionType) {
  const res = await fetch(`${K0NSULT_URL}/api/n8n/pre-check`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ workflow_id: workflowId, data_classification: dataClass, action_type: actionType })
  });
  return res.json();
}

// Log execution result
async function logExecution(workflowId, status, durationMs) {
  const res = await fetch(`${K0NSULT_URL}/api/n8n/execution-log`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ workflow_id: workflowId, status, duration_ms: durationMs })
  });
  return res.json();
}

// Request approval (pause workflow)
async function requestApproval(workflowId, reason) {
  const res = await fetch(`${K0NSULT_URL}/api/n8n/pause-for-approval`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ workflow_id: workflowId, reason })
  });
  return res.json();
}

// Get audit trail
async function getAudit(workflowId) {
  const res = await fetch(`${K0NSULT_URL}/api/n8n/audit/${workflowId}`);
  return res.json();
}

// Example usage
(async () => {
  // 1. Check policy before running
  const check = await preCheck('invoice-processing', 'financial', 'modify');
  console.log('Policy check:', check.decision, 'Risk:', check.risk_score);

  if (check.decision === 'APPROVE') {
    // 2. Run your workflow (via n8n or directly)
    // ... your execution logic ...

    // 3. Log the result
    await logExecution('invoice-processing', 'COMPLETED', 3200);
  } else if (check.decision === 'REVIEW') {
    // 4. Request human approval
    const approval = await requestApproval('invoice-processing', 'High-value financial transaction');
    console.log('Approval ID:', approval.approval_id);
  }

  // 5. Check audit trail
  const audit = await getAudit('invoice-processing');
  console.log('Audit entries:', audit.count);
})();

import requests

K0NSULT_URL = 'https://k0nsult.fly.dev'

class K0nsultClient:
    def __init__(self, base_url=K0NSULT_URL):
        self.base_url = base_url

    def pre_check(self, workflow_id, data_class, action_type):
        r = requests.post(f'{self.base_url}/api/n8n/pre-check', json={
            'workflow_id': workflow_id,
            'data_classification': data_class,
            'action_type': action_type
        })
        return r.json()

    def log_execution(self, workflow_id, status, duration_ms):
        r = requests.post(f'{self.base_url}/api/n8n/execution-log', json={
            'workflow_id': workflow_id,
            'status': status,
            'duration_ms': duration_ms
        })
        return r.json()

    def request_approval(self, workflow_id, reason):
        r = requests.post(f'{self.base_url}/api/n8n/pause-for-approval', json={
            'workflow_id': workflow_id,
            'reason': reason
        })
        return r.json()

    def get_audit(self, workflow_id):
        r = requests.get(f'{self.base_url}/api/n8n/audit/{workflow_id}')
        return r.json()

    def get_policy(self, workflow_id):
        r = requests.get(f'{self.base_url}/api/n8n/policy/{workflow_id}')
        return r.json()

# Usage
client = K0nsultClient()
result = client.pre_check('support-triage', 'internal', 'classify')
print(f"Decision: {result['decision']}, Risk: {result['risk_score']}")

# Pre-check: validate workflow before execution
curl -X POST https://k0nsult.fly.dev/api/n8n/pre-check \
  -H "Content-Type: application/json" \
  -d '{"workflow_id":"test","data_classification":"internal","action_type":"classify"}'

# Log execution result to audit trail
curl -X POST https://k0nsult.fly.dev/api/n8n/execution-log \
  -H "Content-Type: application/json" \
  -d '{"workflow_id":"test","status":"COMPLETED","duration_ms":1500}'

# Get audit trail for a workflow
curl https://k0nsult.fly.dev/api/n8n/audit/test

# Get policy rules for a workflow
curl https://k0nsult.fly.dev/api/n8n/policy/default