cable_club.network package

Submodules

• cable_club.network.states module
  • Connected
    • Connected.handle()
    • Connected.peer
  • Connecting
    • Connecting.handle()
  • Finding
    • Finding.handle()
    • Finding.write()
  • State
    • State.handle()
  • public_id()

Module contents

Manage connections.

class cable_club.network.Client(address: tuple[int, int])

Bases: object

Represent a client.

class cable_club.network.Server(config: Config)

Bases: object

Model the server’s logic.

connect(s_connecting: socket, s_finding: socket) → None

Tell two clients about each other’s existence.

disconnect(socket: socket, reason: str = 'unknown error') → None

Close a client’s connection.

handle_error(socket: socket) → None

Handle a single error socket.

handle_errors(sockets: list[socket]) → None

Handle all error sockets.

maybe_reload_rules() → None

Check the rules folder for updates.

This happens every config.rules_refresh_rate seconds (approx).

read_all(sockets: list[socket]) → None

Read from all sockets.

read_from(socket: socket) → None

Read from a single socket.

run() → None

Execute the server’s logic (blocking busy loop).

select() → tuple[list[socket], list[socket], list[socket]]

Thin wrapper on top of select.

Collects all readers and writers and hands them off to select.select().

write_server_rules(writer: Writer) → None

Dump server’s rules into a writer.

write_to(socket: socket) → None

Write to a single socket.

write_to_all(sockets: list[socket]) → None

Write to all sockets.