Inbound Email Agent

agentuity project create --name inbound-email-agent
cd inbound-email-agent
bun add openai inboundemail

import { createAgent } from '@agentuity/runtime';
import { s } from '@agentuity/schema';
import OpenAI from 'openai';
 
const client = new OpenAI();
 
export const AgentInput = s.object({
	from: s.string().describe('Sender email address'),
	subject: s.string().describe('Email subject line'),
	body: s.string().describe('Email body content'),
	to: s.string().optional().describe('Recipient email address'),
	replyTo: s.string().optional().describe('Reply-to address if different from sender'),
});
 
export const AgentOutput = s.object({
	response: s.string().describe('AI-generated email response'),
	subject: s.string().describe('Subject line for the response'),
	summary: s.string().describe('Brief summary of the original email'),
	sentiment: s.string().describe('Detected sentiment of the incoming email'),
	threadId: s.string().describe('Thread ID for conversation continuity'),
});
 
const agent = createAgent('email', {
	description: 'Processes inbound emails and generates helpful responses',
	schema: {
		input: AgentInput,
		output: AgentOutput,
	},
	handler: async (ctx, { from, subject, body, to }) => {
		const completion = await client.chat.completions.create({
			model: 'gpt-4o-mini',
			messages: [
				{
					role: 'system',
					content:
						'You are a helpful email assistant. Generate concise, professional replies.',
				},
				{
					role: 'user',
					content: `From: ${from}\nSubject: ${subject}\n${to ? `To: ${to}` : ''}\n\n${body}`,
				},
			],
			// JSON mode ensures the response is machine-parseable for structured extraction
			response_format: { type: 'json_object' },
		});
 
		let result: Record<string, string>;
		try {
			result = JSON.parse(completion.choices[0]?.message?.content ?? '{}');
		} catch (err) {
			ctx.logger.error('Failed to parse LLM response as JSON', { err });
			result = {};
		}
 
		return {
			response: result.response ?? 'Thanks for your email. We will get back to you shortly.',
			subject: result.subject ?? `Re: ${subject}`,
			summary: result.summary ?? 'Email received and processed.',
			sentiment: result.sentiment ?? 'neutral',
			threadId: ctx.thread.id,
		};
	},
});
 
export default agent;

import { createRouter } from '@agentuity/runtime';
import email from '../agent/email';
// See https://inbound.new/docs/quickstart/getting-started for Inbound SDK setup
import { Inbound } from 'inboundemail';
 
const inbound = new Inbound({ apiKey: process.env.INBOUND_API_KEY });
const api = createRouter();
 
api.post('/email/inbound', async (c) => {
	const payload = await c.req.json();
	const emailData = payload.email;
 
	if (!emailData?.id) {
		c.var.logger.error('Missing email payload');
		return c.json({ error: 'Missing email data' }, 400);
	}
 
	const agentInput = {
		from: emailData.from?.addresses?.[0]?.address ?? '',
		subject: emailData.subject ?? '',
		body: emailData.cleanedContent?.text ?? emailData.parsedData?.textBody ?? '',
		to: emailData.to?.addresses?.[0]?.address ?? '',
	};
 
	c.var.logger.info('Processing inbound email', { from: agentInput.from, subject: agentInput.subject });
	const result = await email.run(agentInput);
 
	try {
		const reply = await inbound.emails.reply(emailData.id, {
			from: agentInput.to,
			subject: result.subject,
			text: result.response,
		});
 
		c.var.logger.info('Reply sent', { replyId: reply.id });
		return c.json({ ...result, replySent: true, replyId: reply.id });
	} catch (err) {
		c.var.logger.error('Failed to send reply', { err: String(err) });
		return c.json({ ...result, replySent: false, error: String(err) }, 500);
	}
});
 
export default api;

agentuity dev

curl -X POST http://localhost:3500/api/email/inbound \
  -H "Content-Type: application/json" \
  -d '{
    "event": "email.received",
    "email": {
      "id": "test_123",
      "from": { "addresses": [{ "address": "test@example.com" }] },
      "to": { "addresses": [{ "address": "hello@yourdomain.com" }] },
      "subject": "Test email",
      "cleanedContent": { "text": "Hello, this is a test!" }
    }
  }'

agentuity deploy