feat: market close all

src/constants/abacus.ts

@@ -209,6 +209,8 @@ export const AbacusMarginMode = Abacus.exchange.dydx.abacus.output.input.MarginM
 
 export type HumanReadablePlaceOrderPayload =
   Abacus.exchange.dydx.abacus.state.manager.HumanReadablePlaceOrderPayload;
+export type HumanReadableCloseAllPositionsPayload =
+  Abacus.exchange.dydx.abacus.state.manager.HumanReadableCloseAllPositionsPayload;
 export type HumanReadableCancelOrderPayload =
   Abacus.exchange.dydx.abacus.state.manager.HumanReadableCancelOrderPayload;
 export type HumanReadableTriggerOrdersPayload =

src/constants/dialogs.ts

@@ -17,6 +17,7 @@ export type AdjustIsolatedMarginDialogProps = {
 };
 export type AdjustTargetLeverageDialogProps = {};
 export type ClosePositionDialogProps = {};
+export type CloseAllPositionsConfirmationDialogProps = {};
 export type CancelAllOrdersConfirmationDialogProps = { marketId?: string };
 export type CancelPendingOrdersDialogProps = { marketId: string };
 export type ComplianceConfigDialogProps = {};
@@ -101,6 +102,7 @@ export const DialogTypes = unionize(
     AdjustTargetLeverage: ofType<AdjustTargetLeverageDialogProps>(),
     CancelAllOrdersConfirmation: ofType<CancelAllOrdersConfirmationDialogProps>(),
     CancelPendingOrders: ofType<CancelPendingOrdersDialogProps>(),
+    CloseAllPositionsConfirmation: ofType<CloseAllPositionsConfirmationDialogProps>(),
     ClosePosition: ofType<ClosePositionDialogProps>(),
     ComplianceConfig: ofType<ComplianceConfigDialogProps>(),
     ConfirmPendingDeposit: ofType<ConfirmPendingDepositDialogProps>(),

src/constants/trade.ts

@@ -195,3 +195,10 @@ export type LocalCancelAllData = {
   failedOrderIds?: string[];
   errorParams?: ErrorParams;
 };
+
+export type LocalCloseAllPositionsData = {
+  submittedOrderClientIds: string[];
+  filledOrderClientIds: string[];
+  failedOrderClientIds: string[];
+  errorParams?: ErrorParams;
+};

src/hooks/useNotificationTypes.tsx

@@ -44,6 +44,7 @@ import { Output, OutputType } from '@/components/Output';
 // eslint-disable-next-line import/no-cycle
 import { BlockRewardNotification } from '@/views/notifications/BlockRewardNotification';
 import { CancelAllNotification } from '@/views/notifications/CancelAllNotification';
+import { CloseAllPositionsNotification } from '@/views/notifications/CloseAllPositionsNotification';
 import { IncentiveSeasonDistributionNotification } from '@/views/notifications/IncentiveSeasonDistributionNotification';
 import { MarketLaunchTrumpwinNotification } from '@/views/notifications/MarketLaunchTrumpwinNotification';
 import { OrderCancelNotification } from '@/views/notifications/OrderCancelNotification';
@@ -58,6 +59,7 @@ import { openDialog } from '@/state/dialogs';
 import {
   getLocalCancelAlls,
   getLocalCancelOrders,
+  getLocalCloseAllPositions,
   getLocalPlaceOrders,
 } from '@/state/localOrdersSelectors';
 import { getAbacusNotifications, getCustomNotifications } from '@/state/notificationsSelectors';
@@ -664,6 +666,7 @@ export const notificationTypes: NotificationTypeConfig[] = [
       const localPlaceOrders = useAppSelector(getLocalPlaceOrders, shallowEqual);
       const localCancelOrders = useAppSelector(getLocalCancelOrders, shallowEqual);
       const localCancelAlls = useAppSelector(getLocalCancelAlls, shallowEqual);
+      const localCloseAllPositions = useAppSelector(getLocalCloseAllPositions, shallowEqual);
 
       const allOrders = useAppSelector(getSubaccountOrders, shallowEqual);
       const stringGetter = useStringGetter();
@@ -754,6 +757,31 @@ export const notificationTypes: NotificationTypeConfig[] = [
           );
         }
       }, [localCancelAlls]);
