ZTh$UdZddlmZddlmZmZddlmZmZm Z m Z m Z m Z m Z mZddlmZmZddlZddlmZddlmZmZddlmZdd lmZdd lmZdd lm Z m!Z!dd l"m#Z#dd l$m%Z%m&Z&ejNZ(de)d<ejNZ*de)d<d dZ+ d! d"dZ, d! d#dZ- d! d"dZ. d! d#dZ/ d! d$dZ0 d! d%dZ1d&dZ2 d! d'dZ3 d! d(dZ4d)dZ5d*dZ6d+dZ7Gdde Z8y),z This module is concerned with creating a gRPC transport channel specifically for interacting with Sift's gRPC API. the `use_sift_channel` method creates said channel and should generally be used within a with-block for correct resource management. ) annotations)PackageNotFoundErrorversion)AnyDictListOptionalTuple TypedDictUnioncast) ParseResulturlparseN) NotRequired TypeAlias)ClientAsyncInterceptor)MetadataAsyncInterceptor)ClientInterceptor)MetadataMetadataInterceptor) RetryPolicy)DEFAULT_KEEPALIVE_CONFIGKeepaliveConfigr SiftChannelSiftAsyncChannelc|stjS ddl}ddlm}|j }|j d}|Dcgc]}|j|j| }}|Dcgc]}|j|j| }}dj|}tj|Scc}wcc}w#t$r} td| d} ~ wwxYw)z} Returns SSL credentials for use with gRPC. Workaround for this issue: https://github.com/grpc/grpc/issues/29682 rN)cryptoT) binary_formzMissing required dependencies for cert_via_openssl. Run `pip install sift-stack-py[openssl]` to install the required dependencies.)grpcssl_channel_credentialssslOpenSSLrcreate_default_context get_ca_certsload_certificate FILETYPE_ASN1dump_certificate FILETYPE_PEMjoin ImportError Exception) cert_via_opensslr"r ssl_context certs_derx certs_x509 certs_pem certs_byteses [/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_py/grpc/transport.pyget_ssl_credentialsr6s ++--"002 ,,,> PYZ1f--f.B.BAFZ ZNXYV,,V-@-@!DY Yhhy) ++K88 [Y  Q  s50C#B<+C1#C'C< C C  CC SiftChannelConfigc"|jdd}|jdd}|s t||St|}t|}t |d|}t j |||}t||}t j|g|S)a Returns an intercepted channel that is meant to be used across all services that make RPCs to Sift's API. It is highly encouraged to use this within a with-block for correct resource clean-up. Should an RPC fail for a reason that isn't explicitly controlled by Sift, `SiftChannel` will automatically leverage gRPC's retry mechanism to try and recover until the max-attempts are exceeded, after which the underlying exception will be raised. use_sslTr-Furi) get_use_insecure_sift_channelr6_compute_channel_options _clean_urir secure_channel_compute_sift_interceptorsintercept_channel) configmetadatar9r- credentialsoptionsapi_urichannel interceptorss r5use_sift_channelrI6sjjD)Gzz"4e< )&(;;%&67K&v.G0G!!';@G-fh?L  ! !' 9L 99rc |jdd}|jdd}|s t||Stjt |d|t |t |t||S)z Like `use_sift_channel` but returns a channel meant to be used within the context of an async runtime when asynchonous I/O is required. r9Tr-Fr:)targetrDrErH)r; _use_insecure_sift_async_channelgrpc_aior?r>r6r= _compute_sift_async_interceptors)rBrCr9r-s r5use_sift_async_channelrOPsrjjD)Gzz"4e< /AA  " "&-1'(89(05fhG  rct|}t|dd}tj||}t ||}tj |g|S)' FOR DEVELOPMENT PURPOSES ONLY r:F)r=r>r insecure_channelr@rA)rBrCrErFrGrHs r5r<r<esR 'v.G.G##GW5G-fh?L  ! !' 9L 99rcrtjt|ddt|t ||S)rQr:F)rKrErH)rMrRr>r=rNrBrCs r5rLrLrs7  $ $&-/(05fhG rct||gS)z, Initialized all interceptors here. )_metadata_interceptorrTs r5r@r@s fh/ rct||gSN)_metadata_async_interceptorrTs r5rNrNs $FH5 rcDddtjjfdtfg}|j dd}t |t r,tt|}|jt||S|r|jtt|S)z Initialize all [channel options](https://github.com/grpc/grpc/blob/v1.64.x/include/grpc/impl/channel_arg_names.h) here. )zgrpc.enable_retrieszgrpc.service_configzgrpc.secondary_user_agentenable_keepaliveT) rdefaultas_json_compute_user_agentr; isinstancedictr rextend _compute_keep_alive_channel_optsr)optsrEr\rBs r5r=r=s #  3 3 5 = = ?@ %&9&;< Gxx 2D9"D)o'787?@ N 78PQR Nrc|d}dd|fg}|r+|jD]\}}|j||ft|S)z% Any new metadata goes here. apikey authorizationBearer )itemsappendrrBrCrfmdkeyvals r5rVrVs\ H F$x&89:B ( "HC IIsCj ! " r ""rc|d}dd|fg}|r+|jD]\}}|j||ft|S)z; Any new metadata goes here for unary-unary calls. rfrgrh)rirjrrks r5rYrYs\ H F$x&89:B ( "HC IIsCj ! " $B ''rcd|vsd|vrt|}|jS|rd|nd|}t|}|jS)z This will automatically transform the URI to an acceptable form regardless of whether or not users included the scheme in the URL or included trailing slashes. zhttp://zhttps://)rnetloc)r:r9parsedfull_uri parsed_ress r5r>r>sR C:,&sm}}#*#'#H&x0J   rc> dtdS#t$rYywxYw)Nzsift_stack_py/ sift_stack_pyz sift-stack-py)rrrr5r_r_s, 89:: s  c6d|dfd|dfd|dfd|dfgS) Nzgrpc.keepalive_time_mskeepalive_time_mszgrpc.keepalive_timeout_mskeepalive_timeout_msz!grpc.http2.max_pings_without_datamax_pings_without_dataz#grpc.keepalive_permit_without_callskeepalive_permit_without_callsrw)rBs r5rcrcsD !6*=#>? $f-C&DE ,f5M.NO .7W0XY  rcDeZdZUdZded<ded<ded<ded<ded <y ) r7a Config class used to instantiate a `SiftChannel` via `use_sift_channel`. - `uri`: The URI of Sift's gRPC API. The scheme portion of the URI i.e. `https://` should be ommitted. - `apikey`: User-generated API key generated via the Sift application. - `enable_keepalive`: Enabled by default, but can be disabled by passing in `False`. HTTP/2 keep-alive prevents connections from being terminated during idle periods. A custom `sift_py.grpc.keepalive.KeepaliveConfig` may also be provided. - `use_ssl`: INTERNAL USE. Meant to be used for local development. - `cert_via_openssl`: Enable this if you want to use OpenSSL to load the certificates. Run `pip install sift-stack-py[openssl]` to install the dependencies required to use this option. This works around this issue with grpc loading SSL certificates: https://github.com/grpc/grpc/issues/29682. Default is False. strr:rfz)NotRequired[Union[bool, KeepaliveConfig]]r\zNotRequired[bool]r9r-N)__name__ __module__ __qualname____doc____annotations__rwrr5r7r7s%  H K?? ''r)r-boolreturnzgrpc.ChannelCredentialsrX)rBr7rCOptional[Dict[str, Any]]rr)rBr7rCrrr)rBr7rCrrzList[ClientInterceptor])rBr7rCrrz List[grpc_aio.ClientInterceptor])rdr7rzList[Tuple[str, Any]])rBr7rCrrr)rBr7rCrrr)r:r~r9rrr~)rr~)rBrrzList[Tuple[str, int]])9r __future__rimportlib.metadatarrtypingrrrr r r r r urllib.parserrr grpc.aioaiorMtyping_extensionsrr%sift_py.grpc._async_interceptors.baser)sift_py.grpc._async_interceptors.metadatarsift_py.grpc._interceptors.baser#sift_py.grpc._interceptors.metadatarrsift_py.grpc._retryrsift_py.grpc.keepaliverrChannelrrrr6rIrOr<rLr@rNr=rVrYr>r_rcr7rwrr5rs #<KKK. 4HN=M+L Y%&..).6EI: :)A::6EI )A,EI :  :)A : :EI   )A  EI )AEI )A%0EI #  #)A # #"EI (  ()A ( ( ( (r