fix(orderbook): recover continuous close reduce-only conflicts

docs/binance-orderbook-trade-development.md

@@ -171,6 +171,34 @@ Required properties:
 - readable, non-minified output
 - generated `@version` matches `src/binance-orderbook-trade/index.user.js`
 
+## Continuous Close Reduce-Only Recovery
+
+A continuous close round handles `90802022` only when one settled native JSON
+response reports `success=false`, its parsed code is `90802022`, and no successful
+or additional response was captured. Toast text alone never authorizes recovery.
+The first rejection establishes an authoritative same-symbol, same-side position
+quantity baseline. Recovery waits the existing three-second readiness cooldown
+and reads that quantity again. Confirmed flat ends normally; an increased
+position stops the round. A strict decrease permits rebuilding without cancelling.
+
+An unchanged quantity permits one confirmed replacement through the existing
+current-symbol, same-close-direction Basic-order workflow. Rejection after that
+replacement triggers another cooldown and position read, not another immediate
+replacement. If the position still has not decreased, recovery ends with the
+native error and a no-progress explanation. Further replacements require a strict
+decrease in authoritative position quantity. Submissions and cancellations do not
+count as position progress. The guard lasts for the whole active round.
+
+Recovery rebuilds use the smaller of the confirmed API position quantity and the
+latest valid DOM closeable quantity. Missing DOM quantity never falls back to the
+API amount. Symbol, direction, precision, and option context stay pinned to the
+active round. Cancel, position-read, context, and unconfirmed-submit errors during
+this recovery are terminal and cannot inherit unrelated continuous retry policies.
+Once reduce-only recovery begins, the executor disables max-open-orders capacity
+recovery too, so a later `90802025` cannot trigger a separate batch of cancellations.
+Ordinary single-round clicks and OPEN ladders retain their existing replacement
+contract. No additional API or DOM cancellation path is introduced.
+
 ## Versioning
 
 Bump `@version` in `src/binance-orderbook-trade/index.user.js` when behavior changes, then run:

e2e/binance-orderbook/specs/close-ladder-recovery.pw.js

