diff --git a/src/lib/postgres.mjs b/src/lib/postgres.mjs index c5baa21..8b1917d 100644 --- a/src/lib/postgres.mjs +++ b/src/lib/postgres.mjs @@ -4514,7 +4514,7 @@ export async function refreshQuoteOutcomes(pool, { ORDER BY COALESCE(observed_at, ingested_at) ASC `, [quoteIds]), pool.query(` - SELECT event_id, observed_at, ingested_at, quote_id, payload + SELECT event_id, observed_at, ingested_at, quote_id, jsonb_build_object('spendable', payload->'spendable', 'synced_at', payload->'synced_at') AS payload FROM ( SELECT event_id, observed_at, ingested_at, quote_id, payload FROM intent_inventory_snapshots @@ -5333,13 +5333,13 @@ async function loadIntentInventorySnapshotsForRequestRefresh(pool, { return pool.query( ` WITH previous_snapshot AS ( - SELECT event_id, observed_at, ingested_at, quote_id, payload, COALESCE(observed_at, ingested_at) AS sort_at + SELECT event_id, observed_at, ingested_at, quote_id, jsonb_build_object('spendable', payload->'spendable', 'synced_at', payload->'synced_at') AS payload, COALESCE(observed_at, ingested_at) AS sort_at FROM intent_inventory_snapshots WHERE COALESCE(observed_at, ingested_at) < $1 ORDER BY COALESCE(observed_at, ingested_at) DESC LIMIT 1 ), following_snapshots AS ( - SELECT event_id, observed_at, ingested_at, quote_id, payload, COALESCE(observed_at, ingested_at) AS sort_at + SELECT event_id, observed_at, ingested_at, quote_id, jsonb_build_object('spendable', payload->'spendable', 'synced_at', payload->'synced_at') AS payload, COALESCE(observed_at, ingested_at) AS sort_at FROM intent_inventory_snapshots WHERE COALESCE(observed_at, ingested_at) >= $1 ORDER BY COALESCE(observed_at, ingested_at) ASC