mirror of
https://github.com/peterantypas/maiana.git
synced 2025-05-15 23:10:11 -07:00
288 lines
9.2 KiB
C++
288 lines
9.2 KiB
C++
// Copyright 2015 Google Inc. All Rights Reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
// TODO(schwehr): Add logging back in or remove it.
|
|
|
|
#include "decode_body.h"
|
|
|
|
#include <memory>
|
|
|
|
#include "ais.h"
|
|
|
|
using libais::AisMsg;
|
|
using std::unique_ptr;
|
|
|
|
namespace libais {
|
|
|
|
// TODO(schwehr): Switch to make_unique when C++14 is available on Travis-CI.
|
|
template <typename T, typename... Args>
|
|
std::unique_ptr<T> MakeUnique(Args &&... args) {
|
|
return std::unique_ptr<T>(new T(std::forward<Args>(args)...));
|
|
}
|
|
|
|
template <typename T>
|
|
std::unique_ptr<T> MakeNull()
|
|
{
|
|
return std::unique_ptr<T>(nullptr);
|
|
}
|
|
|
|
unique_ptr<AisMsg> CreateAisMsg6(const string &body, const int fill_bits) {
|
|
libais::Ais6 msg(body.c_str(), fill_bits);
|
|
switch (msg.dac) {
|
|
// International Maritime Organization (IMO).
|
|
case libais::AIS_DAC_1_INTERNATIONAL:
|
|
switch (msg.fi) {
|
|
case 0:
|
|
return MakeUnique<libais::Ais6_1_0>(body.c_str(), fill_bits);
|
|
case 1:
|
|
return MakeUnique<libais::Ais6_1_1>(body.c_str(), fill_bits);
|
|
case 2:
|
|
return MakeUnique<libais::Ais6_1_2>(body.c_str(), fill_bits);
|
|
case 3:
|
|
return MakeUnique<libais::Ais6_1_3>(body.c_str(), fill_bits);
|
|
case 4:
|
|
return MakeUnique<libais::Ais6_1_4>(body.c_str(), fill_bits);
|
|
case 12:
|
|
return MakeUnique<libais::Ais6_1_12>(body.c_str(), fill_bits);
|
|
case 14:
|
|
return MakeUnique<libais::Ais6_1_14>(body.c_str(), fill_bits);
|
|
case 18:
|
|
return MakeUnique<libais::Ais6_1_18>(body.c_str(), fill_bits);
|
|
case 20:
|
|
return MakeUnique<libais::Ais6_1_20>(body.c_str(), fill_bits);
|
|
case 25:
|
|
return MakeUnique<libais::Ais6_1_25>(body.c_str(), fill_bits);
|
|
// TODO(schwehr): 28.
|
|
// TODO(schwehr): 30.
|
|
case 32:
|
|
return MakeUnique<libais::Ais6_1_32>(body.c_str(), fill_bits);
|
|
case 40:
|
|
return MakeUnique<libais::Ais6_1_40>(body.c_str(), fill_bits);
|
|
}
|
|
// FI not handled.
|
|
break;
|
|
}
|
|
return nullptr;
|
|
}
|
|
|
|
unique_ptr<AisMsg> CreateAisMsg8(const string &body, const int fill_bits) {
|
|
libais::Ais8 msg(body.c_str(), fill_bits);
|
|
switch (msg.dac) {
|
|
// International Maritime Organization (IMO).
|
|
case libais::AIS_DAC_1_INTERNATIONAL:
|
|
switch (msg.fi) {
|
|
case 0:
|
|
return MakeUnique<libais::Ais8_1_0>(body.c_str(), fill_bits);
|
|
case 11:
|
|
return MakeUnique<libais::Ais8_1_11>(body.c_str(), fill_bits);
|
|
case 13:
|
|
return MakeUnique<libais::Ais8_1_13>(body.c_str(), fill_bits);
|
|
case 15:
|
|
return MakeUnique<libais::Ais8_1_15>(body.c_str(), fill_bits);
|
|
case 16:
|
|
return MakeUnique<libais::Ais8_1_16>(body.c_str(), fill_bits);
|
|
case 17:
|
|
return MakeUnique<libais::Ais8_1_17>(body.c_str(), fill_bits);
|
|
case 19:
|
|
return MakeUnique<libais::Ais8_1_19>(body.c_str(), fill_bits);
|
|
case 21:
|
|
return MakeUnique<libais::Ais8_1_21>(body.c_str(), fill_bits);
|
|
case 22:
|
|
return MakeUnique<libais::Ais8_1_22>(body.c_str(), fill_bits);
|
|
case 24:
|
|
return MakeUnique<libais::Ais8_1_24>(body.c_str(), fill_bits);
|
|
case 26:
|
|
return MakeUnique<libais::Ais8_1_26>(body.c_str(), fill_bits);
|
|
case 27:
|
|
return MakeUnique<libais::Ais8_1_27>(body.c_str(), fill_bits);
|
|
case 29:
|
|
return MakeUnique<libais::Ais8_1_29>(body.c_str(), fill_bits);
|
|
case 31:
|
|
return MakeUnique<libais::Ais8_1_31>(body.c_str(), fill_bits);
|
|
}
|
|
// FI not handled.
|
|
break;
|
|
// European River Information System (RIS).
|
|
case libais::AIS_DAC_200_RIS:
|
|
switch (msg.fi) {
|
|
case 10:
|
|
// Inland ship static and voyage related data
|
|
return MakeUnique<libais::Ais8_200_10>(body.c_str(), fill_bits);
|
|
case 21:
|
|
// ETA at lock/bridge/terminal
|
|
return MakeUnique<libais::Ais8_200_21>(body.c_str(), fill_bits);
|
|
case 22:
|
|
// RTA at lock/bridge/terminal
|
|
return MakeUnique<libais::Ais8_200_22>(body.c_str(), fill_bits);
|
|
case 23:
|
|
// EMMA warning
|
|
return MakeUnique<libais::Ais8_200_23>(body.c_str(), fill_bits);
|
|
case 24:
|
|
// Water levels
|
|
return MakeUnique<libais::Ais8_200_24>(body.c_str(), fill_bits);
|
|
case 40:
|
|
// Signal status
|
|
return MakeUnique<libais::Ais8_200_40>(body.c_str(), fill_bits);
|
|
case 55:
|
|
// Number of persons on board
|
|
return MakeUnique<libais::Ais8_200_55>(body.c_str(), fill_bits);
|
|
}
|
|
// FI not handled.
|
|
break;
|
|
// TODO(schwehr): 366 US Coast Guard.
|
|
case 367: // US Coast Guard.
|
|
switch (msg.fi) {
|
|
case 22:
|
|
return MakeUnique<libais::Ais8_367_22>(body.c_str(), fill_bits);
|
|
}
|
|
// FI not handled.
|
|
break;
|
|
}
|
|
return nullptr;
|
|
}
|
|
|
|
unique_ptr<AisMsg> CreateAisMsg(const string &body, const int fill_bits) {
|
|
if (body.empty()) {
|
|
return nullptr;
|
|
}
|
|
if (fill_bits < 0 || fill_bits > 5) {
|
|
return nullptr;
|
|
}
|
|
|
|
switch (body[0]) {
|
|
case '1': // FALLTHROUGH
|
|
case '2': // FALLTHROUGH
|
|
case '3': // 1-3: Class A position report.
|
|
return MakeUnique<libais::Ais1_2_3>(body.c_str(), fill_bits);
|
|
|
|
case '4': // FALLTHROUGH - 4 - Basestation report
|
|
case ';': // 11 - UTC date response
|
|
//return MakeUnique<libais::Ais4_11>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
case '5': // 5 - Ship and Cargo
|
|
return MakeUnique<libais::Ais5>(body.c_str(), fill_bits);
|
|
//return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '6': // 6 - Addressed binary message
|
|
//return CreateAisMsg6(body, fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '7': // FALLTHROUGH - 7 - ACK for addressed binary message
|
|
case '=': // 13 - ASRM Ack (safety message)
|
|
//return MakeUnique<libais::Ais7_13>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '8': // 8 - Binary broadcast message (BBM)
|
|
//return CreateAisMsg8(body, fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '9': // 9 - SAR Position
|
|
//return MakeUnique<libais::Ais9>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case ':': // 10 - UTC Query
|
|
//return MakeUnique<libais::Ais10>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
// ';' 11 - See 4
|
|
|
|
case '<': // 12 - Addressed Safety Related Messages (ASRM)
|
|
//return MakeUnique<libais::Ais12>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
// '=' 13 - See 7
|
|
|
|
case '>': // 14 - Safety Related Broadcast Message (SRBM)
|
|
//return MakeUnique<libais::Ais14>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '?': // 15 - Interrogation
|
|
//return MakeUnique<libais::Ais15>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case '@': // 16 - Assigned mode command
|
|
//return MakeUnique<libais::Ais16>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'A': // 17 - GNSS broadcast
|
|
//return MakeUnique<libais::Ais17>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'B': // 18 - Position, Class B
|
|
return MakeUnique<libais::Ais18>(body.c_str(), fill_bits);
|
|
|
|
case 'C': // 19 - Position and ship, Class B
|
|
//return MakeUnique<libais::Ais19>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'D': // 20 - Data link management
|
|
//return MakeUnique<libais::Ais20>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'E': // 21 - Aids to navigation report
|
|
return MakeUnique<libais::Ais21>(body.c_str(), fill_bits);
|
|
//return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'F': // 22 - Channel Management
|
|
//return MakeUnique<libais::Ais22>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'G': // 23 - Group Assignment Command
|
|
//return MakeUnique<libais::Ais23>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'H': // 24 - Static data report
|
|
return MakeUnique<libais::Ais24>(body.c_str(), fill_bits);
|
|
|
|
case 'I': // 25 - Single slot binary message
|
|
//return MakeUnique<libais::Ais25>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'J': // 26 - Multi slot binary message with comm state
|
|
//return MakeUnique<libais::Ais26>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
case 'K': // 27 - Long-range AIS broadcast message
|
|
//return MakeUnique<libais::Ais27>(body.c_str(), fill_bits);
|
|
return MakeNull<libais::AisMsg>();
|
|
|
|
|
|
default:
|
|
return nullptr;
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
} // namespace libais
|