diff --git a/README.md b/README.md index b9c2872..80960a8 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,39 @@ # FASI -Fast And Sleek Invite (FASI) \ No newline at end of file +Fast And Sleek Invite (FASI) + +## About + +FASI is an HTML invite page for XMPP. +The main purpose, is to provide an interface to share XMPP contacts via HTML +browsers. +It also provides an interface to explore XMPP server conferences, pubsub and +other services. + +FASI is written in Python and utilizes Jinja2, FastAPI and Slixmpp. + +## Features +- MUC +- Photo +- PubSub +- QR code +- Service discovery +- vCard + +## Install + +Use the following commands, to begin FASI. + +```shell +git clone https://git.xmpp-it.net/sch/FASI +cd FASI/ +python -m uvicorn fasi:app +``` + +## License + +AGPL-3.0-only + +## Copyright + +Schimon Jehudah Zachary 2024 diff --git a/configuration.toml b/configuration.toml new file mode 100644 index 0000000..958b3bf --- /dev/null +++ b/configuration.toml @@ -0,0 +1,5 @@ +# An account to connect FASI to the XMPP network + +[account] +xmpp = "" # Jabber ID +pass = "" # Password diff --git a/css/stylesheet.css b/css/stylesheet.css new file mode 100644 index 0000000..96e3501 --- /dev/null +++ b/css/stylesheet.css @@ -0,0 +1,384 @@ +* { + user-select: none; +} + +div, h1, h2, h3, h4, h5 { + font-family: system-ui; +} + +html { + height: 100%; +} + +body { + background: url(/img/background.svg); + background-repeat: repeat; + /*height: 100vh;*/ + /* + background: linear-gradient(-45deg, rgba(0,0,0,0) 25%, rgba(255,255,255,0.2) 25%, rgba(255,255,255,0.2) 50%, rgba(0,0,0,0) 50%, rgba(0,0,0,0) 75%, rgba(255,255,255,0.2) 75%), linear-gradient(45deg, rgba(0,0,0,0) 25%, rgba(255,255,255,0.2) 25%, rgba(255,255,255,0.2) 50%, rgba(0,0,0,0) 50%, rgba(0,0,0,0) 75%, rgba(255,255,255,0.2) 75%), rgb(2, 115, 127) + */ + /* background: url(/img/background.svg); */ + /* background-repeat: repeat; */ + /* NOTE Value "contain" can be useful for tiled background */ + /* background-size: contain; */ + /* background-size: 100vw; */ + /* background-size: cover; */ + margin: 0; + min-height: 100%; +} +/* +div:has(#bar) { + height: 100vh; +} + */ +#bar { + background: #f5f5f5; + filter: drop-shadow(0 0 4px grey); + min-height: 3em; + padding-top: 1em; + padding-bottom: 1em; + margin-bottom: 2.5em; + /* position: fixed; + width: 100%; */ + z-index: 1; +} + +#bar > * { + margin-left: 0.5em; + margin-right: 0.5em; +} + +#logo { + height: 3em; +} + +#xmpp-uri { + user-select: all; +} + +input, +input[type="submit" i], +input:not([type="email" i], [type="number" i], [type="password" i], [type="search" i], [type="tel" i], [type="text" i], [type="url" i]), +input:not([type="file" i], [type="image" i], [type="checkbox" i], [type="radio" i]) { + all: unset; +} + +label, +#action, +#exception, +#xmpp-uri, +#preview { + line-height: 3em; /* 2em */ +} + +#download { + float: right; +} + +#jid { + font-size: 1.5em; + margin-bottom: 1em; + /* padding-bottom: 1em; */ +} + +#action, +#download, +#input { + border-radius: 26px; + font-size: 1.4em; + padding: 0.5em; +} + +#action, +#input { + background: #13b5ea; /* #002b5c */ +} + +#action:hover, +#input:hover { + background: #1b3967; +} + +#action, +#download, +#download-narrow, +#input { + color: #f5f5f5; + font-weight: bold; + padding-left: 2em; + padding-right: 2em; + text-decoration: none; + text-transform: uppercase; +} + +#download, +#download-narrow { + background: #d9541e; /* #e96d1f */ +} + +#download:hover, +#download-narrow:hover { + background: #439639; /* #a0ce67 */ +} + +#download-narrow { + border-bottom-left-radius: 16px; + border-bottom-right-radius: 16px; + font-size: 2em; + margin-bottom: 3em; + padding: 0.5em; + /* width: 60%; */ + width: 360px; +} + +#logo-narrow { + height: 1em; + padding-right: 1em; +} + +#download-narrow, +#logo-bottom { + display: none; +} + +#logo-bottom { + margin: auto; + margin-top: 4em; + /* padding-bottom: 2.5em; */ + width: 30%; +} + +h1 { + overflow-x: hidden; + /* padding: 10px; */ + text-overflow: ellipsis; +} + +/* +#count { + margin: 1em; +} +*/ + +#photo, +#qrcode { + border: 1px solid #c0c0c0; + /* width: 40%; */ + /* margin-bottom: 2.5em; */ + /* NOTE Reason for dimensions 276x276: To be in accord with generated QR Code. */ + height: 276px; + width: 276px; + /* + max-height: 276px; + max-width: 276px; + min-height: 276px; + outline: solid; + outline-color: #7a7a7a; + */ +} + +#photo { + background: #fff; + border-right: none; + /* border-radius: 100px; 500px */ + border-bottom-left-radius: 50px; + border-top-left-radius: 50px; + margin-right: -3px; + object-fit: scale-down; +} + +/* + +NOTE +Use border to equalize element #phoro with #qrcode. +Perhaps also contain it within a span, in order to fill the background. + + border: 1em solid #fff; + height: 240px; + width: 240px; + +*/ + +#qrcode { + border-left: none; + border-bottom-right-radius: 50px; + border-top-right-radius: 50px; + margin-left: -3px; +} + +h3, h4, h5 { + padding-left: 2em; + padding-right: 2em; +} + +#profile { + background: #f5f5f5; + border-radius: 30px; + filter: drop-shadow(2px 4px 6px grey); + margin-bottom: 2.5em; + margin-left: auto; + margin-right: auto; + max-width: 55em; + /* FIXME + Elements of element #profile overflow upon decreasing height, once property + min-width has been added. + */ + min-width: 35em; + /* NOTE + The problem is not with elements within element #profile. + Issue has been fixed, once property max-height was commented. + If you would, add @media (max-height: 300px) for lower height. + */ + /* max-height: 75vh; */ + padding-top: 1em; + padding-bottom: 3em; + text-align: center; + width: 80%; +} + +#entries { + padding: 2em; + text-align: left; +} + +.entry > * { + margin-bottom: 1em; +} + +.summary { + white-space: pre-wrap; + word-break: break-word; +} + +#services { + text-align: left; +} + +#count > a, +#preview { + color: #5c5656; + text-decoration: none; +} + +#count > a:hover, +#preview:hover { + color: #000; + text-decoration: underline; +} + +#note { + color: #fff; + font-weight: bold; + padding-bottom: 1em; + text-align: center; + text-shadow: 1px 1px #000; +} + +#message { + background: #000; + color: white; + font-weight: bold; + opacity: 10%; + padding: 1em; + position: fixed; + text-align: center; + bottom: 0; + left: 0; + right: 0; +} + +#message:hover { + opacity: unset; +} + +/* NOTE This rule useful, for larger images (800x800), to switch from + background-size: 100vw; +*/ + +/* +@media (max-width: 950px) { + + body { + background-size: 100vh; + } + +} +*/ + +@media (max-width: 725px) { + + body { + background: #f5f5f5; + } + + #bar, + #message { + display: none; + } + + #download-narrow { + background: #a3a3a3; + display: inline-block; + margin-bottom: unset; + } + + #download-narrow:hover { + background: #a7a7a7; + } + + #logo-bottom { + display: unset; + } + + #profile { + border-radius: unset; + filter: unset; + margin-bottom: unset; + max-height: unset; + max-width: unset; + min-width: 25em; + padding-top: unset; + width: unset; + } + + #note { + background: #f5f5f5; + color: #000; + /* display: none; */ + font-weight: unset; + padding-bottom: 1em; + text-shadow: unset; + } + + #photo, + #qrcode { + border: unset; + border-radius: 50px; + /* height: unset; */ + height: 360px; + margin-bottom: 2.5em; + max-width: 70%; + min-width: 360px; + /* width: 360px; */ + } + + #photo { + background: unset; + /* + border-bottom-left-radius: unset; + border-top-left-radius: unset; + */ + margin-right: unset; + /* object-fit: unset; */ + } + + #qrcode { + /* + border-bottom-right-radius: unset; + border-top-right-radius: unset; + */ + margin-left: unset; + } + + +} diff --git a/fasi.py b/fasi.py new file mode 100644 index 0000000..6335d4f --- /dev/null +++ b/fasi.py @@ -0,0 +1,934 @@ +#!/usr/bin/env python3 +# -*- coding: utf-8 -*- + +from datetime import datetime +from email.utils import parseaddr +from fastapi import FastAPI, Form, HTTPException, Request, Response +from fastapi.middleware.cors import CORSMiddleware +from fastapi.responses import FileResponse, HTMLResponse +from fastapi.staticfiles import StaticFiles +from fastapi.templating import Jinja2Templates +#import logging +#from os import mkdir +#from os.path import getsize, exists +import os +import qrcode +import random +import re +from slixmpp import ClientXMPP, stanza +from slixmpp.exceptions import IqError, IqTimeout +from starlette.responses import RedirectResponse +#import time +import tomli_w +from urllib.parse import urlsplit +import uvicorn +import xml.etree.ElementTree as ET + +try: + import cv2 +except: + print('OpenCV (cv2) is required for dynamic background.') + +try: + import numpy +except: + print('NumPy (numpy) is required for dynamic background.') + +try: + import tomllib +except: + import tomli as tomllib + +class XmppInstance(ClientXMPP): + def __init__(self, jid, password, jid_bare): + super().__init__(jid, password) + + self.jid_bare = jid_bare + + self.register_plugin('xep_0030') # XEP-0030: Service Discovery + self.register_plugin('xep_0045') # XEP-0045: Multi-User Chat + self.register_plugin('xep_0054') # XEP-0054: vcard-temp + self.register_plugin('xep_0060') # XEP-0060: Publish-Subscribe + + self.add_event_handler("session_start", self.on_session_start) + + async def on_session_start(self, event): + self.send_presence() + #self.disconnect() + +class HttpInstance: + def __init__(self, jabber_id, password): + + self.app = FastAPI() + templates = Jinja2Templates(directory='xhtml') + + # TODO + # 1) Mount at the same mountpoint /img. + # 2) Image filename to be constant, i.e. /img/photo.png and /img/qr.png. + self.app.mount('/photo', StaticFiles(directory='photo'), name='photo') + self.app.mount('/qr', StaticFiles(directory='qr'), name='qr') + self.app.mount('/css', StaticFiles(directory='css'), name='css') + self.app.mount('/img', StaticFiles(directory='img'), name='img') + +# @self.app.get('/favicon.ico', include_in_schema=False) +# def favicon_get(): +# return FileResponse('graphic/hermes.ico') + +# @self.app.get('/hermes.svg') +# def logo_get(): +# return FileResponse('graphic/hermes.svg') + + # NOTE Was /b/ + @self.app.get('/d/{jid}/{node_name}') + async def browse_jid_node_get(request: Request, jid, node_name): + """Browse items of a pubsub node""" + jid_path = urlsplit(jid).path + if parseaddr(jid_path)[1] == jid_path: + jid_bare = jid_path.lower() + else: + jid_bare = jid + note = 'Jabber ID appears to be malformed' + + try: + exception = note = selection = services_sorted = None + title = node_name + link_href = 'xmpp:{}?pubsub;node={};action=subscribe'.format(jid_bare, node_name) + link_text = 'Subscribe' + xmpp_uri = 'xmpp:{}?;node={}'.format(jid_bare, node_name) + + # Start an XMPP instance and retrieve information + xmpp_instance = XmppInstance(jabber_id, password, jid_bare) + xmpp_instance.connect() + + # Title + if '@' in jid_bare and node_name == 'urn:xmpp:microblog:0': + title = 'Journal' + else: + jid_items = await XmppXep0030.get_jid_items(xmpp_instance, jid_bare) + iq = jid_items['iq'] + iq_disco_items = iq['disco_items'] + iq_disco_items_items = iq_disco_items['items'] + category = 'unsorted' + for item in iq_disco_items_items: + if item[2] and item[1] == node_name: + title = item[2] + break + + # Node items + action = 'Browse' + entries = [] + node_items = await XmppXep0060.get_node_items(xmpp_instance, jid_bare, node_name) + if not node_items: + action = 'Warning' + title = jid_info['condition'] + note = jid_info['text'] + services = services_sorted = None + elif isinstance(node_items, IqTimeout): + action = 'Warning' + title = 'Timeout' + note = 'Timeout error' + services = services_sorted = None + elif isinstance(node_items, IqError): + action = 'Warning' + breakpoint() + title = node_items['condition'] + note = node_items['text'] + services = services_sorted = None + else: + #title = title or node_name + if not title: title = node_name + note = jid_bare + for item in node_items['pubsub']['items']: + item_payload = item['payload'] + entry = Syndication.extract_items(item_payload) + entries.append(entry) + if entries: entries.reverse() + + xmpp_instance.disconnect() + + except Exception as e: + exception = str(e) + action = 'Error' + title = 'Slixmpp error' + xmpp_uri = note = jid + filename = jid_bare = services = url = link_href = link_text = None + + #if title == 'remote-server-timeout': + # raise HTTPException(status_code=408, detail='remote-server-timeout') + #else: + template_file = 'node.xhtml' + template_dict = { + 'action' : action, + 'exception' : exception, + 'filename' : 'default.svg', + 'jid_bare' : jid, + 'note' : note, + 'request' : request, + 'entries' : entries, + 'title' : title, + 'url' : request.url._url, + 'link_href' : link_href, + 'link_text' : link_text, + 'xmpp_uri' : xmpp_uri} + response = templates.TemplateResponse(template_file, template_dict) + response.headers['Content-Type'] = 'application/xhtml+xml' + return response + + @self.app.get('/d/{jid}') + async def discover_jid_get(request: Request, jid): + """View items of a selected service""" + + jid_path = urlsplit(jid).path + if parseaddr(jid_path)[1] == jid_path: + jid_bare = jid_path.lower() + else: + jid_bare = jid + note = 'Jabber ID appears to be malformed' + + try: + exception = note = selection = services_sorted = None + title = 'Services' + link_href = xmpp_uri = jid_bare + link_text = 'Reload' + + # Start an XMPP instance and retrieve information + xmpp_instance = XmppInstance(jabber_id, password, jid_bare) + xmpp_instance.connect() + + # JID services + action = 'Discover' + jid_info = await XmppXep0030.get_jid_info(xmpp_instance, jid_bare) + iq = jid_info['iq'] + if iq: + jid_kind = jid_info['kind'] + iq_disco_info = iq['disco_info'] + for identity in iq_disco_info['identities']: + if jid_kind == identity[0] and identity[3]: + note = identity[3] + if not note: note = jid_bare + jid_items = await XmppXep0030.get_jid_items(xmpp_instance, jid_bare) + iq = jid_items['iq'] + iq_disco_items = iq['disco_items'] + iq_disco_items_items = iq_disco_items['items'] + services = {} + #services_sorted = {} + category = 'unsorted' + for item in iq_disco_items_items: + jid_bare = item[0] + if len(iq_disco_items_items) > 20 or jid_kind and jid_kind in ('pubsub'): + identity = sub_jid_info = sub_jid_info_iq = '' + if jid_kind and jid_kind in ('conference', 'mix', 'muc'): + category = 'conference' + if jid_kind and jid_kind in ('pubsub'): + category = 'pubsub' + else: + sub_jid_info = await XmppXep0030.get_jid_info(xmpp_instance, jid_bare) + sub_jid_info_iq = sub_jid_info['iq'] + try: + for identity_item in sub_jid_info_iq['disco_info']['identities']: + identity = identity_item + break + if sub_jid_info_iq: + category = identity[0] if (identity, list) and identity[0] else 'other' + except: + identity = None + category = 'unavailable' + + sub_jid_kind = sub_jid_info['kind'] if 'kind' in sub_jid_info else None + if category not in services: services[category] = [] + + services[category].append( + {'identity' : identity, + 'info' : sub_jid_info, + 'jid' : jid_bare, + 'kind' : sub_jid_kind, + 'name' : item[2] or item[1] or item[0], + 'node' : item[1]}) + + services_sorted = {k: v for k, v in services.items() if k != 'unavailable'} + if 'unavailable' in services: services_sorted['unavailable'] = services['unavailable'] + else: + action = 'Warning' + title = jid_info['condition'] + note = jid_info['text'] + services = services_sorted = None + + xmpp_instance.disconnect() + + except Exception as e: + exception = str(e) + action = 'Error' + title = 'Slixmpp error' + xmpp_uri = note = jid + filename = jid_bare = services = url = link_href = link_text = None + + #if title == 'remote-server-timeout': + # raise HTTPException(status_code=408, detail='remote-server-timeout') + #else: + template_file = 'disco.xhtml' + template_dict = { + 'action' : action, + 'exception' : exception, + 'filename' : 'default.svg', + 'jid_bare' : jid, + 'note' : note, + 'request' : request, + 'services' : services_sorted, + 'title' : title, + 'url' : request.url._url, + 'link_href' : link_href, + 'link_text' : link_text, + 'xmpp_uri' : xmpp_uri} + response = templates.TemplateResponse(template_file, template_dict) + response.headers['Content-Type'] = 'application/xhtml+xml' + return response + + @self.app.get('/v/{jid}') + async def view_jid_get(request: Request, jid): + """View recent messages of a conference""" + pass #TODO + + @self.app.get('/{jid}/{node_name}') + async def jid_node_get(request: Request, jid, node_name): + response = await main_jid_node_get(request, jid, node_name) + return response + + @self.app.get('/{jid}') + async def jid_node_get(request: Request, jid): + node_name = request.query_params.get('node', '') + if node_name: + response = RedirectResponse(url='/{}/{}'.format(jid, node_name)) + else: + response = await main_jid_node_get(request, jid) + return response + + async def main_jid_node_get(request: Request, jid, node_name=None): + + jid_bare = jid + jid_path = urlsplit(jid).path + if parseaddr(jid_path)[1] == jid_path: + jid_bare = jid_path.lower() + else: + jid_bare = jid + note = 'Jabber ID appears to be malformed' + + try: + exception = note = selection = title = view_href = None + + # Start an XMPP instance and retrieve information + xmpp_instance = XmppInstance(jabber_id, password, jid_bare) + xmpp_instance.connect() + + # JID kind + instance = message = node_id = None + jid_info = await XmppXep0030.get_jid_info(xmpp_instance, jid_bare) + jid_info_iq = jid_info['iq'] + jid_kind = jid_info['kind'] + if jid_info['error']: + message = '{}: {} (XEP-0030)'.format(jid_info['text'], jid_info['condition']) + action = 'Connect with' + link_text = 'Connect' + link_href = xmpp_uri = 'xmpp:{}'.format(jid_bare) + elif jid_kind in ('conference', 'server'): + action = link_text = 'Discover' + if jid_kind == 'conference': + instance = 'conferences' + elif jid_kind == 'server': + instance = 'services' + link_href = xmpp_uri = 'xmpp:{}'.format(jid_bare) + view_href = '/d/' + jid_bare + elif jid_kind in ('mix', 'muc'): + #title = 'Group Chat ' + title + # TODO Set group chat subject as description. + action = 'Join to' + instance = 'participants' + link_text = 'Join' + link_href = xmpp_uri = 'xmpp:{}?join'.format(jid_bare) + view_href = '/v/' + jid_bare + # room_info = await XmppXep0045.get_room_data(xmpp_instance, jid_bare) + # breakpoint() + elif jid_kind == 'pubsub': + #node_name = request.query_params.get('node', '') + if node_name: + action = 'Subscribe to' + instance = 'articles' + link_text = 'Subscribe' + link_href = xmpp_uri = 'xmpp:{}?pubsub;node={};action=subscribe'.format(jid_bare, node_name) + view_href = '/d/{}/{}'.format(jid_bare, node_name) + else: + action = link_text = 'Browse' + instance = 'nodes' + link_href = xmpp_uri = 'xmpp:{}'.format(jid_bare) + view_href = '/d/' + jid_bare + else: + action = link_text = 'Message' + instance = 'articles' + link_href = xmpp_uri = 'xmpp:{}?message'.format(jid_bare) + node_name = 'urn:xmpp:microblog:0' + view_href = '/d/{}/{}'.format(jid_bare, node_name) + + # JID item count + count = None + if jid_kind in ('mix', 'muc', 'conference', 'server'): + jid_items = await XmppXep0030.get_jid_items(xmpp_instance, jid_bare) + count = len(jid_items['iq']['disco_items']['items']) + elif jid_kind in ('account', 'pubsub'): + node_items = await XmppXep0060.get_node_item_ids(xmpp_instance, jid_bare, node_name) + if isinstance(node_items, stanza.iq.Iq): + count = len(node_items['disco_items']['items']) + + # JID info + # NOTE Group chat of Psi+ Project at jabber.ru has a note in its vCard. + vcard_data = await XmppXep0054.get_vcard_data(xmpp_instance, jid_bare) + if vcard_data['error']: + jid_detail = {} + #jid_detail['note'] = '{}: {}'.format(vcard_data['text'], vcard_data['condition']) + jid_detail['name'] = jid_detail['note'] = jid_detail['note'] = jid_detail['type'] = jid_detail['bin'] = None + else: + conference_title = None + if jid_kind in ('mix', 'muc'): + for identity in jid_info_iq['disco_info']['identities']: + if identity[3]: + conference_title = identity[3] + break + vcard_temp = vcard_data['iq']['vcard_temp'] + jid_detail = { + 'name' : vcard_temp['FN'] or conference_title, + 'note' : vcard_temp['notes'] or node_id, + 'type' : vcard_temp['PHOTO']['TYPE'], + 'bin' : vcard_temp['PHOTO']['BINVAL'] + } + + # Title + if jid_kind == 'pubsub': + jid_items = await XmppXep0030.get_jid_items(xmpp_instance, jid_bare) + iq = jid_items['iq'] + iq_disco_items = iq['disco_items'] + iq_disco_items_items = iq_disco_items['items'] + for item in iq_disco_items_items: + if item[2] and item[1] == node_name: + title = item[2] + break + if jid_kind == 'server': + if jid_info_iq: + for identity in jid_info_iq['disco_info']['identities']: + if jid_kind == identity[0] and identity[1] == 'im' and identity[3]: + title = identity[3] + print(jid_bare) + print(identity) + print(jid_info) + # String 'undefined' is sourced from JID discuss@conference.conversejs.org + if not title: + if jid_detail['name'] and not 'undefined' in jid_detail['name']: + title = jid_detail['name'] + else: + title = jid_bare.split('@')[0] + + + # Notes + jid_detail_note = jid_detail['note'] + if isinstance(jid_detail_note, list) and len(jid_detail_note): + note = jid_detail_note[0]['NOTE'] + else: + note = jid_detail_note + #if not note and jid_detail['name'] and not 'undefined' in jid_detail['name'] and title != jid_detail['name']: + # note = jid_detail['name'] + + # File type + mimetype = filename = filepath = None + if jid_detail['type']: + mimetype = jid_detail['type'] + if mimetype: + filetype = mimetype.split('/')[1] + if filetype == 'svg+xml': filetype = 'svg' + filename = '{}.{}'.format(jid_bare, filetype) + filepath = 'photo/{}.{}'.format(jid_bare, filetype) + #img.save(filename) + + # Write the decoded bytes to a file + with open(filepath, 'wb') as file: + file.write(jid_detail['bin']) + + #from PIL import Image + #img = Image.open(filepath) + #rgb_im = im.convert("RGB") + #rgb_im.save('{}_mod.jpg'.format(jid_bare)) + + # Default photo. Utilized, if there is no image file. + if not filepath or not os.path.exists(filepath) or os.path.getsize(filepath) == 0: + filename = 'default.svg' + elif filetype == 'svg': + selection = Graphics.extract_colours_from_vector(filepath) + else: + selection = Graphics.extract_colours_from_raster(filepath) + + xmpp_instance.disconnect() + + # QR code + Graphics.generate_qr_code_graphics_from_string(xmpp_uri, jid_bare) + + except Exception as e: + exception = str(e) + print(exception) + action = 'Error' + title = 'Slixmpp error' + xmpp_uri = jid + count = filename = jid_bare = jid_kind = link_href = link_text = message = selection = url = None + + template_file = 'jid.xhtml' + template_dict = { + 'action' : action, + 'count' : count, + 'instance' : instance, + 'exception' : exception, + 'filename' : filename, + 'jid_bare' : jid_bare, + 'jid_kind' : jid_kind, + 'link_href' : link_href, + 'link_text' : link_text, + 'message' : message, + 'note' : note, + 'request' : request, + 'selection' : selection, + 'title' : title, + 'url' : request.url._url, + 'view_href' : view_href, + 'xmpp_uri' : xmpp_uri} + response = templates.TemplateResponse(template_file, template_dict) + response.headers['Content-Type'] = 'application/xhtml+xml' + return response + + @self.app.exception_handler(404) + def not_found_exception_handler(request: Request, exc: HTTPException): + action = 'Warning' + title = 'Not Found' + return result_get(request, action, title) + + @self.app.exception_handler(500) + def internal_error_exception_handler(request: Request, exc: HTTPException): + action = 'Error' + title = 'Internal Server Error' + return result_get(request, action, title) + + def result_get(request: Request, action: str, title: str): + template_file = 'result.xhtml' + template_dict = { + 'action' : action, + 'request' : request, + 'title' : title, + 'url' : request.url._url} + response = templates.TemplateResponse(template_file, template_dict) + response.headers['Content-Type'] = 'application/xhtml+xml' + return response + + @self.app.get('/') + async def main_get(request: Request): + jabber_id = request.query_params.get('jid', '') + if jabber_id: + response = RedirectResponse(url='/' + jabber_id) + else: + template_file = 'main.xhtml' + template_dict = { + 'request' : request, + 'url' : request.url._url} + response = templates.TemplateResponse(template_file, template_dict) + response.headers['Content-Type'] = 'application/xhtml+xml' + return response + +class Data: + + def open_file_toml(filename: str) -> dict: + with open(filename, mode="rb") as fn: + data = tomllib.load(fn) + return data + + def save_to_toml(filename: str, data: dict) -> None: + with open(filename, 'w') as fn: + data_as_string = tomli_w.dumps(data) + fn.write(data_as_string) + +class Graphics: + + + def extract_colours_from_raster(filepath): + try: + img = cv2.imread(filepath) + #thresholded = cv2.inRange(img, (50, 100, 200), (50, 100, 200)) + thresholded = cv2.inRange(img, (90, 90, 90), (190, 190, 190)) + #thresholded = cv2.bitwise_not(thresholded) + #thresholded = cv2.inRange(img, (0, 0, 0), (0, 0, 0)) + #res = img + cv2.cvtColor(thresholded, cv2.COLOR_GRAY2BGR) + + img = cv2.cvtColor(img, cv2.COLOR_BGR2RGB) + #result = numpy.clip(img, 90, 190) + #result = numpy.clip(img, 50, 200) + #result = numpy.clip(img, 100, 150) + result = numpy.clip(img, 100, 200) + res = cv2.cvtColor(result, cv2.COLOR_RGB2BGR) + + """ + img = cv2.cvtColor(img, cv2.COLOR_BGR2RGB) + mask = numpy.all(numpy.logical_and(img >= 90, img <= 190), axis=2) + result = numpy.where(mask[...,None], img, 255) + res = cv2.cvtColor(result, cv2.COLOR_RGB2BGR) + """ + + """ + # Thresholding for black: + lower_black = numpy.array([0, 0, 0]) + upper_black = numpy.array([50, 50, 50]) # Adjust this value for the black range + black_mask = cv2.inRange(img, lower_black, upper_black) + + # Thresholding for white: + lower_white = numpy.array([250, 250, 250]) + upper_white = numpy.array([255, 255, 255]) + white_mask = cv2.inRange(img, lower_white, upper_white) + + # Combine the masks + combined_mask = cv2.bitwise_or(black_mask, white_mask) + + # Invert the combined mask + inverted_mask = cv2.bitwise_not(combined_mask) + + # Apply the mask to the original image + res = cv2.bitwise_and(img, img, mask=inverted_mask) + """ + + selection = [] + + ix_1st = random.randint(1, len(res)-1) + res_ix_1st = res[ix_1st] + ix_ix_1st = random.randint(1, len(res_ix_1st)-1) + res_ix_ix_1st = res_ix_1st[ix_ix_1st] + selection.append(numpy.array(res_ix_ix_1st).tolist()) + + ix_2nd = random.randint(1, len(res)-1) + res_ix_2nd = res[ix_2nd] + ix_ix_2nd = random.randint(1, len(res_ix_2nd)-1) + res_ix_ix_2nd = res_ix_2nd[ix_ix_2nd] + selection.append(numpy.array(res_ix_ix_2nd).tolist()) + print(selection) + + except Exception as e: + exception = str(e) + print(exception) + + return selection + + def extract_colours_from_vector(filepath): + # Parse the SVG file + tree = ET.parse(filepath) + root = tree.getroot() + + # Set to store unique colours + colours_hex = set() + colours_rgb = [] + + # SVG namespace + namespace = {'svg': 'http://www.w3.org/2000/svg'} + + # Find all possible elements + for elem in root.findall('.//svg:circle', namespace) + \ + root.findall('.//svg:ellipse', namespace) + \ + root.findall('.//svg:line', namespace) + \ + root.findall('.//svg:path', namespace) + \ + root.findall('.//svg:polygon', namespace) + \ + root.findall('.//svg:rect', namespace) + \ + root.findall('.//svg:text', namespace): + + fill = elem.get('fill') + stroke = elem.get('stroke') + + # Add colours to the set if they are not None or 'none' + if fill and fill.startswith('#') and len(fill) > 4 and fill.lower() != 'none': + colours_hex.add(fill) + if stroke and stroke.startswith('#') and len(stroke) > 4 and stroke.lower() != 'none': + colours_hex.add(stroke) + + for colour in colours_hex: + hex = colour.lstrip('#') + rgb = list(int(hex[i:i+2], 16) for i in (0, 2, 4)) + rgb.reverse() + colours_rgb.append(rgb) + + selection = [] + if len(colours_rgb) > 1: + for i in range(2): + ix = random.randint(0, len(colours_rgb)-1) + selection.append(colours_rgb[ix]) + del colours_rgb[ix] + elif len(colours_rgb) == 1: + selection = [colours_rgb[0], colours_rgb[0]] + + return selection + + def generate_qr_code_graphics_from_string(text, jid_bare): + qrcode_graphics = qrcode.make(text) + qrcode_graphics.save('qr/{}.png'.format(jid_bare)) + +class Syndication: + + def extract_items(item_payload, limit=False): + namespace = '{http://www.w3.org/2005/Atom}' + title = item_payload.find(namespace + 'title') + links = item_payload.find(namespace + 'link') + if (not isinstance(title, ET.Element) and + not isinstance(links, ET.Element)): return None + title_text = '' if title == None else title.text + if isinstance(links, ET.Element): + for link in item_payload.findall(namespace + 'link'): + link_href = link.attrib['href'] if 'href' in link.attrib else '' + if link_href: break + contents = item_payload.find(namespace + 'content') + content_text = '' + if isinstance(contents, ET.Element): + for content in item_payload.findall(namespace + 'content'): + content_text = content.text or '' + if content_text: break + summaries = item_payload.find(namespace + 'summary') + summary_text = '' + if isinstance(summaries, ET.Element): + for summary in item_payload.findall(namespace + 'summary'): + summary_text = summary.text or '' + if summary_text: break + published = item_payload.find(namespace + 'published') + published_text = '' if published == None else published.text + categories = item_payload.find(namespace + 'category') + tags = [] + if isinstance(categories, ET.Element): + for category in item_payload.findall(namespace + 'category'): + if 'term' in category.attrib and category.attrib['term']: + category_term = category.attrib['term'] + if len(category_term) < 20: + tags.append(category_term) + elif len(category_term) < 50: + tags.append(category_term) + if limit and len(tags) > 4: break + + + identifier = item_payload.find(namespace + 'id') + if identifier and identifier.attrib: print(identifier.attrib) + identifier_text = '' if identifier == None else identifier.text + + instances = '' # TODO Check the Blasta database for instances. + + entry = {'content' : content_text, + 'link' : link_href, + 'published' : published_text, + 'summary' : summary_text, + 'tags' : tags, + 'title' : title_text, + 'updated' : published_text} # TODO "Updated" is missing + return entry + +class XmppXep0030: + + async def get_jid_items(self, jid_bare): + try: + condition = text = None + error = False + iq = await self['xep_0030'].get_items(jid=jid_bare) + except (IqError, IqTimeout) as e: + #logger.warning('Chat type could not be determined for {}'.format(jid_bare)) + #logger.error(e) + iq = None + error = True + condition = e.iq['error']['condition'] + text = e.iq['error']['text'] or 'Error' + #if not text: + # # NOTE We might want to set a specific photo for condition remote-server-not-found + # if condition: + # text = 'Could not determine JID type' + # else: + # text = 'Unknown Error' + result = { + 'condition' : condition, + 'error' : error, + 'iq' : iq, + 'text' : text} + return result + + # NOTE + # Feature "urn:xmpp:mucsub:0" is present in both, MUC local and MUC hostname + # Feature "urn:xmpp:serverinfo:0" is present in both, MUC hostname and main hostname + async def get_jid_info(self, jid_bare): + jid_kind = None + try: + error = False + condition = text = None + iq = await self['xep_0030'].get_info(jid=jid_bare) + iq_disco_info = iq['disco_info'] + if iq_disco_info: + features = iq_disco_info['features'] + if 'http://jabber.org/protocol/muc#unique' in features: + jid_kind = 'conference' + elif 'urn:xmpp:mix:core:1' in features: + jid_kind = 'mix' + elif ('muc_moderated' in features or + 'muc_open' in features or + 'muc_persistent' in features or + 'muc_public' in features or + 'muc_semianonymous' in features or + 'muc_unmoderated' in features or + 'muc_unsecured' in features): + jid_kind = 'muc' + else: + for identity in iq_disco_info['identities']: + if identity[0] == 'pubsub' and identity[1] == 'service': + #if 'http://jabber.org/protocol/pubsub' in features: + #if 'http://jabber.org/protocol/pubsub#access-authorize' in features: + #if 'http://jabber.org/protocol/rsm' in features: + jid_kind = 'pubsub' + break + if identity[0] == 'server' and identity[1] == 'im': + jid_kind = 'server' + break + #if identity[0] == 'pubsub' and identity[1] == 'pep': + if identity[0] == 'account': + #if 'urn:xmpp:bookmarks:1#compat-pep' in features: + #if 'urn:xmpp:bookmarks:1#compat' in features: + #if 'urn:xmpp:push:0' in features: + #if 'urn:xmpp:pep-vcard-conversion:0' in features: + #if 'urn:xmpp:sid:0' in features: + + # Also in MIX + #if 'urn:xmpp:mam:2' in features: + #if 'urn:xmpp:mam:2#extended' in features: + jid_kind = 'account' + break + if identity[0] == 'client' and identity[1] == 'bot': + jid_kind = 'bot' + #logger.info('Jabber ID: {}\n' + # 'Chat Type: {}'.format(jid_bare, result)) + else: + iq = condition = text = None + except (IqError, IqTimeout) as e: + #logger.warning('Chat type could not be determined for {}'.format(jid_bare)) + #logger.error(e) + iq = None + error = True + condition = e.iq['error']['condition'] + text = e.iq['error']['text'] or 'Error' + #if not text: + # # NOTE We might want to set a specific photo for condition remote-server-not-found + # if condition: + # text = 'Could not determine JID type' + # else: + # text = 'Unknown Error' + result = { + 'condition' : condition, + 'error' : error, + 'iq' : iq, + 'text' : text, + 'kind' : jid_kind} + return result + + +class XmppXep0045: + + async def get_room_data(self, jid_bare): + return await self['xep_0045'].get_room_config(jid_bare) + + async def get_number_of_participants(self, jid_bare): + return len(await self['xep_0045'].get_roster(jid_bare)) + + +# NOTE: "Item not found", yet is a group chat +# That is, JID has no vcard +# messaging-off@conference.movim.eu + +class XmppXep0054: + + async def get_vcard_data(self, jid_bare): + try: + error = False + condition = text = None + iq = await self['xep_0054'].get_vcard(jid_bare) + except (IqError, IqTimeout) as e: + error = True + condition = e.iq['error']['condition'] + text = e.iq['error']['text'] + if not text: + if condition: + text = 'Could not retrieve vCard' + else: + text = 'Unknown Error' + iq = None + result = { + 'error' : error, + 'condition' : condition, + 'text' : text, + 'iq' : iq} + return result + +class XmppXep0060: + + async def get_node_items(self, jid_bare, node_name, item_ids=None, max_items=None): + try: + if max_items: + iq = await self['xep_0060'].get_items( + jid_bare, node_name, timeout=5) + it = self['xep_0060'].get_items( + jid_bare, node_name, timeout=5, max_items=max_items, iterator=True) + q = rsm.Iq() + q['to'] = jid_bare + q['disco_items']['node'] = node_name + async for item in rsm.ResultIterator(q, 'disco_items', '10'): + print(item['disco_items']['items']) + + else: + iq = await self['xep_0060'].get_items( + jid_bare, node_name, timeout=5, item_ids=item_ids) + result = iq + except IqError as e: + if e.iq['error']['text'] == 'Node not found': + result = 'Node not found' + elif e.iq['error']['condition'] == 'item-not-found': + result = 'Item not found' + else: + result = None + except IqTimeout as e: + result = e + return result + + async def get_node_item_ids(self, jid_bare, node_name): + try: + iq = await self['xep_0030'].get_items( + jid_bare, node_name) + # Broken. See https://codeberg.org/poezio/slixmpp/issues/3548 + #iq = await self['xep_0060'].get_item_ids( + # jid_bare, node_name, timeout=5) + result = iq + except IqError as e: + if e.iq['error']['text'] == 'Node not found': + result = 'Node not found' + elif e.iq['error']['condition'] == 'item-not-found': + result = 'Item not found' + else: + result = None + except IqTimeout as e: + result = e + return result + +class XmppXep0369: + + async def get_room_data(self, jid_bare): + return await self['xep_0369'].get_channel_info(jid_bare) + + +def main(): + filename_configuration = 'configuration.toml' + data = Data.open_file_toml(filename_configuration) + + account = data['account'] + jabber_id = account['xmpp'] + password = account['pass'] + + http_instance = HttpInstance(jabber_id, password) + return http_instance.app + +app = main() + +# FIXME +if __name__ == '__main__': + uvicorn.run(app, host='127.0.0.1', port=8000, reload=True) diff --git a/img/favicon.svg b/img/favicon.svg new file mode 100644 index 0000000..22860dc --- /dev/null +++ b/img/favicon.svg @@ -0,0 +1,109 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/img/xmpp-logo-wordmark-horizontal.svg b/img/xmpp-logo-wordmark-horizontal.svg new file mode 100644 index 0000000..02f6723 --- /dev/null +++ b/img/xmpp-logo-wordmark-horizontal.svg @@ -0,0 +1,123 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/img/xmpp-logo-wordmark-vertical.svg b/img/xmpp-logo-wordmark-vertical.svg new file mode 100644 index 0000000..0c904a7 --- /dev/null +++ b/img/xmpp-logo-wordmark-vertical.svg @@ -0,0 +1,30 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/img/xmpp-logo.svg b/img/xmpp-logo.svg new file mode 100644 index 0000000..a6895bd --- /dev/null +++ b/img/xmpp-logo.svg @@ -0,0 +1,108 @@ + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/photo/README b/photo/README new file mode 100644 index 0000000..9ff95e8 --- /dev/null +++ b/photo/README @@ -0,0 +1 @@ +This directory caches photo files. diff --git a/photo/default.svg b/photo/default.svg new file mode 100644 index 0000000..c4e6ceb --- /dev/null +++ b/photo/default.svg @@ -0,0 +1,53 @@ + + + + + + + + + + + + + diff --git a/qr/README b/qr/README new file mode 100644 index 0000000..906f310 --- /dev/null +++ b/qr/README @@ -0,0 +1 @@ +This directory caches QR code files. diff --git a/xhtml/disco.xhtml b/xhtml/disco.xhtml new file mode 100644 index 0000000..fd729dd --- /dev/null +++ b/xhtml/disco.xhtml @@ -0,0 +1,140 @@ + + + + + + + + + XMPP: {{action}} {{title}} + + + + + + + + + + + + + + + +
+
+ + + + + Download + +
+
+
+ +
+
+
+ + + Download + +
+

