procmgr.mjs

import { v4 as uuidv4 } from 'uuid';

export default function({ db, originator, config }) {
  let process_uuid = uuidv4();
  console.log("Process UUID:", process_uuid);

  const register = async function() {
    let registered = false;
    while (!registered) {
      let [ result, _ ] = await Promise.all([
        db.register_process({ originator, process_uuid }),
        new Promise(_ => setTimeout(_, config.pollingDelay))
      ]);
      if (!result) {
        console.log(`Process lock detected on originator ${originator}; will retry...`);
      } else {
        console.log(`Process lock acquired for originator ${originator}`);
        registered = true;
      }
    }
  };

  const unregister = function() {
    return db.unregister_process({ originator, process_uuid });
  };

  return {
    register,
    unregister
  };
}