IoSL/service-aware-frontend
3
0
Fork 0
generated from Luis/nextjs-python-web-template
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

nix fmt
All checks were successful
checks-impure / test (pull_request) Successful in 2m19s
Details
checks / test (pull_request) Has been cancelled
Details

Browse Source
This commit is contained in:
Luis-Hebendanz
2023-11-26 12:47:16 +01:00
parent b034bd11f1
commit 258bf656cf
6 changed files with 216 additions and 211 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkgs/clan-cli/clan_cli/dirs.py
View File

@@ -4,8 +4,8 @@ import sys
from pathlib import Path from pathlib import Path
from typing import Optional from typing import Optional
from .clan_types import FlakeName
from .errors import ClanError from .errors import ClanError
from .types import FlakeName
log = logging.getLogger(__name__) log = logging.getLogger(__name__)

2
pkgs/clan-cli/clan_cli/webui/api_inputs.py
View File

@@ -5,8 +5,8 @@ from typing import Any
from pydantic import AnyUrl, BaseModel, validator from pydantic import AnyUrl, BaseModel, validator
from pydantic.tools import parse_obj_as from pydantic.tools import parse_obj_as
from ..clan_types import validate_path
from ..dirs import clan_data_dir, clan_flakes_dir from ..dirs import clan_data_dir, clan_flakes_dir
from ..types import validate_path
DEFAULT_URL = parse_obj_as(AnyUrl, "http://localhost:8000") DEFAULT_URL = parse_obj_as(AnyUrl, "http://localhost:8000")

7
pkgs/clan-cli/clan_cli/webui/app.py
View File

