Python client library for OOCSI. OOCSI is a multi-platform communication framework that allows for easy messaging between clients. OOCSI is light-weight, message-oriented, allows for point-to-point messaging and broadcasting to channels (or topics). The Python client library allows to connect from Python to an OOCSI server and to communicate with other OOCSI clients, on Python or on different platforms such as plain Java, Processing, Android, Websocket or Arduino ESP.
Installing the OOCSI library is very straight-forward for Python:
pip install oocsiTo use OOCSI on Python, we first need to connect to OOCSI. Then we can send and receive messages. This example follows the channel send and receive example that can be found in the examples folder.
The first step is to connect to a OOCSI server, either running on the local machine (see here how to do that) or on a publicly accessible server. To connect, you will need the server address and also create a unique handle for this client. This handle will be used to identify the client when other clients send messages to it. A handle is composed of ASCII characters, but cannot contain spaces.
from oocsi import OOCSI
# connect to OOCSI running on the local machine ('localhost')
oocsi = OOCSI('Alice', 'localhost')
# connect to OOCSI running on a webserver
oocsi = OOCSI('Alice', 'oocsi.example.com')
# connect to OOCSI running on a webserver with a custom port (4545)
oocsi = OOCSI('Alice', 'oocsi.example.com', 4545)
# connect to OOCSI running on the local machine ('localhost') using a newly-generated handle (e.g. OOCSIClient_<unique id>)
oocsi = OOCSI()
# print the handle that was generated
print(oocsi.handle)In case the connection fails, the error will be printed on the Python console. The most common reason that a client fails connecting is because the client's chosen handle is already active on the server. Choosing a slightly different handle will then solve the problem.
Now that the client Alice is connected to OOCSI, the client can send messages to others in the network. The recipients of messages can be either handles of other clients (direct communication, point-to-point) or the name of a channel (broadcasting).
# send a message to client Bob with data (as a Dict)
oocsi.send('Bob', {'color': 120})
# send a message to channel coloChannel with data (as a Dict)
oocsi.send('colorChannel', {'color': 120})Messages from OOCSI that are sent directly to thsi client (using the handle Alice in the example), can be received using a callback that is provided when connecting. In the example below, all direct messages to Alice are received through the callback handleDirectMessage. This callback method receives the sender of the message, the recipient (channel name) and the event data as arguments.
from oocsi import OOCSI
def handleDirectMessage(sender, recipient, event):
print(event['color'])
# connect and provide callback for messages sent directly to Alice
oocsi = OOCSI('Alice', 'localhost', callback=handleDirectMessage)Messages from OOCSI channels can be received by subscribing to channels callbacks. In the example below, the client Alice subscribes to a channel colorchannel and receives events to this channel via the callback handleColorEvent. This callback method receives the sender of the message, the recipient (channel name) and the event data as arguments. The recipient is added to allow for distinguishing messages when subscribing to multiple channels with the same callback.
from oocsi import OOCSI
def handleColorEvent(sender, recipient, event):
print(event['color'])
# connect to OOCSI running on the local machine ('localhost')
oocsi = OOCSI()
# subscribe to channel testchannel with a callback handleColorEvent
oocsi.subscribe('testchannel', handleColorEvent)Clients can send messages to others in the network also in a synchronous way. That means, that the client sends a message to another client and waits for a corresponding reply message. This is useful for queries for data or remote processing of data by another client. This mechanism is shown in the call-response example.
OOCSI can work with variables that are automatically synchronized over channels in the OOCSI network. A variable is created by a client for a channel on a key of a message. Whenever a message with that key is received over the channel the variable is locally updated, and whenever the local variable is set by the client, it will send out the new value on the given channel.
from oocsi import OOCSI
# connect to OOCSI running on the local machine ('localhost')
oocsi = OOCSI()
# subscribe to channel testchannel with a callback handleColorEvent
color = oocsi.variable('colorchannel', 'color')
# set the variable
color.set(255)
# get the variable's value
color.get()This mechanism is shown more detail in the variables example. In the OOCSI Python client, variables do not have different types such as int, float or string. Therefore, checking the content of the variable might be advisable before using it.
You can configure how this library prints its log messages on the Python console. For example, if you are using a log framework, or simply because you would like a different log format (including a timestamp and other information).
from oocsi import OOCSI
# use this function to change how the log output is printed
# you can also switch logging off by providing a function that does not do anything
def logFunction(msg):
print('custom log: ' + msg)
# initialize OOCSI connection with a custom logger
oocsi = OOCSI('python_custom_logger', 'localhost', logger=logFunction)This is also available in the customLogger example.
The OOCSI client will try to reconnect to the OOCSI server if the connection drops for some reason. That's usually the expected behavior, but sometimes you want to reconnect only for several times and then let the OOCSI client fail, so can try something else or alert a user about the connection issue. No problem, just configure the OOCSI with a maximum number of reconnection attempts:
from oocsi import OOCSI
# initialize OOCSI connection with a maximum number of reconnection attempts, here 10
oocsi = OOCSI('python_custom_reconnection', 'localhost', maxReconnectionAttempts=10)This is also available in the customReconnection example.
At the moment, a subset of functionality that is available in the OOCSI Java implementation is implemented for Python. Beyond the basic communication framework, higher level functions like synchronization, negotiation etc are yet to be implemented.
Tbd.
This project is licensed under the MIT License - see the LICENSE file for details