Apex 捆绑包

# Two signed transactions from the helper in Sending transactions.
# Exactly one of them may carry the tip, so build the first one without it.
TX1=$(node -e 'import("./apex-tx.mjs").then(async (m) => console.log(Buffer.from((await m.buildTx({ tip: false, label: "apex bundle 1" })).serialize()).toString("base64")))')
TX2=$(node -e 'import("./apex-tx.mjs").then(async (m) => console.log(Buffer.from((await m.buildTx({ tip: true, label: "apex bundle 2" })).serialize()).toString("base64")))')

BUNDLE_ID=$(curl -s "$APEX_RPC" \
  -H "Content-Type: application/json" \
  -H "x-api-key: $APEX_API_KEY" \
  -d "{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"sendBundle\",\"params\":[[\"$TX1\",\"$TX2\"],{\"encoding\":\"base64\"}]}" \
  | jq -r '.result // .error')
echo "bundle id: $BUNDLE_ID"

curl -s "$APEX_RPC" \
  -H "Content-Type: application/json" \
  -H "x-api-key: $APEX_API_KEY" \
  -d "{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"getInflightBundleStatuses\",\"params\":[[\"$BUNDLE_ID\"]]}"

import { apexRpc, buildTx } from "./apex-tx.mjs";

// Exactly one transaction carries the tip.
const txs = [
  await buildTx({ tip: false, label: "apex bundle 1" }),
  await buildTx({ tip: true, label: "apex bundle 2" }),
];

const bundleId = await apexRpc("sendBundle", [
  txs.map((tx) => Buffer.from(tx.serialize()).toString("base64")),
  { encoding: "base64" },
]);
console.log("bundle id:", bundleId);

// Poll until the bundle settles.
for (;;) {
  const { value } = await apexRpc("getInflightBundleStatuses", [[bundleId]]);
  const { status, landed_slot } = value[0];
  if (status === "Landed") { console.log("landed in slot", landed_slot); break; }
  if (status === "Failed" || status === "Invalid") { console.log("bundle", status); break; }
  await new Promise((resolve) => setTimeout(resolve, 1000));
}

import base64
import time

from apex_tx import apex_rpc, build_tx

# Exactly one transaction carries the tip.
txs = [
    build_tx(tip=False, label="apex bundle 1"),
    build_tx(tip=True, label="apex bundle 2"),
]

bundle_id = apex_rpc("sendBundle", [
    [base64.b64encode(bytes(tx)).decode() for tx in txs],
    {"encoding": "base64"},
])
print("bundle id:", bundle_id)

# Poll until the bundle settles.
while True:
    entry = apex_rpc("getInflightBundleStatuses", [[bundle_id]])["value"][0]
    if entry["status"] == "Landed":
        print("landed in slot", entry["landed_slot"])
        break
    if entry["status"] in ("Failed", "Invalid"):
        print("bundle", entry["status"])
        break
    time.sleep(1)

import { APEX_RPC, API_KEY, buildTx } from "./apex-tx.mjs";

const txs = [
  await buildTx({ tip: false, label: "apex bundle 1" }),
  await buildTx({ tip: true, label: "apex bundle 2" }),
];

// Each frame: u16 big-endian length, then the transaction bytes.
const frames = txs.map((tx) => {
  const wire = Buffer.from(tx.serialize());
  const length = Buffer.alloc(2);
  length.writeUInt16BE(wire.length);
  return Buffer.concat([length, wire]);
});

const res = await fetch(`${APEX_RPC}/send-bundle`, {
  method: "POST",
  headers: { "Content-Type": "application/octet-stream", "x-api-key": API_KEY },
  body: Buffer.concat(frames),
});
const body = await res.json();
if (!body.bundle_id) throw new Error(`rejected ${res.status} ${body.error}: ${body.message}`);
console.log("bundle id:", body.bundle_id);
console.log("signatures:", body.signatures);

import struct

from apex_tx import APEX_RPC, build_tx, session

txs = [
    bytes(build_tx(tip=False, label="apex bundle 1")),
    bytes(build_tx(tip=True, label="apex bundle 2")),
]
# Each frame: u16 big-endian length, then the transaction bytes.
payload = b"".join(struct.pack(">H", len(wire)) + wire for wire in txs)

r = session.post(f"{APEX_RPC}/send-bundle", headers={"Content-Type": "application/octet-stream"},
                 data=payload, timeout=5)
body = r.json()
if "bundle_id" not in body:
    raise RuntimeError(f"rejected {r.status_code} {body['error']}: {body['message']}")
print("bundle id:", body["bundle_id"])
print("signatures:", body["signatures"])