FIX api service manager

ahmetkuslular · ahmetkuslular · commit c8b5ceddccc8 · 2022-05-27T14:43:11.000+03:00
diff --git a/src/index.js b/src/index.js
@@ -1,6 +1,5 @@
 import voltran from './universal/partials/withBaseComponent';
-import { SERVICES } from './universal/utils/constants';
-import { ClientApiManager, ServerApiManager } from './universal/core/api';
+import apiService, { ClientApiManager, ServerApiManager } from './universal/core/apiService';
 
 export default voltran;
-export { SERVICES, ClientApiManager, ServerApiManager };
+export { ClientApiManager, ServerApiManager, apiService };
diff --git a/src/renderMultiple.js b/src/renderMultiple.js
@@ -63,32 +63,24 @@ function getRenderer(name, req) {
 }
 
 function iterateServicesMap(servicesMap, callback) {
-  Object.getOwnPropertySymbols(servicesMap).forEach(serviceName => {
-    const endPoints = servicesMap[serviceName];
+  Object.getOwnPropertyNames(servicesMap).forEach(serviceName => {
+    const requests = servicesMap[serviceName];
 
-    Object.keys(endPoints).forEach(endPointName => {
-      callback(serviceName, endPointName);
-    });
+    callback(serviceName, requests);
   });
 }
 
-function reduceServicesMap(servicesMap, callback, initialValue) {
-  return Object.getOwnPropertySymbols(servicesMap).map(serviceName => {
-    const endPoints = servicesMap[serviceName];
-
-    return Object.keys(endPoints).reduce((obj, endPointName) => {
-      return callback(serviceName, endPointName, obj);
-    }, initialValue);
+function reduceServicesMap(servicesMap, callback, obj) {
+  return Object.getOwnPropertyNames(servicesMap).map(serviceName => {
+    return callback(serviceName, obj);
   });
 }
 
 function getHashes(renderers) {
   return renderers
     .filter(renderer => renderer.servicesMap)
     .reduce((hashes, renderer) => {
-      iterateServicesMap(renderer.servicesMap, (serviceName, endPointName) => {
-        const requests = renderer.servicesMap[serviceName][endPointName];
-
+      iterateServicesMap(renderer.servicesMap, (serviceName, requests) => {
         requests.forEach(request => {
           if (hashes[request.hash]) {
             hashes[request.hash].occurrence += 1;
@@ -121,12 +113,8 @@ function incWinnerScore(winner, hashes) {
   hashes[winner.hash].score += 1;
 }
 
-function putWinnerMap(serviceName, endPointName, winnerMap, winner) {
-  if (winnerMap[serviceName]) {
-    winnerMap[serviceName][endPointName] = winner;
-  } else {
-    winnerMap[serviceName] = { [endPointName]: winner };
-  }
+function putWinnerMap(serviceName, winnerMap, winner) {
+  winnerMap[serviceName] = winner;
 }
 
 async function setInitialStates(renderers) {
@@ -135,12 +123,10 @@ async function setInitialStates(renderers) {
   const promises = renderers
     .filter(renderer => renderer.servicesMap)
     .reduce((promises, renderer) => {
-      iterateServicesMap(renderer.servicesMap, (serviceName, endPointName) => {
-        const requests = renderer.servicesMap[serviceName][endPointName];
-
+      iterateServicesMap(renderer.servicesMap, (serviceName, requests) => {
         const winner = getWinner(requests, hashes);
         incWinnerScore(winner, hashes);
-        putWinnerMap(serviceName, endPointName, renderer.winnerMap, winner);
+        putWinnerMap(serviceName, renderer.winnerMap, winner);
 
         if (!promises[winner.hash]) {
           promises[winner.hash] = callback => {
@@ -176,9 +162,9 @@ async function setInitialStates(renderers) {
       renderer.setInitialState(
         reduceServicesMap(
           renderer.winnerMap,
-          (serviceName, endPointName, obj) => {
-            const request = renderer.winnerMap[serviceName][endPointName];
-            obj[endPointName] = results[request.hash];
+          (serviceName, obj) => {
+            const request = renderer.winnerMap[serviceName];
+            obj[serviceName] = results[request.hash];
             return obj;
           },
           {}
diff --git a/src/universal/core/api/ClientApiManager.js b/src/universal/core/api/ClientApiManager.js
diff --git a/src/universal/core/api/ClientApiManagerCache.js b/src/universal/core/api/ClientApiManagerCache.js
diff --git a/src/universal/core/api/ServerApiManagerCache.js b/src/universal/core/api/ServerApiManagerCache.js
diff --git a/src/universal/core/api/index.js b/src/universal/core/api/index.js
diff --git a/src/universal/core/apiService/apiManager/BaseApiManager.js b/src/universal/core/apiService/apiManager/BaseApiManager.js
@@ -3,13 +3,13 @@ import {
   CONTENT_TYPE_HEADER,
   JSON_CONTENT_TYPE,
   REQUEST_TYPES_WITH_BODY
-} from '../../utils/constants';
+} from '../../../utils/constants';
 
 function createBaseConfig() {
   return {};
 }
 
-class ApiManager {
+class BaseApiManager {
   constructor(customConfig) {
     const headers = {
       common: {
@@ -40,4 +40,4 @@ class ApiManager {
   }
 }
 
-export default ApiManager;
+export default BaseApiManager;
diff --git a/src/universal/core/apiService/apiManager/ClientApiManager.js b/src/universal/core/apiService/apiManager/ClientApiManager.js
@@ -0,0 +1,11 @@
+import createApiClient from '../utils/createApiClient';
+import BaseApiManager from './BaseApiManager';
+
+export default (config, timeout) => {
+  const apiManager = new BaseApiManager({
+    baseURL: config.clientUrl || config.url || config.serverUrl || '/',
+    timeout
+  });
+
+  return createApiClient(apiManager);
+};
diff --git a/src/universal/core/apiService/apiManager/ServerApiManager.js b/src/universal/core/apiService/apiManager/ServerApiManager.js
@@ -1,5 +1,5 @@
-import ApiManager from './ApiManager';
-import { createApiClient } from '../../common/network/apiUtils';
+import createApiClient from '../utils/createApiClient';
+import BaseApiManager from './BaseApiManager';
 
 import http from 'http';
 import https from 'https';
@@ -10,9 +10,9 @@ const BASE_HTTP_AGENT_CONFIG = {
 };
 
 export default (config, timeout) => {
-  const apiManager = new ApiManager({
+  const apiManager = new BaseApiManager({
     timeout,
-    baseURL: config.serverUrl,
+    baseURL: config.serverUrl || config.url || config.clientUrl || '/',
     httpAgent: new http.Agent(BASE_HTTP_AGENT_CONFIG),
     httpsAgent: new https.Agent(BASE_HTTP_AGENT_CONFIG)
   });
diff --git a/src/universal/core/apiService/apiManager/index.js b/src/universal/core/apiService/apiManager/index.js
@@ -0,0 +1,3 @@
+export { default as BaseApiManager } from './BaseApiManager';
+export { default as ClientApiManager } from './ClientApiManager';
+export { default as ServerApiManager } from './ServerApiManager';
diff --git a/src/universal/core/apiService/apiManagerCache/ClientApiManagerCache.js b/src/universal/core/apiService/apiManagerCache/ClientApiManagerCache.js
@@ -0,0 +1,9 @@
+/* istanbul ignore file */
+import ClientApiManager from '../apiManager/ClientApiManager';
+import createCache from '../utils/createCache';
+
+const { services, timeouts } = require('__APP_CONFIG__');
+
+const cache = createCache(ClientApiManager, services, timeouts.clientApiManager);
+
+export default cache;
diff --git a/src/universal/core/apiService/apiManagerCache/ServerApiManagerCache.js b/src/universal/core/apiService/apiManagerCache/ServerApiManagerCache.js
@@ -0,0 +1,9 @@
+/* istanbul ignore file */
+import ServerApiManager from '../apiManager/ServerApiManager';
+import createCache from '../utils/createCache';
+
+const { services, timeouts } = require('__APP_CONFIG__');
+
+const cache = createCache(ServerApiManager, services, timeouts.serverApiManager);
+
+export default cache;
diff --git a/src/universal/core/apiService/apiManagerCache/index.js b/src/universal/core/apiService/apiManagerCache/index.js
@@ -0,0 +1,2 @@
+export { default as ServerApiManagerCache } from './ServerApiManagerCache';
+export { default as ClientApiManagerCache } from './ClientApiManagerCache';
diff --git a/src/universal/core/apiService/apiService.js b/src/universal/core/apiService/apiService.js
@@ -0,0 +1,10 @@
+import { ServerApiManagerCache, ClientApiManagerCache } from './apiManagerCache';
+
+const getApiService = () => {
+  const isBrowser = typeof window !== 'undefined';
+
+  return isBrowser ? ClientApiManagerCache : ServerApiManagerCache;
+};
+
+const apiService = getApiService();
+export default apiService;
diff --git a/src/universal/core/apiService/index.js b/src/universal/core/apiService/index.js
@@ -0,0 +1,3 @@
+export { default } from './apiService';
+export { default as ClientApiManager } from './apiManagerCache/ClientApiManagerCache';
+export { default as ServerApiManager } from './apiManagerCache/ServerApiManagerCache';
diff --git a/src/universal/core/apiService/utils/createApiClient.js b/src/universal/core/apiService/utils/createApiClient.js
@@ -1,5 +1,5 @@
-import Request from '../../model/Request';
-import { createCacheManagerInstance } from '../../core/cache/cacheUtils';
+import Request from '../../../model/Request';
+import { createCacheManagerInstance } from '../../cache/cacheUtils';
 
 function createApiClient(apiManager) {
   const cacheManager = createCacheManagerInstance();
@@ -101,5 +101,4 @@ function createApiClient(apiManager) {
   };
 }
 
-// eslint-disable-next-line import/prefer-default-export
-export { createApiClient };
+export default createApiClient;
diff --git a/src/universal/core/apiService/utils/createCache.js b/src/universal/core/apiService/utils/createCache.js
@@ -0,0 +1,15 @@
+import freezeServices from './freezeServices';
+
+const createCache = (ApiManager, services, timeout) => {
+  const cache = {};
+  const frozenServicesData = freezeServices(services);
+
+  Object.entries(services).forEach(entity => {
+    const [serviceKey, serviceValues] = entity;
+    cache[frozenServicesData[serviceKey]] = ApiManager(serviceValues, timeout);
+  });
+
+  return cache;
+};
+
+export default createCache;
diff --git a/src/universal/core/apiService/utils/freezeServices.js b/src/universal/core/apiService/utils/freezeServices.js
@@ -0,0 +1,11 @@
+function freezeServices(services) {
+  return Object.freeze(
+    Object.keys(services).reduce((obj, val) => {
+      // eslint-disable-next-line no-param-reassign
+      obj[val] = val;
+      return obj;
+    }, {})
+  );
+}
+
+export default freezeServices;
diff --git a/src/universal/model/Renderer.js b/src/universal/model/Renderer.js
@@ -33,8 +33,7 @@ export default class Renderer {
   }
 
   getServicesWithMultiple() {
-    const options = { isServer: false };
-    return this.component.object.getServicesWithMultiple(this.context, options);
+    return this.component.object.getServicesWithMultiple(this.context);
   }
 
   render() {
diff --git a/src/universal/utils/constants.js b/src/universal/utils/constants.js
@@ -19,13 +19,6 @@ const HTTP_STATUS_CODES = {
 const JSON_CONTENT_TYPE = 'application/json';
 const CONTENT_TYPE_HEADER = 'Content-Type';
 const REQUEST_TYPES_WITH_BODY = ['post', 'put', 'patch'];
-const SERVICES = Object.freeze(
-  Object.keys(appConfig.services).reduce((obj, val) => {
-    // eslint-disable-next-line no-param-reassign
-    obj[val] = Symbol(val);
-    return obj;
-  }, {})
-);
 
 const BLACKLIST_OUTPUT = [
   'componentName',
@@ -41,6 +34,5 @@ export {
   JSON_CONTENT_TYPE,
   CONTENT_TYPE_HEADER,
   REQUEST_TYPES_WITH_BODY,
-  SERVICES,
   BLACKLIST_OUTPUT
 };

Original file line number	Diff line number	Diff line change
`@@ -3,13 +3,13 @@ import {`
`3`	`3`	`CONTENT_TYPE_HEADER,`
`4`	`4`	`JSON_CONTENT_TYPE,`
`5`	`5`	`REQUEST_TYPES_WITH_BODY`
`6`		`-} from '../../utils/constants';`
	`6`	`+} from '../../../utils/constants';`
`7`	`7`
`8`	`8`	`function createBaseConfig() {`
`9`	`9`	`return {};`
`10`	`10`	`}`
`11`	`11`
`12`		`-class ApiManager {`
	`12`	`+class BaseApiManager {`
`13`	`13`	`constructor(customConfig) {`
`14`	`14`	`const headers = {`
`15`	`15`	`common: {`
`@@ -40,4 +40,4 @@ class ApiManager {`
`40`	`40`	`}`
`41`	`41`	`}`
`42`	`42`
`43`		`-export default ApiManager;`
	`43`	`+export default BaseApiManager;`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+export { default as BaseApiManager } from './BaseApiManager';`
	`2`	`+export { default as ClientApiManager } from './ClientApiManager';`
	`3`	`+export { default as ServerApiManager } from './ServerApiManager';`