PHP Examples

<?php
// add_lead.php

require_once 'load_env.php';
require_once 'MagnetiteClient.php';

function addSingleLead() {
    try {
        $client = new MagnetiteClient();

        $result = $client->addLead(
            getenv('MAGNETITE_CAMPAIGN_ID'),
            [
                'companyName' => 'Acme Corp',
                'contactName' => 'John Smith',
                'email' => 'john@acme.com',
                'title' => 'VP of Sales',
                'domain' => 'acme.com',
                'linkedInUrl' => 'https://linkedin.com/in/johnsmith',
                'notes' => 'Met at SaaStr conference'
            ]
        );

        echo "Lead added successfully!\n";
        echo "Prospect ID: {$result['prospectId']}\n";
        echo "Status: {$result['status']}\n";
        echo "Message: {$result['message']}\n";

        return $result;

    } catch (Exception $e) {
        echo "Error adding lead: " . $e->getMessage() . "\n";
        throw $e;
    }
}

// Run the example
try {
    addSingleLead();
    echo "Done!\n";
} catch (Exception $e) {
    exit(1);
}

<?php
// add_enriched_lead.php

require_once 'load_env.php';
require_once 'MagnetiteClient.php';

function addEnrichedLead() {
    try {
        $client = new MagnetiteClient();

        $result = $client->addLead(
            getenv('MAGNETITE_CAMPAIGN_ID'),
            [
                // Required fields
                'companyName' => 'TechCorp Inc',
                'contactName' => 'Jane Doe',
                'email' => 'jane@techcorp.com',

                // Optional basic fields
                'title' => 'Marketing Director',
                'domain' => 'techcorp.com',
                'phone' => '+1-555-123-4567',
                'linkedInUrl' => 'https://linkedin.com/in/janedoe',
                'companyLinkedInUrl' => 'https://linkedin.com/company/techcorp',
                'notes' => 'Referred by partner XYZ',

                // Pre-enriched company data (optional)
                'company' => [
                    'industry' => 'Technology',
                    'employeeCount' => 250,
                    'revenue' => '$50M-100M',
                    'fundingStage' => 'Series B',
                    'technologies' => ['React', 'Node.js', 'AWS'],
                    'description' => 'Enterprise SaaS platform'
                ],

                // Pre-enriched contact data (optional)
                'contact' => [
                    'bio' => 'Marketing leader with 10+ years experience',
                    'seniority' => 'Director',
                    'department' => 'Marketing',
                    'city' => 'San Francisco',
                    'state' => 'CA',
                    'country' => 'USA'
                ],

                // Extra context for research agent (optional)
                'extraContext' => [
                    'meetingNotes' => 'Discussed integration needs',
                    'painPoints' => ['Lead generation', 'Sales automation'],
                    'referredBy' => 'Partner program'
                ]
            ]
        );

        echo "Enriched lead added!\n";
        echo "Result: " . json_encode($result, JSON_PRETTY_PRINT) . "\n";

    } catch (Exception $e) {
        echo "Error: " . $e->getMessage() . "\n";
        throw $e;
    }
}

// Run the example
try {
    addEnrichedLead();
    echo "Done!\n";
} catch (Exception $e) {
    exit(1);
}

<?php
// bulk_import.php

require_once 'load_env.php';
require_once 'MagnetiteClient.php';

function bulkImport() {
    $client = new MagnetiteClient();

    $leads = [
        [
            'companyName' => 'StartupCo',
            'contactName' => 'Sarah Johnson',
            'email' => 'sarah@startupco.com',
            'title' => 'CEO'
        ],
        [
            'companyName' => 'BigCorp Industries',
            'contactName' => 'Michael Chen',
            'email' => 'michael@bigcorp.com',
            'title' => 'Sales Director'
        ],
        [
            'companyName' => 'MidSize Solutions',
            'contactName' => 'Emily Rodriguez',
            'email' => 'emily@midsize.com',
            'title' => 'VP of Marketing'
        ]
    ];

    echo "Importing " . count($leads) . " leads to campaign...\n";

    $results = $client->addLeadsBulk(
        getenv('MAGNETITE_CAMPAIGN_ID'),
        $leads,
        1 // 1 second delay between requests
    );

    // Summary
    $successful = array_filter($results, function($r) { return $r['success']; });
    $failed = array_filter($results, function($r) { return !$r['success']; });

    echo "\n=== IMPORT SUMMARY ===\n";
    echo "Total processed: " . count($results) . "\n";
    echo "Successful: " . count($successful) . "\n";
    echo "Failed: " . count($failed) . "\n";

    if (count($failed) > 0) {
        echo "\nFailed leads:\n";
        foreach ($failed as $result) {
            echo "  - {$result['lead']['email']}: {$result['error']}\n";
        }
    }

    return $results;
}

