ccl_compatibility.cpp

// Copyright 2012-2020:
//   GobySoft, LLC (2013-)
//   Massachusetts Institute of Technology (2007-2014)
//   Community contributors (see AUTHORS file)
// File authors:
//   Toby Schneider <toby@gobysoft.org>
//   Chris Murphy <cmurphy@aphysci.com>
//
//
// This file is part of the Dynamic Compact Control Language Library
// ("DCCL").
//
// DCCL is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 2.1 of the License, or
// (at your option) any later version.
//
// DCCL is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with DCCL.  If not, see <http://www.gnu.org/licenses/>.
 
#include <chrono>
#include <ctime>
 
#include "../codec.h"
#include "WhoiUtil.h"
#include "ccl_compatibility.h"
 
extern "C"
{
    void dccl3_load(dccl::Codec* dccl)
    {
        using namespace dccl;
        using namespace dccl::legacyccl;
 
        dccl->manager().add<dccl::legacyccl::IdentifierCodec>("dccl.ccl.id");
 
        if (dccl->get_id_codec() != "dccl.ccl.id")
            dccl->set_id_codec("dccl.ccl.id");
 
        dccl->manager().add<LatLonCompressedCodec>("_ccl_latloncompressed");
        dccl->manager().add<FixAgeCodec>("_ccl_fix_age");
        dccl->manager().add<TimeDateCodec>("_ccl_time_date");
        dccl->manager().add<HeadingCodec>("_ccl_heading");
        dccl->manager().add<DepthCodec>("_ccl_depth");
        dccl->manager().add<VelocityCodec>("_ccl_velocity");
        dccl->manager().add<WattsCodec>("_ccl_watts");
        dccl->manager().add<GFIPitchOilCodec>("_ccl_gfi_pitch_oil");
        dccl->manager().add<SpeedCodec>("_ccl_speed");
        dccl->manager().add<HiResAltitudeCodec>("_ccl_hires_altitude");
        dccl->manager().add<TemperatureCodec>("_ccl_temperature");
        dccl->manager().add<SalinityCodec>("_ccl_salinity");
        dccl->manager().add<SoundSpeedCodec>("_ccl_sound_speed");
 
        dccl->load<protobuf::CCLMDATEmpty>();
        dccl->load<protobuf::CCLMDATRedirect>();
        dccl->load<protobuf::CCLMDATBathy>();
        dccl->load<protobuf::CCLMDATCTD>();
        dccl->load<protobuf::CCLMDATState>();
        dccl->load<protobuf::CCLMDATCommand>();
        dccl->load<protobuf::CCLMDATError>();
    }
 
    void dccl3_unload(dccl::Codec* dccl)
    {
        using namespace dccl;
        using namespace dccl::legacyccl;
 
        dccl->unload<protobuf::CCLMDATEmpty>();
        dccl->unload<protobuf::CCLMDATRedirect>();
        dccl->unload<protobuf::CCLMDATBathy>();
        dccl->unload<protobuf::CCLMDATCTD>();
        dccl->unload<protobuf::CCLMDATState>();
        dccl->unload<protobuf::CCLMDATCommand>();
        dccl->unload<protobuf::CCLMDATError>();
 
        dccl->manager().remove<dccl::legacyccl::IdentifierCodec>("dccl.ccl.id");
        dccl->manager().remove<LatLonCompressedCodec>("_ccl_latloncompressed");
        dccl->manager().remove<FixAgeCodec>("_ccl_fix_age");
        dccl->manager().remove<TimeDateCodec>("_ccl_time_date");
        dccl->manager().remove<HeadingCodec>("_ccl_heading");
        dccl->manager().remove<DepthCodec>("_ccl_depth");
        dccl->manager().remove<VelocityCodec>("_ccl_velocity");
        dccl->manager().remove<WattsCodec>("_ccl_watts");
        dccl->manager().remove<GFIPitchOilCodec>("_ccl_gfi_pitch_oil");
        dccl->manager().remove<SpeedCodec>("_ccl_speed");
        dccl->manager().remove<HiResAltitudeCodec>("_ccl_hires_altitude");
        dccl->manager().remove<TemperatureCodec>("_ccl_temperature");
        dccl->manager().remove<SalinityCodec>("_ccl_salinity");
        dccl->manager().remove<SoundSpeedCodec>("_ccl_sound_speed");
    }
}
 
