Integrate chat from upstream
Substantially borrowed from upstream ref: 13a208ee88e55 (before they started editing generated artefacts instead of source). Integrated, including: - Remove previously removed features: emoji, hats, and name colors - Compensate for lack of unified root template - Add React build process to Dockerfile and `bootstrap/init.sh` - Preliminary integration of chat websocket workers For testing, modify `supervisord.conf.dev` to put chat on port 80 and the site service on some other port. Then visit: http://localhost/chat Still to do: - Access control for specific small-groups (and admins probably): Set the values somewhere (site_settings.json? Redis?) and use for authorization in `chat_is_allowed`. - Proxying only /chat to the websocket workers - Chat persistance across restarts: either Redis devops or to DB
This commit is contained in:
TLSM
Ben Rog-Wilhelm
parent
dba6d37456
commit
d74ba5d197
48 changed files with 2649 additions and 398 deletions
|
|
@ -1,117 +1,173 @@
|
|||
import functools
|
||||
import time
|
||||
from files.helpers.config.environment import SITE, SITE_FULL
|
||||
from files.helpers.wrappers import auth_required
|
||||
from files.helpers.sanitize import sanitize
|
||||
from files.helpers.config.const import *
|
||||
from datetime import datetime
|
||||
import uuid
|
||||
from typing import Any, Final
|
||||
|
||||
from flask_socketio import SocketIO, emit
|
||||
from files.__main__ import app, limiter, cache
|
||||
from flask import render_template, make_response, send_from_directory
|
||||
import sys
|
||||
import atexit
|
||||
|
||||
if SITE == 'localhost':
|
||||
socketio = SocketIO(app, async_mode='gevent', cors_allowed_origins=[SITE_FULL], logger=True, engineio_logger=True, debug=True)
|
||||
from files.__main__ import app, cache, limiter
|
||||
from files.helpers.alerts import *
|
||||
from files.helpers.config.const import *
|
||||
from files.helpers.config.environment import *
|
||||
from files.helpers.config.regex import *
|
||||
from files.helpers.sanitize import sanitize
|
||||
from files.helpers.wrappers import get_logged_in_user, is_not_permabanned
|
||||
|
||||
def chat_is_allowed(perm_level: int=0):
|
||||
def wrapper_maker(func):
|
||||
@functools.wraps(func)
|
||||
def wrapper(*args: Any, **kwargs: Any) -> bool | None:
|
||||
v = get_logged_in_user()
|
||||
# TODO: access control to specific small-groups
|
||||
if not v or v.is_suspended_permanently or v.admin_level < perm_level:
|
||||
return False
|
||||
return func(*args, v=v, **kwargs)
|
||||
return wrapper
|
||||
return wrapper_maker
|
||||
|
||||
if app.debug:
|
||||
socketio = SocketIO(
|
||||
app,
|
||||
async_mode='gevent',
|
||||
logger=True,
|
||||
engineio_logger=True,
|
||||
debug=True,
|
||||
)
|
||||
else:
|
||||
socketio = SocketIO(app, async_mode='gevent', cors_allowed_origins=[SITE_FULL])
|
||||
socketio = SocketIO(
|
||||
app,
|
||||
async_mode='gevent',
|
||||
)
|
||||
|
||||
typing = []
|
||||
online = []
|
||||
muted = cache.get(f'{SITE}_muted') or {}
|
||||
messages = cache.get(f'{SITE}_chat') or []
|
||||
total = cache.get(f'{SITE}_total') or 0
|
||||
CHAT_SCROLLBACK_ITEMS: Final[int] = 500
|
||||
|
||||
typing: list[str] = []
|
||||
online: list[str] = []
|
||||
muted: dict[str, int] = cache.get(f'{SITE}_muted') or {}
|
||||
messages: list[dict[str, Any]] = cache.get(f'{SITE}_chat') or []
|
||||
total: int = cache.get(f'{SITE}_total') or 0
|
||||
socket_ids_to_user_ids = {}
|
||||
user_ids_to_socket_ids = {}
|
||||
|
||||
@app.get("/chat")
|
||||
@auth_required
|
||||
@is_not_permabanned
|
||||
def chat(v):
|
||||
return render_template("chat.html", v=v, messages=messages)
|
||||
|
||||
|
||||
@app.get('/chat.js')
|
||||
@limiter.exempt
|
||||
def chatjs():
|
||||
resp = make_response(send_from_directory('assets', 'js/chat.js'))
|
||||
return resp
|
||||
|
||||
|
||||
@socketio.on('speak')
|
||||
@limiter.limit("3/second;10/minute")
|
||||
@auth_required
|
||||
@chat_is_allowed()
|
||||
def speak(data, v):
|
||||
limiter.check()
|
||||
if v.is_banned: return '', 403
|
||||
|
||||
vname = v.username.lower()
|
||||
if vname in muted:
|
||||
if vname in muted and not v.admin_level >= PERMS['CHAT_BYPASS_MUTE']:
|
||||
if time.time() < muted[vname]: return '', 403
|
||||
else: del muted[vname]
|
||||
|
||||
global messages, total
|
||||
text = data[:1000].strip()
|
||||
if not text: return '', 403
|
||||
text_html = sanitize(text)
|
||||
|
||||
data={
|
||||
text = sanitize_raw(
|
||||
data['message'],
|
||||
allow_newlines=True,
|
||||
length_limit=CHAT_LENGTH_LIMIT,
|
||||
)
|
||||
if not text: return '', 400
|
||||
|
||||
text_html = sanitize(text)
|
||||
quotes = data['quotes']
|
||||
recipient = data['recipient']
|
||||
data = {
|
||||
"id": str(uuid.uuid4()),
|
||||
"quotes": quotes,
|
||||
"avatar": v.profile_url,
|
||||
"user_id": v.id,
|
||||
"dm": bool(recipient and recipient != ""),
|
||||
"username": v.username,
|
||||
"namecolor": v.namecolor,
|
||||
"text": text,
|
||||
"text_html": text_html,
|
||||
"text_censored": text,
|
||||
"time": int(time.time())
|
||||
"time": int(time.time()),
|
||||
}
|
||||
|
||||
if v.shadowbanned:
|
||||
emit('speak', data)
|
||||
elif recipient:
|
||||
if user_ids_to_socket_ids.get(recipient):
|
||||
recipient_sid = user_ids_to_socket_ids[recipient]
|
||||
emit('speak', data, broadcast=False, to=recipient_sid)
|
||||
else:
|
||||
emit('speak', data, broadcast=True)
|
||||
messages.append(data)
|
||||
messages = messages[-50:]
|
||||
messages = messages[-CHAT_SCROLLBACK_ITEMS:]
|
||||
|
||||
total += 1
|
||||
|
||||
if v.admin_level >= 2:
|
||||
if v.admin_level >= PERMS['CHAT_MODERATION']:
|
||||
text = text.lower()
|
||||
for i in mute_regex.finditer(text):
|
||||
username = i.group(1)
|
||||
username = i.group(1).lower()
|
||||
duration = int(int(i.group(2)) * 60 + time.time())
|
||||
muted[username] = duration
|
||||
|
||||
return '', 204
|
||||
chat_save()
|
||||
|
||||
|
||||
@socketio.on('connect')
|
||||
@auth_required
|
||||
@chat_is_allowed()
|
||||
def connect(v):
|
||||
if v.username not in online:
|
||||
online.append(v.username)
|
||||
emit("online", online, broadcast=True)
|
||||
|
||||
if not socket_ids_to_user_ids.get(request.sid):
|
||||
socket_ids_to_user_ids[request.sid] = v.id
|
||||
user_ids_to_socket_ids[v.id] = request.sid
|
||||
|
||||
emit('online', online)
|
||||
emit('catchup', messages)
|
||||
emit('typing', typing)
|
||||
return '', 204
|
||||
|
||||
|
||||
@socketio.on('disconnect')
|
||||
@auth_required
|
||||
@chat_is_allowed()
|
||||
def disconnect(v):
|
||||
if v.username in online:
|
||||
online.remove(v.username)
|
||||
emit("online", online, broadcast=True)
|
||||
|
||||
if v.username in typing: typing.remove(v.username)
|
||||
|
||||
if socket_ids_to_user_ids.get(request.sid):
|
||||
del socket_ids_to_user_ids[request.sid]
|
||||
del user_ids_to_socket_ids[v.id]
|
||||
|
||||
emit('typing', typing, broadcast=True)
|
||||
return '', 204
|
||||
|
||||
|
||||
@socketio.on('typing')
|
||||
@auth_required
|
||||
@chat_is_allowed()
|
||||
def typing_indicator(data, v):
|
||||
if data and v.username not in typing: typing.append(v.username)
|
||||
elif not data and v.username in typing: typing.remove(v.username)
|
||||
if data and v.username not in typing:
|
||||
typing.append(v.username)
|
||||
elif not data and v.username in typing:
|
||||
typing.remove(v.username)
|
||||
|
||||
emit('typing', typing, broadcast=True)
|
||||
return '', 204
|
||||
|
||||
|
||||
def close_running_threads():
|
||||
@socketio.on('delete')
|
||||
@chat_is_allowed(PERMS['CHAT_MODERATION'])
|
||||
def delete(text, v):
|
||||
for message in messages:
|
||||
if message['text'] == text:
|
||||
messages.remove(message)
|
||||
|
||||
emit('delete', text, broadcast=True)
|
||||
|
||||
|
||||
def chat_save():
|
||||
cache.set(f'{SITE}_chat', messages)
|
||||
cache.set(f'{SITE}_total', total)
|
||||
cache.set(f'{SITE}_muted', muted)
|
||||
atexit.register(close_running_threads)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue