@@ -158,17 +158,23 @@ func main() {
158158 broker .SetPool (pool )
159159
160160 // <--- transport --->
161- orders := make (map [abstraction.PacketId ]struct {})
162- for _ , board := range podData .Boards {
163- for _ , packet := range board .Packets {
164- if packet .Type == "order" {
165- orders [abstraction .PacketId (packet .Id )] = struct {}{}
166- }
167- }
161+ transp := transport .NewTransport ()
162+
163+ // <--- vehicle --->
164+ ipToBoardId := make (map [string ]abstraction.BoardId )
165+ for name , ip := range info .Addresses .Boards {
166+ ipToBoardId [ip .String ()] = abstraction .BoardId (info .BoardIds [name ])
168167 }
169168
170- transp := transport .NewTransport ()
169+ vehicle := vehicle .New ()
170+ vehicle .SetBroker (broker )
171+ vehicle .SetLogger (loggerHandler )
172+ vehicle .SetUpdateFactory (updateFactory )
173+ vehicle .SetIpToBoardId (ipToBoardId )
174+ vehicle .SetIdToBoardName (idToBoard )
175+ vehicle .SetTransport (transp )
171176
177+ // <--- transport --->
172178 // Load and set packet decoder and encoder
173179 decoder , encoder := getTransportDecEnc (info , podData )
174180 transp .WithDecoder (decoder ).WithEncoder (encoder )
@@ -212,20 +218,6 @@ func main() {
212218 }
213219 go transp .HandleSniffer (sniffer .New (source , & layers .LayerTypeEthernet ))
214220
215- // <--- vehicle --->
216- ipToBoardId := make (map [string ]abstraction.BoardId )
217- for name , ip := range info .Addresses .Boards {
218- ipToBoardId [ip .String ()] = abstraction .BoardId (info .BoardIds [name ])
219- }
220-
221- vehicle := vehicle .New ()
222- vehicle .SetBroker (broker )
223- vehicle .SetLogger (loggerHandler )
224- vehicle .SetUpdateFactory (updateFactory )
225- vehicle .SetIpToBoardId (ipToBoardId )
226- vehicle .SetIdToBoardName (idToBoard )
227- vehicle .SetTransport (transp )
228-
229221 // <--- http server --->
230222 podDataHandle , err := h .HandleDataJSON ("podData.json" , pod_data .GetDataOnlyPodData (podData ))
231223 if err != nil {
0 commit comments