o /h, @sddlZddlmZmZmZmZddlmZddlm Z m Z ddl m Z ddl mZmZmZddlmZddlmZdd lmZdd lmZd d lmZd dlmZGdddeZGdddZ dde!de!deedfde fddZ"dS)N)AnyDictOptionalUnion)AsyncMemoryStorage)AuthChangeEventSession)Timeout)AsyncPostgrestClientAsyncRequestBuilderAsyncRPCFilterRequestBuilder) DEFAULT_POSTGREST_CLIENT_TIMEOUTAsyncStorageClient)DEFAULT_TIMEOUT)AsyncFunctionsClient) ClientOptions)AsyncSupabaseAuthClientcs"eZdZdeffdd ZZS)SupabaseExceptionmessagecs||_t|jdSN)rsuper__init__)selfr __class__O/var/www/html/govbot/env/lib/python3.10/site-packages/supabase/_async/client.pyrszSupabaseException.__init__)__name__ __module__ __qualname__strr __classcell__rrrrrsrc@seZdZdZ d6dededeedffddZe d6dededeedffdd Z d ed e fd d Z ded e fddZ d ed e fddZ d6dedeeeefd efddZeddZeddZeddZeedfdedeeefd ed!ed ef d"d#Zed$ed%ed efd&d'Zee dfd(edeeefded)eee!e"fd!ed e f d*d+Z#d,efd-d.Z$ d6d/eedfd eeeffd0d1Z%d2e&d3ee'dffd4d5Z(dS)7 AsyncClientzSupabase client class.N supabase_url supabase_keyoptionscCs|std|s tdtd|stdtd|s td|dur*ttd}||_||_||_|j | |d |_ |d  d d |_ |d |_|d|_|d|_|j|j|d|_d|_d|_d|_d|_|j|jdS)aInstantiate the client. Parameters ---------- supabase_url: str The URL to the Supabase instance that should be connected to. supabase_key: str The API key to the Supabase instance that should be connected to. **options Any extra settings to be optionally specified - also see the `DEFAULT_OPTIONS` dict. zsupabase_url is requiredzsupabase_key is requiredz^(https?)://.+z Invalid URLz7^[A-Za-z0-9-_=]+\.[A-Za-z0-9-_=]+\.?[A-Za-z0-9-_.+/=]*$zInvalid API keyN)storagez/rest/v1z /realtime/v1httpwsz/auth/v1z /storage/v1z /functions/v1auth_urlclient_options)rrematchrrr&r'r(headersupdate_get_auth_headersrest_urlreplace realtime_urlr- storage_url functions_url_init_supabase_auth_clientauthrealtime _postgrest_storage _functionson_auth_state_change_listen_to_auth_events)rr&r'r(rrrrs<       zAsyncClient.__init__c s|r |jdnd}||||}|durDz|jIdH}||j}Wnty9}zd}WYd}~nd}~ww|jj| ||S)N Authorization) r1getr: get_session_create_auth_header access_token Exceptionr(r2r3) clsr&r'r( auth_headerclientsessionsession_access_tokenerrrrrcreate^s zAsyncClient.create table_namereturncCs ||S)zPerform a table operation. Note that the supabase client uses the `from` method, but in Python, this is a reserved keyword, so we have elected to use the name `table`. Alternatively you can use the `.from_()` method. )from_rrNrrrtableus zAsyncClient.tableschemacCs$|j|j|jj||jjd|_|jS)zSelect a schema to query or perform an function (rpc) call. The schema needs to be on the list of exposed schemas inside Supabase. r4r1rStimeout)_init_postgrest_clientr4r(r1postgrest_client_timeoutr<)rrSrrrrS~szAsyncClient.schemacCs |j|S)zDPerform a table operation. See the `table` method. ) postgrestrPrQrrrrPs zAsyncClient.from_fnparamscCs|duri}|j||S)aPerforms a stored procedure call. Parameters ---------- fn : callable The stored procedure call to be executed. params : dict of any Parameters passed into the stored procedure call. Returns ------- SyncFilterRequestBuilder Returns a filter builder. This lets you apply filters on the response of an RPC. N)rXrpc)rrYrZrrrr[szAsyncClient.rpccCs2|jdur|j|j|jj|jj|jjd|_|jS)NrT)r<rVr4r(r1rSrWrrrrrXs zAsyncClient.postgrestcCs,|jdur|j|j|jj|jjd|_|jS)N)r7r1storage_client_timeout)r=_init_storage_clientr7r(r1r]r\rrrr)s zAsyncClient.storagecCs(|jdurt|j|jj|jj|_|jSr)r>rr8r(r1function_client_timeoutr\rrr functionss zAsyncClient.functionsTr7r1r]verifycCst||||Srr)r7r1r]rarrrr^sz AsyncClient._init_storage_clientr-r.cCst||j|j|j|j|jdS)z0Creates a wrapped instance of the GoTrue Client.)urlauto_refresh_tokenpersist_sessionr)r1 flow_type)rrcrdr)r1rer,rrrr9sz&AsyncClient._init_supabase_auth_clientr4rUcCst|||||dS)z@Private helper for creating an instance of the Postgrest client.)r1rSrUra)r )r4r1rSrUrarrrrVs z"AsyncClient._init_postgrest_clienttokencCs d|S)NzBearer r)rrfrrrrDs zAsyncClient._create_auth_header authorizationcCs.|dur|jjd||j} |j|dS)NrA)apiKeyrA)r(r1rBrDr')rrgrrrr3s zAsyncClient._get_auth_headerseventrJcCsF|j}|dvrd|_d|_d|_|r|jn|j}|||jjd<dS)N) SIGNED_INTOKEN_REFRESHED SIGNED_OUTrA)r'r<r=r>rErDr(r1)rrirJrErrrr@%sz"AsyncClient._listen_to_auth_eventsr))r r!r"__doc__r#rrr classmethodrMr rRr rSrPrrrr r[propertyrXr)r` staticmethodDEFAULT_STORAGE_CLIENT_TIMEOUTintboolrr^rr9r floatr rVrDr3rrr@rrrrr%s  ?        ,          r%r&r'r(rOcstj|||dIdHS)aCreate client function to instantiate supabase client like JS runtime. Parameters ---------- supabase_url: str The URL to the Supabase instance that should be connected to. supabase_key: str The API key to the Supabase instance that should be connected to. **options Any extra settings to be optionally specified - also see the `DEFAULT_OPTIONS` dict. Examples -------- Instantiating the client. >>> import os >>> from supabase import create_client, Client >>> >>> url: str = os.environ.get("SUPABASE_TEST_URL") >>> key: str = os.environ.get("SUPABASE_TEST_KEY") >>> supabase: Client = create_client(url, key) Returns ------- Client r&r'r(N)r%rMrurrr create_client3s rvr)#r/typingrrrrgotruer gotrue.typesrrhttpxr rXr r r postgrest.constantsr storage3rstorage3.constantsrrqsupafuncrlib.client_optionsr auth_clientrrFrr%r#rvrrrrs4