Mercurial > pub > ImplabJs

comparison src/implab/data/RestStore.js @ 0:fc2517695ee1

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Initial commit, draft import of existing work
author cin
date Thu, 01 Jun 2017 13:20:03 +0300
parents
children f0035923ff3e
comparison
equal deleted inserted replaced
-1:000000000000 0:fc2517695ee1
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 core/data/RestStore
6 *
7 * Реализует шаблон репозитария dojo/store над уже имеющимся хранилищем. При получении и
8 * отправке данных в нижележащие хранилище используется core/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 });