Function createSchemaTriggerFunction

packages/node-core/src/db/sync-helper.ts:289–300

(schema: string)

}

export function createSchemaTriggerFunction(schema: string): string {
  return `
  CREATE OR REPLACE FUNCTION "${schema}".schema_notification()
    RETURNS trigger AS $$
  BEGIN
    PERFORM pg_notify(
            '${hashName(schema, 'schema_channel', '_metadata')}',
            'schema_updated');
    RETURN NULL;
  END;
  $$ LANGUAGE plpgsql;`;
}

export function createRewindTrigger(schema: string): string {
  const triggerName = hashName(schema, 'rewind_trigger', '_global');