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

Increment seq id only for valid docs during indexing.

Browse Source
This commit is contained in:
kishorenc 2020-09-25 07:17:29 +05:30
parent 249c4886dc
commit 9716aa5b55
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/collection.cpp
View File

@ -111,21 +111,23 @@ Option<uint32_t> Collection::to_doc(const std::string & json_str, nlohmann::json
return Option<uint32_t>(400, "Bad JSON: not a properly formed document.");
}
uint32_t seq_id = get_next_seq_id();
std::string seq_id_str = std::to_string(seq_id);
if(document.count("id") == 0) {
document["id"] = seq_id_str;
} else if(!document["id"].is_string()) {
return Option<uint32_t>(400, "Document's `id` field should be a string.");
}
uint32_t seq_id = get_next_seq_id();
document["id"] = std::to_string(seq_id);
return Option<uint32_t>(seq_id);
} else {
if(!document["id"].is_string()) {
return Option<uint32_t>(400, "Document's `id` field should be a string.");
}
const std::string& doc_id = document["id"];
if(doc_exists(doc_id)) {
return Option<uint32_t>(409, std::string("A document with id ") + doc_id + " already exists.");
}
const std::string& doc_id = document["id"];
if(doc_exists(doc_id)) {
return Option<uint32_t>(409, std::string("A document with id ") + doc_id + " already exists.");
}
return Option<uint32_t>(seq_id);
uint32_t seq_id = get_next_seq_id();
return Option<uint32_t>(seq_id);
}
}
nlohmann::json Collection::get_summary_json() {