@withonevision/omnihive-core - npm Package Compare versions

Comparing version 4.0.3-dev.27 to 4.0.3-dev.29

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/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

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

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,3 +1,3 @@
+import { ConnectionSchema } from "../models/ConnectionSchema";
 import { StoredProcSchema } from "../models/StoredProcSchema";
-import { TableSchema } from "../models/TableSchema";
 import { IHiveWorker } from "./IHiveWorker";
@@ -12,7 +12,4 @@ export interface IDatabaseWorker extends IHiveWorker {
     }[]) => Promise<any[][]>;
-    getSchema: () => Promise<{
-        tables: TableSchema[];
-        storedProcs: StoredProcSchema[];
-    }>;
+    getSchema: () => Promise<ConnectionSchema>;
 }
 //# sourceMappingURL=IDatabaseWorker.d.ts.map

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,6 +1,7 @@
+import { RestEndpointExecuteResponse } from "../models/RestEndpointExecuteResponse";
 import { IHiveWorker } from "./IHiveWorker";
 export interface IRestEndpointWorker extends IHiveWorker {
     getSwaggerDefinition: () => any | undefined;
-    execute: (headers: any, url: string, body: any) => Promise<[{} | undefined, number]>;
+    execute: (headers: any, url: string, body: any) => Promise<RestEndpointExecuteResponse>;
 }
 //# sourceMappingURL=IRestEndpointWorker.d.ts.map

interfaces/IRestEndpointWorker.js

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

interfaces/IServerWorker.d.ts

 import { IHiveWorker } from "./IHiveWorker";
 export interface IServerWorker extends IHiveWorker {
-    buildServer: () => Promise<void>;
+    buildServer: (app: any) => Promise<any>;
 }
 //# sourceMappingURL=IServerWorker.d.ts.map

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

@@ -7,2 +7,3 @@ export declare class HiveWorker {
     importPath: string;
+    core: boolean;
     default: boolean;
@@ -9,0 +10,0 @@ enabled: boolean;

models/HiveWorker.js

@@ -11,2 +11,3 @@ "use strict";
         this.importPath = "";
+        this.core = false;
         this.default = true;
@@ -13,0 +14,0 @@ this.enabled = true;

models/HiveWorkerBase.d.ts

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

models/HiveWorkerBase.js

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

models/HiveWorkerMetadataDatabase.d.ts

@@ -5,7 +5,7 @@ export declare class HiveWorkerMetadataDatabase {
     databaseName: string;
-    graphEndpoint: string;
     userName: string;
     password: string;
     rowLimit: number;
+    urlRoute: string;
 }
 //# sourceMappingURL=HiveWorkerMetadataDatabase.d.ts.map

models/HiveWorkerMetadataDatabase.js

@@ -9,6 +9,6 @@ "use strict";
         this.databaseName = "";
-        this.graphEndpoint = "";
         this.userName = "";
         this.password = "";
         this.rowLimit = 0;
+        this.urlRoute = "";
     }
@@ -15,0 +15,0 @@ }

models/HiveWorkerMetadataGraphBuilder.d.ts

 export declare class HiveWorkerMetadataGraphBuilder {
-    graphUrl: string;
     dbWorkers: string[];
+    urlRoute: string;
 }
 //# sourceMappingURL=HiveWorkerMetadataGraphBuilder.d.ts.map

models/HiveWorkerMetadataGraphBuilder.js

@@ -6,4 +6,4 @@ "use strict";
     constructor() {
-        this.graphUrl = "";
         this.dbWorkers = [];
+        this.urlRoute = "";
     }
@@ -10,0 +10,0 @@ }

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

 import { RestMethod } from "../enums/RestMethod";
 export declare class HiveWorkerMetadataRestFunction {
-    methodUrl: string;
     restMethod: RestMethod;
-    isSystem: boolean;
+    urlRoute: string;
 }
 //# sourceMappingURL=HiveWorkerMetadataRestFunction.d.ts.map

models/HiveWorkerMetadataRestFunction.js

@@ -7,5 +7,4 @@ "use strict";
     constructor() {
-        this.methodUrl = "";
         this.restMethod = RestMethod_1.RestMethod.POST;
-        this.isSystem = false;
+        this.urlRoute = "";
     }
@@ -12,0 +11,0 @@ }

