feat(release): update 692ed15

src/arch/arweaveGateway.ts

@@ -69,6 +69,7 @@ export interface Gateway {
       bundledIn?: TransactionId;
     }[]
   >;
+  postBundleTxToAdminQueue(bundleTxId: TransactionId): Promise<void>;
 }
 
 export class ArweaveGateway implements Gateway {
@@ -382,4 +383,33 @@ export class ArweaveGateway implements Gateway {
     );
     return new Winston(res.data);
   }
+
+  /** Optionally posts a prepared bundle to the ar.io gateway's priority bundle queue if an admin key exists */
+  public async postBundleTxToAdminQueue(
+    bundleTxId: TransactionId
+  ): Promise<void> {
+    if (process.env.AR_IO_ADMIN_KEY !== undefined) {
+      logger.debug("Posting bundle to admin queue...", { bundleTxId });
+      try {
+        await this.retryStrategy.sendRequest(() =>
+          this.axiosInstance.post(
+            `${this.endpoint.href}ar-io/admin/queue-bundle`,
+            {
+              id: bundleTxId,
+            },
+            {
+              headers: {
+                Authorization: `Bearer ${process.env.AR_IO_ADMIN_KEY}`,
+              },
+            }
+          )
+        );
+      } catch (error) {
+        logger.error("Error posting bundle to admin queue", {
+          bundleTxId,
+          error: error instanceof Error ? error.message : "Unknown error",
+        });
+      }
+    }
+  }
 }

src/jobs/post.ts

@@ -65,9 +65,10 @@ export async function postBundleHandler(
 
   try {
     // post bundle, throw error on failure
-    const transactionPostResponseData = await arweaveGateway.postBundleTx(
-      bundleTx
-    );
+    const [transactionPostResponseData] = await Promise.all([
+      arweaveGateway.postBundleTx(bundleTx),
+      arweaveGateway.postBundleTxToAdminQueue(bundleTx.id),
+    ]);
 
     // fetch AR rate - but don't throw on failure
     const usdToArRate = await paymentService