Instantly Performance Tuning

Instantly Performance Tuning

Overview

Optimize Instantly cold outreach campaigns for deliverability and API throughput. Focus on lead upload batching, campaign analytics caching, email warmup scheduling, and webhook processing for reply tracking.

Prerequisites

• Instantly API key (v1 REST API)
• Understanding of email sending limits and warmup
• Redis or database for campaign state caching
• Webhook endpoint for reply/bounce tracking

Instructions

Step 1: Batch Lead Upload with Rate Limiting

const INSTANTLY_API = 'https://api.instantly.ai/api/v1';

async function batchUploadLeads(
  campaignId: string,
  leads: Array<{ email: string; first_name?: string; company?: string }>,
  batchSize = 100
) {
  const results = { uploaded: 0, errors: 0 };

  for (let i = 0; i < leads.length; i += batchSize) {
    const batch = leads.slice(i, i + batchSize);

    const response = await fetch(`${INSTANTLY_API}/lead/add`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({
        api_key: process.env.INSTANTLY_API_KEY,
        campaign_id: campaignId,
        skip_if_in_workspace: true,
        leads: batch,
      }),
    });

    if (response.ok) {
      results.uploaded += batch.length;
    } else {
      results.errors += batch.length;
    }

    // Respect rate limits: 10 req/sec
    await new Promise(r => setTimeout(r, 200));  # HTTP 200 OK
  }
  return results;
}

Step 2: Cache Campaign Analytics

import { LRUCache } from 'lru-cache';

const analyticsCache = new LRUCache<string, any>({
  max: 100,
  ttl: 1000 * 60 * 5, // 5 min - analytics change slowly  # 1000: 1 second in ms
});

async function getCampaignAnalytics(campaignId: string) {
  const cacheKey = `analytics:${campaignId}`;
  const cached = analyticsCache.get(cacheKey);
  if (cached) return cached;

  const response = await fetch(
    `${INSTANTLY_API}/analytics/campaign/summary?api_key=${process.env.INSTANTLY_API_KEY}&campaign_id=${campaignId}`
  );
  const data = await response.json();
  analyticsCache.set(cacheKey, data);
  return data;
}

async function getAllCampaignMetrics() {
  const campaigns = await fetch(
    `${INSTANTLY_API}/campaign/list?api_key=${process.env.INSTANTLY_API_KEY}`
  ).then(r => r.json());

  return Promise.all(
    campaigns.map((c: any) => getCampaignAnalytics(c.id))
  );
}

Step 3: Efficient Lead Status Polling

async function* paginateLeads(campaignId: string, limit = 100) {
  let skip = 0;
  let hasMore = true;

  while (hasMore) {
    const response = await fetch(`${INSTANTLY_API}/lead/get`, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        api_key: process.env.INSTANTLY_API_KEY,
        campaign_id: campaignId,
        limit,
        skip,
      }),
    });

    const leads = await response.json();
    if (!leads.length) { hasMore = false; break; }

    yield* leads;
    skip += limit;
    await new Promise(r => setTimeout(r, 150));
  }
}

// Usage: stream leads without loading all into memory
for await (const lead of paginateLeads('campaign-123')) {
  if (lead.status === 'replied') {
    await processReply(lead);
  }
}

Step 4: Webhook Reply Processing Queue

const replyQueue: any[] = [];

async function handleInstantlyWebhook(event: any) {
  if (event.event_type === 'reply_received') {
    replyQueue.push({
      leadEmail: event.lead_email,
      campaignId: event.campaign_id,
      replyText: event.reply_text,
      timestamp: Date.now(),
    });
  }
  // Process asynchronously
  setImmediate(drainReplyQueue);
}

async function drainReplyQueue() {
  while (replyQueue.length > 0) {
    const reply = replyQueue.shift();
    // Invalidate analytics cache
    analyticsCache.delete(`analytics:${reply.campaignId}`);
    await syncReplyToCRM(reply);
  }
}

Error Handling

Examples

Campaign Health Monitor

async function monitorCampaigns() {
  const metrics = await getAllCampaignMetrics();
  return metrics.map((m: any) => ({
    campaign: m.campaign_name,
    sent: m.sent,
    opened: m.opened,
    replied: m.replied,
    openRate: ((m.opened / m.sent) * 100).toFixed(1) + '%',
    replyRate: ((m.replied / m.sent) * 100).toFixed(1) + '%',
  }));
}

Resources

• Instantly API Docs
• Instantly Rate Limits

Output

• Configuration files or code changes applied to the project
• Validation report confirming correct implementation
• Summary of changes made and their rationale