@@ -19,22 +19,22 @@ describe('maxAffected', () => {
19
19
expectType < InvalidMethodError < 'maxAffected method only available on postgrest 13+' > > ( resUpdate )
20
20
} )
21
21
test ( 'types: maxAffected should show type warning on non update / delete' , async ( ) => {
22
- const resSelect = await postgrest13 . from ( 'messages' ) . select ( '*' ) . maxAffected ( 10 )
23
- const resInsert = await postgrest13
22
+ const resSelect = postgrest13 . from ( 'messages' ) . select ( '*' ) . maxAffected ( 10 )
23
+ const resInsert = postgrest13
24
24
. from ( 'messages' )
25
25
. insert ( { message : 'foo' , username : 'supabot' , channel_id : 1 } )
26
26
. maxAffected ( 10 )
27
- const resUpsert = await postgrest13
27
+ const resUpsert = postgrest13
28
28
. from ( 'messages' )
29
29
. upsert ( { id : 3 , message : 'foo' , username : 'supabot' , channel_id : 2 } )
30
30
. maxAffected ( 10 )
31
- const resUpdate = await postgrest13
31
+ const resUpdate = postgrest13
32
32
. from ( 'messages' )
33
33
. update ( { channel_id : 2 } )
34
34
. eq ( 'message' , 'foo' )
35
35
. maxAffected ( 1 )
36
36
. select ( )
37
- const resDelete = await postgrest13
37
+ const resDelete = postgrest13
38
38
. from ( 'messages' )
39
39
. delete ( )
40
40
. eq ( 'message' , 'foo' )
@@ -77,6 +77,9 @@ describe('maxAffected', () => {
77
77
const { error } = result
78
78
expect ( error ) . toBeDefined ( )
79
79
expect ( error ?. code ) . toBe ( 'PGRST124' )
80
+
81
+ // cleanup
82
+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test1' )
80
83
} )
81
84
82
85
test ( 'update should succeed when within maxAffected limit' , async ( ) => {
@@ -105,6 +108,9 @@ describe('maxAffected', () => {
105
108
expect ( error ) . toBeNull ( )
106
109
expect ( data ) . toHaveLength ( 1 )
107
110
expect ( data ?. [ 0 ] . message ) . toBe ( 'updated' )
111
+
112
+ // cleanup
113
+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'updated' )
108
114
} )
109
115
110
116
test ( 'delete should fail when maxAffected is exceeded' , async ( ) => {
@@ -124,6 +130,9 @@ describe('maxAffected', () => {
124
130
. select ( )
125
131
expect ( error ) . toBeDefined ( )
126
132
expect ( error ?. code ) . toBe ( 'PGRST124' )
133
+
134
+ // cleanup
135
+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test3' )
127
136
} )
128
137
129
138
test ( 'delete should succeed when within maxAffected limit' , async ( ) => {
@@ -165,6 +174,9 @@ describe('maxAffected', () => {
165
174
catchphrase : null ,
166
175
} ,
167
176
] )
177
+
178
+ // cleanup
179
+ await postgrest13 . from ( 'users' ) . delete ( ) . eq ( 'username' , 'testuser' )
168
180
} )
169
181
170
182
test ( 'should fail when rpc returns more results than maxAffected' , async ( ) => {
@@ -184,5 +196,8 @@ describe('maxAffected', () => {
184
196
expect ( error ) . toBeDefined ( )
185
197
expect ( error ?. code ) . toBe ( 'PGRST124' )
186
198
expect ( data ) . toBeNull ( )
199
+
200
+ // cleanup
201
+ await postgrest13 . from ( 'users' ) . delete ( ) . in ( 'username' , [ 'testuser1' , 'testuser2' , 'testuser3' ] )
187
202
} )
188
203
} )
0 commit comments