-- pg_trickle v0.108.1 -> v0.108.2
-- V3 fixes bpchar identity canonicalization; V2 bytes remain immutable.

CREATE FUNCTION pgtrickle."encode_row_id_v3"(
    "domain" TEXT,
    "record" anyelement
) RETURNS bytea
STRICT STABLE PARALLEL SAFE
LANGUAGE c
AS 'MODULE_PATHNAME', 'encode_row_id_v3_wrapper';
GRANT EXECUTE ON FUNCTION pgtrickle.encode_row_id_v3(text, anyelement) TO PUBLIC;

UPDATE pgtrickle.pgt_stream_tables
   SET row_identity_version = NULL,
       row_probe_version = NULL,
       needs_reinit = TRUE,
       updated_at = now();

-- New writes use the V3 encoder, while all existing stream tables remain
-- blocked from differential maintenance until their protected FULL rebuild.
SELECT pgtrickle.rebuild_cdc_triggers();

-- Keep queued change rows intact. Only replace each synthetic CDC sentinel
-- and update the buffer metadata after the V3 encoder is installed.
DO $pgt$
DECLARE
    change_schema TEXT := COALESCE(
        NULLIF(current_setting('pg_trickle.change_buffer_schema', true), ''),
        'pgtrickle_changes'
    );
    buffer RECORD;
BEGIN
    FOR buffer IN
        SELECT buffer_key::text AS buffer_key, sentinel_token
        FROM pgtrickle.pgt_change_buffers
    LOOP
        EXECUTE format(
            'DELETE FROM %I.%I WHERE action = %L',
            change_schema, buffer.buffer_key, 'S'
        );
        EXECUTE format(
            'INSERT INTO %I.%I (lsn, action, __pgt_row_id) VALUES (%L::pg_lsn, %L, pgtrickle.encode_row_id_v3(''SYNTHETIC'', ROW(%L::bigint)))',
            change_schema, buffer.buffer_key, '0/0', 'S', buffer.sentinel_token
        );
    END LOOP;

    UPDATE pgtrickle.pgt_change_buffers
       SET row_identity_version = 3,
           row_probe_version = 1;
END
$pgt$;