opencode init

Python1320 · Python1320 · commit 64cc4c371788 · 2026-05-09T02:11:02.000+03:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,14 @@
+# Python-generated files
+__pycache__/
+*.py[oc]
+build/
+dist/
+wheels/
+*.egg-info
+
+# Virtual environments
+.venv
+stderr.txt
+stderr2.txt
+stdout.txt
+stdout2.txt
diff --git a/.python-version b/.python-version
@@ -0,0 +1 @@
+3.14
diff --git a/.vscode/extensions.json b/.vscode/extensions.json
@@ -0,0 +1,10 @@
+{
+	"recommendations": [
+	  "ms-python.python",
+	  "ms-python.vscode-pylance",
+	  "ms-python.debugpy",
+	  "charliermarsh.ruff",
+	  "Gruntfuggly.todo-tree"
+	]
+  }
+  
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -0,0 +1,20 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+    
+        {
+            "name": "Python Debugger: Current File",
+            "type": "debugpy",
+            "request": "launch",
+            "program": "${file}",
+            "console": "integratedTerminal",
+            "env": {
+                "PYTHONASYNCIODEBUG": "1",
+                "DEBUG": "1"
+            }
+        }
+    ]
+}
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -0,0 +1,46 @@
+{
+  "python.autoComplete.extraPaths": [],
+  "python.analysis.autoImportCompletions": true,
+  "[python]": {
+    "editor.formatOnSaveMode": "file",
+    "editor.formatOnSave": true,
+    "editor.defaultFormatter": "charliermarsh.ruff",
+    "editor.formatOnType": false,
+    "editor.insertSpaces": false,
+    "editor.tabSize": 4,
+    "editor.detectIndentation": false
+  },
+  "editor.defaultFormatter": "charliermarsh.ruff",
+  "notebook.defaultFormatter": "charliermarsh.ruff",
+  "editor.defaultFoldingRangeProvider": "charliermarsh.ruff",
+  "[jsonc]": {
+    "editor.defaultFormatter": "vscode.json-language-features"
+  },
+  "[json]": {
+    "editor.defaultFormatter": "vscode.json-language-features"
+  },
+  "cSpell.words": [
+    "ASMR",
+    "autotapping",
+    "byewave",
+    "Chillout",
+    "gameobject",
+    "Poiyomi",
+    "Resonite",
+    "steamvr",
+    "Toastacuga",
+    "unitypackage",
+    "vrcfury",
+    "vrchat",
+    "zeroconf"
+  ],
+  "cSpell.enabledFileTypes": {
+    "markdown": true,
+    "python": false
+  },
+  "cSpell.useGitignore": false,
+  "workbench.colorCustomizations": {
+    "titleBar.activeBackground": "#374e19",
+    "titleBar.inactiveBackground": "#2c3f14",
+  }
+}
diff --git a/README.md b/README.md
@@ -0,0 +1,24 @@
+# crosschat-python
+
+Game server cross-chat via MQTT.
+
+## Requirements
+
+- Python >= 3.14
+- [uv](https://docs.astral.sh/uv/getting-started/installation/)
+
+## Usage
+
+```sh
+uv run python src/crosschat/main.py
+uv run python src/crosschat/main.py --config config.metatest2.json
+uv run python src/crosschat/main.py --server-id metatest2 --host 10.0.0.1 -v
+```
+
+Connect to the aiomonitor REPL:
+
+```sh
+telnet localhost 20103
+```
+
+Type `status` to see known servers and their online/users state.
diff --git a/config.json b/config.json
@@ -0,0 +1,9 @@
+{
+	"mqtt": {
+		"host": "10.0.0.1",
+		"port": 1883
+	},
+	"server_id": "metatest1",
+	"topic_prefix": "crosschat/",
+	"last_will_topic": "crosschat/state/metatest1/online"
+}
diff --git a/config.metatest2.json b/config.metatest2.json
@@ -0,0 +1,9 @@
+{
+	"mqtt": {
+		"host": "10.0.0.1",
+		"port": 1883
+	},
+	"server_id": "metatest2",
+	"topic_prefix": "crosschat/",
+	"last_will_topic": "crosschat/state/metatest2/online"
+}
diff --git a/opencode.json b/opencode.json
@@ -0,0 +1,4 @@
+{
+  "$schema": "https://opencode.ai/config.json",
+  "lsp": true
+}
diff --git a/pyproject.toml b/pyproject.toml
@@ -0,0 +1,92 @@
+[project]
+name = "crosschat-python"
+version = "0.1.0"
+description = "Add your description here"
+readme = "README.md"
+requires-python = ">=3.14"
+dependencies = [
+    "aiomonitor>=0.7.1",
+    "aiomqtt>=2.5.1",
+    "fastapi[standard]>=0.136.1",
+    "paho-mqtt>=2.1.0",
+    "pydantic>=2.13.4",
+    "rich>=15.0.0",
+    "structlog>=25.5.0",
+]
+
+
+# https://docs.astral.sh/ruff/tutorial/
+[tool.ruff.lint]
+#select = ["ALL"]
+ignore = ["W191","E101"]
+per-file-ignores = { }
+
+[tool.ruff.lint.flake8-quotes]
+inline-quotes = "single"
+
+[tool.ruff]
+line-length = 120
+target-version = "py313"
+
+src = ["src", "tests"]
+
+
+[tool.ruff.format]
+quote-style = "single"
+indent-style = "tab"
+docstring-code-format = true
+
+exclude = [
+    ".bzr",
+    ".direnv",
+    ".eggs",
+    ".git",
+    ".hg",
+    ".mypy_cache",
+    ".nox",
+    ".pants.d",
+    ".ruff_cache",
+    ".svn",
+    ".tox",
+    ".venv",
+    "__pypackages__",
+    "_build",
+    "buck-out",
+    "build",
+    "dist",
+    "node_modules",
+    "venv",
+    "*.json",
+]
+
+
+[tool.mypy]
+strict = false
+exclude = ["venv", ".venv"]
+ignore_missing_imports = true
+allow_untyped_decorators = true
+plugins = ["pydantic.mypy"]
+follow_imports = "silent"
+warn_redundant_casts = true
+warn_unused_ignores = true
+disallow_any_generics = true
+no_implicit_reexport = true
+disallow_untyped_defs = false
+
+[tool.pydantic-mypy]
+init_forbid_extra = true
+init_typed = true
+warn_required_dynamic_aliases = true
+
+[dependency-groups]
+dev = [
+    "pylance>=4.0.1",
+    "pyright>=1.1.409",
+    "pytest>=9.0.3",
+    "pytest-asyncio>=1.3.0",
+    "ruff>=0.15.12",
+    "ty>=0.0.34",
+]
+
+[tool.ruff.lint.pycodestyle]
+max-line-length = 130
diff --git a/pyrightconfig.json b/pyrightconfig.json
@@ -0,0 +1,5 @@
+{
+  "venvPath": ".",
+  "venv": ".venv",
+  "pythonVersion": "3.14"
+}
diff --git a/src/crosschat/__init__.py b/src/crosschat/__init__.py
diff --git a/src/crosschat/main.py b/src/crosschat/main.py
@@ -0,0 +1,149 @@
+import argparse
+import asyncio
+import json
+import logging
+import signal
+import sys
+from pathlib import Path
+
+import aiomqtt
+import aiomonitor
+import structlog
+
+from crosschat.state import CrossChatState
+
+
+def parse_args() -> argparse.Namespace:
+	parser = argparse.ArgumentParser()
+	parser.add_argument('--config', '-c', type=Path, default=Path('config.json'))
+	parser.add_argument('--host', type=str)
+	parser.add_argument('--port', type=int)
+	parser.add_argument('--server-id', type=str)
+	parser.add_argument('--verbose', '-v', action='store_true')
+	return parser.parse_args()
+
+
+def load_config(path: Path) -> dict:
+	with open(path) as f:
+		return json.load(f)
+
+
+def setup_logging(verbose: bool) -> None:
+	level = logging.DEBUG if verbose else logging.INFO
+	structlog.configure(
+		processors=[
+			structlog.stdlib.add_log_level,
+			structlog.processors.TimeStamper(fmt='iso'),
+			structlog.dev.ConsoleRenderer(),
+		],
+		wrapper_class=structlog.stdlib.BoundLogger,
+		cache_logger_on_first_use=True,
+	)
+	logging.basicConfig(format='%(message)s', level=level, force=True)
+
+
+log = structlog.get_logger()
+
+
+async def listen_messages(client: aiomqtt.Client, state: CrossChatState) -> None:
+	await client.subscribe('crosschat/state/+/online')
+	async for message in client.messages:
+		topic = message.topic.value
+		payload = message.payload.decode()
+		parts = topic.split('/')
+		if len(parts) >= 4:
+			sid = parts[2]
+			online = payload == 'online'
+			prev = state.servers.get(sid)
+			prev_online = prev.online if prev else None
+			state.set_online(sid, online)
+			if prev_online != online:
+				log.info('server_state_changed', server_id=sid, online=online)
+
+
+async def main() -> None:
+	args = parse_args()
+	setup_logging(args.verbose)
+	config = load_config(args.config)
+
+	if args.host is not None:
+		config['mqtt']['host'] = args.host
+	if args.port is not None:
+		config['mqtt']['port'] = args.port
+	if args.server_id is not None:
+		config['server_id'] = args.server_id
+
+	sid = config['server_id']
+	prefix = config['topic_prefix']
+	host = config['mqtt']['host']
+	port = config['mqtt']['port']
+
+	state = CrossChatState()
+	state.set_own_id(sid)
+
+	will = aiomqtt.Will(
+		topic=f'{prefix}state/{sid}/online',
+		payload='offline',
+		qos=1,
+		retain=True,
+	)
+
+	log.info('connecting', host=host, port=port, server_id=sid)
+	async with aiomqtt.Client(
+		hostname=host,
+		port=port,
+		will=will,
+		identifier=sid,
+	) as client:
+		log.info('connected', host=host, port=port, server_id=sid)
+		await client.publish(
+			f'{prefix}state/{sid}/online',
+			payload='online',
+			qos=1,
+			retain=True,
+		)
+		log.info('state_published', topic=f'{prefix}state/{sid}/online', state='online')
+
+		listener = asyncio.create_task(listen_messages(client, state))
+
+		loop = asyncio.get_running_loop()
+
+		class _Status:
+			def __repr__(self) -> str:
+				return state.format_status()
+
+			def __call__(self) -> str:
+				return state.format_status()
+
+		status = _Status()
+		with aiomonitor.start_monitor(
+			loop=loop,
+			webui_port=0,
+			locals={
+				'state': state,
+				'status': status,
+			},
+		):
+			stop_event = asyncio.Event()
+			try:
+				loop.add_signal_handler(signal.SIGINT, stop_event.set)
+				loop.add_signal_handler(signal.SIGTERM, stop_event.set)
+			except NotImplementedError:
+				pass
+
+			log.info('running', server_id=sid)
+			await stop_event.wait()
+
+		listener.cancel()
+		try:
+			await listener
+		except asyncio.CancelledError:
+			pass
+
+	log.info('shutdown', server_id=sid)
+
+
+if __name__ == '__main__':
+	if sys.platform == 'win32':
+		asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
+	asyncio.run(main())
diff --git a/src/crosschat/models.py b/src/crosschat/models.py
diff --git a/src/crosschat/monitor.py b/src/crosschat/monitor.py
diff --git a/src/crosschat/state.py b/src/crosschat/state.py

-Original file line number
+Diff line change
@@ @@ -0,0 +1,4 @@ @@
 +{
 +  "$schema": "https://opencode.ai/config.json",
 +  "lsp": true
 +}