onMessage method

@override Future<void> onMessage(dynamic message)

Handle incoming messages with command/event routing

Implementation

@override
Future<void> onMessage(dynamic message) async {
  // Capture sender at the START of message processing, keyed by command ID
  // This handles concurrent message processing where multiple commands
  // may be processed at the same time
  String? commandKey;
  if (message is Command && context.sender != null) {
    commandKey = message.commandId;
    _capturedSenders[commandKey] = context.sender!;
  }

  try {
    if (message is Command) {

      // Check if this is a duplicate command
      if (message is CreateWalletCommand) {
        try {
          if (currentState.isCreated) {
            return;
          }
        } catch (e) {
          _log.warning('Failed to check duplicate CreateWalletCommand: $e');
        }
      }
    } else {
    }
    await super.onMessage(message);
  } catch (e, stack) {
    rethrow;
  } finally {
    // Clean up the captured sender for this specific command
    if (commandKey != null) {
      _capturedSenders.remove(commandKey);
    }
  }
}