Mission-Critical Autonomous Ingestion and OTP Engine for AI Agents and Enterprise Pipelines

# 1. Generate New Address for Agent Task
curl -X POST https://mail.trustdigital.my.id/api/generate   -H "Content-Type: application/json"   -d '{"domain":"trustdigital.my.id","username":"agent-task"}'

# Output: {"address":"agent-task-912@trustdigital.my.id"}

# 2. Poll OTP via Long-Polling (30-second timeout)
curl -X GET "https://mail.trustdigital.my.id/api/otp?addr=agent-task-912@trustdigital.my.id&wait=30"

# Output: {"found":true,"is_spam": m.is_spam, "otp":"682104","sender":"security@app.com"}

# Autonomous Email Harvester Tool for LangChain / AutoGen
import requests

BASE_URL = "https://mail.trustdigital.my.id/api"

def create_agent_inbox(prefix="autogen-worker"):
    resp = requests.post(f"{BASE_URL}/generate", json={"username": prefix})
    return resp.json()["address"]

def harvest_otp(email_address, timeout=30):
    # Long-poll until OTP extracted by server regex
    resp = requests.get(f"{BASE_URL}/otp", params={"addr": email_address, "wait": timeout})
    data = resp.json()
    if data.get("otp"):
        return data["otp"]
    raise TimeoutError("OTP not received within timeout window.")

inbox = create_agent_inbox()
print(f"Use email for signup: {inbox}")
otp = harvest_otp(inbox)
print(f"Verified OTP: {otp}")

{
  "name": "TRUSTD Mail OTP Harvester Node",
  "nodes": [
    {
      "parameters": {
        "httpMethod": "POST",
        "path": "trustd-otp-webhook"
      },
      "name": "Webhook Ingest Trigger",
      "type": "n8n-nodes-base.webhook"
    }
  ]
}