How to Integrate Replit with Propertybase

1// check-salesforce-secrets.js
2const required = ['SF_CLIENT_ID', 'SF_CLIENT_SECRET', 'SF_USERNAME', 'SF_PASSWORD', 'SF_LOGIN_URL'];
3for (const key of required) {
4  if (!process.env[key]) {
5    throw new Error(`Missing secret: ${key}. Set it in Replit Secrets (lock icon 🔒).`);
6  }
7}
8console.log('Salesforce secrets verified.');
9console.log('Login URL:', process.env.SF_LOGIN_URL);
10console.log('Username:', process.env.SF_USERNAME);

1// propertybase.js — Propertybase/Salesforce API with JSForce for Node.js on Replit
2const jsforce = require('jsforce');
3const express = require('express');
4
5const app = express();
6app.use(express.json());
7
8const conn = new jsforce.Connection({
9  loginUrl: process.env.SF_LOGIN_URL  // https://login.salesforce.com or https://test.salesforce.com
10});
11
12// Authenticate once and reuse the connection
13let isConnected = false;
14async function ensureConnected() {
15  if (!isConnected) {
16    await conn.login(process.env.SF_USERNAME, process.env.SF_PASSWORD);
17    isConnected = true;
18    console.log('Salesforce connected. Instance:', conn.instanceUrl);
19  }
20}
21
22// Get active Propertybase listings
23app.get('/api/listings', async (req, res) => {
24  try {
25    await ensureConnected();
26    const { status = 'Active', limit = 50 } = req.query;
27    
28    // pb__Listing__c is Propertybase's listing object
29    // Field names vary by org — run describe() to find exact field names
30    const result = await conn.query(
31      `SELECT Id, Name, pb__Property_Address__c, pb__List_Price__c, 
32              pb__Property_Type__c, pb__Status__c, pb__MLS_Number__c,
33              pb__Listing_Agent__r.Name
34       FROM pb__Listing__c 
35       WHERE pb__Status__c = '${status}' 
36       LIMIT ${parseInt(limit)}`
37    );
38    
39    res.json({ listings: result.records, total: result.totalSize });
40  } catch (err) {
41    if (err.errorCode === 'INVALID_FIELD') {
42      return res.status(400).json({ error: 'Field name not found. Run GET /api/describe/pb__Listing__c to see available fields.', detail: err.message });
43    }
44    res.status(500).json({ error: err.message });
45  }
46});
47
48// Get contacts/leads from Salesforce (standard objects)
49app.get('/api/contacts', async (req, res) => {
50  try {
51    await ensureConnected();
52    const result = await conn.query(
53      `SELECT Id, FirstName, LastName, Email, Phone, LeadSource, CreatedDate
54       FROM Contact 
55       ORDER BY CreatedDate DESC 
56       LIMIT 100`
57    );
58    res.json({ contacts: result.records, total: result.totalSize });
59  } catch (err) {
60    res.status(500).json({ error: err.message });
61  }
62});
63
64// Describe a Salesforce object to find field names
65app.get('/api/describe/:objectName', async (req, res) => {
66  try {
67    await ensureConnected();
68    const metadata = await conn.sobject(req.params.objectName).describe();
69    const fields = metadata.fields.map(f => ({ name: f.name, label: f.label, type: f.type }));
70    res.json({ object: req.params.objectName, fields });
71  } catch (err) {
72    res.status(500).json({ error: err.message });
73  }
74});
75
76app.listen(3000, '0.0.0.0', () => console.log('Propertybase/Salesforce server running on port 3000'));

1# propertybase_api.py — Propertybase/Salesforce with simple-salesforce for Python on Replit
2import os
3from simple_salesforce import Salesforce
4from flask import Flask, request, jsonify
5
6app = Flask(__name__)
7
8# Connect to Salesforce / Propertybase
9# simple-salesforce appends security_token to password automatically
10sf = Salesforce(
11    username=os.environ['SF_USERNAME'],
12    password=os.environ['SF_PASSWORD'],
13    security_token='',  # Set SF_SECURITY_TOKEN secret and use os.environ['SF_SECURITY_TOKEN']
14    domain='login' if os.environ.get('SF_LOGIN_URL', '').find('test') == -1 else 'test'
15)
16
17@app.route('/api/listings')
18def get_listings():
19    status = request.args.get('status', 'Active')
20    limit = min(int(request.args.get('limit', 50)), 200)
21    try:
22        result = sf.query(
23            f"SELECT Id, Name, pb__Property_Address__c, pb__List_Price__c, "
24            f"pb__Property_Type__c, pb__Status__c "
25            f"FROM pb__Listing__c "
26            f"WHERE pb__Status__c = '{status}' "
27            f"LIMIT {limit}"
28        )
29        return jsonify({'listings': result['records'], 'total': result['totalSize']})
30    except Exception as e:
31        return jsonify({'error': str(e)}), 500
32
33@app.route('/api/contacts')
34def get_contacts():
35    try:
36        result = sf.query(
37            "SELECT Id, FirstName, LastName, Email, Phone, LeadSource "
38            "FROM Contact ORDER BY CreatedDate DESC LIMIT 100"
39        )
40        return jsonify({'contacts': result['records'], 'total': result['totalSize']})
41    except Exception as e:
42        return jsonify({'error': str(e)}), 500
43
44@app.route('/api/describe/<object_name>')
45def describe_object(object_name):
46    try:
47        metadata = getattr(sf, object_name).describe()
48        fields = [{'name': f['name'], 'label': f['label'], 'type': f['type']}
49                  for f in metadata['fields']]
50        return jsonify({'object': object_name, 'fieldCount': len(fields), 'fields': fields})
51    except Exception as e:
52        return jsonify({'error': str(e)}), 500
53
54if __name__ == '__main__':
55    app.run(host='0.0.0.0', port=3000)