RedisDB.py

import redis
import string
import json
import os

class redisDB:    
    def __init__(self):        
        self.redisClient = redis.from_url(os.environ.get('REDIS_URL') or 'redis://127.0.0.1:6379/')       

    #get name from session['name'] and answer from request.form['name']
    def add_user_answer(self, name, answer):
        questionNum = self.redisClient.get("CurrentQuestion").decode("utf-8")
        self.redisClient.hset("Answers" + questionNum, name, answer)
        self.redisClient.publish("answer-stats", "new user answer")        

    def login(self,userName):
        return self.redisClient.zadd("Scores",{userName: 0},nx=True)

    def next_question(self):
        questionNum=self.redisClient.get("CurrentQuestion").decode("utf-8")
        students=self.redisClient.hgetall("Answers"+str(questionNum))
        correct=self.redisClient.hget("Question"+str(questionNum),"ans")
        for name, answer in students.items():
            if answer==correct:
                self.redisClient.zincrby("Scores", 1, name)
        questionString=self.redisClient.hget("Question" + str(int(questionNum)+1), "question").decode("utf-8")
        theleader=self.redisClient.zrange("Scores", 0, -1, desc=True, withscores=True)
        self.redisClient.set("CurrentQuestion", int(questionNum)+1)
        self.redisClient.publish("next-question",int(questionNum)+1)
        return json.dumps({"question": json.loads(questionString), "leaderboard": [(name.decode("utf-8"), score) for (name, score) in theleader]})

    def store_question(self, question_string):        
        self.redisClient.flushdb()
        string_list = question_string.splitlines()        
        length = len(string_list)
        question = ""
        potential_answer_list = []
        question_count = 0
        for iterator in range(0, length + 1):
            if iterator % 6 == 0:  #this line is the question
                question = string_list[iterator].strip()
                correct_awnser = 0
            elif iterator % 6 == 5:     # this line is blank signaling the end of a question, we go ahead and enter in the data we have
                question_string = json.dumps({"question": question, "answers": potential_answer_list})
                self.redisClient.hset("Question" + str(int(iterator/6) + 1), "question", question_string)
                self.redisClient.hset("Question" + str(int(iterator/6) + 1), "ans", correct_awnser)
                potential_answer_list.clear()
                question_count += 1
            else:       #these lines will be the potential awnsers
                string_line = string_list[iterator].strip()
                if string_line[0] == "+":
                    correct_awnser = iterator % 6
                potential_answer_list.append(string_line[2:])         
        self.redisClient.set("QuestionCount", question_count)           
        self.redisClient.set("CurrentQuestion", 1)