feat: Support search logs by timestamp for structured and unstructured logs.

src/clp_ffi_js/ir/StreamReader.cpp

@@ -129,6 +129,7 @@ EMSCRIPTEN_BINDINGS(ClpStreamReader) {
             "Array<[string, bigint, number, number]>"
     );
     emscripten::register_type<clp_ffi_js::ir::FilteredLogEventMapTsType>("number[] | null");
+    emscripten::register_type<clp_ffi_js::ir::LogEventIdxTsType>("number | null");
     emscripten::class_<clp_ffi_js::ir::StreamReader>("ClpStreamReader")
             .constructor(
                     &clp_ffi_js::ir::StreamReader::create,
@@ -145,7 +146,11 @@ EMSCRIPTEN_BINDINGS(ClpStreamReader) {
             )
             .function("filterLogEvents", &clp_ffi_js::ir::StreamReader::filter_log_events)
             .function("deserializeStream", &clp_ffi_js::ir::StreamReader::deserialize_stream)
-            .function("decodeRange", &clp_ffi_js::ir::StreamReader::decode_range);
+            .function("decodeRange", &clp_ffi_js::ir::StreamReader::decode_range)
+            .function(
+                    "getLogEventIndexByTimestamp",
+                    &clp_ffi_js::ir::StreamReader::get_log_event_index_by_timestamp
+            );
 }
 }  // namespace
 

src/clp_ffi_js/ir/StreamReader.hpp

@@ -11,6 +11,7 @@
 #include <type_traits>
 #include <vector>
 
+#include <clp/ir/types.hpp>
 #include <clp/streaming_compression/zstd/Decompressor.hpp>
 #include <clp/type_utils.hpp>
 #include <emscripten/em_asm.h>
@@ -29,6 +30,7 @@ EMSCRIPTEN_DECLARE_VAL_TYPE(ReaderOptions);
 // JS types used as outputs
 EMSCRIPTEN_DECLARE_VAL_TYPE(DecodedResultsTsType);
 EMSCRIPTEN_DECLARE_VAL_TYPE(FilteredLogEventMapTsType);
+EMSCRIPTEN_DECLARE_VAL_TYPE(LogEventIdxTsType);
 
 enum class StreamType : uint8_t {
     Structured,
@@ -60,10 +62,9 @@ class StreamReader {
      * @return The created instance.
      * @throw ClpFfiJsException if any error occurs.
      */
-    [[nodiscard]] static auto create(
-            DataArrayTsType const& data_array,
-            ReaderOptions const& reader_options
-    ) -> std::unique_ptr<StreamReader>;
+    [[nodiscard]] static auto
+    create(DataArrayTsType const& data_array, ReaderOptions const& reader_options)
+            -> std::unique_ptr<StreamReader>;
 
     // Destructor
     virtual ~StreamReader() = default;
@@ -122,7 +123,21 @@ class StreamReader {
      * @throw ClpFfiJsException if a message cannot be decoded.
      */
     [[nodiscard]] virtual auto decode_range(size_t begin_idx, size_t end_idx, bool use_filter) const
-            -> DecodedResultsTsType = 0;
+            -> DecodedResultsTsType
+            = 0;
+    /**
+     * Retrieves the index of the last log event that matches the given timestamp.
+     *
+     * @tparam LogEvent
+     * @param timestamp The timestamp to search for, in milliseconds since the Unix epoch.
+     * @return The index of the last matched log event.
+     * @return null value if log events are empty.
+     * @return the last index smaller than the timestamp if no exact timestamp match, unless all log
+     * event timestamps are larger than the target. In that case, return the first log event index.
+     */
+    [[nodiscard]] virtual auto get_log_event_index_by_timestamp(clp::ir::epoch_time_ms_t timestamp)
+            -> LogEventIdxTsType
+            = 0;
 
 protected:
     explicit StreamReader() = default;
@@ -163,7 +178,6 @@ class StreamReader {
      * @tparam LogEvent
      * @param log_level_filter
      * @param log_events Derived class's log events.
-     * @param log_events
      * @param[out] filtered_log_event_map Returns the filtered log events.
      */
     template <typename LogEvent>
@@ -172,6 +186,30 @@ class StreamReader {
             LogLevelFilterTsType const& log_level_filter,
             LogEvents<LogEvent> const& log_events
     ) -> void;
+
+    /**
+     * Templated implementation of `get_log_event_index_by_timestamp`.
+     *
+     * @tparam LogEvent
+     * @param timestamp The timestamp to search for, in milliseconds since the Unix epoch.
+     * @return The index of the last matched log event.
+     * @return null value if log events are empty.
+     * @return the last index smaller than the timestamp if no exact timestamp match, unless all log
+     * event timestamps are larger than the target. In that case, return the first log event index.
+     */
+    template <typename LogEvent>
+    requires requires(
+            LogEventWithFilterData<LogEvent> const& event,
+            clp::ir::epoch_time_ms_t timestamp
+    ) {
+        {
+            event.get_timestamp()
+        } -> std::convertible_to<clp::ir::epoch_time_ms_t>;
+    }
+    static auto generic_get_log_event_index_by_timestamp(
+            LogEvents<LogEvent> const& log_events,
+            clp::ir::epoch_time_ms_t timestamp
+    ) -> LogEventIdxTsType;
 };
 
 template <typename LogEvent, typename ToStringFunc>
@@ -258,6 +296,39 @@ auto StreamReader::generic_filter_log_events(
         }
     }
 }
+
+template <typename LogEvent>
+requires requires(
+        LogEventWithFilterData<LogEvent> const& event,
+        clp::ir::epoch_time_ms_t timestamp
+) {
+    {
+        event.get_timestamp()
+    } -> std::convertible_to<clp::ir::epoch_time_ms_t>;
+}
+auto StreamReader::generic_get_log_event_index_by_timestamp(
+        LogEvents<LogEvent> const& log_events,
+        clp::ir::epoch_time_ms_t timestamp
+) -> LogEventIdxTsType {
+    if (log_events.empty()) {
+        return LogEventIdxTsType{emscripten::val::null()};
+    }
+    auto it = std::upper_bound(
+            log_events.begin(),
+            log_events.end(),
+            timestamp,
+            [](clp::ir::epoch_time_ms_t ts, LogEventWithFilterData<LogEvent> const& log_event) {
+                return ts < log_event.get_timestamp();
+            }
+    );
+
+    // If the iterator is not pointing to the beginning, decrement it so that it points to
+    // first element that is larger than timestamp.
+    if (it != log_events.begin()) {
+        --it;
+    }
+    return LogEventIdxTsType{emscripten::val(std::distance(log_events.begin(), it))};
+}
 }  // namespace clp_ffi_js::ir
 
 #endif  // CLP_FFI_JS_IR_STREAMREADER_HPP

