display_filter.hpp

Go to the documentation of this file.

#pragma once
 
#include <async/async_queue.hpp>
#include <core/events.hpp>
#include <memory>
#include <optional>
#include <string>
#include <variant>
 
namespace radix_relay::core {
 
struct display_filter
{
  // Type traits for standard_processor
  using in_queue_t = async::async_queue<events::display_filter_input_t>;
 
  struct out_queues_t
  {
    std::shared_ptr<async::async_queue<events::display_message>> filtered;
  };
 
  explicit display_filter(const out_queues_t &queues) : filtered_queue_(queues.filtered) {}
 
  auto handle(const events::display_filter_input_t &input) const -> void
  {
    std::visit([this](const auto &evt) { this->handle(evt); }, input);
  }
 
  auto handle(const events::enter_chat_mode &evt) const -> void { active_chat_rdx_ = evt.rdx_fingerprint; }
 
  auto handle(const events::exit_chat_mode & /*evt*/) const -> void { active_chat_rdx_.reset(); }
 
  auto handle(const events::display_message &msg) const -> void
  {
    // System messages and command feedback always pass through
    if (msg.source_type == events::display_message::source::system
        or msg.source_type == events::display_message::source::command_feedback) {
      filtered_queue_->push(msg);
      return;
    }
 
    // Not in chat mode: pass everything through
    if (not active_chat_rdx_.has_value()) {
      filtered_queue_->push(msg);
      return;
    }
 
    // In chat mode: only pass messages associated with active contact
    if (msg.contact_rdx.has_value() and msg.contact_rdx.value() == active_chat_rdx_.value()) {
      filtered_queue_->push(msg);
    }
    // Messages not matching active contact are discarded (already stored in history)
  }
 
private:
  std::shared_ptr<async::async_queue<events::display_message>> filtered_queue_;
 
  // Chat context state (only accessed by this processor's thread, no mutex needed)
  mutable std::optional<std::string> active_chat_rdx_;
};
 
}// namespace radix_relay::core