supascript--1.4.sql

--complain if script is sourced in psql, rather than via CREATE EXTENSION
\echo Use "CREATE EXTENSION supascript CASCADE" to load this file. \quit

/* the alter database line below needs to be run ONCE on your database */
SET PLV8.START_PROC = 'supascript_init';
ALTER DATABASE POSTGRES SET PLV8.START_PROC TO 'supascript_init';

CREATE TABLE IF NOT EXISTS supascript_log
(
    id uuid primary key default uuid_generate_v4(),
    created timestamp with time zone DEFAULT CURRENT_TIMESTAMP,
    _catalog text DEFAULT CURRENT_CATALOG,
    _user text DEFAULT CURRENT_USER,
    _schema text DEFAULT CURRENT_SCHEMA,
    _schemas name[] DEFAULT CURRENT_SCHEMAS(true),
    _pid int DEFAULT PG_BACKEND_PID(),
    log_type text,
    query text,
    content jsonb
);

CREATE TABLE IF NOT EXISTS SUPASCRIPT_JS_MODULES (MODULE text UNIQUE PRIMARY KEY,
AUTOLOAD BOOL DEFAULT FALSE,
SOURCE text);

CREATE OR REPLACE FUNCTION supascript_init() RETURNS VOID 
AS $$

    this.moduleCache = {};
    
    // this handles "TypeError: Do not know how to serialize a BigInt"
    function toJson(data) {
        if (data !== undefined) {
            return JSON.stringify(data, (_, v) => typeof v === 'bigint' ? `${v}#bigint` : v)
                .replace(/"(-?\d+)#bigint"/g, (_, a) => a);
        }
    }

    this.console = {
        timers:{},
        write_to_log: function() {
            const arr = [];
            for (let i=0; i < arguments.length; i++) {
                if (!(i === 1 && arguments[0] === 'ASSERT')) {                    
                    const arg = JSON.parse(toJson(arguments[i])); // required to handle bigint
                    arr.push(arg);
                }
            }
            let query = '';
            try {
                query = JSON.stringify(sql('select current_query()')[0].current_query);
                if (query.length > 23 && query.substr(0,23).toLowerCase() === '"with pgrst_source as (') {
                    query = query.substr(23);
                    let index = query.indexOf('AS pgrst_scalar');
                    if (index < 0) { index = 999; };
                    query = query.substr(0,index);
                    query = query.replace(new RegExp(String.fromCharCode(92, 92, 34), 'g'), String.fromCharCode(34));
                }
            } catch (queryParseError) {
                query = 'query parse error';
            }
            const log_type = arr.shift();
            sql(`insert into supascript_log (content, log_type, query) values ($1, $2, $3)`,[arr, log_type, query]);
        },
        log: function() {
            console.write_to_log('LOG', ...arguments);
        },
        info: function() {
            console.write_to_log('INFO', ...arguments);
        },
        warn: function() {
            console.write_to_log('WARN', ...arguments);
        },
        assert: function() {
            if (arguments[0] === false) {
                // arguments.shift(); // remove assert expression
                console.write_to_log('ASSERT', ...arguments); // log rest of arguments (1 to n)
            }
        },
        error: function() {
            console.write_to_log('ERROR', ...arguments);
        },
        time: function(label = 'DEFAULT_TIMER') {
            this.timers[label] = +new Date();
        },
        timeEnd: function(label = 'DEFAULT_TIMER') {
            console.write_to_log('TIMER',label,+new Date() - this.timers[label]);
            delete this.timers[label];
        }

    };
    

    // execute a Postgresql function
    // i.e. exec('my_function',['parm1', 123, {"item_name": "test json object"}])
    this.exec = function(function_name, parms) {
      var func = plv8.find_function(function_name);
      return func(...parms);
    }

    this.load = function(key, source) {
        var module = {exports: {}};
        try {
            eval("(function(module, exports) {" + source + "; })")(module, module.exports);
        } catch (err) {
            plv8.elog(ERROR, `eval error in source: ${err} (SOURCE): ${source}`);
        }

        // store in cache
        moduleCache[key] = module.exports;
        return module.exports;
    };

    // execute a sql statement against the Postgresql database with optional args
    // i.e. sql('select * from people where first_name = $1 and last_name = $2', ['John', 'Smith'])
    this.sql = function(sql_statement, args) {
      if (args) {
        return plv8.execute(sql_statement, args);
      } else {
        return plv8.execute(sql_statement);
      }
    };

    // emulate node.js "require", with automatic download from the internet via CDN sites
    // optional autoload (boolean) parameter allows the module to be preloaded later
    // i.e. var myModule = require('https://some.cdn.com/module_content.js', true)
    this.require = function(module, autoload) {
        if (module === 'http' || module === 'https') {
          // emulate NodeJS require('http')
          module = 'https://raw.githubusercontent.com/burggraf/SupaScript/main/modules/http.js';
        }
        if(moduleCache[module])
            return moduleCache[module];
        var rows = plv8.execute(
            'select source from supascript_js_modules where module = $1',
            [module]
        );

        if (rows.length === 0 && module.substr(0,4) === 'http') {
            try {
                source = plv8.execute(`SELECT content FROM http_get('${module}');`)[0].content;
            } catch (err) {
                plv8.elog(ERROR, `Could not load module through http: ${module}`, JSON.stringify(err));
            }
            try {
                /* the line below is written purely for esthetic reasons, so as not to mess up the online source editor */
                /* when using standard regExp expressions, the single-quote char messes up the code highlighting */
                /* in the editor and everything looks funky */
                const quotedSource = source.replace(new RegExp(String.fromCharCode(39), 'g'), String.fromCharCode(39, 39));

                plv8.execute(`insert into supascript_js_modules (module, autoload, source) values ('${module}', ${autoload ? true : false}, '${quotedSource}')`);
            } catch (err) {
                plv8.elog(ERROR, `Error inserting module into supascript_js_modules: ${err} ${module}, ${autoload ? true : false}, '${plv8.quote_literal(source)}'`);
            }
            return load(module, source);
        } else if(rows.length === 0) {
            plv8.elog(NOTICE, `Could not load module: ${module}`);
            return null;
        } else {
            return load(module, rows[0].source);
        }

    };

    // Grab modules worth auto-loading at context start and let them cache
    var query = `select module, source from supascript_js_modules where autoload = true`;
    plv8.execute(query).forEach(function(row) {
        this.load(row.module, row.source);
    });
$$ LANGUAGE PLV8;
ALTER PUBLICATION supabase_realtime ADD TABLE supascript_log;