pch_xyz/sedi-relay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

rewrite default.py

Browse source
This commit is contained in:
gled 2019-07-25 11:54:19 -07:00
parent f34b42ae78
commit d12772dcfb
1 changed files with 79 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

99
relay/default.py
View file

@ -1,36 +1,95 @@
import aiohttp.web import aiohttp.web
import urllib.parse import urllib.parse
from . import app, CONFIG import time
import datetime
from . import app, CONFIG
from .database import DATABASE from .database import DATABASE
host = CONFIG['ap']['host'] host = CONFIG['ap']['host']
note = CONFIG['note'] note = CONFIG['note']
inboxes = DATABASE.get('relay-list', []) START_TIME=time.time()
async def default(request): async def default(request):
targets = '<br>'.join([urllib.parse.urlsplit(target).hostname for target in inboxes]) from .actor import INBOUND_STATS
return aiohttp.web.Response( inboxes = DATABASE.get('relay-list', [])
status=200, target = []
for t in inboxes:
if urllib.parse.urlsplit(t).hostname not in DATABASE.get('backoff-instances',{}):
target.append('<a href=https://%s>%s</a>' % (urllib.parse.urlsplit(t).hostname,urllib.parse.urlsplit(t).hostname))
targets = '</li><li>'.join(target)
err=[]
warn=[]
not_subd = '</li><li>'.join(['<a href=https://%s>%s</a>' % (s,s) for s in DATABASE.get('not-subscribed',[])])
for instance,val in DATABASE.get('backoff-instances',{}).items():
if time.time() - val['ts'] > 86400:
err.append('<a href=https://%s>%s</a>' % (instance,instance))
else:
warn.append("<a href=https://%s>%s</a>' <span class='greyed'>(%s left before stopping attempts)</span>" % (instance,instance,str(datetime.timedelta(seconds=86400-(time.time()-val['ts']))).split(".")[0])) errs='</li><li>'.join(err)
warns='</li><li>'.join(warn)
banned='</li><li>'.join(CONFIG['ap']['blocked_instances'])
return aiohttp.web.Response(
status=200,
content_type="text/html", content_type="text/html",
charset="utf-8", charset="utf-8",
text=""" text="""
<html><head> <html><head>
<title>ActivityPub Relay at {host}</title> <title>ActivityPub Relay at {host}</title>
<style> <style>
a {{ color: #4ea2df; text-decoration: none; }}
a:hover {{ text-decoration: underline; }}
p {{ color: #FFFFFF; font-family: monospace, arial; font-size: 100%; }} p {{ color: #FFFFFF; font-family: monospace, arial; font-size: 100%; }}
body {{ background-color: #000000; }} h4 {{ color: #FFFFFF; font-family: monospace, arial; font-size: 100%; }} html, body {{
</style> margin: 0;
height: 100%;
}}
body {{ background-color: #282c37; }}
#content {{
display: flex;
flex-direction: column;
height: 100%
}}
.greyed {{ color: #606984; }}
main {{
flex: 1;
overflow: auto;
}}
.footer {{
flex-shrink: 0;
font-size: 80%;
background-color: #20232C;
}}
.header {{
text-align: center;
background-color: #20232C;
}}
</style>
</head> </head>
<body> <body>
<p>This is an Activity Relay for fediverse instances.</p> <div id='content'>
<div class='header'>
<p>{note}</p> <p>{note}</p>
<p>For Mastodon instances, you may subscribe to this relay with the address: <a href="https://{host}/inbox">https://{host}/inbox</a></p> <p><i>For Mastodon instances, you may subscribe to this relay with the address: <a href="https://{host}/inbox">https://{host}/inbox</a></i></p>
<p>For Pleroma and other instances, you may subscribe to this relay with the address: <a href="https://{host}/actor">https://{host}/actor</a></p> <p><i>For Pleroma and other instances, you may subscribe to this relay with the address: <a href="https://{host}/actor">https://{host}/actor</a></i></p>
<p>To host your own relay, you may download the code at this address: <a href="https://git.pleroma.social/pleroma/relay">https://git.pleroma.social/pleroma/relay</a></p> <p class="greyed" style='font-size: 80%;'>[ <a href='#registered'>Active ({count})</a> | <a href='#nonvalid'>Invalid ({countf})</a> | <a href='#failing'>In error ({countw})</a> | <a href='#notsubd'>Non subscribed ({countn})</a> | <a href=
<br><p>List of {count} registered instances:<br>{targets}</p> '#unreachable'>Unreachable ({counte})</a> | <a href='#banned'>Banned ({countb})</a> ]</p>
</div>
<main>
<h4><a name='registered'></a>List of {count} registered and active instances:</h4><ul><li>{targets}</li></ul>
<h4><a name='failing'></a>List of {countw} instances with errors (last failure to deliver a post is less than a day, not all posts are sent, only periodic retries):</h4><ul><li>{warnings}</li></ul>
<h4><a name='notsubd'></a>List of {countn} instances trying to send posts and not following the relay (those posts are ignored and nothing is sent to those instances):</h4><span class='greyed'><ul><li>{nosub}</li></ul></span>
<h4><a name='unreachable'></a>List of {counte} unreachable instances (not being delivered anything anymore till we receive a post from them again):</h4><ul><li>{errors}</li></ul>
<h4 class='greyed'><a name='banned'></a>There are currently {countb} instances banned in the configuration file of this relay.</h4>
</main>
<div class='footer'>
<p class="greyed" style='text-align: center;'><i>We processed {statuscounts} statuses and rejected {rejectcount} since last restart, {starttime} ago.</i></p>
<p class='greyed' style='text-align: center'>To host your own relay, you may download the code at this address: <a href="https://git.pleroma.social/pleroma/relay">https://git.pleroma.social/pleroma/relay</a></p>
</div>
</div>
</body></html> </body></html>
""".format(host=host, note=note,targets=targets,count=len(inboxes))) """.format(host=host, note=note,targets=targets,count=len(target),warnings=warns,countw=len(warn),errors=errs,counte=len(err),nosub=not_subd,countn=len(DATABASE.get('not-subscribed',[])),starttime=str(datetime.timede
lta(seconds=(time.time()-START_TIME))).split(".")[0],statuscounts=INBOUND_STATS['processed']+INBOUND_STATS['rejected'],rejectcount=INBOUND_STATS['rejected'],countb=len(CONFIG['ap']['blocked_instances']),banned=banned))
app.router.add_get('/', default) app.router.add_get('/', default)