wasm, core: add action to request atomic matches

renegade-fi · Oct 30, 2024 · 1c17d0c · 1c17d0c
1 parent a7584a7
commit 1c17d0c
Show file tree

Hide file tree

Showing 20 changed files with 270 additions and 70 deletions.
diff --git a/packages/core/src/actions/cancelOrder.ts b/packages/core/src/actions/cancelOrder.ts
@@ -6,6 +6,7 @@ import { stringifyForWasm } from '../utils/bigJSON.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getBackOfQueueWallet } from './getBackOfQueueWallet.js'
 import { getWalletId } from './getWalletId.js'
+import { getSymmetricKey } from '../exports/index.js'
 
 export type CancelOrderParameters = {
   id: string
@@ -21,23 +22,23 @@ export async function cancelOrder(
 ): Promise<CancelOrderReturnType> {
   const { id } = parameters
   const {
-    getRelayerBaseUrl,
     utils,
     state: { seed },
   } = config
   invariant(seed, 'Seed is required')
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
   const wallet = await getBackOfQueueWallet(config)
 
   const body = utils.cancel_order(seed, stringifyForWasm(wallet), id)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(CANCEL_ORDER_ROUTE(walletId, id)),
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(CANCEL_ORDER_ROUTE(walletId, id)),
       body,
-    )
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/cancelOrderRequest.ts b/packages/core/src/actions/cancelOrderRequest.ts
@@ -1,6 +1,7 @@
 import { CANCEL_ORDER_ROUTE } from '../constants.js'
 import type { Config } from '../createConfig.js'
 import type { BaseErrorType } from '../errors/base.js'
+import { getSymmetricKey } from '../exports/index.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getWalletId } from './getWalletId.js'
 
@@ -15,16 +16,15 @@ export async function cancelOrderRequest(
   parameters: CancelOrderRequestParameters,
 ): Promise<CancelOrderRequestReturnType> {
   const { request, id } = parameters
-  const { getRelayerBaseUrl } = config
-
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(CANCEL_ORDER_ROUTE(walletId, id)),
-      request,
-    )
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(CANCEL_ORDER_ROUTE(walletId, id)),
+      body: request,
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/createOrder.ts b/packages/core/src/actions/createOrder.ts
@@ -7,6 +7,7 @@ import { stringifyForWasm } from '../utils/bigJSON.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getBackOfQueueWallet } from './getBackOfQueueWallet.js'
 import { getWalletId } from './getWalletId.js'
+import { getSymmetricKey } from '../exports/index.js'
 
 export type CreateOrderParameters = {
   id?: string
@@ -38,12 +39,12 @@ export async function createOrder(
     allowExternalMatches = false,
   } = parameters
   const {
-    getRelayerBaseUrl,
     utils,
     state: { seed },
   } = config
   invariant(seed, 'Seed is required')
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
   const wallet = await getBackOfQueueWallet(config)
 
@@ -61,11 +62,11 @@ export async function createOrder(
   )
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(WALLET_ORDERS_ROUTE(walletId)),
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(WALLET_ORDERS_ROUTE(walletId)),
       body,
-    )
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/createOrderRequest.ts b/packages/core/src/actions/createOrderRequest.ts
@@ -1,6 +1,7 @@
 import { WALLET_ORDERS_ROUTE } from '../constants.js'
 import type { Config } from '../createConfig.js'
 import type { BaseErrorType } from '../errors/base.js'
+import { getSymmetricKey } from '../exports/actions.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getWalletId } from './getWalletId.js'
 
@@ -15,16 +16,16 @@ export async function createOrderRequest(
   parameters: CreateOrderRequestParameters,
 ): Promise<CreateOrderRequestReturnType> {
   const { request } = parameters
-  const { getRelayerBaseUrl } = config
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(WALLET_ORDERS_ROUTE(walletId)),
-      request,
-    )
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(WALLET_ORDERS_ROUTE(walletId)),
+      body: request,
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/deposit.ts b/packages/core/src/actions/deposit.ts
@@ -8,6 +8,7 @@ import { stringifyForWasm } from '../utils/bigJSON.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getBackOfQueueWallet } from './getBackOfQueueWallet.js'
 import { getWalletId } from './getWalletId.js'
+import { getSymmetricKey } from '../exports/actions.js'
 
 export type DepositParameters = {
   fromAddr: Address
@@ -29,7 +30,6 @@ export async function deposit(
   const { fromAddr, mint, amount, permitNonce, permitDeadline, permit } =
     parameters
   const {
-    getRelayerBaseUrl,
     utils,
     state: { seed },
   } = config
@@ -38,6 +38,7 @@ export async function deposit(
   const token = Token.findByAddress(mint)
   invariant(token, 'Token not found')
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
   const wallet = await getBackOfQueueWallet(config)
   const walletStr = stringifyForWasm(wallet)
@@ -54,11 +55,11 @@ export async function deposit(
   )
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(DEPOSIT_BALANCE_ROUTE(walletId)),
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(DEPOSIT_BALANCE_ROUTE(walletId)),
       body,
-    )
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/depositRequest.ts b/packages/core/src/actions/depositRequest.ts
@@ -1,6 +1,7 @@
 import { DEPOSIT_BALANCE_ROUTE } from '../constants.js'
 import type { Config } from '../createConfig.js'
 import type { BaseErrorType } from '../errors/base.js'
+import { getSymmetricKey } from '../exports/actions.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getWalletId } from './getWalletId.js'
 
@@ -15,16 +16,15 @@ export async function depositRequest(
   parameters: DepositRequestParameters,
 ): Promise<DepositRequestReturnType> {
   const { request } = parameters
-  const { getRelayerBaseUrl } = config
-
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(DEPOSIT_BALANCE_ROUTE(walletId)),
-      request,
-    )
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(DEPOSIT_BALANCE_ROUTE(walletId)),
+      body: request,
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/getAtomicMatch.ts b/packages/core/src/actions/getAtomicMatch.ts
@@ -0,0 +1,50 @@
+import invariant from 'tiny-invariant'
+import {
+  RENEGADE_API_KEY_HEADER,
+  REQUEST_EXTERNAL_MATCH_ROUTE,
+} from '../constants.js'
+import type { Config } from '../createConfig.js'
+import type { BaseErrorType } from '../errors/base.js'
+import { postRelayerWithAuth } from '../utils/http.js'
+import { toHex } from 'viem'
+
+export type GetAtomicMatchParameters = {
+  base: `0x${string}`
+  quote: `0x${string}`
+  side: 'buy' | 'sell'
+  amount: bigint
+  minFillSize?: bigint
+}
+
+export type GetAtomicMatchReturnType = any
+
+export type GetAtomicMatchErrorType = BaseErrorType
+
+export async function getAtomicMatch(
+  config: Config,
+  parameters: GetAtomicMatchParameters,
+): Promise<GetAtomicMatchReturnType> {
+  const {
+    base,
+    quote,
+    side,
+    amount,
+    minFillSize = BigInt(0),
+  } = parameters
+  const { apiSecret, apiKey } = config
+  invariant(apiSecret, 'API secret not specified in config')
+  invariant(apiKey, 'API key not specified in config')
+  const symmetricKey = config.utils.b64_to_hex_hmac_key(apiSecret)
+
+  const body = config.utils.new_external_order(base, quote, side, toHex(amount), toHex(minFillSize))
+
+  const res = await postRelayerWithAuth(config, {
+    url: config.getAuthServerUrl(REQUEST_EXTERNAL_MATCH_ROUTE),
+    body,
+    key: symmetricKey,
+    headers: {
+      [RENEGADE_API_KEY_HEADER]: apiKey,
+    },
+  })
+  return res
+}
diff --git a/packages/core/src/actions/payFees.ts b/packages/core/src/actions/payFees.ts
@@ -1,6 +1,7 @@
 import { PAY_FEES_ROUTE } from '../constants.js'
 import type { Config } from '../createConfig.js'
 import type { BaseError } from '../errors/base.js'
+import { getSymmetricKey } from '../exports/actions.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getWalletId } from './getWalletId.js'
 
@@ -9,14 +10,14 @@ export type PayFeesReturnType = { taskIds: string[] }
 export type PayFeesErrorType = BaseError
 
 export async function payFees(config: Config): Promise<PayFeesReturnType> {
-  const { getRelayerBaseUrl } = config
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(PAY_FEES_ROUTE(walletId)),
-    )
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(PAY_FEES_ROUTE(walletId)),
+      key: symmetricKey,
+    })
     if (res?.task_ids) {
       res.task_ids.map((id: string) => {
         console.log(`task pay-fees(${id}): ${walletId}`)

diff --git a/packages/core/src/actions/refreshWallet.ts b/packages/core/src/actions/refreshWallet.ts
@@ -1,19 +1,20 @@
 import { REFRESH_WALLET_ROUTE } from '../constants.js'
 import type { Config } from '../createConfig.js'
+import { getSymmetricKey } from '../exports/actions.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getWalletId } from './getWalletId.js'
 
 export type RefreshWalletReturnType = Promise<{ taskId: string }>
 
 export async function refreshWallet(config: Config): RefreshWalletReturnType {
-  const { getRelayerBaseUrl } = config
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(REFRESH_WALLET_ROUTE(walletId)),
-    )
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(REFRESH_WALLET_ROUTE(walletId)),
+      key: symmetricKey,
+    })
     if (res?.task_id) {
       console.log(`task refresh-wallet(${res.task_id}): ${walletId}`)
     }

diff --git a/packages/core/src/actions/updateOrder.ts b/packages/core/src/actions/updateOrder.ts
@@ -6,6 +6,7 @@ import { stringifyForWasm } from '../utils/bigJSON.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getBackOfQueueWallet } from './getBackOfQueueWallet.js'
 import { getWalletId } from './getWalletId.js'
+import { getSymmetricKey } from '../exports/actions.js'
 
 export type UpdateOrderParameters = {
   id?: string
@@ -35,12 +36,12 @@ export async function updateOrder(
     allowExternalMatches = false,
   } = parameters
   const {
-    getRelayerBaseUrl,
     utils,
     state: { seed },
   } = config
   invariant(seed, 'Seed is required')
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
   const wallet = await getBackOfQueueWallet(config)
 
@@ -58,11 +59,11 @@ export async function updateOrder(
   )
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(UPDATE_ORDER_ROUTE(walletId, id)),
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(UPDATE_ORDER_ROUTE(walletId, id)),
       body,
-    )
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {

diff --git a/packages/core/src/actions/withdraw.ts b/packages/core/src/actions/withdraw.ts
@@ -6,6 +6,7 @@ import { stringifyForWasm } from '../utils/bigJSON.js'
 import { postRelayerWithAuth } from '../utils/http.js'
 import { getBackOfQueueWallet } from './getBackOfQueueWallet.js'
 import { getWalletId } from './getWalletId.js'
+import { getSymmetricKey } from '../exports/actions.js'
 
 export type WithdrawParameters = {
   mint: Address
@@ -21,12 +22,12 @@ export async function withdraw(
 ): WithdrawReturnType {
   const { mint, amount, destinationAddr } = parameters
   const {
-    getRelayerBaseUrl,
     utils,
     state: { seed },
   } = config
   invariant(seed, 'Seed is required')
 
+  const symmetricKey = getSymmetricKey(config)
   const walletId = getWalletId(config)
   const wallet = await getBackOfQueueWallet(config)
 
@@ -40,11 +41,11 @@ export async function withdraw(
   )
 
   try {
-    const res = await postRelayerWithAuth(
-      config,
-      getRelayerBaseUrl(WITHDRAW_BALANCE_ROUTE(walletId, mint)),
+    const res = await postRelayerWithAuth(config, {
+      url: config.getRelayerBaseUrl(WITHDRAW_BALANCE_ROUTE(walletId, mint)),
       body,
-    )
+      key: symmetricKey,
+    })
     console.log(`task update-wallet(${res.task_id}): ${walletId}`)
     return { taskId: res.task_id }
   } catch (error) {