// Run the example
try {
    bulkImport();
    echo "\nBulk import complete!\n";
} catch (Exception $e) {
    echo "Fatal error: " . $e->getMessage() . "\n";
    exit(1);
}

<?php
// csv_import.php

require_once 'load_env.php';
require_once 'MagnetiteClient.php';

function importFromCsv($csvPath) {
    $client = new MagnetiteClient();
    $campaignId = getenv('MAGNETITE_CAMPAIGN_ID');

    $leads = [];

    // Read CSV file
    if (($handle = fopen($csvPath, 'r')) !== false) {
        $headers = fgetcsv($handle);

        while (($row = fgetcsv($handle)) !== false) {
            $data = array_combine($headers, $row);

            $lead = [
                'companyName' => $data['company_name'] ?? $data['company'],
                'contactName' => $data['contact_name'] ?? $data['name'],
                'email' => $data['email'],
            ];

            // Add optional fields if present
            if (!empty($data['title'])) {
                $lead['title'] = $data['title'];
            }
            if (!empty($data['domain'])) {
                $lead['domain'] = $data['domain'];
            }
            if (!empty($data['linkedin_url'])) {
                $lead['linkedInUrl'] = $data['linkedin_url'];
            }
            if (!empty($data['notes'])) {
                $lead['notes'] = $data['notes'];
            }

            $leads[] = $lead;
        }

        fclose($handle);
    }

    echo "Loaded " . count($leads) . " leads from CSV\n";
    echo "Importing to campaign $campaignId...\n";

    $results = $client->addLeadsBulk($campaignId, $leads, 1);

    // Summary
    $successful = array_filter($results, function($r) { return $r['success']; });
    $failed = array_filter($results, function($r) { return !$r['success']; });

    echo "\nImported " . count($successful) . " leads successfully\n";
    echo "Failed: " . count($failed) . "\n";

    // Save failed leads for retry
    if (count($failed) > 0) {
        $fp = fopen('failed_leads.csv', 'w');
        fputcsv($fp, array_keys($failed[0]['lead']));
        foreach ($failed as $item) {
            fputcsv($fp, $item['lead']);
        }
        fclose($fp);
        echo "Failed leads saved to failed_leads.csv\n";
    }

    return $results;
}

// Run the example
if (isset($argv[1])) {
    importFromCsv($argv[1]);
} else {
    echo "Usage: php csv_import.php leads.csv\n";
}

<?php
// webhook.php

// Read the incoming webhook payload
$payload = file_get_contents('php://input');
$event = json_decode($payload, true);

// Log the webhook
file_put_contents(
    'webhooks.log',
    date('Y-m-d H:i:s') . " - " . $payload . "\n",
    FILE_APPEND
);

if ($event['event'] === 'meeting_booked') {
    $prospect = $event['prospect'];
    $meeting = $event['meeting'];
    $campaignId = $event['campaignId'];

    // Handle the meeting booking
    echo "Meeting booked!\n";
    echo "Company: {$prospect['companyName']}\n";
    echo "Contact: {$prospect['contactName']}\n";
    echo "Email: {$prospect['email']}\n";
    echo "Scheduled: {$meeting['scheduledAt']}\n";
    echo "Duration: {$meeting['duration']} minutes\n";

    // Examples of what you might do:
    // - Update your CRM
    // - Send Slack notification
    // - Create calendar event
    // - Update database

    // updateCRM($prospect, $meeting);
    // sendSlackNotification($prospect, $meeting);
}

// Return success response
http_response_code(200);
header('Content-Type: application/json');
echo json_encode(['received' => true]);