//
// LatLonCompressedCodec
//
 
dccl::Bitset dccl::legacyccl::LatLonCompressedCodec::encode() { return encode(0); }
 
dccl::Bitset dccl::legacyccl::LatLonCompressedCodec::encode(const double& wire_value)
{
    LONG_AND_COMP encoded;
    encoded.as_long = 0;
    encoded.as_compressed = Encode_latlon(wire_value);
    return dccl::Bitset(size(), static_cast<unsigned long>(encoded.as_long));
}
 
double dccl::legacyccl::LatLonCompressedCodec::decode(Bitset* bits)
{
    LONG_AND_COMP decoded;
    decoded.as_long = static_cast<long>(bits->to_ulong());
    return Decode_latlon(decoded.as_compressed);
}
 
unsigned dccl::legacyccl::LatLonCompressedCodec::size()
{
    return LATLON_COMPRESSED_BYTE_SIZE * BITS_IN_BYTE;
}
 
//
// TimeDateCodec
//
 
dccl::Bitset dccl::legacyccl::TimeDateCodec::encode() { return encode(0); }
 
dccl::Bitset dccl::legacyccl::TimeDateCodec::encode(const dccl::uint64& wire_value)
{
    TIME_DATE_LONG encoded;
    encoded.as_long = 0;
    encoded.as_time_date = Encode_time_date(wire_value / MICROSECONDS_IN_SECOND);
    return dccl::Bitset(size(), static_cast<unsigned long>(encoded.as_long));
}
 
dccl::uint64 dccl::legacyccl::TimeDateCodec::decode(Bitset* bits)
{
    TIME_DATE_LONG decoded;
    decoded.as_long = bits->to_ulong();
    short mon, day, hour, min, sec;
    Decode_time_date(decoded.as_time_date, &mon, &day, &hour, &min, &sec);
 
    // Get the current time
    auto now = std::chrono::system_clock::now();
    std::time_t now_time_t = std::chrono::system_clock::to_time_t(now);
 
    // Get the current year
    std::tm current_year_tm = *std::gmtime(&now_time_t);
    int current_year = current_year_tm.tm_year + 1900;
 
    // Construct a tm structure with the given date and time
    std::tm input_tm;
    input_tm.tm_year = current_year - 1900;
    input_tm.tm_mon = mon - 1;
    input_tm.tm_mday = day;
    input_tm.tm_hour = hour;
    input_tm.tm_min = min;
    input_tm.tm_sec = sec;
    input_tm.tm_isdst = -1; // Let the system determine the DST setting
 
    // Convert the input tm structure to a time_t
    std::time_t input_time_t = timegm(&input_tm);
 
    return to_uint64_time(input_time_t);
}
 
dccl::uint64 dccl::legacyccl::TimeDateCodec::to_uint64_time(const std::time_t& time_date)
{
    std::chrono::system_clock::duration input_duration =
        std::chrono::system_clock::from_time_t(time_date) -
        std::chrono::system_clock::from_time_t(0); // UNIX Epoch
    uint64_t microseconds_since_epoch =
        std::chrono::duration_cast<std::chrono::microseconds>(input_duration).count();
    return microseconds_since_epoch;
}
 
unsigned dccl::legacyccl::TimeDateCodec::size()
{
    return TIME_DATE_COMPRESSED_BYTE_SIZE * BITS_IN_BYTE;
}
 
//
// HeadingCodec
//
dccl::Bitset dccl::legacyccl::HeadingCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_heading(wire_value));
}
 
float dccl::legacyccl::HeadingCodec::decode(Bitset* bits)
{
    return Decode_heading(bits->to_ulong());
}
 
//
// DepthCodec
//
dccl::Bitset dccl::legacyccl::DepthCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_depth(wire_value));
}
 
float dccl::legacyccl::DepthCodec::decode(Bitset* bits) { return Decode_depth(bits->to_ulong()); }
 
//
// VelocityCodec
//
dccl::Bitset dccl::legacyccl::VelocityCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_est_velocity(wire_value));
}
 
float dccl::legacyccl::VelocityCodec::decode(Bitset* bits)
{
    return Decode_est_velocity(bits->to_ulong());
}
 
