Function isTxCommittedPayload

packages/db-sqlite-persistence-core/src/persisted.ts:727–754

(payload: unknown)

}

function isTxCommittedPayload(payload: unknown): payload is TxCommitted {
  if (!isRecord(payload) || payload.type !== `tx:committed`) {
    return false
  }

  if (
    typeof payload.term !== `number` ||
    typeof payload.seq !== `number` ||
    typeof payload.txId !== `string` ||
    typeof payload.latestRowVersion !== `number` ||
    typeof payload.requiresFullReload !== `boolean`
  ) {
    return false
  }

  if (payload.requiresFullReload) {
    return true
  }

  return (
    Array.isArray(payload.changedRows) &&
    Array.isArray(payload.deletedKeys) &&
    (payload.rowMetadataMutations === undefined ||
      Array.isArray(payload.rowMetadataMutations)) &&
    (payload.collectionMetadataMutations === undefined ||
      Array.isArray(payload.collectionMetadataMutations))
  )
}

function isCollectionResetPayload(
  payload: unknown,