Compare commits
No commits in common. "be1bc22538f5fab6d47b859fc83a68cf0c83bda6" and "259f5859686e7d6d4773d4d8e9db020cceb497d3" have entirely different histories.
be1bc22538
...
259f585968
|
@ -98,7 +98,6 @@ def _main():
|
|||
return 0
|
||||
|
||||
|
||||
|
||||
def _confdir(args):
|
||||
if args["-c"]:
|
||||
# Custom config directory
|
||||
|
|
|
@ -82,7 +82,6 @@ async def control(req, ws):
|
|||
await asend(ws, StatusMsg(status="ack", req=cmd))
|
||||
|
||||
|
||||
|
||||
@bp.websocket("watch")
|
||||
@websocket_wrapper
|
||||
async def watch(req, ws):
|
||||
|
|
|
@ -39,14 +39,12 @@ async def main_start(app, loop):
|
|||
app.ctx.threadexec = ThreadPoolExecutor(max_workers=8)
|
||||
|
||||
|
||||
|
||||
@app.after_server_stop
|
||||
async def main_stop(app, loop):
|
||||
await watching.stop(app, loop)
|
||||
app.ctx.threadexec.shutdown()
|
||||
|
||||
|
||||
|
||||
@app.on_request
|
||||
async def use_session(req):
|
||||
req.ctx.session = session.get(req)
|
||||
|
|
|
@ -74,7 +74,6 @@ def verify(request, *, privileged=False):
|
|||
raise Unauthorized("Login required", "cookie")
|
||||
|
||||
|
||||
|
||||
bp = Blueprint("auth")
|
||||
|
||||
|
||||
|
|
|
@ -24,7 +24,6 @@ class User(msgspec.Struct, omit_defaults=True):
|
|||
lastSeen: int = 0 # noqa: N815
|
||||
|
||||
|
||||
|
||||
class Link(msgspec.Struct, omit_defaults=True):
|
||||
location: str
|
||||
creator: str = ""
|
||||
|
|
|
@ -25,7 +25,6 @@ class MkDir(ControlBase):
|
|||
path.mkdir(parents=True, exist_ok=False)
|
||||
|
||||
|
||||
|
||||
class Rename(ControlBase):
|
||||
path: str
|
||||
to: str
|
||||
|
@ -51,7 +50,6 @@ class Rm(ControlBase):
|
|||
p.unlink()
|
||||
|
||||
|
||||
|
||||
class Mv(ControlBase):
|
||||
sel: list[str]
|
||||
dst: str
|
||||
|
|
|
@ -36,7 +36,6 @@ def run(*, dev=False):
|
|||
Sanic.serve_single()
|
||||
|
||||
|
||||
|
||||
def check_cert(certdir, domain):
|
||||
if (certdir / "privkey.pem").exist() and (certdir / "fullchain.pem").exists():
|
||||
return
|
||||
|
|
|
@ -221,7 +221,6 @@ async def broadcast(msg):
|
|||
logging.exception("Broadcast error")
|
||||
|
||||
|
||||
|
||||
async def start(app, loop):
|
||||
config.load_config()
|
||||
app.ctx.watcher = threading.Thread(
|
||||
|
|
|
@ -27,7 +27,6 @@ dependencies = [
|
|||
"stream-zip",
|
||||
"tomli_w",
|
||||
]
|
||||
requires-python = ">=3.10"
|
||||
|
||||
[project.urls]
|
||||
Homepage = ""
|
||||
|
|
|
@ -2,6 +2,7 @@ import tempfile
|
|||
from pathlib import Path
|
||||
|
||||
import pytest
|
||||
|
||||
from cista import config
|
||||
from cista.protocol import Cp, MkDir, Mv, Rename, Rm
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user