399 lines
11 KiB
PHP
399 lines
11 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Instans av klassen skapar en koppling till databasen egytalk
|
|
* och tillhandahåller ett antal metoder för att hämta och manipulera data i databasen.
|
|
*/
|
|
class DbEgyTalk
|
|
{
|
|
/**
|
|
* Används i metoder genom $this->db</code>
|
|
*/
|
|
private $db;
|
|
|
|
/**
|
|
* DbEgyTalk constructor.
|
|
*
|
|
* Skapar en koppling till databaseb egytalk
|
|
*/
|
|
public function __construct()
|
|
{
|
|
// Definierar konstanter med användarinformation.
|
|
define('DB_USER', 'egytalk');
|
|
define('DB_PASSWORD', '12345');
|
|
define('DB_HOST', 'mariadb');
|
|
define('DB_NAME', 'egytalk');
|
|
|
|
// Skapar en anslutning till MySql och databasen world
|
|
$dsn = 'mysql:host=' . DB_HOST . ';dbname=' . DB_NAME . ';charset=utf8';
|
|
$this->db = new PDO($dsn, DB_USER, DB_PASSWORD);
|
|
}
|
|
|
|
/**
|
|
* Kontrollerar av användare och lösen.
|
|
* Skapar global sessions-array med användarinformation.
|
|
*
|
|
* @param $userName Användarnamn
|
|
* @param $passWord Lösenord
|
|
* @return $response användardata eller tom [] om inloggning misslyckas
|
|
*/
|
|
function auth($userName, $passWord)
|
|
{
|
|
$userName = trim(filter_var($userName, FILTER_UNSAFE_RAW));
|
|
$response = [];
|
|
|
|
/* Bygger upp sql frågan */
|
|
$stmt = $this->db->prepare("SELECT * FROM user WHERE username = :user");
|
|
$stmt->bindValue(":user", $userName);
|
|
$stmt->execute();
|
|
|
|
|
|
/** Kontroll att resultat finns */
|
|
if ($stmt->rowCount() == 1) {
|
|
// Hämtar användaren, kan endast vara 1 person
|
|
$user = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
// Kontrollerar lösenordet, och allt ok.
|
|
if (password_verify($passWord, $user['password'])) {
|
|
$response['uid'] = $user['uid'];
|
|
$response['firstname'] = $user['firstname'];
|
|
$response['surname'] = $user['surname'];
|
|
}
|
|
}
|
|
|
|
return $response;
|
|
}
|
|
|
|
/**
|
|
* Hämtar anvädardata från användare med secifikt användarID
|
|
*
|
|
* @param $uid användarID
|
|
* @return $response användardata eller tom [] om ingen anvädare hittats eller fel inträffat
|
|
*/
|
|
function getUserFromUid($uid)
|
|
{
|
|
$response = [];
|
|
try {
|
|
/* Bygger upp sql frågan */
|
|
$stmt = $this->db->prepare("SELECT * FROM user WHERE uid = :uid");
|
|
$stmt->bindValue(":uid", $uid);
|
|
$stmt->execute();
|
|
|
|
/** Kontroll att resultat finns */
|
|
if ($stmt->rowCount() == 1) {
|
|
// Hämtar användaren, kan endast vara 1 person
|
|
$user = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
|
|
$response['uid'] = $user['uid'];
|
|
$response['firstname'] = $user['firstname'];
|
|
$response['surname'] = $user['surname'];
|
|
}
|
|
} catch (Exception $e) {}
|
|
|
|
return $response;
|
|
}
|
|
|
|
/**
|
|
* Hämtar alla poster som gjorts på egytalk
|
|
*
|
|
* @return array med alla poster
|
|
*/
|
|
function getAllPosts()
|
|
{
|
|
$posts = [];
|
|
|
|
try {
|
|
$sqlkod = "SELECT post.*, user.firstname, user.surname FROM post
|
|
NATURAL JOIN user ORDER BY post.date DESC";
|
|
$stmt = $this->db->prepare($sqlkod);
|
|
$stmt->execute();
|
|
|
|
$posts = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
for ($i = 0; $i < count($posts); $i++) {
|
|
$posts[$i]['comments'] = $this->getComments($posts[$i]['pid']);
|
|
}
|
|
} catch (Exception $e) {
|
|
}
|
|
|
|
return $posts;
|
|
}
|
|
|
|
/**
|
|
* Hämtar poster för en användare,
|
|
* sorterade efter publiceringsdatum
|
|
*
|
|
* @param $uid användar-ID för användaren
|
|
* @return array med statusuppdateringar sorterade efter datum
|
|
*/
|
|
function getPosts($uid)
|
|
{
|
|
$posts = [];
|
|
|
|
try {
|
|
$sqlkod = "SELECT post.*, user.firstname, user.surname FROM post
|
|
NATURAL JOIN user WHERE post.uid = :uid ORDER BY post.date DESC";
|
|
|
|
$stmt = $this->db->prepare($sqlkod);
|
|
$stmt->bindValue(":uid", $uid, PDO::PARAM_INT);
|
|
$stmt->execute();
|
|
|
|
$posts = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
for ($i = 0; $i < count($posts); $i++) {
|
|
$posts[$i]['comments'] = $this->getComments($posts[$i]['pid']);
|
|
}
|
|
} catch (Exception $e) {
|
|
}
|
|
|
|
return $posts;
|
|
}
|
|
|
|
/**
|
|
* Hämtar alla kommentarer till en post
|
|
*
|
|
* @param $pid postens ID-nummer
|
|
* @return array med kommentarer sorterade efter datum
|
|
*/
|
|
function getComments($pid)
|
|
{
|
|
$comments = [];
|
|
|
|
try {
|
|
$sqlkod = "SELECT comment.*,user.firstname, user.surname FROM comment
|
|
NATURAL JOIN user WHERE comment.pid = :pid ORDER BY comment.date ASC";
|
|
|
|
$stmt = $this->db->prepare($sqlkod);
|
|
$stmt->bindValue(":pid", $pid, PDO::PARAM_INT);
|
|
$stmt->execute();
|
|
|
|
$comments = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
} catch (Exception $e) {
|
|
}
|
|
|
|
return $comments;
|
|
}
|
|
|
|
/**
|
|
* Skapar ny samtalstråd.
|
|
*
|
|
* @param $uid Användar-ID
|
|
* @param $postTxt Postat inlägg
|
|
* @return true om det lyckades, annars false
|
|
*/
|
|
function addPost($uid, $postTxt)
|
|
{
|
|
$postTxt = filter_var($postTxt, FILTER_SANITIZE_SPECIAL_CHARS);
|
|
|
|
try {
|
|
$stmt = $this->db->prepare("INSERT INTO post(uid, post_txt, date) VALUES(:uid, :post, :date)");
|
|
|
|
$stmt->bindValue(":uid", $uid);
|
|
$stmt->bindValue(":post", $postTxt);
|
|
$stmt->bindValue(":date", date("Y-m-d H:i:s"));
|
|
|
|
return $stmt->execute();
|
|
} catch (Exception $e) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Lägger till en ny kommentar till en post.
|
|
*
|
|
* @param $userID Användar-ID för den som skriver kommentaren
|
|
* @param $statusID Status-ID för statusuppdatering som kommenteras
|
|
* @param $comment Kommentar
|
|
* @return true om det lyckades, annars false
|
|
*/
|
|
function addComment($uid, $pid, $comment)
|
|
{
|
|
$pid = filter_var($pid, FILTER_SANITIZE_NUMBER_INT);
|
|
$comment = filter_var($comment, FILTER_SANITIZE_SPECIAL_CHARS);
|
|
|
|
try {
|
|
$stmt = $this->db->prepare("INSERT INTO comment(uid, pid, comment_txt, date) VALUES(:uid, :pid, :com, :date)");
|
|
|
|
$stmt->bindValue(":uid", $uid);
|
|
$stmt->bindValue(":pid", $pid);
|
|
$stmt->bindValue(":com", $comment);
|
|
$stmt->bindValue(":date", date("Y-m-d H:i:s"));
|
|
|
|
return $stmt->execute();
|
|
} catch (Exception $e) {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Lägger till en ny användare
|
|
*
|
|
* @param $fname Förnamn
|
|
* @param $sname Efternamn
|
|
* @param $user Användarnamn
|
|
* @param $pwd Lösenord
|
|
* @return true om det lyckades, annars false
|
|
*/
|
|
function addUser($fname, $sname, $user, $pwd)
|
|
{
|
|
$fname = filter_var($fname, FILTER_SANITIZE_SPECIAL_CHARS);
|
|
$sname = filter_var($sname, FILTER_SANITIZE_SPECIAL_CHARS);
|
|
$user = filter_var($user, FILTER_SANITIZE_SPECIAL_CHARS);
|
|
$pwd = password_hash($pwd, PASSWORD_DEFAULT);
|
|
|
|
try {
|
|
$stmt = $this->db->prepare("INSERT INTO user(uid, firstname, surname, username, password) VALUES(UUID(), :fn, :sn, :user, :pwd)");
|
|
|
|
$stmt->bindValue(":fn", $fname);
|
|
$stmt->bindValue(":sn", $sname);
|
|
$stmt->bindValue(":user", $user);
|
|
$stmt->bindValue(":pwd", $pwd);
|
|
} catch (Exception $e) {
|
|
return false;
|
|
}
|
|
|
|
return $stmt->execute();
|
|
}
|
|
|
|
/**
|
|
* Hämtar alla avändare i nätverket
|
|
* @return array med användare
|
|
*/
|
|
function getUsers()
|
|
{
|
|
$users = [];
|
|
try {
|
|
$stmt = $this->db->prepare("SELECT uid, firstname, surname FROM user WHERE 1 ORDER BY surname, firstname");
|
|
if ($stmt->execute())
|
|
$users = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
} catch (Exception $e) {}
|
|
|
|
return $users;
|
|
}
|
|
|
|
/**
|
|
* Söker efter användare.
|
|
*
|
|
* @param $searchWord Sökord
|
|
* @return array med användare
|
|
*/
|
|
function findUsers($searchWord)
|
|
{
|
|
$searchWord = filter_var($searchWord, FILTER_UNSAFE_RAW);
|
|
$sql = "SELECT uid, firstname, surname FROM user WHERE firstname LIKE :search OR surname LIKE :search ORDER BY surname, firstname";
|
|
$stmt = $this->db->prepare($sql);
|
|
$stmt->bindValue(":search", "%$searchWord%");
|
|
|
|
$stmt->execute();
|
|
|
|
return $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
}
|
|
|
|
/**
|
|
* Returnerar användarinstälningar
|
|
*
|
|
* @param $uid användarens uid
|
|
* @return json-obj med användardata, mail, phone
|
|
*/
|
|
function getSettings($uid)
|
|
{
|
|
$settings = [];
|
|
|
|
try {
|
|
$stmt = $this->db->prepare("SELECT mail, phone FROM user WHERE uid = :uid");
|
|
$stmt->bindValue(":uid", $uid);
|
|
|
|
if ($stmt->execute())
|
|
$settings = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
} catch (Exception $e) {}
|
|
|
|
return $settings;
|
|
}
|
|
|
|
|
|
/**
|
|
* Uppdaterar användarinstälningar
|
|
*
|
|
* @param $uid användarens uid
|
|
* @param $settings array med inställningar, $settings['phone'], $settings['mail']
|
|
* @return true om uppdateringen lyckades
|
|
*/
|
|
function setSettings($uid, $settings)
|
|
{
|
|
$success = false;
|
|
|
|
if (isset($settings['phone']))
|
|
$set = 'phone = :phone';
|
|
|
|
if (isset($settings['mail'])) {
|
|
if (count($settings) == 1)
|
|
$set = 'mail = :mail';
|
|
else
|
|
$set .= ', mail = :mail';
|
|
}
|
|
|
|
try {
|
|
$sql = "UPDATE user SET $set WHERE uid = :uid";
|
|
$stmt = $this->db->prepare($sql);
|
|
$stmt->bindValue(":uid", $uid);
|
|
|
|
if (isset($settings['phone']))
|
|
$stmt->bindValue(":phone", $settings['phone']);
|
|
|
|
if (isset($settings['mail']))
|
|
$stmt->bindValue(":mail", $settings['mail']);
|
|
|
|
$success = $stmt->execute();
|
|
} catch (Exception $e) {}
|
|
|
|
return $success;
|
|
}
|
|
|
|
/**
|
|
* Verifierar om lösenord överenstämmer med användarens lösenord
|
|
*
|
|
* @param $uid Användarens uid
|
|
* @param $pwd Lösenord som skall testas
|
|
* @return true om löseordet är korrekt
|
|
*/
|
|
private function verifyPassword($uid, $pwd){
|
|
$verified = false;
|
|
|
|
try {
|
|
$stmt = $this->db->prepare("SELECT password FROM user WHERE uid = :uid ");
|
|
$stmt->bindValue(":uid", $uid);
|
|
|
|
if ($stmt->execute()){
|
|
$user = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
$verified = password_verify($pwd, $user['password']);
|
|
}
|
|
|
|
} catch (Exception $e) {}
|
|
|
|
return $verified;
|
|
}
|
|
|
|
/**
|
|
* Uppdaterar lösenorder
|
|
*
|
|
* @param $uid användarens uid
|
|
* @param $oldpwd Nuvarande lösenord
|
|
* @param $pwd Nytt lösenord
|
|
* @return true om uppdateringen lyckades
|
|
*/
|
|
function setPassword($uid, $oldpwd, $pwd){
|
|
$success = false;
|
|
if($this->verifyPassword($uid, $oldpwd)){
|
|
$pwd = password_hash($pwd, PASSWORD_DEFAULT);
|
|
try {
|
|
$sql = "UPDATE user SET password = :pwd WHERE uid = :uid";
|
|
$stmt = $this->db->prepare($sql);
|
|
$stmt->bindValue(":pwd", $pwd);
|
|
$stmt->bindValue(":uid", $uid);
|
|
$success = $stmt->execute();
|
|
} catch (Exception $e) {}
|
|
}
|
|
|
|
return $success;
|
|
}
|
|
}
|