Develop

TODO

@@ -0,0 +1,10 @@
+#TODO redirect
+#TODO login/logout
+#TODO CSS
+
+USER PAGE:
+#TODO querry find all questions from user
+#TODO querry find all answers from user
+#TODO querry find all comment from user
+#TODO server function use this and send the datas to the html
+#TODO user page html

answer_data_manager.py

@@ -0,0 +1,134 @@
+import connection
+
+@connection.connection_handler
+def delete_answer(cursor, q_id, a_id):
+    cursor.execute("""
+    delete from comment
+    where question_id = %(q_id)s or answer_id  = %(a_id)s; 
+    delete from answer
+    where question_id = %(q_id)s and id  = %(a_id)s
+    """,
+                   {'q_id': q_id, 'a_id': a_id})
+
+
+@connection.connection_handler
+def collect_answers(cursor, q_id):
+    cursor.execute("""
+    SELECT * from answer
+    where question_id = %(q_id)s
+    """,
+                   {'q_id': q_id})
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def find_answer(cursor, a_id):
+    cursor.execute("""
+    SELECT * from answer
+    where id = %(a_id)s
+    """,
+                   {'a_id': a_id})
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def update_answer(cursor, datas):
+    cursor.execute("""
+                    UPDATE answer
+                    SET message=%s, image=%s 
+                    WHERE id=%s""",
+                   (datas['message'], datas['image'], int(datas['id'])))
+
+
+@connection.connection_handler
+def collect_all_answer(cursor):
+    cursor.execute("""
+        SELECT * FROM answer
+        """)
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def add_answer(cursor, form_data):
+    cursor.execute("""
+                INSERT INTO answer(submission_time, vote_number, question_id, message, image,user_id,accepted)
+                VALUES (%s, %s, %s, %s, %s,%s,%s)""",
+                   (form_data['submission_time'], form_data['vote_number'], form_data['question_id'],
+                    form_data['message'], form_data['image'], form_data['user_id'], form_data['accepted']))
+
+
+@connection.connection_handler
+def accept_answer(cursor, a_id):
+    cursor.execute("""
+    Update answer 
+    set accepted = TRUE
+    where id = %(a_id)s
+    """,
+                   {'a_id': a_id})
+
+
+@connection.connection_handler
+def update_vote_number_answer(cursor, vote, a_id):
+    cursor.execute("""
+        UPDATE answer
+        set vote_number = %(vote)s
+        WHERE id = %(a_id)s
+    """,
+        {'vote': vote, 'a_id': a_id})
+
+
+@connection.connection_handler
+def update_view_number(cursor, q_id):
+    cursor.execute("""
+    update question
+    set view_number = view_number+1
+    where id = %(q_id)s
+    """,
+                   {'q_id': q_id})
+
+
+@connection.connection_handler
+def update_reputation(cursor,user_id,new_reputation):
+    cursor.execute("""
+    UPDATE "user"
+    SET reputation = %(new_reputation)s
+    WHERE id = %(user_id)s
+    """,
+                   {'user_id':user_id, 'new_reputation':new_reputation})
+
+
+@connection.connection_handler
+def get_userid_used_answer(cursor,a_id):
+    cursor.execute("""
+    SELECT user_id FROM answer
+    WHERE id = %(a_id)s
+    """,
+                   {'a_id':a_id})
+
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def get_reputation(cursor,user_id):
+    cursor.execute("""
+    SELECT reputation FROM "user"
+    WHERE id = %(user_id)s
+    """,
+                   {'user_id':user_id})
+    result = cursor.fetchone()
+    return result
+
+
+@connection.connection_handler
+def get_all_answes_form_user(cursor, u_id):
+    cursor.execute("""Select question_id, question.title as question_title, answer.message as answer, answer.vote_number as vote_number from answer
+    join question on question_id=question.id
+    where answer.user_id= %(u_id)s
+    """,
+                   {'u_id':u_id})
+    result=cursor.fetchall()
+    return result

comment_data_manager.py

