Function serializeDrain

apps/sim/lib/data-drains/serializers.ts:17–37

(row: DataDrainRow)

 * surface as errors instead of leaking through the response.
 */
export function serializeDrain(row: DataDrainRow): DataDrain {
  const destinationConfig = getDestination(row.destinationType).configSchema.parse(
    row.destinationConfig
  )
  return dataDrainSchema.parse({
    id: row.id,
    organizationId: row.organizationId,
    name: row.name,
    source: row.source,
    scheduleCadence: row.scheduleCadence,
    enabled: row.enabled,
    cursor: row.cursor,
    lastRunAt: row.lastRunAt ? row.lastRunAt.toISOString() : null,
    lastSuccessAt: row.lastSuccessAt ? row.lastSuccessAt.toISOString() : null,
    createdBy: row.createdBy,
    createdAt: row.createdAt.toISOString(),
    updatedAt: row.updatedAt.toISOString(),
    destinationType: row.destinationType,
    destinationConfig,
  })
}

export function serializeDrainRun(row: DataDrainRunRow): DataDrainRun {
  return {