Function items

xml/parse_records_test.ts:13–49

(
  xml: string | string[],
)

}

function items(
  xml: string | string[],
): AsyncGenerator<Record<string, string>> {
  const chunks = Array.isArray(xml) ? xml : [xml];
  return parseXmlRecords<Record<string, string>>(
    ReadableStream.from(chunks),
    (emit) => {
      let insideItem = false;
      let currentTag = "";
      let currentItem: Record<string, string> = {};
      return {
        onStartElement(name) {
          if (name === "item") {
            insideItem = true;
            currentItem = {};
          } else if (insideItem) {
            currentTag = name;
          }
        },
        onText(text) {
          if (insideItem && currentTag) {
            currentItem[currentTag] = (currentItem[currentTag] ?? "") + text;
          }
        },
        onEndElement(name) {
          if (name === "item") {
            emit(currentItem);
            insideItem = false;
            currentItem = {};
          }
          currentTag = "";
        },
      };
    },
    { ignoreWhitespace: true },
  );
}

// =============================================================================
// Basic record emission