Method parse

apps/dotcom/sync-worker/src/TLPostgresReplicator.ts:54–70

(buffer: Buffer)

	// If fixups also fail, we deliberately let the error propagate — a crash loop is
	// preferable to silently skipping (and acknowledging) unprocessable changes.
	override parse(buffer: Buffer): any {
		const raw = buffer.toString()
		try {
			return JSON.parse(raw)
		} catch (e) {
			const fixed = raw
				.replace(/"change":\[,+/g, '"change":[') // leading commas: [,{ → [{
				.replace(/,+]/g, ']') // trailing commas: ,] → ]
				.replace(/,,+/g, ',') // consecutive commas: ,, → ,
			const result = JSON.parse(fixed)
			console.warn(
				`SafeWal2JsonPlugin: fixed malformed wal2json output (eulerto/wal2json#266). ` +
					`Original error: ${e}. Payload sample: ${raw.slice(0, 200)}`
			)
			return result
		}
	}
}

const ONE_MINUTE = 60 * 1000