ZmqHeader.hpp

Go to the documentation of this file.

#pragma once
#include "aare/core/Frame.hpp"
#include "aare/utils/logger.hpp"
 
#include "simdjson.h"
#include <array>
#include <cstdint>
#include <map>
#include <string>
namespace simdjson {
template <> simdjson_inline simdjson::simdjson_result<std::array<int, 4>> simdjson::ondemand::value::get() noexcept {
    ondemand::array array;
    auto error = get_array().get(array);
    if (error) {
        return error;
    }
    std::array<int, 4> arr;
    int i = 0;
    for (auto v : array) {
        int64_t val;
        error = v.get_int64().get(val);
 
        if (error) {
            return error;
        }
        arr[i++] = val;
    }
    return arr;
}
 
template <> simdjson_inline simdjson::simdjson_result<uint32_t> simdjson::ondemand::value::get() noexcept {
    size_t val;
    auto error = get_uint64().get(val);
    if (error) {
        return error;
    }
    if (val > std::numeric_limits<uint32_t>::max()) {
        return 1;
    }
    return static_cast<uint32_t>(val);
}
 
template <>
simdjson_inline simdjson::simdjson_result<std::map<std::string, std::string>>
simdjson::ondemand::value::get() noexcept {
    std::map<std::string, std::string> map;
    ondemand::object obj;
    auto error = get_object().get(obj);
    if (error) {
        return error;
    }
    for (auto field : obj) {
        simdjson::ondemand::raw_json_string tmp;
        error = field.key().get(tmp);
        if (error) {
            return error;
        }
        error = field.value().get(tmp);
        if (error) {
            return error;
        }
        std::string_view key_view = field.unescaped_key();
        std::string key_str(key_view.data(), key_view.size());
        std::string_view value_view = field.value().get_string();
        map[key_str] = {value_view.data(), value_view.size()};
    }
    return map;
}
 
} // namespace simdjson
 
namespace aare {
 
struct ZmqHeader {
    bool data{true};
    uint32_t jsonversion{0};
    uint32_t dynamicRange{0};
    uint64_t fileIndex{0};
    uint32_t ndetx{0};
    uint32_t ndety{0};
    uint32_t npixelsx{0};
    uint32_t npixelsy{0};
    uint32_t imageSize{0};
    uint64_t acqIndex{0};
    uint64_t frameIndex{0};
    double progress{0};
    std::string fname;
    uint64_t frameNumber{0};
    uint32_t expLength{0};
    uint32_t packetNumber{0};
    uint64_t detSpec1{0};
    uint64_t timestamp{0};
    uint16_t modId{0};
    uint16_t row{0};
    uint16_t column{0};
    uint16_t detSpec2{0};
    uint32_t detSpec3{0};
    uint16_t detSpec4{0};
    uint8_t detType{0};
    uint8_t version{0};
    int flipRows{0};
    uint32_t quad{0};
    bool completeImage{false};
    std::map<std::string, std::string> addJsonHeader;
    std::array<int, 4> rx_roi{};
 
    std::string to_string() const;
    void from_string(std::string &s);
    // compare operator
    bool operator==(const ZmqHeader &other) const;
};
 
} // namespace aare