123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250 |
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.getAnalyticsController = getAnalyticsController;
- exports.getAuthDataManager = getAuthDataManager;
- exports.getCacheController = getCacheController;
- exports.getControllers = getControllers;
- exports.getDatabaseAdapter = getDatabaseAdapter;
- exports.getDatabaseController = getDatabaseController;
- exports.getFilesController = getFilesController;
- exports.getHooksController = getHooksController;
- exports.getLiveQueryController = getLiveQueryController;
- exports.getLoggerController = getLoggerController;
- exports.getParseGraphQLController = getParseGraphQLController;
- exports.getPushController = getPushController;
- exports.getUserController = getUserController;
- var _Auth = _interopRequireDefault(require("../Adapters/Auth"));
- var _Options = require("../Options");
- var _AdapterLoader = require("../Adapters/AdapterLoader");
- var _defaults = _interopRequireDefault(require("../defaults"));
- var _LoggerController = require("./LoggerController");
- var _FilesController = require("./FilesController");
- var _HooksController = require("./HooksController");
- var _UserController = require("./UserController");
- var _CacheController = require("./CacheController");
- var _LiveQueryController = require("./LiveQueryController");
- var _AnalyticsController = require("./AnalyticsController");
- var _PushController = require("./PushController");
- var _PushQueue = require("../Push/PushQueue");
- var _PushWorker = require("../Push/PushWorker");
- var _DatabaseController = _interopRequireDefault(require("./DatabaseController"));
- var _GridFSBucketAdapter = require("../Adapters/Files/GridFSBucketAdapter");
- var _WinstonLoggerAdapter = require("../Adapters/Logger/WinstonLoggerAdapter");
- var _InMemoryCacheAdapter = require("../Adapters/Cache/InMemoryCacheAdapter");
- var _AnalyticsAdapter = require("../Adapters/Analytics/AnalyticsAdapter");
- var _MongoStorageAdapter = _interopRequireDefault(require("../Adapters/Storage/Mongo/MongoStorageAdapter"));
- var _PostgresStorageAdapter = _interopRequireDefault(require("../Adapters/Storage/Postgres/PostgresStorageAdapter"));
- var _ParseGraphQLController = _interopRequireDefault(require("./ParseGraphQLController"));
- var _SchemaCache = _interopRequireDefault(require("../Adapters/Cache/SchemaCache"));
- function _interopRequireDefault(e) { return e && e.__esModule ? e : { default: e }; }
- function ownKeys(e, r) { var t = Object.keys(e); if (Object.getOwnPropertySymbols) { var o = Object.getOwnPropertySymbols(e); r && (o = o.filter(function (r) { return Object.getOwnPropertyDescriptor(e, r).enumerable; })), t.push.apply(t, o); } return t; }
- function _objectSpread(e) { for (var r = 1; r < arguments.length; r++) { var t = null != arguments[r] ? arguments[r] : {}; r % 2 ? ownKeys(Object(t), !0).forEach(function (r) { _defineProperty(e, r, t[r]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(e, Object.getOwnPropertyDescriptors(t)) : ownKeys(Object(t)).forEach(function (r) { Object.defineProperty(e, r, Object.getOwnPropertyDescriptor(t, r)); }); } return e; }
- function _defineProperty(e, r, t) { return (r = _toPropertyKey(r)) in e ? Object.defineProperty(e, r, { value: t, enumerable: !0, configurable: !0, writable: !0 }) : e[r] = t, e; }
- function _toPropertyKey(t) { var i = _toPrimitive(t, "string"); return "symbol" == typeof i ? i : i + ""; }
- function _toPrimitive(t, r) { if ("object" != typeof t || !t) return t; var e = t[Symbol.toPrimitive]; if (void 0 !== e) { var i = e.call(t, r || "default"); if ("object" != typeof i) return i; throw new TypeError("@@toPrimitive must return a primitive value."); } return ("string" === r ? String : Number)(t); }
- function getControllers(options) {
- const loggerController = getLoggerController(options);
- const filesController = getFilesController(options);
- const userController = getUserController(options);
- const cacheController = getCacheController(options);
- const analyticsController = getAnalyticsController(options);
- const liveQueryController = getLiveQueryController(options);
- const databaseController = getDatabaseController(options);
- const hooksController = getHooksController(options, databaseController);
- const authDataManager = getAuthDataManager(options);
- const parseGraphQLController = getParseGraphQLController(options, {
- databaseController,
- cacheController
- });
- return {
- loggerController,
- filesController,
- userController,
- analyticsController,
- cacheController,
- parseGraphQLController,
- liveQueryController,
- databaseController,
- hooksController,
- authDataManager,
- schemaCache: _SchemaCache.default
- };
- }
- function getLoggerController(options) {
- const {
- appId,
- jsonLogs,
- logsFolder,
- verbose,
- logLevel,
- maxLogFiles,
- silent,
- loggerAdapter
- } = options;
- const loggerOptions = {
- jsonLogs,
- logsFolder,
- verbose,
- logLevel,
- silent,
- maxLogFiles
- };
- const loggerControllerAdapter = (0, _AdapterLoader.loadAdapter)(loggerAdapter, _WinstonLoggerAdapter.WinstonLoggerAdapter, loggerOptions);
- return new _LoggerController.LoggerController(loggerControllerAdapter, appId, loggerOptions);
- }
- function getFilesController(options) {
- const {
- appId,
- databaseURI,
- databaseOptions = {},
- filesAdapter,
- databaseAdapter,
- preserveFileName,
- fileKey
- } = options;
- if (!filesAdapter && databaseAdapter) {
- throw 'When using an explicit database adapter, you must also use an explicit filesAdapter.';
- }
- const filesControllerAdapter = (0, _AdapterLoader.loadAdapter)(filesAdapter, () => {
- return new _GridFSBucketAdapter.GridFSBucketAdapter(databaseURI, databaseOptions, fileKey);
- });
- return new _FilesController.FilesController(filesControllerAdapter, appId, {
- preserveFileName
- });
- }
- function getUserController(options) {
- const {
- appId,
- emailAdapter,
- verifyUserEmails
- } = options;
- const emailControllerAdapter = (0, _AdapterLoader.loadAdapter)(emailAdapter);
- return new _UserController.UserController(emailControllerAdapter, appId, {
- verifyUserEmails
- });
- }
- function getCacheController(options) {
- const {
- appId,
- cacheAdapter,
- cacheTTL,
- cacheMaxSize
- } = options;
- const cacheControllerAdapter = (0, _AdapterLoader.loadAdapter)(cacheAdapter, _InMemoryCacheAdapter.InMemoryCacheAdapter, {
- appId: appId,
- ttl: cacheTTL,
- maxSize: cacheMaxSize
- });
- return new _CacheController.CacheController(cacheControllerAdapter, appId);
- }
- function getParseGraphQLController(options, controllerDeps) {
- return new _ParseGraphQLController.default(_objectSpread({
- mountGraphQL: options.mountGraphQL
- }, controllerDeps));
- }
- function getAnalyticsController(options) {
- const {
- analyticsAdapter
- } = options;
- const analyticsControllerAdapter = (0, _AdapterLoader.loadAdapter)(analyticsAdapter, _AnalyticsAdapter.AnalyticsAdapter);
- return new _AnalyticsController.AnalyticsController(analyticsControllerAdapter);
- }
- function getLiveQueryController(options) {
- return new _LiveQueryController.LiveQueryController(options.liveQuery);
- }
- function getDatabaseController(options) {
- const {
- databaseURI,
- collectionPrefix,
- databaseOptions
- } = options;
- let {
- databaseAdapter
- } = options;
- if ((databaseOptions || databaseURI && databaseURI !== _defaults.default.databaseURI || collectionPrefix !== _defaults.default.collectionPrefix) && databaseAdapter) {
- throw 'You cannot specify both a databaseAdapter and a databaseURI/databaseOptions/collectionPrefix.';
- } else if (!databaseAdapter) {
- databaseAdapter = getDatabaseAdapter(databaseURI, collectionPrefix, databaseOptions);
- } else {
- databaseAdapter = (0, _AdapterLoader.loadAdapter)(databaseAdapter);
- }
- return new _DatabaseController.default(databaseAdapter, options);
- }
- function getHooksController(options, databaseController) {
- const {
- appId,
- webhookKey
- } = options;
- return new _HooksController.HooksController(appId, databaseController, webhookKey);
- }
- async function getPushController(options) {
- const {
- scheduledPush,
- push
- } = options;
- const pushOptions = Object.assign({}, push);
- const pushQueueOptions = pushOptions.queueOptions || {};
- if (pushOptions.queueOptions) {
- delete pushOptions.queueOptions;
- }
-
- const ParsePushAdapter = await (0, _AdapterLoader.loadModule)('@parse/push-adapter');
- const pushAdapter = (0, _AdapterLoader.loadAdapter)(pushOptions && pushOptions.adapter, ParsePushAdapter, pushOptions);
-
-
- const pushController = new _PushController.PushController();
- const hasPushSupport = !!(pushAdapter && push);
- const hasPushScheduledSupport = hasPushSupport && scheduledPush === true;
- const {
- disablePushWorker
- } = pushQueueOptions;
- const pushControllerQueue = new _PushQueue.PushQueue(pushQueueOptions);
- let pushWorker;
- if (!disablePushWorker) {
- pushWorker = new _PushWorker.PushWorker(pushAdapter, pushQueueOptions);
- }
- return {
- pushController,
- hasPushSupport,
- hasPushScheduledSupport,
- pushControllerQueue,
- pushWorker
- };
- }
- function getAuthDataManager(options) {
- const {
- auth,
- enableAnonymousUsers
- } = options;
- return (0, _Auth.default)(auth, enableAnonymousUsers);
- }
- function getDatabaseAdapter(databaseURI, collectionPrefix, databaseOptions) {
- let protocol;
- try {
- const parsedURI = new URL(databaseURI);
- protocol = parsedURI.protocol ? parsedURI.protocol.toLowerCase() : null;
- } catch (e) {
-
- }
- switch (protocol) {
- case 'postgres:':
- case 'postgresql:':
- return new _PostgresStorageAdapter.default({
- uri: databaseURI,
- collectionPrefix,
- databaseOptions
- });
- default:
- return new _MongoStorageAdapter.default({
- uri: databaseURI,
- collectionPrefix,
- mongoOptions: databaseOptions
- });
- }
- }
|