aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/server/Search.ts1
-rw-r--r--src/server/index.ts9
2 files changed, 10 insertions, 0 deletions
diff --git a/src/server/Search.ts b/src/server/Search.ts
index 7d8602346..bcea03d5c 100644
--- a/src/server/Search.ts
+++ b/src/server/Search.ts
@@ -6,6 +6,7 @@ export class Search {
private url = 'http://localhost:8983/solr/';
public updateDocument(document: any): rp.RequestPromise {
+ console.log(JSON.stringify(document));
return rp.post(this.url + "dash/update/json/docs", {
headers: { 'content-type': 'application/json' },
body: JSON.stringify(document)
diff --git a/src/server/index.ts b/src/server/index.ts
index a68dabc0c..b3df90199 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -34,6 +34,7 @@ import expressFlash = require('express-flash');
import flash = require('connect-flash');
import c = require("crypto");
import { Search } from './Search';
+import { debug } from 'util';
const MongoStore = require('connect-mongo')(session);
const mongoose = require('mongoose');
@@ -276,6 +277,7 @@ function setField(socket: Socket, newValue: Transferable) {
socket.broadcast.emit(MessageStore.SetField.Message, newValue));
if (newValue.type === Types.Text) {
Search.Instance.updateDocument({ id: newValue.id, data: (newValue as any).data });
+ console.log("set field");
}
}
@@ -286,10 +288,17 @@ function GetRefField([id, callback]: [string, (result?: Transferable) => void])
function UpdateField(socket: Socket, diff: Diff) {
Database.Instance.update(diff.id, diff.diff,
() => socket.broadcast.emit(MessageStore.UpdateField.Message, diff), false, "newDocuments");
+ //if (diff.diff === Types.Text) {
+ Search.Instance.updateDocument({ name: "john", burns: "true" });
+ Search.Instance.updateDocument({ id: diff.id, data: diff.diff.data });
+ //console.log("set field");
+ //}
+ console.log("updated field", diff.diff);
}
function CreateField(newValue: any) {
Database.Instance.insert(newValue, "newDocuments");
+ console.log("created field");
}
server.listen(serverPort);