Edit: /tmp/tsx-0/17887-dac1101a7e02195558dc0f5da219dc7aa6ca2a99 (5007B)
{"code":"__filename=\"/opt/canhelp/node_modules/better-auth/node_modules/@better-auth/core/dist/context/transaction.mjs\";(()=>{\nvar __defProp=Object.defineProperty;var __getOwnPropDesc=Object.getOwnPropertyDescriptor;var __getOwnPropNames=Object.getOwnPropertyNames;var __hasOwnProp=Object.prototype.hasOwnProperty;var __name=(target,value)=>__defProp(target,\"name\",{value,configurable:true});var __export=(target,all)=>{for(var name in all)__defProp(target,name,{get:all[name],enumerable:true})};var __copyProps=(to,from,except,desc)=>{if(from&&typeof from===\"object\"||typeof from===\"function\"){for(let key of __getOwnPropNames(from))if(!__hasOwnProp.call(to,key)&&key!==except)__defProp(to,key,{get:()=>from[key],enumerable:!(desc=__getOwnPropDesc(from,key))||desc.enumerable})}return to};var __toCommonJS=mod=>__copyProps(__defProp({},\"__esModule\",{value:true}),mod);var transaction_exports={};__export(transaction_exports,{getCurrentAdapter:()=>getCurrentAdapter,getCurrentDBAdapterAsyncLocalStorage:()=>getCurrentDBAdapterAsyncLocalStorage,queueAfterTransactionHook:()=>queueAfterTransactionHook,runWithAdapter:()=>runWithAdapter,runWithTransaction:()=>runWithTransaction});module.exports=__toCommonJS(transaction_exports);var import_global=require(\"./global.mjs\");var import_async_hooks=require(\"@better-auth/core/async_hooks\");const ensureAsyncStorage=__name(async()=>{const betterAuthGlobal=(0,import_global.__getBetterAuthGlobal)();if(!betterAuthGlobal.context.adapterAsyncStorage){const AsyncLocalStorage=await(0,import_async_hooks.getAsyncLocalStorage)();betterAuthGlobal.context.adapterAsyncStorage=new AsyncLocalStorage}return betterAuthGlobal.context.adapterAsyncStorage},\"ensureAsyncStorage\");const getCurrentDBAdapterAsyncLocalStorage=__name(async()=>{return ensureAsyncStorage()},\"getCurrentDBAdapterAsyncLocalStorage\");const getCurrentAdapter=__name(async fallback=>{return ensureAsyncStorage().then(als=>{return als.getStore()?.adapter||fallback}).catch(()=>{return fallback})},\"getCurrentAdapter\");const runWithAdapter=__name(async(adapter,fn)=>{let called=false;return ensureAsyncStorage().then(async als=>{called=true;const pendingHooks=[];let result;let error;let hasError=false;try{result=await als.run({adapter,pendingHooks},fn)}catch(err){error=err;hasError=true}for(const hook of pendingHooks)await hook();if(hasError)throw error;return result}).catch(err=>{if(!called)return fn();throw err})},\"runWithAdapter\");const runWithTransaction=__name(async(adapter,fn)=>{let called=true;return ensureAsyncStorage().then(async als=>{called=true;const pendingHooks=[];let result;let error;let hasError=false;try{result=await adapter.transaction(async trx=>{return als.run({adapter:trx,pendingHooks},fn)})}catch(e){hasError=true;error=e}for(const hook of pendingHooks)await hook();if(hasError)throw error;return result}).catch(err=>{if(!called)return fn();throw err})},\"runWithTransaction\");const queueAfterTransactionHook=__name(async hook=>{return ensureAsyncStorage().then(als=>{const store=als.getStore();if(store)store.pendingHooks.push(hook);else return hook()}).catch(()=>{return hook()})},\"queueAfterTransactionHook\");0&&(module.exports={getCurrentAdapter,getCurrentDBAdapterAsyncLocalStorage,queueAfterTransactionHook,runWithAdapter,runWithTransaction});\n})()\n","warnings":[],"map":{"version":3,"mappings":";suBAAA,wXAAsC,wBACtC,uBAAqC,yCAGrC,MAAM,mBAAqB,gBAAY,CACtC,MAAM,oBAAmB,qCAAsB,EAC/C,GAAI,CAAC,iBAAiB,QAAQ,oBAAqB,CAClD,MAAM,kBAAoB,QAAM,yCAAqB,EACrD,iBAAiB,QAAQ,oBAAsB,IAAI,iBACpD,CACA,OAAO,iBAAiB,QAAQ,mBACjC,EAP2B,sBAa3B,MAAM,qCAAuC,gBAAY,CACxD,OAAO,mBAAmB,CAC3B,EAF6C,wCAG7C,MAAM,kBAAoB,aAAO,UAAa,CAC7C,OAAO,mBAAmB,EAAE,KAAM,KAAQ,CACzC,OAAO,IAAI,SAAS,GAAG,SAAW,QACnC,CAAC,EAAE,MAAM,IAAM,CACd,OAAO,QACR,CAAC,CACF,EAN0B,qBAO1B,MAAM,eAAiB,aAAO,QAAS,KAAO,CAC7C,IAAI,OAAS,MACb,OAAO,mBAAmB,EAAE,KAAK,MAAO,KAAQ,CAC/C,OAAS,KACT,MAAM,aAAe,CAAC,EACtB,IAAI,OACJ,IAAI,MACJ,IAAI,SAAW,MACf,GAAI,CACH,OAAS,MAAM,IAAI,IAAI,CACtB,QACA,YACD,EAAG,EAAE,CACN,OAAS,IAAK,CACb,MAAQ,IACR,SAAW,IACZ,CACA,UAAW,QAAQ,aAAc,MAAM,KAAK,EAC5C,GAAI,SAAU,MAAM,MACpB,OAAO,MACR,CAAC,EAAE,MAAO,KAAQ,CACjB,GAAI,CAAC,OAAQ,OAAO,GAAG,EACvB,MAAM,GACP,CAAC,CACF,EAxBuB,kBAyBvB,MAAM,mBAAqB,aAAO,QAAS,KAAO,CACjD,IAAI,OAAS,KACb,OAAO,mBAAmB,EAAE,KAAK,MAAO,KAAQ,CAC/C,OAAS,KACT,MAAM,aAAe,CAAC,EACtB,IAAI,OACJ,IAAI,MACJ,IAAI,SAAW,MACf,GAAI,CACH,OAAS,MAAM,QAAQ,YAAY,MAAO,KAAQ,CACjD,OAAO,IAAI,IAAI,CACd,QAAS,IACT,YACD,EAAG,EAAE,CACN,CAAC,CACF,OAAS,EAAG,CACX,SAAW,KACX,MAAQ,CACT,CACA,UAAW,QAAQ,aAAc,MAAM,KAAK,EAC5C,GAAI,SAAU,MAAM,MACpB,OAAO,MACR,CAAC,EAAE,MAAO,KAAQ,CACjB,GAAI,CAAC,OAAQ,OAAO,GAAG,EACvB,MAAM,GACP,CAAC,CACF,EA1B2B,sBA+B3B,MAAM,0BAA4B,aAAO,MAAS,CACjD,OAAO,mBAAmB,EAAE,KAAM,KAAQ,CACzC,MAAM,MAAQ,IAAI,SAAS,EAC3B,GAAI,MAAO,MAAM,aAAa,KAAK,IAAI,MAClC,QAAO,KAAK,CAClB,CAAC,EAAE,MAAM,IAAM,CACd,OAAO,KAAK,CACb,CAAC,CACF,EARkC","names":[],"ignoreList":[],"sources":["/opt/canhelp/node_modules/better-auth/node_modules/@better-auth/core/dist/context/transaction.mjs"],"sourcesContent":[null]}}