Skip to content

Commit f0e3b8c

Browse files
committed
Added account/positions protobuf support
1 parent db70d64 commit f0e3b8c

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

55 files changed

+4469
-43
lines changed

client.go

Lines changed: 273 additions & 17 deletions
Large diffs are not rendered by default.

client_utils.go

Lines changed: 120 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1024,3 +1024,123 @@ func createCancelMarketDepthProto(reqID int64, isSmartDepth bool) *protobuf.Canc
10241024

10251025
return cancelMarketDepthProto
10261026
}
1027+
1028+
func createAccountDataRequestProto(subscribe bool, acctCode string) *protobuf.AccountDataRequest {
1029+
accountDataRequestProto := &protobuf.AccountDataRequest{}
1030+
1031+
if subscribe {
1032+
accountDataRequestProto.Subscribe = &subscribe
1033+
}
1034+
1035+
if !stringIsEmpty(acctCode) {
1036+
accountDataRequestProto.AcctCode = &acctCode
1037+
}
1038+
1039+
return accountDataRequestProto
1040+
}
1041+
1042+
func createManagedAccountsRequestProto() *protobuf.ManagedAccountsRequest {
1043+
return &protobuf.ManagedAccountsRequest{}
1044+
}
1045+
1046+
func createPositionsRequestProto() *protobuf.PositionsRequest {
1047+
return &protobuf.PositionsRequest{}
1048+
}
1049+
1050+
func createCancelPositionsRequestProto() *protobuf.CancelPositions {
1051+
return &protobuf.CancelPositions{}
1052+
}
1053+
1054+
func createAccountSummaryRequestProto(reqID int64, group string, tags string) *protobuf.AccountSummaryRequest {
1055+
accountSummaryRequestProto := &protobuf.AccountSummaryRequest{}
1056+
1057+
if isValidInt64Value(reqID) {
1058+
id := int32(reqID)
1059+
accountSummaryRequestProto.ReqId = &id
1060+
}
1061+
1062+
if !stringIsEmpty(group) {
1063+
accountSummaryRequestProto.Group = &group
1064+
}
1065+
1066+
if !stringIsEmpty(tags) {
1067+
accountSummaryRequestProto.Tags = &tags
1068+
}
1069+
1070+
return accountSummaryRequestProto
1071+
}
1072+
1073+
func createCancelAccountSummaryRequestProto(reqID int64) *protobuf.CancelAccountSummary {
1074+
cancelAccountSummaryProto := &protobuf.CancelAccountSummary{}
1075+
1076+
if isValidInt64Value(reqID) {
1077+
id := int32(reqID)
1078+
cancelAccountSummaryProto.ReqId = &id
1079+
}
1080+
1081+
return cancelAccountSummaryProto
1082+
}
1083+
1084+
func createPositionsMultiRequestProto(reqID int64, account string, modelCode string) *protobuf.PositionsMultiRequest {
1085+
positionsMultiRequestProto := &protobuf.PositionsMultiRequest{}
1086+
1087+
if isValidInt64Value(reqID) {
1088+
id := int32(reqID)
1089+
positionsMultiRequestProto.ReqId = &id
1090+
}
1091+
1092+
if !stringIsEmpty(account) {
1093+
positionsMultiRequestProto.Account = &account
1094+
}
1095+
1096+
if !stringIsEmpty(modelCode) {
1097+
positionsMultiRequestProto.ModelCode = &modelCode
1098+
}
1099+
1100+
return positionsMultiRequestProto
1101+
}
1102+
1103+
func createCancelPositionsMultiRequestProto(reqID int64) *protobuf.CancelPositionsMulti {
1104+
cancelPositionsMultiProto := &protobuf.CancelPositionsMulti{}
1105+
1106+
if isValidInt64Value(reqID) {
1107+
id := int32(reqID)
1108+
cancelPositionsMultiProto.ReqId = &id
1109+
}
1110+
1111+
return cancelPositionsMultiProto
1112+
}
1113+
1114+
func createAccountUpdatesMultiRequestProto(reqID int64, account string, modelCode string, ledgerAndNLV bool) *protobuf.AccountUpdatesMultiRequest {
1115+
accountUpdatesMultiRequestProto := &protobuf.AccountUpdatesMultiRequest{}
1116+
1117+
if isValidInt64Value(reqID) {
1118+
id := int32(reqID)
1119+
accountUpdatesMultiRequestProto.ReqId = &id
1120+
}
1121+
1122+
if !stringIsEmpty(account) {
1123+
accountUpdatesMultiRequestProto.Account = &account
1124+
}
1125+
1126+
if !stringIsEmpty(modelCode) {
1127+
accountUpdatesMultiRequestProto.ModelCode = &modelCode
1128+
}
1129+
1130+
if ledgerAndNLV {
1131+
accountUpdatesMultiRequestProto.LedgerAndNLV = &ledgerAndNLV
1132+
}
1133+
1134+
return accountUpdatesMultiRequestProto
1135+
}
1136+
1137+
func createCancelAccountUpdatesMultiRequestProto(reqID int64) *protobuf.CancelAccountUpdatesMulti {
1138+
cancelAccountUpdatesMultiProto := &protobuf.CancelAccountUpdatesMulti{}
1139+
1140+
if isValidInt64Value(reqID) {
1141+
id := int32(reqID)
1142+
cancelAccountUpdatesMultiProto.ReqId = &id
1143+
}
1144+
1145+
return cancelAccountUpdatesMultiProto
1146+
}

0 commit comments

Comments
 (0)