Skip to content

Commit

Permalink
test: wip: add tests for verifier in cmd-socketio-server
Browse files Browse the repository at this point in the history
tests

Closes: hyperledger-cacti#123
Signed-off-by: Michal Bajer <michal.bajer@fujitsu.com>
  • Loading branch information
outSH committed Nov 15, 2021
1 parent 4beab22 commit 2ed2412
Show file tree
Hide file tree
Showing 3 changed files with 310 additions and 31 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ export class Verifier implements IVerifier {
logger.debug(`socketOptions = ${JSON.stringify(socketOptions)}`);
Verifier.mapUrlSocket.set(
this.validatorID,
io(this.validatorUrl, socketOptions)
io(this.validatorUrl, socketOptions),
);
}
}
Expand All @@ -84,13 +84,13 @@ export class Verifier implements IVerifier {
public sendAsyncRequest(
contract: object,
method: object,
args: object
args: object,
): Promise<void> {
return new Promise((resolve, reject) => {
logger.debug(
`call: sendAsyncRequest, contract = ${JSON.stringify(
contract
)}, method = ${JSON.stringify(method)}, args = ${args}`
contract,
)}, method = ${JSON.stringify(method)}, args = ${args}`,
);
try {
// verifier comunicate with socket
Expand Down Expand Up @@ -130,7 +130,7 @@ export class Verifier implements IVerifier {
private requestLedgerOperationNeo(
contract: object,
method: object,
args: object
args: object,
): void {
logger.debug("call : requestLedgerOperation");
try {
Expand All @@ -153,17 +153,17 @@ export class Verifier implements IVerifier {
public sendSyncRequest(
contract: object,
method: object,
args: object
args: object,
): Promise<any> {
return new Promise((resolve, reject) => {
logger.debug("call : sendSyncRequest");
try {
logger.debug(
`##in sendSyncRequest, contract = ${JSON.stringify(
contract
contract,
)}, method = ${JSON.stringify(method)}, args = ${JSON.stringify(
args
)}, `
args,
)}, `,
);
let responseFlag = false;

Expand Down Expand Up @@ -197,7 +197,7 @@ export class Verifier implements IVerifier {

VerifierAuthentication.verify(
this.validatorKeyPath,
result.resObj.data
result.resObj.data,
)
.then((decodedData) => {
const resultObj = {
Expand Down Expand Up @@ -242,16 +242,16 @@ export class Verifier implements IVerifier {
private requestLedgerOperationHttp(
contract: object,
method: object,
args: object
args: object,
): Promise<void> {
return new Promise((resolve, reject) => {
try {
logger.debug(
`##in requestLedgerOperationHttp, contract = ${JSON.stringify(
contract
contract,
)}, method = ${JSON.stringify(method)}, args = ${JSON.stringify(
args
)}`
args,
)}`,
);
const eventListenerHash = this.eventListenerHash;
const validatorID = this.validatorID;
Expand All @@ -273,23 +273,23 @@ export class Verifier implements IVerifier {
for (const key in eventListenerHash) {
logger.debug(
`key : ${key}, eventListenerHash[key] : ${JSON.stringify(
eventListenerHash[key]
)}`
eventListenerHash[key],
)}`,
);
eventListener = eventListenerHash[key];
eventListener.onEvent(event);
}
} else {
logger.debug(
`##requestLedgerOperationHttp eventListener does not exist`
`##requestLedgerOperationHttp eventListener does not exist`,
);
}
logger.debug(`##after onEvent()`);

// resolve(responseObj);
} catch (err) {
logger.error(
`##Error: requestLedgerOperationHttp#httpReq.onload, ${err}`
`##Error: requestLedgerOperationHttp#httpReq.onload, ${err}`,
);
}
};
Expand Down Expand Up @@ -328,7 +328,7 @@ export class Verifier implements IVerifier {
public startMonitor(
id: string,
options: Object,
eventListener: VerifierEventListener
eventListener: VerifierEventListener,
): Promise<void> {
return new Promise((resolve, reject) => {
logger.debug("call : startMonitor");
Expand All @@ -337,7 +337,7 @@ export class Verifier implements IVerifier {

if (Object.keys(this.eventListenerHash).length > 0) {
logger.debug(
`##in startMonitor, validatorUrl = ${this.validatorUrl}`
`##in startMonitor, validatorUrl = ${this.validatorUrl}`,
);

const socket = Verifier.mapUrlSocket.get(this.validatorID);
Expand Down Expand Up @@ -368,12 +368,12 @@ export class Verifier implements IVerifier {
logger.debug(
`##eventReceived Object.keys(this.eventListenerHash).length : ${
Object.keys(this.eventListenerHash).length
}`
}`,
);
if (Object.keys(this.eventListenerHash).length > 0) {
VerifierAuthentication.verify(
this.validatorKeyPath,
res.blockData
res.blockData,
)
.then((decodedData) => {
const resultObj = {
Expand All @@ -389,7 +389,7 @@ export class Verifier implements IVerifier {
const eventListener = this.eventListenerHash[key];
if (eventListener != null) {
logger.debug(
`##set eventListener: ${eventListener}, ${this.constructor.name}, ${this.validatorID}`
`##set eventListener: ${eventListener}, ${this.constructor.name}, ${this.validatorID}`,
);
eventListener.onEvent(event);
} else {
Expand Down Expand Up @@ -448,7 +448,7 @@ export class Verifier implements IVerifier {

private setEventListener(
appId: string,
eventListener: VerifierEventListener | null
eventListener: VerifierEventListener | null,
): void {
logger.debug(`##call : setEventListener`);
this.eventListenerHash[appId] = eventListener;
Expand Down
Loading

0 comments on commit 2ed2412

Please sign in to comment.