CoreManager.js 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507
  1. /*:: import type { AttributeMap, ObjectCache, OpsMap, State } from './ObjectStateMutations';*/
  2. /*:: import type ParseFile from './ParseFile';*/
  3. /*:: import type { FileSource } from './ParseFile';*/
  4. /*:: import type { Op } from './ParseOp';*/
  5. /*:: import type ParseObject from './ParseObject';*/
  6. /*:: import type { QueryJSON } from './ParseQuery';*/
  7. /*:: import type ParseUser from './ParseUser';*/
  8. /*:: import type { AuthData } from './ParseUser';*/
  9. /*:: import type { PushData } from './Push';*/
  10. /*:: import type { RequestOptions, FullOptions } from './RESTController';*/
  11. /*:: type AnalyticsController = {
  12. track: (name: string, dimensions: { [key: string]: string }) => Promise;
  13. };*/
  14. /*:: type CloudController = {
  15. run: (name: string, data: mixed, options: RequestOptions) => Promise;
  16. getJobsData: (options: RequestOptions) => Promise;
  17. startJob: (name: string, data: mixed, options: RequestOptions) => Promise;
  18. };*/
  19. /*:: type ConfigController = {
  20. current: () => Promise;
  21. get: () => Promise;
  22. save: (attrs: { [key: string]: any }) => Promise;
  23. };*/
  24. /*:: type FileController = {
  25. saveFile: (name: string, source: FileSource, options: FullOptions) => Promise;
  26. saveBase64: (name: string, source: FileSource, options: FullOptions) => Promise;
  27. download: (uri: string) => Promise;
  28. };*/
  29. /*:: type InstallationController = {
  30. currentInstallationId: () => Promise;
  31. };*/
  32. /*:: type ObjectController = {
  33. fetch: (object: ParseObject | Array<ParseObject>, forceFetch: boolean, options: RequestOptions) => Promise;
  34. save: (object: ParseObject | Array<ParseObject | ParseFile>, options: RequestOptions) => Promise;
  35. destroy: (object: ParseObject | Array<ParseObject>, options: RequestOptions) => Promise;
  36. };*/
  37. /*:: type ObjectStateController = {
  38. getState: (obj: any) => ?State;
  39. initializeState: (obj: any, initial?: State) => State;
  40. removeState: (obj: any) => ?State;
  41. getServerData: (obj: any) => AttributeMap;
  42. setServerData: (obj: any, attributes: AttributeMap) => void;
  43. getPendingOps: (obj: any) => Array<OpsMap>;
  44. setPendingOp: (obj: any, attr: string, op: ?Op) => void;
  45. pushPendingState: (obj: any) => void;
  46. popPendingState: (obj: any) => OpsMap;
  47. mergeFirstPendingState: (obj: any) => void;
  48. getObjectCache: (obj: any) => ObjectCache;
  49. estimateAttribute: (obj: any, attr: string) => mixed;
  50. estimateAttributes: (obj: any) => AttributeMap;
  51. commitServerChanges: (obj: any, changes: AttributeMap) => void;
  52. enqueueTask: (obj: any, task: () => Promise) => Promise;
  53. clearAllState: () => void;
  54. duplicateState: (source: any, dest: any) => void;
  55. };*/
  56. /*:: type PushController = {
  57. send: (data: PushData, options: RequestOptions) => Promise;
  58. };*/
  59. /*:: type QueryController = {
  60. find: (className: string, params: QueryJSON, options: RequestOptions) => Promise;
  61. aggregate: (className: string, params: any, options: RequestOptions) => Promise;
  62. };*/
  63. /*:: type RESTController = {
  64. request: (method: string, path: string, data: mixed, options: RequestOptions) => Promise;
  65. ajax: (method: string, url: string, data: any, headers?: any, options: FullOptions) => Promise;
  66. };*/
  67. /*:: type SchemaController = {
  68. purge: (className: string) => Promise;
  69. get: (className: string, options: RequestOptions) => Promise;
  70. delete: (className: string, options: RequestOptions) => Promise;
  71. create: (className: string, params: any, options: RequestOptions) => Promise;
  72. update: (className: string, params: any, options: RequestOptions) => Promise;
  73. send(className: string, method: string, params: any, options: RequestOptions): Promise;
  74. };*/
  75. /*:: type SessionController = {
  76. getSession: (token: RequestOptions) => Promise;
  77. };*/
  78. /*:: type StorageController = {
  79. async: 0;
  80. getItem: (path: string) => ?string;
  81. setItem: (path: string, value: string) => void;
  82. removeItem: (path: string) => void;
  83. getItemAsync?: (path: string) => Promise;
  84. setItemAsync?: (path: string, value: string) => Promise;
  85. removeItemAsync?: (path: string) => Promise;
  86. clear: () => void;
  87. } | {
  88. async: 1;
  89. getItem?: (path: string) => ?string;
  90. setItem?: (path: string, value: string) => void;
  91. removeItem?: (path: string) => void;
  92. getItemAsync: (path: string) => Promise;
  93. setItemAsync: (path: string, value: string) => Promise;
  94. removeItemAsync: (path: string) => Promise;
  95. clear: () => void;
  96. };*/
  97. /*:: type LocalDatastoreController = {
  98. fromPinWithName: (name: string) => ?any;
  99. pinWithName: (name: string, objects: any) => void;
  100. unPinWithName: (name: string) => void;
  101. getAllContents: () => ?any;
  102. clear: () => void;
  103. };*/
  104. /*:: type UserController = {
  105. setCurrentUser: (user: ParseUser) => Promise;
  106. currentUser: () => ?ParseUser;
  107. currentUserAsync: () => Promise;
  108. signUp: (user: ParseUser, attrs: AttributeMap, options: RequestOptions) => Promise;
  109. logIn: (user: ParseUser, options: RequestOptions) => Promise;
  110. become: (options: RequestOptions) => Promise;
  111. hydrate: (userJSON: AttributeMap) => Promise;
  112. logOut: (options: RequestOptions) => Promise;
  113. me: (options: RequestOptions) => Promise;
  114. requestPasswordReset: (email: string, options: RequestOptions) => Promise;
  115. updateUserOnDisk: (user: ParseUser) => Promise;
  116. upgradeToRevocableSession: (user: ParseUser, options: RequestOptions) => Promise;
  117. linkWith: (user: ParseUser, authData: AuthData) => Promise;
  118. removeUserFromDisk: () => Promise;
  119. };*/
  120. /*:: type HooksController = {
  121. get: (type: string, functionName?: string, triggerName?: string) => Promise;
  122. create: (hook: mixed) => Promise;
  123. delete: (hook: mixed) => Promise;
  124. update: (hook: mixed) => Promise;
  125. send: (method: string, path: string, body?: mixed) => Promise;
  126. };*/
  127. /*:: type WebSocketController = {
  128. onopen: () => void;
  129. onmessage: (message: any) => void;
  130. onclose: () => void;
  131. onerror: (error: any) => void;
  132. send: (data: any) => void;
  133. close: () => void;
  134. }*/
  135. /*:: type Config = {
  136. AnalyticsController?: AnalyticsController,
  137. CloudController?: CloudController,
  138. ConfigController?: ConfigController,
  139. FileController?: FileController,
  140. InstallationController?: InstallationController,
  141. ObjectController?: ObjectController,
  142. ObjectStateController?: ObjectStateController,
  143. PushController?: PushController,
  144. QueryController?: QueryController,
  145. RESTController?: RESTController,
  146. SchemaController?: SchemaController,
  147. SessionController?: SessionController,
  148. StorageController?: StorageController,
  149. LocalDatastoreController?: LocalDatastoreController,
  150. UserController?: UserController,
  151. HooksController?: HooksController,
  152. WebSocketController?: WebSocketController,
  153. };*/
  154. "use strict";
  155. /*
  156. * Copyright (c) 2015-present, Parse, LLC.
  157. * All rights reserved.
  158. *
  159. * This source code is licensed under the BSD-style license found in the
  160. * LICENSE file in the root directory of this source tree. An additional grant
  161. * of patent rights can be found in the PATENTS file in the same directory.
  162. *
  163. * @flow
  164. */
  165. const config
  166. /*: Config & { [key: string]: mixed }*/
  167. = {
  168. // Defaults
  169. IS_NODE: typeof process !== 'undefined' && !!process.versions && !!process.versions.node && !process.versions.electron,
  170. REQUEST_ATTEMPT_LIMIT: 5,
  171. SERVER_URL: 'https://api.parse.com/1',
  172. SERVER_AUTH_TYPE: null,
  173. SERVER_AUTH_TOKEN: null,
  174. LIVEQUERY_SERVER_URL: null,
  175. VERSION: 'js' + "2.6.0",
  176. APPLICATION_ID: null,
  177. JAVASCRIPT_KEY: null,
  178. MASTER_KEY: null,
  179. USE_MASTER_KEY: false,
  180. PERFORM_USER_REWRITE: true,
  181. FORCE_REVOCABLE_SESSION: false
  182. };
  183. function requireMethods(name
  184. /*: string*/
  185. , methods
  186. /*: Array<string>*/
  187. , controller
  188. /*: any*/
  189. ) {
  190. methods.forEach(func => {
  191. if (typeof controller[func] !== 'function') {
  192. throw new Error(`${name} must implement ${func}()`);
  193. }
  194. });
  195. }
  196. module.exports = {
  197. get: function (key
  198. /*: string*/
  199. )
  200. /*: any*/
  201. {
  202. if (config.hasOwnProperty(key)) {
  203. return config[key];
  204. }
  205. throw new Error('Configuration key not found: ' + key);
  206. },
  207. set: function (key
  208. /*: string*/
  209. , value
  210. /*: any*/
  211. )
  212. /*: void*/
  213. {
  214. config[key] = value;
  215. },
  216. /* Specialized Controller Setters/Getters */
  217. setAnalyticsController(controller
  218. /*: AnalyticsController*/
  219. ) {
  220. requireMethods('AnalyticsController', ['track'], controller);
  221. config['AnalyticsController'] = controller;
  222. },
  223. getAnalyticsController()
  224. /*: AnalyticsController*/
  225. {
  226. return config['AnalyticsController'];
  227. },
  228. setCloudController(controller
  229. /*: CloudController*/
  230. ) {
  231. requireMethods('CloudController', ['run', 'getJobsData', 'startJob'], controller);
  232. config['CloudController'] = controller;
  233. },
  234. getCloudController()
  235. /*: CloudController*/
  236. {
  237. return config['CloudController'];
  238. },
  239. setConfigController(controller
  240. /*: ConfigController*/
  241. ) {
  242. requireMethods('ConfigController', ['current', 'get', 'save'], controller);
  243. config['ConfigController'] = controller;
  244. },
  245. getConfigController()
  246. /*: ConfigController*/
  247. {
  248. return config['ConfigController'];
  249. },
  250. setFileController(controller
  251. /*: FileController*/
  252. ) {
  253. requireMethods('FileController', ['saveFile', 'saveBase64'], controller);
  254. config['FileController'] = controller;
  255. },
  256. getFileController()
  257. /*: FileController*/
  258. {
  259. return config['FileController'];
  260. },
  261. setInstallationController(controller
  262. /*: InstallationController*/
  263. ) {
  264. requireMethods('InstallationController', ['currentInstallationId'], controller);
  265. config['InstallationController'] = controller;
  266. },
  267. getInstallationController()
  268. /*: InstallationController*/
  269. {
  270. return config['InstallationController'];
  271. },
  272. setObjectController(controller
  273. /*: ObjectController*/
  274. ) {
  275. requireMethods('ObjectController', ['save', 'fetch', 'destroy'], controller);
  276. config['ObjectController'] = controller;
  277. },
  278. getObjectController()
  279. /*: ObjectController*/
  280. {
  281. return config['ObjectController'];
  282. },
  283. setObjectStateController(controller
  284. /*: ObjectStateController*/
  285. ) {
  286. requireMethods('ObjectStateController', ['getState', 'initializeState', 'removeState', 'getServerData', 'setServerData', 'getPendingOps', 'setPendingOp', 'pushPendingState', 'popPendingState', 'mergeFirstPendingState', 'getObjectCache', 'estimateAttribute', 'estimateAttributes', 'commitServerChanges', 'enqueueTask', 'clearAllState'], controller);
  287. config['ObjectStateController'] = controller;
  288. },
  289. getObjectStateController()
  290. /*: ObjectStateController*/
  291. {
  292. return config['ObjectStateController'];
  293. },
  294. setPushController(controller
  295. /*: PushController*/
  296. ) {
  297. requireMethods('PushController', ['send'], controller);
  298. config['PushController'] = controller;
  299. },
  300. getPushController()
  301. /*: PushController*/
  302. {
  303. return config['PushController'];
  304. },
  305. setQueryController(controller
  306. /*: QueryController*/
  307. ) {
  308. requireMethods('QueryController', ['find', 'aggregate'], controller);
  309. config['QueryController'] = controller;
  310. },
  311. getQueryController()
  312. /*: QueryController*/
  313. {
  314. return config['QueryController'];
  315. },
  316. setRESTController(controller
  317. /*: RESTController*/
  318. ) {
  319. requireMethods('RESTController', ['request', 'ajax'], controller);
  320. config['RESTController'] = controller;
  321. },
  322. getRESTController()
  323. /*: RESTController*/
  324. {
  325. return config['RESTController'];
  326. },
  327. setSchemaController(controller
  328. /*: SchemaController*/
  329. ) {
  330. requireMethods('SchemaController', ['get', 'create', 'update', 'delete', 'send', 'purge'], controller);
  331. config['SchemaController'] = controller;
  332. },
  333. getSchemaController()
  334. /*: SchemaController*/
  335. {
  336. return config['SchemaController'];
  337. },
  338. setSessionController(controller
  339. /*: SessionController*/
  340. ) {
  341. requireMethods('SessionController', ['getSession'], controller);
  342. config['SessionController'] = controller;
  343. },
  344. getSessionController()
  345. /*: SessionController*/
  346. {
  347. return config['SessionController'];
  348. },
  349. setStorageController(controller
  350. /*: StorageController*/
  351. ) {
  352. if (controller.async) {
  353. requireMethods('An async StorageController', ['getItemAsync', 'setItemAsync', 'removeItemAsync'], controller);
  354. } else {
  355. requireMethods('A synchronous StorageController', ['getItem', 'setItem', 'removeItem'], controller);
  356. }
  357. config['StorageController'] = controller;
  358. },
  359. setLocalDatastoreController(controller
  360. /*: LocalDatastoreController*/
  361. ) {
  362. requireMethods('LocalDatastoreController', ['pinWithName', 'fromPinWithName', 'unPinWithName', 'getAllContents', 'clear'], controller);
  363. config['LocalDatastoreController'] = controller;
  364. },
  365. getLocalDatastoreController()
  366. /*: LocalDatastoreController*/
  367. {
  368. return config['LocalDatastoreController'];
  369. },
  370. setLocalDatastore(store
  371. /*: any*/
  372. ) {
  373. config['LocalDatastore'] = store;
  374. },
  375. getLocalDatastore() {
  376. return config['LocalDatastore'];
  377. },
  378. getStorageController()
  379. /*: StorageController*/
  380. {
  381. return config['StorageController'];
  382. },
  383. setAsyncStorage(storage
  384. /*: any*/
  385. ) {
  386. config['AsyncStorage'] = storage;
  387. },
  388. getAsyncStorage() {
  389. return config['AsyncStorage'];
  390. },
  391. setWebSocketController(controller
  392. /*: WebSocketController*/
  393. ) {
  394. config['WebSocketController'] = controller;
  395. },
  396. getWebSocketController()
  397. /*: WebSocketController*/
  398. {
  399. return config['WebSocketController'];
  400. },
  401. setUserController(controller
  402. /*: UserController*/
  403. ) {
  404. requireMethods('UserController', ['setCurrentUser', 'currentUser', 'currentUserAsync', 'signUp', 'logIn', 'become', 'logOut', 'me', 'requestPasswordReset', 'upgradeToRevocableSession', 'linkWith'], controller);
  405. config['UserController'] = controller;
  406. },
  407. getUserController()
  408. /*: UserController*/
  409. {
  410. return config['UserController'];
  411. },
  412. setLiveQueryController(controller
  413. /*: any*/
  414. ) {
  415. requireMethods('LiveQueryController', ['setDefaultLiveQueryClient', 'getDefaultLiveQueryClient', '_clearCachedDefaultClient'], controller);
  416. config['LiveQueryController'] = controller;
  417. },
  418. getLiveQueryController()
  419. /*: any*/
  420. {
  421. return config['LiveQueryController'];
  422. },
  423. setHooksController(controller
  424. /*: HooksController*/
  425. ) {
  426. requireMethods('HooksController', ['create', 'get', 'update', 'remove'], controller);
  427. config['HooksController'] = controller;
  428. },
  429. getHooksController()
  430. /*: HooksController*/
  431. {
  432. return config['HooksController'];
  433. }
  434. };