@@ -0,0 +1,76 @@
+import connection
+
+
+@connection.connection_handler
+def update_view_number(cursor, q_id):
+    cursor.execute("""
+    update question
+    set view_number = view_number+1
+    where id = %(q_id)s
+    """,
+                   {'q_id': q_id})
+
+
+@connection.connection_handler
+def update_vote_number(cursor, vote, q_id):
+    cursor.execute("""
+        UPDATE question
+        set vote_number = %(vote)s
+        WHERE id = %(q_id)s
+    """,
+                   {'vote': vote, 'q_id': q_id})
+
+
+@connection.connection_handler
+def add_comment_to_question(cursor, q_id, comment_message, u_id, s_time):
+    cursor.execute("""
+                    insert into comment(question_id, message, user_id, submission_time)
+                    values (%(q_id)s,%(comment_message)s,%(u_id)s,%(s_time)s)
+
+    """,
+                   {'q_id': q_id, 'comment_message': comment_message, 'u_id': u_id, 's_time': s_time})
+
+
+@connection.connection_handler
+def add_comment_to_answer(cursor, a_id, comment_message):
+    cursor.execute("""
+                    insert into comment(answer_id, message)
+                    values (%(a_id)s,%(comment_message)s)
+
+    """,
+                   {'a_id': a_id, 'comment_message': comment_message})
+
+
+@connection.connection_handler
+def collect_comment_to_question(cursor, q_id):
+    cursor.execute("""
+                    Select message from comment
+                    where question_id = %(q_id)s
+    """,
+                   {'q_id': q_id})
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def collect_comment_to_answer(cursor, a_id):
+    cursor.execute("""
+                    Select message, answer_id from comment
+                    where answer_id = %(a_id)s
+    """,
+                   {'a_id': a_id})
+    result = cursor.fetchall()
+    return result
+
+
+@connection.connection_handler
+def get_all_comments_from_user(cursor, u_id):
+    cursor.execute("""
+    Select comment.message as comment, question.title as question, question.id as q_id, answer.question_id as question_id, answer.message as answer from comment
+    full join answer on comment.answer_id = answer.id
+    full join question on comment.question_id = question.id
+    where comment.user_id = %(u_id)s
+    """,
+                   {'u_id': u_id})
+    result = cursor.fetchall()
+    return result

connection.py

@@ -0,0 +1,51 @@
+# Creates a decorator to handle the database connection/cursor opening/closing.
+# Creates the cursor with RealDictCursor, thus it returns real dictionaries, where the column names are the keys.
+import os
+import psycopg2
+import psycopg2.extras
+
+
+def get_connection_string():
+    # setup connection string
+    # to do this, please define these environment variables first
+    user_name = os.environ.get('PSQL_USER_NAME')
+    password = os.environ.get('PSQL_PASSWORD')
+    host = os.environ.get('PSQL_HOST')
+    database_name = os.environ.get('PSQL_DB_NAME')
+
+    env_variables_defined = user_name and password and host and database_name
+
+    if env_variables_defined:
+        # this string describes all info for psycopg2 to connect to the database
+        return 'postgresql://{user_name}:{password}@{host}/{database_name}'.format(
+            user_name=user_name,
+            password=password,
+            host=host,
+            database_name=database_name
+        )
+    else:
+        raise KeyError('Some necessary environment variable(s) are not defined')
+
+
+def open_database():
+    try:
+        connection_string = get_connection_string()
+        connection = psycopg2.connect(connection_string)
+        connection.autocommit = True
+    except psycopg2.DatabaseError as exception:
+        print('Database connection problem')
+        raise exception
+    return connection
+
+
+def connection_handler(function):
+    def wrapper(*args, **kwargs):
+        connection = open_database()
+        # we set the cursor_factory parameter to return with a RealDictCursor cursor (cursor which provide dictionaries)
+        dict_cur = connection.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
+        ret_value = function(dict_cur, *args, **kwargs)
+        dict_cur.close()
+        connection.close()
+        return ret_value
+
+    return wrapper

password_hash.py

@@ -0,0 +1,12 @@
+import bcrypt
+
+
+def hash_password(plain_text_password):
+    # By using bcrypt, the salt is saved into the hash itself
+    hashed_bytes = bcrypt.hashpw(plain_text_password.encode('utf-8'), bcrypt.gensalt())
+    return hashed_bytes.decode('utf-8')
+
+
+def verify_password(plain_text_password, hashed_password):
+    hashed_bytes_password = hashed_password.encode('utf-8')
+    return bcrypt.checkpw(plain_text_password.encode('utf-8'), hashed_bytes_password)