feat(globals): adds globals

package.json

@@ -75,6 +75,7 @@
     "@types/object-hash": "^1.2.0",
     "@types/pify": "^3.0.2",
     "@types/prompts": "^2.4.0",
+    "@types/read-pkg-up": "^3.0.1",
     "@types/semver": "^6.0.0",
     "@typescript-eslint/eslint-plugin": "^1.7.0",
     "@typescript-eslint/parser": "^1.7.0",
@@ -131,6 +132,7 @@
     "pify": "^4.0.1",
     "promist": "^0.5.3",
     "prompts": "^2.0.4",
+    "read-pkg-up": "^5.0.0",
     "semver": "^6.0.0",
     "slimconf": "^0.9.0",
     "string-argv": "^0.3.0"

src/constants.ts

@@ -16,3 +16,7 @@ export const CONCURRENTLY_PATH = require.resolve(
 );
 // Environment variable name for core state storage
 export const KPO_ENV_STATE = 'KPO_STATE';
+/* Shared between instances: changes might imply a major version release */
+export const LOG_ENV_KEY = 'kpo_log';
+export const GLOBALS_KEY = 'kpo_globals';
+export type TGlobal = 'version' | 'core' | 'options' | 'processses';

src/globals/globals.ts

@@ -0,0 +1,4 @@
+import { GLOBALS_KEY, TGlobal } from '~/constants';
+
+export default ((global as any)[GLOBALS_KEY] ||
+  ((global as any)[GLOBALS_KEY] = {})) as { [key in TGlobal]: any };

src/globals/index.ts

@@ -0,0 +1,17 @@
+import inVersionRange from './version-range';
+import _ from './globals';
+import { TGlobal } from '~/constants';
+
+// eslint-disable-next-line @typescript-eslint/explicit-function-return-type
+export default function globals<T>(key: TGlobal, initial: T) {
+  inVersionRange();
+
+  return {
+    get(): T {
+      return _[key] || (_[key] = initial);
+    },
+    set(value: T): void {
+      _[key] = value;
+    }
+  };
+}

src/globals/pkg.ts

@@ -0,0 +1,15 @@
+import read from 'read-pkg-up';
+import cache from '~/utils/cache';
+import { IOfType } from '~/types';
+import errors from '~/utils/errors';
+
+export default cache(
+  null,
+  (): IOfType<any> => {
+    try {
+      return read.sync({ cwd: __dirname }).pkg;
+    } catch (e) {
+      throw new errors.CustomError(`Package couldn't be retrieved`, null, e);
+    }
+  }
+);

src/globals/version-range.ts

@@ -0,0 +1,31 @@
+import { clean, diff } from 'semver';
+import pkg from './pkg';
+import globals from './globals';
+
+export default function inVersionRange(): void {
+  if (!globals.version) {
+    globals.version = clean(pkg().version);
+    return;
+  }
+
+  const executable = globals.version && clean(globals.version);
+  const local = pkg().version && clean(pkg().version);
+
+  if (!executable || !local) throw Error(`Version could not be parsed`);
+
+  const release = diff(executable, local);
+
+  // `false` if difference is a major version or we're on v0.x.x
+  if (
+    release !== 'major' &&
+    release !== 'premajor' &&
+    (!release || (local as string)[0] !== '0')
+  ) {
+    return;
+  }
+
+  throw Error(
+    `Local kpo version (${local})` +
+      ` doesn't match executing version (${executable})`
+  );
+}