if/SymphonyElectron
1
0
Fork 0
mirror of https://github.com/finos/SymphonyElectron.git synced 2025-02-25 18:55:29 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #187 from keerthi16/SEARCH-155

Browse Source 
Search 155 (Real time indexing)
This commit is contained in:
Vikas Shashidhar 2017-09-18 16:41:35 +05:30 committed by GitHub
commit f72e0b7db6
2 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
demo/search.html
View File

@ -122,7 +122,7 @@
buttonIndex.addEventListener('click', function () { buttonIndex.addEventListener('click', function () {
let batchIndex = batchNumber.value; let batchIndex = batchNumber.value;
search.readJson(batchIndex).then(function (res) { search.readJson(batchIndex).then(function (res) {
search.indexBatch(res).then(function () { search.indexBatch(JSON.stringify(res)).then(function () {
resultsEl.innerHTML = "Index created"; resultsEl.innerHTML = "Index created";
}); });
}).catch(function (err) { }).catch(function (err) {
@ -185,7 +185,7 @@
sendMessage.addEventListener('click', function () { sendMessage.addEventListener('click', function () {
if (realTimeIndexing.value !== "") { if (realTimeIndexing.value !== "") {
let message = JSON.parse(realTimeIndexing.value); let message = realTimeIndexing.value;
resultsEl.innerHTML = search.realTimeIndexing(message); resultsEl.innerHTML = search.realTimeIndexing(message);
} else { } else {
resultsEl.innerHTML = "Please check the entered value" resultsEl.innerHTML = "Please check the entered value"

17
js/search/search.js
View File

@ -109,7 +109,12 @@ class Search {
*/ */
indexBatch(messages) { indexBatch(messages) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
if (!messages && !(JSON.parse(messages) instanceof Array)) { if (!messages) {
reject(new Error('Messages is required'));
return;
}
if (!(JSON.parse(messages) instanceof Array)) {
reject(new Error('Messages must be an array')); reject(new Error('Messages must be an array'));
return; return;
} }
@ -151,15 +156,19 @@ class Search {
* @param message * @param message
*/ */
realTimeIndexing(message) { realTimeIndexing(message) {
if (!Array.isArray(message)) { if (!message) {
return new Error('Messages should be an array'); return new Error('Message is required');
}
if (!(JSON.parse(message) instanceof Array)){
return new Error('Message must be an array');
} }
if (!this.isInitialized) { if (!this.isInitialized) {
return new Error('Library not initialized'); return new Error('Library not initialized');
} }
let result = libSymphonySearch.symSEIndexRealTime(this.realTimeIndex, JSON.stringify(message)); let result = libSymphonySearch.symSEIndexRealTime(this.realTimeIndex, message);
return result === 0 ? "Successful" : result return result === 0 ? "Successful" : result
} }