1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
import { Field, FIELD_ID } from "./fields/Field"
import { Key, KeyStore } from "./fields/Key"
import { ObservableMap, action } from "mobx";
import { Document } from "./fields/Document"
export class SocketStub {
static FieldStore: ObservableMap<FIELD_ID, Field> = new ObservableMap();
public static SEND_ADD_DOCUMENT(document: Document) {
// Send a serialized version of the document to the server
// ...SOCKET(ADD_DOCUMENT, serialied document)
// server stores each document field in its repository of stored fields
document.fields.forEach((f, key) => this.FieldStore.set((f as Field).Id, f as Field));
// server stores stripped down document (w/ only field id proxies) in the field store
this.FieldStore.set(document.Id, new Document(document.Id));
document.fields.forEach((f, key) => (this.FieldStore.get(document.Id) as Document)._proxies.set(key, (f as Field).Id));
}
public static SEND_FIELD_REQUEST(fieldid: FIELD_ID, callback: (field: Field) => void, timeout: number) {
if (timeout < 0)// this is a hack to make things easier to setup until we have a server... won't be neededa fter that.
callback(this.FieldStore.get(fieldid) as Field);
else { // actual logic here...
// Send a request for fieldid to the server
// ...SOCKET(RETRIEVE_FIELD, fieldid)
// server responds (simulated with a timeout) and the callback is invoked
setTimeout(() =>
// when the field data comes back, call the callback() function
callback(this.FieldStore.get(fieldid) as Field),
timeout);
}
}
public static SEND_ADD_DOCUMENT_FIELD(doc: Document, key: Key, value: Field) {
// Send a serialized version of the field to the server along with the
// associated info of the document id and key where it is used.
// ...SOCKET(ADD_DOCUMENT_FIELD, document id, key id, serialized field)
// server updates its document to hold a proxy mapping from key => fieldId
var document = this.FieldStore.get(doc.Id) as Document;
if (document)
document._proxies.set(key, value.Id);
// server adds the field to its repository of fields
this.FieldStore.set(value.Id, value);
}
public static SEND_DELETE_DOCUMENT_FIELD(doc: Document, key: Key) {
// Send a request to delete the field stored under the specified key from the document
// ...SOCKET(DELETE_DOCUMENT_FIELD, document id, key id)
// Server removes the field id from the document's list of field proxies
var document = this.FieldStore.get(doc.Id) as Document;
if (document)
document._proxies.delete(key);
}
public static SEND_SET_FIELD(field: Field, value: any) {
// Send a request to set the value of a field
// ...SOCKET(SET_FIELD, field id, serialized field value)
// Server updates the value of the field in its fieldstore
if (this.FieldStore.get(field.Id))
this.FieldStore.get(field.Id)!.TrySetValue(value);
}
}
|
