Lines 1-29javascript
1"use strict";var S=Object.defineProperty;var k=Object.getOwnPropertyDescriptor;var _=Object.getOwnPropertyNames;var L=Object.prototype.hasOwnProperty;var I=(o,t)=>{for(var e in t)S(o,e,{get:t[e],enumerable:!0})},N=(o,t,e,s)=>{if(t&&typeof t=="object"||typeof t=="function")for(let l of _(t))!L.call(o,l)&&l!==e&&S(o,l,{get:()=>t[l],enumerable:!(s=k(t,l))||s.enumerable});return o};var R=o=>N(S({},"__esModule",{value:!0}),o);var $={};I($,{postgres:()=>O});module.exports=R($);var y=require("pg"),c=require("awaitly/durable");var g=require("crypto");function E(o,t,e){let s,l=async()=>{let n=await o.c ...
LowAi Review Evidence
The runtime imports PostgreSQL and awaitly persistence helpers; its visible operations store, retrieve, list, and delete workflow snapshots through parameterized database queries.
dist/index.cjsView on unpkg · L1 2 CREATE TABLE IF NOT EXISTS ${e} (
HighCopied Package Dependency Bridge
Package metadata claims a different repository identity while copied source loads a runtime dependency bridge.
dist/index.cjsView on unpkg · L1 3 workflow_id TEXT PRIMARY KEY,
4 owner_token TEXT NOT NULL,
5 expires_at TIMESTAMPTZ NOT NULL
7 CREATE INDEX IF NOT EXISTS ${s} ON ${e}(expires_at);
8 `);async function n(d,a){let w=a?.ttlMs??6e4,r=(0,g.randomUUID)(),i=new Date(Date.now()+w);await l();let p=await o.query(`
9 INSERT INTO ${e} (workflow_id, owner_token, expires_at)
11 ON CONFLICT (workflow_id) DO UPDATE SET
12 owner_token = EXCLUDED.owner_token,
13 expires_at = EXCLUDED.expires_at
14 WHERE ${e}.expires_at < NOW()
16 `,[d,r,i]);return p.rowCount===1&&p.rows[0].owner_token===r?{ownerToken:r}:null}async function u(d,a){await o.query(`DELETE FROM ${e} WHERE workflow_id = $1 AND owner_token = $2`,[d,a])}async function T(d,a,w){let r=w?.ttlMs??6e4,i=new Date(Date.now()+r);return((await o.query(`UPDATE ${e} SET expires_at = $1 WHERE workflow_id = $2 AND owner_token = $3`,[i,d,a])).rowCount??0)>0}return{tryAcquire:n,release:u,renew:T,ensureLockTable:l}}var A=/^[a-zA-Z_][a-zA-Z0-9_]*$/;function O(o){let t=typeof o=="string"?{url:o}:o,e=t.table??"awaitly_snapshots";if(!A.test(e))throw new Error(`
17 CREATE TABLE IF NOT EXISTS ${e} (
19 snapshot JSONB NOT NULL,
20 updated_at TIMESTAMPTZ DEFAULT NOW()
22 CREATE INDEX IF NOT EXISTS ${e}_updated_at_idx ON ${e} (updated_at DESC);
23 `),d=()=>l?T():Promise.resolve(),a=t.lock?P(u,t.lock):null,w={async save(r,i){await d();let p=s+r,m=(0,c.isResumeState)(i)?(0,c.serializeResumeState)(i):i;await u.query(`INSERT INTO ${e} (id, snapshot, updated_at)
24 VALUES ($1, $2, NOW())
25 ON CONFLICT (id) DO UPDATE SET snapshot = $2, updated_at = NOW()`,[p,JSON.stringify(m)])},async load(r){await d();let i=s+r,p=await u.query(`SELECT snapshot FROM ${e} WHERE id = $1`,[i]);if(p.rows.length===0)return null;let m=p.rows[0].snapshot;return(0,c.isSerializedResumeState)(m)?(0,c.deserializeResumeState)(m):((0,c.isWorkflowSnapshot)(m),m)},async loadResumeState(r){let i=await w.load(r);return i===null?null:(0,c.isResumeState)(i)?i:null},async delete(r){await d();let i=s+r;await u.query(`DELETE FROM
27 ORDER BY updated_at DESC
28 LIMIT $2`,[i+"%",p])).rows.map(f=>({id:f.id.slice(s.length),updatedAt:f.updated_at.toISOString()}))},async close(){n&&await u.end()}};return a&&(w.tryAcquire=a.tryAcquire.bind(a),w.release=a.release.bind(a),w.renew=
29//# sourceMappingURL=index.cjs.map
LowAi Review Evidence
The pool is created from the caller-provided URL or supplied pool, and the adapter only closes a pool it created itself.
dist/index.cjsView on unpkg · L28 Long lines were clipped for display.