Function createFunction

src/persisters/common/database/postgresql.ts:81–97

(
    name: string,
    body: string,
    returnPrefix = '',
    declarations = '',
  )

  const channel = TINYBASE + '_' + configHash;

  const createFunction = async (
    name: string,
    body: string,
    returnPrefix = '',
    declarations = '',
  ): Promise<string> => {
    const escapedFunctionName = escapeIds(TINYBASE, name, configHash);
    await executeCommand(
      CREATE +
        OR_REPLACE +
        FUNCTION +
        escapedFunctionName +
        `()RETURNS ${returnPrefix}trigger ` +
        `AS $$ ${declarations}BEGIN ${body}END;$$ LANGUAGE plpgsql;`,
    );
    return escapedFunctionName;
  };

  const createTrigger = async (
    prefix: string,