Operaciones de negociación

Al crear su propio adaptador para una bolsa, implemente los métodos que realizan las operaciones de negociación: registro, reemplazo y cancelación de órdenes. Estos métodos se llaman cuando el adaptador recibe los mensajes correspondientes del núcleo de StockSharp.

Registro de órdenes

Para registrar una nueva orden, se implementa el método RegisterOrderAsync. Este método se llama al recibir el mensaje OrderRegisterMessage.

Los pasos principales al registrar una orden:

Comprobación del tipo de orden y las condiciones adicionales.
Conversión de los parámetros de la orden a un formato comprensible para la bolsa.
Envío de una solicitud para registrar la orden a través de la API de la bolsa.
Procesamiento de la respuesta de la bolsa y envío del mensaje ExecutionMessage correspondiente.

public override async ValueTask RegisterOrderAsync(OrderRegisterMessage regMsg, CancellationToken cancellationToken)
{
	var condition = (CoinbaseOrderCondition)regMsg.Condition;

	switch (regMsg.OrderType)
	{
		case null:
		case OrderTypes.Limit:
		case OrderTypes.Market:
			break;
		case OrderTypes.Conditional:
		{
			// Procesar órdenes condicionales, por ejemplo, retiro de fondos
			if (!condition.IsWithdraw)
				break;

			var withdrawId = await _restClient.Withdraw(regMsg.SecurityId.SecurityCode, regMsg.Volume, condition.WithdrawInfo, cancellationToken);

			await SendOutMessageAsync(new ExecutionMessage
			{
				DataTypeEx = DataType.Transactions,
				OrderStringId = withdrawId,
				ServerTime = CurrentTime.ConvertToUtc(),
				OriginalTransactionId = regMsg.TransactionId,
				OrderState = OrderStates.Done,
				HasOrderInfo = true,
			}, cancellationToken);

			await PortfolioLookupAsync(null, cancellationToken);
			return;
		}
		default:
			throw new NotSupportedException(LocalizedStrings.OrderUnsupportedType.Put(regMsg.OrderType, regMsg.TransactionId));
	}

	// Determinar el tipo de orden (de mercado o limitada)
	var isMarket = regMsg.OrderType == OrderTypes.Market;
	var price = isMarket ? (decimal?)null : regMsg.Price;

	// Enviar orden a la bolsa
	var result = await _restClient.RegisterOrder(
		regMsg.TransactionId.To<string>(), regMsg.SecurityId.ToSymbol(),
		regMsg.OrderType.ToNative(), regMsg.Side.ToNative(), price,
		condition?.StopPrice, regMsg.Volume, regMsg.TimeInForce,
		regMsg.TillDate.EnsureToday(), regMsg.Leverage, cancellationToken);

	var orderState = result.Status.ToOrderState();

	// Procesar resultado de registro de la orden
	if (orderState == OrderStates.Failed)
	{
		await SendOutMessageAsync(new ExecutionMessage
		{
			DataTypeEx = DataType.Transactions,
			ServerTime = result.CreationTime,
			OriginalTransactionId = regMsg.TransactionId,
			OrderState = OrderStates.Failed,
			Error = new InvalidOperationException(),
			HasOrderInfo = true,
		}, cancellationToken);
	}
}

Reemplazo de órdenes

Para reemplazar una orden existente, se implementa el método ReplaceOrderAsync. Este método se llama al recibir el mensaje OrderReplaceMessage.

Los pasos principales al reemplazar una orden:

Comprobación de la posibilidad de reemplazar la orden en la bolsa.
Envío de una solicitud para reemplazar la orden a través de la API de la bolsa.
Procesamiento de la respuesta de la bolsa y envío del mensaje ExecutionMessage correspondiente.

public override async ValueTask ReplaceOrderAsync(OrderReplaceMessage replaceMsg, CancellationToken cancellationToken)
{
	// Enviar solicitud para reemplazar la orden
	await _restClient.EditOrder(
		replaceMsg.OldOrderId.To<string>(),
		replaceMsg.Price,
		replaceMsg.Volume,
		cancellationToken);

	// Nota: el procesamiento del resultado de reemplazo de la orden suele ocurrir
	// en un método separado que se llama al recibir una actualización de la bolsa
}

Particularidades del reemplazo de órdenes

Al implementar el reemplazo de órdenes, tenga en cuenta el protocolo de la bolsa. StockSharp proporciona la propiedad MessageAdapter.IsReplaceCommandEditCurrent para ello.

