Skip to content

Commit 06cac61

Browse files
committed
feat: store decipher packet in gt client
1 parent 0aefed7 commit 06cac61

File tree

1 file changed

+14
-12
lines changed

1 file changed

+14
-12
lines changed

telemetry_client.go

Lines changed: 14 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -41,12 +41,13 @@ type Config struct {
4141
}
4242

4343
type GTClient struct {
44-
logger *utils.Logger
45-
ipAddr string
46-
sendPort int
47-
receivePort int
48-
Statistics *statistics
49-
Telemetry *transformer
44+
logger *utils.Logger
45+
ipAddr string
46+
sendPort int
47+
receivePort int
48+
DecipheredPacket []byte
49+
Statistics *statistics
50+
Telemetry *transformer
5051
}
5152

5253
func NewGTClient(config Config) (*GTClient, error) {
@@ -68,10 +69,11 @@ func NewGTClient(config Config) (*GTClient, error) {
6869
}
6970

7071
return &GTClient{
71-
logger: logger,
72-
ipAddr: config.IPAddr,
73-
sendPort: 33739,
74-
receivePort: 33740,
72+
logger: logger,
73+
ipAddr: config.IPAddr,
74+
sendPort: 33739,
75+
receivePort: 33740,
76+
DecipheredPacket: []byte{},
7577
Statistics: &statistics{
7678
enabled: config.StatsEnabled,
7779
decodeTimeLast: time.Duration(0),
@@ -129,9 +131,9 @@ func (c *GTClient) Run() {
129131

130132
decodeStart := time.Now()
131133

132-
telemetryData := salsa20Decode(buffer[:bufLen])
134+
c.DecipheredPacket = salsa20Decode(buffer[:bufLen])
133135

134-
reader := bytes.NewReader(telemetryData)
136+
reader := bytes.NewReader(c.DecipheredPacket)
135137
stream := kaitai.NewStream(reader)
136138

137139
err = rawTelemetry.Read(stream, nil, nil)

0 commit comments

Comments
 (0)