aiosfstream
aiosfstream copied to clipboard
Salesforce Streaming API client for asyncio
The documentation for disabling the `connection_timeout` functionality incorrectly says to use `None`, which fails MyPy type checking. According to the `aiocometd` source code, this value must be an Integer or...
I have the below code that is working if the Pgsql table is empty. But if it pulls an existing replay id, it is throwing the below exception. Thanks for...
JWT Authentication is a common scenario for Server to server applications. It will be nice to have this supported built-in, otherwise developers will need to do it in their application....
Is it possible to use the session token that I have obtained using a different mechanism (cannot obtain it via the username and password because of organization having SSO) to...
I've noticed when I `KeyboardInterrupt` I can't get the client to gracefully exit when using this setup: ``` await client.open() # subscribe to topics await client.subscribe("/topic/my-topic") # listen for incoming...
Related to https://github.com/robertmrk/aiocometd/issues/13 in the aiocometd dependency. The loop parameter was removed. See last bullet of https://docs.python.org/3/whatsnew/3.10.html#removed. > Traceback (most recent call last): > ... > File "/external/aiosfstream/aiosfstream/client.py", line 149,...
Needed proxy support, also for authentication step. Added environment proxy setting support as described here: https://docs.aiohttp.org/en/stable/client_advanced.html?highlight=proxy#proxy-support
I've been seeing errors when connecting to Salesforce for 'client identifier invalid'. The errors happen sporadically, so it's not something on our end, it's Salesforce. I found [some posts](https://blog.jeffdouglas.com/2012/12/21/oauth-dance-client-identifier-invalid/) that...
It would be great to edit the variables TOKEN_URL, COMETD_PATH and API_VERSION. I had to clone the repo and change this values. BTW. great job. Very helpful.
We need to be able to provide "verify=False" to ignore SSL certificate and "cert= path_to_cert_bundle" to provide a custom certificate authority bundle while creating the connection with SalesforceStreamingClient. By default...