parity3

import functools
import logging
import os
import struct
from typing import Dict, cast, Optional, List
import cytoolz
from trio.hazmat import wait_readable
import inotify_simple
import trio

parity3

from contextlib import asynccontextmanager

import trio

class broadcaster:
    def __init__(self):
        super().__init__()
        self.subscribers = {}

    async def __aenter__(self):

parity3

import logging
import sys

import trio, trio_asyncio, asyncio
from hypercorn.trio.run import worker_serve
from hypercorn import Config
import contextlib
import math
from types import TracebackType
from quart import current_app, json

parity3

import functools
import logging
import os
import struct
from typing import Dict, cast, Optional, List
import cytoolz
from trio.hazmat import wait_readable
import inotify_simple
import trio

parity3

#!/usr/bin/env bash
set -o pipefail
set -e
set -x

function _get_userid_from_mounts() {
    type -fp awk >/dev/null || return 1
    local mountpath
    local folder_uid
    while read -r mountpath ; do