ADD server side data functions and response setter

.eslintrc.js

@@ -7,7 +7,7 @@ module.exports = {
     window: true,
     hepsiBus: true,
     global: true,
-    jest: true,
+    jest: true
   },
   parserOptions: {
     ecmaFeatures: {
@@ -46,7 +46,13 @@ module.exports = {
     'no-nested-ternary': 'off',
     'no-underscore-dangle': 'off',
     'consistent-return': 'off',
-    'array-callback-return': 'off'
+    'array-callback-return': 'off',
+    'no-restricted-syntax': [
+      'error',
+      'FunctionExpression',
+      'WithStatement',
+      "BinaryExpression[operator='in']"
+    ]
   },
   env: {
     jest: true,

config/emptyModule.js

@@ -0,0 +1 @@
+module.exports = {};

config/string.js

@@ -7,27 +7,76 @@ const voltranConfig = require('../voltran.config');
 
 const prometheusFile = voltranConfig.monitoring.prometheus;
 
-function replaceString () {
-	const data = [
-		{ search: '__V_COMPONENTS__', replace: normalizeUrl(voltranConfig.routing.components), flags: 'g' },
+function replaceString() {
+  const data = [
+    {
+      search: '__V_COMPONENTS__',
+      replace: normalizeUrl(voltranConfig.routing.components),
+      flags: 'g'
+    },
     {
       search: '__APP_CONFIG__',
-      replace: normalizeUrl(`${voltranConfig.appConfigFile.output.path}/${voltranConfig.appConfigFile.output.name}.js`),
+      replace: normalizeUrl(
+        `${voltranConfig.appConfigFile.output.path}/${voltranConfig.appConfigFile.output.name}.js`
+      ),
       flags: 'g'
     },
     {
       search: '__ASSETS_FILE_PATH__',
       replace: normalizeUrl(`${voltranConfig.inputFolder}/assets.json`),
       flags: 'g'
     },
-    { search: '__V_DICTIONARY__', replace: normalizeUrl(voltranConfig.routing.dictionary), flags: 'g' },
-    { search: '@voltran/core', replace: normalizeUrl(path.resolve(__dirname, '../src/index')), flags: 'g' },
+    {
+      search: '__V_DICTIONARY__',
+      replace: normalizeUrl(voltranConfig.routing.dictionary),
+      flags: 'g'
+    },
+    {
+      search: '__V_REQUEST_CONFIGS__',
+      replace: normalizeUrl(
+        voltranConfig.requestConfigs || path.resolve(__dirname, './emptyModule.js')
+      ),
+      flags: 'g'
+    },
+    {
+      search: '__V_PREVIEW__',
+      replace: normalizeUrl(voltranConfig.preview || path.resolve(__dirname, './emptyModule.js')),
+      flags: 'g'
+    },
+    {
+      search: '@voltran/core',
+      replace: normalizeUrl(path.resolve(__dirname, '../src/index')),
+      flags: 'g'
+    },
+    {
+      search: '@voltran/server',
+      replace: normalizeUrl(path.resolve(__dirname, '../src/server')),
+      flags: 'g'
+    },
+    {
+      search: '__V_MAIN__',
+      replace: normalizeUrl(
+        voltranConfig.entry.main || path.resolve(__dirname, './emptyModule.js')
+      ),
+      flags: 'g'
+    },
+    {
+      search: '__V_SERVER__',
+      replace: normalizeUrl(
+        voltranConfig.entry.server || path.resolve(__dirname, './emptyModule.js')
+      ),
+      flags: 'g'
+    },
     { search: '"__V_styles__"', replace: getStyles() }
   ];
 
-  data.push({ search: '__V_PROMETHEUS__', replace: normalizeUrl(prometheusFile ? prometheusFile : '../lib/tools/prom.js'), flags: 'g' });
+  data.push({
+    search: '__V_PROMETHEUS__',
+    replace: normalizeUrl(prometheusFile || '../lib/tools/prom.js'),
+    flags: 'g'
+  });
 
-	return data;
+  return data;
 }
 
 module.exports = replaceString;

jest.config.js

@@ -1,5 +1,3 @@
-// Jest configuration
-// https://facebook.github.io/jest/docs/en/configuration.html
 module.exports = {
   verbose: true,
   automock: false,
@@ -11,6 +9,11 @@ module.exports = {
     '!src/public/**',
     '!src/tools/**'
   ],
+  env: {
+    production: {
+      plugins: ['transform-es2015-modules-commonjs']
+    }
+  },
   coverageDirectory: '<rootDir>/coverage',
   globals: {
     window: true,

lib/os.js

@@ -1,9 +1,13 @@
 const path = require('path');
 
 function normalizeUrl(url) {
-	const urlArray = url.split(path.sep);
-
-  return urlArray.join('/');
+  if (url) {
+    const urlArray = url?.split(path.sep);
+
+    return urlArray.join('/');
+  }
+
+  return '';
 }
 
-module.exports = normalizeUrl;
+module.exports = normalizeUrl;

package.json

@@ -40,6 +40,7 @@
     "classnames": "2.2.6",
     "clean-webpack-plugin": "1.0.0",
     "cli-color": "^2.0.0",
+    "colors": "^1.4.0",
     "compose-middleware": "5.0.0",
     "compression": "^1.7.4",
     "cookie-parser": "1.4.3",
@@ -59,6 +60,7 @@
     "file-loader": "1.1.11",
     "helmet": "3.21.3",
     "hiddie": "^1.0.0",
+    "history": "^5.3.0",
     "husky": "^3.1.0",
     "identity-obj-proxy": "3.0.0",
     "intersection-observer": "0.7.0",
@@ -132,5 +134,9 @@
     "commitLimit": false,
     "template": "changelog-template.hbs",
     "package": true
+  },
+  "peerDependencies": {
+    "react": ">=16.13.0",
+    "react-dom": ">=16.13.0"
   }
 }

src/index.js

@@ -1,7 +1,18 @@
-import withBaseComponent from './universal/partials/withBaseComponent';
-import { SERVICES } from './universal/utils/constants';
+import voltran from './universal/partials/withBaseComponent';
+import apiService, {
+  ClientApiManager,
+  ServerApiManager,
+  apiServiceMiddleware
+} from './universal/core/apiService';
+import requestDispatcher from './universal/utils/requestDispatcher';
+import useRequestDispatcher from './universal/hooks/useRequestDispatcher';
 
-export default {
-  withBaseComponent,
-  SERVICES
+export default voltran;
+export {
+  ClientApiManager,
+  ServerApiManager,
+  apiService,
+  apiServiceMiddleware,
+  requestDispatcher,
+  useRequestDispatcher
 };

src/main.js

@@ -6,41 +6,48 @@ import Hiddie from 'hiddie';
 import http from 'http';
 import voltranConfig from '../voltran.config';
 import prom from 'prom-client';
-import {HTTP_STATUS_CODES} from './universal/utils/constants';
+import { HTTP_STATUS_CODES } from './universal/utils/constants';
+
+const voltranMain = require('__V_MAIN__');
 
 const enablePrometheus = voltranConfig.monitoring.prometheus;
 
 function triggerMessageListener(worker) {
-  worker.on('message', function (message) {
+  worker.on('message', function(message) {
     if (message?.options?.forwardAllWorkers) {
       sendMessageToAllWorkers(message);
     }
   });
 }
 
 function sendMessageToAllWorkers(message) {
-  Object.keys(cluster.workers).forEach(function (key) {
+  Object.keys(cluster.workers).forEach(function(key) {
     const worker = cluster.workers[key];
     worker.send({
-      msg: message.msg,
+      msg: message.msg
     });
   }, this);
 }
 
-cluster.on('fork', (worker) => {
+cluster.on('fork', worker => {
   triggerMessageListener(worker);
 });
 
-if (cluster.isMaster) {
-  for (let i = 0; i < os.cpus().length; i += 1) {
+const DEFAULT_CPU_COUNT = os.cpus().length;
+
+function forkClusters(cpuCount = DEFAULT_CPU_COUNT) {
+  for (let i = 0; i < cpuCount; i += 1) {
     cluster.fork();
   }
 
   cluster.on('exit', worker => {
     logger.error(`Worker ${worker.id} died`);
-    cluster.fork();
+    const newWorker = cluster.fork();
+    cluster.emit('message', newWorker, 'NEW_WORKER');
   });
+}
 
+if (cluster.isMaster) {
   if (enablePrometheus) {
     const aggregatorRegistry = new prom.AggregatorRegistry();
     const metricsPort = voltranConfig.port + 1;
@@ -52,7 +59,7 @@ if (cluster.isMaster) {
         return res.end(await aggregatorRegistry.clusterMetrics());
       }
       res.statusCode = HTTP_STATUS_CODES.NOT_FOUND;
-      res.end(JSON.stringify({message: 'not found'}));
+      res.end(JSON.stringify({ message: 'not found' }));
     });
 
     http.createServer(hiddie.run).listen(metricsPort, () => {
@@ -63,7 +70,14 @@ if (cluster.isMaster) {
       );
     });
   }
+
+  if (voltranConfig.entry.main) {
+    const voltranMainFile = voltranMain.default;
+    forkClusters(voltranMainFile.cpuCount);
+    voltranMainFile.load(cluster);
+  }
+} else if (voltranConfig.entry.server) {
+  require('__V_SERVER__');
 } else {
-  // eslint-disable-next-line global-require
   require('./server');
 }