feat: Implement py-peer of Universal Connectivity dApp

.github/workflows/generated-pr.yml

@@ -0,0 +1,14 @@
+name: Close Generated PRs
+
+on:
+  schedule:
+    - cron: '0 0 * * *'
+  workflow_dispatch:
+
+permissions:
+  issues: write
+  pull-requests: write
+
+jobs:
+  stale:
+    uses: ipdxco/unified-github-workflows/.github/workflows/reusable-generated-pr.yml@v1

.github/workflows/go-ci-config.json

@@ -0,0 +1,3 @@
+{
+  "skip32bit": true
+}

.github/workflows/go-ci.yml

@@ -1,20 +1,20 @@
 name: go-peer ci
 
-on: 
+on:
   pull_request:
     paths:
-      - 'go-peer/**'
+      - "go-peer/**"
 
 concurrency:
   group: ${{ github.workflow }}-${{ github.ref }}
   cancel-in-progress: true
 
 jobs:
   go-check:
-    uses: libp2p/uci/.github/workflows/go-check.yml@v0.0
+    uses: ipdxco/unified-github-workflows/.github/workflows/go-check.yml@v0.0
     with:
-      go-version: '1.23.x'
+      go-version: "1.25.x"
   go-test:
-    uses: libp2p/uci/.github/workflows/go-test.yml@v0.0
+    uses: ipdxco/unified-github-workflows/.github/workflows/go-test.yml@v0.0
     with:
-      go-versions: '["1.23.x"]'
+      go-versions: '["1.25.x"]'

.github/workflows/stale.yml

@@ -1,13 +1,14 @@
-name: Close and mark stale issue
+name: Close Stale Issues
 
 on:
   schedule:
     - cron: '0 0 * * *'
+  workflow_dispatch:
 
 permissions:
   issues: write
   pull-requests: write
 
 jobs:
   stale:
-    uses: pl-strflt/.github/.github/workflows/reusable-stale-issue.yml@v0.3
+    uses: ipdxco/unified-github-workflows/.github/workflows/reusable-stale-issue.yml@v1

.gitignore

@@ -9,3 +9,5 @@ yarn.lock
 .DS_Store
 go-peer/go-peer
 **/.idea
+nim-peer/nim_peer
+nim-peer/local.*

README.md

