some linting things

This commit is contained in:
Joel Wetzell
2026-05-17 09:25:27 -05:00
parent e7bdeb46ff
commit 145c13a976
4 changed files with 28 additions and 14 deletions
+7 -8
View File
@@ -6,12 +6,10 @@ import (
)
type Decoder struct {
lastInfoPacketHeader *chunks.PacketHeaderChunk
lastDataPacketHeader *chunks.PacketHeaderChunk
infoPacketFrames map[uint8][]chunks.InfoPacketChunk
dataPacketFrames map[uint8][]chunks.DataPacketChunk
Trackers map[uint16]*Tracker
SystemName string
infoPacketFrames map[uint8][]chunks.InfoPacketChunk
dataPacketFrames map[uint8][]chunks.DataPacketChunk
Trackers map[uint16]*Tracker
SystemName string
}
func NewDecoder() *Decoder {
@@ -58,7 +56,8 @@ func (d *Decoder) Decode(bytes []byte) error {
return err
}
if chunk.Header.Id == 0x6756 {
switch chunk.Header.Id {
case 0x6756:
infoPacket, err := decoders.DecodeInfoPacketChunk(bytes)
if err != nil {
return err
@@ -76,7 +75,7 @@ func (d *Decoder) Decode(bytes []byte) error {
d.updateInfo(d.infoPacketFrames[currentInfoPacketHeader.Data.FrameId])
delete(d.infoPacketFrames, currentInfoPacketHeader.Data.FrameId)
}
} else if chunk.Header.Id == 0x6755 {
case 0x6755:
dataPacket, err := decoders.DecodeDataPacketChunk(bytes)
if err != nil {
return err
+8 -2
View File
@@ -70,7 +70,10 @@ func benchmark(trackerCount int, iterations int, encoder psn.Encoder, decoder ps
dataDecodedStart := time.Now().UnixMicro()
for range iterations {
for _, packet := range latestEncodedPackets {
decoder.Decode(packet)
err := decoder.Decode(packet)
if err != nil {
fmt.Printf("failed to decode packet, error: %v\n", err)
}
}
}
benchmarkResults.data.decode = float64(time.Now().UnixMicro()-dataDecodedStart) / 1000.0
@@ -85,7 +88,10 @@ func benchmark(trackerCount int, iterations int, encoder psn.Encoder, decoder ps
infoDecodeStart := time.Now().UnixMicro()
for range iterations {
for _, packet := range latestEncodedPackets {
decoder.Decode(packet)
err := decoder.Decode(packet)
if err != nil {
fmt.Printf("failed to decode packet, error: %v\n", err)
}
}
}
benchmarkResults.info.decode = float64(time.Now().UnixMicro()-infoDecodeStart) / 1000.0
+9 -3
View File
@@ -72,13 +72,19 @@ func main() {
slog.Info("Sending Info Packets")
infoPackets := encoder.GetInfoPackets(uint64(timestamp), trackers)
for _, infoPacket := range infoPackets {
client.Write(infoPacket)
_, err := client.Write(infoPacket)
if err != nil {
slog.Error("failed to send info packet", "error", err)
}
}
case <-dataTicker.C:
slog.Info("Sending Data Packets")
dataPackets := encoder.GetDataPackets(uint64(timestamp), trackers)
for _, DataPacket := range dataPackets {
client.Write(DataPacket)
for _, dataPacket := range dataPackets {
_, err := client.Write(dataPacket)
if err != nil {
slog.Error("failed to send data packet", "error", err)
}
}
timestamp += 1
}
+4 -1
View File
@@ -106,6 +106,9 @@ func BenchmarkChunkDecoding(b *testing.B) {
0x80, 0x01, 0x00, 0x0d, 0x80, 0x00, 0x00, 0x09, 0x00, 0x54, 0x72, 0x61, 0x63, 0x6b, 0x65, 0x72, 0x20, 0x31,
}
for b.Loop() {
DecodeChunk(data)
_, err := DecodeChunk(data)
if err != nil {
b.Errorf("failed to decode chunk properly, error: %v", err)
}
}
}