Compare commits
5 Commits
Author | SHA1 | Date |
---|---|---|
Ben Harris | 1538aad56e | |
khuxkm | 9488ade7fb | |
Ben Harris | ee85dfe5ab | |
Ben Harris | 5c708b436b | |
Ben Harris | 68253447b7 |
36
README.md
36
README.md
|
@ -5,11 +5,41 @@ miraculously shit out a fully functional, text-driven community bulletin board.
|
|||
Requires Python 3.4 and up for the server and the official TUI client (clients/urwid/).
|
||||
|
||||
![AAAAAAAAAAAAAAAAAAAA](readme.png)
|
||||
<center><h2>Look Ma, it boots !!11!</h2></center>
|
||||
<div style="text-align: center;"><h2>Look Ma, it boots !!11!</h2></div>
|
||||
|
||||
It's all driven by an API sitting on top of CherryPy. Currently it does not
|
||||
It's all driven by an API sitting on top of CherryPy. Currently, it does not
|
||||
serve HTML but this is planned for the (distant?) future.
|
||||
|
||||
The two official client implementations are a stand alone TUI client for
|
||||
The two official client implementations are a standalone TUI client for
|
||||
the unix terminal, and GNU Emacs. The API is simple and others are welcome
|
||||
to join the party at some point.
|
||||
|
||||
## Setup Instructions
|
||||
|
||||
1. Make a virtual env
|
||||
```
|
||||
python3 -m venv venv
|
||||
source venv/bin/activate
|
||||
```
|
||||
|
||||
2. Run setup.sh
|
||||
```
|
||||
./setup.sh venv/bin/python3
|
||||
```
|
||||
|
||||
3. Add systemd service (optional)
|
||||
```
|
||||
cp contrib/bbj.service /etc/systemd/system/
|
||||
$EDITOR /etc/systemd/system/bbj.service
|
||||
systemctl enable --now bbj
|
||||
```
|
||||
Be sure to edit bbj.service with your venv and paths.
|
||||
|
||||
4. Make a client script
|
||||
|
||||
Create a script somewhere in your `$PATH` (I used `/usr/local/bin/bbj`) with the following contents,
|
||||
adapting the path to your install:
|
||||
```shell
|
||||
#!/bin/sh
|
||||
exec /srv/bbj/venv/bin/python3 /srv/bbj/clients/urwid/main.py
|
||||
```
|
||||
|
|
32
bundle.py
32
bundle.py
|
@ -1,32 +0,0 @@
|
|||
import zipfile
|
||||
import glob
|
||||
import os
|
||||
|
||||
|
||||
# TODO: should we include .pyc files?
|
||||
# TODO: add urwid source into the repo somewhere
|
||||
|
||||
files = {
|
||||
'__main__.py': 'clients/urwid/main.py',
|
||||
'network.py': 'clients/network_client.py',
|
||||
'urwid': 'env/lib/python3.8/site-packages/urwid/*.py',
|
||||
}
|
||||
|
||||
with open('bbj_demo', 'wb') as f:
|
||||
f.write(b"#!/usr/bin/env python3\n")
|
||||
with zipfile.ZipFile(f, 'w', compression=zipfile.ZIP_DEFLATED) as z:
|
||||
z.comment = b'BBJ'
|
||||
for name, source in files.items():
|
||||
if '*' in source:
|
||||
dirname = name
|
||||
for path in sorted(glob.glob(source)):
|
||||
name = dirname + '/' + os.path.basename(path)
|
||||
z.write(path, name)
|
||||
else:
|
||||
z.write(source, name)
|
||||
try:
|
||||
mask = os.umask(0)
|
||||
os.umask(mask)
|
||||
except OSError:
|
||||
mask = 0
|
||||
os.chmod(z.filename, 0o777&~mask)
|
|
@ -1,15 +1,15 @@
|
|||
from urllib.error import URLError
|
||||
import json
|
||||
import urllib.request as url
|
||||
from hashlib import sha256
|
||||
from time import time
|
||||
import json
|
||||
from urllib.error import URLError
|
||||
|
||||
|
||||
class BBJ(object):
|
||||
# this module isnt exactly complete. The below description claims
|
||||
# this module isn't exactly complete. The below description claims
|
||||
# `all of its endpoints are mapped to native methods` though this
|
||||
# is not yet true. The documentation for the API is not yet
|
||||
# complete, and neither is this client. Currently this module is
|
||||
# complete, and neither is this client. Currently, this module is
|
||||
# being adapted to fit the needs of the urwid client. As it evolves,
|
||||
# and the rest of the project evolves, this client will be completed
|
||||
# and well documented.
|
||||
|
@ -44,11 +44,12 @@ class BBJ(object):
|
|||
except UserWarning as e:
|
||||
assert e.code == 4
|
||||
print(e.description)
|
||||
# want the raw error object? thats weird, but whatever.
|
||||
# want the raw error object? that's weird, but whatever.
|
||||
return e.body
|
||||
|
||||
See the offical API error documentation for more details.
|
||||
See the official API error documentation for more details.
|
||||
"""
|
||||
|
||||
def __init__(self, host="127.0.0.1", port=7099, https=False):
|
||||
"""
|
||||
Optionally takes port and host as kwargs. It will immediately
|
||||
|
@ -80,22 +81,20 @@ class BBJ(object):
|
|||
except URLError:
|
||||
raise URLError("Cannot connect to %s (is the server down?)" % self.base[0:-2])
|
||||
|
||||
|
||||
def __call__(self, *args, **kwargs):
|
||||
"""
|
||||
Calling the network object itself is exactly the same as calling
|
||||
it's .request() method.
|
||||
its .request() method.
|
||||
"""
|
||||
return self.request(*args, **kwargs)
|
||||
|
||||
|
||||
def _hash(self, string):
|
||||
@staticmethod
|
||||
def _hash(string):
|
||||
"""
|
||||
Handy function to hash a password and return it.
|
||||
"""
|
||||
return sha256(bytes(string, "utf8")).hexdigest()
|
||||
|
||||
|
||||
def request(self, endpoint, **params):
|
||||
"""
|
||||
Takes the string endpoint, and a variable number of kwargs
|
||||
|
@ -104,7 +103,7 @@ class BBJ(object):
|
|||
raised.
|
||||
|
||||
However, one kwarg is magical here: no_auth. If you include
|
||||
this, its not sent with the request, it just disables the
|
||||
this, it's not sent with the request, it just disables the
|
||||
sending of auth info when it is available (for more info,
|
||||
read __init__'s documentation).
|
||||
|
||||
|
@ -139,7 +138,6 @@ class BBJ(object):
|
|||
|
||||
return value
|
||||
|
||||
|
||||
def raise_exception(self, error_object):
|
||||
"""
|
||||
Takes an API error object and raises the appropriate exception,
|
||||
|
@ -158,7 +156,7 @@ class BBJ(object):
|
|||
except UserWarning as e:
|
||||
assert e.code == 4
|
||||
print(e.description)
|
||||
# want the raw error object? thats weird, but whatever.
|
||||
# want the raw error object? that's weird, but whatever.
|
||||
return e.body
|
||||
"""
|
||||
description = error_object["description"]
|
||||
|
@ -178,7 +176,6 @@ class BBJ(object):
|
|||
e.code, e.description, e.body = code, description, error_object
|
||||
raise e
|
||||
|
||||
|
||||
def update_instance_info(self):
|
||||
"""
|
||||
Stores configuration info for the connected BBJ server.
|
||||
|
@ -192,10 +189,9 @@ class BBJ(object):
|
|||
response = self("instance_info")
|
||||
self.instance_info = response["data"]
|
||||
|
||||
|
||||
def validate(self, key, value, exception=AssertionError):
|
||||
"""
|
||||
Uses the server's db_validate method to verify the validty
|
||||
Uses the server's db_validate method to verify the validity
|
||||
of `value` by `key`. If it is invalid, kwarg exception (default
|
||||
AssertionError) is raised with the exception containing the
|
||||
attribute .description as the server's reason. Exception can
|
||||
|
@ -203,7 +199,7 @@ class BBJ(object):
|
|||
|
||||
Examples:
|
||||
|
||||
# this will fail bacause the server wont allow newlines in usernames.
|
||||
# this will fail because the server won't allow newlines in usernames.
|
||||
try:
|
||||
bbj.validate("user_name", "des\nvox")
|
||||
except AssertionError as e:
|
||||
|
@ -229,7 +225,6 @@ class BBJ(object):
|
|||
|
||||
return True
|
||||
|
||||
|
||||
def validate_all(self, keys_and_values, exception=AssertionError):
|
||||
"""
|
||||
Takes a single iterable object as its argument, containing
|
||||
|
@ -263,12 +258,11 @@ class BBJ(object):
|
|||
self.validate(key, value, exception) for key, value in keys_and_values
|
||||
]
|
||||
|
||||
|
||||
def set_credentials(self, user_name, user_auth, hash_auth=True, check_validity=True):
|
||||
"""
|
||||
Internalizes user_name and user_auth. Unless hash_auth=False is
|
||||
specified, user_auth is assumed to be an unhashed password
|
||||
string and it gets hashed with sha256. If you want to handle
|
||||
string, and it gets hashed with sha256. If you want to handle
|
||||
hashing yourself, make sure to disable that.
|
||||
|
||||
Unless check_validity is set to false, the new credentials are
|
||||
|
@ -290,7 +284,7 @@ class BBJ(object):
|
|||
except ConnectionRefusedError:
|
||||
# bad auth info
|
||||
except ValueError:
|
||||
# paramter validation failed or the user is not registered
|
||||
# parameter validation failed or the user is not registered
|
||||
|
||||
# you can handle hashing yourself if you want
|
||||
password = input("Enter your password:")
|
||||
|
@ -312,7 +306,6 @@ class BBJ(object):
|
|||
self.user = self("get_me")["data"]
|
||||
return True
|
||||
|
||||
|
||||
def validate_credentials(self, user_name, user_auth, exception=True):
|
||||
"""
|
||||
Pings the server to check that user_name can be authenticated with
|
||||
|
@ -351,7 +344,6 @@ class BBJ(object):
|
|||
raise e
|
||||
return False
|
||||
|
||||
|
||||
def user_is_registered(self, user_name):
|
||||
"""
|
||||
Returns True or False whether user_name is registered
|
||||
|
@ -365,7 +357,6 @@ class BBJ(object):
|
|||
|
||||
return response["data"]
|
||||
|
||||
|
||||
def user_register(self, user_name, user_auth, hash_auth=True, set_as_user=True):
|
||||
"""
|
||||
Register user_name into the system with user_auth. Unless hash_auth
|
||||
|
@ -406,7 +397,6 @@ class BBJ(object):
|
|||
|
||||
return response
|
||||
|
||||
|
||||
def user_update(self, **params):
|
||||
"""
|
||||
Update the user's data on the server. The new parameters
|
||||
|
@ -422,7 +412,6 @@ class BBJ(object):
|
|||
self.user = self("get_me")["data"]
|
||||
return response["data"]
|
||||
|
||||
|
||||
def user_get(self, user_id_or_name):
|
||||
"""
|
||||
Return a full user object by their id or username.
|
||||
|
@ -432,13 +421,12 @@ class BBJ(object):
|
|||
same objects. You shouldn't use this method when a usermap
|
||||
is provided.
|
||||
|
||||
If the user element isnt found, ValueError is raised.
|
||||
If the user element isn't found, ValueError is raised.
|
||||
See also `user_is_registered`
|
||||
"""
|
||||
response = self("user_get", target_user=user_id_or_name)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def thread_index(self, include_op=False):
|
||||
"""
|
||||
Returns a tuple where [0] is a list of all threads ordered by
|
||||
|
@ -453,7 +441,6 @@ class BBJ(object):
|
|||
response = self("thread_index", include_op=include_op)
|
||||
return response["data"], response["usermap"]
|
||||
|
||||
|
||||
def thread_load(self, thread_id, format=None, op_only=False):
|
||||
"""
|
||||
Returns a tuple where [0] is a thread object and [1] is a usermap object.
|
||||
|
@ -469,7 +456,6 @@ class BBJ(object):
|
|||
format=format, thread_id=thread_id, op_only=op_only)
|
||||
return response["data"], response["usermap"]
|
||||
|
||||
|
||||
def thread_create(self, title, body):
|
||||
"""
|
||||
Submit a new thread, and return its new object. Requires the
|
||||
|
@ -480,7 +466,6 @@ class BBJ(object):
|
|||
response = self("thread_create", title=title, body=body)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def thread_reply(self, thread_id, body):
|
||||
"""
|
||||
Submits a new reply to a thread and returns the new object.
|
||||
|
@ -489,10 +474,9 @@ class BBJ(object):
|
|||
response = self("thread_reply", thread_id=thread_id, body=body)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def fake_message(self, body="!!", format="sequential", author=None, post_id=0):
|
||||
"""
|
||||
Produce a a valid message object with `body`. Useful for
|
||||
Produce a valid message object with `body`. Useful for
|
||||
testing and can also be used mimic server messages in a
|
||||
client.
|
||||
"""
|
||||
|
@ -506,7 +490,6 @@ class BBJ(object):
|
|||
"thread_id": "gibberish"
|
||||
}
|
||||
|
||||
|
||||
def format_message(self, body, format="sequential"):
|
||||
"""
|
||||
Send `body` to the server to be formatted according to `format`,
|
||||
|
@ -515,7 +498,6 @@ class BBJ(object):
|
|||
response = self("format_message", body=body, format=format)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def message_delete(self, thread_id, post_id):
|
||||
"""
|
||||
Delete message `post_id` from `thread_id`. The same rules apply
|
||||
|
@ -526,11 +508,10 @@ class BBJ(object):
|
|||
response = self("delete_post", thread_id=thread_id, post_id=post_id)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def edit_query(self, thread_id, post_id):
|
||||
"""
|
||||
Queries ther server database to see if a post can
|
||||
be edited by the logged in user. thread_id and
|
||||
Queries the database to see if a post can
|
||||
be edited by the logged-in user. thread_id and
|
||||
post_id are required.
|
||||
|
||||
Returns a message object on success, or raises
|
||||
|
@ -539,11 +520,10 @@ class BBJ(object):
|
|||
response = self("edit_query", thread_id=thread_id, post_id=int(post_id))
|
||||
return response["data"]
|
||||
|
||||
|
||||
def can_edit(self, thread_id, post_id):
|
||||
"""
|
||||
Return bool True/False that the post at thread_id | post_id
|
||||
can be edited by the logged in user. Will not raise UserWarning.
|
||||
can be edited by the logged-in user. Will not raise UserWarning.
|
||||
"""
|
||||
try:
|
||||
result = bool(self.edit_query(thread_id, post_id))
|
||||
|
@ -551,7 +531,6 @@ class BBJ(object):
|
|||
result = False
|
||||
return result
|
||||
|
||||
|
||||
def edit_message(self, thread_id, post_id, new_body):
|
||||
"""
|
||||
Requires the thread_id and post_id. The edit flag is then
|
||||
|
@ -566,7 +545,6 @@ class BBJ(object):
|
|||
post_id=post_id, body=new_body)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def set_post_raw(self, thread_id, post_id, value):
|
||||
"""
|
||||
This is a subset of `edit_message` that retains the old
|
||||
|
@ -581,7 +559,6 @@ class BBJ(object):
|
|||
value=bool(value))
|
||||
return response["data"]
|
||||
|
||||
|
||||
def user_is_admin(self, user_name_or_id):
|
||||
"""
|
||||
Return boolean True or False whether the given user identifier
|
||||
|
@ -591,18 +568,16 @@ class BBJ(object):
|
|||
response = self("is_admin", target_user=user_name_or_id)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def thread_set_pin(self, thread_id, new_status):
|
||||
"""
|
||||
Set whether a thread should be pinned or not. new_status
|
||||
is evaluated as a boolean, and given that the logged in
|
||||
is evaluated as a boolean, and given that the logged-in
|
||||
user is an admin, the thread is set to this status on
|
||||
the server, and the boolean is returned.
|
||||
"""
|
||||
response = self("thread_set_pin", thread_id=thread_id, value=new_status)
|
||||
return response["data"]
|
||||
|
||||
|
||||
def message_feed(self, time, format=None):
|
||||
"""
|
||||
Returns a special object representing all activity on the board since
|
||||
|
@ -628,7 +603,7 @@ class BBJ(object):
|
|||
objects from the usermap object.
|
||||
|
||||
The "messages" array is already sorted by submission time, newest
|
||||
first. The order in the threads object is undefined and you should
|
||||
first. The order in the threads object is undefined, and you should
|
||||
instead use their `last_mod` attribute if you intend to list them
|
||||
out visually.
|
||||
|
||||
|
|
File diff suppressed because it is too large
Load Diff
|
@ -2,6 +2,6 @@
|
|||
"port": 7099,
|
||||
"host": "127.0.0.1",
|
||||
"instance_name": "BBJ",
|
||||
"allow_anon": True,
|
||||
"debug": False
|
||||
"allow_anon": true,
|
||||
"debug": false
|
||||
}
|
|
@ -0,0 +1,16 @@
|
|||
[Unit]
|
||||
Description=bbj daemon
|
||||
After=network-online.target
|
||||
|
||||
[Service]
|
||||
Type=simple
|
||||
WorkingDirectory=/srv/bbj/bbj
|
||||
ExecStart=/srv/bbj/bbj/venv/bin/python3 server.py
|
||||
User=bbj
|
||||
Restart=always
|
||||
RestartSec=5
|
||||
StartLimitInterval=60s
|
||||
StartLimitBurst=3
|
||||
|
||||
[Install]
|
||||
WantedBy=default.target
|
|
@ -0,0 +1,2 @@
|
|||
#!/bin/sh
|
||||
exec /srv/bbj/venv/bin/python3 /srv/bbj/clients/urwid/main.py
|
|
@ -0,0 +1 @@
|
|||
theme: jekyll-theme-midnight
|
|
@ -12,7 +12,7 @@ at the root:
|
|||
|
||||
`http://server.com/api/endpoint_here`
|
||||
|
||||
The body of your request contains all of it's argument fields, instead of
|
||||
The body of your request contains all of its argument fields, instead of
|
||||
using URL parameters. As a demonstration, to call `thread_create`,
|
||||
it requires two arguments: `title`, and `body`. We put those argument
|
||||
names at the root of the json object, and their values are the info
|
||||
|
@ -33,13 +33,13 @@ GET these if you so choose.
|
|||
|
||||
For all endpoints, argument keys that are not consumed by the endpoint are
|
||||
ignored. Posting an object with a key/value pair of `"sandwich": True` will
|
||||
not clog up any pipes :) In the same vein, endpoints who dont take arguments
|
||||
not clog up any pipes :) In the same vein, endpoints who don't take arguments
|
||||
don't care if you supply them anyway.
|
||||
|
||||
## Output
|
||||
|
||||
BBJ returns data in a consistently formatted json object. The base object
|
||||
has three keys: `data`, `usermap`, and `error`. Visualizied:
|
||||
has three keys: `data`, `usermap`, and `error`. Visualized:
|
||||
|
||||
```javascript
|
||||
{
|
||||
|
@ -74,7 +74,7 @@ objects. BBJ handles users entirely by an ID system, meaning any references
|
|||
to them inside of response data will not include vital information like their
|
||||
username, or their profile information. Instead, we fetch those values from
|
||||
this usermap object. All of it's root keys are user_id's and their values
|
||||
are user objects. It should be noted that the anonymous user has it's own
|
||||
are user objects. It should be noted that the anonymous user has its own
|
||||
ID and profile object as well.
|
||||
|
||||
### error
|
||||
|
@ -121,7 +121,7 @@ is correct for the given user.
|
|||
Requires the arguments `thread_id` and `post_id`.
|
||||
|
||||
Delete a message from a thread. The same rules apply
|
||||
here as `edit_post` and `edit_query`: the logged in user
|
||||
here as `edit_post` and `edit_query`: the logged-in user
|
||||
must either be the one who posted the message within 24hrs,
|
||||
or have admin rights. The same error descriptions and code
|
||||
are returned on falilure. Boolean true is returned on
|
||||
|
@ -215,7 +215,7 @@ you can access metadata for these threads by the `threads` object
|
|||
which is also provided.
|
||||
|
||||
The `messages` array is already sorted by submission time, newest
|
||||
first. The order in the threads object is undefined and you should
|
||||
first. The order in the threads object is undefined, and you should
|
||||
instead use their `last_mod` attribute if you intend to list them
|
||||
out visually.
|
||||
|
||||
|
@ -319,7 +319,7 @@ for the original post.
|
|||
Returns the thread object with all of its messages loaded.
|
||||
Requires the argument `thread_id`. `format` may also be
|
||||
specified as a formatter to run the messages through.
|
||||
Currently only "sequential" is supported.
|
||||
Currently, only "sequential" is supported.
|
||||
|
||||
You may also supply the parameter `op_only`. When it's value
|
||||
is non-nil, the messages array will only include post_id 0 (the first)
|
||||
|
|
|
@ -23,7 +23,7 @@ users.
|
|||
|
||||
* **Code 0**: Malformed but non-empty json input. An empty json input where it is required is handled by code 3. This is just decoding errors. The exception text is returned as description.
|
||||
|
||||
* **Code 1**: Internal server error. A short representation of the internal exception as well as the code the server logged it as is returned in the description. Your clients cannot recover from this class of error, and its probably not your fault if you encounter it. If you ever get one, file a bug report.
|
||||
* **Code 1**: Internal server error. A short representation of the internal exception as well as the code the server logged it as is returned in the description. Your clients cannot recover from this class of error, and it's probably not your fault if you encounter it. If you ever get one, file a bug report.
|
||||
|
||||
* **Code 2**: Server HTTP error: This is similar to the above but captures errors for the HTTP server rather than BBJs own codebase. The description contains the HTTP error code and server description. This notably covers 404s and thus invalid endpoint names. The HTTP error code is left intact, so you may choose to let your HTTP library or tool of choice handle these for you.
|
||||
|
||||
|
|
|
@ -120,7 +120,7 @@ users.</p>
|
|||
<p><strong>Code 0</strong>: Malformed but non-empty json input. An empty json input where it is required is handled by code 3. This is just decoding errors. The exception text is returned as description.</p>
|
||||
</li>
|
||||
<li>
|
||||
<p><strong>Code 1</strong>: Internal server error. A short representation of the internal exception as well as the code the server logged it as is returned in the description. Your clients cannot recover from this class of error, and its probably not your fault if you encounter it. If you ever get one, file a bug report.</p>
|
||||
<p><strong>Code 1</strong>: Internal server error. A short representation of the internal exception as well as the code the server logged it as is returned in the description. Your clients cannot recover from this class of error, and It's probably not your fault if you encounter it. If you ever get one, file a bug report.</p>
|
||||
</li>
|
||||
<li>
|
||||
<p><strong>Code 2</strong>: Server HTTP error: This is similar to the above but captures errors for the HTTP server rather than BBJs own codebase. The description contains the HTTP error code and server description. This notably covers 404s and thus invalid endpoint names. The HTTP error code is left intact, so you may choose to let your HTTP library or tool of choice handle these for you.</p>
|
||||
|
|
|
@ -107,7 +107,7 @@ attributes like a more traditional forum. Registration is optional and there
|
|||
are only minimal restrictions on anonymous participation.</p>
|
||||
<p><img alt="screenshot" src="./img/screenshot.png" /></p>
|
||||
<p>Being a command-line-oriented text board, BBJ has no avatars or file sharing
|
||||
capabilties, so its easier to administrate and can't be used to distribute illegal
|
||||
capabilties, so it's easier to administrate and can't be used to distribute illegal
|
||||
content like imageboards. It has very few dependancies and is easy to set up.</p>
|
||||
<p>The API is simple and doesn't use require complex authorization schemes or session management.
|
||||
It is fully documented on this site (though the verbage is still being revised for friendliness)</p></div>
|
||||
|
|
|
@ -13,10 +13,10 @@ define(['module'], function (module) {
|
|||
|
||||
var text, fs, Cc, Ci, xpcIsWindows,
|
||||
progIds = ['Msxml2.XMLHTTP', 'Microsoft.XMLHTTP', 'Msxml2.XMLHTTP.4.0'],
|
||||
xmlRegExp = /^\s*<\?xml(\s)+version=[\'\"](\d)*.(\d)*[\'\"](\s)*\?>/im,
|
||||
xmlRegExp = /^\s*<\?xml(\s)+version=['"](\d)*.(\d)*['"](\s)*\?>/im,
|
||||
bodyRegExp = /<body[^>]*>\s*([\s\S]+)\s*<\/body>/im,
|
||||
hasLocation = typeof location !== 'undefined' && location.href,
|
||||
defaultProtocol = hasLocation && location.protocol && location.protocol.replace(/\:/, ''),
|
||||
defaultProtocol = hasLocation && location.protocol && location.protocol.replace(/:/, ''),
|
||||
defaultHostName = hasLocation && location.hostname,
|
||||
defaultPort = hasLocation && (location.port || undefined),
|
||||
buildMap = {},
|
||||
|
@ -116,7 +116,7 @@ define(['module'], function (module) {
|
|||
};
|
||||
},
|
||||
|
||||
xdRegExp: /^((\w+)\:)?\/\/([^\/\\]+)/,
|
||||
xdRegExp: /^((\w+):)?\/\/([^\/\\]+)/,
|
||||
|
||||
/**
|
||||
* Is an URL on another domain. Only works for browser use, returns
|
||||
|
|
|
@ -4,6 +4,4 @@
|
|||
# Nothing magical here.
|
||||
|
||||
python3 ./mkendpoints.py
|
||||
cd ./docs
|
||||
mkdocs build
|
||||
cd ..
|
||||
(cd docs; mkdocs build)
|
||||
|
|
|
@ -12,7 +12,7 @@ def geterr(obj):
|
|||
error = obj.get("error")
|
||||
if not error:
|
||||
return False
|
||||
return (error["code"], error["description"])
|
||||
return error["code"], error["description"]
|
||||
|
||||
|
||||
def register_prompt(user, initial=True):
|
||||
|
|
|
@ -1,8 +1,8 @@
|
|||
from time import time
|
||||
|
||||
from src import db
|
||||
from src import formatting
|
||||
from src import schema
|
||||
from time import time
|
||||
from src import db
|
||||
|
||||
|
||||
endpoints = {
|
||||
"check_auth": ["user", "auth_hash"],
|
||||
|
@ -20,7 +20,6 @@ endpoints = {
|
|||
"user_name_to_id": ["target_user"]
|
||||
}
|
||||
|
||||
|
||||
authless = [
|
||||
"is_registered",
|
||||
"user_register"
|
||||
|
@ -58,7 +57,7 @@ def is_registered(json):
|
|||
|
||||
|
||||
def check_auth(json):
|
||||
"Returns true or false whether auth_hashes matches user."
|
||||
"""Returns true or false whether auth_hashes matches user."""
|
||||
return bool(db.user_auth(json["user"], json["auth_hash"]))
|
||||
|
||||
|
||||
|
|
|
@ -0,0 +1,3 @@
|
|||
CherryPy~=18.6.1
|
||||
Markdown~=3.3.6
|
||||
urwid~=2.1.2
|
42
server.py
42
server.py
|
@ -1,16 +1,18 @@
|
|||
from src.exceptions import BBJException, BBJParameterError, BBJUserError
|
||||
from src import db, schema, formatting
|
||||
from functools import wraps
|
||||
from uuid import uuid1
|
||||
from sys import argv
|
||||
import traceback
|
||||
import cherrypy
|
||||
import sqlite3
|
||||
import json
|
||||
import sqlite3
|
||||
import traceback
|
||||
from functools import wraps
|
||||
from sys import argv
|
||||
from uuid import uuid1
|
||||
|
||||
import cherrypy
|
||||
|
||||
from src import db, schema, formatting
|
||||
from src.exceptions import BBJException, BBJParameterError, BBJUserError
|
||||
|
||||
dbname = "data.sqlite"
|
||||
|
||||
# any values here may be overrided in the config.json. Any values not listed
|
||||
# any values here may be overridden in the config.json. Any values not listed
|
||||
# here will have no effect on the server.
|
||||
default_config = {
|
||||
"admins": [],
|
||||
|
@ -29,7 +31,7 @@ try:
|
|||
# The application will never store a config value
|
||||
# as the NoneType, so users may set an option as
|
||||
# null in their file to reset it to default
|
||||
if key not in app_config or app_config[key] == None:
|
||||
if key not in app_config or app_config[key] is None:
|
||||
app_config[key] = default_value
|
||||
# else just use the defaults
|
||||
except FileNotFoundError:
|
||||
|
@ -217,6 +219,7 @@ class API(object):
|
|||
validate(args, ["user_name", "auth_hash"])
|
||||
return db.user_register(
|
||||
database, args["user_name"], args["auth_hash"])
|
||||
|
||||
user_register.doctype = "Users"
|
||||
user_register.arglist = (
|
||||
("user_name", "string: the desired display name"),
|
||||
|
@ -240,6 +243,7 @@ class API(object):
|
|||
no_anon_hook(user, "Anons cannot modify their account.")
|
||||
validate(args, []) # just make sure its not empty
|
||||
return db.user_update(database, user, args)
|
||||
|
||||
user_update.doctype = "Users"
|
||||
user_update.arglist = (
|
||||
("Any of the following may be submitted", ""),
|
||||
|
@ -257,6 +261,7 @@ class API(object):
|
|||
including your `auth_hash`.
|
||||
"""
|
||||
return user
|
||||
|
||||
get_me.doctype = "Users"
|
||||
get_me.arglist = (("", ""),)
|
||||
|
||||
|
@ -281,6 +286,7 @@ class API(object):
|
|||
for user in users
|
||||
}
|
||||
return list(users)
|
||||
|
||||
user_map.doctype = "Tools"
|
||||
user_map.arglist = (("", ""),)
|
||||
|
||||
|
@ -292,6 +298,7 @@ class API(object):
|
|||
validate(args, ["target_user"])
|
||||
return db.user_resolve(
|
||||
database, args["target_user"], return_false=False, externalize=True)
|
||||
|
||||
user_get.doctype = "Users"
|
||||
user_get.arglist = (
|
||||
("target_user", "string: either a user_name or a user_id"),
|
||||
|
@ -305,6 +312,7 @@ class API(object):
|
|||
"""
|
||||
validate(args, ["target_user"])
|
||||
return bool(db.user_resolve(database, args["target_user"]))
|
||||
|
||||
user_is_registered.doctype = "Users"
|
||||
user_is_registered.arglist = (
|
||||
("target_user", "string: either a user_name or a user_id"),
|
||||
|
@ -320,6 +328,7 @@ class API(object):
|
|||
user = db.user_resolve(
|
||||
database, args["target_user"], return_false=False)
|
||||
return args["target_hash"].lower() == user["auth_hash"].lower()
|
||||
|
||||
check_auth.doctype = "Authorization"
|
||||
check_auth.arglist = (
|
||||
("target_user", "string: either a user_name or a user_id"),
|
||||
|
@ -338,6 +347,7 @@ class API(object):
|
|||
threads = db.thread_index(database, include_op=args.get("include_op"))
|
||||
cherrypy.thread_data.usermap = create_usermap(database, threads, True)
|
||||
return threads
|
||||
|
||||
thread_index.doctype = "Threads & Messages"
|
||||
thread_index.arglist = (
|
||||
("OPTIONAL: include_op", "boolean: Include a `messages` object containing the original post"),
|
||||
|
@ -382,6 +392,7 @@ class API(object):
|
|||
|
||||
do_formatting(args.get("format"), feed["messages"])
|
||||
return feed
|
||||
|
||||
message_feed.doctype = "Threads & Messages"
|
||||
message_feed.arglist = (
|
||||
("time", "int/float: epoch/unix time of the earliest point of interest"),
|
||||
|
@ -405,6 +416,7 @@ class API(object):
|
|||
cherrypy.thread_data.usermap = \
|
||||
create_usermap(database, thread["messages"])
|
||||
return thread
|
||||
|
||||
thread_create.doctype = "Threads & Messages"
|
||||
thread_create.arglist = (
|
||||
("body", "string: The body of the first message"),
|
||||
|
@ -426,6 +438,7 @@ class API(object):
|
|||
return db.thread_reply(
|
||||
database, user["user_id"], args["thread_id"],
|
||||
args["body"], args.get("send_raw"))
|
||||
|
||||
thread_reply.doctype = "Threads & Messages"
|
||||
thread_reply.arglist = (
|
||||
("thread_id", "string: the id for the thread this message should post to."),
|
||||
|
@ -451,6 +464,7 @@ class API(object):
|
|||
create_usermap(database, thread["messages"])
|
||||
do_formatting(args.get("format"), thread["messages"])
|
||||
return thread
|
||||
|
||||
thread_load.doctype = "Threads & Messages"
|
||||
thread_load.arglist = (
|
||||
("thread_id", "string: the thread to load."),
|
||||
|
@ -484,6 +498,7 @@ class API(object):
|
|||
return db.message_edit_commit(
|
||||
database, user["user_id"], args["thread_id"],
|
||||
args["post_id"], args["body"], args.get("send_raw"))
|
||||
|
||||
edit_post.doctype = "Threads & Messages"
|
||||
edit_post.arglist = (
|
||||
("thread_id", "string: the thread the message was posted in."),
|
||||
|
@ -510,6 +525,7 @@ class API(object):
|
|||
validate(args, ["thread_id", "post_id"])
|
||||
return db.message_delete(
|
||||
database, user["user_id"], args["thread_id"], args["post_id"])
|
||||
|
||||
delete_post.doctype = "Threads & Messages"
|
||||
delete_post.arglist = (
|
||||
("thread_id", "string: the id of the thread this message was posted in."),
|
||||
|
@ -539,6 +555,7 @@ class API(object):
|
|||
database, user["user_id"],
|
||||
args["thread_id"], args["post_id"],
|
||||
None, args["value"], None)
|
||||
|
||||
set_post_raw.doctype = "Threads & Messages"
|
||||
set_post_raw.arglist = (
|
||||
("thread_id", "string: the id of the thread the message was posted in."),
|
||||
|
@ -556,6 +573,7 @@ class API(object):
|
|||
user = db.user_resolve(
|
||||
database, args["target_user"], return_false=False)
|
||||
return user["is_admin"]
|
||||
|
||||
is_admin.doctype = "Users"
|
||||
is_admin.arglist = (
|
||||
("target_user", "string: user_id or user_name to check against."),
|
||||
|
@ -575,6 +593,7 @@ class API(object):
|
|||
validate(args, ["thread_id", "post_id"])
|
||||
return db.message_edit_query(
|
||||
database, user["user_id"], args["thread_id"], args["post_id"])
|
||||
|
||||
edit_query.doctype = "Threads & Messages"
|
||||
edit_query.arglist = (
|
||||
("thread_id", "string: the id of the thread the message was posted in."),
|
||||
|
@ -592,6 +611,7 @@ class API(object):
|
|||
message = [{"body": args["body"]}]
|
||||
do_formatting(args["format"], message)
|
||||
return message[0]["body"]
|
||||
|
||||
format_message.doctype = "Tools"
|
||||
format_message.arglist = (
|
||||
("body", "string: the message body to apply formatting to."),
|
||||
|
@ -613,6 +633,7 @@ class API(object):
|
|||
if not user["is_admin"]:
|
||||
raise BBJUserError("Only admins can set thread pins")
|
||||
return db.thread_set_pin(database, args["thread_id"], args["value"])
|
||||
|
||||
thread_set_pin.doctype = "Threads & Messages"
|
||||
thread_set_pin.arglist = (
|
||||
("thread_id", "string: the id of the thread to modify."),
|
||||
|
@ -656,6 +677,7 @@ class API(object):
|
|||
response["bool"] = False
|
||||
response["description"] = e.description
|
||||
return response
|
||||
|
||||
db_validate.doctype = "Tools"
|
||||
db_validate.arglist = (
|
||||
("key", "string: the identifier for the ruleset to check."),
|
||||
|
|
41
setup.sh
41
setup.sh
|
@ -1,12 +1,12 @@
|
|||
#!/bin/bash
|
||||
#!/bin/sh
|
||||
|
||||
DEPS=(
|
||||
cherrypy
|
||||
urwid
|
||||
)
|
||||
create_db() {
|
||||
sqlite3 data.sqlite < schema.sql
|
||||
chmod 600 data.sqlite
|
||||
}
|
||||
|
||||
case $1 in
|
||||
--help )
|
||||
--help)
|
||||
cat <<EOF
|
||||
This script initializes the deps and files for bbj and also sets up its database.
|
||||
It takes the following flags:
|
||||
|
@ -15,20 +15,25 @@ It takes the following flags:
|
|||
|
||||
You can optionally pass a different python interpreter to use (such as
|
||||
a virtual environment), with no arguments this will use the system python3
|
||||
|
||||
EOF
|
||||
exit;;
|
||||
--dbset )
|
||||
sqlite3 data.sqlite < schema.sql
|
||||
echo cleared
|
||||
chmod 600 data.sqlite
|
||||
|
||||
--dbset)
|
||||
create_db
|
||||
exit;;
|
||||
esac
|
||||
|
||||
PYTHON=`which python3`
|
||||
[[ -e logs ]] || mkdir logs; mkdir logs/exceptions
|
||||
[[ -z $1 ]] || PYTHON=$1
|
||||
echo Using $PYTHON...
|
||||
$PYTHON -m pip install ${DEPS[*]}
|
||||
echo "Enter [i] to initialize a new database"
|
||||
read CLEAR
|
||||
[[ $CLEAR == "i" ]] && sqlite3 data.sqlite < schema.sql; chmod 600 data.sqlite
|
||||
[ -e logs ] || mkdir -p logs/exceptions
|
||||
|
||||
PYTHON=$(which python3)
|
||||
[ -z "$1" ] || PYTHON="$1"
|
||||
printf "Using %s...\n" "$PYTHON"
|
||||
$PYTHON -m pip install -r requirements.txt
|
||||
|
||||
printf "Enter [i] to initialize a new database\n"
|
||||
read -r CLEAR
|
||||
|
||||
if [ "$CLEAR" = "i" ]; then
|
||||
create_db
|
||||
fi
|
||||
|
|
28
src/db.py
28
src/db.py
|
@ -1,12 +1,12 @@
|
|||
"""
|
||||
This module contains all of the interaction with the SQLite database. It
|
||||
doesnt hold a connection itself, rather, a connection is passed in as
|
||||
This module contains all the interaction with the SQLite database. It
|
||||
doesn't hold a connection itself, rather, a connection is passed in as
|
||||
an argument to all the functions and is maintained by CherryPy's threading
|
||||
system. This is clunky but fuck it, it works (for now at least).
|
||||
|
||||
All post and thread data are stored in the database without formatting.
|
||||
This is questionable, as it causes formatting to be reapplied with each
|
||||
pull for the database. Im debating whether posts should be stored in all
|
||||
pull for the database. I'm debating whether posts should be stored in all
|
||||
4 formats, or if maybe a caching system should be used.
|
||||
|
||||
The database, nor ANY part of the server, DOES NOT HANDLE PASSWORD HASHING!
|
||||
|
@ -20,13 +20,12 @@ use of sha256.
|
|||
# database user object: these user objects are always resolved on
|
||||
# incoming requests and re-resolving them from their ID is wasteful.
|
||||
|
||||
from time import time
|
||||
from uuid import uuid1
|
||||
|
||||
from src import schema
|
||||
from src.exceptions import BBJParameterError, BBJUserError
|
||||
from src.utils import ordered_keys, schema_values
|
||||
from src import schema
|
||||
from uuid import uuid1
|
||||
from time import time
|
||||
import json
|
||||
import os
|
||||
|
||||
anon = None
|
||||
|
||||
|
@ -97,10 +96,9 @@ def thread_get(connection, thread_id, messages=True, op_only=False):
|
|||
thread = schema.thread(*thread)
|
||||
|
||||
if messages or op_only:
|
||||
query = "SELECT * FROM messages WHERE thread_id = ? %s"
|
||||
c.execute(query % (
|
||||
"AND post_id = 0" if op_only else "ORDER BY post_id"
|
||||
), (thread_id,))
|
||||
query = "SELECT * FROM messages WHERE thread_id = ? "
|
||||
query += "AND post_id = 0" if op_only else "ORDER BY post_id"
|
||||
c.execute(query, (thread_id,))
|
||||
# create a list where each post_id matches its list[index]
|
||||
thread["messages"] = [schema.message(*values) for values in c.fetchall()]
|
||||
|
||||
|
@ -230,7 +228,7 @@ def message_delete(connection, author, thread_id, post_id):
|
|||
WHERE thread_id = ?
|
||||
AND post_id = ?
|
||||
""", (anon["user_id"], "[deleted]", False, thread_id, post_id))
|
||||
# DONT deincrement the reply_count of this thread,
|
||||
# DON'T decrement the reply_count of this thread,
|
||||
# or even delete the message itself. This breaks
|
||||
# balance between post_id and the post's index when
|
||||
# the thread is served with the messages in an array.
|
||||
|
@ -250,7 +248,8 @@ def message_edit_query(connection, author, thread_id, post_id):
|
|||
user = user_resolve(connection, author)
|
||||
thread = thread_get(connection, thread_id)
|
||||
|
||||
try: message = thread["messages"][post_id]
|
||||
try:
|
||||
message = thread["messages"][post_id]
|
||||
except IndexError:
|
||||
raise BBJParameterError("post_id out of bounds for requested thread")
|
||||
|
||||
|
@ -418,7 +417,6 @@ def set_admins(connection, users):
|
|||
not included in `users` will have their privledge
|
||||
revoked.
|
||||
"""
|
||||
connection.execute("UPDATE users SET is_admin = 0")
|
||||
for user in users:
|
||||
connection.execute(
|
||||
"UPDATE users SET is_admin = 1 WHERE user_name = ?",
|
||||
|
|
|
@ -62,11 +62,10 @@ Just like the brackets themselves, backslashes may occur freely within bodies,
|
|||
they are only removed when they occur before a valid expression.
|
||||
"""
|
||||
|
||||
from string import punctuation
|
||||
import re
|
||||
|
||||
colors = [
|
||||
#0, 1 2 3 4 5 6 dim is not used in color api
|
||||
# 0, 1 2 3 4 5 6 dim is not used in color api
|
||||
"red", "yellow", "green", "blue", "cyan", "magenta", "dim"
|
||||
]
|
||||
|
||||
|
@ -74,7 +73,6 @@ markup = [
|
|||
"bold", "underline", "linequote", "quote", "rainbow"
|
||||
]
|
||||
|
||||
|
||||
# quotes being references to other post_ids, like >>34 or >>0 for OP
|
||||
quotes = re.compile(">>([0-9]+)")
|
||||
bold = re.compile(r"(?<!\\)\*{2}(.+?)(?<!\\)\*{2}")
|
||||
|
@ -133,9 +131,9 @@ def sequential_expressions(string):
|
|||
but this cannot effectively express an input like
|
||||
[bold: [red: bolded colors.]], in which case the innermost
|
||||
expression will take precedence. For the input:
|
||||
"[bold: [red: this] is some shit [green: it cant handle]]"
|
||||
"[bold: [red: this] is some shit [green: it can't handle]]"
|
||||
you get:
|
||||
[('red', 'this'), ('bold', ' is some shit '), ('green', 'it cant handle')]
|
||||
[('red', 'this'), ('bold', ' is some shit '), ('green', 'it can't handle')]
|
||||
"""
|
||||
# abandon all hope ye who enter here
|
||||
directives = colors + markup
|
||||
|
@ -151,13 +149,13 @@ def sequential_expressions(string):
|
|||
continue
|
||||
|
||||
if not escaped and char == "[":
|
||||
directive = paragraph[index+1:paragraph.find(": ", index+1)]
|
||||
directive = paragraph[index + 1:paragraph.find(": ", index + 1)]
|
||||
open_p = directive in directives
|
||||
else:
|
||||
open_p = False
|
||||
clsd_p = not escaped and nest[-1] != None and char == "]"
|
||||
|
||||
# dont splice other directives into linequotes: that is far
|
||||
# don't splice other directives into linequotes: that is far
|
||||
# too confusing for the client to determine where to put line
|
||||
# breaks
|
||||
if open_p and nest[-1] != "linequote":
|
||||
|
@ -210,7 +208,6 @@ def strip(text):
|
|||
pass # me the bong im boutta smash tha bish
|
||||
|
||||
|
||||
|
||||
def entities(text):
|
||||
"""
|
||||
Returns a tuple where [0] is raw text and [1] is documentation
|
||||
|
@ -220,7 +217,6 @@ def entities(text):
|
|||
pass
|
||||
|
||||
|
||||
|
||||
def html(text):
|
||||
"""
|
||||
Returns messages in html format, after being sent through markdown.
|
||||
|
|
|
@ -43,7 +43,9 @@ def base():
|
|||
}
|
||||
|
||||
|
||||
def response(data, usermap={}):
|
||||
def response(data, usermap=None):
|
||||
if usermap is None:
|
||||
usermap = {}
|
||||
result = base()
|
||||
result["data"] = data
|
||||
result["usermap"].update(usermap)
|
||||
|
|
Loading…
Reference in New Issue