@@ -20,12 +20,14 @@ Some of the cool and cutting-edge [transport protocols](https://connectivity.lib
 
 ## Packages
 
-| Package                     | Description                     | WebTransport | WebRTC | WebRTC-direct | QUIC | TCP |
-| :-------------------------- | :------------------------------ | ------------ | ------ | ------------- | ---- | --- |
-| [`js-peer`](./js-peer/)     | Browser Chat Peer in TypeScript | ✅           | ✅     | ✅            | ❌   | ❌  |
-| [`go-peer`](./go-peer/)     | Chat peer implemented in Go     | ✅           | ❌     | ✅            | ✅   | ✅  |
-| [`rust-peer`](./rust-peer/) | Chat peer implemented in Rust   | ❌           | ❌     | ✅            | ✅   | ❌  |
-| [`py-peer`](./py-peer/)     | Chat peer implemented in Python | ❌           | ❌     | ❌            | ✅   | ✅  |
+| Package                           | Description                     | WebTransport | WebRTC | WebRTC-direct | QUIC | TCP |
+| :-------------------------------- | :------------------------------ | ------------ | ------ | ------------- | ---- | --- |
+| [`js-peer`](./js-peer/)           | Browser Chat Peer in TypeScript | ✅           | ✅     | ✅            | ❌   | ❌  |
+| [`node-js-peer`](./node-js-peer/) | Node.js Chat Peer in TypeScript | ✅           | ✅     | ✅            | ✅   | ✅  |
+| [`go-peer`](./go-peer/)           | Chat peer implemented in Go     | ✅           | ❌     | ✅            | ✅   | ✅  |
+| [`rust-peer`](./rust-peer/)       | Chat peer implemented in Rust   | ❌           | ❌     | ✅            | ✅   | ✅  |
+| [`py-peer`](./py-peer/)     | Chat peer implemented in Python       | ❌           | ❌     | ❌            | ✅   | ✅  |
+| [`nim-peer`](./nim-peer/)         | Chat peer implemented in Nim    | ❌           | ❌     | ❌            | ❌   | ✅  |
 
 ✅ - Protocol supported
 ❌ - Protocol not supported
@@ -42,8 +44,7 @@ There are two ways to connect to a peer:
 
 Load the UI, and enter the multiaddr into the UI. Ensure that it includes the peerID, e.g.`/ip4/192.168.178.21/udp/61838/quic-v1/webtransport/certhash/uEiCQCALYac4V3LJ2ourLdauXOswIXpIuJ_JNT-8Wavmxyw/certhash/uEiCdYghq5FlXGkVONQXT07CteA16BDyMPI23-0GjA9Ej_w/p2p/12D3KooWF7ovRNBKPxERf6GtUbFdiqJsQviKUb7Z8a2Uuuo6MrDX`
 
-
-## Getting started: JS
+## Getting started: Browser JS
 
 ### 1. Install dependencies
 
@@ -62,14 +63,29 @@ Start the dev server:
 npm run dev
 ```
 
+## Getting started: Node.js
+
+### 1. Install dependencies
+
+```
+cd node-js-peer
+npm i
+```
+
+### 2. Start the app
+
+```
+npm start
+```
+
 ## Getting started: Rust
 
 ```
 cd rust-peer
 cargo run
 ```
 
-This will automatically connect you to the bootstrap node running on [fly.io](https://fly.io).
+This will automatically connect you to the bootstrap nodes running on bootstrap.libp2p.io.
 
 To explore more advanced configurations if you e.g. want to set up our own network, try:
 
@@ -89,7 +105,45 @@ go run .
 Make sure you have the [uv package manager](https://github.com/astral-sh/uv)
 installed first. Follow the instructions on their Github to install it.
 
-```
+### 1. Create a virtual environment
+
+Create and activate a virtual environment for the Python peer:
+
+```bash
 cd py-peer
-uv run hello.py
+uv venv
+source .venv/bin/activate
+```
+
+### 2. Install dependencies
+
+Install the Python peer dependencies:
+
+```bash
+uv pip install -e .
+```
+
+### 3. Start the Python peer
+
+Start the peer:
+
+```bash
+python main.py
+```
+
+If you want a specific mode, you can pass flags such as `--ui`, `--kivy`, or `--api`. For example:
+
+```bash
+python main.py --ui
+
+## Getting started: Nim
+```
+cd nim-peer
+nimble build
+
+# Wait for connections in tcp/9093
+./nim_peer
+
+# Connect to another node (e.g. in localhost tcp/9092)
+./nim_peer --connect /ip4/127.0.0.1/tcp/9092/p2p/12D3KooSomePeerId
 ```

go-peer/Dockerfile

@@ -1,5 +1,5 @@
 # Use a specific version of golang alpine for better reproducibility
-FROM golang:1.23-alpine AS builder
+FROM golang:1.25-alpine AS builder
 
 WORKDIR /usr/src/app
 
@@ -18,11 +18,11 @@ FROM alpine:latest
 
 # Add CA certificates for HTTPS and create non-root user
 RUN apk --no-cache add ca-certificates && \
-    adduser -D appuser
+  adduser -D appuser
 
 # Create a directory for the application and set proper permissions
 RUN mkdir -p /app/data && \
-    chown -R appuser:appuser /app
+  chown -R appuser:appuser /app
 
 # Copy the binary from builder
 COPY --from=builder /usr/local/bin/universal-chat-go /usr/local/bin/universal-chat-go

go-peer/chatroom.go

@@ -18,9 +18,6 @@ const ChatRoomBufSize = 128
 // Topic used to broadcast browser WebRTC addresses
 const PubSubDiscoveryTopic string = "universal-connectivity-browser-peer-discovery"
 
-const ChatTopic string = "universal-connectivity"
-const ChatFileTopic string = "universal-connectivity-file"
-
 // ChatRoom represents a subscription to a single PubSub topic. Messages
 // can be published to the topic with ChatRoom.Publish, and received
 // messages are pushed to the Messages channel.
@@ -46,15 +43,15 @@ type ChatRoom struct {
 // ChatMessage gets converted to/from JSON and sent in the body of pubsub messages.
 type ChatMessage struct {
 	Message    string
-	SenderID   string
+	SenderID   peer.ID
 	SenderNick string
 }
 
 // JoinChatRoom tries to subscribe to the PubSub topic for the room name, returning
 // a ChatRoom on success.
-func JoinChatRoom(ctx context.Context, h host.Host, ps *pubsub.PubSub, nickname string) (*ChatRoom, error) {
+func JoinChatRoom(ctx context.Context, h host.Host, ps *pubsub.PubSub, nickname string, roomName string) (*ChatRoom, error) {
 	// join the pubsub chatTopic
-	chatTopic, err := ps.Join(ChatTopic)
+	chatTopic, err := ps.Join(roomName)
 	if err != nil {
 		return nil, err
 	}
@@ -66,7 +63,8 @@ func JoinChatRoom(ctx context.Context, h host.Host, ps *pubsub.PubSub, nickname
 	}
 
 	// join the pubsub fileTopic
-	fileTopic, err := ps.Join(ChatFileTopic)
+	fileTopicName := roomName + "-file"
+	fileTopic, err := ps.Join(fileTopicName)
 	if err != nil {
 		return nil, err
 	}
@@ -100,6 +98,7 @@ func JoinChatRoom(ctx context.Context, h host.Host, ps *pubsub.PubSub, nickname
 		peerDiscoveryTopic: peerDiscoveryTopic,
 		peerDiscoverySub:   peerDiscoverySub,
 		nick:               nickname,
+		roomName:           roomName,
 		Messages:           make(chan *ChatMessage, ChatRoomBufSize),
 		SysMessages:        make(chan *ChatMessage, ChatRoomBufSize),
 	}
@@ -115,7 +114,7 @@ func (cr *ChatRoom) Publish(message string) error {
 }
 
 func (cr *ChatRoom) ListPeers() []peer.ID {
-	return cr.ps.ListPeers(ChatTopic)
+	return cr.ps.ListPeers(cr.roomName)
 }
 
 // readLoop pulls messages from the pubsub chat/file topic and handles them.
@@ -138,8 +137,9 @@ func (cr *ChatRoom) readChatLoop() {
 		}
 		cm := new(ChatMessage)
 		cm.Message = string(msg.Data)
-		cm.SenderID = msg.ID
-		cm.SenderNick = string(msg.ID[len(msg.ID)-8])
+		cm.SenderID = msg.GetFrom()
+		senderStr := cm.SenderID.String()
+		cm.SenderNick = senderStr[len(senderStr)-8:]
 		// send valid messages onto the Messages channel
 		cr.Messages <- cm
 	}
@@ -167,8 +167,9 @@ func (cr *ChatRoom) readFileLoop() {
 
 		cm := new(ChatMessage)
 		cm.Message = fmt.Sprintf("File: %s (%v bytes) from %s", string(fileID), len(fileBody), msg.GetFrom().String())
-		cm.SenderID = msg.ID
-		cm.SenderNick = string(msg.ID[len(msg.ID)-8])
+		cm.SenderID = msg.GetFrom()
+		senderStr := cm.SenderID.String()
+		cm.SenderNick = senderStr[len(senderStr)-8:]
 		// send valid messages onto the Messages channel
 		cr.Messages <- cm
 	}
@@ -183,13 +184,13 @@ func (cr *ChatRoom) requestFile(toPeer peer.ID, fileID []byte) ([]byte, error) {
 	defer stream.Close()
 
 	reqLen := binary.AppendUvarint([]byte{}, uint64(len(fileID)))
-	if _, err := stream.Write(reqLen); err != nil {
+	if _, err = stream.Write(reqLen); err != nil {
 		return nil, fmt.Errorf("failed to write fileID to the stream: %w", err)
 	}
-	if _, err := stream.Write(fileID); err != nil {
+	if _, err = stream.Write(fileID); err != nil {
 		return nil, fmt.Errorf("failed to write fileID to the stream: %w", err)
 	}
-	if err := stream.CloseWrite(); err != nil {
+	if err = stream.CloseWrite(); err != nil {
 		return nil, fmt.Errorf("failed to close write stream: %w", err)
 	}
 
@@ -207,4 +208,4 @@ func (cr *ChatRoom) requestFile(toPeer peer.ID, fileID []byte) ([]byte, error) {
 	}
 
 	return fileBody, nil
-}
+}