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