<reponame>nikramakrishnan/distributed-dictionary-attack
#
#  Copyright (C) 2019 by
#  <NAME>
#
#  This project is licensed under the MIT License

import sys

import mysql.connector
from mysql.connector import Error, errorcode


# DB Default Info
host = '10.12.2.93'
user = 'slave'
paswd = '<PASSWORD>'
dbname = 'pass_dict'

def mysql_connect(dbhost,dbuser='root',dbpasswd='',dbname='pass_dict'):
    '''Connect to the database with the provided credentials.'''
    try:
        conn = mysql.connector.connect(
        host=dbhost,
        user=dbuser,
        passwd=dbpasswd,
        database=dbname
        )
    except Error as e:
        print("\nERROR: SQL connection error.\n",e,sep='')
        return None
    return conn

def start_session(conn, id, host, username):
    '''Start a new session'''
    csr = conn.cursor()
    sql = "INSERT INTO sessions (id,host,username) VALUES (%s, %s, %s)"
    val = (id, host, username)
    csr.execute(sql, val)
    conn.commit()
    if(csr.rowcount == 1):
        csr.close()
        return True
    csr.close()
    return False

def get_session_data(conn,id):
    '''Get session details of the database'''
    csr = conn.cursor()
    sql = "SELECT host,username FROM sessions WHERE id = %s"
    val = (id,)
    csr.execute(sql, val)
    res = csr.fetchall()
    if len(res)==0:
        return None
    return res[0]

def clear_flags(conn):
    '''Reset flags if any to default values'''
    csr = conn.cursor()
    sql = "UPDATE passwords SET used = 0"
    csr.execute(sql)
    conn.commit()
    csr.close()

def get_password(conn):
    '''Returns a password value from the database'''
    # Make sure we are in transaction mode
    conn.autocommit = False
    csr = conn.cursor()
    try:
        # Get a password
        sql = "SELECT id,pass FROM passwords WHERE used = 0 ORDER BY RAND() LIMIT 1"
        csr.execute(sql)
        res = csr.fetchone()
        if res is None:
            return None
        # Now update the value to show pass is used
        sql = "UPDATE passwords SET used = 1 WHERE id = %s"
        val = (res[0],)
        csr.execute(sql, val)
        conn.commit()
        csr.close()
        return res[1]
    except mysql.connector.Error:
        conn.rollback()
    csr.close()
    return None

def password_found(conn, id, password):
    '''Update the flag if a password is found'''
    csr = conn.cursor()
    sql = "UPDATE sessions SET found = 1, password = %s WHERE id = %s"
    val = (password, id)
    csr.execute(sql, val)
    conn.commit()
    if(csr.rowcount == 1):
        csr.close()
        return True
    csr.close()
    return False

def is_session_running(conn, id):
    '''Checkk if current session is running based on id'''
    csr = conn.cursor()
    sql = "SELECT found FROM sessions WHERE id = %s LIMIT 1"
    val = (id,)
    csr.execute(sql, val)
    res = csr.fetchall()
    if len(res) == 0:
        return False
    if res[0][0] == 1:
        csr.close()
        return False
    csr.close()
    return True

def check_running_sessions(conn):
    '''Checks if any previous session is running'''
    csr = conn.cursor()
    sql = "SELECT id FROM sessions WHERE found = 0"
    csr.execute(sql)
    res = csr.fetchall()
    if(len(res) > 0):
        return res[0][0]
    return None

def rollback(conn, id):
    '''Delete info about current running session'''
    csr = conn.cursor()
    sql = "DELETE FROM sessions WHERE id = %s"
    val = (id,)
    csr.execute(sql,val)
    conn.commit()
    csr.close()
    clear_flags(conn)

def clean(conn):
    ''''''
    csr = conn.cursor()
    sql = "DELETE FROM sessions WHERE found = 0"
    csr.execute(sql)
    conn.commit()
    csr.close()
    clear_flags(conn)
    close_connection(conn)


def close_connection(conn):
    '''Close connection to database'''
    if(conn.is_connected()):
        conn.close()

#
#  Copyright (C) 2019 by
#  <NAME>
#
#  This project is licensed under the MIT License

import sys

import mysql.connector
from mysql.connector import Error, errorcode