models/HiveWorkerMetadataServer.d.ts

 export declare class HiveWorkerMetadataServer {
     buildWorkers: string[];
+    urlRoute: string;
 }
 //# sourceMappingURL=HiveWorkerMetadataServer.d.ts.map

models/HiveWorkerMetadataServer.js

@@ -7,2 +7,3 @@ "use strict";
         this.buildWorkers = [];
+        this.urlRoute = "";
     }
@@ -9,0 +10,0 @@ }

models/PubSubListener.d.ts

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

models/PubSubListener.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.27",
+    "version": "4.0.3-dev.29",
     "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

 import { IHiveWorker } from "../interfaces/IHiveWorker";
 import { HiveWorker } from "../models/HiveWorker";
+import { RegisteredHiveWorker } from "../models/RegisteredHiveWorker";
 export declare class WorkerService {
@@ -7,8 +8,9 @@ private static singleton;
     static getSingleton: () => WorkerService;
-    registeredWorkers: [HiveWorker, any][];
+    registeredWorkers: RegisteredHiveWorker[];
     initWorkers: (configs: HiveWorker[]) => Promise<void>;
     clearWorkers: () => void;
     getWorker: <T extends IHiveWorker | undefined>(type: string, name?: string | undefined) => Promise<T | undefined>;
+    getWorkersByType: (type: string) => RegisteredHiveWorker[];
     pushWorker: (hiveWorker: HiveWorker) => Promise<void>;
 }
 //# sourceMappingURL=WorkerService.d.ts.map

services/WorkerService.js

@@ -48,6 +48,7 @@ "use strict";
                     await AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.init(hiveWorker));
-                    this.registeredWorkers.push([hiveWorker, newWorkerInstance]);
+                    const registeredWorker = { ...hiveWorker, instance: newWorkerInstance };
+                    this.registeredWorkers.push(registeredWorker);
                 }
                 for (const worker of this.registeredWorkers) {
-                    await AwaitHelper_1.AwaitHelper.execute(worker[1].afterInit());
+                    await AwaitHelper_1.AwaitHelper.execute(worker.instance.afterInit());
                 }
@@ -68,3 +69,3 @@ }
             if (!name) {
-                const defaultWorkers = this.registeredWorkers.filter((d) => d[0].type === type && d[0].default === true && d[0].enabled === true);
+                const defaultWorkers = this.registeredWorkers.filter((rw) => rw.type === type && rw.default === true && rw.enabled === true);
                 if (defaultWorkers.length > 1) {
@@ -77,3 +78,3 @@ throw new Error("You cannot have multiple default workers of the same type");
                 if (!hiveWorker) {
-                    const anyWorkers = this.registeredWorkers.filter((d) => d[0].type === type && d[0].enabled === true);
+                    const anyWorkers = this.registeredWorkers.filter((rw) => rw.type === type && rw.enabled === true);
                     if (anyWorkers && anyWorkers.length > 0) {
@@ -88,3 +89,3 @@ hiveWorker = anyWorkers[0];
             else {
-                hiveWorker = this.registeredWorkers.find((d) => d[0].type === type && d[0].name === name && d[0].enabled === true);
+                hiveWorker = this.registeredWorkers.find((rw) => rw.type === type && rw.name === name && rw.enabled === true);
                 if (!hiveWorker) {
@@ -94,4 +95,7 @@ return undefined;
             }
-            return hiveWorker[1];
+            return hiveWorker.instance;
         };
+        this.getWorkersByType = (type) => {
+            return this.registeredWorkers.filter((rw) => rw.type === type && rw.enabled === true);
+        };
         this.pushWorker = async (hiveWorker) => {
@@ -105,3 +109,4 @@ if (!hiveWorker.importPath || hiveWorker.importPath === "") {
             await AwaitHelper_1.AwaitHelper.execute(newWorkerInstance.afterInit());
-            this.registeredWorkers.push([hiveWorker, newWorkerInstance]);
+            const registeredWorker = { ...hiveWorker, instance: newWorkerInstance };
+            this.registeredWorkers.push(registeredWorker);
         };
@@ -108,0 +113,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

Improved metrics

Total package byte prevSize

824884

increased by0.77%

Number of package files

243

increased by5.19%

Lines of code

1235

increased by4.4%

No dependency changes