Skip to content

Commit ffe7ecd

Browse files
committed
code review fixes
1 parent b42dbdd commit ffe7ecd

File tree

5 files changed

+15
-22
lines changed

5 files changed

+15
-22
lines changed

src/apiActionSteps.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { When } from '@cucumber/cucumber';
22
import { logPayload, sendHttpRequest } from './utils';
3-
import { MemoryValue } from '@qavajs/core/src/load';
3+
import { MemoryValue } from '@qavajs/core';
44

55
/**
66
* Send request to the API

src/apiConstructionSteps.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { DataTable, When } from '@cucumber/cucumber';
22
import { dataTable2Object, sendHttpRequest } from './utils';
33
import GraphQl from './GraphQl';
4-
import { MemoryValue } from '@qavajs/core/src/load';
4+
import { MemoryValue } from '@qavajs/core';
55

66
/**
77
* Create request template and save it to memory

src/utils.ts

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import { DataTable, IWorld } from '@cucumber/cucumber';
2-
import { MemoryValue } from '@qavajs/core/src/load';
32
import WebSocket from 'ws';
43

54
/**
@@ -79,17 +78,6 @@ export function logPayload(type: string, payload: any): string {
7978
}
8079
}
8180

82-
export async function sendMessage(
83-
{
84-
messageKey,
85-
wsKey,
86-
}: {
87-
messageKey: MemoryValue;
88-
wsKey: MemoryValue;
89-
},
90-
context: any,
91-
) {
92-
const ws = (await context.getValue(wsKey)) as WebSocket;
93-
const message = await context.getValue(messageKey);
81+
export function sendMessage(message: any, ws: WebSocket){
9482
ws.send(Buffer.from(message));
9583
}

src/websocket.ts

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
11
import { When } from '@cucumber/cucumber';
22
import WebSocket from 'ws';
3-
import { MemoryValue } from '@qavajs/core/src/load';
3+
import { MemoryValue } from '@qavajs/core';
44
import { sendMessage } from './utils';
5+
import memory from "@qavajs/memory";
56

67
When('I connect to {value} ws endpoint {value}', async function (uriKey: MemoryValue, wsKey: MemoryValue) {
78
const uri = await uriKey.value();
@@ -35,15 +36,19 @@ When(
3536
},
3637
);
3738

38-
When('I send {string} message to {string} ws endpoint', async function (messageKey: MemoryValue, wsKey: MemoryValue) {
39-
await sendMessage({ messageKey, wsKey }, this);
39+
When('I send {value} message to {value} ws endpoint', async function (messageKey: MemoryValue, wsKey: MemoryValue) {
40+
const message = await messageKey.value();
41+
const ws = await wsKey.value();
42+
sendMessage(message, ws);
4043
});
4144

42-
When('I send message to {string} ws endpoint:', async function (wsKey: MemoryValue, messageKey) {
43-
await sendMessage({ messageKey, wsKey }, this);
45+
When('I send message to {value} ws endpoint:', async function (wsKey: MemoryValue, messageKey: string) {
46+
const message = await memory.getValue(messageKey);
47+
const ws = await wsKey.value();
48+
sendMessage(message, ws);
4449
});
4550

46-
When('I close {string} ws connection', async function (wsKey: MemoryValue) {
51+
When('I close {value} ws connection', async function (wsKey: MemoryValue) {
4752
const ws = (await wsKey.value()) as WebSocket;
4853
ws.close();
4954
});

test-e2e/step-definitions/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { Then } from '@cucumber/cucumber';
22
import { expect } from 'chai';
3-
import { MemoryValue } from '@qavajs/core/src/load';
3+
import { MemoryValue } from '@qavajs/core';
44

55
Then('I expect {value} memory value to be equal {value}', async function (actual: MemoryValue, expected: MemoryValue) {
66
const actualValue = await actual.value();

0 commit comments

Comments
 (0)