diff options
| author | Amlal El Mahrouss <amlal@nekernel.org> | 2025-07-26 01:47:32 +0100 |
|---|---|---|
| committer | Amlal El Mahrouss <amlal@nekernel.org> | 2025-07-26 01:47:32 +0100 |
| commit | c52dbf5513ae7f106634967162da5cfb01dc5af3 (patch) | |
| tree | b6715d0fdacebd48491b9b05cf85f1d92028f84b /dev/lib/fix | |
| parent | 01565adb9cf5ef991196f56c7f5f7b6161daa005 (diff) | |
feat: SOCL v1.0.2, changelog soon!v1.0.2
Signed-off-by: Amlal El Mahrouss <amlal@nekernel.org>
Diffstat (limited to 'dev/lib/fix')
| -rw-r--r-- | dev/lib/fix/network.hpp | 20 | ||||
| -rw-r--r-- | dev/lib/fix/parser.hpp | 198 |
2 files changed, 218 insertions, 0 deletions
diff --git a/dev/lib/fix/network.hpp b/dev/lib/fix/network.hpp new file mode 100644 index 0000000..0ca0920 --- /dev/null +++ b/dev/lib/fix/network.hpp @@ -0,0 +1,20 @@ +/* +* File: fix/netowrk.hpp + * Purpose: Financial Information Exchange in C++ + * Author: Amlal El Mahrouss (founder@snu.systems) + * Copyright 2025, Amlal El Mahrouss and SNU Systems Corp all rights reserved. + */ + +#ifndef _SNU_FIX_NETWORK_HPP +#define _SNU_FIX_NETWORK_HPP + +#include <arpa/inet.h> +#include <sys/socket.h> + +namespace snu::fix +{ + class network_rx; + class network_tx; +} // namespace snu::fix + +#endif // ifndef _SNU_FIX_NETWORK_HPP
\ No newline at end of file diff --git a/dev/lib/fix/parser.hpp b/dev/lib/fix/parser.hpp new file mode 100644 index 0000000..e432b6c --- /dev/null +++ b/dev/lib/fix/parser.hpp @@ -0,0 +1,198 @@ +/* + * File: fix/parser.hpp + * Purpose: Financial Information Exchange parser in C++ + * Author: Amlal El Mahrouss (founder@snu.systems) + * Copyright 2025, Amlal El Mahrouss and SNU Systems Corp all rights reserved. + */ + +#ifndef _SNU_FIX_PARSER_HPP +#define _SNU_FIX_PARSER_HPP + +#include <cstddef> +#include <cassert> +#include <utility> +#include <string> +#include <vector> + +namespace snu::fix +{ + template <typename char_type> + struct visitor; + + template <typename char_type> + struct range; + + template <typename char_type> + struct range_data; + + /// @brief Buffer+Length structure + template <typename char_type> + using range_ptr_t = range<char_type>; + + namespace detail + { + template <typename char_type> + const char_type* begin_fix(); + + template <> + inline const char* begin_fix<char>() + { + return "FIX."; + } + + template <> + inline const char16_t* begin_fix<char16_t>() + { + return u"FIX."; + } + + template <> + inline const char8_t* begin_fix<char8_t>() + { + return u8"FIX."; + } + } // namespace detail + + template <typename char_type> + struct range final + { + char_type* bytes_; + size_t length_; + + bool is_valid() + { + return bytes_ && length_ > 0; + } + + operator bool() + { + return this->is_valid(); + } + }; + + /// @brief Convert range to usable string. + /// @note This function assumes that the range is valid and contains ASCII bytes. + template <typename char_type> + inline std::basic_string<char_type> to_string(range<char_type>& range) noexcept + { + if (range.length_ < 0) + return std::basic_string<char_type>{}; + + return std::basic_string<char_type>(range.ascii_bytes_, range.length_); + } + + /// @brief a range object containing the FIX packet values. + template <typename char_type> + class range_data final + { + public: + std::basic_string<char_type> msg_magic_; + std::size_t msg_body_len_; + std::vector<std::pair<std::basic_string<char_type>, std::basic_string<char_type>>> msg_body_; + + static inline const char_type* begin = detail::begin_fix<char_type>(); + + explicit range_data() = default; + ~range_data() = default; + + range_data& operator=(const range_data&) = default; + range_data(const range_data&) = default; + + std::basic_string<char_type> operator[](const std::basic_string<char_type>& key) + { + if (key.empty()) + { + return std::basic_string<char_type>{}; + } + + for (const auto& pair : msg_body_) + { + if (pair.first == key) + { + return pair.second; + } + } + return std::basic_string<char_type>{}; + } + + bool is_valid() + { + return msg_magic_.starts_with(range_data<char_type>::begin); + } + + operator bool() + { + return this->is_valid(); + } + }; + + /// @brief visitor object which returns a fix::range_data instance. + template <typename char_type> + class visitor final + { + public: + static constexpr const char_type soh = '|'; + static constexpr const char_type eq = '='; + static constexpr uint32_t base = 10U; + + explicit visitor() = default; + ~visitor() = default; + + visitor& operator=(const visitor&) = default; + visitor(const visitor&) = default; + + range<char_type> operator()(const std::basic_string<char_type>& in) + { + return this->visit(in); + } + + range_data<char_type> visit(const std::basic_string<char_type>& in) + { + thread_local range_data<char_type> ret{}; + + if (in.empty()) + return ret; + + thread_local std::basic_string<char_type> in_tmp{}; + + in_tmp.reserve(in.size()); + + try + { + for (auto& ch : in) + { + if (ch != visitor::soh) + { + in_tmp += ch; + continue; + } + + std::basic_string<char_type> key = in_tmp.substr(0, in_tmp.find(visitor::eq)); + std::basic_string<char_type> val = in_tmp.substr(in_tmp.find(visitor::eq) + 1); + + if (ret.msg_magic_.empty()) + { + ret.msg_magic_ = val; + } + else + { + ret.msg_body_.emplace_back(std::make_pair(key, val)); + ret.msg_body_len_ += in_tmp.size(); + } + + in_tmp.clear(); + } + } + catch (...) + { + in_tmp.clear(); + return ret; + } + + in_tmp.clear(); + return ret; + } + }; +} // namespace snu::fix + +#endif // ifndef _SNU_FIX_PARSER_HPP |
