blob: 91ba97b17c193126a04517326500ea6fc14983e6 (
plain) (
blame)
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
//
// main.swift
// ADSBDecoder
//
// Created by Jacky Jack on 28/05/2024.
//
import Foundation
import ArgumentParser
import RegexBuilder
import SQLite3
struct CommandLineArgs: ParsableCommand {
@Option(name: .shortAndLong) var inputfile: String
@Flag(name: .shortAndLong) var debug:Bool = false
@Flag(name: .shortAndLong) var version:Bool = false
@Flag(name: .shortAndLong) var show_stats:Bool = false
}
let args = CommandLineArgs.parseOrExit()
let fileUrl = URL(fileURLWithPath:args.inputfile)
print("File location [\(fileUrl.absoluteString)]")
//check if file excists
if (checkIfFileExists(fileUrl.path) == false) {
print("Supplied path \(fileUrl.path) doesnt exists")
exit(1)
}
//load the file with adsb data
var adsb_source = ""
do {
adsb_source = try String(contentsOfFile: fileUrl.path)
print("Loaded \(adsb_source.count) bytes")
} catch {
print("Couldn't load text from a file \(fileUrl.path)")
exit(1)
}
//gather stats
var q_df = QueryDF()
var q_dftc = QueryDF17TC()
var q_decoded = QueryDecodedMessages()
var q_df17_decoded = QueryDF17TC_decoded()
//track all airplanes
var tracker = AirPlaneTracker()
//parse line by line
var count_messages=0
for line in adsb_source.components(separatedBy: .newlines) {
var found=false
//print("\(cnt) \(line)")
count_messages += 1
let matchADSBLong = MatchADSBLong()
//if let tokenMatch = try matchADSBLong.prefixMatch(in: line) {
if let tokenMatch = matchADSBLong.prefixMatch(line) {
print("ADSB Long match \(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() {
//print(d17)
q_dftc.addTC(d17.TypeCode)
q_decoded.addDecoded()
if (d17.TypeCode == 4) {
if let indentification = d17.messageIdentification {
tracker.addDF17Indentification(d17.AddressAnnounced, indentification.ICAOName)
}
q_df17_decoded.addDecoded(4)
} else if (d17.TypeCode >= 9 && d17.TypeCode <= 18) {
if let airbornposition = d17.messageAirbornPositon {
tracker.addDF17AirBornPosition(
d17.AddressAnnounced,
airbornposition.Latitude,
airbornposition.Longitude,
airbornposition.Altitude,
airbornposition.CPRFormat == 0
)
}
q_df17_decoded.addDecoded(d17.TypeCode)
} else {
q_df17_decoded.addUndecode(d17.TypeCode)
}
}
} else {
q_decoded.addUndecoded()
}
q_df.addDF(decoder.DataFormat)
};
/*
if let tokenMatch = try matchADSBShort.prefixMatch(in: line) {
print("\(tokenMatch.output)")
found = true
q_decoded.addUndecoded()
};*/
let matchADSBShort = MatchADSBShort()
if let tokenMatch = matchADSBShort.prefixMatch(line) {
print("ADSBShort Match\(tokenMatch.output)")
found = true
q_decoded.addUndecoded()
}
if (found == false) {
print("Unknown adsb data line \(line)")
}
}
if args.show_stats {
print("----STAT----")
//q_df.showStat()
print(q_df)
print(q_dftc)
print(q_decoded)
print(q_df17_decoded)
tracker.printAllICAOnames()
print("Total message:\(count_messages)")
}
|
