Function parseMessageSQLResult

keyserver/src/fetchers/message-fetchers.js:160–195

(
  rows: $ReadOnlyArray<MessageSQLResultRow>,
  derivedMessages: $ReadOnlyMap<
    string,
    RawComposableMessageInfo | RawRobotextMessageInfo,
  >,
  viewer?: Viewer,
)

  +rows: $ReadOnlyArray<MessageSQLResultRow>,
}>;
function parseMessageSQLResult(
  rows: $ReadOnlyArray<MessageSQLResultRow>,
  derivedMessages: $ReadOnlyMap<
    string,
    RawComposableMessageInfo | RawRobotextMessageInfo,
  >,
  viewer?: Viewer,
): MessageSQLResult {
  const rowsByID = new Map<string, Array<MessageSQLResultRow>>();
  for (const row of rows) {
    if (!row.id) {
      continue;
    }
    const id = row.id.toString();
    const currentRowsForID = rowsByID.get(id);
    if (currentRowsForID) {
      currentRowsForID.push(row);
    } else {
      rowsByID.set(id, [row]);
    }
  }

  const messages = [];
  for (const messageRows of rowsByID.values()) {
    const rawMessageInfo = rawMessageInfoFromRows(
      messageRows,
      viewer,
      derivedMessages,
    );
    if (rawMessageInfo) {
      messages.push({ rawMessageInfo, rows: messageRows });
    }
  }

  return messages;
}

function assertSingleRow(rows: $ReadOnlyArray<Object>): Object {
  if (rows.length === 0) {