1
1
'use strict'
2
2
3
- const { test } = require ( 'tap ' )
3
+ const { test } = require ( 'node:test ' )
4
4
const { Client } = require ( '@opensearch-project/opensearch' )
5
5
const Fastify = require ( 'fastify' )
6
6
const fastifyOpensearch = require ( '..' )
7
7
const isOpensearchClient = require ( '..' ) . isOpensearchClient
8
8
9
9
test ( 'with reachable cluster' , async t => {
10
10
const fastify = Fastify ( )
11
- t . teardown ( ( ) => fastify . close ( ) )
11
+ t . after ( ( ) => fastify . close ( ) )
12
12
fastify . register ( fastifyOpensearch , { node : 'http://localhost:9200' } )
13
13
14
14
await fastify . ready ( )
15
- t . equal ( fastify . opensearch . name , 'opensearch-js' )
15
+ t . assert . deepStrictEqual ( fastify . opensearch . name , 'opensearch-js' )
16
16
} )
17
17
18
- test ( 'with unreachable cluster' , async t => {
18
+ test ( 'with unreachable cluster' , t => {
19
19
const fastify = Fastify ( )
20
- t . teardown ( ( ) => fastify . close ( ) )
20
+ t . after ( ( ) => fastify . close ( ) )
21
21
fastify . register ( fastifyOpensearch , { node : 'http://localhost:9201' } )
22
22
23
- try {
24
- await fastify . ready ( )
25
- t . fail ( 'should not boot successfully' )
26
- } catch ( err ) {
27
- t . ok ( err )
28
- }
23
+ return t . assert . rejects ( fastify . ready ( ) )
29
24
} )
30
25
31
26
test ( 'with unreachable cluster and healthcheck disabled' , async t => {
32
27
const fastify = Fastify ( )
33
- t . teardown ( ( ) => fastify . close ( ) )
28
+ t . after ( ( ) => fastify . close ( ) )
34
29
fastify . register ( fastifyOpensearch , {
35
30
node : 'http://localhost:9201' ,
36
31
healthcheck : false
37
32
} )
38
33
39
- try {
40
- await fastify . ready ( )
41
- t . equal ( fastify . opensearch . name , 'opensearch-js' )
42
- } catch {
43
- t . fail ( 'should not error' )
44
- }
34
+ await fastify . ready ( )
35
+ t . assert . deepStrictEqual ( fastify . opensearch . name , 'opensearch-js' )
45
36
} )
46
37
47
38
test ( 'namespaced' , async t => {
48
39
const fastify = Fastify ( )
49
- t . teardown ( ( ) => fastify . close ( ) )
40
+ t . after ( ( ) => fastify . close ( ) )
50
41
fastify . register ( fastifyOpensearch , {
51
42
node : 'http://localhost:9200' ,
52
43
namespace : 'cluster'
53
44
} )
54
45
55
46
await fastify . ready ( )
56
- t . strictEqual ( fastify . opensearch . cluster . name , 'opensearch-js' )
57
- t . equal ( isOpensearchClient ( fastify . opensearch ) , false )
58
- t . equal ( isOpensearchClient ( fastify . opensearch . cluster ) , true )
47
+ t . assert . deepStrictEqual ( fastify . opensearch . cluster . name , 'opensearch-js' )
48
+ t . assert . deepStrictEqual ( isOpensearchClient ( fastify . opensearch ) , false )
49
+ t . assert . deepStrictEqual ( isOpensearchClient ( fastify . opensearch . cluster ) , true )
59
50
await fastify . close ( )
60
51
} )
61
52
62
53
test ( 'namespaced (errored)' , async t => {
63
54
const fastify = Fastify ( )
64
- t . teardown ( ( ) => fastify . close ( ) )
55
+ t . after ( ( ) => fastify . close ( ) )
65
56
fastify . register ( fastifyOpensearch , {
66
57
node : 'http://localhost:9200' ,
67
58
namespace : 'cluster'
@@ -72,12 +63,7 @@ test('namespaced (errored)', async t => {
72
63
namespace : 'cluster'
73
64
} )
74
65
75
- try {
76
- await fastify . ready ( )
77
- t . fail ( 'should not boot successfully' )
78
- } catch ( err ) {
79
- t . ok ( err )
80
- }
66
+ await t . assert . rejects ( fastify . ready ( ) )
81
67
} )
82
68
83
69
test ( 'custom client' , async t => {
@@ -87,24 +73,19 @@ test('custom client', async t => {
87
73
} )
88
74
89
75
const fastify = Fastify ( )
90
- t . teardown ( ( ) => fastify . close ( ) )
76
+ t . after ( ( ) => fastify . close ( ) )
91
77
fastify . register ( fastifyOpensearch , { client } )
92
78
93
79
await fastify . ready ( )
94
- t . equal ( isOpensearchClient ( fastify . opensearch ) , true )
95
- t . strictEqual ( fastify . opensearch . name , 'custom' )
80
+ t . assert . deepStrictEqual ( isOpensearchClient ( fastify . opensearch ) , true )
81
+ t . assert . deepStrictEqual ( fastify . opensearch . name , 'custom' )
96
82
await fastify . close ( )
97
83
} )
98
84
99
- test ( 'Missing configuration' , async t => {
85
+ test ( 'Missing configuration' , t => {
100
86
const fastify = Fastify ( )
101
- t . teardown ( ( ) => fastify . close ( ) )
87
+ t . after ( ( ) => fastify . close ( ) )
102
88
fastify . register ( fastifyOpensearch )
103
89
104
- try {
105
- await fastify . ready ( )
106
- t . fail ( 'should not boot successfully' )
107
- } catch ( err ) {
108
- t . ok ( err )
109
- }
90
+ return t . assert . rejects ( fastify . ready ( ) )
110
91
} )
0 commit comments