Function solve

solver/index.js:69–158

(challenge, config = {})

const workerUrl = URL.createObjectURL(workerBlob);

export default function solve(challenge, config = {}) {
  let challenges = challenge;

  if (!Array.isArray(challenges)) {
    let i = 0;

    challenges = Array.from({ length: config.c }, () => {
      i = i + 1;

      return [
        prng(`${challenges}${i}`, config.s),
        prng(`${challenges}${i}d`, config.d),
      ];
    });
  }

  const totalChallenges = challenges.length;
  const numWorkers =
    config?.workerCount || Math.min(totalChallenges, os.cpus().length);

  let challengesProcessed = 0;
  let nextChallengeIndex = 0;
  let activeWorkers = 0;
  const results = new Array(totalChallenges);

  if (totalChallenges === 0) {
    resolve([]);
  }

  return new Promise((resolve, reject) => {
    function startWorker() {
      if (nextChallengeIndex < totalChallenges && activeWorkers < numWorkers) {
        const currentChallengeIndex = nextChallengeIndex;
        const [salt, target] = challenges[currentChallengeIndex];
        nextChallengeIndex++;
        activeWorkers++;

        const worker = new Worker(workerUrl, {
          workerData: { salt, target, challengeIndex: currentChallengeIndex },
        });

        worker.on("message", (result) => {
          worker.terminate();
          activeWorkers--;

          if (result.error) {
            console.error(
              `Error in worker for challenge ${currentChallengeIndex}:`,
              result.error,
            );
            reject(new Error(`Worker error: ${result.error}`));
            return;
          }

          results[result.challengeIndex] = result.nonce;
          challengesProcessed++;

          if (config?.onProgress) {