Differences

This shows you the differences between two versions of the page.

--- developers:websocket:accounts [2025/03/14 23:11] – chad
+++ developers:websocket:accounts [2025/03/15 13:18] (current) – chad
@@ Line 24: / Line 24: @@
 Once subscribed, the server will begin streaming real-time updates for the selected accounts.
-===== Account Snapshot =====
-The **AccountSnapshot** message is a **batch message** that contains the latest state of an account including:
-  * Account balances
-  * Open positions
-  * Working orders
@@ Line 38: / Line 30: @@
 The server sends account-related updates as separate messages. These include:
+  * **AccountSubscribeResponse** – A response message indicating whether the account subscription was successful or not.
+  * **AccountSnapshot** – A batch message containing the latest state of the account.
   * **AccountDetails** – Provides static information about the account.
   * **AccountUpdate** – Sends real-time updates for account values.
   * **AccountPosition** – Reports current open positions.
-  * **AccountSnapshot** – A batch message containing the latest state of the account.
   * **OrderUpdateMulti** – Sends batch updates for a position.
+  * **MarketDetails** – Market details are always sent before a new position is sent to ensure the client has the altest pricing details for the market.
 Example message handling structure:
-<code>
+<code c#>
-```csharp
 private void HandleAccountMessage(ServerMessage serverMessage)
 {
@@ Line 59: / Line 52: @@
         case ServerMessage.PayloadOneofCase.AccountDetails:
             ProcessAccountDetails(serverMessage.AccountDetails);
-            _logger.LogInformation("Received account details: {AccountId}", serverMessage.AccountDetails.AccountId);
             break;
         case ServerMessage.PayloadOneofCase.AccountUpdate:
             ProcessAccountUpdate(serverMessage.AccountUpdate);
-            _logger.LogInformation("Received account update: {AccountId}", serverMessage.AccountUpdate.AccountId);
             break;
         case ServerMessage.PayloadOneofCase.AccountPosition:
             ProcessAccountPosition(serverMessage.AccountPosition);
-            _logger.LogInformation("Received account position: {AccountId}, Market: {MarketId}", serverMessage.AccountPosition.AccountId, serverMessage.AccountPosition.MarketId);
             break;
         case ServerMessage.PayloadOneofCase.AccountSnapshot:
             ProcessAccountSnapshot(serverMessage.AccountSnapshot);
-            _logger.LogInformation("Received account snapshot: {AccountId}", serverMessage.AccountSnapshot.AccountId);
             break;
         case ServerMessage.PayloadOneofCase.OrderUpdateMulti:
             ProcessOrderUpdateMulti(serverMessage.OrderUpdateMulti);
-            _logger.LogInformation("Received order update multi: {AccountId}", serverMessage.OrderUpdateMulti.AccountId);
             break;
         case ServerMessage.PayloadOneofCase.MarketDetails:
             ProcessMarketDetails(serverMessage.MarketDetails);
-            _logger.LogInformation("Received market details: {MarketId}", serverMessage.MarketDetails.MarketId);
             break;
@@ Line 96: / Line 83: @@
+===== Account Snapshot =====
+The **AccountSnapshot** message is a **batch message** that contains the latest state of an account including:
+  * Account balances
+  * Open positions
+  * Working orders
+<code c#>
+private void ProcessAccountSnapshot(AccountSnapshot snapshotMessage)
+{
+      switch (snapshotMessage.PayloadCase)
+      {
+            case AccountSnapshotMessage.PayloadOneofCase.AccountDetails:
+                 _details = snapshotMessage.AccountDetails;
+                 break;
+            case AccountSnapshotMessage.PayloadOneofCase.AccountUpdate:
+                 _update = snapshotMessage.AccountUpdate;
+                 break;
+            case AccountSnapshotMessage.PayloadOneofCase.AccountPosition:
+                 {
+                      var position = _positions.AddOrUpdate(
+                           snapshotMessage.AccountPosition.MarketId,
+                           // Add new Position if key doesn't exist
+                           _ => new Position(this, snapshotMessage.AccountPosition, _loggerFactory.CreateLogger<Position>()),
+                           // Update existing Position
+                           (_, existingPosition) => existingPosition);
+                      if (position != null)
+                      {
+                           position.UpdateWithMessage(snapshotMessage);
+                           updatedPositions.Add(position);
+                      }
+                      _logger.LogInformation("=> SNAPSHOT => AccountPosition: {AccountId} / {MarketID}", snapshotMessage.AccountPosition.AccountId, snapshotMessage.AccountPosition.MarketId);
+                 }
+                 break;
+            case AccountSnapshotMessage.PayloadOneofCase.OrderUpdateMulti:
+                 var orderMultiUpdates = ProcessOrderUpdateMulti(snapshotMessage.OrderUpdateMulti);
+                 updatedOrders.AddRange(orderMultiUpdates.Select(res => res.Order));
+                 updatedTrades.AddRange(orderMultiUpdates.SelectMany(res => res.Trades));
+                 break;
+            default:
+                 _logger.LogInformation($" > Unhandled Snapshot Message: {snapshotMessage.PayloadCase}");
+                 break;
+     }
+}
+</code>