if sys.version_info.major < 3:
timerbase = threading._Timer
+ stringbase = basestring
else:
+ import tempfile
timerbase = threading.Timer
+ stringbase = str
try:
class TriviaState(object):
def __init__(self, parent=None, pointvote=False):
+ self.streak = 0
+ self.streak_holder = None
if parent is not None:
self.gotParent(parent, pointvote)
if json is not None and json.dump is not None:
# json.dump(self.db, open(self.questionfile, "w"))#, indent=4, separators=(',', ': '))
dbjson = json.dumps(self.db)
+ # we have to do a dance to save the file to make the update atomic, and also because Py3 doesn't have os.tempnam in the misguided pursuit of "security"
if len(dbjson) > 0:
os.rename(self.questionfile, self.questionfile+".auto.bak")
- tmpfn = os.tempnam('.', 'trivia')
try:
- f = open(tmpfn, "w")
+ # TODO replace both of these with tempfile.NamedTemporaryFile(delete=False, dir=os.path.dirname(self.questionfile), prefix='trivia') & f.name :
+ if sys.version_info.major < 3:
+ tmpfn = os.tempnam('.', 'trivia')
+ f = open(tmpfn, "w")
+ else:
+ fd, tmpfn = tempfile.mkstemp(dir='.', prefix='trivia')
+ f = open(fd, "w")
f.write(dbjson)
f.close()
os.rename(tmpfn, self.questionfile)
os.unlink(tmpfn)
except OSError: # temp file is already gone
pass
- raise # we may be better off just swallowing exceptions?
+ except UnboundLocalError:
+ pass
+ raise
return False
def getchan(self):
if self.hintstr is None or self.revealpossibilities is None or self.reveal is None:
oldhintstr = ""
self.hintstr = list(re.sub(r'[a-zA-Z0-9]', '*', answer))
- self.revealpossibilities = range(''.join(self.hintstr).count('*'))
+ self.revealpossibilities = list(range(''.join(self.hintstr).count('*')))
self.reveal = int(round(''.join(self.hintstr).count('*') * (7/24.0)))
else:
oldhintstr = ''.join(self.hintstr)
except Exception as e:
msg("DERP! %r" % (e))
- self.db['lastwinner'] = winner
- self.db['lastwon'] = time.time()
-
if self.db['hofpath'] is not None and self.db['hofpath'] != '':
self.writeHof()
+ self.db['lastwinner'] = winner
+ self.db['lastwon'] = time.time()
+
self.db['users'] = {}
self.db['ranks'] = []
self.savedb()
insertpos = f.tell()
fcontents = f.read()
f.seek(insertpos)
- f.write((self.db['hofformat']+"\n") % {
+ new_line = self.db['hofformat'] % {
'date': time.strftime("%F", time.gmtime()),
'duration': str(datetime.timedelta(seconds=time.time()-self.db['lastwon'])),
'targetscore': self.db['target'],
'secondscore': pts(1),
'thirdperson': person(2),
'thirdscore': pts(2),
- })
+ }
+ f.write(new_line.encode() + b"\n")
f.write(fcontents)
status = True
except Exception as e:
+ print(repr(e))
+ print(type(e))
+ print(e.message)
status = False
finally:
if f is not None:
self.lastqid = self.curqid
self.curq = None
self.curqid = None
+ self.lastqtime = time.time()
if self.gameover == True:
return self.doGameOver()
if qskipped:
+ self.streak = 0
+ self.streak_holder = None
self.getchan().fastmsg("\00304Fail! The correct answer was: %s" % (self.hintanswer))
self.missedquestions += 1
else:
else:
nextq.append(time.time())
- if isinstance(nextq[1], basestring):
+ if isinstance(nextq[1], stringbase):
nextq[1] = nextq[1].lower()
else:
nextq[1] = [s.lower() for s in nextq[1]]
qtext += " "
for qword in qary:
spacer = random.choice(
- range(0x61,0x7A) + ([0x20]*4)
+ list(range(0x61,0x7A)) + ([0x20]*4)
)
qtext += "\00304,01"+qword+"\00301,01"+chr(spacer) #a-z
if not self.getbot().fastmsg(self.chan, qtext): #if message is too long:
self.curq = nextq
self.curqid = nextqid
- if isinstance(self.curq[1], basestring): self.hintanswer = self.curq[1]
+ if isinstance(self.curq[1], stringbase): self.hintanswer = self.curq[1]
else: self.hintanswer = random.choice(self.curq[1])
self.steptimer = MyTimer(self.db['hinttimer'], self.nexthint, args=[1])
def checkanswer(self, answer):
if self.curq is None:
return False
- elif isinstance(self.curq[1], basestring):
+ elif isinstance(self.curq[1], stringbase):
return answer.lower() == self.curq[1]
else: # assume it's a list or something.
return answer.lower() in self.curq[1]
line = ' '.join([str(arg) for arg in args])
if state.checkanswer(line):
state.curq = None
- if state.hintanswer.lower() == line.lower():
- bot.fastmsg(chan, "\00312%s\003 has it! The answer was \00312%s\003. New score: %d. Rank: %d. Target: %s %s" % (user, line, state.addpoint(user), state.rank(user), state.targetuser(user), state.targetpoints(user)))
+
+ if state.streak_holder == user:
+ state.streak += 1
else:
- bot.fastmsg(chan, "\00312%s\003 has it! The answer was \00312%s\003 (hinted answer: %s). New score: %d. Rank: %d. Target: %s%s" % (user, line, state.hintanswer, state.addpoint(user), state.rank(user), state.targetuser(user), state.targetpoints(user)))
+ if state.streak >= 3:
+ bot.fastmsg(chan, "\00312%s\003 broke \00304%s\003's streak of \00307%d\003!" % (user, state.streak_holder, state.streak))
+ state.streak_holder = user
+ state.streak = 1
+
+ response = "\00312%s\003 got it in %d seconds! The answer was \00312%s\003" % (user, time.time()-state.lastqtime, line)
+ if state.hintanswer.lower() != line.lower():
+ response += " (hinted answer: %s)" % (state.hintanswer)
+ response += ". New score: %d. Rank: %d. Target: %s %s" % (state.addpoint(user), state.rank(user), state.targetuser(user), state.targetpoints(user))
+ bot.fastmsg(chan, response)
+
+ if state.streak >= 3:
+ bot.msg(chan, "\00312%s\003 is on a streak! \00307%d\003 answers correct in a row!" % (user, state.streak))
+
if state.hintsgiven == 0:
bot.msg(chan, "\00312%s\003 got an extra point for getting it before the hints! New score: %d." % (user, state.addpoint(user)))
+
state.nextquestion()
@lib.hook(glevel=1, needchan=False, wantchan=True)
else: replyto = user
if chan is not None and chan.name != state.db['chan']:
- bot.msg(replyto, "That command isn't valid here.")
+ bot.msg(replyto, "That command is only valid in %s" % (state.db['chan']))
return
if state.curq is None and state.pointvote is None and state.nextquestiontimer is None:
try:
backup = questions[int(args[0])]
del questions[int(args[0])]
- bot.msg(user, "Deleted %s*%s" % (backup[0], backup[1]))
- except:
+ bot.msg(user, "Deleted %s*%s" % (backup[0], backup[1]), True)
+ except Exception as e:
bot.msg(user, "Couldn't delete that question. %r" % (e))
@lib.hook(glevel=lib.STAFF, needchan=False)
projects / erebus.git / blobdiff