How to Integrate Replit with LeadSquared

1# Python — verify LeadSquared connection (verify.py)
2import requests
3import os
4
5ACCESS_KEY = os.environ['LEADSQUARED_ACCESS_KEY']
6SECRET_KEY = os.environ['LEADSQUARED_SECRET_KEY']
7HOST = os.environ.get('LEADSQUARED_HOST', 'https://api.leadsquared.com')
8
9# Test connection by fetching a single lead (lightweight request)
10params = {
11    'accessKey': ACCESS_KEY,
12    'secretKey': SECRET_KEY
13}
14response = requests.get(
15    f'{HOST}/v2/LeadManagement.svc/Leads.GetByPaging',
16    params={**params, 'start': 0, 'size': 1}
17)
18if response.status_code == 200:
19    data = response.json()
20    print(f'Connection successful. Status: {data.get("Status")}')
21else:
22    print(f'Connection failed: {response.status_code} - {response.text}')

1// Node.js — Replit Secrets verification (check-secrets.js)
2const required = ['LEADSQUARED_ACCESS_KEY', 'LEADSQUARED_SECRET_KEY', 'LEADSQUARED_HOST'];
3let allOk = true;
4for (const key of required) {
5  const val = process.env[key];
6  if (!val) {
7    console.error(`MISSING: ${key} — add it via Replit Secrets (lock icon 🔒)`);
8    allOk = false;
9  } else {
10    console.log(`OK: ${key} (${val.length} chars)`);
11  }
12}
13if (allOk) console.log('All LeadSquared secrets verified.');

1// Node.js — lead capture endpoint (index.js)
2const express = require('express');
3const axios = require('axios');
4
5const app = express();
6app.use(express.json());
7
8const ACCESS_KEY = process.env.LEADSQUARED_ACCESS_KEY;
9const SECRET_KEY = process.env.LEADSQUARED_SECRET_KEY;
10const HOST = process.env.LEADSQUARED_HOST || 'https://api.leadsquared.com';
11
12const lsParams = { accessKey: ACCESS_KEY, secretKey: SECRET_KEY };
13
14app.post('/capture-lead', async (req, res) => {
15  const { firstName, lastName, email, phone, source } = req.body;
16  if (!email) return res.status(400).json({ error: 'email is required' });
17
18  const leadData = [
19    { SchemaName: 'FirstName', Value: firstName || '' },
20    { SchemaName: 'LastName', Value: lastName || '' },
21    { SchemaName: 'EmailAddress', Value: email },
22    { SchemaName: 'Phone', Value: phone || '' },
23    { SchemaName: 'mx_Source', Value: source || 'Website Form' }
24  ];
25
26  try {
27    const response = await axios.post(
28      `${HOST}/v2/LeadManagement.svc/Lead.Create`,
29      leadData,
30      { params: lsParams }
31    );
32    const leadId = response.data.Message?.Id;
33    console.log(`Lead created: ${leadId}`);
34    res.json({ success: true, leadId });
35  } catch (err) {
36    console.error('LeadSquared error:', err.response?.data || err.message);
37    res.status(500).json({ error: 'Failed to create lead' });
38  }
39});
40
41app.listen(3000, '0.0.0.0', () => console.log('Lead capture server running'));

1# Python — log activity against a lead (log_activity.py)
2import requests
3import os
4
5ACCESS_KEY = os.environ['LEADSQUARED_ACCESS_KEY']
6SECRET_KEY = os.environ['LEADSQUARED_SECRET_KEY']
7HOST = os.environ.get('LEADSQUARED_HOST', 'https://api.leadsquared.com')
8
9params = {'accessKey': ACCESS_KEY, 'secretKey': SECRET_KEY}
10
11def log_activity(email, event_code, note=''):
12    """
13    Log an activity against a lead identified by email.
14    event_code: integer (system codes) or custom event name
15    """
16    payload = [{
17        'RelatedProspectId': email,
18        'ActivityEvent': event_code,
19        'ActivityNote': note,
20        'ActivityDateTime': None  # None uses current time
21    }]
22    response = requests.post(
23        f'{HOST}/v2/ProspectActivity.svc/Activity.Push',
24        json=payload,
25        params=params
26    )
27    if response.status_code == 200:
28        result = response.json()
29        print(f'Activity logged: {result.get("Status")}')
30        return result
31    else:
32        print(f'Error {response.status_code}: {response.text}')
33        return None
34
35# Example: Log a 'Webinar Attended' activity (use your custom event code)
36log_activity(
37    email='test@example.com',
38    event_code=208,  # Replace with your custom activity event code
39    note='Attended product overview webinar on 2026-03-30'
40)

1// Node.js — search leads and get scores (search-leads.js)
2const axios = require('axios');
3
4const ACCESS_KEY = process.env.LEADSQUARED_ACCESS_KEY;
5const SECRET_KEY = process.env.LEADSQUARED_SECRET_KEY;
6const HOST = process.env.LEADSQUARED_HOST || 'https://api.leadsquared.com';
7const params = { accessKey: ACCESS_KEY, secretKey: SECRET_KEY };
8
9async function searchLeadByEmail(email) {
10  const response = await axios.get(
11    `${HOST}/v2/LeadManagement.svc/Lead.GetByEmailAddress`,
12    { params: { ...params, emailaddress: email } }
13  );
14  return response.data;
15}
16
17async function getLeadsByScore(minScore) {
18  const criteria = [
19    {
20      Attribute: 'mx_LeadScore',
21      Operator: 'GreaterThan',
22      Value: String(minScore)
23    }
24  ]
25  const response = await axios.post(
26    `${HOST}/v2/LeadManagement.svc/Leads.GetByCriteria`,
27    criteria,
28    { params: { ...params, start: 0, size: 50 } }
29  );
30  return response.data;
31}
32
33(async () => {
34  // Example: get leads with score > 50
35  const result = await getLeadsByScore(50);
36  const leads = result.Leads || [];
37  console.log(`Found ${leads.length} leads with score > 50`);
38  leads.forEach(lead => {
39    const name = `${lead.FirstName || ''} ${lead.LastName || ''}`.trim();
40    const score = lead.mx_LeadScore || 0;
41    console.log(`  ${name} (${lead.EmailAddress}) — Score: ${score}`);
42  });
43})();