Si el protocolo de la bolsa modifica una orden manteniendo el identificador antiguo, sobrescriba esta propiedad y devuelva true. Esto le indica a StockSharp que el reemplazo de una orden no debe esperar un nuevo identificador de la bolsa.

public override bool IsReplaceCommandEditCurrent => true;

Si, al cambiar una orden, la antigua se cancela y se registra una nueva con un nuevo identificador de bolsa, entonces no es necesario sobrescribir esta propiedad. Por defecto, devuelve false, lo que corresponde al comportamiento de la mayoría de las bolsas.

Cancelación de órdenes

Para cancelar una orden existente, se implementa el método CancelOrderAsync. Este método se llama al recibir el mensaje OrderCancelMessage.

Los pasos principales al cancelar una orden:

Comprobación de la presencia del identificador de la orden.
Envío de una solicitud para cancelar la orden a través de la API de la bolsa.
Procesamiento de la respuesta de la bolsa y envío del mensaje ExecutionMessage correspondiente.

public override async ValueTask CancelOrderAsync(OrderCancelMessage cancelMsg, CancellationToken cancellationToken)
{
	// Comprobar la presencia del identificador de la orden
	if (cancelMsg.OrderStringId.IsEmpty())
		throw new InvalidOperationException(LocalizedStrings.OrderNoExchangeId.Put(cancelMsg.OriginalTransactionId));

	// Enviar solicitud para cancelar la orden
	await _restClient.CancelOrder(cancelMsg.OrderStringId, cancellationToken);

	// Nota: el procesamiento del resultado de cancelación de la orden suele ocurrir
	// en un método separado que se llama al recibir una actualización de la bolsa
}

Cancelación masiva de órdenes

Algunas bolsas admiten la función de cancelación masiva de órdenes, que permite cancelar varias o todas las órdenes activas con una sola solicitud. Esto puede ser útil para cerrar posiciones rápidamente o limpiar el libro de órdenes bajo ciertas condiciones de mercado.

Para implementar la cancelación masiva de órdenes en el adaptador, normalmente se utiliza el método CancelOrderGroupAsync. Este método se llama al recibir el mensaje OrderGroupCancelMessage.

No todas las bolsas admiten esta función. Por ejemplo, Coinbase no proporciona una API para la cancelación masiva de órdenes. En tales casos, implemente la cancelación secuencial de órdenes individuales si es necesario.

A continuación se muestra un ejemplo de implementación del método de cancelación masiva de órdenes, tomado del conector BitStamp, que admite esta función:

public override async ValueTask CancelOrderGroupAsync(OrderGroupCancelMessage cancelMsg, CancellationToken cancellationToken)
{
	await _httpClient.CancelAllOrders(cancellationToken);
}

No elimine el soporte de este tipo de comando en el constructor del adaptador:

//this.RemoveSupportedMessage(MessageTypes.OrderGroupCancel);

Seguimiento del estado de las órdenes

En el caso de Coinbase, así como de algunas otras bolsas modernas, las actualizaciones del estado de las órdenes se transmiten a través de una conexión WebSocket. Esto significa que, después de realizar operaciones de negociación (registro, reemplazo o cancelación de una orden), no es necesario solicitar inmediatamente el nuevo estado de la orden a través de la API REST. En su lugar, el adaptador recibirá las actualizaciones automáticamente a través de la conexión WebSocket establecida.

El procesamiento de estas actualizaciones ocurre en un método similar a SessionOnOrderReceived, que se trató en la sección sobre solicitud del estado actual de la cartera y las órdenes. Este método se llama cada vez que la bolsa envía una actualización sobre el estado de la orden, independientemente de si esta actualización fue provocada por acciones del usuario o por cambios en la propia bolsa.

Este enfoque permite realizar un seguimiento más eficiente de los estados de las órdenes, reduce la carga sobre la API de la bolsa y proporciona actualizaciones en tiempo real. Al implementar su propio adaptador, estudie cuidadosamente la documentación de la API de la bolsa para que estas actualizaciones de WebSocket se configuren y manejen correctamente.

Manejo de errores

Al realizar operaciones de negociación, maneje correctamente los posibles errores y excepciones. Si se produce un error, envíe un mensaje ExecutionMessage con la propiedad Error establecida.

Particularidades de la implementación

Al implementar los métodos de operaciones de negociación, tenga en cuenta las particularidades de cada bolsa en concreto:

Tipos de órdenes admitidos (mercado, límite, órdenes stop, etc.).
Formato de los identificadores de órdenes.
Particularidades de la API de la bolsa para trabajar con órdenes.
Posibles restricciones sobre la frecuencia de envío de solicitudes.