@@ -0,0 +1,132 @@
+import { test, expect } from '../test.js';
+import { CURRENT_SYMBOL, createCancelScenario } from '../scenarios/cancel-current-symbol.js';
+import { openUserscriptScenario, readFixtureState } from '../helpers/userscript-page.js';
+
+test('continuous close preserves partial submissions through repeated reduce-only rejections and confirmed flat', async ({ page }) => {
+  test.setTimeout(30_000);
+  const scenario = createCancelScenario({
+    positions: [{ symbol: CURRENT_SYMBOL, side: 'SHORT', quantity: '100' }],
+    ui: { tradeMode: 'CLOSE', orderbookPrecision: '0.1' },
+  });
+  const { errors } = await openUserscriptScenario(page, scenario);
+  let submissions = 0;
+  const quantities = ['100', '80', '80', '60', '0'];
+  let positionReads = 0;
+  await page.route('**/bapi/futures/v1/private/future/order/place-order', async (route) => {
+    submissions += 1;
+    expect(submissions).toBeLessThanOrEqual(5);
+    await route.fulfill({
+      status: 200,
+      contentType: 'application/json',
+      body: JSON.stringify(submissions <= 2 ? { success: true } : {
+        success: false, code: '90802022', message: 'Reduce-only order failed',
+      }),
+    });
+  });
+  await page.route('**/bapi/futures/v6/private/future/user-data/user-position', async (route) => {
+    const quantity = quantities[positionReads++];
+    expect(quantity).not.toBeUndefined();
+    await route.fulfill({
+      status: 200,
+      contentType: 'application/json',
+      body: JSON.stringify({
+        success: true,
+        data: [{ symbol: CURRENT_SYMBOL, positionSide: 'SHORT', positionAmount: `-${quantity}` }],
+      }),
+    });
+  });
+  const panel = page.locator('#jh-binance-close-qty-multiplier-panel');
+  await panel.getByRole('button', { name: '阶梯平空', exact: true }).click({ modifiers: ['Alt'] });
+  const status = panel.locator('#jh-binance-ladder-status');
+  await expect(status).toContainText('只减仓冲突，3s 后复核仓位', { timeout: 8_000 });
+  await expect(status).toContainText('当前方向已无持仓', { timeout: 18_000 });
+  await expect(status).toContainText('连续阶梯平空');
+  await expect(status).toContainText('累计 2 笔');
+  expect(submissions).toBe(5);
+  expect(positionReads).toBe(5);
+  const events = (await readFixtureState(page)).events;
+  const orders = events.filter(({ type }) => type === 'order-submitted');
+  expect(orders.map(({ quantity }) => quantity)).toEqual(['0.06', '0.06', '0.06', '0.04', '0.03']);
+  expect(events.filter(({ type }) => /cancel/.test(type))).toEqual([]);
+  expect(errors).toEqual([]);
+});
+
+test('a close that disables the native button during recovery still confirms flat', async ({ page }) => {
+  const scenario = createCancelScenario({
+    positions: [{ symbol: CURRENT_SYMBOL, side: 'SHORT', quantity: '100' }],
+    ui: { tradeMode: 'CLOSE', orderbookPrecision: '0.1' },
+  });
+  const { errors } = await openUserscriptScenario(page, scenario);
+  let submissions = 0;
+  let positionReads = 0;
+  await page.route('**/bapi/futures/v1/private/future/order/place-order', async (route) => {
+    submissions += 1;
+    await route.fulfill({
+      status: 200, contentType: 'application/json',
+      body: JSON.stringify({ success: false, code: 90802022, message: 'Reduce-only order failed' }),
+    });
+  });
+  await page.route('**/bapi/futures/v6/private/future/user-data/user-position', async (route) => {
+    positionReads += 1;
+    expect(positionReads).toBeLessThanOrEqual(2);
+    if (positionReads === 1) {
+      await page.getByRole('button', { name: '平空', exact: true }).evaluate((button) => {
+        button.disabled = true;
+      });
+    }
+    await route.fulfill({
+      status: 200, contentType: 'application/json',
+      body: JSON.stringify({ success: true, data: [{
+        symbol: CURRENT_SYMBOL, positionSide: 'SHORT', positionAmount: positionReads === 1 ? '-100' : '0',
+      }] }),
+    });
+  });
+  const panel = page.locator('#jh-binance-close-qty-multiplier-panel');
+  await panel.getByRole('button', { name: '阶梯平空', exact: true }).click({ modifiers: ['Alt'] });
+  await expect(panel.locator('#jh-binance-ladder-status')).toContainText('当前方向已无持仓', { timeout: 10_000 });
+  expect(submissions).toBe(1);
+  expect(positionReads).toBe(2);
+  expect(errors).toEqual([]);
+});
+
+test('a capacity rejection during reduce-only recovery stops without entering batch cancellation', async ({ page }) => {
+  const scenario = createCancelScenario({
+    positions: [{ symbol: CURRENT_SYMBOL, side: 'SHORT', quantity: '100' }],
+    ui: { tradeMode: 'CLOSE', orderbookPrecision: '0.1' },
+  });
+  const { errors } = await openUserscriptScenario(page, scenario);
+  let submissions = 0;
+  let positionReads = 0;
+  await page.route('**/bapi/futures/v1/private/future/order/place-order', async (route) => {
+    submissions += 1;
+    expect(submissions).toBeLessThanOrEqual(2);
+    await route.fulfill({
+      status: 200, contentType: 'application/json',
+      body: JSON.stringify(submissions === 1
+        ? { success: false, code: 90802022 }
+        : { success: false, code: 90802025, message: 'Maximum open orders' }),
+    });
+  });
+  await page.route('**/bapi/futures/v6/private/future/user-data/user-position', async (route) => {
+    positionReads += 1;
+    expect(positionReads).toBeLessThanOrEqual(2);
+    await route.fulfill({
+      status: 200, contentType: 'application/json',
+      body: JSON.stringify({ success: true, data: [{
+        symbol: CURRENT_SYMBOL, positionSide: 'SHORT', positionAmount: positionReads === 1 ? '-100' : '-80',
+      }] }),
+    });
+  });
+  const panel = page.locator('#jh-binance-close-qty-multiplier-panel');
+  await panel.getByRole('button', { name: '阶梯平空', exact: true }).click({ modifiers: ['Alt'] });
+  const status = panel.locator('#jh-binance-ladder-status');
+  await expect(status).toContainText('失败', { timeout: 10_000 });
+  await expect(status).toContainText('Maximum open orders');
+  await expect(status).toContainText('90802025');
+  await expect(status).toContainText('只减仓订单被拒绝');
+  await expect(status).not.toContainText('null');
+  expect(submissions).toBe(2);
+  expect(positionReads).toBe(2);
+  expect((await readFixtureState(page)).events.filter(({ type }) => /cancel/.test(type))).toEqual([]);
+  expect(errors).toEqual([]);
+});