forked from hyperledger/cacti
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(cmd-api-server): support grpc web services hyperledger#1189
WORK IN PROGRESS! Fixes hyperledger#1189 Signed-off-by: Peter Somogyvari <peter.somogyvari@accenture.com>
- Loading branch information
Showing
10 changed files
with
1,378 additions
and
4 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -14,3 +14,5 @@ | |
| # **/coverage/** | ||
|
|
||
| # typings/** | ||
|
|
||
| **/src/main/typescript/generated/proto/** | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
25 changes: 25 additions & 0 deletions
25
packages/cactus-cmd-api-server/src/main/proto/healthcheck.proto
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,25 @@ | ||
| syntax = "proto3"; | ||
|
|
||
| package org.hyperledger.cactus.cmd_api_server; | ||
|
|
||
| service Healthcheck { | ||
| // Obtains the memory usage statistics of the API server's NodeJS process. | ||
| rpc GetHealtcheck(HealthcheckRequest) returns (stream HealthcheckResponse) {} | ||
| } | ||
|
|
||
| message MemoryUsage { | ||
| int64 rss = 1; | ||
| int64 heapTotal = 2; | ||
| int64 heapUsed = 3; | ||
| int64 external = 4; | ||
| int64 arrayBuffers = 5; | ||
| } | ||
|
|
||
| message HealthcheckRequest { | ||
| } | ||
|
|
||
| message HealthcheckResponse { | ||
| bool success = 1; | ||
| string createdAt = 2; | ||
| MemoryUsage memoryUsage = 3; | ||
| } |
864 changes: 864 additions & 0 deletions
864
packages/cactus-cmd-api-server/src/main/typescript/generated/proto/pbjs.js
Large diffs are not rendered by default.
Oops, something went wrong.
361 changes: 361 additions & 0 deletions
361
packages/cactus-cmd-api-server/src/main/typescript/generated/proto/pbts.d.ts
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
75 changes: 75 additions & 0 deletions
75
...tus-cmd-api-server/src/main/typescript/web-services/grpc/watch-healthcheck-v1-endpoint.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,75 @@ | ||
| import { Socket as SocketIoSocket } from "socket.io"; | ||
|
|
||
| import { Logger, Checks } from "@hyperledger/cactus-common"; | ||
| import { LogLevelDesc, LoggerProvider } from "@hyperledger/cactus-common"; | ||
|
|
||
| import { org } from "../../generated/proto/pbts"; | ||
| import { WatchHealthcheckV1 } from "../../generated/openapi/typescript-axios/api"; | ||
|
|
||
| const { HealthcheckResponse } = org.hyperledger.cactus.cmd_api_server; | ||
|
|
||
| export interface IWatchHealthcheckV1EndpointOptions { | ||
| logLevel?: LogLevelDesc; | ||
| socket: SocketIoSocket; | ||
| process: NodeJS.Process; | ||
| } | ||
|
|
||
| export class WatchHealthcheckV1Endpoint { | ||
| public static readonly CLASS_NAME = "WatchHealthcheckV1Endpoint"; | ||
|
|
||
| private readonly log: Logger; | ||
| private readonly process: NodeJS.Process; | ||
|
|
||
| public get className(): string { | ||
| return WatchHealthcheckV1Endpoint.CLASS_NAME; | ||
| } | ||
|
|
||
| constructor(public readonly options: IWatchHealthcheckV1EndpointOptions) { | ||
| const fnTag = `${this.className}#constructor()`; | ||
| Checks.truthy(options, `${fnTag} arg options`); | ||
| Checks.truthy(options.process, `${fnTag} arg options.process`); | ||
|
|
||
| this.process = options.process; | ||
|
|
||
| const level = this.options.logLevel || "INFO"; | ||
| const label = this.className; | ||
| this.log = LoggerProvider.getOrCreate({ level, label }); | ||
| } | ||
|
|
||
| public async subscribe(): Promise<void> { | ||
| const { log } = this; | ||
| log.debug(`${WatchHealthcheckV1.Subscribe} => FIXME - connection ID here`); | ||
|
|
||
| const timerId = setInterval(() => { | ||
| try { | ||
| const next: org.hyperledger.cactus.cmd_api_server.IHealthcheckResponse = HealthcheckResponse.create( | ||
| { | ||
| createdAt: new Date().toJSON(), | ||
| memoryUsage: this.process.memoryUsage(), | ||
| success: true, | ||
| }, | ||
| ); | ||
|
|
||
| const validationMessage = HealthcheckResponse.verify(next); | ||
| if (validationMessage) { | ||
| // socket.emit(WatchHealthcheckV1.Error, validationMessage); | ||
| } else { | ||
| // socket.emit(WatchHealthcheckV1.Next, next); | ||
| } | ||
| } catch (ex) { | ||
| log.error(`Failed to construct health check response:`, ex); | ||
| // socket.emit(WatchHealthcheckV1.Error, ex); | ||
| clearInterval(timerId); | ||
| } | ||
| }, 1000); | ||
|
|
||
| // socket.on("disconnect", async (reason: string) => { | ||
| // log.debug("WebSocket:disconnect reason=%o", reason); | ||
| // clearInterval(timerId); | ||
| // }); | ||
|
|
||
| // socket.on(WatchHealthcheckV1.Unsubscribe, () => { | ||
| // clearInterval(timerId); | ||
| // }); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters