OpenCPN Partial API docs
Loading...
Searching...
No Matches
ais_decoder.h
1/***************************************************************************
2 *
3 * Project: OpenCPN
4 *
5 ***************************************************************************
6 * Copyright (C) 2010 by David S. Register *
7 * *
8 * This program is free software; you can redistribute it and/or modify *
9 * it under the terms of the GNU General Public License as published by *
10 * the Free Software Foundation; either version 2 of the License, or *
11 * (at your option) any later version. *
12 * *
13 * This program is distributed in the hope that it will be useful, *
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
16 * GNU General Public License for more details. *
17 * *
18 * You should have received a copy of the GNU General Public License *
19 * along with this program; if not, write to the *
20 * Free Software Foundation, Inc., *
21 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
22 ***************************************************************************
23 */
24
25#ifndef _AIS_DECODER_H__
26#define _AIS_DECODER_H__
27
28#include <map>
29#include <unordered_map>
30#include <memory>
31#include <vector>
32
33#include <wx/datetime.h>
34#include <wx/event.h>
35#include <wx/string.h>
36
37#include "rapidjson/fwd.h"
38#include "model/ais_bitstring.h"
39#include "model/ais_defs.h"
40#include "model/ais_target_data.h"
41#include "model/comm_navmsg.h"
42#include "model/ocpn_types.h"
43#include "model/select.h"
44#include "model/track.h"
45#include "observable_evtvar.h"
46
47class AisDecoder; // forward
48class ArrayOfMmsiProperties; // forward
49
50// AISTargetAlertDialog in gui layer
51extern wxEvtHandler *g_pais_alert_dialog_active;
52
53extern Select *pSelectAIS;
54extern wxString AISTargetNameFileName;
55extern AisDecoder *g_pAIS;
56extern ArrayOfMmsiProperties g_MMSI_Props_Array;
57
58enum AISAudioSoundType {
59 AISAUDIO_NONE,
60 AISAUDIO_CPA,
61 AISAUDIO_SART,
62 AISAUDIO_DSC
63};
64
65class MmsiProperties {
66public:
67 MmsiProperties() {};
68 MmsiProperties(int mmsi) {
69 Init();
70 MMSI = mmsi;
71 }
72 MmsiProperties(wxString &spec);
73
74 ~MmsiProperties();
75
76 wxString Serialize();
77
78 void Init(void);
79 int MMSI;
80 int TrackType;
81 bool m_bignore;
82 bool m_bMOB;
83 bool m_bVDM;
84 bool m_bFollower;
85 bool m_bPersistentTrack;
86 wxString m_ShipName;
87};
88
89WX_DEFINE_ARRAY_PTR(MmsiProperties *, ArrayOfMmsiProperties);
90
91struct AisDecoderCallbacks {
92 std::function<bool()> confirm_stop_track;
93 std::function<int()> get_target_mmsi;
94 AisDecoderCallbacks()
95 : confirm_stop_track([]() { return true; }),
96 get_target_mmsi([]() { return 0; }) {}
97};
98
99class AisDecoder : public wxEvtHandler {
100public:
101 AisDecoder(AisDecoderCallbacks callbacks);
102
103 ~AisDecoder(void);
104
105 AisError DecodeN0183(const wxString &str);
106 std::unordered_map<int, std::shared_ptr<AisTargetData>> &GetTargetList(void) {
107 return AISTargetList;
108 }
109 std::unordered_map<int, std::shared_ptr<AisTargetData>> &
110 GetAreaNoticeSourcesList(void) {
111 return AIS_AreaNotice_Sources;
112 }
113 std::shared_ptr<AisTargetData> Get_Target_Data_From_MMSI(int mmsi);
114 int GetNumTargets(void) { return m_n_targets; }
115 bool IsAISSuppressed(void) { return m_bSuppressed; }
116 bool IsAISAlertGeneral(void) { return m_bGeneralAlert; }
117 AisError DecodeSingleVDO(const wxString &str, GenericPosDatEx *pos,
118 wxString *acc);
119 void DeletePersistentTrack(Track *track);
120 std::map<int, Track *> m_persistent_tracks;
121 bool AIS_AlertPlaying(void) { return m_bAIS_AlertPlaying; };
122
127 EventVar info_update;
128
130 EventVar touch_state;
131
133 EventVar new_ais_wp;
134
136 EventVar new_track;
137
139 EventVar delete_track;
140
142 EventVar plugin_msg;
143
144private:
145 void OnActivate(wxActivateEvent &event);
146 void OnTimerAIS(wxTimerEvent &event);
147 void OnTimerDSC(wxTimerEvent &event);
148
149 bool NMEACheckSumOK(const wxString &str);
150 bool Parse_VDXBitstring(AisBitstring *bstr,
151 std::shared_ptr<AisTargetData> ptd);
152 void UpdateAllCPA(void);
153 void UpdateOneCPA(AisTargetData *ptarget);
154 void UpdateAllAlarms(void);
155 void UpdateAllTracks(void);
156 void UpdateOneTrack(AisTargetData *ptarget);
157 void BuildERIShipTypeHash(void);
158 std::shared_ptr<AisTargetData> ProcessDSx(const wxString &str,
159 bool b_take_dsc = false);
160
161 wxString DecodeDSEExpansionCharacters(wxString dseData);
162 void getAISTarget(long mmsi, std::shared_ptr<AisTargetData> &pTargetData,
163 std::shared_ptr<AisTargetData> &pStaleTarget,
164 bool &bnewtarget, int &last_report_ticks, wxDateTime &now);
165 void getMmsiProperties(std::shared_ptr<AisTargetData> &pTargetData);
166 void handleUpdate(std::shared_ptr<AisTargetData> pTargetData, bool bnewtarget,
167 const rapidjson::Value &update);
168 void updateItem(std::shared_ptr<AisTargetData> pTargetData, bool bnewtarget,
169 const rapidjson::Value &item, wxString &sfixtime) const;
170 void CommitAISTarget(std::shared_ptr<AisTargetData> pTargetData,
171 const wxString &str, bool message_valid,
172 bool new_target);
173 void InitCommListeners(void);
174 bool HandleN0183_AIS(std::shared_ptr<const Nmea0183Msg> n0183_msg);
175 void HandleSignalK(std::shared_ptr<const SignalkMsg> sK_msg);
176
177 bool HandleN2K_129038(std::shared_ptr<const Nmea2000Msg> n2k_msg);
178 bool HandleN2K_129039(std::shared_ptr<const Nmea2000Msg> n2k_msg);
179 bool HandleN2K_129041(std::shared_ptr<const Nmea2000Msg> n2k_msg);
180 bool HandleN2K_129794(std::shared_ptr<const Nmea2000Msg> n2k_msg);
181 bool HandleN2K_129809(std::shared_ptr<const Nmea2000Msg> n2k_msg);
182 bool HandleN2K_129810(std::shared_ptr<const Nmea2000Msg> n2k_msg);
183 bool HandleN2K_129793(std::shared_ptr<const Nmea2000Msg> n2k_msg);
184
185 wxString m_signalk_selfid;
186 std::unordered_map<int, std::shared_ptr<AisTargetData>> AISTargetList;
187 std::unordered_map<int, std::shared_ptr<AisTargetData>>
188 AIS_AreaNotice_Sources;
189 AIS_Target_Name_Hash *AISTargetNamesC;
190 AIS_Target_Name_Hash *AISTargetNamesNC;
191
192 ObservableListener listener_N0183_VDM;
193 ObservableListener listener_N0183_FRPOS;
194 ObservableListener listener_N0183_CDDSC;
195 ObservableListener listener_N0183_CDDSE;
196 ObservableListener listener_N0183_TLL;
197 ObservableListener listener_N0183_TTM;
198 ObservableListener listener_N0183_OSD;
199 ObservableListener listener_N0183_WPL;
200 ObservableListener listener_SignalK;
201
202 ObservableListener listener_N2K_129038;
203 ObservableListener listener_N2K_129039;
204 ObservableListener listener_N2K_129041;
205 ObservableListener listener_N2K_129794;
206 ObservableListener listener_N2K_129809;
207 ObservableListener listener_N2K_129810;
208 ObservableListener listener_N2K_129793;
209
210 bool m_busy;
211 wxTimer TimerAIS;
212 wxFrame *m_parent_frame;
213 AisDecoderCallbacks m_callbacks;
214
215 int nsentences;
216 int isentence;
217 wxString sentence_accumulator;
218 bool m_OK;
219
220 std::shared_ptr<AisTargetData> m_pLatestTargetData;
221
222 bool m_bAIS_Audio_Alert_On;
223 wxTimer m_AIS_Audio_Alert_Timer;
224 int m_n_targets;
225 bool m_bSuppressed;
226 bool m_bGeneralAlert;
227 std::shared_ptr<AisTargetData> m_ptentative_dsctarget;
228 wxTimer m_dsc_timer;
229 wxString m_dsc_last_string;
230 std::vector<int> m_MMSI_MismatchVec;
231
232 bool m_bAIS_AlertPlaying;
233 DECLARE_EVENT_TABLE()
234};
235
236#endif // _AIS_DECODER_H__
AisDecoder::plugin_msg
EventVar plugin_msg
A JSON message should be sent.
Definition ais_decoder.h:142
AisDecoder::new_track
EventVar new_track
Notified on new track creation.
Definition ais_decoder.h:136
AisDecoder::new_ais_wp
EventVar new_ais_wp
Notified when new AIS wp is created.
Definition ais_decoder.h:133
AisDecoder::info_update
EventVar info_update
Notified when AIS user dialogs should update.
Definition ais_decoder.h:127
AisDecoder::delete_track
EventVar delete_track
Notified when about to delete track.
Definition ais_decoder.h:139
AisDecoder::touch_state
EventVar touch_state
Notified when gFrame->TouchAISActive() should be invoked.
Definition ais_decoder.h:130
EventVar
Generic event handling between MVC Model and Controller based on a shared EventVar variable.
Definition observable_evtvar.h:71
ObservableListener
Keeps listening over it's lifespan, removes itself on destruction.
Definition observable.h:131
Track
Represents a track, which is a series of connected track points.
Definition track.h:78
comm_navmsg.h
Raw, undecoded messages definitions.