Work

export function computeIngredientDiff(
  oldIngredients: CommitIngredient[],
  newIngredients: CommitIngredient[]
): IngredientDiffEntry[] {
  const oldMap = new Map<number, IngredientSnapshot>()
  const newMap = new Map<number, IngredientSnapshot>()

  for (const ing of normalizeIngredients(oldIngredients)) {
    oldMap.set(ing.ingredientId, ing)
  }
  for (const ing of normalizeIngredients(newIngredients)) {
    newMap.set(ing.ingredientId, ing)
  }

  const result: IngredientDiffEntry[] = []

  for (const [id, oldIng] of oldMap) {
    const newIng = newMap.get(id)

    if (!newIng) {
      result.push({ type: 'removed', ingredientId: id, /* ... */ })
    } else {
      const changes: ('quantity' | 'unit')[] = []
      if (oldIng.quantity !== newIng.quantity) changes.push('quantity')
      if (oldIng.unit !== newIng.unit) changes.push('unit')
      // ... push 'modified' when changes.length > 0, else 'unchanged'
    }
  }
  // ... a second pass picks up ids present only in newMap
}

it('produces an identical command from the click path and the speech path', () => {
  const text = 'HANSA 471 TAXI TO RUNWAY 27 VIA ALPHA';
  const issuedAt = 1_700_000_000_000;

  const fromMouse = makeCommand({ raw: text, source: 'mouse', issuedAt });
  const fromSpeech = makeCommand({ raw: text, source: 'speech', issuedAt });

  const { source: _mouseSource, ...mouseRest } = fromMouse;
  const { source: _speechSource, ...speechRest } = fromSpeech;

  expect(speechRest).toEqual(mouseRest);
  expect(bus.dispatch(fromMouse)).toEqual(bus.dispatch(fromSpeech));
});

const atomicWrite = async (filePath: string, content: string): Promise<void> => {
  const tmpPath = `${filePath}.${randomUUID()}.tmp`;
  try {
    await fs.promises.writeFile(tmpPath, content, 'utf8');
    await fs.promises.rename(tmpPath, filePath);
  } catch (err) {
    await fs.promises.unlink(tmpPath).catch(() => {});
    throw err;
  }
};

if (!force && currentEntry?.etag) {
  headers['If-None-Match'] = currentEntry.etag;
}
if (!force && currentEntry?.lastModified) {
  headers['If-Modified-Since'] = currentEntry.lastModified;
}

const res = await fetch(`https://www.gesetze-im-internet.de/${slug}/xml.zip`, {
  method: 'HEAD',
  headers,
});

if (res.status === 304) {
  // Law has not changed since last check
  skippedUnchanged++;
  return;
}

if (res.status === 404) {
  // Obsolete or repealed law with no XML archive
  notFoundCount++;
  manifest[slug] = {
    ...currentEntry,
    status: 'not_found',
    lastSynced: new Date().toISOString(),
  };
  return;
}

if (res.status === 200) {
  const etag = res.headers.get('etag') || undefined;
  const lastModified = res.headers.get('last-modified') || undefined;
  toUpdate.push({ slug, etag, lastModified });
  return;
}
// ... the surrounding try/catch queues any other status, or a failed HEAD, for a full download