diff options
author | yipstanley <stanley_yip@brown.edu> | 2019-02-13 20:17:21 -0500 |
---|---|---|
committer | yipstanley <stanley_yip@brown.edu> | 2019-02-13 20:17:21 -0500 |
commit | f3544f004a696e4682fbd8d1f18ac69beec59439 (patch) | |
tree | 0839c355fe813ba494c6451b9017c5e325e1cfb8 /src/server/index.ts | |
parent | 430878f6dd8d36b1322e15d0898ada0d44fecacb (diff) |
asdfkj
Diffstat (limited to 'src/server/index.ts')
-rw-r--r-- | src/server/index.ts | 33 |
1 files changed, 19 insertions, 14 deletions
diff --git a/src/server/index.ts b/src/server/index.ts index 98d897d2f..b256b6a82 100644 --- a/src/server/index.ts +++ b/src/server/index.ts @@ -13,6 +13,7 @@ import { FIELD_ID, Field } from '../fields/Field'; import { Database } from './database'; import { ServerUtils } from './ServerUtil'; import { ObjectID } from 'mongodb'; +import { Document } from '../fields/Document'; const config = require('../../webpack.config') const compiler = webpack(config) const port = 1050; // default port to listen @@ -65,22 +66,26 @@ function addDocument(document: Document) { } -function setField(newValue: Transferable) { - console.log(newValue._id) - if (Database.Instance.getDocument(newValue._id)) { - Database.Instance.update(newValue._id, newValue) - } - else { - Database.Instance.insert(newValue) - } +function getField([id, callback]: [string, (result: any) => void]) { + Database.Instance.getDocument(id, (result: any) => { + if (result) { + callback(result) + } + else { + callback(undefined) + } + }) } -function getField([fieldRequest, callback]: [GetFieldArgs, (field: Field) => void]) { - let fieldid: string = fieldRequest.field - let result: string | undefined = Database.Instance.getDocument(new ObjectID(fieldid)) - if (result) { - let fromJson: Field = ServerUtils.FromJson(result) - } +function setField(newValue: Transferable) { + Database.Instance.getDocument(newValue._id, (res: any) => { + if (res) { + Database.Instance.update(newValue._id, newValue) + } + else { + Database.Instance.insert(newValue) + } + }) } server.listen(serverPort); |