Added cancelContractData and cancelHistoricalTicks requests.

Author: pchavanne

README.md

@@ -8,7 +8,7 @@
 **We will do our best to keep it in sync** with the official API releases to ensure compatibility and feature parity, but users should be aware that this is a community-driven project and may lag behind the official versions at times.
 
 > [!CAUTION]
-> This package is in the **beta phase**. While functional, it may still have bugs or incomplete features. Please test extensively in non-production environments.
+> Please test extensively in non-production environments before relying on it for live trading.
 
 ## Getting Started
 
@@ -83,7 +83,7 @@ For more information on how to use this package, please refer to the [GoDoc](htt
 ## Notice of Non-Affiliation and Disclaimer
 
 > [!CAUTION]
-> This project is in the **beta phase** and is still undergoing testing and development. Users are advised to thoroughly test the software in non-production environments before relying on it for live trading. Features may be incomplete, and bugs may exist. Use at your own risk.
+> Users are advised to thoroughly test the software in non-production environments before relying on it for live trading. Features may be incomplete, and bugs may exist. Use at your own risk.
 
 > [!IMPORTANT]
 > This project is **not affiliated** with Interactive Brokers Group, Inc. All references to Interactive Brokers, including trademarks, logos, and brand names, belong to their respective owners. The use of these names is purely for informational purposes and does not imply endorsement by Interactive Brokers.

client.go

@@ -6329,3 +6329,75 @@ func (c *EClient) reqCurrentTimeInMillisProtoBuf(currentTimeInMillisRequestProto
 
 	c.reqChan <- me.Bytes()
 }
+
+// CancelContractData cancels contract data request.
+func (c *EClient) CancelContractData(reqID int64) {
+	c.cancelContractDataProtoBuf(createCancelContractDataProto(reqID))
+}
+
+func (c *EClient) cancelContractDataProtoBuf(cancelContractDataProto *protobuf.CancelContractData) {
+	reqID := NO_VALID_ID
+	if cancelContractDataProto.ReqId != nil {
+		reqID = int64(*cancelContractDataProto.ReqId)
+	}
+
+	if !c.IsConnected() {
+		c.wrapper.Error(reqID, currentTimeMillis(), NOT_CONNECTED.Code, NOT_CONNECTED.Msg, "")
+		return
+	}
+
+	if c.serverVersion < MIN_SERVER_VER_CANCEL_CONTRACT_DATA {
+		c.wrapper.Error(reqID, currentTimeMillis(), UPDATE_TWS.Code, UPDATE_TWS.Msg+"  It does not support contract data cancels.", "")
+		return
+	}
+
+	me := NewMsgEncoder(1, c)
+
+	me.encodeMsgID(CANCEL_CONTRACT_DATA + PROTOBUF_MSG_ID)
+
+	msg, err := proto.Marshal(cancelContractDataProto)
+	if err != nil {
+		c.wrapper.Error(reqID, currentTimeMillis(), ERROR_ENCODING_PROTOBUF.Code, ERROR_ENCODING_PROTOBUF.Msg+err.Error(), "")
+		return
+	}
+
+	me.encodeProto(msg)
+
+	c.reqChan <- me.Bytes()
+}
+
+// CancelHistoricalTicks cancels historical ticks request.
+func (c *EClient) CancelHistoricalTicks(reqID int64) {
+	c.cancelHistoricalTicksProtoBuf(createCancelHistoricalTicksProto(reqID))
+}
+
+func (c *EClient) cancelHistoricalTicksProtoBuf(cancelHistoricalTicksProto *protobuf.CancelHistoricalTicks) {
+	reqID := NO_VALID_ID
+	if cancelHistoricalTicksProto.ReqId != nil {
+		reqID = int64(*cancelHistoricalTicksProto.ReqId)
+	}
+
+	if !c.IsConnected() {
+		c.wrapper.Error(reqID, currentTimeMillis(), NOT_CONNECTED.Code, NOT_CONNECTED.Msg, "")
+		return
+	}
+
+	if c.serverVersion < MIN_SERVER_VER_CANCEL_CONTRACT_DATA {
+		c.wrapper.Error(reqID, currentTimeMillis(), UPDATE_TWS.Code, UPDATE_TWS.Msg+"  It does not support historical ticks cancels.", "")
+		return
+	}
+
+	me := NewMsgEncoder(1, c)
+
+	me.encodeMsgID(CANCEL_HISTORICAL_TICKS + PROTOBUF_MSG_ID)
+
+	msg, err := proto.Marshal(cancelHistoricalTicksProto)
+	if err != nil {
+		c.wrapper.Error(reqID, currentTimeMillis(), ERROR_ENCODING_PROTOBUF.Code, ERROR_ENCODING_PROTOBUF.Msg+err.Error(), "")
+		return
+	}
+
+	me.encodeProto(msg)
+
+	c.reqChan <- me.Bytes()
+}

client_utils.go

@@ -2049,3 +2049,21 @@ func createUnsubscribeFromGroupEventsRequestProto(reqID int64) *protobuf.Unsubsc
 func createMarketDepthExchangesRequestProto() *protobuf.MarketDepthExchangesRequest {
 	return &protobuf.MarketDepthExchangesRequest{}
 }
+
+func createCancelContractDataProto(reqID int64) *protobuf.CancelContractData {
+	req := &protobuf.CancelContractData{}
+	if isValidInt64Value(reqID) {
+		id := int32(reqID)
+		req.ReqId = &id
+	}
+	return req
+}
+
+func createCancelHistoricalTicksProto(reqID int64) *protobuf.CancelHistoricalTicks {
+	req := &protobuf.CancelHistoricalTicks{}
+	if isValidInt64Value(reqID) {
+		id := int32(reqID)
+		req.ReqId = &id
+	}
+	return req
+}

message.go

@@ -179,6 +179,8 @@ const (
 	CANCEL_WSH_EVENT_DATA         OUT = 103
 	REQ_USER_INFO                 OUT = 104
 	REQ_CURRENT_TIME_IN_MILLIS    OUT = 105
+	CANCEL_CONTRACT_DATA          OUT = 106
+	CANCEL_HISTORICAL_TICKS       OUT = 107
 )
 
 // TWS New Bulletins constants

proto/CancelContractData.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+package protobuf;
+
+option go_package = ".;protobuf";
+
+message CancelContractData {
+    optional int32 reqId = 1;
+}

proto/CancelHistoricalTicks.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+package protobuf;
+
+option go_package = ".;protobuf";
+
+message CancelHistoricalTicks {
+    optional int32 reqId = 1;
+}