11import { PostgrestClient } from '../src/index'
22import { Database } from './types.override'
3- import { Database as DatabasePostgrest13 } from './types.override-with-options-postgrest13 '
3+ import { Database as DatabasePostgrest14 } from './types.override-with-options-postgrest14 '
44import { expectType , TypeEqual } from './types'
55import { InvalidMethodError } from '../src/PostgrestFilterBuilder'
66import { z } from 'zod'
77import { RequiredDeep } from 'type-fest'
88
9- const REST_URL_13 = 'http://localhost:3001'
10- const postgrest13 = new PostgrestClient < DatabasePostgrest13 > ( REST_URL_13 )
11- const postgrest12 = new PostgrestClient < Database > ( REST_URL_13 )
9+ const REST_URL_14 = 'http://localhost:3001'
10+ const postgrest14 = new PostgrestClient < DatabasePostgrest14 > ( REST_URL_14 )
11+ const postgrest12 = new PostgrestClient < Database > ( REST_URL_14 )
1212
1313const MessageRowSchema = z . object ( {
1414 channel_id : z . number ( ) ,
@@ -28,22 +28,22 @@ describe('maxAffected', () => {
2828 expectType < InvalidMethodError < 'maxAffected method only available on postgrest 13+' > > ( resUpdate )
2929 } )
3030 test ( 'types: maxAffected should show type warning on non update / delete' , async ( ) => {
31- const resSelect = postgrest13 . from ( 'messages' ) . select ( '*' ) . maxAffected ( 10 )
32- const resInsert = postgrest13
31+ const resSelect = postgrest14 . from ( 'messages' ) . select ( '*' ) . maxAffected ( 10 )
32+ const resInsert = postgrest14
3333 . from ( 'messages' )
3434 . insert ( { message : 'foo' , username : 'supabot' , channel_id : 1 } )
3535 . maxAffected ( 10 )
36- const resUpsert = postgrest13
36+ const resUpsert = postgrest14
3737 . from ( 'messages' )
3838 . upsert ( { id : 3 , message : 'foo' , username : 'supabot' , channel_id : 2 } )
3939 . maxAffected ( 10 )
40- const resUpdate = postgrest13
40+ const resUpdate = postgrest14
4141 . from ( 'messages' )
4242 . update ( { channel_id : 2 } )
4343 . eq ( 'message' , 'foo' )
4444 . maxAffected ( 1 )
4545 . select ( )
46- const resDelete = postgrest13
46+ const resDelete = postgrest14
4747 . from ( 'messages' )
4848 . delete ( )
4949 . eq ( 'message' , 'foo' )
@@ -70,14 +70,14 @@ describe('maxAffected', () => {
7070
7171 test ( 'update should fail when maxAffected is exceeded' , async ( ) => {
7272 // First create multiple rows
73- await postgrest13 . from ( 'messages' ) . insert ( [
73+ await postgrest14 . from ( 'messages' ) . insert ( [
7474 { message : 'test1' , username : 'supabot' , channel_id : 1 } ,
7575 { message : 'test1' , username : 'supabot' , channel_id : 1 } ,
7676 { message : 'test1' , username : 'supabot' , channel_id : 1 } ,
7777 ] )
7878
7979 // Try to update all rows with maxAffected=2
80- const result = await postgrest13
80+ const result = await postgrest14
8181 . from ( 'messages' )
8282 . update ( { message : 'updated' } )
8383 . eq ( 'message' , 'test1' )
@@ -88,17 +88,17 @@ describe('maxAffected', () => {
8888 expect ( error ?. code ) . toBe ( 'PGRST124' )
8989
9090 // cleanup
91- await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test1' )
91+ await postgrest14 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test1' )
9292 } )
9393
9494 test ( 'update should succeed when within maxAffected limit' , async ( ) => {
9595 // First create a single row
96- await postgrest13
96+ await postgrest14
9797 . from ( 'messages' )
9898 . insert ( [ { message : 'test2' , username : 'supabot' , channel_id : 1 } ] )
9999
100100 // Try to update with maxAffected=2
101- const { data, error } = await postgrest13
101+ const { data, error } = await postgrest14
102102 . from ( 'messages' )
103103 . update ( { message : 'updated' } )
104104 . eq ( 'message' , 'test2' )
@@ -116,19 +116,19 @@ describe('maxAffected', () => {
116116 expect ( data ?. [ 0 ] . message ) . toBe ( 'updated' )
117117
118118 // cleanup
119- await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'updated' )
119+ await postgrest14 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'updated' )
120120 } )
121121
122122 test ( 'delete should fail when maxAffected is exceeded' , async ( ) => {
123123 // First create multiple rows
124- await postgrest13 . from ( 'messages' ) . insert ( [
124+ await postgrest14 . from ( 'messages' ) . insert ( [
125125 { message : 'test3' , username : 'supabot' , channel_id : 1 } ,
126126 { message : 'test3' , username : 'supabot' , channel_id : 1 } ,
127127 { message : 'test3' , username : 'supabot' , channel_id : 1 } ,
128128 ] )
129129
130130 // Try to delete all rows with maxAffected=2
131- const { error } = await postgrest13
131+ const { error } = await postgrest14
132132 . from ( 'messages' )
133133 . delete ( )
134134 . eq ( 'message' , 'test3' )
@@ -138,17 +138,17 @@ describe('maxAffected', () => {
138138 expect ( error ?. code ) . toBe ( 'PGRST124' )
139139
140140 // cleanup
141- await postgrest13 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test3' )
141+ await postgrest14 . from ( 'messages' ) . delete ( ) . eq ( 'message' , 'test3' )
142142 } )
143143
144144 test ( 'delete should succeed when within maxAffected limit' , async ( ) => {
145145 // First create a single row
146- await postgrest13
146+ await postgrest14
147147 . from ( 'messages' )
148148 . insert ( [ { message : 'test4' , username : 'supabot' , channel_id : 1 } ] )
149149
150150 // Try to delete with maxAffected=2
151- const { data, error } = await postgrest13
151+ const { data, error } = await postgrest14
152152 . from ( 'messages' )
153153 . delete ( )
154154 . eq ( 'message' , 'test4' )
@@ -162,9 +162,9 @@ describe('maxAffected', () => {
162162
163163 test ( 'should be able to use .maxAffected with setof records returning rpc' , async ( ) => {
164164 // First create a user that will be returned by the RPC
165- await postgrest13 . from ( 'users' ) . insert ( [ { username : 'testuser' , status : 'ONLINE' } ] )
165+ await postgrest14 . from ( 'users' ) . insert ( [ { username : 'testuser' , status : 'ONLINE' } ] )
166166 // Call the RPC function that returns a set of records
167- const { data, error } = await postgrest13
167+ const { data, error } = await postgrest14
168168 . rpc ( 'set_users_offline' , { name_param : 'testuser' } )
169169 . maxAffected ( 1 )
170170 . select ( )
@@ -182,19 +182,19 @@ describe('maxAffected', () => {
182182 ] )
183183
184184 // cleanup
185- await postgrest13 . from ( 'users' ) . delete ( ) . eq ( 'username' , 'testuser' )
185+ await postgrest14 . from ( 'users' ) . delete ( ) . eq ( 'username' , 'testuser' )
186186 } )
187187
188188 test ( 'should fail when rpc returns more results than maxAffected' , async ( ) => {
189189 // First create multiple users that will be returned by the RPC
190- await postgrest13 . from ( 'users' ) . insert ( [
190+ await postgrest14 . from ( 'users' ) . insert ( [
191191 { username : 'testuser1' , status : 'ONLINE' } ,
192192 { username : 'testuser2' , status : 'ONLINE' } ,
193193 { username : 'testuser3' , status : 'ONLINE' } ,
194194 ] )
195195
196196 // Call the RPC function that returns a set of records
197- const { data, error } = await postgrest13
197+ const { data, error } = await postgrest14
198198 . rpc ( 'set_users_offline' , { name_param : 'testuser%' } )
199199 . maxAffected ( 1 )
200200 . select ( )
@@ -204,6 +204,6 @@ describe('maxAffected', () => {
204204 expect ( data ) . toBeNull ( )
205205
206206 // cleanup
207- await postgrest13 . from ( 'users' ) . delete ( ) . in ( 'username' , [ 'testuser1' , 'testuser2' , 'testuser3' ] )
207+ await postgrest14 . from ( 'users' ) . delete ( ) . in ( 'username' , [ 'testuser1' , 'testuser2' , 'testuser3' ] )
208208 } )
209209} )
0 commit comments