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;
57extern int g_OwnShipmmsi;
58
59enum AISAudioSoundType {
60 AISAUDIO_NONE,
61 AISAUDIO_CPA,
62 AISAUDIO_SART,
63 AISAUDIO_DSC
64};
65
66class MmsiProperties {
67public:
68 MmsiProperties() {};
69 MmsiProperties(int mmsi) {
70 Init();
71 MMSI = mmsi;
72 }
73 MmsiProperties(wxString &spec);
74
75 ~MmsiProperties();
76
77 wxString Serialize();
78
79 void Init(void);
80 int MMSI;
81 int TrackType;
82 bool m_bignore;
83 bool m_bMOB;
84 bool m_bVDM;
85 bool m_bFollower;
86 bool m_bPersistentTrack;
87 wxString m_ShipName;
88};
89
90WX_DEFINE_ARRAY_PTR(MmsiProperties *, ArrayOfMmsiProperties);
91
92struct AisDecoderCallbacks {
93 std::function<bool()> confirm_stop_track;
94 std::function<int()> get_target_mmsi;
95 AisDecoderCallbacks()
96 : confirm_stop_track([]() { return true; }),
97 get_target_mmsi([]() { return 0; }) {}
98};
99
100class AisDecoder : public wxEvtHandler {
101public:
102 AisDecoder(AisDecoderCallbacks callbacks);
103
104 ~AisDecoder(void);
105
106 AisError DecodeN0183(const wxString &str);
107 std::unordered_map<int, std::shared_ptr<AisTargetData>> &GetTargetList(void) {
108 return AISTargetList;
109 }
110 std::unordered_map<int, std::shared_ptr<AisTargetData>> &
111 GetAreaNoticeSourcesList(void) {
112 return AIS_AreaNotice_Sources;
113 }
114 std::shared_ptr<AisTargetData> Get_Target_Data_From_MMSI(int mmsi);
115 int GetNumTargets(void) { return m_n_targets; }
116 bool IsAISSuppressed(void) { return m_bSuppressed; }
117 bool IsAISAlertGeneral(void) { return m_bGeneralAlert; }
118 void UpdateMMSItoNameFile(const wxString &mmsi, const wxString &name);
119 wxString GetMMSItoNameEntry(const wxString &mmsi);
120 AisError DecodeSingleVDO(const wxString &str, GenericPosDatEx *pos,
121 wxString *acc);
122 void DeletePersistentTrack(Track *track);
123 std::map<int, Track *> m_persistent_tracks;
124 bool AIS_AlertPlaying(void) { return m_bAIS_AlertPlaying; };
125
130 EventVar info_update;
131
133 EventVar touch_state;
134
136 EventVar new_ais_wp;
137
139 EventVar new_track;
140
142 EventVar delete_track;
143
145 EventVar plugin_msg;
146
147private:
148 void OnActivate(wxActivateEvent &event);
149 void OnTimerAIS(wxTimerEvent &event);
150 void OnTimerDSC(wxTimerEvent &event);
151
152 bool NMEACheckSumOK(const wxString &str);
153 bool Parse_VDXBitstring(AisBitstring *bstr,
154 std::shared_ptr<AisTargetData> ptd);
155 void UpdateAllCPA(void);
156 void UpdateOneCPA(AisTargetData *ptarget);
157 void UpdateAllAlarms(void);
158 void UpdateAllTracks(void);
159 void UpdateOneTrack(AisTargetData *ptarget);
160 void BuildERIShipTypeHash(void);
161 std::shared_ptr<AisTargetData> ProcessDSx(const wxString &str,
162 bool b_take_dsc = false);
163
164 wxString DecodeDSEExpansionCharacters(wxString dseData);
165 void getAISTarget(long mmsi, std::shared_ptr<AisTargetData> &pTargetData,
166 std::shared_ptr<AisTargetData> &pStaleTarget,
167 bool &bnewtarget, int &last_report_ticks, wxDateTime &now);
168 void getMmsiProperties(std::shared_ptr<AisTargetData> &pTargetData);
169 void handleUpdate(std::shared_ptr<AisTargetData> pTargetData, bool bnewtarget,
170 const rapidjson::Value &update);
171 void updateItem(std::shared_ptr<AisTargetData> pTargetData, bool bnewtarget,
172 const rapidjson::Value &item, wxString &sfixtime) const;
173 void CommitAISTarget(std::shared_ptr<AisTargetData> pTargetData,
174 const wxString &str, bool message_valid,
175 bool new_target);
176 void InitCommListeners(void);
177 bool HandleN0183_AIS(std::shared_ptr<const Nmea0183Msg> n0183_msg);
178 void HandleSignalK(std::shared_ptr<const SignalkMsg> sK_msg);
179
180 bool HandleN2K_129038(std::shared_ptr<const Nmea2000Msg> n2k_msg);
181 bool HandleN2K_129039(std::shared_ptr<const Nmea2000Msg> n2k_msg);
182 bool HandleN2K_129041(std::shared_ptr<const Nmea2000Msg> n2k_msg);
183 bool HandleN2K_129794(std::shared_ptr<const Nmea2000Msg> n2k_msg);
184 bool HandleN2K_129809(std::shared_ptr<const Nmea2000Msg> n2k_msg);
185 bool HandleN2K_129810(std::shared_ptr<const Nmea2000Msg> n2k_msg);
186 bool HandleN2K_129793(std::shared_ptr<const Nmea2000Msg> n2k_msg);
187
188 wxString m_signalk_selfid;
189 std::unordered_map<int, std::shared_ptr<AisTargetData>> AISTargetList;
190 std::unordered_map<int, std::shared_ptr<AisTargetData>>
191 AIS_AreaNotice_Sources;
192 AIS_Target_Name_Hash *AISTargetNamesC;
193 AIS_Target_Name_Hash *AISTargetNamesNC;
194
195 ObservableListener listener_N0183_VDM;
196 ObservableListener listener_N0183_FRPOS;
197 ObservableListener listener_N0183_CDDSC;
198 ObservableListener listener_N0183_CDDSE;
199 ObservableListener listener_N0183_TLL;
200 ObservableListener listener_N0183_TTM;
201 ObservableListener listener_N0183_OSD;
202 ObservableListener listener_N0183_WPL;
203 ObservableListener listener_SignalK;
204
205 ObservableListener listener_N2K_129038;
206 ObservableListener listener_N2K_129039;
207 ObservableListener listener_N2K_129041;
208 ObservableListener listener_N2K_129794;
209 ObservableListener listener_N2K_129809;
210 ObservableListener listener_N2K_129810;
211 ObservableListener listener_N2K_129793;
212
213 bool m_busy;
214 wxTimer TimerAIS;
215 wxFrame *m_parent_frame;
216 AisDecoderCallbacks m_callbacks;
217
218 int nsentences;
219 int isentence;
220 wxString sentence_accumulator;
221 bool m_OK;
222
223 std::shared_ptr<AisTargetData> m_pLatestTargetData;
224
225 bool m_bAIS_Audio_Alert_On;
226 wxTimer m_AIS_Audio_Alert_Timer;
227 int m_n_targets;
228 bool m_bSuppressed;
229 bool m_bGeneralAlert;
230 std::shared_ptr<AisTargetData> m_ptentative_dsctarget;
231 wxTimer m_dsc_timer;
232 wxString m_dsc_last_string;
233 std::vector<int> m_MMSI_MismatchVec;
234
235 bool m_bAIS_AlertPlaying;
236 DECLARE_EVENT_TABLE()
237};
238
239#endif // _AIS_DECODER_H__
AisDecoder::plugin_msg
EventVar plugin_msg
A JSON message should be sent.
Definition ais_decoder.h:145
AisDecoder::new_track
EventVar new_track
Notified on new track creation.
Definition ais_decoder.h:139
AisDecoder::new_ais_wp
EventVar new_ais_wp
Notified when new AIS wp is created.
Definition ais_decoder.h:136
AisDecoder::info_update
EventVar info_update
Notified when AIS user dialogs should update.
Definition ais_decoder.h:130
AisDecoder::delete_track
EventVar delete_track
Notified when about to delete track.
Definition ais_decoder.h:142
AisDecoder::touch_state
EventVar touch_state
Notified when gFrame->TouchAISActive() should be invoked.
Definition ais_decoder.h:133
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:111
comm_navmsg.h
Raw, undecoded messages definitions.
GenericPosDatEx
A generic position and navigation data structure.
Definition ocpn_types.h:74