Function createTolerantCodec

packages/utils/src/lib/wal.ts:67–86

(codec: {
  encode: (v: I) => O;
  decode: (d: O) => I;
})

};

export const createTolerantCodec = <I, O = string>(codec: {
  encode: (v: I) => O;
  decode: (d: O) => I;
}): Codec<I | InvalidEntry<O>, O> => {
  const { encode, decode } = codec;

  return {
    encode: v =>
      v && typeof v === 'object' && '__invalid' in v
        ? (v as InvalidEntry<O>).raw
        : encode(v as I),
    decode: d => {
      try {
        return decode(d);
      } catch {
        return { __invalid: true, raw: d };
      }
    },
  };
};

export function filterValidRecords<T>(
  records: (T | InvalidEntry<unknown>)[],