-
Notifications
You must be signed in to change notification settings - Fork 301
/
adapter-ws.test.ts
131 lines (119 loc) · 4.24 KB
/
adapter-ws.test.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
import {
TestAdapter,
setEnvVariables,
mockWebSocketProvider,
MockWebsocketServer,
runAllUntilTime,
} from '@chainlink/external-adapter-framework/util/testing-utils'
import {
mockCryptoWebSocketServer,
mockCryptoLwbaWebSocketServer,
mockIexWebSocketServer,
mockForexWebSocketServer,
} from './fixtures'
import { WebSocketClassProvider } from '@chainlink/external-adapter-framework/transports'
import FakeTimers from '@sinonjs/fake-timers'
describe('websocket', () => {
let mockWsServerCrypto: MockWebsocketServer | undefined
let mockWsServerCryptoLwba: MockWebsocketServer | undefined
let mockWsServerIex: MockWebsocketServer | undefined
let mockWsServerForex: MockWebsocketServer | undefined
let testAdapter: TestAdapter
const wsEndpoint = 'ws://localhost:9090'
let oldEnv: NodeJS.ProcessEnv
const priceData = {
base: 'eth',
quote: 'usd',
}
const spreadData = {
endpoint: 'crypto_lwba',
base: 'eth',
quote: 'usd',
}
const priceDataAapl = {
endpoint: 'iex',
base: 'aapl',
transport: 'ws',
}
const priceDataAmzn = {
endpoint: 'iex',
base: 'amzn',
transport: 'ws',
}
const priceDataForex = {
endpoint: 'forex',
base: 'eur',
quote: 'usd',
}
beforeAll(async () => {
oldEnv = JSON.parse(JSON.stringify(process.env))
process.env['WS_API_ENDPOINT'] = wsEndpoint
process.env['API_KEY'] = 'fake-api-key'
process.env['WS_SUBSCRIPTION_UNRESPONSIVE_TTL'] = '180000'
process.env['CACHE_MAX_AGE'] = '150000'
process.env['WS_SUBSCRIPTION_TTL'] = '180000'
// Start mock web socket server
mockWebSocketProvider(WebSocketClassProvider)
mockWsServerCrypto = mockCryptoWebSocketServer(wsEndpoint + '/crypto-synth')
mockWsServerCryptoLwba = mockCryptoLwbaWebSocketServer(wsEndpoint + '/crypto-synth-top')
mockWsServerIex = mockIexWebSocketServer(wsEndpoint + '/iex')
mockWsServerForex = mockForexWebSocketServer(wsEndpoint + '/fx')
const adapter = (await import('./../../src')).adapter
testAdapter = await TestAdapter.startWithMockedCache(adapter, {
clock: FakeTimers.install(),
testAdapter: {} as TestAdapter<never>,
})
// Send initial request to start background execute and wait for cache to be filled with results
await testAdapter.request(priceData)
await testAdapter.request(spreadData)
await testAdapter.request(priceDataAapl)
await testAdapter.request(priceDataAmzn)
await testAdapter.request(priceDataForex)
await testAdapter.waitForCache(5)
})
afterAll(async () => {
setEnvVariables(oldEnv)
mockWsServerCrypto?.close()
mockWsServerCryptoLwba?.close()
mockWsServerIex?.close()
mockWsServerForex?.close()
testAdapter.clock?.uninstall()
await testAdapter.api.close()
})
describe('crypto endpoint', () => {
it('should return success', async () => {
const response = await testAdapter.request(priceData)
expect(response.json()).toMatchSnapshot()
})
})
describe('crypto_lwba endpoint', () => {
it('should return success', async () => {
const response = await testAdapter.request(spreadData)
expect(response.json()).toMatchSnapshot()
})
})
describe('forex endpoint', () => {
it('should return success', async () => {
const response = await testAdapter.request(priceDataForex)
expect(response.json()).toMatchSnapshot()
})
})
describe('iex endpoint', () => {
it('Q request should return success', async () => {
const response = await testAdapter.request(priceDataAapl)
expect(response.json()).toMatchSnapshot()
})
it('T request should return success', async () => {
const response = await testAdapter.request(priceDataAmzn)
expect(response.json()).toMatchSnapshot()
})
it('should update the ttl after heartbeat is received', async () => {
// The cache ttl is 150 seconds. Mocked heartbeat message is sent after 10s after connection which should
// update the ttl and therefore after 153 seconds (from the initial message) we can access the asset
await runAllUntilTime(testAdapter.clock, 153000)
const response = await testAdapter.request(priceDataAapl)
expect(response.statusCode).toBe(200)
expect(response.json()).toMatchSnapshot()
})
})
})