# coding=utf-8
import _mysql
from database import *
from framework import *
from template import *
from img import *
from post import *
from settings import Settings
d_thread = {}
d_post = {}
def anarkia(self, path_split):
setBoard('anarkia')
if len(path_split) <= 2:
self.output = main()
return
raise UserError, 'Ya fue, baisano...'
if path_split[2] == 'opt':
self.output = boardoptions(self.formdata)
elif path_split[2] == 'mod':
self.output = mod(self.formdata)
elif path_split[2] == 'bans':
self.output = bans(self.formdata)
elif path_split[2] == 'css':
self.output = css(self.formdata)
elif path_split[2] == 'type':
self.output = type(self.formdata)
elif path_split[2] == 'emojis':
self.output = emojis(self.formdata)
else:
raise UserError, 'ke?'
def main():
board = Settings._.BOARD
logs = FetchAll(
"SELECT * FROM `logs` WHERE `staff` = 'Anarko' ORDER BY `timestamp` DESC")
for log in logs:
log['timestamp_formatted'] = formatTimestamp(log['timestamp'])
return renderTemplate('anarkia.html', {'mode': 0, 'logs': logs})
def type(formdata):
board = Settings._.BOARD
if board['board_type'] == '1':
(type_now, type_do, do_num) = ('BBS', 'IB', '0')
else:
(type_now, type_do, do_num) = ('IB', 'BBS', '1')
if formdata.get('transform') == 'do':
t = 0
try:
with open('anarkia_time') as f:
t = int(f.read())
except IOError:
pass
dif = time.time() - t
if dif > (10 * 60):
# if True:
import re
t = time.time()
board['board_type'] = do_num
board['force_css'] = Settings.HOME_URL + \
'anarkia/style_' + type_do.lower() + '.css'
updateBoardSettings()
# update posts
fix_board()
# regenerate
setBoard('anarkia')
regenerateBoard(True)
tf = timeTaken(t, time.time())
with open('anarkia_time', 'w') as f:
t = f.write(str(int(time.time())))
msg = 'Cambiada estructura de sección a %s. (%s)' % (type_do, tf)
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
else:
raise UserError, 'Esta acción sólo se puede realizar cada 10 minutos. Faltan: %d mins.' % (10-int(dif/60))
return renderTemplate('anarkia.html', {'mode': 7, 'type_now': type_now, 'type_do': type_do})
def fix_board():
board = Settings._.BOARD
get_fix_dictionary()
if board['board_type'] == '1':
to_fix = FetchAll(
"SELECT * FROM posts WHERE message LIKE '%%anarkia/res/%%' AND boardid = %s" % board['id'])
else:
to_fix = FetchAll(
"SELECT * FROM posts WHERE message LIKE '%%anarkia/read/%%' AND boardid = %s" % board['id'])
for p in to_fix:
try:
if board['board_type'] == '1':
newmessage = re.sub(
r'/anarkia/res/(\d+).html#(\d+)">>>(\d+)', fix_to_bbs, p['message'])
else:
newmessage = re.sub(
r'/anarkia/read/(\d+)/(\d+)">>>(\d+)', fix_to_ib, p['message'])
UpdateDb("UPDATE posts SET message = '%s' WHERE boardid = %s AND id = %s" %
(_mysql.escape_string(newmessage), board['id'], p['id']))
except KeyError:
pass
return True
def fix_to_bbs(matchobj):
threadid = matchobj.group(1)
pid = matchobj.group(2)
new_thread = d_thread[threadid]
new_post = d_post[new_thread][pid]
return '/anarkia/read/%s/%s">>>%s' % (new_thread, new_post, new_post)
def fix_to_ib(matchobj):
threadid = matchobj.group(1)
num = int(matchobj.group(2))
new_thread = d_thread[threadid]
new_post = d_post[new_thread][num]
return '/anarkia/res/%s.html#%s">>>%s' % (new_thread, new_post, new_post)
def get_fix_dictionary():
global d_thread, d_post
board = Settings._.BOARD
res = FetchAll(
"SELECT id, timestamp, parentid FROM posts WHERE boardid = %s ORDER BY CASE parentid WHEN 0 THEN id ELSE parentid END ASC, `id` ASC" % board['id'])
num = 1
thread = 0
for p in res:
pid = p['id']
if p['parentid'] == '0':
num = 1
time = p['timestamp']
if board['board_type'] == '1':
d_thread[pid] = time
thread = time
else:
d_thread[time] = pid
thread = pid
d_post[thread] = {}
if board['board_type'] == '1':
d_post[thread][pid] = num
else:
d_post[thread][num] = pid
num += 1
return
def css(formdata):
board = Settings._.BOARD
if board['board_type'] == '1':
basename = 'style_bbs.css'
else:
basename = 'style_ib.css'
fname = '%sanarkia/%s' % (Settings.HOME_DIR, basename)
if formdata.get('cssfile'):
with open(fname, 'w') as f:
cssfile = f.write(formdata['cssfile'])
msg = 'CSS actualizado.'
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
with open(fname) as f:
cssfile = f.read()
return renderTemplate('anarkia.html', {'mode': 6, 'basename': basename, 'cssfile': cssfile})
def bans(formdata):
board = Settings._.BOARD
if formdata.get('unban'):
unban = int(formdata['unban'])
boardpickle = pickle.dumps(['anarkia'])
ban = FetchOne("SELECT * FROM `bans` WHERE id = %d" % unban)
if not ban:
raise UserError, "Ban inválido."
if ban['boards'] != boardpickle:
raise USerError, "Ban inválido."
UpdateDb('DELETE FROM `bans` WHERE id = %s' % ban['id'])
logAction("Usuario %s desbaneado." % ban['ip'][:4])
regenerateAccess()
bans = FetchAll('SELECT * FROM `bans` WHERE staff = \'anarko\'')
for ban in bans:
ban['added'] = formatTimestamp(ban['added'])
if ban['until'] == '0':
ban['until'] = _('Does not expire')
else:
ban['until'] = formatTimestamp(ban['until'])
return renderTemplate('anarkia.html', {'mode': 5, 'bans': bans})
def mod(formdata):
board = Settings._.BOARD
if formdata.get('thread'):
parentid = int(formdata['thread'])
posts = FetchAll('SELECT * FROM `posts` WHERE (parentid = %d OR id = %d) AND boardid = %s ORDER BY `id` ASC' %
(parentid, parentid, board['id']))
return renderTemplate('anarkia.html', {'mode': 3, 'posts': posts})
elif formdata.get('lock'):
postid = int(formdata['lock'])
post = FetchOne('SELECT id, locked FROM posts WHERE boardid = %s AND id = %d AND parentid = 0 LIMIT 1' % (
board['id'], postid))
if post['locked'] == '0':
setLocked = 1
msg = "Hilo %s cerrado." % post['id']
else:
setLocked = 0
msg = "Hilo %s abierto." % post['id']
UpdateDb("UPDATE `posts` SET `locked` = %d WHERE `boardid` = '%s' AND `id` = '%s' LIMIT 1" % (
setLocked, board["id"], post["id"]))
threadUpdated(post['id'])
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
elif formdata.get('del'):
postid = int(formdata['del'])
post = FetchOne('SELECT id, parentid FROM posts WHERE boardid = %s AND id = %d LIMIT 1' % (
board['id'], postid))
if post['parentid'] != '0':
deletePost(post['id'], None, '3', False)
msg = "Mensaje %s eliminado." % post['id']
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
else:
raise UserError, "jaj no"
elif formdata.get('restore'):
postid = int(formdata['restore'])
post = FetchOne('SELECT id, parentid FROM posts WHERE boardid = %s AND id = %d LIMIT 1' % (
board['id'], postid))
UpdateDb('UPDATE `posts` SET `IS_DELETED` = 0 WHERE `boardid` = %s AND `id` = %s LIMIT 1' % (
board['id'], post['id']))
if post['parentid'] != '0':
threadUpdated(post['parentid'])
else:
regenerateFrontPages()
msg = "Mensaje %s recuperado." % post['id']
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
elif formdata.get('ban'):
postid = int(formdata['ban'])
post = FetchOne('SELECT id, ip FROM posts WHERE boardid = %s AND id = %d LIMIT 1' % (
board['id'], postid))
return renderTemplate('anarkia.html', {'mode': 4, 'post': post})
elif formdata.get('banto'):
postid = int(formdata['banto'])
post = FetchOne('SELECT id, message, parentid, ip FROM posts WHERE boardid = %s AND id = %d LIMIT 1' % (
board['id'], postid))
reason = formdata.get('reason').replace(
'script', '').replace('meta', '')
if reason is not None:
if formdata['seconds'] != '0':
until = str(timestamp() + int(formdata['seconds']))
else:
until = '0'
where = pickle.dumps(['anarkia'])
ban = FetchOne("SELECT `id` FROM `bans` WHERE `ip` = '" +
post['ip'] + "' AND `boards` = '" + _mysql.escape_string(where) + "' LIMIT 1")
if ban:
raise UserError, "Este usuario ya esta baneado."
# Blind mode
if formdata.get('blind') == '1':
blind = '1'
else:
blind = '0'
InsertDb("INSERT INTO `bans` (`ip`, `netmask`, `boards`, `added`, `until`, `staff`, `reason`, `blind`) VALUES ('" + post['ip'] + "', INET_ATON('255.255.255.255'), '" + _mysql.escape_string(
where) + "', " + str(timestamp()) + ", " + until + ", 'anarko', '" + _mysql.escape_string(formdata['reason']) + "', '"+blind+"')")
newmessage = post['message'] + \
'<hr /><span class="banned">A este usuario se le revocó el acceso. Razón: %s</span>' % reason
UpdateDb("UPDATE posts SET message = '%s' WHERE boardid = %s AND id = %s" % (
_mysql.escape_string(newmessage), board['id'], post['id']))
if post['parentid'] != '0':
threadUpdated(post['parentid'])
else:
regenerateFrontPages()
regenerateAccess()
msg = "Usuario %s baneado." % post['ip'][:4]
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
else:
reports = FetchAll("SELECT * FROM `reports` WHERE board = 'anarkia'")
threads = FetchAll(
'SELECT * FROM `posts` WHERE boardid = %s AND parentid = 0 ORDER BY `bumped` DESC' % board['id'])
return renderTemplate('anarkia.html', {'mode': 2, 'threads': threads, 'reports': reports})
def boardoptions(formdata):
board = Settings._.BOARD
if formdata.get('longname'):
# submitted
board['longname'] = formdata['longname'].replace('script', '')
board['postarea_desc'] = formdata['postarea_desc'].replace(
'script', '').replace('meta', '')
board['postarea_extra'] = formdata['postarea_extra'].replace(
'script', '').replace('meta', '')
board['anonymous'] = formdata['anonymous'].replace('script', '')
board['subject'] = formdata['subject'].replace('script', '')
board['message'] = formdata['message'].replace('script', '')
board['useid'] = formdata['useid']
if 'disable_name' in formdata.keys():
board['disable_name'] = '1'
else:
board['disable_name'] = '0'
if 'disable_subject' in formdata.keys():
board['disable_subject'] = '1'
else:
board['disable_subject'] = '0'
if 'allow_noimage' in formdata.keys():
board['allow_noimage'] = '1'
else:
board['allow_noimage'] = '0'
if 'allow_images' in formdata.keys():
board['allow_images'] = '1'
else:
board['allow_images'] = '0'
if 'allow_image_replies' in formdata.keys():
board['allow_image_replies'] = '1'
else:
board['allow_image_replies'] = '0'
# Update file types
UpdateDb("DELETE FROM `boards_filetypes` WHERE `boardid` = %s" %
board['id'])
for filetype in filetypelist():
if 'filetype'+filetype['ext'] in formdata.keys():
UpdateDb("INSERT INTO `boards_filetypes` VALUES (%s, %s)" %
(board['id'], filetype['id']))
try:
board['maxsize'] = int(formdata['maxsize'])
if board['maxsize'] > 10000:
board['maxsize'] = 10000
except:
raise UserError, _("Max size must be numeric.")
try:
board['thumb_px'] = int(formdata['thumb_px'])
if board['thumb_px'] > 500:
board['thumb_px'] = 500
except:
raise UserError, _("Max thumb dimensions must be numeric.")
try:
board['numthreads'] = int(formdata['numthreads'])
if board['numthreads'] > 15:
board['numthreads'] = 15
except:
raise UserError, _("Max threads shown must be numeric.")
try:
board['numcont'] = int(formdata['numcont'])
if board['numcont'] > 15:
board['numcont'] = 15
except:
raise UserError, _("Max replies shown must be numeric.")
t = time.time()
updateBoardSettings()
setBoard('anarkia')
regenerateBoard(True)
tf = timeTaken(t, time.time())
msg = 'Opciones cambiadas. %s' % tf
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
else:
return renderTemplate('anarkia.html', {'mode': 1, 'boardopts': board, 'filetypes': filetypelist(), 'supported_filetypes': board['filetypes_ext']})
def emojis(formdata):
board = Settings._.BOARD
board_pickle = _mysql.escape_string(pickle.dumps([board['dir']]))
if formdata.get('new'):
import re
ext = {'image/jpeg': 'jpg', 'image/gif': 'gif', 'image/png': 'png'}
if not formdata['name']:
raise UserError, 'Ingresa nombre.'
if not re.match(r"^[0-9a-zA-Z]+$", formdata['name']):
raise UserError, 'Nombre inválido; solo letras/números.'
name = ":%s:" % formdata['name'][:15]
data = formdata['file']
if not data:
raise UserError, 'Ingresa imagen.'
# check if it exists
already = FetchOne("SELECT 1 FROM `filters` WHERE `boards` = '%s' AND `from` = '%s'" % (
board_pickle, _mysql.escape_string(name)))
if already:
raise UserError, 'Este emoji ya existe.'
# get image information
content_type, width, height, size, extra = getImageInfo(data)
if content_type not in ext.keys():
raise UserError, 'Formato inválido.'
if width > 500 or height > 500:
raise UserError, 'Dimensiones muy altas.'
if size > 150000:
raise UserError, 'Tamaño muy grande.'
# create file names
thumb_width, thumb_height = getThumbDimensions(width, height, 32)
file_path = Settings.ROOT_DIR + \
board["dir"] + "/e/" + formdata['name'][:15] + \
'.' + ext[content_type]
file_url = Settings.BOARDS_URL + \
board["dir"] + "/e/" + formdata['name'][:15] + \
'.' + ext[content_type]
to_filter = '<img src="%s" width="%d" height="%d" />' % (
file_url, thumb_width, thumb_height)
# start processing image
args = [Settings.CONVERT_PATH, "-", "-limit", "thread", "1", "-resize",
"%dx%d" % (thumb_width, thumb_height), "-quality", "80", file_path]
p = subprocess.Popen(args, stdout=subprocess.PIPE,
stdin=subprocess.PIPE, stderr=subprocess.PIPE)
out = p.communicate(input=data)[0]
# insert into DB
sql = "INSERT INTO `filters` (`boards`, `type`, `action`, `from`, `to`, `staff`, `added`) VALUES ('%s', 0, 1, '%s', '%s', 'Anarko', '%s')" % (
board_pickle, _mysql.escape_string(name), _mysql.escape_string(to_filter), timestamp())
UpdateDb(sql)
msg = "Emoji %s agregado." % name
logAction(msg)
return renderTemplate('anarkia.html', {'mode': 99, 'msg': msg})
elif formdata.get('del'):
return renderTemplate('anarkia.html', {'mode': 99, 'msg': 'Del.'})
else:
filters = FetchAll(
"SELECT * FROM `filters` WHERE `boards` = '%s' ORDER BY `added` DESC" % board_pickle)
return renderTemplate('anarkia.html', {'mode': 8, 'emojis': filters})
def filetypelist():
filetypes = FetchAll('SELECT * FROM `filetypes` ORDER BY `ext` ASC')
return filetypes
def logAction(action):
InsertDb("INSERT INTO `logs` (`timestamp`, `staff`, `action`) VALUES (" +
str(timestamp()) + ", 'Anarko', '" + _mysql.escape_string(action) + "')")
