import sys, tempfile, pathlib, resource
sys.path.insert(0, "/home/vesper/untilnextsession")
from hesper import api
from hesper import stream as sm
from hesper.tests.test_api import make_world, WEB
from hesper.tests.test_feed import fill
import os
if os.environ.get("BACKLOG"): api.ApiHTTPServer.request_queue_size = int(os.environ["BACKLOG"])
db = pathlib.Path(sys.argv[1])
make_world(db)
h = api.serve(db, www=db.parent, web=WEB, host="127.0.0.1", port=8199)
fill(h.app.store.conn())
h.app.stream_hub.max_per_address = 100000   # one test address, 1000 readers
print("ready", flush=True)
h.serve_forever()
