quidproquo-webserver - npm Package Compare versions

Comparing version 0.0.192 to 0.0.193

lib/commonjs/config/settings/logs.js

@@ -90,2 +90,3 @@ "use strict";
         (0, route_1.defineRoute)('GET', '/log/{correlationId}', (0, quidproquo_core_1.getServiceEntry)('log', 'controller', 'logController'), 'getLog', routeAuthSettings),
+        (0, route_1.defineRoute)('GET', '/log/{correlationId}/toggle', (0, quidproquo_core_1.getServiceEntry)('log', 'controller', 'logController'), 'toggleLogCheck', routeAuthSettings),
         (0, route_1.defineRoute)('GET', '/log/children/{fromCorrelation}', (0, quidproquo_core_1.getServiceEntry)('log', 'controller', 'logController'), 'getChildren', routeAuthSettings),
@@ -92,0 +93,0 @@ (0, route_1.defineRoute)('GET', '/log/{correlationId}/hierarchies', (0, quidproquo_core_1.getServiceEntry)('log', 'controller', 'logController'), 'getHierarchies', routeAuthSettings),

lib/commonjs/services/log/entry/controller/logController.d.ts

@@ -18,2 +18,5 @@ import { QpqRuntimeType, AskResponse } from 'quidproquo-core';
 }): Generator<import("quidproquo-core").Action<any>, HTTPEventResponse<string>, any>;
+export declare function toggleLogCheck(event: HTTPEvent, params: {
+    correlationId: string;
+}): Generator<import("quidproquo-core").Action<any>, HTTPEventResponse<string>, any>;
 export declare function getServiceNames(event: HTTPEvent): Generator<import("quidproquo-core").ConfigGetGlobalAction, HTTPEventResponse<string>, unknown>;
