diff options
Diffstat (limited to 'http2/sf/bb12.py')
| -rwxr-xr-x | http2/sf/bb12.py | 274 |
1 files changed, 274 insertions, 0 deletions
diff --git a/http2/sf/bb12.py b/http2/sf/bb12.py new file mode 100755 index 0000000..7ea6e6e --- /dev/null +++ b/http2/sf/bb12.py @@ -0,0 +1,274 @@ +#! /usr/bin/python + +import cgi, os, string, time +form = cgi.FieldStorage() + +def txtfilter(s): + l = filter(lambda c: c in "!$*,-.0123456789:@ABCDEFGHIJKLMNOPQRSTUVWXYZ^_`abcdefghijklmnopqrstuvwxyz{|}", s) + return string.join(l, '') + +def identity(s): + return s + +def fieldlist(name, filter=txtfilter): + result = [] + if form.has_key(name): + field = form[name] + if type(field) is type([]): + for f in field: + result.append(filter(f.value)) + else: + result.append(filter(field.value)) + return result + +def goodmatch(addr1, addr2): + l1 = string.split(addr1, '.') + if len(l1) >= 4: del l1[-1] + l2 = string.split(addr2, '.') + if len(l2) >= 4: del l2[-1] + return l1 == l2 + + +class Entry: + Notice = '' + FIELDS = [('server', 128), ('desc', 128), ('icon', 64), + ('orig', 64), ('dele1', 64), ('dele2', 64)] + + def __init__(self, f): + self.pos = f.tell() + for fname, flen in self.FIELDS: + s = f.read(flen) + if not s: + self.filled = 0 + break + setattr(self, fname, string.rstrip(s)) + else: + self.filled = 1 + + def __nonzero__(self): + return self.filled + + def write(self, f): + if not getattr(self, 'icon', ''): + try: + import random + lst = os.listdir('../htdocs/images') + except: + pass + else: + lst = filter(lambda x: x[-4:]=='.png' and 'A'<=x[0]<='Z', lst) + if lst: + self.icon = random.choice(lst) + f.seek(self.pos) + for fname, flen in self.FIELDS: + data = getattr(self, fname, '')[:flen] + f.write(data + ' '*(flen-len(data))) + + +def main(): + DATABASE = 'servers' + SIZEMAX = 65536 + Serv = 0 + Orig = 1 + Dele1 = 2 + REMOTE_ADDR = os.environ['REMOTE_ADDR'] + REMOTE_ID = REMOTE_ADDR + time.strftime('@%d%m', time.localtime(time.time())) + OPS = {} + + for srv in fieldlist('d'): + OPS[srv] = 'd' + for srv in fieldlist('a'): + OPS[srv] = 'a' + desc = (fieldlist('desc', identity) or [''])[0] + + f = open(DATABASE, 'r+b') + freelist = [] + published = [] + while 1: + e = Entry(f) + if not e: + break + if e.server: + if OPS.get(e.server) == 'a': + validdesc = desc and goodmatch(REMOTE_ADDR, e.orig) + if e.dele1 or e.dele2 or (validdesc and desc != e.desc): + e.dele1 = e.dele2 = '' # re-enable server + if validdesc: e.desc = desc + e.write(f) + del OPS[e.server] + elif OPS.get(e.server) == 'd': + if goodmatch(REMOTE_ADDR, e.orig) or ( + REMOTE_ID != e.dele1 and REMOTE_ID != e.dele2): + if goodmatch(REMOTE_ADDR, e.orig): + e.server = '' # remove server + elif e.dele1 == '': + e.dele1 = REMOTE_ID + elif e.dele2 == '': + e.dele2 = REMOTE_ID + else: + e.server = '' # remove server + e.write(f) + Entry.Notice = 'd' + if e.server: + published.append((e.pos, e)) + else: + freelist.append(e) + + for srv, action in OPS.items(): + if action == 'a': + if freelist: + e = freelist[-1] + del freelist[-1] + else: + f.seek(0, 2) + e = Entry(f) + if e.pos >= SIZEMAX: + raise Exception("Sorry, server database too big") + hostname = string.split(srv, ':')[0] + if '.' not in hostname: + Entry.Notice = 'Server hostname "%s" incomplete.' % hostname + else: + import socket + try: + result = socket.gethostbyaddr(hostname) + except socket.error, e: + Entry.Notice = ('%s: %s' % (hostname, e)) + else: + if result[0] == 'projects.sourceforge.net': # ???? + Entry.Notice = ('Server hostname "%s" does not exist.' % + hostname) + else: + e.server = srv + e.icon = '' + e.desc = desc + e.orig = REMOTE_ADDR + e.dele1 = e.dele2 = '' + e.write(f) + published.append((e.pos, e)) + Entry.Notice = 'a' + + f.close() + + published.sort() + return map(lambda (pos, e): e, published) + + +def publish_list(serverlist): + url = (fieldlist('url', identity) or ['http://127.0.0.1:8000'])[0] + query = [] + for s in fieldlist('redirected'): + query.append('redirected=' + s) + for s in serverlist: + query.append('s=' + txtfilter(s.server)) + url = url + '?' + string.join(query, '&') + for s in fieldlist('frag'): + url = url + '#' + s + print 'Content-Type: text/html' + print 'Location:', url + print + print '<html><head></head><body>' + print 'Please <a href="%s">click here</a> to continue.' % url + print '</body></html>' + +def publish_default(serverlist): + import htmlentitydefs + text_to_html = {} + for key, value in htmlentitydefs.entitydefs.items(): + text_to_html[value] = '&' + key + ';' + for i in range(32): + text_to_html[chr(i)] = '?' + def htmlquote(s, getter=text_to_html.get): + lst = [] + for c in s: lst.append(getter(c, c)) + return string.join(lst, '') + + REMOTE_ADDR = os.environ['REMOTE_ADDR'] + f = open('started.html', 'r') + header, row, footer = string.split(f.read(), '\\') + f.close() + import sys + print 'Content-Type: text/html' + print + sys.stdout.write(header % "List of registered Internet Servers") + counter = 0 + for s in serverlist: + if s.icon: + s1 = '<img width=32 height=32 src="/images/%s">' % s.icon + else: + s1 = '' + lst = string.split(txtfilter(s.server), ':') + hostname, port, udpport, httpport = (lst+['?','?','?','?'])[:4] + s2 = '<strong>%s</strong>' % hostname + try: + int(httpport) + except ValueError: + pass + else: + s2 = '<a href="http://%s:%s/">%s:%s</a>' % (hostname, httpport, + s2, port) + s2 = '<font size=+1>' + s2 + '</font>' + if s.desc: + s2 = s2 + ' playing <strong>%s</strong>' % htmlquote(s.desc) + if goodmatch(REMOTE_ADDR, s.orig): + s2 = s2 + ' <a href="bb12.py?d=%s"><i>(if this server is dead, click here to remove it)</i></a>' % s.server + sys.stdout.write(row % (s1, ('#C0D0D0', '#E0D0A8')[counter&1], s2)) + counter = counter + 1 + if not serverlist: + sys.stdout.write(row % ('', '#FFFFFF', 'There is no registered server at the moment.')) + sys.stdout.write(footer % "If your browser understands Java, you can click on a server to join the game. Note however that you will still need to install the whole Python client to benefit from the background musics, as this feature is missing from the Java client.<br><br>This list might contain already-dead servers; such 'zombies' disappear after some time.") + +def publish_raw(serverlist): + print 'Content-Type: text/plain' + print + print 'Raw list produced for', os.environ['REMOTE_ADDR'] + print + for s in serverlist: + print repr((s.server, s.desc, s.icon, s.orig)) + +def publish_img(serverlist): + import sys + print 'Content-Type: image/png' + print + f = open('sfbub.png', 'rb') + sys.stdout.write(f.read()) + f.close() + +def publish_register(serverlist): + if Entry.Notice == 'a': + banner = 'The game server is now registered to SourceForge.' + elif Entry.Notice == 'd': + banner = ('Server <font color="#FF8000">unregistered</font> ' + 'from SourceForge.') + elif Entry.Notice == '': + if fieldlist('a'): + banner = "The game server is already registered to SourceForge." + elif fieldlist('d'): + banner = 'The game server was <font color="#FF8000">already absent</font> from SourceForge.' + else: + publish_default(serverlist) + return + else: # errors + banner = ('%s<br><br>' % Entry.Notice + + 'If you are behind a firewall or NAT device (e.g. ADSL routers) you can still make your server reachable but it requires manual configuration. (Instructions not available yet -- sorry)') + f = open('started.html', 'r') + header, row, footer = string.split(f.read(), '\\') + f.close() + import sys + print 'Content-Type: text/html' + print + sys.stdout.write(header % banner) + sys.stdout.write(footer % 'Press <a href="javascript: back()">Back</a> to come back to the main page.') + + +try: + slist = main() + cmd = (fieldlist('cmd') or ['?'])[0] + publish = globals().get('publish_'+cmd, publish_default) + publish(slist) +except: + import traceback, sys + print "Content-Type: text/plain" + print + print "ERROR REPORT" + print + traceback.print_exc(file=sys.stdout) |