index.ts

Filename	Percent	Threshold	Total	Covered	Uncovered
src/results/parsers/msg/index.ts	100.00%	80%	104	104	0

import {
  prettifyMessageTypeCodes,
  prettifyTransmissionSourceTypeCodes,
} from 'utils/prettifyCodes.js';

import type { Document } from './types.js';
import { MSG } from 'constants/docTypes.js';
import type { NewDocumentSequence } from 'db/schema/documentSequence.js';
import type { NewMessage } from 'db/schema/message.js';
import { parseKey } from 'utils/documentKey.js';
import { uniqBy } from 'lodash-es';

/**
 * Parses documents we get from querying the `results/msg` endpoint. It then transforms the data to fit the structure of the Message model and returns an array of objects that can be upserted into the model.
 */
const parseMessages = (documents: Document[]) => {
  const instances: NewMessage[] = [];
  for (const doc of documents) {
    const {
      content,
      eType,
      jCde,
      jType,
      mLvl: securityLevel,
      mPrio: priority,
      mType,
      transSrc,
      ts,
    } = doc;
    const { st } = doc.key;

    const { state, jurisdiction, jurisdictionRace } = parseKey({
      ...doc.key,
      eType,
      jType,
      jCde,
    });

    const instance: NewMessage = {
      uid: `${st}_${ts}`,
      state,
      jurisdiction,
      jurisdictionRace,
      content,
      type: prettifyMessageTypeCodes(mType),
      priority, // 0 is highest priority
      securityLevel,
      transmissionSource: prettifyTransmissionSourceTypeCodes(transSrc),
      timestamp: new Date(ts),
    };
    instances.push(instance);
  }
  return instances;
};

const parseSequenceId = (doc: Document) => `${doc.key.st}`;

/**
 * Parses documents we get from querying the `results/msg` endpoint. It then transforms the data to fit the structure of the DocumentSequence model and returns an array of objects that can be upserted into the model.
 */
const parseDocumentSequences = (documents: Document[]) => {
  const sequences: NewDocumentSequence[] = [];
  for (const message of documents) {
    const { seq: sequence } = message;
    const uid = parseSequenceId(message);

    const documentSequence = {
      uid,
      docType: MSG,
      sequence,
    };

    sequences.push(documentSequence);
  }

  /**
   * Message docs aren't exactly like most other docs. Message doc keys don't guarantee uniqueness.
   * This can cause duplicates with big sweeps, so we reduce by largest sequence number.
   */
  const latestSequences = uniqBy(
    sequences.sort((a, b) => b.sequence - a.sequence),
    'uid'
  );

  return latestSequences;
};

export default {
  parseMessages,
  parseSequenceId,
  parseDocumentSequences,
};

[]

TypeScript Coverage Report generated by type-coverage and typescript-coverage-report at Thu, 04 Apr 2024 19:50:44 GMT

TypeScript coverage report