-
Notifications
You must be signed in to change notification settings - Fork 103
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #277 from VikasShashidhar/master
Revert "Merge pull request #269 from keerthi16/skynet"
- Loading branch information
Showing
15 changed files
with
1,728 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,284 @@ | ||
<!DOCTYPE html> | ||
<html lang="en"> | ||
<head> | ||
<meta charset="UTF-8"> | ||
<title>Search</title> | ||
<style> | ||
table, th, td { | ||
border: 1px solid black; | ||
border-collapse: collapse; | ||
padding: 5px; | ||
text-align: center; | ||
} | ||
|
||
.hidden { | ||
display: none; | ||
} | ||
|
||
input { | ||
padding: 5px; | ||
margin: 2px 0; | ||
border: 1px solid #ccc; | ||
} | ||
|
||
label { | ||
padding-right: 10px; | ||
} | ||
|
||
button { | ||
padding: 10px; | ||
background-color: rgba(0, 64, 98, 0.7); | ||
color: white; | ||
} | ||
</style> | ||
</head> | ||
<body> | ||
<div style="padding: 20px;"> | ||
<h1>Symphony Electron Search API Demo</h1> | ||
<div> | ||
<p>Search</p> | ||
</div> | ||
<div> | ||
<label for="query">Query:</label><input id="query" size=60> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="has">Has:</label><input id="has"> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="offset">Offset:</label><input id="offset" type="number" value="0" size=5> | ||
<label for="limit">Limit:</label><input id="limit" type="number" value="25" size=5> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="start">Start:</label><input id="start" type="date"> | ||
<label for="end">End:</label><input id="end" type="date"> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="senderId">SenderId:</label><input id="senderId" placeholder='["abc", "123"]'> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="threadId">ThreadId:</label><input id="threadId" placeholder='["abc", "123"]'> | ||
</div> | ||
<br> | ||
<div> | ||
<button id='search'>Search</button> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="var1">var1:</label><input id="var1" type="number" value="0" size=5> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="realTimeIndexing">Real Time Indexing:</label><input placeholder="Pass array of messages:" | ||
id="realTimeIndexing"> | ||
<button id='sendMessage'>Send</button> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="batchNumber">Batch Number: </label><input placeholder="Ex: batch1, batch2" id="batchNumber"> | ||
<button id='index'>Index Messages</button> | ||
<button id='merge'>Merge</button> | ||
</div> | ||
<br> | ||
<div> | ||
<label for="batchNumber">Get Latest Message Timestamp</label> | ||
<button id='getLatestMessageTimestamp'>Click</button> | ||
</div> | ||
<br> | ||
<div> | ||
<label>Check Free Space: </label> | ||
<button id='checkFreeSpace'>Click</button> | ||
</div> | ||
<br> | ||
<div> | ||
<label>View User Config</label> | ||
<button id='viewUserConfig'>Click</button> | ||
</div> | ||
<br> | ||
<div> | ||
<div> | ||
<label>Update User Config</label> | ||
</div> | ||
<br> | ||
<label for="rotationId">Rotation Id: </label><input placeholder="Ex: 0, 1" id="rotationId"> | ||
<br> | ||
<label for="version">Version: </label><input placeholder="Ex: 1, 2" id="version"> | ||
<br> | ||
<button id='updateUserConfig'>Save</button> | ||
</div> | ||
<div> | ||
<div> | ||
<p>Results:</p> | ||
<p id="results"></p> | ||
<table id="table" class="hidden" style="width:100%"> | ||
<tr> | ||
<th>ThreadId</th> | ||
<th>SenderId</th> | ||
<th>Text</th> | ||
</tr> | ||
</table> | ||
<br> | ||
</div> | ||
</div> | ||
</div> | ||
|
||
<script> | ||
var search = new ssf.Search("12345678910112", "jjjehdnctsjyieoalskcjdhsnahsadndfnusdfsdfsd="); | ||
var searchUtils = new ssf.SearchUtils(); | ||
var buttonEl = document.getElementById('search'); | ||
var merge = document.getElementById('merge'); | ||
var buttonIndex = document.getElementById('index'); | ||
var queryEl = document.getElementById('query'); | ||
var offsetEl = document.getElementById('offset'); | ||
var limitEl = document.getElementById('limit'); | ||
var startEl = document.getElementById('start'); | ||
var endEl = document.getElementById('end'); | ||
var resultsEl = document.getElementById('results'); | ||
var senderIdEl = document.getElementById('senderId'); | ||
var threadIdEl = document.getElementById('threadId'); | ||
var var1El = document.getElementById('var1'); | ||
var table = document.getElementById('table'); | ||
var sendMessage = document.getElementById('sendMessage'); | ||
var realTimeIndexing = document.getElementById('realTimeIndexing'); | ||
var batchNumber = document.getElementById('batchNumber'); | ||
var timestamp = document.getElementById('getLatestMessageTimestamp'); | ||
var has = document.getElementById('has'); | ||
var checkFreeSpace = document.getElementById('checkFreeSpace'); | ||
var viewUserConfig = document.getElementById('viewUserConfig'); | ||
var version = document.getElementById('version'); | ||
var rotationId = document.getElementById('rotationId'); | ||
var updateUserConfig = document.getElementById('updateUserConfig'); | ||
|
||
|
||
buttonIndex.addEventListener('click', function () { | ||
let batchIndex = batchNumber.value; | ||
search.readJson(batchIndex).then(function (res) { | ||
search.indexBatch(JSON.stringify(res)).then(function () { | ||
resultsEl.innerHTML = "Index created"; | ||
}); | ||
}).catch(function (err) { | ||
console.log(err); | ||
}); | ||
}); | ||
|
||
buttonEl.addEventListener('click', function () { | ||
if (!search.isLibInit()) { | ||
search.init(); | ||
} | ||
let out; | ||
table.innerHTML = ''; | ||
table.classList.remove('hidden'); | ||
let startDate = new Date(startEl.value); | ||
let endDate = new Date(endEl.value); | ||
let threadIdObj, senderIdObj; | ||
if (senderIdEl.value && senderIdEl.value !== "" && senderIdEl.value.replace(/ /g, "").length > 0) { | ||
senderIdObj = JSON.parse(senderIdEl.value); | ||
} | ||
if (threadIdEl.value && threadIdEl.value !== "" && threadIdEl.value.replace(/ /g, "").length > 0) { | ||
threadIdObj = JSON.parse(threadIdEl.value); | ||
} | ||
let _has = has.value || null; | ||
search.searchQuery(queryEl.value, senderIdObj, threadIdObj, _has, startDate, endDate, limitEl.value, offsetEl.value, 0).then(function (result) { | ||
if (result.messages.length < 1) { | ||
resultsEl.innerHTML = "No results found" | ||
} | ||
if (result.messages.length > 0) { | ||
out = result; | ||
var th = document.createElement('tr'); | ||
var th1 = document.createElement('td'); | ||
th1.innerText = "ThreadId"; | ||
var th2 = document.createElement('td'); | ||
th2.innerText = 'SenderId'; | ||
var th3 = document.createElement('td'); | ||
th3.innerText = 'Text'; | ||
th.appendChild(th1); | ||
th.appendChild(th2); | ||
th.appendChild(th3); | ||
table.appendChild(th); | ||
out.messages.forEach(function (msg) { | ||
var tr = document.createElement('tr'); | ||
var t1 = document.createElement('td'); | ||
t1.innerText = msg.threadId; | ||
var t2 = document.createElement('td'); | ||
t2.innerText = msg.senderId; | ||
var t3 = document.createElement('td'); | ||
t3.innerText = msg.text; | ||
tr.appendChild(t1); | ||
tr.appendChild(t2); | ||
tr.appendChild(t3); | ||
table.appendChild(tr); | ||
}); | ||
} | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = 'Error: ' + err; | ||
}); | ||
|
||
}); | ||
|
||
sendMessage.addEventListener('click', function () { | ||
search.deleteRealTimeFolder(); | ||
if (realTimeIndexing.value !== "") { | ||
let message = realTimeIndexing.value; | ||
search.batchRealTimeIndexing(JSON.parse(message)); | ||
resultsEl.innerHTML = 'success'; | ||
} else { | ||
resultsEl.innerHTML = "Please check the entered value" | ||
} | ||
}); | ||
|
||
merge.addEventListener('click', function () { | ||
search.mergeIndexBatches().then(function () { | ||
search.encryptIndex('jjjehdnctsjyieoalskcjdhsnahsadndfnusdfsdfsd=').then(function () { | ||
searchUtils.updateUserConfig(12345678910112, {rotationId:0, version: 1}).then(function (res) { | ||
resultsEl.innerHTML = JSON.stringify(res); | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = JSON.stringify(err); | ||
}); | ||
}); | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = 'Error: ' + err; | ||
}); | ||
}); | ||
|
||
timestamp.addEventListener('click', function () { | ||
search.getLatestMessageTimestamp().then(function (res) { | ||
resultsEl.innerHTML = res; | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = 'Error: ' + err; | ||
}); | ||
}); | ||
|
||
checkFreeSpace.addEventListener('click', function () { | ||
searchUtils.checkFreeSpace().then(function (res) { | ||
resultsEl.innerHTML = res ? "Free Disk Space Available" : "Insufficient Disk Space"; | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = err; | ||
}); | ||
}); | ||
|
||
viewUserConfig.addEventListener('click', function () { | ||
searchUtils.getSearchUserConfig(12345678910112).then(function (res) { | ||
resultsEl.innerHTML = JSON.stringify(res); | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = JSON.stringify(err); | ||
}); | ||
}); | ||
|
||
updateUserConfig.addEventListener('click', function () { | ||
var data = { | ||
rotationId: rotationId.value || 0, | ||
version: version.value || 1 | ||
}; | ||
searchUtils.updateUserConfig(12345678910112, data).then(function (res) { | ||
resultsEl.innerHTML = JSON.stringify(res); | ||
}).catch(function (err) { | ||
resultsEl.innerHTML = JSON.stringify(err); | ||
}); | ||
}); | ||
</script> | ||
</body> | ||
</html> |
Oops, something went wrong.