import mysql.connector
import json

from classes_data import Node
from classes_data import dbLogin

class EnqueteNode(Node):
    query = "INSERT INTO `Reply` (Result, Node_NodeID, Question_QuestionID) VALUES (%s, %s, %s)"
    
    def __init__(self, macAdress, response, questionID):
        super().__init__(macAdress) 
        self.response = response
        self.questionID = questionID

    async def processEnqueteNodeData(data, nodeID):
        try:
            mydb = dbLogin()
            cursor = mydb.cursor()

            processedData = json.loads(data)

            EnqueteNode.questionID = (processedData['QuestionID'])
            EnqueteNode.response = (processedData['Response'])

            pushingDataArray = [(EnqueteNode.questionID, nodeID, EnqueteNode.response)]

            for i in pushingDataArray:
                print(EnqueteNode.query, i)
                cursor.execute(EnqueteNode.query, i)
                mydb.commit()
        except mysql.connector.Error as err:
            print("MySQL Error:", err)
        finally:
            cursor.close()
            mydb.close()