{{title}}

+ {% if note %} +

{{note}}

+ {% endif %} + {% if services %} +
+ {% for category in services %} + {% if services[category] %} +

Services ({{category}})

+
+ {% for service in services[category] %} + {% if service['info']['text'] %} +
+

{{service['jid']}}

+
+
+ + {{service['info']['condition']}} + +
+
+ {{service['info']['text']}} +
+ {% else %} +
+

+ {% if service['identity'] and service['identity'][3] %} + {{service['identity'][3]}} + {% else %} + {{service['name']}} + {% endif %} +

+
+
+ 
Jabber ID: {{service['jid']}}
+ {% if service['node'] %} + 
Node Name: {{service['node']}}
+ {% endif %} +
+ {% if service['kind'] %} +
+ 
     Kind: {{service['kind']}}
+
+ {% endif %} + {% if service['identity'] %} +
+ 
 Category: {{service['identity'][0]}}
+
+
+ 
     Type: {{service['identity'][1]}}
+
+ {% endif %} + {% endif %} + {% endfor %} +
+ {% endif %} + {% endfor %} +
+ {% endif %} +
+ 
{{xmpp_uri}}
+
+ {% if exception %} +
+ {{exception}} +
+ {% endif %} + + {% if link_href %} +
+ + {{link_text}} + +
+ {% endif %} + + +
+
+ + {% if message %} +
{{message}}
+ {% endif %} +
+ + diff --git a/xhtml/jid.xhtml b/xhtml/jid.xhtml new file mode 100644 index 0000000..dc5feee --- /dev/null +++ b/xhtml/jid.xhtml @@ -0,0 +1,109 @@ + + + + + + + + + XMPP: {{action}} {{title}} + + + + + + + + + + + + + + {% if selection %} + + {% endif %} + + +
+
+ + + + + Download + +
+
+
+
+ + + Download + +
+

