Build email into
your workflow.

import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { StreamableHTTPClientTransport } from '@modelcontextprotocol/sdk/client/streamableHttp.js';

const key = process.env.TMB_API_KEY;
if (!key) throw Error('Set TMB_API_KEY');
const url = process.env.TMB_MCP_URL || 'https://mcp-staging.tempmailboxes.com/mcp';
const transport = new StreamableHTTPClientTransport(new URL(url), {
  requestInit: { headers: { Authorization: 'Bearer ' + key } }
});
const client = new Client({ name: 'otp-example', version: '1.0.0' });
const value = (result) => {
  const data = JSON.parse(result.content.find((part) => part.type === 'text').text);
  if (result.isError) throw Error(data.error || 'MCP tool failed');
  return data;
};
try {
  await client.connect(transport);
  const inbox = value(await client.callTool({ name: 'create_private_inbox', arguments: {} }));
  console.log('Send your test email to', inbox.address);
  const otp = value(await client.callTool({
    name: 'wait_for_otp', arguments: { inbox_id: inbox.id, timeout_seconds: 30 }
  }));
  console.log(otp.found ? otp.code : 'No OTP: ' + otp.reason);
} finally {
  await client.close().catch(() => {});
}

const key = process.env.TMB_API_KEY;
if (!key) throw Error('Set TMB_API_KEY');
const api = process.env.TMB_API_ORIGIN || 'https://api-staging.tempmailboxes.com';
const auth = { Authorization: 'Bearer ' + key };
const created = await fetch(api + '/v1/inboxes/private', {
  method: 'POST', headers: { ...auth, 'Content-Type': 'application/json' }, body: '{}'
});
if (!created.ok) throw Error(await created.text());
const inbox = (await created.json()).data;
console.log('New address:', inbox.address);
const stream = await fetch(api + '/v1/inboxes/' + inbox.id + '/otp/events', {
  headers: { ...auth, Accept: 'text/event-stream' }
});
if (!stream.ok) throw Error(await stream.text());
let buffer = '';
let finished = false;
const decoder = new TextDecoder();
watch: for await (const chunk of stream.body) {
  buffer = (buffer + decoder.decode(chunk, { stream: true })).replaceAll('\r\n', '\n');
  let end;
  while ((end = buffer.indexOf('\n\n')) >= 0) {
    const event = buffer.slice(0, end); buffer = buffer.slice(end + 2);
    if (event.startsWith('event: ready')) console.log('Send your test email now');
    if (event.startsWith('event: otp.found')) {
      console.log(JSON.parse(event.match(/^data: (.+)$/m)[1]).code);
      finished = true;
      break watch;
    }
    if (event.startsWith('event: stream.error')) throw Error('OTP stream interrupted');
    if (event.startsWith('event: complete')) {
      console.log('No OTP candidate found');
      finished = true;
      break watch;
    }
  }
}
if (!finished) throw Error('OTP stream ended before completion');

import os, json, requests

key = os.environ['TMB_API_KEY']
api = os.environ.get('TMB_API_ORIGIN', 'https://api-staging.tempmailboxes.com')
auth = {'Authorization': 'Bearer ' + key}
created = requests.post(api + '/v1/inboxes/private', headers=auth, json={}, timeout=15)
created.raise_for_status()
inbox = created.json()['data']
print('New address:', inbox['address'], flush=True)
with requests.get(api + '/v1/inboxes/' + inbox['id'] + '/otp/events',
                  headers={**auth, 'Accept': 'text/event-stream'},
                  stream=True, timeout=(10, 65)) as response:
    response.raise_for_status()
    response.encoding = 'utf-8'
    event = None
    for line in response.iter_lines(chunk_size=1, decode_unicode=True):
        if line.startswith('event: '): event = line[7:]
        elif line.startswith('data: '):
            data = json.loads(line[6:])
            if event == 'ready': print('Send your test email now', flush=True)
            if event == 'otp.found':
                print(data['code'])
                break
            if event == 'stream.error': raise RuntimeError(data['message'])
            if event == 'complete':
                print('No OTP candidate found')
                break
        elif not line: event = None