1
1
import re
2
- from typing import Any , Dict , Union
2
+ from typing import Any , Dict , Optional , Union
3
3
4
4
from gotrue import SyncMemoryStorage
5
5
from gotrue .types import AuthChangeEvent , Session
6
6
from httpx import Timeout
7
- from postgrest import SyncFilterRequestBuilder , SyncPostgrestClient , SyncRequestBuilder
7
+ from postgrest import (
8
+ SyncPostgrestClient ,
9
+ SyncRequestBuilder ,
10
+ SyncRPCFilterRequestBuilder ,
11
+ )
8
12
from postgrest .constants import DEFAULT_POSTGREST_CLIENT_TIMEOUT
9
13
from storage3 import SyncStorageClient
10
14
from storage3 .constants import DEFAULT_TIMEOUT as DEFAULT_STORAGE_CLIENT_TIMEOUT
@@ -115,7 +119,9 @@ def from_(self, table_name: str) -> SyncRequestBuilder:
115
119
"""
116
120
return self .postgrest .from_ (table_name )
117
121
118
- def rpc (self , fn : str , params : Dict [Any , Any ]) -> SyncFilterRequestBuilder :
122
+ def rpc (
123
+ self , fn : str , params : Optional [Dict [Any , Any ]] = None
124
+ ) -> SyncRPCFilterRequestBuilder :
119
125
"""Performs a stored procedure call.
120
126
121
127
Parameters
@@ -131,6 +137,8 @@ def rpc(self, fn: str, params: Dict[Any, Any]) -> SyncFilterRequestBuilder:
131
137
Returns a filter builder. This lets you apply filters on the response
132
138
of an RPC.
133
139
"""
140
+ if params is None :
141
+ params = {}
134
142
return self .postgrest .rpc (fn , params )
135
143
136
144
@property
0 commit comments