{{title}}

+ {% if filename %} +
+ + + + +
+ {% endif %} + {% if note %} +

{{note}}

+ {% endif %} +
+ 
{{xmpp_uri}}
+
+ {% if exception %} +
+ {{exception}} +
+ {% endif %} + + {% if link_href %} +
+ + {{link_text}} + +
+ {% endif %} + + {% if count %} + + {% endif %} + +
+
+ + {% if message %} +
{{message}}
+ {% endif %} +
+ + diff --git a/xhtml/main.xhtml b/xhtml/main.xhtml new file mode 100644 index 0000000..934ecbd --- /dev/null +++ b/xhtml/main.xhtml @@ -0,0 +1,69 @@ + + + + + + + + + FASI : Welcome + + + + + + + + + + + + + + + +
+
+ + + + + Download + +
+
+
+
+ + + Download + +
+

FASI

+

Fast And Sleek Invite

+
+
+
+ +
+
+ +
+
+ +
+
+
+
+ + + +
+
+
+
+ The Universal Messaging Standard +
+
+ + diff --git a/xhtml/node.xhtml b/xhtml/node.xhtml new file mode 100644 index 0000000..d5659b2 --- /dev/null +++ b/xhtml/node.xhtml @@ -0,0 +1,109 @@ + + + + + + + + + XMPP: {{action}} {{title}} + + + + + + + + + + + + + + + +
+
+ + + + + Download + +
+
+
+ +
+
+
+ + + Download + +
+

{{title}}

+ {% if note %} +

{{note}}

+ {% endif %} + {% if entries %} +
+ {% for entry in entries %} +
+ {{entry['title']}} +
{{entry['content'] or entry['summary']}}
+
{{entry['updated'] or entry['published']}}
+ {% if entry['tags'] %} +
+ Tags: + {% for tag in entry['tags'] %} + {{tag}} + {% endfor %} +
+ {% endif %} +
+ + {{entry['title']}} + +
+
+ {% endfor %} +
+ {% endif %} +
+ 
{{xmpp_uri}}
+
+ {% if exception %} +
+ {{exception}} +
+ {% endif %} + + {% if link_href %} +
+ + {{link_text}} + +
+ {% endif %} + + +
+
+ + {% if message %} +
{{message}}
+ {% endif %} +
+ +