@withonevision/omnihive-core - npm Package Compare versions

Comparing version 4.0.3-dev.34 to 4.0.3-dev.35

enums/HiveWorkerType.d.ts

@@ -0,0 +0,0 @@ export declare enum HiveWorkerType {

enums/HiveWorkerType.js

@@ -0,0 +0,0 @@ "use strict";

enums/LifecycleWorkerAction.d.ts

@@ -0,0 +0,0 @@ export declare enum LifecycleWorkerAction {

enums/LifecycleWorkerAction.js

@@ -0,0 +0,0 @@ "use strict";

enums/LifecycleWorkerStage.d.ts

@@ -0,0 +0,0 @@ export declare enum LifecycleWorkerStage {

enums/LifecycleWorkerStage.js

@@ -0,0 +0,0 @@ "use strict";

enums/LocalFunctionType.d.ts

@@ -0,0 +0,0 @@ export declare enum LocalFunctionType {

enums/LocalFunctionType.js

@@ -0,0 +0,0 @@ "use strict";

enums/OmniHiveLogLevel.d.ts

@@ -0,0 +0,0 @@ export declare enum OmniHiveLogLevel {

enums/OmniHiveLogLevel.js

@@ -0,0 +0,0 @@ "use strict";

enums/RegisteredUrlType.d.ts

@@ -0,0 +0,0 @@ export declare enum RegisteredUrlType {

enums/RegisteredUrlType.js

@@ -0,0 +0,0 @@ "use strict";

enums/RestMethod.d.ts

@@ -0,0 +0,0 @@ export declare enum RestMethod {

enums/RestMethod.js

@@ -0,0 +0,0 @@ "use strict";

enums/ServerStatus.d.ts

@@ -0,0 +0,0 @@ export declare enum ServerStatus {

enums/ServerStatus.js

@@ -0,0 +0,0 @@ "use strict";

factories/CoreServiceFactory.d.ts

@@ -0,0 +0,0 @@ import { ConfigurationService } from "../services/ConfigurationService";

factories/CoreServiceFactory.js

@@ -0,0 +0,0 @@ "use strict";

helpers/AwaitHelper.d.ts

@@ -0,0 +0,0 @@ export declare class AwaitHelper {

helpers/AwaitHelper.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -16,3 +7,3 @@ exports.AwaitHelper = void 0;
 exports.AwaitHelper = AwaitHelper;
-AwaitHelper.execute = (promise) => __awaiter(void 0, void 0, void 0, function* () {
+AwaitHelper.execute = async (promise) => {
     return promise
@@ -23,3 +14,3 @@ .then((data) => data)
     });
-});
+};
 //# sourceMappingURL=AwaitHelper.js.map

helpers/ObjectHelper.d.ts

@@ -0,0 +0,0 @@ export declare class ObjectHelper {

helpers/ObjectHelper.js

@@ -0,0 +0,0 @@ "use strict";

helpers/StringBuilder.d.ts

@@ -0,0 +0,0 @@ export declare class StringBuilder {

helpers/StringBuilder.js

@@ -0,0 +0,0 @@ "use strict";

helpers/StringHelper.d.ts

@@ -0,0 +0,0 @@ export declare class StringHelper {

helpers/StringHelper.js

@@ -0,0 +0,0 @@ "use strict";

interfaces/ICacheWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/ICacheWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=ICacheWorker.js.map

interfaces/IDatabaseWorker.d.ts

@@ -0,0 +0,0 @@ import { ConnectionSchema } from "../models/ConnectionSchema";

interfaces/IDatabaseWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IDatabaseWorker.js.map

interfaces/IDateWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IDateWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IDateWorker.js.map

interfaces/IEncryptionWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IEncryptionWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IEncryptionWorker.js.map

interfaces/IErrorWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IErrorWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IErrorWorker.js.map

interfaces/IFeatureWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IFeatureWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IFeatureWorker.js.map

interfaces/IFileSystemWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IFileSystemWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IFileSystemWorker.js.map

interfaces/IGraphBuildWorker.d.ts

@@ -0,0 +0,0 @@ import { ConnectionSchema } from "../models/ConnectionSchema";

interfaces/IGraphBuildWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IGraphBuildWorker.js.map

interfaces/IGraphEndpointWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IGraphEndpointWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IGraphEndpointWorker.js.map

interfaces/IHiveAccountWorker.d.ts

@@ -0,0 +0,0 @@ import { HiveAccount } from "../models/HiveAccount";

interfaces/IHiveAccountWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IHiveAccountWorker.js.map

interfaces/IHiveWorker.d.ts

@@ -0,0 +0,0 @@ import { HiveWorker } from "../models/HiveWorker";

interfaces/IHiveWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IHiveWorker.js.map

interfaces/ILogWorker.d.ts

@@ -0,0 +0,0 @@ import { OmniHiveLogLevel } from "../enums/OmniHiveLogLevel";

interfaces/ILogWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=ILogWorker.js.map

interfaces/IPubSubClientWorker.d.ts

@@ -0,0 +0,0 @@ import { PubSubListener } from "../models/PubSubListener";

interfaces/IPubSubClientWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IPubSubClientWorker.js.map

interfaces/IPubSubServerWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IPubSubServerWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IPubSubServerWorker.js.map

interfaces/IRestEndpointWorker.d.ts

@@ -0,0 +0,0 @@ import { RestEndpointExecuteResponse } from "../models/RestEndpointExecuteResponse";

interfaces/IRestEndpointWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IRestEndpointWorker.js.map

interfaces/IServerWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IServerWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IServerWorker.js.map

interfaces/IStorageWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/IStorageWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IStorageWorker.js.map

interfaces/ITokenWorker.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "./IHiveWorker";

interfaces/ITokenWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=ITokenWorker.js.map

interfaces/IUserWorker.d.ts

@@ -0,0 +0,0 @@ import { AuthUser } from "../models/AuthUser";

interfaces/IUserWorker.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 //# sourceMappingURL=IUserWorker.js.map

models/AuthUser.d.ts

@@ -0,0 +0,0 @@ export declare class AuthUser {

models/AuthUser.js

@@ -0,0 +0,0 @@ "use strict";

models/ClientSettings.d.ts

@@ -0,0 +0,0 @@ export declare class ClientSettings {

models/ClientSettings.js

@@ -0,0 +0,0 @@ "use strict";

models/ConnectionSchema.d.ts

@@ -0,0 +0,0 @@ import { StoredProcSchema } from "./StoredProcSchema";

models/ConnectionSchema.js

@@ -0,0 +0,0 @@ "use strict";

models/ConverterSqlInfo.d.ts

@@ -0,0 +0,0 @@ export declare class ConverterSqlInfo {

models/ConverterSqlInfo.js

@@ -0,0 +0,0 @@ "use strict";

models/Customer.d.ts

@@ -0,0 +0,0 @@ export declare class Customer {

models/Customer.js

@@ -0,0 +0,0 @@ "use strict";

models/GraphQLJSON.d.ts

@@ -0,0 +0,0 @@ import { GraphQLScalarType } from "graphql";

models/GraphQLJSON.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveAccount.d.ts

@@ -0,0 +0,0 @@ import { Customer } from "./Customer";

models/HiveAccount.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveAccountType.d.ts

@@ -0,0 +0,0 @@ export declare class HiveAccountType {

models/HiveAccountType.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorker.d.ts

@@ -0,0 +0,0 @@ export declare class HiveWorker {

models/HiveWorker.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorkerBase.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "../interfaces/IHiveWorker";

models/HiveWorkerBase.js

 "use strict";
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -27,14 +18,10 @@ exports.HiveWorkerBase = void 0;
     }
-    afterInit() {
-        return __awaiter(this, void 0, void 0, function* () {
-            return;
-        });
+    async afterInit() {
+        return;
     }
-    init(config) {
-        return __awaiter(this, void 0, void 0, function* () {
-            if (!config || Object.keys(config).length <= 0) {
-                throw new Error("Configuration not specified");
-            }
-            this.config = config;
-        });
+    async init(config) {
+        if (!config || Object.keys(config).length <= 0) {
+            throw new Error("Configuration not specified");
+        }
+        this.config = config;
     }
@@ -41,0 +28,0 @@ }

models/HiveWorkerMetadataDatabase.d.ts

@@ -0,0 +0,0 @@ export declare class HiveWorkerMetadataDatabase {

models/HiveWorkerMetadataDatabase.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorkerMetadataGraphBuilder.d.ts

@@ -0,0 +0,0 @@ export declare class HiveWorkerMetadataGraphBuilder {

models/HiveWorkerMetadataGraphBuilder.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorkerMetadataLifecycleFunction.d.ts

@@ -0,0 +0,0 @@ import { LifecycleWorkerAction } from "../enums/LifecycleWorkerAction";

models/HiveWorkerMetadataLifecycleFunction.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorkerMetadataRestFunction.d.ts

@@ -0,0 +0,0 @@ import { RestMethod } from "../enums/RestMethod";

models/HiveWorkerMetadataRestFunction.js

@@ -0,0 +0,0 @@ "use strict";

models/HiveWorkerMetadataServer.d.ts

@@ -0,0 +0,0 @@ export declare class HiveWorkerMetadataServer {

models/HiveWorkerMetadataServer.js

@@ -0,0 +0,0 @@ "use strict";

models/PubSubListener.d.ts

@@ -0,0 +0,0 @@ export declare class PubSubListener {

models/PubSubListener.js

@@ -0,0 +0,0 @@ "use strict";

models/RegisteredHiveWorker.d.ts

@@ -0,0 +0,0 @@ import { HiveWorker } from "./HiveWorker";

models/RegisteredHiveWorker.js

@@ -0,0 +0,0 @@ "use strict";

models/RegisteredUrl.d.ts

@@ -0,0 +0,0 @@ export declare class RegisteredUrl {

models/RegisteredUrl.js

@@ -0,0 +0,0 @@ "use strict";

models/RestEndpointExecuteResponse.d.ts

@@ -0,0 +0,0 @@ export declare class RestEndpointExecuteResponse {

models/RestEndpointExecuteResponse.js

@@ -0,0 +0,0 @@ "use strict";

models/ServerConfigSettings.d.ts

@@ -0,0 +0,0 @@ export declare class ServerConfigSettings {

models/ServerConfigSettings.js

@@ -0,0 +0,0 @@ "use strict";

models/ServerSettings.d.ts

@@ -0,0 +0,0 @@ import { HiveWorker } from "./HiveWorker";

models/ServerSettings.js

@@ -0,0 +0,0 @@ "use strict";

models/StoredProcSchema.d.ts

@@ -0,0 +0,0 @@ export declare class StoredProcSchema {

models/StoredProcSchema.js

@@ -0,0 +0,0 @@ "use strict";

models/TableSchema.d.ts

@@ -0,0 +0,0 @@ export declare class TableSchema {

models/TableSchema.js

@@ -0,0 +0,0 @@ "use strict";

models/TestConfigSettings.d.ts

@@ -0,0 +0,0 @@ import { HiveWorker } from "./HiveWorker";

models/TestConfigSettings.js

@@ -0,0 +0,0 @@ "use strict";

models/TestSettings.d.ts

@@ -0,0 +0,0 @@ import { TestConfigSettings } from "./TestConfigSettings";

models/TestSettings.js

@@ -0,0 +0,0 @@ "use strict";

package.json

 {
     "name": "@withonevision/omnihive-core",
-    "version": "4.0.3-dev.34",
+    "version": "4.0.3-dev.35",
     "description": "OmniHive Core",
@@ -5,0 +5,0 @@ "license": "MIT",

services/ConfigurationService.d.ts

@@ -0,0 +0,0 @@ import { HiveAccount } from "../models/HiveAccount";

services/ConfigurationService.js

@@ -0,0 +0,0 @@ "use strict";

services/ConnectionService.d.ts

@@ -0,0 +0,0 @@ import { ConnectionSchema } from "../models/ConnectionSchema";

services/ConnectionService.js

@@ -0,0 +0,0 @@ "use strict";

services/WorkerService.d.ts

@@ -0,0 +0,0 @@ import { IHiveWorker } from "../interfaces/IHiveWorker";

services/WorkerService.js

@@ -21,11 +21,2 @@ "use strict";
 };
-var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
-    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
-    return new (P || (P = Promise))(function (resolve, reject) {
-        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
-        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
-        step((generator = generator.apply(thisArg, _arguments || [])).next());
-    });
-};
 var __importDefault = (this && this.__importDefault) || function (mod) {
@@ -45,3 +36,3 @@ return (mod && mod.__esModule) ? mod : { "default": mod };
         this.registeredWorkers = [];
-        this.initWorkers = (configs) => __awaiter(this, void 0, void 0, function* () {
+        this.initWorkers = async (configs) => {
             try {
@@ -63,10 +54,10 @@ for (const hiveWorker of configs) {
                     }
-                    const newWorker = yield AwaitHelper_1.AwaitHelper.execute(Promise.resolve().then(() => __importStar(require(hiveWorker.importPath))));
+                    const newWorker = await AwaitHelper_1.AwaitHelper.execute(Promise.resolve().then(() => __importStar(require(hiveWorker.importPath))));
                     const newWorkerInstance = new newWorker.default();
-                    yield AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.init(hiveWorker));
-                    const registeredWorker = Object.assign(Object.assign({}, hiveWorker), { instance: newWorkerInstance });
+                    await AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.init(hiveWorker));
+                    const registeredWorker = { ...hiveWorker, instance: newWorkerInstance };
                     this.registeredWorkers.push(registeredWorker);
                 }
                 for (const worker of this.registeredWorkers) {
-                    yield AwaitHelper_1.AwaitHelper.execute(worker.instance.afterInit());
+                    await AwaitHelper_1.AwaitHelper.execute(worker.instance.afterInit());
                 }
@@ -77,7 +68,7 @@ }
             }
-        });
+        };
         this.clearWorkers = () => {
             this.registeredWorkers = [];
         };
-        this.getWorker = (type, name) => __awaiter(this, void 0, void 0, function* () {
+        this.getWorker = async (type, name) => {
             if (this.registeredWorkers.length === 0) {
@@ -112,17 +103,17 @@ return undefined;
             return hiveWorker.instance;
-        });
+        };
         this.getWorkersByType = (type) => {
             return this.registeredWorkers.filter((rw) => rw.type === type && rw.enabled === true);
         };
-        this.pushWorker = (hiveWorker) => __awaiter(this, void 0, void 0, function* () {
+        this.pushWorker = async (hiveWorker) => {
             if (!hiveWorker.importPath || hiveWorker.importPath === "") {
                 throw new Error(`Hive worker type ${hiveWorker.type} with name ${hiveWorker.name} has no import path`);
             }
-            const newWorker = yield AwaitHelper_1.AwaitHelper.execute(Promise.resolve().then(() => __importStar(require(hiveWorker.importPath))));
+            const newWorker = await AwaitHelper_1.AwaitHelper.execute(Promise.resolve().then(() => __importStar(require(hiveWorker.importPath))));
             const newWorkerInstance = new newWorker.default();
-            yield AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.init(hiveWorker));
-            yield AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.afterInit());
-            const registeredWorker = Object.assign(Object.assign({}, hiveWorker), { instance: newWorkerInstance });
+            await AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.init(hiveWorker));
+            await AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.afterInit());
+            const registeredWorker = { ...hiveWorker, instance: newWorkerInstance };
             this.registeredWorkers.push(registeredWorker);
-        });
+        };
     }
@@ -129,0 +120,0 @@ }

tsconfig.json

 {
     "extends": "../../../tsconfig.json"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

826095

decreased by-0.45%

Lines of code

1244

decreased by-2.43%

No dependency changes