@@ -20,0 +23,0 @@ export declare function getHierarchies(event: HTTPEvent, params: {

lib/commonjs/services/log/entry/controller/logController.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getChatMessages = exports.sendChatMessage = exports.downloadUrl = exports.getChildren = exports.getHierarchies = exports.getServiceNames = exports.getLog = exports.getLogs = void 0;
+exports.getChatMessages = exports.sendChatMessage = exports.downloadUrl = exports.getChildren = exports.getHierarchies = exports.getServiceNames = exports.toggleLogCheck = exports.getLog = exports.getLogs = void 0;
 /* eslint-disable @typescript-eslint/no-unused-vars */
@@ -11,2 +11,3 @@ const quidproquo_core_1 = require("quidproquo-core");
 const logic_1 = require("../../logic");
+const logs_1 = require("../../logic/logs");
 function* getLogs(event, params) {
@@ -26,2 +27,7 @@ const { nextPageKey, startIsoDateTime, endIsoDateTime, runtimeType, errorFilter, serviceFilter, infoFilter, userFilter, onlyErrors, } = (0, httpEventUtils_1.fromJsonEventRequest)(event);
 exports.getLog = getLog;
+function* toggleLogCheck(event, params) {
+    const log = yield* (0, logs_1.askToggleLogChecked)(params.correlationId, false);
+    return (0, httpEventUtils_1.toJsonEventResponse)(log);
+}
+exports.toggleLogCheck = toggleLogCheck;
 function* getServiceNames(event) {
@@ -28,0 +34,0 @@ const serviceNames = yield* (0, quidproquo_core_1.askConfigGetGlobal)('qpq-serviceNames');

lib/commonjs/services/log/entry/data/logMetadataData.d.ts

 import { AskResponse, QpqPagedData, QpqRuntimeType, StoryResultMetadata, StoryResultMetadataWithChildren } from 'quidproquo-core';
 import { LogMetadata } from '../domain';
 export declare function askUpsert(logMetadata: LogMetadata): AskResponse<void>;
+export declare function askSetChecked(correlation: string, checked: boolean, checkedBy: string): AskResponse<LogMetadata>;
 export declare function askListLogs(runtimeType: QpqRuntimeType, startDateTime: string, endDateTime: string, errorFilter: string, serviceFilter: string, infoFilter: string, userFilter: string, onlyErrors: boolean, nextPageKey?: string): AskResponse<QpqPagedData<LogMetadata>>;
@@ -5,0 +6,0 @@ export declare function askGetByCorrelation(correlation: string): AskResponse<LogMetadata | undefined>;

lib/commonjs/services/log/entry/data/logMetadataData.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.askGetHierarchiesByCorrelation = exports.askCreateHierarchy = exports.askFindRootLog = exports.askGetAllByFromCorrelation = exports.askGetByFromCorrelation = exports.askGetByCorrelation = exports.askListLogs = exports.askUpsert = void 0;
+exports.askGetHierarchiesByCorrelation = exports.askCreateHierarchy = exports.askFindRootLog = exports.askGetAllByFromCorrelation = exports.askGetByFromCorrelation = exports.askGetByCorrelation = exports.askListLogs = exports.askSetChecked = exports.askUpsert = void 0;
 const quidproquo_core_1 = require("quidproquo-core");
@@ -11,2 +11,10 @@ const config_1 = require("../../../../config");
 exports.askUpsert = askUpsert;
+function* askSetChecked(correlation, checked, checkedBy) {
+    return yield* (0, quidproquo_core_1.askKeyValueStoreUpdatePartialProperties)(metadataStoreName, 'correlation', {
+        correlation,
+        checked,
+        checkedBy,
+    });
+}
+exports.askSetChecked = askSetChecked;
 function* askListLogs(runtimeType, startDateTime, endDateTime, errorFilter, serviceFilter, infoFilter, userFilter, onlyErrors, nextPageKey) {
@@ -13,0 +21,0 @@ const filters = [];

lib/commonjs/services/log/entry/domain/LogMetadata.d.ts

 import { StoryResultMetadata } from 'quidproquo-core';
 export type LogMetadata = StoryResultMetadata & {
     ttl?: number;
+    checked?: boolean;
+    checkedBy?: string;
 };

lib/commonjs/services/log/logic/auth/index.d.ts

@@ -1,3 +0,4 @@
-export * from "./askLogin";
-export * from "./askRefreshToken";
-export * from "./askRespondToAuthChallenge";
+export * from './askLogin';
+export * from './askRefreshToken';
+export * from './askRespondToAuthChallenge';
+export * from './askGetLoggedInUsername';

lib/commonjs/services/log/logic/auth/index.js

@@ -20,1 +20,2 @@ "use strict";
 __exportStar(require("./askRespondToAuthChallenge"), exports);
+__exportStar(require("./askGetLoggedInUsername"), exports);

lib/commonjs/services/log/logic/logs/index.d.ts

 export * from './askGetLogs';
+export * from './askToggleLogChecked';
+export * from './askAnnounceLogMetadataByCorrelationId';

lib/commonjs/services/log/logic/logs/index.js

@@ -18,1 +18,3 @@ "use strict";
 __exportStar(require("./askGetLogs"), exports);
+__exportStar(require("./askToggleLogChecked"), exports);
+__exportStar(require("./askAnnounceLogMetadataByCorrelationId"), exports);

lib/commonjs/services/log/logic/webSocket/askProcessOnMessage.js

@@ -7,2 +7,3 @@ "use strict";
 const messageProcessors_1 = require("./messageProcessors");
+const askAuthenticateConnection_1 = require("./askAuthenticateConnection");
 function* askProcessOnMessage(connectionId, message) {
@@ -26,2 +27,11 @@ if ((0, messageProcessors_1.isWebSocketAuthenticateMessage)(message)) {
     }
+    // Make sure any messages below have access to the authenticated user
+    yield* (0, askAuthenticateConnection_1.askAuthenticateConnection)(connectionId);
+    if ((0, messageProcessors_1.isWebSocketMarkLogCheckedMessage)(message)) {
+        yield* (0, messageProcessors_1.askProcessOnMarkLogChecked)(connectionId, message.payload.correlationId, message.payload.checked);
+        return;
+    }
+    if ((0, messageProcessors_1.isWebSocketRefreshLogMetadataMessage)(message)) {
+        yield* (0, messageProcessors_1.askProcessOnRefreshLogMetadata)(message.payload.correlationId);
+    }
     // This should never be hit.
@@ -28,0 +38,0 @@ yield* (0, quidproquo_core_1.askThrowError)(quidproquo_core_1.ErrorTypeEnum.GenericError, `Unabled to process [${message === null || message === void 0 ? void 0 : message.messageType}] WebSocket message`);

lib/commonjs/services/log/logic/webSocket/index.d.ts

@@ -6,1 +6,3 @@ export * from './askProcessOnConnect';
 export * from './serverMessages';
+export * from './askAuthenticateConnection';
+export * from './clientMessages';

lib/commonjs/services/log/logic/webSocket/index.js

@@ -22,1 +22,3 @@ "use strict";
 __exportStar(require("./serverMessages"), exports);
+__exportStar(require("./askAuthenticateConnection"), exports);
+__exportStar(require("./clientMessages"), exports);

lib/commonjs/services/log/logic/webSocket/messageProcessors/index.d.ts

 export * from './askProcessOnAuthenticate';
 export * from './askProcessOnUnauthenticate';
 export * from './askProcessOnPing';
+export * from './askProcessOnChecked';
+export * from './askProcessOnRefreshLogMetadata';

lib/commonjs/services/log/logic/webSocket/messageProcessors/index.js

@@ -20,1 +20,3 @@ "use strict";
 __exportStar(require("./askProcessOnPing"), exports);
+__exportStar(require("./askProcessOnChecked"), exports);
+__exportStar(require("./askProcessOnRefreshLogMetadata"), exports);

lib/commonjs/types/webSocket/clientMessages/index.d.ts

 export * from './WebSocketClientEventMessageAuthenticate';
 export * from './WebSocketClientEventMessageUnauthenticate';
 export * from './WebSocketClientEventMessagePing';
+export * from './WebSocketClientEventMessageMarkLogChecked';

lib/commonjs/types/webSocket/clientMessages/index.js

@@ -20,1 +20,2 @@ "use strict";
 __exportStar(require("./WebSocketClientEventMessagePing"), exports);
+__exportStar(require("./WebSocketClientEventMessageMarkLogChecked"), exports);

lib/commonjs/types/webSocket/WebsocketClientMessageEventType.d.ts

 export declare enum WebsocketClientMessageEventType {
     Authenticate = "qpq/ws/Authenticate",
     Unauthenticate = "qpq/ws/Unauthenticate",
-    Ping = "qpq/ws/Ping"
+    Ping = "qpq/ws/Ping",
+    MarkLogChecked = "qpq/ws/MarkLogChecked"
 }

lib/commonjs/types/webSocket/WebsocketClientMessageEventType.js

@@ -9,2 +9,3 @@ "use strict";
     WebsocketClientMessageEventType["Ping"] = "qpq/ws/Ping";
+    WebsocketClientMessageEventType["MarkLogChecked"] = "qpq/ws/MarkLogChecked";
 })(WebsocketClientMessageEventType = exports.WebsocketClientMessageEventType || (exports.WebsocketClientMessageEventType = {}));

package.json

 {
   "name": "quidproquo-webserver",
-  "version": "0.0.192",
+  "version": "0.0.193",
   "description": "",
@@ -29,8 +29,8 @@ "main": "./lib/commonjs/index.js",
     "@anthropic-ai/sdk": "^0.19.1",
-    "quidproquo-core": "0.0.192"
+    "quidproquo-core": "0.0.193"
   },
   "devDependencies": {
-    "quidproquo-tsconfig": "0.0.192",
+    "quidproquo-tsconfig": "0.0.193",
     "typescript": "^4.9.3"
   }
 }

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

251668

increased by5.86%

Number of package files

338

increased by6.96%

Lines of code

4709

increased by5.65%

Dependency changes

• + Addedquidproquo-core@0.0.193(transitive)

• - Removedquidproquo-core@0.0.192(transitive)

• Updatedquidproquo-core@0.0.193