# DB Default Info
host = '10.12.2.93'
user = 'slave'
paswd = '<PASSWORD>'
dbname = 'pass_dict'

def mysql_connect(dbhost,dbuser='root',dbpasswd='',dbname='pass_dict'):
    '''Connect to the database with the provided credentials.'''
    try:
        conn = mysql.connector.connect(
        host=dbhost,
        user=dbuser,
        passwd=dbpasswd,
        database=dbname
        )
    except Error as e:
        print("\nERROR: SQL connection error.\n",e,sep='')
        return None
    return conn

def start_session(conn, id, host, username):
    '''Start a new session'''
    csr = conn.cursor()
    sql = "INSERT INTO sessions (id,host,username) VALUES (%s, %s, %s)"
    val = (id, host, username)
    csr.execute(sql, val)
    conn.commit()
    if(csr.rowcount == 1):
        csr.close()
        return True
    csr.close()
    return False

def get_session_data(conn,id):
    '''Get session details of the database'''
    csr = conn.cursor()
    sql = "SELECT host,username FROM sessions WHERE id = %s"
    val = (id,)
    csr.execute(sql, val)
    res = csr.fetchall()
    if len(res)==0:
        return None
    return res[0]

def clear_flags(conn):
    '''Reset flags if any to default values'''
    csr = conn.cursor()
    sql = "UPDATE passwords SET used = 0"
    csr.execute(sql)
    conn.commit()
    csr.close()

def get_password(conn):
    '''Returns a password value from the database'''
    # Make sure we are in transaction mode
    conn.autocommit = False
    csr = conn.cursor()
    try:
        # Get a password
        sql = "SELECT id,pass FROM passwords WHERE used = 0 ORDER BY RAND() LIMIT 1"
        csr.execute(sql)
        res = csr.fetchone()
        if res is None:
            return None
        # Now update the value to show pass is used
        sql = "UPDATE passwords SET used = 1 WHERE id = %s"
        val = (res[0],)
        csr.execute(sql, val)
        conn.commit()
        csr.close()
        return res[1]
    except mysql.connector.Error:
        conn.rollback()
    csr.close()
    return None

def password_found(conn, id, password):
    '''Update the flag if a password is found'''
    csr = conn.cursor()
    sql = "UPDATE sessions SET found = 1, password = %s WHERE id = %s"
    val = (password, id)
    csr.execute(sql, val)
    conn.commit()
    if(csr.rowcount == 1):
        csr.close()
        return True
    csr.close()
    return False

def is_session_running(conn, id):
    '''Checkk if current session is running based on id'''
    csr = conn.cursor()
    sql = "SELECT found FROM sessions WHERE id = %s LIMIT 1"
    val = (id,)
    csr.execute(sql, val)
    res = csr.fetchall()
    if len(res) == 0:
        return False
    if res[0][0] == 1:
        csr.close()
        return False
    csr.close()
    return True

def check_running_sessions(conn):
    '''Checks if any previous session is running'''
    csr = conn.cursor()
    sql = "SELECT id FROM sessions WHERE found = 0"
    csr.execute(sql)
    res = csr.fetchall()
    if(len(res) > 0):
        return res[0][0]
    return None

def rollback(conn, id):
    '''Delete info about current running session'''
    csr = conn.cursor()
    sql = "DELETE FROM sessions WHERE id = %s"
    val = (id,)
    csr.execute(sql,val)
    conn.commit()
    csr.close()
    clear_flags(conn)

def clean(conn):
    ''''''
    csr = conn.cursor()
    sql = "DELETE FROM sessions WHERE found = 0"
    csr.execute(sql)
    conn.commit()
    csr.close()
    clear_flags(conn)
    close_connection(conn)


def close_connection(conn):
    '''Close connection to database'''
    if(conn.is_connected()):
        conn.close()
# #  Copyright (C) 2019 by #  <NAME> # #  This project is licensed under the MIT License # DB Default Info Connect to the database with the provided credentials. Start a new session Get session details of the database Reset flags if any to default values Returns a password value from the database # Make sure we are in transaction mode # Get a password # Now update the value to show pass is used Update the flag if a password is found Checkk if current session is running based on id Checks if any previous session is running Delete info about current running session Close connection to database