+
+      useEffect(() => {
+        if (!localCloseAllPositions) return;
+        const localCloseAllKey = localCloseAllPositions.submittedOrderClientIds.join('-');
+        // eslint-disable-next-line no-restricted-syntax
+        trigger(
+          localCloseAllKey,
+          {
+            icon: null,
+            title: stringGetter({ key: STRING_KEYS.CLOSE_ALL_POSITIONS }),
+            toastSensitivity: 'background',
+            groupKey: localCloseAllKey,
+            toastDuration: DEFAULT_TOAST_AUTO_CLOSE_MS,
+            renderCustomBody: ({ isToast, notification }) => (
+              <CloseAllPositionsNotification
+                isToast={isToast}
+                localCloseAllPositions={localCloseAllPositions}
+                notification={notification}
+              />
+            ),
+          },
+          [localCloseAllPositions],
+          true
+        );
+      }, [localCloseAllPositions]);
     },
     useNotificationAction: () => {
       const dispatch = useAppDispatch();

src/hooks/useSubaccount.tsx

@@ -40,6 +40,7 @@ import {
   cancelOrderFailed,
   cancelOrderSubmitted,
   clearLocalOrders,
+  closeAllPositionsSubmitted,
   placeOrderFailed,
   placeOrderSubmitted,
 } from '@/state/localOrders';
@@ -601,6 +602,36 @@ const useSubaccountContext = ({ localDydxWallet }: { localDydxWallet?: LocalWall
     [dispatch, orders]
   );
 
+  const closeAllPositions = useCallback(() => {
+    // this is for each single close position / place order transaction
+    const callback = (
+      success: boolean,
+      parsingError?: Nullable<ParsingError>,
+      data?: Nullable<HumanReadablePlaceOrderPayload>
+    ) => {
+      if (!success) {
+        const errorParams = getValidErrorParamsFromParsingError(parsingError);
+        if (data?.clientId !== undefined) {
+          dispatch(
+            placeOrderFailed({
+              clientId: data.clientId,
+              errorParams,
+            })
+          );
+        }
+      }
+    };
+
+    const payload = abacusStateManager.closeAllPositions(callback);
+    if (payload) {
+      dispatch(
+        closeAllPositionsSubmitted(
+          payload.payloads.toArray().map((orderPayload) => orderPayload.clientId)
+        )
+      );
+    }
+  }, [dispatch]);
+
   // ------ Trigger Orders Methods ------ //
   const placeTriggerOrders = useCallback(
     async ({
@@ -892,6 +923,7 @@ const useSubaccountContext = ({ localDydxWallet }: { localDydxWallet?: LocalWall
     // Trading Methods
     placeOrder,
     closePosition,
+    closeAllPositions,
     cancelOrder,
     cancelAllOrders,
     placeTriggerOrders,

src/layout/DialogManager.tsx

@@ -6,6 +6,7 @@ import { AdjustIsolatedMarginDialog } from '@/views/dialogs/AdjustIsolatedMargin
 import { AdjustTargetLeverageDialog } from '@/views/dialogs/AdjustTargetLeverageDialog';
 import { CancelAllOrdersConfirmationDialog } from '@/views/dialogs/CancelAllOrdersConfirmationDialog';
 import { CancelPendingOrdersDialog } from '@/views/dialogs/CancelPendingOrdersDialog';
+import { CloseAllPositionsConfirmationDialog } from '@/views/dialogs/CloseAllPositionsConfirmationDialog';
 import { ClosePositionDialog } from '@/views/dialogs/ClosePositionDialog';
 import { ComplianceConfigDialog } from '@/views/dialogs/ComplianceConfigDialog';
 import { ConfirmPendingDepositDialog } from '@/views/dialogs/ConfirmPendingDepositDialog';
@@ -69,6 +70,9 @@ export const DialogManager = () => {
     AdjustIsolatedMargin: (args) => <AdjustIsolatedMarginDialog {...args} {...modalProps} />,
     AdjustTargetLeverage: (args) => <AdjustTargetLeverageDialog {...args} {...modalProps} />,
     ClosePosition: (args) => <ClosePositionDialog {...args} {...modalProps} />,
+    CloseAllPositionsConfirmation: (args) => (
+      <CloseAllPositionsConfirmationDialog {...args} {...modalProps} />
+    ),
     CancelAllOrdersConfirmation: (args) => (
       <CancelAllOrdersConfirmationDialog {...args} {...modalProps} />
     ),

src/lib/abacus/index.ts

@@ -8,6 +8,7 @@ import type {
   HistoricalTradingRewardsPeriod,
   HistoricalTradingRewardsPeriods,
   HumanReadableCancelOrderPayload,
+  HumanReadableCloseAllPositionsPayload,
   HumanReadablePlaceOrderPayload,
   HumanReadableSubaccountTransferPayload,
   HumanReadableTriggerOrdersPayload,
@@ -402,6 +403,15 @@ class AbacusStateManager {
     ) => void
   ): Nullable<HumanReadablePlaceOrderPayload> => this.stateManager.commitClosePosition(callback);
 
+  closeAllPositions = (
+    callback: (
+      success: boolean,
+      parsingError: Nullable<ParsingError>,
+      data: Nullable<HumanReadablePlaceOrderPayload>
+    ) => void
+  ): Nullable<HumanReadableCloseAllPositionsPayload> =>
+    this.stateManager.closeAllPositions(callback);
+
   cancelOrder = (
     orderId: string,
     callback: (

src/state/localOrders.ts

@@ -2,13 +2,14 @@ import type { PayloadAction } from '@reduxjs/toolkit';
 import { createSlice } from '@reduxjs/toolkit';
 import _ from 'lodash';
 
-import { Nullable, SubaccountFill, SubaccountOrder } from '@/constants/abacus';
+import { AbacusOrderStatus, Nullable, SubaccountFill, SubaccountOrder } from '@/constants/abacus';
 import { DEFAULT_SOMETHING_WENT_WRONG_ERROR_PARAMS, ErrorParams } from '@/constants/errors';
 import {
   CANCEL_ALL_ORDERS_KEY,
   CancelOrderStatuses,
   LocalCancelAllData,
   LocalCancelOrderData,
+  LocalCloseAllPositionsData,
   LocalPlaceOrderData,
   PlaceOrderStatuses,
   TradeTypes,
@@ -21,13 +22,15 @@ export interface LocalOrdersState {
   localPlaceOrders: LocalPlaceOrderData[];
   localCancelOrders: LocalCancelOrderData[];
   localCancelAlls: Record<string, LocalCancelAllData>;
+  localCloseAllPositions?: LocalCloseAllPositionsData;
   latestOrder?: Nullable<SubaccountOrder>;
 }
 
 const initialState: LocalOrdersState = {
   localPlaceOrders: [],
   localCancelOrders: [],
   localCancelAlls: {},
+  localCloseAllPositions: undefined,
   latestOrder: undefined,
 };
 
@@ -39,12 +42,19 @@ export const localOrdersSlice = createSlice({
       return initialState;
     },
     updateOrders: (state, action: PayloadAction<SubaccountOrder[]>) => {
-      const canceledOrderIdsInPayload = action.payload
-        .filter((order) => isOrderStatusCanceled(order.status))
-        .map((order) => order.id);
+      const { payload: orders } = action;
+      let { localCloseAllPositions } = state;
+      const canceledOrders = orders.filter((order) => isOrderStatusCanceled(order.status));
+      const filledOrderClientIds = orders
+        .filter((order) => order.status === AbacusOrderStatus.Filled)
+        .map((order) => order.clientId)
+        .filter(isTruthy);
 
-      if (!canceledOrderIdsInPayload) return state;
+      // no relevant cancel or filled orders
+      if (!canceledOrders.length && (!localCloseAllPositions || !filledOrderClientIds.length))
+        return state;
 
+      const canceledOrderIdsInPayload = canceledOrders.map((order) => order.id);
       // ignore locally canceled orders since it's intentional and already handled
       // by local cancel tracking and notification
       const isOrderCanceledByBackend = (orderId: string) =>
@@ -56,6 +66,23 @@ export const localOrdersSlice = createSlice({
         return _.uniq([...(batch.canceledOrderIds ?? []), ...newCanceledOrderIds]);
       };
 
+      if (localCloseAllPositions) {
+        localCloseAllPositions = {
+          ...localCloseAllPositions,
+          filledOrderClientIds: _.uniq([
+            ..._.intersection(localCloseAllPositions.submittedOrderClientIds, filledOrderClientIds),
+            ...localCloseAllPositions.filledOrderClientIds,
+          ]),
+          failedOrderClientIds: _.uniq([
+            ..._.intersection(
+              localCloseAllPositions.submittedOrderClientIds,
+              canceledOrders.map((order) => order.clientId)?.filter(isTruthy)
+            ),
+            ...localCloseAllPositions.failedOrderClientIds,
+          ]),
+        };
+      }
+
       return {
         ...state,
         localPlaceOrders: state.localPlaceOrders.map((order) =>
@@ -77,6 +104,7 @@ export const localOrdersSlice = createSlice({
           ...batch,
           canceledOrderIds: getNewCanceledOrderIds(batch),
         })),
+        localCloseAllPositions,
       };
     },
     updateFilledOrders: (state, action: PayloadAction<SubaccountFill[]>) => {
@@ -212,6 +240,13 @@ export const localOrdersSlice = createSlice({
       updateCancelAllOrderIds(state, order.id, 'failedOrderIds', order.marketId);
       if (errorParams) cancelOrderFailed({ orderId: order.id, errorParams });
     },
+    closeAllPositionsSubmitted: (state, action: PayloadAction<string[]>) => {
+      state.localCloseAllPositions = {
+        submittedOrderClientIds: action.payload,
+        filledOrderClientIds: [],
+        failedOrderClientIds: [],
+      };
+    },
   },
 });
 
@@ -232,6 +267,8 @@ export const {
 
   cancelAllSubmitted,
   cancelAllOrderFailed,
+
+  closeAllPositionsSubmitted,
 } = localOrdersSlice.actions;
 
 // helper functions

src/state/localOrdersSelectors.ts

@@ -32,6 +32,12 @@ export const getLocalCancelOrders = (state: RootState) => state.localOrders.loca
  */
 export const getLocalCancelAlls = (state: RootState) => state.localOrders.localCancelAlls;
 
+/**
+ * @returns the local close all positions data for the current FE session
+ */
+export const getLocalCloseAllPositions = (state: RootState) =>
+  state.localOrders.localCloseAllPositions;
+
 /**
  * @returns whether the subaccount has uncommitted orders (local orders that are only submitted and not placed)
  */

src/views/dialogs/CloseAllPositionsConfirmationDialog.tsx

@@ -0,0 +1,34 @@
+import { useCallback } from 'react';
+
+import { ButtonAction, ButtonType } from '@/constants/buttons';
+import { CloseAllPositionsConfirmationDialogProps, DialogProps } from '@/constants/dialogs';
+import { STRING_KEYS } from '@/constants/localization';
+
+import { useStringGetter } from '@/hooks/useStringGetter';
+import { useSubaccount } from '@/hooks/useSubaccount';
+
+import { Button } from '@/components/Button';
+import { Dialog } from '@/components/Dialog';
+
+export const CloseAllPositionsConfirmationDialog = ({
+  setIsOpen,
+}: DialogProps<CloseAllPositionsConfirmationDialogProps>) => {
+  const stringGetter = useStringGetter();
+  const { closeAllPositions } = useSubaccount();
+
+  const onSubmit = useCallback(() => {
+    closeAllPositions();
+    setIsOpen?.(false);
+  }, [closeAllPositions, setIsOpen]);
+
+  return (
+    <Dialog isOpen setIsOpen={setIsOpen} title={stringGetter({ key: STRING_KEYS.CONFIRM })}>
+      <form onSubmit={onSubmit} tw="flex flex-col gap-0.75">
+        <div>{stringGetter({ key: STRING_KEYS.ARE_YOU_SURE_CLOSE_MULTI_POSITION_ALL })}</div>
+        <Button action={ButtonAction.Destroy} type={ButtonType.Submit} tw="w-full">
+          {stringGetter({ key: STRING_KEYS.CLOSE_ALL_POSITIONS })}
+        </Button>
+      </form>
+    </Dialog>
+  );
+};