The integration that keeps two systems honest

import { app, Datastore } from 'codehooks-js';

// Routes require a key by default, so let the partner system post here
app.auth('/webhook/*', (req, res, next) => next());

// A change arrives from system A
app.post('/webhook/orders', async (req, res) => {
  // Verify the signature first. Our webhook-verify package covers 21
  // providers, and has generic handlers for anything in-house:
  // verify('shopify', req.rawBody, req.headers, process.env.SECRET)

  const db = await Datastore.open();
  await db.insertOne('orders', { ...req.body, synced: false });
  await db.enqueue('sync-erp', { id: req.body.id });
  res.status(202).end();
});

// Runs in the background, so a slow partner never blocks the response
app.worker('sync-erp', async (req, res) => {
  const db = await Datastore.open();
  const { id } = req.body.payload;

  try {
    await pushToErp(id);
    await db.updateOne('orders', { id }, { synced: true });
  } catch (err) {
    // Leave it unsynced. The nightly job below re-queues it.
    await db.updateOne('orders', { id }, { lastError: String(err) });
  }
  res.end();
});

// Every night at 03:00, prove both sides still agree
app.job('0 3 * * *', async (req, res) => {
  const db = await Datastore.open();

  // One queued job per record that never synced
  const { ticket } = await db.enqueueFromQuery('orders', {
    synced: false
  }, 'sync-erp');

  console.log(`re-queued ${ticket.count} orders`);
  res.end();
});

export default app.init();