Function serializeForSQLite

packages/powersync-db-collection/src/serialization.ts:40–102

(
  value: TOutput,
  tableSchema: TTable,
  customSerializer: Partial<
    CustomSQLiteSerializer<TOutput, ExtractedTableColumns<TTable>>
  > = {},
)

 * - Throws if a value cannot be converted to the required SQLite type.
 */
export function serializeForSQLite<
  TOutput extends Record<string, unknown>,
  // The keys should match
  TTable extends Table<MapBaseColumnType<TOutput>> = Table<
    MapBaseColumnType<TOutput>
  >,
>(
  value: TOutput,
  tableSchema: TTable,
  customSerializer: Partial<
    CustomSQLiteSerializer<TOutput, ExtractedTableColumns<TTable>>
  > = {},
): ExtractedTable<TTable> {
  return Object.fromEntries(
    // eslint-disable-next-line no-shadow
    Object.entries(value).map(([key, value]) => {
      // First get the output schema type
      const outputType =
        key == `id`
          ? ColumnType.TEXT
          : tableSchema.columns.find((column) => column.name == key)?.type
      if (!outputType) {
        throw new Error(`Could not find schema for ${key} column.`)
      }

      if (value == null) {
        return [key, value]
      }

      const customTransform = customSerializer[key]
      if (customTransform) {
        return [key, customTransform(value as TOutput[string])]
      }

      // Map to the output
      switch (outputType) {
        case ColumnType.TEXT:
          if (typeof value == `string`) {
            return [key, value]
          } else if (value instanceof Date) {
            return [key, value.toISOString()]
          } else {
            return [key, JSON.stringify(value)]
          }
        case ColumnType.INTEGER:
        case ColumnType.REAL:
          if (typeof value == `number`) {
            return [key, value]
          } else if (typeof value == `boolean`) {
            return [key, value ? 1 : 0]
          } else {
            const numberValue = Number(value)
            if (isNaN(numberValue)) {
              throw new Error(
                `Could not convert ${key}=${value} to a number for SQLite`,
              )
            }
            return [key, numberValue]