first commit
This commit is contained in:
commit
d1ed318e13
3
.gitignore
vendored
Normal file
3
.gitignore
vendored
Normal file
|
|
@ -0,0 +1,3 @@
|
|||
*.cfg
|
||||
*.swp
|
||||
__pycache__/
|
||||
9
README.md
Normal file
9
README.md
Normal file
|
|
@ -0,0 +1,9 @@
|
|||
# Anonkun
|
||||
By popular demand, I'm building a better anonkun. It doesn't do much right now though. Actual results in the decades to come.
|
||||
|
||||
## Requirements
|
||||
Python 3.6+
|
||||
Python packages: `flask flask_socketio`
|
||||
|
||||
## Todo
|
||||
Rename this project to something that doesn't mean "shit" in weebspeak.
|
||||
88
anonkun.py
Normal file
88
anonkun.py
Normal file
|
|
@ -0,0 +1,88 @@
|
|||
#!/usr/bin/env python3
|
||||
"""
|
||||
Simple file host using Flask.
|
||||
"""
|
||||
import os
|
||||
import time
|
||||
|
||||
from flask import Flask, session, request, abort, redirect, url_for, g, \
|
||||
render_template
|
||||
from flask_socketio import SocketIO, emit
|
||||
|
||||
class ReverseProxied(object):
|
||||
"""
|
||||
Wrap the application in this middleware and configure the
|
||||
front-end server to add these headers, to let you quietly bind
|
||||
this to a URL other than / and to an HTTP scheme that is
|
||||
different than what is used locally.
|
||||
|
||||
In nginx:
|
||||
location /myprefix {
|
||||
proxy_pass http://192.168.0.1:5001;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
|
||||
proxy_set_header X-Scheme $scheme;
|
||||
proxy_set_header X-Script-Name /myprefix;
|
||||
}
|
||||
|
||||
:param app: the WSGI application
|
||||
"""
|
||||
def __init__(self, app):
|
||||
self.app = app
|
||||
|
||||
def __call__(self, environ, start_response):
|
||||
script_name = environ.get('HTTP_X_SCRIPT_NAME', '')
|
||||
if script_name:
|
||||
environ['SCRIPT_NAME'] = script_name
|
||||
path_info = environ['PATH_INFO']
|
||||
if path_info.startswith(script_name):
|
||||
environ['PATH_INFO'] = path_info[len(script_name):]
|
||||
|
||||
scheme = environ.get('HTTP_X_SCHEME', '')
|
||||
if scheme:
|
||||
environ['wsgi.url_scheme'] = scheme
|
||||
return self.app(environ, start_response)
|
||||
|
||||
|
||||
app = Flask(__name__)
|
||||
app.wsgi_app = ReverseProxied(app.wsgi_app)
|
||||
app.config['SECRET_KEY'] = 'secret!'
|
||||
app.config['MAX_CONTENT_LENGTH'] = 16 * 1024 * 1024
|
||||
socketio = SocketIO(app)
|
||||
|
||||
@socketio.on('joined', namespace='/chat')
|
||||
def joined(message):
|
||||
"""
|
||||
Sent by clients when they enter a room.
|
||||
"""
|
||||
print("Client connected.")
|
||||
|
||||
|
||||
@socketio.on('text', namespace='/chat')
|
||||
def text(data):
|
||||
"""
|
||||
Sent by a client when the user entered a new message.
|
||||
"""
|
||||
message = data["msg"]
|
||||
emit('message', {'msg': message})
|
||||
|
||||
|
||||
@app.template_filter("strftime")
|
||||
def unix2string(unix):
|
||||
"""
|
||||
Converts a unix timestamp into a string.
|
||||
"""
|
||||
form = "[%Y-%m-%d %H:%M:%S]"
|
||||
t = time.localtime(unix)
|
||||
return time.strftime(form, t)
|
||||
|
||||
|
||||
messages = [{"name":"Anonymous", "date":1528998539, "message":"lol"}, {"name":"Namefag", "date":1528998521, "message":"kek"}]
|
||||
@app.route("/", methods=["GET", "POST"])
|
||||
def index():
|
||||
if request.method == "GET":
|
||||
return render_template('index.html', messages=messages)
|
||||
message = request.form.get("msg")
|
||||
messages.append(message)
|
||||
#print(message)
|
||||
return redirect(url_for("index"))
|
||||
8
static/socket.io.slim.js
Normal file
8
static/socket.io.slim.js
Normal file
File diff suppressed because one or more lines are too long
52
templates/index.html
Normal file
52
templates/index.html
Normal file
|
|
@ -0,0 +1,52 @@
|
|||
<!DOCTYPE html>
|
||||
<html>
|
||||
<head>
|
||||
<title>Meet the new anonkun.</title>
|
||||
<script type="text/javascript" src="{{ url_for('static', filename='socket.io.slim.js') }}"></script>
|
||||
<script>
|
||||
var socket;
|
||||
var messages_received = [];
|
||||
var tid = setInterval( function () {
|
||||
if ( document.readyState !== 'complete' ) return;
|
||||
clearInterval( tid );
|
||||
|
||||
socket = io.connect('https://' + document.domain + ':' + location.port + '/chat');
|
||||
socket.on('connect', function() {
|
||||
socket.emit('joined', {});
|
||||
});
|
||||
socket.on('message', function(data) {
|
||||
if (messages_received.length >= 50) {
|
||||
message_received.shift()
|
||||
}
|
||||
messages_received.push(data.msg);
|
||||
message_string = '';
|
||||
for (var i = 0; i < messages_received.length; i++) {
|
||||
message_string = message_string + '<tr><td>2018</td><td>Anonymous</td><td>' + messages_received[i] + '</td>';
|
||||
}
|
||||
document.getElementById('messages').innerHTML = message_string;
|
||||
});
|
||||
document.getElementById('text').addEventListener('keypress', function(event) {
|
||||
if (event.key == 'Enter') {
|
||||
text = document.getElementById('text').value;
|
||||
document.getElementById('text').value = '';
|
||||
socket.emit('text', {msg: text});
|
||||
}
|
||||
});
|
||||
}, 100 );
|
||||
</script>
|
||||
</head>
|
||||
<body>
|
||||
<div id="document">
|
||||
<h1>Lol</h1>
|
||||
</div>
|
||||
<div id="messagebox" style="height:120px; width:320px; border:1px solid #ccc; overflow:auto;">
|
||||
{% for message in messages %}
|
||||
<div class="message">
|
||||
<div class="messageHeader">{{ message["name"] }} {{ message["date"] | strftime }}</div>
|
||||
<div class="messageMessage">{{ message["message"] }}</div>
|
||||
</div>
|
||||
{% endfor %}
|
||||
</div>
|
||||
<textarea id="text" rows="3" cols="43" style="resize:none"></textarea>
|
||||
</body>
|
||||
</html>
|
||||
Loading…
Reference in New Issue
Block a user