@@ -1,16 +1,16 @@
import logging import logging
from contextlib import asynccontextmanager
from typing import Any
from fastapi import FastAPI from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware from fastapi.middleware.cors import CORSMiddleware
from fastapi.routing import APIRoute from fastapi.routing import APIRoute
from fastapi.staticfiles import StaticFiles from fastapi.staticfiles import StaticFiles
from contextlib import asynccontextmanager
from typing import Any
from ..errors import ClanError from ..errors import ClanError
from .assets import asset_path from .assets import asset_path
from .error_handlers import clan_error_handler from .error_handlers import clan_error_handler
from .routers import health, root, socket_manager, socket_manager2 from .routers import health, root, socket_manager2
origins = [ origins = [
"http://localhost:3000", "http://localhost:3000",
@@ -38,7 +38,6 @@ def setup_app() -> FastAPI:
app.include_router(health.router) app.include_router(health.router)
app.include_router(socket_manager.router)
app.include_router(socket_manager2.router) app.include_router(socket_manager2.router)
# Needs to be last in register. Because of wildcard route # Needs to be last in register. Because of wildcard route

87
pkgs/clan-cli/clan_cli/webui/routers/messenger.html
View File

@@ -1,78 +1,80 @@
<!DOCTYPE html> <!doctype html>
<html> <html>
<head> <head>
<script src='http://ajax.googleapis.com/ajax/libs/jquery/1.11.0/jquery.min.js'></script> <script src="http://ajax.googleapis.com/ajax/libs/jquery/1.11.0/jquery.min.js"></script>
<script> <script>
$(document).ready(function () { $(document).ready(function () {
if (typeof WebSocket != 'undefined') { if (typeof WebSocket != "undefined") {
$('#ask').show(); $("#ask").show();
} else { } else {
$('#error').show(); $("#error").show();
} }
// join on enter // join on enter
$('#ask input').keydown(function(event) { $("#ask input").keydown(function (event) {
if (event.keyCode == 13) { if (event.keyCode == 13) {
$('#ask a').click(); $("#ask a").click();
} }
}) });
// join on click // join on click
$('#ask a').click(function() { $("#ask a").click(function () {
join($('#ask input').val()); join($("#ask input").val());
$('#ask').hide(); $("#ask").hide();
$('#channel').show(); $("#channel").show();
$('input#message').focus(); $("input#message").focus();
}); });
function join(name) { function join(name) {
var host = window.location.host.split(':')[0]; var host = window.location.host.split(":")[0];
var ws = new WebSocket("ws://localhost:2979/ws2"); var ws = new WebSocket("ws://localhost:2979/ws2");
var container = $('div#msgs'); var container = $("div#msgs");
ws.onmessage = function (evt) { ws.onmessage = function (evt) {
var obj = JSON.parse(evt.data); var obj = JSON.parse(evt.data);
if (typeof obj != 'object') return; if (typeof obj != "object") return;
console.log("Received: " + obj); console.log("Received: " + obj);
var action = obj['action']; var action = obj["action"];
var struct = container.find('li.' + action + ':first'); var struct = container.find("li." + action + ":first");
if (struct.length < 1) { if (struct.length < 1) {
console.log("Could not handle: " + evt.data); console.log("Could not handle: " + evt.data);
return; return;
} }
var msg = struct.clone(); var msg = struct.clone();
msg.find('.time').text((new Date()).toString("HH:mm:ss")); msg.find(".time").text(new Date().toString("HH:mm:ss"));
if (action == 'message') { if (action == "message") {
var matches; var matches;
if (matches = obj['message'].match(/^\s*[\/\\]me\s(.*)/)) { if ((matches = obj["message"].match(/^\s*[\/\\]me\s(.*)/))) {
msg.find('.user').text(obj['user'] + ' ' + matches[1]); msg.find(".user").text(obj["user"] + " " + matches[1]);
msg.find('.user').css('font-weight', 'bold'); msg.find(".user").css("font-weight", "bold");
} else { } else {
msg.find('.user').text(obj['user']); msg.find(".user").text(obj["user"]);
msg.find('.message').text(': ' + obj['message']); msg.find(".message").text(": " + obj["message"]);
} }
} else if (action == 'control') { } else if (action == "control") {
msg.find('.user').text(obj['user']); msg.find(".user").text(obj["user"]);
msg.find('.message').text(obj['message']); msg.find(".message").text(obj["message"]);
msg.addClass('control'); msg.addClass("control");
} }
if (obj['user'] == name) msg.find('.user').addClass('self'); if (obj["user"] == name) msg.find(".user").addClass("self");
container.find('ul').append(msg.show()); container.find("ul").append(msg.show());
container.scrollTop(container.find('ul').innerHeight()); container.scrollTop(container.find("ul").innerHeight());
} };
$('#channel form').submit(function(event) { $("#channel form").submit(function (event) {
event.preventDefault(); event.preventDefault();
var input = $(this).find(':input'); var input = $(this).find(":input");
var msg = input.val(); var msg = input.val();
if (msg) { if (msg) {
ws.send(JSON.stringify({ action: 'message', user: name, message: msg })); ws.send(
JSON.stringify({ action: "message", user: name, message: msg }),
);
} }
input.val(''); input.val("");
}); });
} }
}); });
@@ -98,7 +100,7 @@ $(document).ready(function(){
-webkit-border-radius: 20px; -webkit-border-radius: 20px;
} }
#error { #error {
background-color: #BA0000; background-color: #ba0000;
color: #fff; color: #fff;
font-weight: bold; font-weight: bold;
} }
@@ -175,14 +177,15 @@ $(document).ready(function(){
</style> </style>
</head> </head>
<body> <body>
<div id="error" class="bordered" style="display: none;"> <div id="error" class="bordered" style="display: none">
This browser has no native WebSocket support.<br /> This browser has no native WebSocket support.<br />
Use a WebKit nightly or Google Chrome. Use a WebKit nightly or Google Chrome.
</div> </div>
<div id="ask" class="bordered" style="display: none;"> <div id="ask" class="bordered" style="display: none">
Name: <input type="text" id="name" /> <a href="#"><span class="join">Join!</span></a> Name: <input type="text" id="name" />
<a href="#"><span class="join">Join!</span></a>
</div> </div>
<div id="channel" class="bordered" style="display: none;"> <div id="channel" class="bordered" style="display: none">
<div id="descr" class="bordered"> <div id="descr" class="bordered">
<strong>Tip:</strong> Open up another browser window to chat. <strong>Tip:</strong> Open up another browser window to chat.
</div> </div>

20
pkgs/clan-cli/clan_cli/webui/routers/socket_manager2.py
View File

@@ -1,13 +1,12 @@
# Requires: `starlette`, `uvicorn`, `jinja2` # Requires: `starlette`, `uvicorn`, `jinja2`
# Run with `uvicorn example:app` # Run with `uvicorn example:app`
import logging
import os
import anyio import anyio
from broadcaster import Broadcast from broadcaster import Broadcast
from fastapi import FastAPI, WebSocket, WebSocketDisconnect from fastapi import APIRouter, WebSocket
from fastapi.responses import HTMLResponse from fastapi.responses import HTMLResponse
from fastapi import APIRouter, Response
import os
import logging
import asyncio
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
router = APIRouter() router = APIRouter()
@@ -18,15 +17,14 @@ brd = Broadcast("memory://")
@router.get("/ws2_example") @router.get("/ws2_example")
async def get() -> HTMLResponse: async def get() -> HTMLResponse:
html = open(f"{os.getcwd()}/webui/routers/messenger.html").read() html = open(f"{os.getcwd()}/webui/routers/messenger.html").read()
return HTMLResponse(html) return HTMLResponse(html)
@router.websocket("/ws2") @router.websocket("/ws2")
async def chatroom_ws(websocket: WebSocket) -> None: async def chatroom_ws(websocket: WebSocket) -> None:
await websocket.accept() await websocket.accept()
async with anyio.create_task_group() as task_group: async with anyio.create_task_group() as task_group:
# run until first is complete # run until first is complete
async def run_chatroom_ws_receiver() -> None: async def run_chatroom_ws_receiver() -> None:
@@ -47,8 +45,8 @@ async def chatroom_ws_receiver(websocket: WebSocket) -> None:
async def chatroom_ws_sender(websocket: WebSocket) -> None: async def chatroom_ws_sender(websocket: WebSocket) -> None:
async with brd.subscribe(channel="chatroom") as subscriber: async with brd.subscribe(channel="chatroom") as subscriber:
log.warning("====>Subscribed to chatroom channel") if subscriber is None:
async for event in subscriber: log.error("Subscriber is None")
log.warning(f"Sending message: {event.message}") return
async for event in subscriber: # type: ignore
await websocket.send_text(event.message) await websocket.send_text(event.message)

5
pkgs/clan-cli/pyproject.toml
View File

@@ -49,6 +49,11 @@ ignore_missing_imports = true
module = "pytest.*" module = "pytest.*"
ignore_missing_imports = true ignore_missing_imports = true
[[tool.mypy.overrides]]
module = "anyio.*"
ignore_missing_imports = true
[[tool.mypy.overrides]] [[tool.mypy.overrides]]
module = "setuptools.*" module = "setuptools.*"
ignore_missing_imports = true ignore_missing_imports = true