o gq@s.dZddlmZdZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZddlmZddlmZddlmZdd lmZmZddlZd d lmZd d l m!Z!d d l"m#Z#d dl$m%Z%d dl&m'Z'd dl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.e/e0Z1GdddZ2GdddZ3dS)z1Core classes and exceptions for Simple-Salesforce)datetimez59.0N) AnyCallableDictIOIteratorListMappingMutableMappingOptionalTupleUnioncast) OrderedDict)partial)Path)urljoinurlparse) SFBulkHandler)SFBulk2Handler)SalesforceGeneralError)SalesforceLogin)SfdcMetadataApi)Headers PerAppUsageProxiesUsagedate_to_iso8601exception_handlerc*seZdZdZdZeZdddddddedddddddddefdee dee dee dee dee dee d ee d ee d ee d ee j d ee dee dee dee dee dee dee e gefdee eeeefgeff$ddZedefddZdaddZdaddZdedeefdd Zdeefd!d"Zd#e deeed$fffd%d& Zd'e de deefd(d)Z  *dbd+e d,eee efd-e dedeef d.d/Z  *dbd+e d,eee efd-e deefd0d1Z!d2e defd3d4Z"d2e defd5d6Z#dedefd7d8Z$ 9dcd:e d;ededefde d?ed;ededef d@dAZ& 9dcd:e d;edede'efdBdCZ( 9dcd:e d;ededee effdDdEZ) * dedFe d-e dGeee efdedef dHdIZ* * dedFe d-e dGeee efdedef dJdKZ+ L M Ndfd-e dOe d#e dPe,dQe,dede j-fdRdSZ.e/dTe de0e ee1e2fffdUdVZ3dWee e4e5fdXededee ee ffdYdZZ6d[e dedee eee e7e e ffffd\d]Z8d^e j-defd_d`Z9Z:S)g SalesforcezSalesforce Instance An instance of Salesforce is a handy way to wrap a Salesforce session for easy use of the Salesforce REST API. Nusernamepasswordsecurity_token session_idinstance instance_urlorganizationIdversionproxiessession client_iddomain consumer_keyconsumer_secretprivatekey_file privatekey parse_floatobject_pairs_hookc Cs*| durd} ||_| |_| pt|_|jj|_d|_| dur/| s)| |j_|_ntd| t dd|||fDrUd|_ t t |j||||j|j| |jd |_| nt dd||p]|fDrd |_ tt||_|durt|j|_t|j}|d vr|jd |7_ntt||_|nt d d|||fDrd |_ t t |j||||j|j| |jd |_| ntt dd||| |fDrd|_ t t |j||| ||j|jd|_| nOt dd|| |p|fDrd|_ t t |j||| |||j|jd |_| n't dd| || fDr*d|_ t t |j| ||j|jd|_| ntdd|jd|_dd|jdd|_d|jd|jd|_d|jd |_d|jd!|jd|_d|jd|jd"|_d|jd#|jd|_|jd$|_d|jd%|_i|_ ||_!||_"d|_#dS)&aeInitialize the instance with the given parameters. Available kwargs Password Authentication: * username -- the Salesforce username to use for authentication * password -- the password for the username * security_token -- the security token for the username * domain -- The domain to using for connecting to Salesforce. Use common domains, such as 'login' or 'test', or Salesforce My domain. If not used, will default to 'login'. OAuth 2.0 Connected App Token Authentication: * consumer_key -- the consumer key generated for the user * consumer_secret -- the consumer secret generated for the user OAuth 2.0 JWT Bearer Token Authentication: * consumer_key -- the consumer key generated for the user Then either * privatekey_file -- the path to the private key file used for signing the JWT token OR * privatekey -- the private key to use for signing the JWT token Direct Session and Instance Access: * session_id -- Access token for this session Then either * instance -- Domain of your Salesforce instance, i.e. `na1.salesforce.com` OR * instance_url -- Full URL of your instance i.e. `https://na1.salesforce.com Universal Kwargs: * version -- the version of the Salesforce API to use, for example `29.0` * proxies -- the optional map of scheme to proxy server * session -- Custom requests session, created in calling code. This enables the use of requests Session features not otherwise exposed by simple_salesforce. * parse_float -- Function to parse float values with. Is passed along to https://docs.python.org/3/library/json.html#json.load * object_pairs_hook -- Function to parse ordered list of pairs in json. To use python 'dict' change it to None or dict. NloginzFProxies must be defined on custom session object, ignoring proxies: %scs|]}|duVqdSN.0argr6r6N/home/ubuntu/webapp/venv/lib/python3.10/site-packages/simple_salesforce/api.py z&Salesforce.__init__..r")r*r!r"r# sf_versionr)r+r,csr4r5r6r7r6r6r:r;r<direct)Ni:csr4r5r6r7r6r6r:r;r<ipfilter)r*r!r"r'r=r)r+r,csr4r5r6r7r6r6r:r;r<)r*r!r"r-r.r)r,csr4r5r6r7r6r6r:r;r<z jwt-bearer)r*r!r&r-r/r0r)r,csr4r5r6r7r6r6r:r;r<zclient-credentials)r*r-r.r)r,z;You must provide login information or an instance and tokenhttps://z.salesforce.comapplication/jsonBearer 1 Content-Type Authorizationz X-PrettyPrint/services/data/v/z/services/apexrest/z/services/async/z/jobs/z/services/Soap/m/ztooling/z/services/oauth2/)$r=r,requestsSessionr*r)_salesforce_login_partialloggerwarningall auth_typerr_refresh_sessionrstrr$rhostname sf_instanceport_generate_headers TypeError auth_siteheadersbase_urlapex_urlbulk_url bulk2_url metadata_url tooling_url oauth2_url api_usage _parse_float_object_pairs_hook_mdapi)selfr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2rUr6r6r:__init__)s H                zSalesforce.__init__returncCs.|jst|j|j|j|j|j|jd|_|jS)z3Utility to interact with metadata api functionality)r*r$r%r^ api_versionrY)rdrr*r$rTr^r=rYrer6r6r:mdapiszSalesforce.mdapicCsdd|jdd|_dS)z7Utility to generate headers when refreshing the sessionrBrCrDrEN)r$rYrir6r6r:rV$s zSalesforce._generate_headerscCs.|jdur td|\|_|_|dS)z+Utility to refresh the session when expiredNzRThe simple_salesforce session can not refreshed if a session id has been provided.)rL RuntimeErrorr$rTrVrir6r6r:rQ,s  zSalesforce._refresh_sessionkwargscKs@|jd}|jd|fddi|}||}t|dkrdS|S)zDescribes all available objects Arguments: * keyword arguments supported by requests.request (e.g. json, timeout) sobjectsGETnamedescriberNrZ_call_salesforceparse_result_to_jsonlen)rerlurlresult json_resultr6r6r:rp6s   zSalesforce.describecCs0d}|jr|ddddigdd}|S)z9After connection returns is the organization in a sandboxNz*SELECT IsSandbox FROM Organization LIMIT 1records IsSandboxr)r$ query_allget)re is_sandboxr6r6r:r|JszSalesforce.is_sandboxroSFTypec sv|dr t|S|dkrt|j|j|j|jS|dkr)t|j|j |j|jSt ||j|j |j |j|j||j dS)aReturns an `SFType` instance for the given Salesforce object type (given in `name`). The magic part of the SalesforceAPI, this function translates calls such as `salesforce_api_instance.Lead.metadata()` into fully constituted `SFType` instances to make a nice Python API wrapper for the REST API. Arguments: * name -- the name of a Salesforce object type, e.g. Lead or Contact __bulkbulk2)r=r)r* salesforcer2) startswithsuper __getattr__rr$r\r)r*rr]r}rTr=rc)rero __class__r6r:rYs0  zSalesforce.__getattr__usercCsd|jd|d}d|i}|jd|t|d}|jdkrdS|jdkr-t||jd |j||S) a#Sets the password of a user salesforce dev documentation link: https://www.salesforce.com/us/developer/docs/api_rest/Content /dome_sobject_user_password.htm Arguments: * user: the userID of the user to set * password: the new password zsobjects/User/z /password NewPasswordPOST)dataNUser)rZrrjsondumps status_codercontentrs)rerr"ruparamsrvr6r6r: set_passwords     zSalesforce.set_passwordrnpathrmethodcKsB|j|}|j||f||d|}||}t|dkrdS|S)alAllows you to make a direct REST call if you know the path Arguments: * path: The path of the request Example: sobjects/User/ABC123/password' * params: dict of parameters to pass to the path * method: HTTP request method, default GET * other arguments supported by requests.request (e.g. json, timeout) rorrNrq)rerrrrlrurvrwr6r6r:restfuls   zSalesforce.restfulcCs^|j|}|j||||d}|jd}|dur!d|vr!||nd}|r-t|dkr-dS|S)apAllows you to make a request to OAuth endpoints if you know the path Arguments: * path: The path of the request Example: /services/oauth2/token' * params: dict of parameters to pass to the path * method: HTTP request method, default GET * other arguments supported by requests.request (e.g. json, timeout) rrFNrr)r`rrrYr{rsrt)rerrrrurv content_typerwr6r6r:oauth2s   zSalesforce.oauth2searchcCsB|jd}d|i}|jd|d|d}||}t|dkrdS|S)zReturns the result of a Salesforce search as a dict decoded from the Salesforce response JSON payload. Arguments: * search -- the fully formatted SOSL search string, e.g. `FIND {Waldo}` zsearch/qrnrrrNrq)rerrurrvrwr6r6r:rs   zSalesforce.searchcCsd|d}||S)aJReturns the result of a Salesforce search as a dict decoded from the Salesforce response JSON payload. Arguments: * search -- the non-SOSL search string, e.g. `Waldo`. This search string will be wrapped to read `FIND {Waldo}` before being sent to Salesforce zFIND {})r)rer search_stringr6r6r: quick_searchs zSalesforce.quick_searchcKs:|jd}|jd|fi|}|jdkrt|||S)zWReturn the result of a Salesforce request to list Organization limits. zlimits/rnr)rZrrrrrs)rerlrurvr6r6r:limitss   zSalesforce.limitsFqueryinclude_deletedcKs>|j|rdnd}d|i}|jd|fd|d|}||S)a^Return the result of a Salesforce SOQL query as a dict decoded from the Salesforce response JSON payload. Arguments: * query -- the SOQL query to send to Salesforce, e.g. SELECT Id FROM Lead WHERE Email = "waldo@somewhere.com" * include_deleted -- True if deleted records should be included z queryAll/zquery/rrnrr)rZrrrs)rerrrlrurrvr6r6r:r#s  zSalesforce.querynext_records_identifieridentifier_is_urlcKsX|r d|j|}n|rdnd}|j|d|}|jd|fddi|}||S)ajRetrieves more results from a query that returned more results than the batch maximum. Returns a dict decoded from the Salesforce response JSON payload. Arguments: * next_records_identifier -- either the Id of the next Salesforce object in the result, or a URL to the next record in the result. * identifier_is_url -- True if `next_records_identifier` should be treated as a URL, False if `next_records_identifier` should be treated as an Id. * include_deleted -- True if the `next_records_identifier` refers to a query that includes deleted records. Only used if `identifier_is_url` is False rAqueryAllrrIrnro query_more)rTrZrrrs)rerrrrlruendpointrvr6r6r:r>s  zSalesforce.query_morecksR|j|fd|i|} |dEdH|ds&|j|dfddi|}ndSq )a;This is a lazy alternative to `query_all` - it does not construct the whole result set into one container, but returns objects from each page it retrieves from the API. Since `query_all` has always been eagerly executed, we reimplemented it using `query_all_iter`, only materializing the returned iterator to maintain backwards compatibility. The one big difference from `query_all` (apart from being lazy) is that we don't return a dictionary with `totalSize` and `done` here, we only return the records in an iterator. Arguments * query -- the SOQL query to send to Salesforce, e.g. SELECT Id FROM Lead WHERE Email = "waldo@somewhere.com" * include_deleted -- True if the query should include deleted records. rTrxNdonenextRecordsUrlr)rr)rerrrlrvr6r6r:query_all_iterbs  zSalesforce.query_all_itercKs.|j|fd|i|}t|}|t|ddS)aReturns the full set of results for the `query`. This is a convenience wrapper around `query(...)` and `query_more(...)`. The returned dict is the decoded JSON payload from the final call to Salesforce, but with the `totalSize` field representing the full number of results retrieved and the `records` list representing the full list of records retrieved. Arguments * query -- the SOQL query to send to Salesforce, e.g. SELECT Id FROM Lead WHERE Email = "waldo@somewhere.com" * include_deleted -- True if the query should include deleted records. rT)rx totalSizer)rlistrt)rerrrlrx all_recordsr6r6r:rzs zSalesforce.query_allactionrcK`|dur t|nd}|j||j|fd|d|}z|}W|Sty/|j}Y|Sw)aMMakes an HTTP request to an TOOLING REST endpoint Arguments: * action -- The REST endpoint for the request. * method -- HTTP method for the request (default GET) * data -- A dict of parameters to send in a POST / PUT request * kwargs -- Additional kwargs to pass to `requests.request` Ntoolingexecuteror)rrrrr_ Exceptiontextrerrrrl json_datarvresponse_contentr6r6r:r"  zSalesforce.toolingexecutecKr)aJMakes an HTTP request to an APEX REST endpoint Arguments: * action -- The REST endpoint for the request. * method -- HTTP method for the request (default GET) * data -- A dict of parameters to send in a POST / PUT request * kwargs -- Additional kwargs to pass to `requests.request` N apexecuter)rrrrr[rrrr6r6r:rrzSalesforce.apexecuterruretries max_retriesc Ks|j}|di}|||jj||fd|i|} |jdurR| jdkrR| d} | ddkrR| |d7}||krEt | |d|j |||fd |i|S| jd kr]t | |d| j d } | rk| | |_| S) zkUtility method for performing HTTP call to Salesforce. Returns a `requests.result` object. rYNr errorCodeINVALID_SESSION_IDrror,Sforce-Limit-Info)rYcopypopupdater*requestrLrrrQrrrr{parse_api_usagera) rerrurorrrlrYadditional_headersrv error_detailssforce_limit_infor6r6r:rrsP         zSalesforce._call_salesforcercCsi}td|}d}t||}|r*|r*|}tt|dt|dd|d<|rG|rG|}tt|dt|d|dd|d <|S) aFparse API usage and limits out of the Sforce-Limit-Info header Arguments: * sforce_limit_info: The value of response header 'Sforce-Limit-Info' Example 1: 'api-usage=18/5000' Example 2: 'api-usage=25/5000; per-app-api-usage=17/250(appName=sample-connected-app)' z)[^-]?api-usage=(?P\d+)/(?P\d+)z>.+per-app-api-usage=(?P\d+)/(?P\d+)\(appName=(?P.+)\)rr)usedtotalz api-usage)rrrozper-app-api-usage)rematchgroupsrintr)rrvrapauper_app_api_usagerr6r6r:rs*        zSalesforce.parse_api_usagezipfilesandboxcKs(|jj||fi|\}}||d}|S)aDeploy using the Salesforce Metadata API. Wrapper for SfdcMetaDataApi.deploy(...). Arguments: * zipfile: a .zip archive to deploy to an org, given as ( "path/to/zipfile.zip") * options: salesforce DeployOptions in .json format. (https://developer.salesforce.com/docs/atlas.en-us.api_meta.meta /api_meta/meta_deploy.htm) Returns a process id and state for this deployment. )asyncIdstate)rjdeploy)rerrrlrrrvr6r6r:r@s zSalesforce.deployrcKs.|jj|fi|\}}}}||||d}|S)a;Check on the progress of a file-based deployment via Salesforce Metadata API. Wrapper for SfdcMetaDataApi.check_deploy_status(...). Arguments: * asyncId: deployment async process ID, returned by Salesforce.deploy() Returns status of the deployment the asyncId given. )r state_detaildeployment_detailunit_test_detail)rjcheck_deploy_status)rerrlrrrrresultsr6r6r:checkDeployStatus\s  zSalesforce.checkDeployStatusrvcC|j|j|jdSz""Parse json from a Response object)r2r1rrcrbrervr6r6r:rstzSalesforce.parse_result_to_json)rgN)Nrn)F)FF)rnN)rrr);__name__ __module__ __qualname____doc__rbrrcDEFAULT_API_VERSIONr rRrrJrKrrrr rfpropertyrrjrVrQrpboolr|r rrrrrrrrrrrrrrrzrrrResponserr staticmethodr rrrrbytesrr rrs __classcell__r6r6rr:r s      o    - ' #       ' '  ! # $ 6 %  r c@s&eZdZdZdZeZeddddefdededede ede e de e j d e e d e eegefd eeeeefgeffd d ZedefddZ dIde edefddZ dIde edefddZ dIdede edefddZ dIdede ededefddZ dIdedede ededef ddZ dId eeefde edefd!d"Z # dJded eeefd$ede edef d%d&Z # dJded eeefd$ede edef d'd(Z # dJded$ede ede e!e j"ffd)d*Z# dId+e$d,e$de edefd-d.Z% dId+e$d,e$de edefd/d0Z& 1 2dKd3ed4ed5e!d6e!dede j"f d7d8Z'd9e j"d:ede e!e j"ffd;d<Z(d=e j"defd>d?Z) @ dLdAedBede edede j"f dCdDZ* @  #dMdedAedBede ed$edede e!e j"ffdEdFZ+ @  dNdedBed e ede edede,f dGdHZ-dS)Or}z*An interface to a specific type of SObjectN object_namer$rTr=r)r*rr1r2c Cs||dur |dur td||_||_||_|pt|_||_| |_|s,|dur,||j_ i|_ d|d|d|d|_ dS)aInitialize the instance with the given parameters. Arguments: * object_name -- the name of the type of SObject this represents, e.g. `Lead` or `Contact` * session_id -- the session ID for authenticating to Salesforce * sf_instance -- the domain of the instance of Salesforce to use * sf_version -- the version of the Salesforce API to use * proxies -- the optional map of scheme to proxy server * session -- Custom requests session, created in calling code. This enables the use of requests Session features not otherwise exposed by simple_salesforce. * parse_float -- Function to parse float values with. Is passed along to https://docs.python.org/3/library/json.html#json.load * object_pairs_hook -- Function to parse ordered list of pairs in json. To use python 'dict' change it to None or dict. NzNThe argument session_id or salesforce must be specified to instanciate SFType.rArHz /sobjects/rI) rk _session_idrrorJrKr*rbrcr)rarZ) rerr$rTr=r)r*rr1r2r6r6r:rfs"" zSFType.__init__rgcCs|jdur |jjS|jS)zHelper to return the session idN)rr$rrir6r6r:r$s zSFType.session_idrYcCs|jd|j|d}||S)zReturns the result of a GET to `.../{object_name}/` as a dict decoded from the JSON payload returned by Salesforce. Arguments: * headers -- a dict with additional request headers. rn)rY)rrrZrsrerYrvr6r6r:metadatas  zSFType.metadatacCs"|jdt|jd|d}||S)zReturns the result of a GET to `.../{object_name}/describe` as a dict decoded from the JSON payload returned by Salesforce. Arguments: * headers -- a dict with additional request headers. rnrprrurYrrrrZrsrr6r6r:rps zSFType.describe record_idcCs,d|}|jdt|j||d}||S)aTReturns the layout of the object Returns the result of a GET to `.../{object_name}/describe/layouts/` as a dict decoded from the JSON payload returned by Salesforce. Arguments: * record_id -- the Id of the SObject to get * headers -- a dict with additional request headers. zdescribe/layouts/rnrr)rerrYcustom_url_partrvr6r6r:describe_layouts  zSFType.describe_layoutrlcKs*|jddt|j||d|}||S)aReturns the result of a GET to `.../{object_name}/{record_id}` as a dict decoded from the JSON payload returned by Salesforce. Arguments: * record_id -- the Id of the SObject to get * headers -- a dict with additional request headers. rnrNr6r)rerrYrlrvr6r6r:r{s   z SFType.getcustom_id_field custom_idcKs8t|j|d|}|jdd||d|}||S)aReturn an ``SFType`` by custom ID Returns the result of a GET to `.../{object_name}/{custom_id_field}/{custom_id}` as a dict decoded from the JSON payload returned by Salesforce. Arguments: * custom_id_field -- the API name of a custom field that was defined as an External ID * custom_id - the External ID value of the SObject to get * headers -- a dict with additional request headers. rIrnrNr6)rrZrrrs)rerrrYrl custom_urlrvr6r6r:get_by_custom_id s  zSFType.get_by_custom_idrcCs$|jd|jt||d}||S)afCreates a new SObject using a POST to `.../{object_name}/`. Returns a dict decoded from the JSON payload returned by Salesforce. Arguments: * data -- a dict of the data to create the SObject from. It will be JSON-encoded before being transmitted. * headers -- a dict with additional request headers. rrrurrY)rrrZrrrs)rerrYrvr6r6r:create(s  z SFType.createF raw_responsecC,|jdt|j|t||d}|||S)aCreates or updates an SObject using a PATCH to `.../{object_name}/{record_id}`. If `raw_response` is false (the default), returns the status code returned by Salesforce. Otherwise, return the `requests.Response` object. Arguments: * record_id -- an identifier for the SObject as described in the Salesforce documentation * data -- a dict of the data to create or update the SObject from. It will be JSON-encoded before being transmitted. * raw_response -- a boolean indicating whether to return the response directly, instead of the status code. * headers -- a dict with additional request headers. PATCHrrrrrZrr _raw_responsererrrrYrvr6r6r:upsert<sz SFType.upsertcCr)aUpdates an SObject using a PATCH to `.../{object_name}/{record_id}`. If `raw_response` is false (the default), returns the status code returned by Salesforce. Otherwise, return the `requests.Response` object. Arguments: * record_id -- the Id of the SObject to update * data -- a dict of the data to update the SObject from. It will be JSON-encoded before being transmitted. * raw_response -- a boolean indicating whether to return the response directly, instead of the status code. * headers -- a dict with additional request headers. rrrrr6r6r:r]sz SFType.updatecCs$|jdt|j||d}|||S)aDeletes an SObject using a DELETE to `.../{object_name}/{record_id}`. If `raw_response` is false (the default), returns the status code returned by Salesforce. Otherwise, return the `requests.Response` object. Arguments: * record_id -- the Id of the SObject to delete * raw_response -- a boolean indicating whether to return the response directly, instead of the status code. * headers -- a dict with additional request headers. DELETEr)rrrrZr)rerrrYrvr6r6r:delete}sz SFType.deletestartendcC:t|jdt|dt|}|jd||d}||S)a~Gets a list of deleted records Use the SObject Get Deleted resource to get a list of deleted records for the specified object. .../deleted/?start=2013-05-05T00:00:00+00:00&end=2013-05-10T00:00:00 +00:00 * start -- start datetime object * end -- end datetime object * headers -- a dict with additional request headers. zdeleted/?start=&end=rnrrrZrrrrsrerrrYrurvr6r6r:deleted  zSFType.deletedcCr)aGets a list of updated records Use the SObject Get Updated resource to get a list of updated (modified or added) records for the specified object. .../updated/?start=2014-03-20T00:00:00+00:00&end=2014-03-22T00:00:00 +00:00 * start -- start datetime object * end -- end datetime object * headers -- a dict with additional request headers. zupdated/?start=r rnrr r r6r6r:updatedr zSFType.updatedrrrrurrc Ksdd|jdd}|di}||pi|jj||fd|i|}|jr[|jjdur[|jdkr[|d} | d d kr[|j |d 7}||krQt ||j d |j ||fi|S|jd krft ||j |j d} | rtt| |_|S)zlUtility method for performing HTTP call to Salesforce. Returns a `requests.result` object. rBrCrDrErYNrrrrrrrr)r$rrr*rrrLrrrQrrorrrYr{r rra) rerrurrrlrYrrvrrr6r6r:rrsN         zSFType._call_salesforceresponse body_flagcCs|s|jS|S)zUtility method for processing the response and returning either the status code or the response object. Returns either an `int` or a `requests.Response` object. )r)rerrr6r6r:rs zSFType._raw_responservcCrrrrr6r6r:rsrzSFType.parse_result_to_jsonBody file_path base64_fieldcKsBi}tt|}|||<|jdd|j||d|}|S)z(Upload base64 encoded file to Salesforcer)rrurYrNr6)base64 b64encoder read_bytesdecoderrrZ)rerrrYrlrbodyrvr6r6r: upload_base64szSFType.upload_base64c KsPi}tt|}|||<|jddt|j|||d|} || |S)z,Updated base64 image from file to Salesforcer)rrurrYNr6) rrrrrrrrrZr) rerrrrYrrlrrrvr6r6r: update_base641s  zSFType.update_base64cKs2|jddt|j|d|||d|}|jS)zReturns binary stream of base64 object at specific path. Arguments: * path: The path of the request Example: sobjects/Attachment/ABC123/Body sobjects/ContentVersion/ABC123/VersionData rnrIrNr6)rrrrZr)rerrrrYrlrvr6r6r: get_base64Ks  zSFType.get_base64r5)FN)rr)rN)rNF)rNN).rrrrrbrrcrrRr rrJrKr rrrr rfrr$rrrprr{rrrrrrr rrrrr rrrrrsrrrrr6r6r6r:r}}s  8         %  #      7       r})4rrrrrloggingrtypingrrrrrrr r r r r r collectionsr functoolsrpathlibr urllib.parserrrJrrrr exceptionsrr3rrrutilrrrrrr getLoggerrrMr r}r6r6r6r:s8 8          c