{"version":3,"file":"findVaultByAddress.cjs","sources":["../../../../../src/plugins/vaultOperatorModule/operations/findVaultByAddress.ts"],"sourcesContent":["import { PublicKey } from '@solana/web3.js';\n\nimport { VaultParameters, toVaultParams } from '../models';\nimport { toVaultParamsAccount } from '../accounts';\n\nimport {\n  Operation,\n  OperationHandler,\n  OperationScope,\n  useOperation,\n} from '../../../types';\nimport { Convergence } from '../../../Convergence';\nimport { EscrowRfq } from '@/plugins/rfqModule';\n\nconst Key = 'FindVaultByAddressOperation' as const;\n\nexport const findVaultByAddressOperation =\n  useOperation<FindVaultByAddressOperation>(Key);\n\nexport type FindVaultByAddressOperation = Operation<\n  typeof Key,\n  FindVaultByAddressInput,\n  FindVaultByAddressOutput\n>;\n\nexport type FindVaultByAddressInput = {\n  /** The address of the Vault. */\n  address: PublicKey;\n};\n\nexport type FindVaultByAddressOutput = {\n  vault: VaultParameters;\n  rfq: EscrowRfq;\n};\n\n/**\n * @group Operations\n * @category Handlers\n */\nexport const findVaultByAddressOperationHandler: OperationHandler<FindVaultByAddressOperation> =\n  {\n    handle: async (\n      operation: FindVaultByAddressOperation,\n      cvg: Convergence,\n      scope: OperationScope\n    ): Promise<FindVaultByAddressOutput> => {\n      const { commitment } = scope;\n      const { address } = operation.input;\n      scope.throwIfCanceled();\n\n      const account = await cvg.rpc().getAccount(address, commitment);\n      const solitaAccount = toVaultParamsAccount(account);\n      const rfq = await cvg\n        .rfqs()\n        .findRfqByAddress({ address: solitaAccount.data.rfq });\n      if (rfq.model !== 'escrowRfq') {\n        throw new Error('Unexpected rfq type');\n      }\n      const vault = toVaultParams(solitaAccount, rfq);\n      scope.throwIfCanceled();\n\n      return {\n        vault,\n        rfq,\n      };\n    },\n  };\n"],"names":["Key","findVaultByAddressOperation","useOperation","findVaultByAddressOperationHandler","handle","_handle","_asyncToGenerator","_regeneratorRuntime","mark","_callee","operation","cvg","scope","commitment","address","account","solitaAccount","rfq","vault","wrap","_callee$","_context","prev","next","input","throwIfCanceled","rpc","getAccount","sent","toVaultParamsAccount","rfqs","findRfqByAddress","data","model","Error","toVaultParams","abrupt","stop","_x","_x2","_x3","apply","arguments"],"mappings":";;;;;;;;;AAcA,IAAMA,GAAG,GAAG,6BAAsC,CAAA;IAErCC,2BAA2B,GACtCC,sBAAY,CAA8BF,GAAG,EAAC;AAkBhD;AACA;AACA;AACA;AACO,IAAMG,kCAAiF,GAC5F;EACEC,MAAM,EAAA,YAAA;AAAA,IAAA,IAAAC,OAAA,GAAAC,0CAAA,eAAAC,4CAAA,EAAAC,CAAAA,IAAA,CAAE,SAAAC,OACNC,CAAAA,SAAsC,EACtCC,GAAgB,EAChBC,KAAqB,EAAA;MAAA,IAAAC,UAAA,EAAAC,OAAA,EAAAC,OAAA,EAAAC,aAAA,EAAAC,GAAA,EAAAC,KAAA,CAAA;AAAA,MAAA,OAAAX,4CAAA,EAAA,CAAAY,IAAA,CAAA,SAAAC,SAAAC,QAAA,EAAA;AAAA,QAAA,OAAA,CAAA,EAAA,QAAAA,QAAA,CAAAC,IAAA,GAAAD,QAAA,CAAAE,IAAA;AAAA,UAAA,KAAA,CAAA;YAEbV,UAAU,GAAKD,KAAK,CAApBC,UAAU,CAAA;AACVC,YAAAA,OAAO,GAAKJ,SAAS,CAACc,KAAK,CAA3BV,OAAO,CAAA;YACfF,KAAK,CAACa,eAAe,EAAE,CAAA;AAACJ,YAAAA,QAAA,CAAAE,IAAA,GAAA,CAAA,CAAA;YAAA,OAEFZ,GAAG,CAACe,GAAG,EAAE,CAACC,UAAU,CAACb,OAAO,EAAED,UAAU,CAAC,CAAA;AAAA,UAAA,KAAA,CAAA;YAAzDE,OAAO,GAAAM,QAAA,CAAAO,IAAA,CAAA;AACPZ,YAAAA,aAAa,GAAGa,6BAAoB,CAACd,OAAO,CAAC,CAAA;AAAAM,YAAAA,QAAA,CAAAE,IAAA,GAAA,CAAA,CAAA;AAAA,YAAA,OACjCZ,GAAG,CAClBmB,IAAI,EAAE,CACNC,gBAAgB,CAAC;AAAEjB,cAAAA,OAAO,EAAEE,aAAa,CAACgB,IAAI,CAACf,GAAAA;AAAI,aAAC,CAAC,CAAA;AAAA,UAAA,KAAA,CAAA;YAFlDA,GAAG,GAAAI,QAAA,CAAAO,IAAA,CAAA;AAAA,YAAA,IAAA,EAGLX,GAAG,CAACgB,KAAK,KAAK,WAAW,CAAA,EAAA;AAAAZ,cAAAA,QAAA,CAAAE,IAAA,GAAA,EAAA,CAAA;AAAA,cAAA,MAAA;AAAA,aAAA;AAAA,YAAA,MACrB,IAAIW,KAAK,CAAC,qBAAqB,CAAC,CAAA;AAAA,UAAA,KAAA,EAAA;AAElChB,YAAAA,KAAK,GAAGiB,yBAAa,CAACnB,aAAa,EAAEC,GAAG,CAAC,CAAA;YAC/CL,KAAK,CAACa,eAAe,EAAE,CAAA;YAAC,OAAAJ,QAAA,CAAAe,MAAA,CAEjB,QAAA,EAAA;AACLlB,cAAAA,KAAK,EAALA,KAAK;AACLD,cAAAA,GAAG,EAAHA,GAAAA;aACD,CAAA,CAAA;AAAA,UAAA,KAAA,EAAA,CAAA;AAAA,UAAA,KAAA,KAAA;YAAA,OAAAI,QAAA,CAAAgB,IAAA,EAAA,CAAA;AAAA,SAAA;AAAA,OAAA,EAAA5B,OAAA,CAAA,CAAA;KACF,CAAA,CAAA,CAAA;AAAA,IAAA,SAAAL,MAAAkC,CAAAA,EAAA,EAAAC,GAAA,EAAAC,GAAA,EAAA;AAAA,MAAA,OAAAnC,OAAA,CAAAoC,KAAA,CAAA,IAAA,EAAAC,SAAA,CAAA,CAAA;AAAA,KAAA;AAAA,IAAA,OAAAtC,MAAA,CAAA;AAAA,GAAA,EAAA;AACH;;;;;"}