@@ -7,17 +7,15 @@ import (
77 "net"
88 "time"
99
10- adj_module "github.com/HyperloopUPV-H8/h9-backend/internal/adj"
1110 "github.com/HyperloopUPV-H8/h9-backend/internal/common"
1211 "github.com/HyperloopUPV-H8/h9-backend/internal/config"
1312 "github.com/HyperloopUPV-H8/h9-backend/internal/pod_data"
1413 "github.com/HyperloopUPV-H8/h9-backend/internal/utils"
1514 "github.com/HyperloopUPV-H8/h9-backend/pkg/abstraction"
16- "github.com/HyperloopUPV-H8/h9-backend/pkg/boards "
15+ adj_module "github.com/HyperloopUPV-H8/h9-backend/pkg/adj "
1716 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport"
1817 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/network/tcp"
1918 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/network/udp"
20- blcu_packet "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/packet/blcu"
2119 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/packet/data"
2220 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/packet/order"
2321 "github.com/HyperloopUPV-H8/h9-backend/pkg/transport/packet/protection"
@@ -45,11 +43,6 @@ func configureTransport(
4543 transp .SetTargetIp (adj .Info .Addresses [board .Name ], abstraction .TransportTarget (board .Name ))
4644 }
4745
48- // If BLCU is configured set BLCU packet ID mappings
49- if common .Contains (config .Vehicle .Boards , "BLCU" ) {
50- configureBLCUTransport (adj , transp , config )
51- }
52-
5346 // Start handling TCP CLIENT connections
5447 configureTCPClientTransport (adj , podData , transp , config )
5548
@@ -61,36 +54,6 @@ func configureTransport(
6154
6255}
6356
64- // configureBLCUTransport sets the packet IDs and target IP for the BLCU board.
65- // It prefers values from config, falls back to ADJ and finally to a loopback default.
66- func configureBLCUTransport (adj adj_module.ADJ ,
67- transp * transport.Transport ,
68- config config.Config ) {
69- // Use configurable packet IDs or defaults
70- downloadOrderID := config .Blcu .DownloadOrderId
71- uploadOrderID := config .Blcu .UploadOrderId
72- if downloadOrderID == 0 {
73- downloadOrderID = boards .DefaultBlcuDownloadOrderId
74- }
75- if uploadOrderID == 0 {
76- uploadOrderID = boards .DefaultBlcuUploadOrderId
77- }
78-
79- transp .SetIdTarget (abstraction .PacketId (downloadOrderID ), abstraction .TransportTarget ("BLCU" ))
80- transp .SetIdTarget (abstraction .PacketId (uploadOrderID ), abstraction .TransportTarget ("BLCU" ))
81-
82- // Use BLCU address from config, ADJ, or default
83- blcuIP := config .Blcu .IP
84- if blcuIP == "" {
85- if adjBlcuIP , exists := adj .Info .Addresses [BLCU ]; exists {
86- blcuIP = adjBlcuIP
87- } else {
88- blcuIP = "127.0.0.1"
89- }
90- }
91- transp .SetTargetIp (blcuIP , abstraction .TransportTarget ("BLCU" ))
92- }
93-
9457func configureTCPClientTransport (
9558 adj adj_module.ADJ ,
9659 podData pod_data.PodData ,
@@ -247,9 +210,6 @@ func getTransportDecEnc(info adj_module.Info, podData pod_data.PodData) (*presen
247210 encoder .SetPacketEncoder (id , dataEncoder )
248211 }
249212
250- // Register BLCU ack decoder
251- decoder .SetPacketDecoder (abstraction .PacketId (info .MessageIds [BlcuAck ]), blcu_packet .NewDecoder ())
252-
253213 // TODO Solve this foking mess, I have tried...
254214 stateOrdersDecoder := order .NewDecoder (binary .LittleEndian )
255215 stateOrdersDecoder .SetActionId (abstraction .PacketId (info .MessageIds [AddStateOrder ]), stateOrdersDecoder .DecodeAdd )
0 commit comments