SSL certificates

Communication between daffi applications can be protected with SSL certificate and key.

For this example consider to use following script in order to generate self signed certificates for localhost IPV6

#!/bin/bash
# Generate self-signed certificates

set -e

IP="::"

openssl req -x509 -newkey rsa:4096 -sha256 -days 3650 -nodes \
  -keyout key.pem -out cert.pem -subj "/CN=example.com" \
  -addext "subjectAltName=DNS:example.com,DNS:www.example.net,IP:${IP}"

As the result you should see cert.pem and key.pem files created in directory where script was executed.

class based approachdecorator based approach

calculator_service.py content:

import logging
from daffi import Global
from daffi.registry import Callback

logging.basicConfig(level=logging.INFO)


class CalculatorService(Callback):
    auto_init = True

    def calculate_sum(self, *numbers):
        return sum(numbers)


if __name__ == '__main__':
    Global(init_controller=True, host="localhost", port=8888, ssl_certificate="cert.pem", ssl_key="key.pem").join()

calculator_client.py content:

import logging
from daffi import Global
from daffi.registry import Fetcher

logging.basicConfig(level=logging.INFO)


class CalculatorClient(Fetcher):

    def calculate_sum(self, *numbers):
        """
        Note: functions without a body are treated as proxies for remote callbacks.
        All arguments provided to this function will be sent to the remote service as-is.
        """
        pass


if __name__ == '__main__':
    g = Global(host="localhost", port=8888, ssl_certificate="cert.pem", ssl_key="key.pem")

    calc_client = CalculatorClient()
    result = calc_client.calculate_sum(1, 2)
    print(result)

    result = calc_client.calculate_sum(10, 20, 30)
    print(result)

    g.stop()

Execute in two separate terminals:

python3 calculator_service.py
python3 calculator_client.py

calculator_service.py content:

import logging
from daffi import Global
from daffi.decorators import callback

logging.basicConfig(level=logging.INFO)


@callback
def calculate_sum(*numbers):
    return sum(numbers)


if __name__ == '__main__':
    Global(init_controller=True, host="localhost", port=8888, ssl_certificate="cert.pem", ssl_key="key.pem").join()

calculator_client.py content:

import logging
from daffi import Global
from daffi.decorators import fetcher

logging.basicConfig(level=logging.INFO)


@fetcher
def calculate_sum(*numbers):
    """
    Note: functions without a body are treated as proxies for remote callbacks.
    All arguments provided to this function will be sent to the remote service as-is.
    """
    pass


if __name__ == '__main__':
    g = Global(host="localhost", port=8888, ssl_certificate="cert.pem", ssl_key="key.pem")

    result = calculate_sum(1, 2)
    print(result)

    result = calculate_sum(10, 20, 30)
    print(result)

    g.stop()

Execute in two separate terminals:

python3 calculator_service.py
python3 calculator_client.py

Note

To use UNIX socket instead of TCP for communication, you should remove the host and port parameters from the initialization of the Global object, and optionally include the unix_sock_path parameter.