Edit: /tmp/tsx-0/17887-7a1366487c7e13b562b997704b03ef219c79ad74 (13089B)
{"code":"__filename=\"/opt/canhelp/node_modules/better-auth/dist/db/with-hooks.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 with_hooks_exports={};__export(with_hooks_exports,{getWithHooks:()=>getWithHooks});module.exports=__toCommonJS(with_hooks_exports);var import_context=require(\"@better-auth/core/context\");var import_instrumentation=require(\"@better-auth/core/instrumentation\");function getWithHooks(adapter,ctx){const hooksEntries=ctx.hooks;async function createWithHooks(data,model,customCreateFn){const context=await(0,import_context.getCurrentAuthContext)().catch(()=>null);let actualData=data;for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.create?.before;if(toRun){const result=await(0,import_instrumentation.withSpan)(`db create.before ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"create.before\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(actualData,context));if(result===false)return null;if(typeof result===\"object\"&&\"data\"in result)actualData={...actualData,...result.data}}}let created=null;if(!customCreateFn||customCreateFn.executeMainFn)created=await(await(0,import_context.getCurrentAdapter)(adapter)).create({model,data:actualData,forceAllowId:true});if(customCreateFn?.fn)created=await customCreateFn.fn(created??actualData);for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.create?.after;if(toRun)await(0,import_context.queueAfterTransactionHook)(async()=>{await(0,import_instrumentation.withSpan)(`db create.after ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"create.after\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(created,context))})}return created}__name(createWithHooks,\"createWithHooks\");async function updateWithHooks(data,where,model,customUpdateFn){const context=await(0,import_context.getCurrentAuthContext)().catch(()=>null);let actualData=data;for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.update?.before;if(toRun){const result=await(0,import_instrumentation.withSpan)(`db update.before ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"update.before\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(data,context));if(result===false)return null;if(typeof result===\"object\"&&\"data\"in result)actualData={...actualData,...result.data}}}const customUpdated=customUpdateFn?await customUpdateFn.fn(actualData):null;const updated=!customUpdateFn||customUpdateFn.executeMainFn?await(await(0,import_context.getCurrentAdapter)(adapter)).update({model,update:actualData,where}):customUpdated;for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.update?.after;if(toRun)await(0,import_context.queueAfterTransactionHook)(async()=>{await(0,import_instrumentation.withSpan)(`db update.after ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"update.after\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(updated,context))})}return updated}__name(updateWithHooks,\"updateWithHooks\");async function updateManyWithHooks(data,where,model,customUpdateFn){const context=await(0,import_context.getCurrentAuthContext)().catch(()=>null);let actualData=data;for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.update?.before;if(toRun){const result=await(0,import_instrumentation.withSpan)(`db updateMany.before ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"updateMany.before\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(data,context));if(result===false)return null;if(typeof result===\"object\"&&\"data\"in result)actualData={...actualData,...result.data}}}const customUpdated=customUpdateFn?await customUpdateFn.fn(actualData):null;const updated=!customUpdateFn||customUpdateFn.executeMainFn?await(await(0,import_context.getCurrentAdapter)(adapter)).updateMany({model,update:actualData,where}):customUpdated;for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.update?.after;if(toRun)await(0,import_context.queueAfterTransactionHook)(async()=>{await(0,import_instrumentation.withSpan)(`db updateMany.after ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"updateMany.after\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(updated,context))})}return updated}__name(updateManyWithHooks,\"updateManyWithHooks\");async function deleteWithHooks(where,model,customDeleteFn){const context=await(0,import_context.getCurrentAuthContext)().catch(()=>null);let entityToDelete=null;try{entityToDelete=(await(await(0,import_context.getCurrentAdapter)(adapter)).findMany({model,where,limit:1}))[0]||null}catch{}if(entityToDelete)for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.delete?.before;if(toRun){if(await(0,import_instrumentation.withSpan)(`db delete.before ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"delete.before\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(entityToDelete,context))===false)return null}}const customDeleted=customDeleteFn?await customDeleteFn.fn(where):null;const deleted=(!customDeleteFn||customDeleteFn.executeMainFn)&&entityToDelete?await(await(0,import_context.getCurrentAdapter)(adapter)).delete({model,where}):customDeleted;if(entityToDelete)for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.delete?.after;if(toRun)await(0,import_context.queueAfterTransactionHook)(async()=>{await(0,import_instrumentation.withSpan)(`db delete.after ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"delete.after\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(entityToDelete,context))})}return deleted}__name(deleteWithHooks,\"deleteWithHooks\");async function deleteManyWithHooks(where,model,customDeleteFn){const context=await(0,import_context.getCurrentAuthContext)().catch(()=>null);let entitiesToDelete=[];try{entitiesToDelete=await(await(0,import_context.getCurrentAdapter)(adapter)).findMany({model,where})}catch{}for(const entity of entitiesToDelete)for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.delete?.before;if(toRun){if(await(0,import_instrumentation.withSpan)(`db delete.before ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"delete.before\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(entity,context))===false)return null}}const customDeleted=customDeleteFn?await customDeleteFn.fn(where):null;const deleted=!customDeleteFn||customDeleteFn.executeMainFn?await(await(0,import_context.getCurrentAdapter)(adapter)).deleteMany({model,where}):customDeleted;for(const entity of entitiesToDelete)for(const{source,hooks}of hooksEntries){const toRun=hooks[model]?.delete?.after;if(toRun)await(0,import_context.queueAfterTransactionHook)(async()=>{await(0,import_instrumentation.withSpan)(`db delete.after ${model}`,{[import_instrumentation.ATTR_HOOK_TYPE]:\"delete.after\",[import_instrumentation.ATTR_DB_COLLECTION_NAME]:model,[import_instrumentation.ATTR_CONTEXT]:source},()=>toRun(entity,context))})}return deleted}__name(deleteManyWithHooks,\"deleteManyWithHooks\");return{createWithHooks,updateWithHooks,updateManyWithHooks,deleteWithHooks,deleteManyWithHooks}}__name(getWithHooks,\"getWithHooks\");0&&(module.exports={getWithHooks});\n})()\n","warnings":[],"map":{"version":3,"mappings":";suBAAA,0JAAoF,qCACpF,2BAAgF,6CAGhF,SAAS,aAAa,QAAS,IAAK,CACnC,MAAM,aAAe,IAAI,MACzB,eAAe,gBAAgB,KAAM,MAAO,eAAgB,CAC3D,MAAM,QAAU,QAAM,sCAAsB,EAAE,MAAM,IAAM,IAAI,EAC9D,IAAI,WAAa,KACjB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,OACpC,GAAI,MAAO,CACV,MAAM,OAAS,QAAM,iCAAS,oBAAoB,KAAK,GAAI,CAC1D,CAAC,qCAAc,EAAG,gBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,WAAY,OAAO,CAAC,EACnC,GAAI,SAAW,MAAO,OAAO,KAC7B,GAAI,OAAO,SAAW,UAAY,SAAU,OAAQ,WAAa,CAChE,GAAG,WACH,GAAG,OAAO,IACX,CACD,CACD,CACA,IAAI,QAAU,KACd,GAAI,CAAC,gBAAkB,eAAe,cAAe,QAAU,MAAO,QAAM,kCAAkB,OAAO,GAAG,OAAO,CAC9G,MACA,KAAM,WACN,aAAc,IACf,CAAC,EACD,GAAI,gBAAgB,GAAI,QAAU,MAAM,eAAe,GAAG,SAAW,UAAU,EAC/E,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,MACpC,GAAI,MAAO,QAAM,0CAA0B,SAAY,CACtD,QAAM,iCAAS,mBAAmB,KAAK,GAAI,CAC1C,CAAC,qCAAc,EAAG,eAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,QAAS,OAAO,CAAC,CACjC,CAAC,CACF,CACA,OAAO,OACR,CApCe,0CAqCf,eAAe,gBAAgB,KAAM,MAAO,MAAO,eAAgB,CAClE,MAAM,QAAU,QAAM,sCAAsB,EAAE,MAAM,IAAM,IAAI,EAC9D,IAAI,WAAa,KACjB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,OACpC,GAAI,MAAO,CACV,MAAM,OAAS,QAAM,iCAAS,oBAAoB,KAAK,GAAI,CAC1D,CAAC,qCAAc,EAAG,gBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,KAAM,OAAO,CAAC,EAC7B,GAAI,SAAW,MAAO,OAAO,KAC7B,GAAI,OAAO,SAAW,UAAY,SAAU,OAAQ,WAAa,CAChE,GAAG,WACH,GAAG,OAAO,IACX,CACD,CACD,CACA,MAAM,cAAgB,eAAiB,MAAM,eAAe,GAAG,UAAU,EAAI,KAC7E,MAAM,QAAU,CAAC,gBAAkB,eAAe,cAAgB,MAAO,QAAM,kCAAkB,OAAO,GAAG,OAAO,CACjH,MACA,OAAQ,WACR,KACD,CAAC,EAAI,cACL,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,MACpC,GAAI,MAAO,QAAM,0CAA0B,SAAY,CACtD,QAAM,iCAAS,mBAAmB,KAAK,GAAI,CAC1C,CAAC,qCAAc,EAAG,eAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,QAAS,OAAO,CAAC,CACjC,CAAC,CACF,CACA,OAAO,OACR,CAnCe,0CAoCf,eAAe,oBAAoB,KAAM,MAAO,MAAO,eAAgB,CACtE,MAAM,QAAU,QAAM,sCAAsB,EAAE,MAAM,IAAM,IAAI,EAC9D,IAAI,WAAa,KACjB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,OACpC,GAAI,MAAO,CACV,MAAM,OAAS,QAAM,iCAAS,wBAAwB,KAAK,GAAI,CAC9D,CAAC,qCAAc,EAAG,oBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,KAAM,OAAO,CAAC,EAC7B,GAAI,SAAW,MAAO,OAAO,KAC7B,GAAI,OAAO,SAAW,UAAY,SAAU,OAAQ,WAAa,CAChE,GAAG,WACH,GAAG,OAAO,IACX,CACD,CACD,CACA,MAAM,cAAgB,eAAiB,MAAM,eAAe,GAAG,UAAU,EAAI,KAC7E,MAAM,QAAU,CAAC,gBAAkB,eAAe,cAAgB,MAAO,QAAM,kCAAkB,OAAO,GAAG,WAAW,CACrH,MACA,OAAQ,WACR,KACD,CAAC,EAAI,cACL,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CAC7C,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,MACpC,GAAI,MAAO,QAAM,0CAA0B,SAAY,CACtD,QAAM,iCAAS,uBAAuB,KAAK,GAAI,CAC9C,CAAC,qCAAc,EAAG,mBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,QAAS,OAAO,CAAC,CACjC,CAAC,CACF,CACA,OAAO,OACR,CAnCe,kDAoCf,eAAe,gBAAgB,MAAO,MAAO,eAAgB,CAC5D,MAAM,QAAU,QAAM,sCAAsB,EAAE,MAAM,IAAM,IAAI,EAC9D,IAAI,eAAiB,KACrB,GAAI,CACH,gBAAkB,MAAO,QAAM,kCAAkB,OAAO,GAAG,SAAS,CACnE,MACA,MACA,MAAO,CACR,CAAC,GAAG,CAAC,GAAK,IACX,MAAQ,CAAC,CACT,GAAI,eAAgB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CACjE,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,OACpC,GAAI,MAAO,CACV,GAAI,QAAM,iCAAS,oBAAoB,KAAK,GAAI,CAC/C,CAAC,qCAAc,EAAG,gBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,eAAgB,OAAO,CAAC,IAAM,MAAO,OAAO,IAC5D,CACD,CACA,MAAM,cAAgB,eAAiB,MAAM,eAAe,GAAG,KAAK,EAAI,KACxE,MAAM,SAAW,CAAC,gBAAkB,eAAe,gBAAkB,eAAiB,MAAO,QAAM,kCAAkB,OAAO,GAAG,OAAO,CACrI,MACA,KACD,CAAC,EAAI,cACL,GAAI,eAAgB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CACjE,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,MACpC,GAAI,MAAO,QAAM,0CAA0B,SAAY,CACtD,QAAM,iCAAS,mBAAmB,KAAK,GAAI,CAC1C,CAAC,qCAAc,EAAG,eAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,eAAgB,OAAO,CAAC,CACxC,CAAC,CACF,CACA,OAAO,OACR,CApCe,0CAqCf,eAAe,oBAAoB,MAAO,MAAO,eAAgB,CAChE,MAAM,QAAU,QAAM,sCAAsB,EAAE,MAAM,IAAM,IAAI,EAC9D,IAAI,iBAAmB,CAAC,EACxB,GAAI,CACH,iBAAmB,MAAO,QAAM,kCAAkB,OAAO,GAAG,SAAS,CACpE,MACA,KACD,CAAC,CACF,MAAQ,CAAC,CACT,UAAW,UAAU,iBAAkB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CACpF,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,OACpC,GAAI,MAAO,CACV,GAAI,QAAM,iCAAS,oBAAoB,KAAK,GAAI,CAC/C,CAAC,qCAAc,EAAG,gBAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,OAAQ,OAAO,CAAC,IAAM,MAAO,OAAO,IACpD,CACD,CACA,MAAM,cAAgB,eAAiB,MAAM,eAAe,GAAG,KAAK,EAAI,KACxE,MAAM,QAAU,CAAC,gBAAkB,eAAe,cAAgB,MAAO,QAAM,kCAAkB,OAAO,GAAG,WAAW,CACrH,MACA,KACD,CAAC,EAAI,cACL,UAAW,UAAU,iBAAkB,SAAW,CAAE,OAAQ,KAAM,IAAK,aAAc,CACpF,MAAM,MAAQ,MAAM,KAAK,GAAG,QAAQ,MACpC,GAAI,MAAO,QAAM,0CAA0B,SAAY,CACtD,QAAM,iCAAS,mBAAmB,KAAK,GAAI,CAC1C,CAAC,qCAAc,EAAG,eAClB,CAAC,8CAAuB,EAAG,MAC3B,CAAC,mCAAY,EAAG,MACjB,EAAG,IAAM,MAAM,OAAQ,OAAO,CAAC,CAChC,CAAC,CACF,CACA,OAAO,OACR,CAnCe,kDAoCf,MAAO,CACN,gBACA,gBACA,oBACA,gBACA,mBACD,CACD,CA/LS","names":[],"ignoreList":[],"sources":["/opt/canhelp/node_modules/better-auth/dist/db/with-hooks.mjs"],"sourcesContent":[null]}}