1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
//
// ADSBNetRunner.swift
// LearnMapKit
//
// Created by Jacky Jack on 05/08/2024.
//
import Foundation
class ADSBNetRunner {
var address = ""
var port = 0
var tracker = AirPlaneTracker()
var adsb_tag_stream = ADSBDataQueue()
var ADSBClient:NetADSBDecoder!
var timer: Timer?
init(address:String, port:Int) {
self.address = address
self.port = port
}
func start() {
var found: Bool = false
let adsb_net_decoder = NetADSBDecoder(host: self.address, port: self.port)
//var _adsb_tag_stream = ADSBDataQueue()
//var _tracker = AirPlaneTracker()
//print("_start ADSBNetRunner")
timer = Timer.scheduledTimer(
withTimeInterval: 1,
repeats: true
) { _ in
//print("Timer drain queue")
//print("\(adsb_net_decoder.msgarray.message_array.count)")
if adsb_net_decoder.msgarray.message_array.count > 0 {
//print(adsb_net_decoder.msgarray.message_array.count)
for _ in 0..<adsb_net_decoder.msgarray.message_array.count-1 {
found = false
//print(adsb_net_decoder.msgarray.message_array.popLast()!,terminator: "")
if let msg = adsb_net_decoder.msgarray.message_array.popLast() {
//print("msg:[\(msg)]")
do {
if let tokenMatch = try matchADSBLong.prefixMatch(in: msg) {
//print("token output \(String(tokenMatch.output))")
found = true
let str = String(tokenMatch.output)
let startIndex = str.index(str.startIndex, offsetBy: 1)
let endIndex = str.index(str.endIndex, offsetBy: -2)
let decoder = Decoder(String(str[startIndex...endIndex]))
if decoder.DataFormat == 17 {
if let d17 = decoder.getDataFormat17() {
if (d17.TypeCode == 4) {
if let indentification = d17.messageIdentification {
self.tracker.addDF17Indentification(d17.AddressAnnounced, indentification.ICAOName)
self.adsb_tag_stream.addIcaoName(d17.AddressAnnounced, self.tracker.getICAOname(d17.AddressAnnounced)!)
}
} else if (d17.TypeCode >= 9 && d17.TypeCode <= 18) {
if let airbornposition = d17.messageAirbornPositon {
self.tracker.addDF17AirBornPosition(
d17.AddressAnnounced,
airbornposition.Latitude,
airbornposition.Longitude,
airbornposition.Altitude,
airbornposition.CPRFormat == 0
)
if let position = self.tracker.getPosition(d17.AddressAnnounced) {
//print("position: \(position)")
self.adsb_tag_stream.addAltitude(d17.AddressAnnounced, self.tracker.getAltitude(d17.AddressAnnounced)!)
let location = self.tracker.getPosition(d17.AddressAnnounced)!
self.adsb_tag_stream.addLocation(d17.AddressAnnounced, location.0, location.1)
}
}
}
}
}
};
} catch {
print("Error")
}
if (found == false) {
//print("Unknown adsb data line [\(msg)]")
}
}
}
}
}
DispatchQueue.global(qos: .background).async {
do {
try adsb_net_decoder.start()
} catch let error {
print("Error: \(error.localizedDescription)")
adsb_net_decoder.stop()
}
}
}
func getDataOut() {
}
func stop() {
}
func getCount() -> Int {
return self.adsb_tag_stream.getCount()
}
}
|
