Skip to content

Commit 7f92997

Browse files
Regenerate tests to handle both tcp and udp
1 parent ecba9c1 commit 7f92997

48 files changed

Lines changed: 876 additions & 438 deletions

File tree

Some content is hidden

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

.github/tests/Asx-AsxSecurities-Ntp-Itch-v1-05-Test.sh

Lines changed: 76 additions & 38 deletions
Large diffs are not rendered by default.

.github/tests/B3-B3Derivatives-BinaryEntryPoint-Sbe-v8-0-Test.sh

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,14 @@ set -o pipefail
66
# Give that user write access to the working directory for json output files.
77
chown -R tester:tester .
88

9-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/NegotiateRejectMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
9+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/NegotiateRejectMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
10+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/NegotiateRejectMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
11+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua"; else echo "could not detect transport port for NegotiateRejectMessage"; exit 1; fi
1012

1113
runuser -u tester -- tshark \
1214
-r "omi-data-packets/B3/BinaryEntryPoint.v8.0/NegotiateRejectMessage.pcap" \
1315
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_0_Dissector.lua" \
14-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua" \
16+
-d "$decode" \
1517
-T json \
1618
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json.stderr \
1719
|| { echo "--- tshark FAILED (NegotiateRejectMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json.stderr; exit 1; }
@@ -30,12 +32,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.0.enteringfirmoptional" B3.B3Deri
3032
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.0.negotiationrejectcode" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json
3133
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.0.offset25padding3" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json
3234
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.0.currentsessionverid" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.NegotiateRejectMessage.json
33-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/TerminateMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
35+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/TerminateMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
36+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.0/TerminateMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
37+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua"; else echo "could not detect transport port for TerminateMessage"; exit 1; fi
3438

3539
runuser -u tester -- tshark \
3640
-r "omi-data-packets/B3/BinaryEntryPoint.v8.0/TerminateMessage.pcap" \
3741
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_0_Dissector.lua" \
38-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.0.lua" \
42+
-d "$decode" \
3943
-T json \
4044
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.TerminateMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.TerminateMessage.json.stderr \
4145
|| { echo "--- tshark FAILED (TerminateMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.0.TerminateMessage.json.stderr; exit 1; }

.github/tests/B3-B3Derivatives-BinaryEntryPoint-Sbe-v8-1-Test.sh

Lines changed: 24 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,14 @@ set -o pipefail
66
# Give that user write access to the working directory for json output files.
77
chown -R tester:tester .
88

9-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/EstablishMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
9+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/EstablishMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
10+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/EstablishMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
11+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for EstablishMessage"; exit 1; fi
1012

1113
runuser -u tester -- tshark \
1214
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/EstablishMessage.pcap" \
1315
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
14-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
16+
-d "$decode" \
1517
-T json \
1618
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json.stderr \
1719
|| { echo "--- tshark FAILED (EstablishMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json.stderr; exit 1; }
@@ -31,12 +33,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.nextseqno" B3.B3Derivatives.Bin
3133
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.cancelondisconnecttype" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json
3234
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.offset33padding1" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json
3335
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.codtimeoutwindow" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.EstablishMessage.json
34-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportNewMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
36+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportNewMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
37+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportNewMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
38+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for ExecutionReportNewMessage"; exit 1; fi
3539

3640
runuser -u tester -- tshark \
3741
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportNewMessage.pcap" \
3842
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
39-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
43+
-d "$decode" \
4044
-T json \
4145
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json.stderr \
4246
|| { echo "--- tshark FAILED (ExecutionReportNewMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json.stderr; exit 1; }
@@ -79,12 +83,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.crossprioritization" B3.B3Deriv
7983
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.mmprotectionresetbooleanoptional" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json
8084
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.offset165padding3" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json
8185
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.strategyid" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportNewMessage.json
82-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportTradeMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
86+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportTradeMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
87+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportTradeMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
88+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for ExecutionReportTradeMessage"; exit 1; fi
8389

8490
runuser -u tester -- tshark \
8591
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/ExecutionReportTradeMessage.pcap" \
8692
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
87-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
93+
-d "$decode" \
8894
-T json \
8995
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json.stderr \
9096
|| { echo "--- tshark FAILED (ExecutionReportTradeMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json.stderr; exit 1; }
@@ -130,12 +136,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.crosstype" B3.B3Derivatives.Bin
130136
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.crossprioritization" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json
131137
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.offset159padding1" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json
132138
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.strategyid" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.ExecutionReportTradeMessage.json
133-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/NegotiateMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
139+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/NegotiateMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
140+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/NegotiateMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
141+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for NegotiateMessage"; exit 1; fi
134142

135143
runuser -u tester -- tshark \
136144
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/NegotiateMessage.pcap" \
137145
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
138-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
146+
-d "$decode" \
139147
-T json \
140148
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json.stderr \
141149
|| { echo "--- tshark FAILED (NegotiateMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json.stderr; exit 1; }
@@ -152,12 +160,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.sessionverid" B3.B3Derivatives.
152160
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.timestamp" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json
153161
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.enteringfirm" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json
154162
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.onbehalffirm" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.NegotiateMessage.json
155-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleModifyOrderMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
163+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleModifyOrderMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
164+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleModifyOrderMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
165+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for SimpleModifyOrderMessage"; exit 1; fi
156166

157167
runuser -u tester -- tshark \
158168
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleModifyOrderMessage.pcap" \
159169
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
160-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
170+
-d "$decode" \
161171
-T json \
162172
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json.stderr \
163173
|| { echo "--- tshark FAILED (SimpleModifyOrderMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json.stderr; exit 1; }
@@ -185,12 +195,14 @@ grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.orderqty" B3.B3Derivatives.Bina
185195
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.priceoptional" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json
186196
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.orderidoptional" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json
187197
grep "b3.b3derivatives.binaryentrypoint.sbe.v8.1.origclordid" B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleModifyOrderMessage.json
188-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleNewOrderMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
198+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleNewOrderMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
199+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleNewOrderMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
200+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua"; else echo "could not detect transport port for SimpleNewOrderMessage"; exit 1; fi
189201

190202
runuser -u tester -- tshark \
191203
-r "omi-data-packets/B3/BinaryEntryPoint.v8.1/SimpleNewOrderMessage.pcap" \
192204
-X "lua_script:B3/B3_B3Derivatives_BinaryEntryPoint_Sbe_v8_1_Dissector.lua" \
193-
-d "udp.port==$port,b3.b3derivatives.binaryentrypoint.sbe.v8.1.lua" \
205+
-d "$decode" \
194206
-T json \
195207
> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleNewOrderMessage.json 2> B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleNewOrderMessage.json.stderr \
196208
|| { echo "--- tshark FAILED (SimpleNewOrderMessage) ---"; cat B3.B3Derivatives.BinaryEntryPoint.Sbe.v8.1.SimpleNewOrderMessage.json.stderr; exit 1; }

.github/tests/B3-B3Derivatives-BinaryUmdf-Sbe-v1-8-Test.sh

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,14 @@ set -o pipefail
66
# Give that user write access to the working directory for json output files.
77
chown -R tester:tester .
88

9-
port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryUmdf.v1.8/SecurityDefinitionMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
9+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryUmdf.v1.8/SecurityDefinitionMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
10+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/B3/BinaryUmdf.v1.8/SecurityDefinitionMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
11+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,b3.b3derivatives.binaryumdf.sbe.v1.8.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,b3.b3derivatives.binaryumdf.sbe.v1.8.lua"; else echo "could not detect transport port for SecurityDefinitionMessage"; exit 1; fi
1012

1113
runuser -u tester -- tshark \
1214
-r "omi-data-packets/B3/BinaryUmdf.v1.8/SecurityDefinitionMessage.pcap" \
1315
-X "lua_script:B3/B3_B3Derivatives_BinaryUmdf_Sbe_v1_8_Dissector.lua" \
14-
-d "udp.port==$port,b3.b3derivatives.binaryumdf.sbe.v1.8.lua" \
16+
-d "$decode" \
1517
-T json \
1618
> B3.B3Derivatives.BinaryUmdf.Sbe.v1.8.SecurityDefinitionMessage.json 2> B3.B3Derivatives.BinaryUmdf.Sbe.v1.8.SecurityDefinitionMessage.json.stderr \
1719
|| { echo "--- tshark FAILED (SecurityDefinitionMessage) ---"; cat B3.B3Derivatives.BinaryUmdf.Sbe.v1.8.SecurityDefinitionMessage.json.stderr; exit 1; }

.github/tests/Cboe-ByxEquities-DepthOfBook-Pitch-v2-41-29-Test.sh

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,14 @@ set -o pipefail
66
# Give that user write access to the working directory for json output files.
77
chown -R tester:tester .
88

9-
port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/AddOrderShortMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
9+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/AddOrderShortMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
10+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/AddOrderShortMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
11+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua"; else echo "could not detect transport port for AddOrderShortMessage"; exit 1; fi
1012

1113
runuser -u tester -- tshark \
1214
-r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/AddOrderShortMessage.pcap" \
1315
-X "lua_script:Cboe/Cboe_ByxEquities_DepthOfBook_Pitch_v2_41_29_Dissector.lua" \
14-
-d "udp.port==$port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua" \
16+
-d "$decode" \
1517
-T json \
1618
> Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json 2> Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json.stderr \
1719
|| { echo "--- tshark FAILED (AddOrderShortMessage) ---"; cat Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json.stderr; exit 1; }
@@ -30,12 +32,14 @@ grep "cboe.byxequities.depthofbook.pitch.v2.41.29.quantityshort" Cboe.ByxEquitie
3032
grep "cboe.byxequities.depthofbook.pitch.v2.41.29.symbol" Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json
3133
grep "cboe.byxequities.depthofbook.pitch.v2.41.29.priceshort" Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json
3234
grep "cboe.byxequities.depthofbook.pitch.v2.41.29.addorderflags" Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.AddOrderShortMessage.json
33-
port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/ModifyOrderShortMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
35+
udp_port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/ModifyOrderShortMessage.pcap" -c 1 -T fields -e udp.dstport 2>/dev/null | tr -d '[:space:]')
36+
tcp_port=$(runuser -u tester -- tshark -r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/ModifyOrderShortMessage.pcap" -c 1 -T fields -e tcp.dstport 2>/dev/null | tr -d '[:space:]')
37+
if [ -n "$udp_port" ]; then decode="udp.port==$udp_port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua"; elif [ -n "$tcp_port" ]; then decode="tcp.port==$tcp_port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua"; else echo "could not detect transport port for ModifyOrderShortMessage"; exit 1; fi
3438

3539
runuser -u tester -- tshark \
3640
-r "omi-data-packets/Cboe/Byx.Equities.DepthOfBook.Pitch.v2.41/ModifyOrderShortMessage.pcap" \
3741
-X "lua_script:Cboe/Cboe_ByxEquities_DepthOfBook_Pitch_v2_41_29_Dissector.lua" \
38-
-d "udp.port==$port,cboe.byxequities.depthofbook.pitch.v2.41.29.lua" \
42+
-d "$decode" \
3943
-T json \
4044
> Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.ModifyOrderShortMessage.json 2> Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.ModifyOrderShortMessage.json.stderr \
4145
|| { echo "--- tshark FAILED (ModifyOrderShortMessage) ---"; cat Cboe.ByxEquities.DepthOfBook.Pitch.v2.41.29.ModifyOrderShortMessage.json.stderr; exit 1; }

0 commit comments

Comments
 (0)