src/clp_ffi_js/ir/StructuredIrStreamReader.cpp

@@ -11,6 +11,7 @@
 #include <clp/Array.hpp>
 #include <clp/ErrorCode.hpp>
 #include <clp/ffi/ir_stream/Deserializer.hpp>
+#include <clp/ir/types.hpp>
 #include <clp/TraceableException.hpp>
 #include <emscripten/val.h>
 #include <spdlog/spdlog.h>
@@ -147,6 +148,15 @@ auto StructuredIrStreamReader::decode_range(size_t begin_idx, size_t end_idx, bo
     );
 }
 
+auto StructuredIrStreamReader::get_log_event_index_by_timestamp(
+        clp::ir::epoch_time_ms_t const timestamp
+) -> LogEventIdxTsType {
+    return generic_get_log_event_index_by_timestamp<StructuredLogEvent>(
+            *m_deserialized_log_events,
+            timestamp
+    );
+}
+
 StructuredIrStreamReader::StructuredIrStreamReader(
         StreamReaderDataContext<StructuredIrDeserializer>&& stream_reader_data_context,
         std::shared_ptr<StructuredLogEvents> deserialized_log_events

src/clp_ffi_js/ir/StructuredIrStreamReader.hpp

@@ -8,6 +8,7 @@
 #include <clp/Array.hpp>
 #include <clp/ffi/ir_stream/Deserializer.hpp>
 #include <clp/ffi/SchemaTree.hpp>
+#include <clp/ir/types.hpp>
 #include <emscripten/val.h>
 
 #include <clp_ffi_js/ir/LogEventWithFilterData.hpp>
@@ -74,6 +75,9 @@ class StructuredIrStreamReader : public StreamReader {
     [[nodiscard]] auto decode_range(size_t begin_idx, size_t end_idx, bool use_filter) const
             -> DecodedResultsTsType override;
 
+    [[nodiscard]] auto get_log_event_index_by_timestamp(clp::ir::epoch_time_ms_t timestamp
+    ) -> LogEventIdxTsType override;
+
 private:
     // Constructor
     explicit StructuredIrStreamReader(

src/clp_ffi_js/ir/UnstructuredIrStreamReader.cpp

@@ -158,6 +158,15 @@ auto UnstructuredIrStreamReader::decode_range(size_t begin_idx, size_t end_idx,
     );
 }
 
+auto UnstructuredIrStreamReader::get_log_event_index_by_timestamp(
+        clp::ir::epoch_time_ms_t const timestamp
+) -> LogEventIdxTsType {
+    return generic_get_log_event_index_by_timestamp<UnstructuredLogEvent>(
+            m_encoded_log_events,
+            timestamp
+    );
+}
+
 UnstructuredIrStreamReader::UnstructuredIrStreamReader(
         StreamReaderDataContext<UnstructuredIrDeserializer>&& stream_reader_data_context
 )

src/clp_ffi_js/ir/UnstructuredIrStreamReader.hpp

@@ -71,6 +71,9 @@ class UnstructuredIrStreamReader : public StreamReader {
     [[nodiscard]] auto decode_range(size_t begin_idx, size_t end_idx, bool use_filter) const
             -> DecodedResultsTsType override;
 
+    [[nodiscard]] auto get_log_event_index_by_timestamp(clp::ir::epoch_time_ms_t timestamp
+    ) -> LogEventIdxTsType override;
+
 private:
     // Constructor
     explicit UnstructuredIrStreamReader(