postgres/typesense
1
0
Fork 0
mirror of https://github.com/typesense/typesense.git synced 2025-05-21 22:33:27 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

update boundary condition for click_event and using event timestamp

Browse Source
This commit is contained in:
krunal 2023-12-01 15:40:15 +05:30
parent 52add3e742
commit aff1f3b9fa
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/analytics_manager.cpp
View File

@ -584,8 +584,7 @@ Option<bool> AnalyticsManager::write_events_to_store(nlohmann::json &event_jsons
//LOG(INFO) << "writing events to analytics db";
for(const auto& event_json : event_jsons) {
auto collection_id = event_json["collection_id"].get<std::string>();
auto timestamp = std::chrono::duration_cast<std::chrono::microseconds>(
std::chrono::system_clock::now().time_since_epoch()).count();
auto timestamp = event_json["timestamp"].get<uint64_t>();
std::string key = "_" + StringUtils::serialize_uint64_t(timestamp) + "_" + collection_id;
if(event_json["event_type"] == "click_events") {
@ -632,7 +631,7 @@ void AnalyticsManager::checkEventsExpiry() {
auto iter = analytics_store->get_iterator();
iter->Seek(delete_prefix_end);
if (!iter->Valid()) { //exact key or key greater than not found
delete_prefix_end = query_hits_prefix;
delete_prefix_end = std::string(CLICK_EVENT) + "`";
}
analytics_store->delete_range(delete_prefix_begin, delete_prefix_end);