]> jfr.im git - erebus.git/blobdiff - modules/trivia.py
reformat json
[erebus.git] / modules / trivia.py
index b4c0785b16c456f6a8e094427cea5425667871ac..7100f777e6e14bb1c2d4f22d12021662e8de6833 100644 (file)
@@ -14,7 +14,8 @@ modinfo = {
 import modlib
 lib = modlib.modlib(__name__)
 def modstart(parent, *args, **kwargs):
-       state.parent = parent
+       state.gotParent(parent)
+       lib.hookchan(state.db['chan'])(trivia_checkanswer) # we need parent for this. so it goes here.
        return lib.modstart(parent, *args, **kwargs)
 def modstop(*args, **kwargs):
        global state
@@ -24,7 +25,7 @@ def modstop(*args, **kwargs):
        return lib.modstop(*args, **kwargs)
 
 # module code
-import json, random, threading, re, time
+import json, random, threading, re, time, datetime
 
 try:
        import twitter 
@@ -37,10 +38,14 @@ def findnth(haystack, needle, n): #http://stackoverflow.com/a/1884151
        return len(haystack)-len(parts[-1])-len(needle)
 
 class TriviaState(object):
-       def __init__(self, questionfile, parent=None, pointvote=False):
+       def __init__(self, parent=None, pointvote=False):
+               if parent is not None:
+                       self.gotParent(parent, pointvote)
+
+       def gotParent(self, parent, pointvote=False):
                self.parent = parent
-               self.questionfile = questionfile
-               self.db = json.load(open(questionfile, "r"))
+               self.questionfile = self.parent.cfg.get('trivia', 'jsonpath')
+               self.db = json.load(open(self.questionfile, "r"))
                self.chan = self.db['chan']
                self.curq = None
                self.nextq = None
@@ -52,6 +57,9 @@ class TriviaState(object):
                self.gameover = False
                self.missedquestions = 0
 
+               if 'starttime' not in self.db or self.db['starttime'] is None:
+                       self.db['starttime'] = time.time()
+
                if pointvote:
                        self.getchan().msg("Vote for the next round target points! Options: %s. Vote using !vote <choice>" % (', '.join([str(x) for x in self.db['targetoptions']])))
                        self.getchan().msg("You have %s seconds." % (self.db['votetimer']))
@@ -99,9 +107,9 @@ class TriviaState(object):
                        self.steptimer.start()
 
        def doGameOver(self):
-               def msg(line): self.getbot().msg(self.getchan(), line)
+               msg = self.getchan().msg
                def person(num): return self.db['users'][self.db['ranks'][num]]['realnick']
-               def pts(num): return self.db['users'][self.db['ranks'][num]]['points']
+               def pts(num): return str(self.db['users'][self.db['ranks'][num]]['points'])
                winner = person(0)
                try:
                        msg("\00312THE GAME IS OVER!!!")
@@ -112,6 +120,9 @@ class TriviaState(object):
                except IndexError: pass
                except Exception as e: msg("DERP! %r" % (e))
 
+               if self.db['hofpath'] is not None and self.db['hofpath'] != '':
+                       self.writeHof()
+
                self.db['users'] = {}
                self.db['ranks'] = []
                stop()
@@ -125,7 +136,41 @@ class TriviaState(object):
                        t.statuses.update(status="Round is over! The winner was %s" % (winner))
                except: pass #don't care if errors happen updating twitter.
 
-               self.__init__(self.questionfile, self.parent, True)
+               self.__init__(self.parent, True)
+
+       def writeHof(self):
+               def person(num):
+                       try: return self.db['users'][self.db['ranks'][num]]['realnick']
+                       except: return "none"
+               def pts(num):
+                       try: return str(self.db['users'][self.db['ranks'][num]]['points'])
+                       except: return 0
+
+               try:
+                       f = open(self.db['hofpath'], 'rb+')
+                       for i in range(self.db['hoflines']): #skip this many lines
+                               f.readline()
+                       insertpos = f.tell()
+                       fcontents = f.read()
+                       f.seek(insertpos)
+                       f.write((self.db['hofformat']+"\n") % {
+                               'date': time.strftime("%F", time.gmtime()),
+                               'duration': str(datetime.timedelta(seconds=time.time()-self.db['starttime'])),
+                               'targetscore': self.db['target'],
+                               'firstperson': person(0),
+                               'firstscore': pts(0),
+                               'secondperson': person(1),
+                               'secondscore': pts(1),
+                               'thirdperson': person(2),
+                               'thirdscore': pts(2),
+                       })
+                       f.write(fcontents)
+                       return True
+               except Exception as e:
+                       raise e
+                       return False
+               finally:
+                       f.close()
 
        def endPointVote(self):
                self.getchan().msg("Voting has ended!")
@@ -138,6 +183,8 @@ class TriviaState(object):
                self.db['target'] = votelist[-1][0]
                self.pointvote = None
 
+               self.nextquestion() #start the game!
+
        def nextquestion(self, qskipped=False, iteration=0):
                if self.gameover == True:
                        return self.doGameOver()
@@ -159,31 +206,34 @@ class TriviaState(object):
                        stop()
                        self.getbot().msg(self.getchan(), "%d questions unanswered! Stopping the game.")
 
-               if state.nextq is not None:
-                       nextq = state.nextq
-                       state.nextq = None
+               if self.nextq is not None:
+                       nextq = self.nextq
+                       self.nextq = None
                else:
                        nextq = random.choice(self.db['questions'])
 
-               if nextq['question'][0] == "!":
+               if nextq[0][0] == "!":
                        nextq = specialQuestion(nextq)
 
-               if iteration < 10 and 'lastasked' in nextq and nextq['lastasked'] - time.time() < 24*60*60:
+               if len(nextq) > 2 and nextq[2] - time.time() < 7*24*60*60 and iteration < 10:
                        return self.nextquestion(iteration=iteration+1) #short-circuit to pick another question
-               nextq['lastasked'] = time.time()
+               if len(nextq) > 2:
+                       nextq[2] = time.time()
+               else:
+                       nextq.append(time.time())
 
-               nextq['answer'] = nextq['answer'].lower()
+               nextq[1] = nextq[1].lower()
 
                qtext = "\00304,01Next up: "
-               qary = nextq['question'].split(None)
+               qary = nextq[0].split(None)
                for qword in qary:
                        qtext += "\00304,01"+qword+"\00301,01"+chr(random.randrange(0x61,0x7A)) #a-z
                self.getbot().msg(self.chan, qtext)
 
                self.curq = nextq
 
-               if isinstance(self.curq['answer'], basestring): self.hintanswer = self.curq['answer']
-               else: self.hintanswer = random.choice(self.curq['answer'])
+               if isinstance(self.curq[1], basestring): self.hintanswer = self.curq[1]
+               else: self.hintanswer = random.choice(self.curq[1])
 
                self.steptimer = threading.Timer(self.db['hinttimer'], self.nexthint, args=[1])
                self.steptimer.start()
@@ -191,10 +241,10 @@ class TriviaState(object):
        def checkanswer(self, answer):
                if self.curq is None:
                        return False
-               elif isinstance(self.curq['answer'], basestring):
-                       return answer.lower() == self.curq['answer']
+               elif isinstance(self.curq[1], basestring):
+                       return answer.lower() == self.curq[1]
                else: # assume it's a list or something.
-                       return answer.lower() in self.curq['answer']
+                       return answer.lower() in self.curq[1]
 
        def addpoint(self, user_obj, count=1):
                user_nick = str(user_obj)
@@ -205,12 +255,12 @@ class TriviaState(object):
                        self.db['users'][user] = {'points': count, 'realnick': user_nick, 'rank': len(self.db['ranks'])}
                        self.db['ranks'].append(user)
 
-               self.db['ranks'].sort(key=lambda nick: state.db['users'][nick]['points'], reverse=True) #re-sort ranks, rather than dealing with anything more efficient
+               self.db['ranks'].sort(key=lambda nick: self.db['users'][nick]['points'], reverse=True) #re-sort ranks, rather than dealing with anything more efficient
                for i in range(0, len(self.db['ranks'])):
                        nick = self.db['ranks'][i]
                        self.db['users'][nick]['rank'] = i
 
-               if self.db['users'][user]['points'] >= state.db['target']:
+               if self.db['users'][user]['points'] >= self.db['target']:
                        self.gameover = True
 
                return self.db['users'][user]['points']
@@ -254,9 +304,9 @@ class TriviaState(object):
                else:
                        return self.db['users'][self.db['ranks'][-1]]['points']
 
-state = TriviaState("/home/jrunyon/erebus/modules/trivia.json") #TODO get path from config
+state = TriviaState()
 
-@lib.hookchan(state.db['chan'])
+# we have to hook this in modstart, since we don't know the channel until then.
 def trivia_checkanswer(bot, user, chan, *args):
        line = ' '.join([str(arg) for arg in args])
        if state.checkanswer(line):
@@ -275,7 +325,7 @@ def cmd_points(bot, user, chan, realtarget, *args):
 
        bot.msg(replyto, "%s has %d points." % (who, state.points(who)))
 
-@lib.hook('give', clevel=lib.OP, needchan=False)
+@lib.hook('give', glevel=lib.STAFF, needchan=False)
 @lib.argsGE(1)
 def cmd_give(bot, user, chan, realtarget, *args):
        whoto = args[0]
@@ -287,7 +337,16 @@ def cmd_give(bot, user, chan, realtarget, *args):
 
        bot.msg(chan, "%s gave %s %d points. New balance: %d" % (user, whoto, numpoints, balance))
 
-@lib.hook('setnext', clevel=lib.OP, needchan=False)
+@lib.hook('setnextid', glevel=1, needchan=False)
+def cmd_setnextid(bot, user, chan, realtarget, *args):
+       try:
+               qid = int(args[0])
+               state.nextq = state.db['questions'][qid]
+               bot.msg(user, "Done. Next question is: %s" % (state.nextq[0]))
+       except Exception as e:
+               bot.msg(user, "Error: %s" % (e))
+
+@lib.hook('setnext', glevel=lib.STAFF, needchan=False)
 @lib.argsGE(1)
 def cmd_setnext(bot, user, chan, realtarget, *args):
        line = ' '.join([str(arg) for arg in args])
@@ -297,10 +356,10 @@ def cmd_setnext(bot, user, chan, realtarget, *args):
                return
        question = linepieces[0].strip()
        answer = linepieces[1].strip()
-       state.nextq = {'question':question,'answer':answer}
+       state.nextq = [question, answer]
        bot.msg(user, "Done.")
 
-@lib.hook('skip', clevel=lib.KNOWN, needchan=False)
+@lib.hook('skip', glevel=1, needchan=False)
 def cmd_skip(bot, user, chan, realtarget, *args):
        state.nextquestion(True)
 
@@ -316,8 +375,7 @@ def cmd_start(bot, user, chan, realtarget, *args):
        else:
                bot.msg(replyto, "Game is already started!")
 
-#FIXME @lib.hook('stop', clevel=lib.KNOWN, needchan=False)
-@lib.hook('stop', needchan=False) #FIXME
+@lib.hook('stop', glevel=1, needchan=False)
 def cmd_stop(bot, user, chan, realtarget, *args):
        if stop():
                bot.msg(state.chan, "Game stopped by %s" % (user))
@@ -325,15 +383,18 @@ def cmd_stop(bot, user, chan, realtarget, *args):
                bot.msg(user, "Game isn't running.")
 
 def stop():
-       if state.curq is not None:
-               state.curq = None
-               try:
-                       state.steptimer.cancel()
-               except Exception as e:
-                       print "!!! steptimer.cancel(): e"
-               return True
-       else:
-               return False
+       try:
+               if state.curq is not None:
+                       state.curq = None
+                       try:
+                               state.steptimer.cancel()
+                       except Exception as e:
+                               print "!!! steptimer.cancel(): %s %r" % (e,e)
+                       return True
+               else:
+                       return False
+       except NameError:
+               pass
 
 @lib.hook('rank', needchan=False)
 def cmd_rank(bot, user, chan, realtarget, *args):
@@ -356,15 +417,32 @@ def cmd_top10(bot, user, chan, realtarget, *args):
                replylist.append("%s (%s)" % (user['realnick'], user['points']))
        bot.msg(state.db['chan'], ', '.join(replylist))
 
-@lib.hook('settarget', clevel=lib.MASTER, needchan=False)
+@lib.hook('settarget', glevel=lib.ADMIN, needchan=False)
 def cmd_settarget(bot, user, chan, realtarget, *args):
        try:
                state.db['target'] = int(args[0])
                bot.msg(state.db['chan'], "Target has been changed to %s points!" % (state.db['target']))
-       except:
+
+               if state.pointvote is not None:
+                       state.pointvote.cancel()
+                       state.pointvote = None
+                       bot.msg(state.db['chan'], "Vote has been cancelled!")
+       except Exception as e:
+               print e
                bot.msg(user, "Failed to set target.")
 
-@lib.hook('maxmissed', clevel=lib.MASTER, needchan=False)
+@lib.hook('vote', needchan=False)
+def cmd_vote(bot, user, chan, realtarget, *args):
+       if state.pointvote is not None:
+               if int(args[0]) in state.voteamounts:
+                       state.voteamounts[int(args[0])] += 1
+                       bot.msg(user, "Your vote has been recorded.")
+               else:
+                       bot.msg(user, "Sorry - that's not an option!")
+       else:
+               bot.msg(user, "There's no vote in progress.")
+
+@lib.hook('maxmissed', glevel=lib.ADMIN, needchan=False)
 def cmd_maxmissed(bot, user, chan, realtarget, *args):
        try:
                state.db['maxmissedquestions'] = int(args[0])
@@ -372,7 +450,7 @@ def cmd_maxmissed(bot, user, chan, realtarget, *args):
        except:
                bot.msg(user, "Failed to set maxmissed.")
 
-@lib.hook('hinttimer', clevel=lib.MASTER, needchan=False)
+@lib.hook('hinttimer', glevel=lib.ADMIN, needchan=False)
 def cmd_hinttimer(bot, user, chan, realtarget, *args):
        try:
                state.db['hinttimer'] = float(args[0])
@@ -380,7 +458,7 @@ def cmd_hinttimer(bot, user, chan, realtarget, *args):
        except:
                bot.msg(user, "Failed to set hint timer.")
 
-@lib.hook('hintnum', clevel=lib.MASTER, needchan=False)
+@lib.hook('hintnum', glevel=lib.ADMIN, needchan=False)
 def cmd_hintnum(bot, user, chan, realtarget, *args):
        try:
                state.db['hintnum'] = int(args[0])
@@ -388,9 +466,9 @@ def cmd_hintnum(bot, user, chan, realtarget, *args):
        except:
                bot.msg(user, "Failed to set hintnum.")
 
-@lib.hook('findq', clevel=lib.KNOWN, needchan=False)
+@lib.hook('findq', glevel=1, needchan=False)
 def cmd_findquestion(bot, user, chan, realtarget, *args):
-       matches = [str(i) for i in range(len(state.db['questions'])) if state.db['questions'][i]['question'] == ' '.join(args)] #FIXME: looser equality check
+       matches = [str(i) for i in range(len(state.db['questions'])) if state.db['questions'][i][0] == ' '.join(args)] #TODO looser equality check
        if len(matches) > 1:
                bot.msg(user, "Multiple matches: %s" % (', '.join(matches)))
        elif len(matches) == 1:
@@ -398,17 +476,17 @@ def cmd_findquestion(bot, user, chan, realtarget, *args):
        else:
                bot.msg(user, "No match.")
 
-@lib.hook('delq', clevel=lib.OP, needchan=False)
-@lib.hook('deleteq', clevel=lib.OP, needchan=False)
+@lib.hook('delq', glevel=lib.STAFF, needchan=False)
+@lib.hook('deleteq', glevel=lib.STAFF, needchan=False)
 def cmd_deletequestion(bot, user, chan, realtarget, *args):
        try:
                backup = state.db['questions'][int(args[0])]
                del state.db['questions'][int(args[0])]
-               bot.msg(user, "Deleted %s*%s" % (backup['question'], backup['answer']))
+               bot.msg(user, "Deleted %s*%s" % (backup[0], backup[1]))
        except:
                bot.msg(user, "Couldn't delete that question.")
 
-@lib.hook('addq', clevel=lib.OP, needchan=False)
+@lib.hook('addq', glevel=lib.STAFF, needchan=False)
 def cmd_addquestion(bot, user, chan, realtarget, *args):
        line = ' '.join([str(arg) for arg in args])
        linepieces = line.split('*')
@@ -417,30 +495,36 @@ def cmd_addquestion(bot, user, chan, realtarget, *args):
                return
        question = linepieces[0].strip()
        answer = linepieces[1].strip()
-       state.db['questions'].append({'question':question,'answer':answer})
+       state.db['questions'].append([question, answer])
        bot.msg(user, "Done. Question is #%s" % (len(state.db['questions'])-1))
 
 
 @lib.hook('triviahelp', needchan=False)
 def cmd_triviahelp(bot, user, chan, realtarget, *args):
-       bot.msg(user,             "START")
-       bot.msg(user,             "TOP10")
-       bot.msg(user,             "POINTS    [<user>]")
-       bot.msg(user,             "RANK      [<user>]")
-       if bot.parent.channel(state.db['chan']).levelof(user.auth) >= lib.KNOWN:
-               bot.msg(user,         "SKIP                        (>=KNOWN )")
-               bot.msg(user,         "STOP                        (>=KNOWN )")
-               bot.msg(user,         "FINDQ     <question>     (>=KNOWN )")
-               if bot.parent.channel(state.db['chan']).levelof(user.auth) >= lib.OP:
-                       bot.msg(user,     "GIVE      <user> [<points>] (>=OP    )")
-                       bot.msg(user,     "SETNEXT   <q>*<a>           (>=OP    )")
-                       bot.msg(user,     "ADDQ      <q>*<a>           (>=OP    )")
-                       bot.msg(user,     "DELETEQ   <q>*<a>           (>=OP    )  [aka DELQ]")
-                       if bot.parent.channel(state.db['chan']).levelof(user.auth) >= lib.MASTER:
-                               bot.msg(user, "SETTARGET <points>          (>=MASTER)")
-                               bot.msg(user, "MAXMISSED <questions>       (>=MASTER)")
-                               bot.msg(user, "HINTTIMER <float seconds>   (>=MASTER)")
-                               bot.msg(user, "HINTNUM   <hints>           (>=MASTER)")
+       if user.glevel == 0:
+               bot.msg(user,         "START")
+               bot.msg(user,         "TOP10")
+               bot.msg(user,         "POINTS    [<user>]")
+               bot.msg(user,         "RANK      [<user>]")
+       else:
+               bot.msg(user,         "START                       (ANYONE )")
+               bot.msg(user,         "TOP10                       (ANYONE )")
+               bot.msg(user,         "POINTS    [<user>]          (ANYONE )")
+               bot.msg(user,         "RANK      [<user>]          (ANYONE )")
+       if user.glevel >= 1:
+               bot.msg(user,         "SKIP                        (>=KNOWN)")
+               bot.msg(user,         "STOP                        (>=KNOWN)")
+               bot.msg(user,         "FINDQ     <question>        (>=KNOWN)")
+               if user.glevel >= lib.STAFF:
+                       bot.msg(user,     "GIVE      <user> [<points>] (>=STAFF)")
+                       bot.msg(user,     "SETNEXT   <q>*<a>           (>=STAFF)")
+                       bot.msg(user,     "ADDQ      <q>*<a>           (>=STAFF)")
+                       bot.msg(user,     "DELETEQ   <q>*<a>           (>=STAFF)  [aka DELQ]")
+                       if user.glevel >= lib.ADMIN:
+                               bot.msg(user, "SETTARGET <points>          (>=ADMIN)")
+                               bot.msg(user, "MAXMISSED <questions>       (>=ADMIN)")
+                               bot.msg(user, "HINTTIMER <float seconds>   (>=ADMIN)")
+                               bot.msg(user, "HINTNUM   <hints>           (>=ADMIN)")
 
 @lib.hooknum(417)
 def num_417(bot, textline):
@@ -449,17 +533,17 @@ def num_417(bot, textline):
 
 
 def specialQuestion(oldq):
-       newq = {'question': oldq['question'], 'answer': oldq['answer']}
-       qtype = oldq['question'].upper()
+       newq = [oldq[0], oldq[1]]
+       qtype = oldq[0].upper()
 
        if qtype == "!MONTH":
-               newq['question'] = "What month is it currently (in UTC)?"
-               newq['answer'] = time.strftime("%B").lower()
+               newq[0] = "What month is it currently (in UTC)?"
+               newq[1] = time.strftime("%B", time.gmtime()).lower()
        elif qtype == "!MATH+":
                randnum1 = random.randrange(0, 11)
                randnum2 = random.randrange(0, 11)
-               newq['question'] = "What is %d + %d?" % (randnum1, randnum2)
-               newq['answer'] = spellout(randnum1+randnum2)
+               newq[0] = "What is %d + %d?" % (randnum1, randnum2)
+               newq[1] = spellout(randnum1+randnum2)
        return newq
 
 def spellout(num):