Building an Autonomous Lead Generation Agent using Eve.dev

/eve
  /agents
    /sdr
      instructions.md
      /tools
        research_company.ts
        send_email.ts
        wait_days.ts

# Autonomous SDR

You are a top-performing Sales Development Representative. Your goal is to get prospects to book a meeting.

## Workflow
1. Use `research_company` to find recent news about the prospect's company.
2. Write a highly personalized cold email based on that news and use `send_email`.
3. Use `wait_days` to pause execution for 3 days.
4. After waking up, evaluate if they replied (this context will be provided to you).
5. If no reply, write a shorter, polite follow-up. Do not be pushy.

import { tool, suspend } from '@eve/core';
import { z } from 'zod';

export default tool({
  name: 'wait_days',
  description: 'Pause the campaign and wait for a specified number of days before following up.',
  schema: z.object({
    days: z.number().min(1).max(14)
  }),
  execute: async ({ days }) => {
    // We calculate the timestamp for when the agent should wake up
    const wakeUpAt = new Date();
    wakeUpAt.setDate(wakeUpAt.getDate() + days);

    // suspend() saves the agent state and stops execution
    return suspend({
      type: 'scheduled_sleep',
      wakeUpAt: wakeUpAt.toISOString(),
      message: `Sleeping for ${days} days.`
    });
  }
});

import { tool } from '@eve/core';
import { z } from 'zod';
// e.g. import { Resend } from 'resend';

export default tool({
  name: 'send_email',
  description: 'Send an email to the prospect.',
  schema: z.object({
    to: z.string().email(),
    subject: z.string(),
    body: z.string()
  }),
  execute: async ({ to, subject, body }) => {
    console.log(`Sending email to ${to}...`);
    // await resend.emails.send({ ... });
    return { success: true, timestamp: new Date().toISOString() };
  }
});

import { Eve } from '@eve/core';

const eve = new Eve({ workspace: './eve' });

// This function runs every hour via a Cron job
async function wakeUpSleepingAgents() {
  // 1. Query your database for workflows where wakeUpAt <= NOW()
  const sleepingWorkflows = await getReadyWorkflowsFromDB();

  for (const workflow of sleepingWorkflows) {
    const agent = await eve.getAgent('sdr');
    
    // Check if the user replied via your email provider API
    const hasReplied = await checkInboxForReply(workflow.prospectEmail);
    
    // Resume the agent with the new context!
    await agent.resume({
      id: workflow.id,
      injectedMessage: hasReplied 
        ? "The prospect replied! STOP the automated sequence immediately."
        : "The prospect has not replied yet. It is time to send the follow-up."
    });
  }
}