Trust Automation

{
  "name": "Auto DMCA Response",
  "description": "Automatically process and respond to DMCA takedown requests",
  "trigger": {
    "type": "event",
    "event": "dmca.request.received"
  },
  "nodes": [
    {
      "id": "validate",
      "type": "action",
      "action": "dmca.validate_request",
      "config": { "checkRequiredFields": true }
    },
    {
      "id": "check_content",
      "type": "action",
      "action": "content.fingerprint_match",
      "config": { "threshold": 0.85 }
    },
    {
      "id": "decision",
      "type": "condition",
      "condition": "{{ check_content.matchScore > 0.85 }}"
    },
    {
      "id": "approve",
      "type": "action",
      "action": "dmca.approve_takedown"
    },
    {
      "id": "review",
      "type": "action",
      "action": "dmca.queue_for_review"
    }
  ],
  "edges": [
    { "from": "validate", "to": "check_content" },
    { "from": "check_content", "to": "decision" },
    { "from": "decision", "to": "approve", "label": "true" },
    { "from": "decision", "to": "review", "label": "false" }
  ]
}

// Response
{
  "workflowId": "wf_abc123",
  "name": "Auto DMCA Response",
  "status": "active",
  "nodeCount": 5,
  "createdAt": "2026-02-12T10:00:00Z"
}

import { DRD } from '@drd/sdk';

const drd = new DRD({ apiKey: process.env.DRD_API_KEY });

// Create a workflow using the SDK builder
const workflow = await drd.workflows.create({
  name: 'Compliance Gap Remediation',
  description: 'Auto-assign and track compliance gap fixes',
  trigger: { type: 'event', event: 'compliance.gap.detected' },
  nodes: [
    { id: 'classify', type: 'action', action: 'compliance.classify_gap' },
    { id: 'assign', type: 'action', action: 'compliance.assign_owner' },
    { id: 'notify', type: 'action', action: 'alerts.send_notification' },
    { id: 'track', type: 'action', action: 'compliance.create_remediation' },
  ],
  edges: [
    { from: 'classify', to: 'assign' },
    { from: 'assign', to: 'notify' },
    { from: 'notify', to: 'track' },
  ],
});

console.log(workflow.workflowId);   // 'wf_def456'
console.log(workflow.status);       // 'active'

// Event-driven trigger
const eventWorkflow = await drd.workflows.create({
  name: 'Security Breach Response',
  trigger: {
    type: 'event',
    event: 'security.finding.critical',
    filter: { severity: 'critical' },
  },
  // ... nodes and edges
});

// Scheduled trigger
const scheduledWorkflow = await drd.workflows.create({
  name: 'Weekly Compliance Report',
  trigger: {
    type: 'schedule',
    cron: '0 9 * * MON',
    timezone: 'America/New_York',
  },
  // ... nodes and edges
});

// Manual trigger (executed on demand)
const manualWorkflow = await drd.workflows.create({
  name: 'Incident Investigation',
  trigger: { type: 'manual' },
  // ... nodes and edges
});

// Execute a manual workflow
const run = await drd.workflows.execute('wf_abc123', {
  input: {
    incidentId: 'inc_001',
    severity: 'critical',
  },
});

console.log(run.runId);         // 'run_xyz789'
console.log(run.status);        // 'running'

// Wait for completion
const result = await drd.workflows.waitForRun(run.runId);
console.log(result.status);     // 'completed'
console.log(result.duration);   // 12340 (ms)

// View run logs
const logs = await drd.workflows.getRunLogs(run.runId);
for (const entry of logs.items) {
  console.log(entry.nodeId);       // 'classify'
  console.log(entry.status);       // 'completed'
  console.log(entry.duration);     // 2100 (ms)
  console.log(entry.output);       // { gapType: 'data_retention', ... }
}

// Response
{
  "runs": [
    {
      "runId": "run_xyz789",
      "workflowId": "wf_abc123",
      "status": "completed",
      "trigger": "manual",
      "startedAt": "2026-02-12T10:30:00Z",
      "completedAt": "2026-02-12T10:30:12Z",
      "duration": 12340,
      "nodesExecuted": 5,
      "nodesFailed": 0
    }
  ],
  "total": 42,
  "byStatus": { "completed": 38, "failed": 3, "cancelled": 1 }
}

// List available templates
const templates = await drd.workflows.listTemplates({
  category: 'security',
});

// Create workflow from template
const workflow = await drd.workflows.createFromTemplate({
  templateId: 'tmpl_breach_response',
  name: 'Custom Breach Response',
  overrides: {
    nodes: {
      notify: {
        config: { channels: ['slack', 'pagerduty'] },
      },
    },
  },
});

console.log(workflow.workflowId);   // 'wf_ghi789'
console.log(workflow.nodeCount);    // 7 (from template)

// Simple condition with two branches
{
  "type": "condition",
  "condition": "trigger.data.trustScore < 50 && trigger.data.violationCount > 3",
  "branches": {
    "true": "quarantine-agent",
    "false": "send-warning"
  }
}

// Switch condition with multiple paths
{
  "type": "switch",
  "expression": "trigger.data.severity",
  "cases": {
    "critical": "immediate-enforcement",
    "high": "review-and-enforce",
    "medium": "queue-review",
    "low": "log-only"
  },
  "default": "log-only"
}