Search That Sells Real Estate

// Your own sync script (e.g. a nightly cron job), server-side only
const listings = await fetchListingsFromMls(); // your MLS/RETS client

const response = await fetch(
  'https://app.searchjetengine.com/api/v1/index/bulk',
  {
    method: 'POST',
    headers: {
      // Private key: keep it in an env var, never in browser code
      'Authorization': 'Bearer ' + process.env.SEARCHJET_PRIVATE_KEY,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      documents: listings.map(listing => ({
        id: String(listing.ListingKey),
        title: listing.StreetAddress,
        content: listing.PublicRemarks,
        url: 'https://example.com/listings/' + listing.ListingKey,
        type: 'listing',
        // Custom fields are stored with the document
        price: listing.ListPrice,
        beds: listing.BedroomsTotal,
        baths: listing.BathroomsTotalInteger,
        sqft: listing.LivingArea,
        propertyType: listing.PropertyType,
        status: listing.Status
      }))
    })
  }
);
const { taskUid } = await response.json();

// Batch index listings (server-side)
const response = await fetch(
  'https://app.searchjetengine.com/api/v1/index/bulk',
  {
    method: 'POST',
    headers: {
      'Authorization': 'Bearer ' + process.env.SEARCHJET_PRIVATE_KEY,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      documents: listings, // [{ id, title, content, url, ... }]; an existing id is replaced
    })
  }
);
const { taskUid } = await response.json();

// Your own webhook endpoint (Express)
app.post('/webhooks/listings', async (req, res) => {
  const { event, listing } = req.body;

  if (event === 'listing.created' || event === 'listing.updated') {
    await fetch('https://app.searchjetengine.com/api/v1/index/bulk', {
      method: 'POST',
      headers: {
        'Authorization': 'Bearer ' + process.env.SEARCHJET_PRIVATE_KEY,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        documents: [{
          id: String(listing.id),
          title: listing.address,
          content: listing.description,
          url: listing.url,
          price: listing.price,
          status: listing.status
          // ... other fields
        }]
      })
    });
  }

  res.sendStatus(200);
});