Mercurial > pub > ImplabJs

comparison src/implab/data/RestStore.js @ 34:27e8e9e38e07 default tip

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Слияние
author nickolay
date Wed, 05 Jun 2019 20:44:15 +0300
parents 8af8e840dd49 1dc2fd263b90
children
comparison
equal deleted inserted replaced
33:8af8e840dd49 34:27e8e9e38e07
1 define([ "dojo/_base/declare", "dojo/_base/lang", "dojo/_base/array",
2 "../safe", "dojo/when", "dojo/Deferred", "dojo/store/util/QueryResults" ], function(declare,
3 lang, array, safe, when, Deferred, QueryResults) {
4 /**
5 * @module implab/data/RestStore
6 *
7 * Реализует шаблон репозитария dojo/store над уже имеющимся хранилищем. При получении и
8 * отправке данных в нижележащие хранилище используется implab/data/MapSchema для преобразования
9 * данных.
10 */
11 return declare(null, {
12
13 itemsType : null,
14
15 _dataContext : null,
16
17 _store : null, // backing store
18 _cache : null,
19
20 constructor : function(options) {
21 options = options || {};
22
23 this._cache = {};
24 if (options.store)
25 this._store = options.store;
26 if (options.dataContext)
27 this._dataContext = options.dataContext;
28 },
29
30 setDataContext : function(v) {
31 this._dataContext = v;
32 },
33
34 getDataContext : function() {
35 return this._dataContext;
36 },
37
38 // READ
39 get : function(id) {
40 var me = this;
41 var cache = me.getCacheEntry(id);
42 if (cache)
43 return cache;
44 else
45 return when(me._store.get(id), function(data) {
46 return me._mapToObject(id, data);
47 });
48 },
49
50 query : function(query, options) {
51 var me = this;
52 var d = me._store.query(query, options);
53 var result = QueryResults(when(d, function(data) {
54 return array.map(data, function(item) {
55 return me._mapToObject(me._store.getIdentity(item), item);
56 });
57 }));
58 result.total = d.total;
59 return result;
60 },
61
62 getIdentity : function(object) {
63 return object.getId();
64 },
65
66 // UPDATE
67 put : function(object, directives) {
68 return this._store.put(this._mapFromObject(object), directives);
69 },
70
71 // INSERT
72 add : function(object, directives) {
73 var me = this;
74 // добавляем в хранилище данные, сохраняем в кеше объект с
75 // полученным идентификатором
76 return when(
77 me._store.add(this._mapFromObject(object), directives),
78 function(id) {
79 object.attach(id, me);
80 me.storeCacheEntry(id, object);
81 return id;
82 });
83 },
84
85 // DELETE
86 remove : function(id) {
87 var me = this;
88 return when(me._store.remove(id), function() {
89 me.removeCacheEntry(id);
90 });
91 },
92
93 _mapToObject : function(id, data) {
94 var instance = this.createInstance(id);
95 this.populateInstance(instance, data);
96 return instance;
97 },
98
99 _mapFromObject : function(object) {
100 return this.serializeInstance(object);
101 },
102
103 getCacheEntry : function(id) {
104 safe.argumentNotNull(id, "id");
105 id = id.toString();
106
107 return this._cache[id];
108 },
109
110 storeCacheEntry : function(id, object) {
111 safe.argumentNotNull(id, "id");
112 id = id.toString();
113
114 this._cache[id] = object;
115 },
116
117 removeCacheEntry : function(id) {
118 safe.argumentNotNull(id, "id");
119 id = id.toString();
120 delete this._cache[id];
121 },
122
123 /** Создает экземпляр сущности с указанным идентификатором, либо извлекает из кеша, если таковая уже имеется.
124 * @remarks
125 * Технически сюда можно было бы дополнительно передать данные для ининциализации объекта,
126 * но концептуально это не верно, поскольку процесс чтения объекта состоит из двух этапов:
127 * 1. Создание пустого объекта (createInstance)
128 * 2. Заполнение объекта при помощи схемы отображения (populateInstance)
129 * при этом первый этап может быть выполнен за долго до второго, например,
130 * при создании заглушек в процессе установления ссылок между объектами.
131 */
132 createInstance : function(id) {
133 var instance = this.getCacheEntry(id);
134 if (!instance) {
135 instance = this.createInstanceImpl(id);
136 this.storeCacheEntry(id, instance);
137 }
138 return instance;
139 },
140
141 /** Непосредственно создает экземпляр сущнсти, т.е. является фабричным методом.
142 * @param {String} id идентификатор создаваемого экземпляра.
143 */
144 createInstanceImpl : function(id) {
145 var opts = {
146 dataContext : this.getDataContext(),
147 id : id
148 };
149
150 return new this.itemsType(opts);
151 },
152
153 populateInstance : function(instance, data) {
154 this.itemsType.readData(instance, data,this.getDataContext());
155 if (instance.onPopulate)
156 instance.onPopulate();
157 },
158
159 serializeInstance : function(instance) {
160 var data = {};
161 this.itemsType.writeData(instance, data, this.getDataContext());
162 return data;
163 }
164
165 });
166 });