async function processDocuments()

in firestore-bigquery-export/scripts/import/src/worker.ts [11:70]
51 lines of code
2 McCabe index (conditional complexity)

async function processDocuments(
  serializableQuery: SerializableQuery,
  config: CliConfig
) {
  const {
    sourceCollectionPath,
    projectId,
    tableId,
    datasetId,
    datasetLocation,
  } = config;

  if (!firebase.apps.length) {
    // Initialize Firebase
    firebase.initializeApp({
      credential: firebase.credential.applicationDefault(),
      databaseURL: `https://${projectId}.firebaseio.com`,
    });
  }

  const query = firebase
    .firestore()
    .collectionGroup(sourceCollectionPath)
    .orderBy(firebase.firestore.FieldPath.documentId(), "asc") as QueryOptions;

  query._queryOptions.startAt = serializableQuery.startAt;
  query._queryOptions.endAt = serializableQuery.endAt;
  query._queryOptions.limit = serializableQuery.limit;
  query._queryOptions.offset = serializableQuery.offset;

  const { docs } = await query.get();

  console.log(
    `worker got ${docs.length} docs, starting at ${docs[0].id} and ending at ${
      docs[docs.length - 1].id
    }`
  );

  const dataSink = new FirestoreBigQueryEventHistoryTracker({
    tableId,
    datasetId,
    datasetLocation,
  });

  const rows: FirestoreDocumentChangeEvent = docs.map((document) => {
    return {
      timestamp: new Date(0).toISOString(),
      operation: ChangeType.IMPORT,
      documentName: `projects/${projectId}/databases/(default)/documents/${
        document.ref.path
      }`,
      documentId: document.id,
      eventId: "",
      data: document.data(),
    };
  });

  await dataSink.record(rows);
  return rows.length;
}