/*
 * Author:          Patrick-Christopher Mattulat
 * Company:         Lynar Studios
 * E-Mail:          webmaster@lynarstudios.com
 * Created:         2022-11-16
 * Changed:         2022-12-28
 *
 * */

#ifndef LS_STD_SOCKET_HPP
#define LS_STD_SOCKET_HPP

#include <ls_std/os/specification.hpp>
#include <ls_std/os/dynamic_goal.hpp>
#include <ls_std/core/Class.hpp>
#include "SocketParameter.hpp"
#include "SocketAddressMapperParameter.hpp"
#include <memory>
#include <ls_std/core/types/Types.hpp>
#include <ls_std/core/interface/IReader.hpp>
#include <ls_std/core/interface/IWriter.hpp>
#include <unordered_map>
#include <ls_std/core/types/SocketTypes.hpp>

namespace ls::std::network
{
  class LS_STD_DYNAMIC_GOAL Socket : public ls::std::core::Class, public ls::std::core::interface_type::IReader, public ls::std::core::interface_type::IWriter
  {
    public:

      explicit Socket(ls::std::network::SocketParameter _parameter);
      ~Socket() override;

      // implementation

      [[nodiscard]] ls::std::core::type::byte_field read() override;
      [[nodiscard]] bool write(const ls::std::core::type::byte_field &_data) override;

      // other functionalities

      [[nodiscard]] ls::std::core::type::connection_id accept();
      [[nodiscard]] bool bind();
      [[nodiscard]] bool close();
      [[nodiscard]] bool connect();
      [[nodiscard]] bool handle(const ls::std::core::type::connection_id& _connectionId);
      [[nodiscard]] bool handle();
      [[nodiscard]] bool isInitialized() const;
      [[nodiscard]] bool listen();

    private:

      ls::std::core::type::connection_id currentAcceptedConnection{};
      bool initialized{};
      ls::std::network::SocketParameter parameter{};
      ls::std::core::type::byte* readBuffer{};
      bool readBufferSet{};
      #if LS_STD_UNIX_PLATFORM
      ::std::unordered_map<ls::std::core::type::connection_id, int> unixDescriptors{}; // TODO: provide a struct with connection information
      ls::std::core::type::connection_id unixUniqueDescriptorId{};
      #endif

      #if LS_STD_UNIX_PLATFORM
      [[nodiscard]] ls::std::core::type::connection_id _acceptUnix();
      void _addUnixDescriptor(const int& _descriptor);
      [[nodiscard]] bool _bindUnix();
      #endif
      [[nodiscard]] bool _close();
      #if LS_STD_UNIX_PLATFORM
      [[nodiscard]] bool _closeUnix(const int& _descriptor);
      [[nodiscard]] bool _connectUnix();
      #endif
      [[nodiscard]] SocketAddressMapperParameter _createSocketAddressMapperParameter() const;
      [[nodiscard]] bool _hasAcceptedConnection(const ls::std::core::type::connection_id& _connectionId);
      #if LS_STD_UNIX_PLATFORM
      [[nodiscard]] bool _hasAcceptedConnectionUnix(const ls::std::core::type::connection_id& _connectionId);
      #endif
      [[nodiscard]] bool _handle(const ls::std::core::type::connection_id& _connectionId);
      void _init();
      void _initReadBuffer();
      #if LS_STD_UNIX_PLATFORM
      [[nodiscard]] bool _initUnix();
      [[nodiscard]] bool _listenUnix();
      #endif
      ls::std::core::type::byte_field _read();
      #if LS_STD_UNIX_PLATFORM
      ls::std::core::type::byte_field _readUnix(const int& _descriptor);
      void _setPosixReaderApi();
      void _setPosixSocketApi();
      void _setPosixWriterApi();
      #endif
      bool _write(const ls::std::core::type::byte_field &_data);
      #if LS_STD_UNIX_PLATFORM
      bool _writeUnix(const int& _descriptor, const ls::std::core::type::byte_field &_data);
      #endif
  };
}

#endif