Distributed State Network

A Python framework for building distributed applications where nodes automatically share state without explicit data requests.

Why DSN?

Traditional distributed systems require constant polling or complex pub/sub mechanisms to share state between nodes. DSN solves this by providing:

• Automatic state synchronization - Changes propagate instantly across the network
• No single point of failure - Every node maintains its own state
• Simple key-value interface - Read any node's data as easily as local variables
• Complete Security - Triple-layer encryption protects your network

Perfect for building distributed monitoring systems, IoT networks, or any application where multiple machines need to share state efficiently.

Installation

pip install distributed-state-network

Quick Start

1. Create Your First Node

The simplest DSN network is a single node:

from distributed_state_network import DSNodeServer, DSNodeConfig

# Start a node
node = DSNodeServer.start(DSNodeConfig(
    node_id="my_first_node",
    port=8000,
    bootstrap_nodes=[]  # Empty for the first node
))

# Write some data
node.node.update_data("status", "online")
node.node.update_data("temperature", "72.5")

How It Works

DSN creates a peer-to-peer network where each node maintains its own state database:

Key concepts:

• Each node owns its state and is the only one who can modify it
• State changes are automatically broadcast to all connected nodes
• Any node can read any other node's state instantly
• All communication is encrypted with AES

Example: Distributed Temperature Monitoring

Create a network of temperature sensors that share readings:

# On each Raspberry Pi with a sensor:
sensor_node = DSNodeServer.start(DSNodeConfig(
    node_id=f"sensor_{location}",
    port=8000,
    bootstrap_nodes=[{"address": "coordinator.local", "port": 8000}]
))

# Continuously update temperature
while True:
    temp = read_temperature_sensor()
    sensor_node.node.update_data("temperature", str(temp))
    sensor_node.node.update_data("timestamp", str(time.time()))
    time.sleep(60)

On the monitoring station:

for node_id in monitor.node.peers():
    if node_id.startswith("sensor_"):
        temp = monitor.node.read_data(node_id, "temperature")
        print(f"{node_id}: {temp}°F")

Documentation

• Usage Examples
• Configuration Class
• Server Class
• Protocol Class
• Protocol

API Reference

• DSNodeServer
• DSNode
• DSNodeConfig