mirror of
https://github.com/finos/SymphonyElectron.git
synced 2025-02-25 18:55:29 -06:00
SEARCH-154 - get latest messages timestamp
This commit is contained in:
@@ -172,6 +172,7 @@
|
|||||||
|
|
||||||
merge.addEventListener('click', function () {
|
merge.addEventListener('click', function () {
|
||||||
search.mergeIndexBatches();
|
search.mergeIndexBatches();
|
||||||
|
search.getLatestMessageTimestamp();
|
||||||
})
|
})
|
||||||
</script>
|
</script>
|
||||||
</html>
|
</html>
|
||||||
@@ -232,6 +232,24 @@ class Search {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
getLatestMessageTimestamp() {
|
||||||
|
let self = this;
|
||||||
|
return new Promise(function (resolve, reject) {
|
||||||
|
libSymphonySearch.symSEGetLastMessageTimestampAsync(self.indexFolderName, function (err, res) {
|
||||||
|
if (err) {
|
||||||
|
reject(new Error(err));
|
||||||
|
}
|
||||||
|
const returnedResult = res;
|
||||||
|
try {
|
||||||
|
let ret = returnedResult.readCString();
|
||||||
|
resolve(ret);
|
||||||
|
} finally {
|
||||||
|
libSymphonySearch.symSEFreeResult(returnedResult);
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* This the query constructor
|
* This the query constructor
|
||||||
* for the query search function
|
* for the query search function
|
||||||
|
|||||||
@@ -48,7 +48,10 @@ let libSymphonySearch = ffi.Library(libraryPath, {
|
|||||||
//Index commit/optimize
|
//Index commit/optimize
|
||||||
'symSE_commit_index': ['int', [symLucyIndexerPtr, 'int']], //will be removed
|
'symSE_commit_index': ['int', [symLucyIndexerPtr, 'int']], //will be removed
|
||||||
//freePointer
|
//freePointer
|
||||||
'symSE_free_results': ['int', ['char *']]
|
'symSE_free_results': ['int', ['char *']],
|
||||||
|
|
||||||
|
//Latest messages timestamp
|
||||||
|
'symSE_get_last_message_timestamp': ['char *', ['string']]
|
||||||
});
|
});
|
||||||
|
|
||||||
module.exports = {
|
module.exports = {
|
||||||
@@ -66,6 +69,7 @@ module.exports = {
|
|||||||
symSEDeleteMessages: libSymphonySearch.symSE_delete_messages,
|
symSEDeleteMessages: libSymphonySearch.symSE_delete_messages,
|
||||||
symSECommitIndex: libSymphonySearch.symSE_commit_index,
|
symSECommitIndex: libSymphonySearch.symSE_commit_index,
|
||||||
symSEFreeResult: libSymphonySearch.symSE_free_results,
|
symSEFreeResult: libSymphonySearch.symSE_free_results,
|
||||||
|
symSEGetLastMessageTimestamp: libSymphonySearch.symSE_get_last_message_timestamp,
|
||||||
symSEInitAsync: libSymphonySearch.symSE_init.async,
|
symSEInitAsync: libSymphonySearch.symSE_init.async,
|
||||||
symSERemoveFolderAsync: libSymphonySearch.symSE_remove_folder.async,
|
symSERemoveFolderAsync: libSymphonySearch.symSE_remove_folder.async,
|
||||||
symSEEnsureIndexExistsAsync: libSymphonySearch.symSE_ensure_index_exists.async,
|
symSEEnsureIndexExistsAsync: libSymphonySearch.symSE_ensure_index_exists.async,
|
||||||
@@ -79,5 +83,6 @@ module.exports = {
|
|||||||
symSESearchAsync: libSymphonySearch.symSE_search.async,
|
symSESearchAsync: libSymphonySearch.symSE_search.async,
|
||||||
symSEDeleteMessagesAsync: libSymphonySearch.symSE_delete_messages.async,
|
symSEDeleteMessagesAsync: libSymphonySearch.symSE_delete_messages.async,
|
||||||
symSECommitIndexAsync: libSymphonySearch.symSE_commit_index.async,
|
symSECommitIndexAsync: libSymphonySearch.symSE_commit_index.async,
|
||||||
symSEFreeResultAsync: libSymphonySearch.symSE_free_results.async
|
symSEFreeResultAsync: libSymphonySearch.symSE_free_results.async,
|
||||||
|
symSEGetLastMessageTimestampAsync: libSymphonySearch.symSE_get_last_message_timestamp.async
|
||||||
};
|
};
|
||||||
Reference in New Issue
Block a user