@@ -19,22 +19,22 @@ describe('maxAffected', () => {
1919 expectType < InvalidMethodError < 'maxAffected method only available on postgrest 13+' > > ( resUpdate )
2020 } )
2121 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
2424 . from ( 'messages' )
2525 . insert ( { message : 'foo' , username : 'supabot' , channel_id : 1 } )
2626 . maxAffected ( 10 )
27- const resUpsert = await postgrest13
27+ const resUpsert = postgrest13
2828 . from ( 'messages' )
2929 . upsert ( { id : 3 , message : 'foo' , username : 'supabot' , channel_id : 2 } )
3030 . maxAffected ( 10 )
31- const resUpdate = await postgrest13
31+ const resUpdate = postgrest13
3232 . from ( 'messages' )
3333 . update ( { channel_id : 2 } )
3434 . eq ( 'message' , 'foo' )
3535 . maxAffected ( 1 )
3636 . select ( )
37- const resDelete = await postgrest13
37+ const resDelete = postgrest13
3838 . from ( 'messages' )
3939 . delete ( )
4040 . eq ( 'message' , 'foo' )
@@ -77,6 +77,9 @@ describe('maxAffected', () => {
7777 const { error } = result
7878 expect ( error ) . toBeDefined ( )
7979 expect ( error ?. code ) . toBe ( 'PGRST124' )
80+
81+ // cleanup
82+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test1' )
8083 } )
8184
8285 test ( 'update should succeed when within maxAffected limit' , async ( ) => {
@@ -105,6 +108,9 @@ describe('maxAffected', () => {
105108 expect ( error ) . toBeNull ( )
106109 expect ( data ) . toHaveLength ( 1 )
107110 expect ( data ?. [ 0 ] . message ) . toBe ( 'updated' )
111+
112+ // cleanup
113+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'updated' )
108114 } )
109115
110116 test ( 'delete should fail when maxAffected is exceeded' , async ( ) => {
@@ -124,6 +130,9 @@ describe('maxAffected', () => {
124130 . select ( )
125131 expect ( error ) . toBeDefined ( )
126132 expect ( error ?. code ) . toBe ( 'PGRST124' )
133+
134+ // cleanup
135+ await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test3' )
127136 } )
128137
129138 test ( 'delete should succeed when within maxAffected limit' , async ( ) => {
@@ -165,6 +174,9 @@ describe('maxAffected', () => {
165174 catchphrase : null ,
166175 } ,
167176 ] )
177+
178+ // cleanup
179+ await postgrest13 . from ( 'users' ) . delete ( ) . eq ( 'username' , 'testuser' )
168180 } )
169181
170182 test ( 'should fail when rpc returns more results than maxAffected' , async ( ) => {
@@ -184,5 +196,8 @@ describe('maxAffected', () => {
184196 expect ( error ) . toBeDefined ( )
185197 expect ( error ?. code ) . toBe ( 'PGRST124' )
186198 expect ( data ) . toBeNull ( )
199+
200+ // cleanup
201+ await postgrest13 . from ( 'users' ) . delete ( ) . in ( 'username' , [ 'testuser1' , 'testuser2' , 'testuser3' ] )
187202 } )
188203} )
0 commit comments