<?php

include 'db_connection.php';




function insertUser($username, $email, $pass)
{   global $conn;

    $sql ="INSERT INTO user (username, email,password ) VALUES ('$username', '$email', '$pass')";
    $result = mysqli_query($conn, $sql);

    if($result)
    {
        echo 'data inserted';
    }
    else
    {
        echo "Error: ".mysqli_error($conn);
    }
}

function updateDate($field,$name)
{
    global $conn;
    
    $query = " UPDATE user SET $field = NOW() WHERE username= '$name'";
    $result = mysqli_query($conn, $query);
    return $result;
}
//email function still need to be added

function redirectToLoginPage() {
    header('Location: ../index.php');
    exit();
}



function updatetUser($username, $email, $oldusername)
{    //this must be changed !!! 
    global $conn;

    $statut=false;
   
    $sql ="UPDATE user SET username = '$username', email= '$email' WHERE username='$oldusername'";
    $result = mysqli_query($conn, $sql);
    if($result)
    {
        echo 1;
        $statut = true;
    }
    else
    {
        echo "Error: ".mysqli_error($conn);
    }
    return $statut;
}


function selectUser(){

    $statut=false;
    $sql = "SELECT * FROM user";
    $result = mysqli_query($conn, $sql);
    $row = mysqli_fetch_array($result);

    $username = $row['username'];
    $id =$row['id'];
    $email = $row['email'];

}







function SaveLog($username,$email,$password,$key)
{   
    $refUser = $_SESSION['id'];
    $statut=false;
    global $conn;

    $qry="SELECT * FROM user WHERE id = $refUser";
    $result = mysqli_query($conn, $qry);
    $row = mysqli_fetch_array($result);
    
    $oldData = json_encode(
        array(
            'username'=>$row['username'],
            'email'=>$row['email'],
            'password'=>$row['password']
        ));
        $newData = json_encode(
            array(
                'username'=>$username,
                'email'=>$email,
                'password'=>$password
            ));

if($row > 0) 
{
    $sql= "INSERT INTO loguser (refUser_id,log_key,log_oldData,log_newData,timestamp) VALUES ($refUser,'$key','$oldData','$newData',NOW())";
    $res = mysqli_query($conn, $sql);
    if($res)
    {
        $statut=true;
    }
    else
    {
        echo "Error: ".mysqli_error($conn);
    }
}
    
    return $statut;
}

function Insertdata($table,$field,$data){
    $statut=false;
    global $conn;
    $field_values= implode(",",$field);
    $data_values=implode("','",$data);

    $sql="INSERT INTO $table (".$field_values.") VALUES ('".$data_values."')";
print_r($sql);
    
    $result=mysqli_query($conn, $sql);
    if($result)
    {
        $statut=true;
    }
    else
    {
        echo "Error: ".mysqli_error($conn);
    }
    return $statut;
  }

  function UpdateTable($table,$fields,$condition) {
    // not implemented yet
        $sql = "update $table set ";
        foreach($fields as $key => $value) {
            $fields[$key] = " `$key` = '".$value."' ";
        }
        $sql .= implode(" , ",array_values($fields))." where ".$condition.";"; 
        $fields = array();
    }
    

    function SelectData($table,$condition)
    { //works but not implement yet
         global $conn;

        $sql ="SELECT * FROM $table"." ".$condition;
        echo $sql;
        $result = mysqli_query ($conn,$sql);
        $count = 0;
        $data = array();
        while ( $row = mysqli_fetch_array($result))
        {
            $data[$count] = $row;
           // print_r($row['email']);
            $count++;
         
        }
           return $data;   
    }
?>