-
Notifications
You must be signed in to change notification settings - Fork 285
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: endpoints implementation in corda plugin
Closes #1346 Signed-off-by: Elena Izaguirre <e.izaguirre.equiza@accenture.com>
- Loading branch information
1 parent
09ace15
commit 21a22b5
Showing
7 changed files
with
817 additions
and
81 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
114 changes: 114 additions & 0 deletions
114
...ugin-ledger-connector-corda/src/main/typescript/web-services/diagnose-node-endpoint-v1.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,114 @@ | ||
| import { Express, Request, Response } from "express"; | ||
|
|
||
| import { | ||
| Logger, | ||
| LoggerProvider, | ||
| LogLevelDesc, | ||
| Checks, | ||
| IAsyncProvider, | ||
| } from "@hyperledger/cactus-common"; | ||
|
|
||
| import { | ||
| IWebServiceEndpoint, | ||
| IExpressRequestHandler, | ||
| IEndpointAuthzOptions, | ||
| Configuration, | ||
| } from "@hyperledger/cactus-core-api"; | ||
|
|
||
| import OAS from "../../json/openapi.json"; | ||
|
|
||
| import { registerWebServiceEndpoint } from "@hyperledger/cactus-core"; | ||
| import { | ||
| DefaultApi, | ||
| DiagnoseNodeV1Request, | ||
| DiagnoseNodeV1Response, | ||
| } from "../generated/openapi/typescript-axios"; | ||
|
|
||
| export interface IDiagnoseNodeEndpointV1Options { | ||
| logLevel?: LogLevelDesc; | ||
| apiUrl?: string; | ||
| } | ||
|
|
||
| export class DiagnoseNodeEndpointV1 implements IWebServiceEndpoint { | ||
| private readonly log: Logger; | ||
| private readonly apiUrl?: string; | ||
|
|
||
| constructor(public readonly opts: IDiagnoseNodeEndpointV1Options) { | ||
| const fnTag = "NetworkMapEndpointV1#constructor()"; | ||
|
|
||
| Checks.truthy(opts, `${fnTag} options`); | ||
|
|
||
| this.log = LoggerProvider.getOrCreate({ | ||
| label: "diagnose-node-endpoint-v1", | ||
| level: opts.logLevel || "INFO", | ||
| }); | ||
|
|
||
| this.apiUrl = opts.apiUrl; | ||
| } | ||
|
|
||
| getAuthorizationOptionsProvider(): IAsyncProvider<IEndpointAuthzOptions> { | ||
| // TODO: make this an injectable dependency in the constructor | ||
| return { | ||
| get: async () => ({ | ||
| isProtected: true, | ||
| requiredRoles: [], | ||
| }), | ||
| }; | ||
| } | ||
|
|
||
| public getExpressRequestHandler(): IExpressRequestHandler { | ||
| return this.handleRequest.bind(this); | ||
| } | ||
|
|
||
| public get oasPath(): typeof OAS.paths["/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-corda/diagnose-node"] { | ||
| return OAS.paths[ | ||
| "/api/v1/plugins/@hyperledger/cactus-plugin-ledger-connector-corda/diagnose-node" | ||
| ]; | ||
| } | ||
|
|
||
| public getPath(): string { | ||
| return this.oasPath.post["x-hyperledger-cactus"].http.path; | ||
| } | ||
|
|
||
| public getVerbLowerCase(): string { | ||
| return this.oasPath.post["x-hyperledger-cactus"].http.verbLowerCase; | ||
| } | ||
|
|
||
| public getOperationId(): string { | ||
| return this.oasPath.post.operationId; | ||
| } | ||
|
|
||
| public async registerExpress( | ||
| expressApp: Express, | ||
| ): Promise<IWebServiceEndpoint> { | ||
| await registerWebServiceEndpoint(expressApp, this); | ||
| return this; | ||
| } | ||
|
|
||
| async handleRequest(req: Request, res: Response): Promise<void> { | ||
| const fnTag = "DiagnoseNodeEndpointV1#handleRequest()"; | ||
| const verbUpper = this.getVerbLowerCase().toUpperCase(); | ||
| this.log.debug(`${verbUpper} ${this.getPath()}`); | ||
|
|
||
| try { | ||
| if (this.apiUrl === undefined) throw "apiUrl option is necessary"; | ||
| const resBody = await this.callInternalContainer(req.body); | ||
| res.status(200); | ||
| res.send(resBody); | ||
| } catch (ex) { | ||
| this.log.error(`${fnTag} failed to serve request`, ex); | ||
| res.status(500); | ||
| res.statusMessage = ex.message; | ||
| res.json({ error: ex.stack }); | ||
| } | ||
| } | ||
|
|
||
| async callInternalContainer( | ||
| req: DiagnoseNodeV1Request, | ||
| ): Promise<DiagnoseNodeV1Response> { | ||
| const apiConfig = new Configuration({ basePath: this.apiUrl }); | ||
| const apiClient = new DefaultApi(apiConfig); | ||
| const res = await apiClient.diagnoseNodeV1(req); | ||
| return res.data; | ||
| } | ||
| } |
Oops, something went wrong.