//
// SpeedCodec
//
dccl::Bitset dccl::legacyccl::SpeedCodec::encode(const float& wire_value)
{
    const google::protobuf::Message* root = FieldCodecBase::root_message();
    const google::protobuf::FieldDescriptor* thrust_mode_field_desc =
        root->GetDescriptor()->FindFieldByNumber(
            FieldCodecBase::dccl_field_options().GetExtension(ccl).thrust_mode_tag());
 
    switch (root->GetReflection()->GetEnum(*root, thrust_mode_field_desc)->number())
    {
        default:
        case protobuf::CCLMDATRedirect::RPM:
            return dccl::Bitset(size(), Encode_speed(SPEED_MODE_RPM, wire_value));
 
        case protobuf::CCLMDATRedirect::METERS_PER_SECOND:
            return dccl::Bitset(size(), Encode_speed(SPEED_MODE_MSEC, wire_value));
    }
}
 
float dccl::legacyccl::SpeedCodec::decode(Bitset* bits)
{
    const google::protobuf::Message* root = FieldCodecBase::root_message();
    const google::protobuf::FieldDescriptor* thrust_mode_field_desc =
        root->GetDescriptor()->FindFieldByNumber(
            FieldCodecBase::dccl_field_options().GetExtension(ccl).thrust_mode_tag());
 
    switch (root->GetReflection()->GetEnum(*root, thrust_mode_field_desc)->number())
    {
        default:
        case protobuf::CCLMDATRedirect::RPM: return Decode_speed(SPEED_MODE_RPM, bits->to_ulong());
 
        case protobuf::CCLMDATRedirect::METERS_PER_SECOND:
            return Decode_speed(SPEED_MODE_MSEC, bits->to_ulong());
    }
}
 
//
// WattsCodec
//
dccl::Bitset dccl::legacyccl::WattsCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_watts(wire_value, 1));
}
 
float dccl::legacyccl::WattsCodec::decode(Bitset* bits) { return Decode_watts(bits->to_ulong()); }
 
//
// GFIPitchOilCodec
//
dccl::Bitset
dccl::legacyccl::GFIPitchOilCodec::encode(const protobuf::CCLMDATState::GFIPitchOil& wire_value)
{
    return dccl::Bitset(
        size(), Encode_gfi_pitch_oil(wire_value.gfi(), wire_value.pitch(), wire_value.oil()));
}
 
dccl::legacyccl::protobuf::CCLMDATState::GFIPitchOil
dccl::legacyccl::GFIPitchOilCodec::decode(Bitset* bits)
{
    float gfi, pitch, oil;
    Decode_gfi_pitch_oil(bits->to_ulong(), &gfi, &pitch, &oil);
    protobuf::CCLMDATState::GFIPitchOil decoded;
    decoded.set_gfi(gfi);
    decoded.set_pitch(pitch);
    decoded.set_oil(oil);
    return decoded;
}
 
//
// HiResAltitudeCodec
//
dccl::Bitset dccl::legacyccl::HiResAltitudeCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_hires_altitude(wire_value));
}
 
float dccl::legacyccl::HiResAltitudeCodec::decode(Bitset* bits)
{
    return Decode_hires_altitude(bits->to_ulong());
}
 
//
// SalinityCodec
//
dccl::Bitset dccl::legacyccl::SalinityCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_salinity(wire_value));
}
 
float dccl::legacyccl::SalinityCodec::decode(Bitset* bits)
{
    return Decode_salinity(bits->to_ulong());
}
 
//
// TemperatureCodec
//
dccl::Bitset dccl::legacyccl::TemperatureCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_temperature(wire_value));
}
 
float dccl::legacyccl::TemperatureCodec::decode(Bitset* bits)
{
    return Decode_temperature(bits->to_ulong());
}
 
//
// SoundSpeedCodec
//
dccl::Bitset dccl::legacyccl::SoundSpeedCodec::encode(const float& wire_value)
{
    return dccl::Bitset(size(), Encode_sound_speed(wire_value));
}
 
float dccl::legacyccl::SoundSpeedCodec::decode(Bitset* bits)
{
    return Decode_sound_speed(bits->to_ulong());
}