Chat application in php using web scocket programming

# Chat application in PHP & MySQL using Ratchet Library (ok) ![](/files/-MUJJuZFe_6LDeSxO0E9) ![](/files/-MUJIVi5Pmc-o7L-sZw_) C:\xampp\htdocs\chatroom\composer.json ``` { "autoload": { "psr-4": { "MyApp\\": "src" } }, "require": { "cboden/ratchet": "^0.4.3" } } ``` C:\xampp\htdocs\chatroom\index.php ``` Chat application in php using web scocket programming

Chat application in PHP & MySQL using Ratchet Library

setEmail($_POST['email']); $objUser->setName($_POST['uname']); $objUser->setLoginStatus(1); $objUser->setLastLogin(date('Y-m-d h:i:s')); $userData = $objUser->getUserByEmail(); if(is_array($userData) && count($userData)>0) { $objUser->setId($userData['id']); if($objUser->updateLoginStatus()) { echo "User login.."; $_SESSION['user'][$userData['id']] = $userData; header("location: chatroom.php"); } else { echo "Failed to login."; } } else { if($objUser->save()) { $lastId = $objUser->dbConn->lastInsertId(); $objUser->setId($lastId); $_SESSION['user'][$lastId] = [ 'id' => $objUser->getId(), 'name' => $objUser->getName(), 'email'=> $objUser->getEmail(), 'login_status'=>$objUser->getLoginStatus(), 'last_login'=> $objUser->getLastLogin() ]; echo "User Registred.."; header("location: chatroom.php"); } else { echo "Failed.."; } } } ?>

``` C:\xampp\htdocs\chatroom\chatroom.php ``` Chat application in php using web scocket programming

Chat application in PHP & MySQL using Ratchet Library

getAllChatRooms(); $objUser = new users; $users = $objUser->getAllUsers(); ?> $user) { $color = 'color: red'; if($user['login_status'] == 1) { $color = 'color: green'; } if(!isset($_SESSION['user'][$user['id']])) { echo ""; echo ""; echo ""; } } ?>

Users
$user) { $userId = $key; echo ''; echo " ".$user['name']." "; echo " ".$user['email']." "; } ?>
".$user['name']."		".$user['last_login']."

$chatroom) { if($userId == $chatroom['userid']) { $from = "Me"; } else { $from = $chatroom['name']; } echo ''; } ?>

Chat Room
'.$from.' '.$chatroom['msg'].'	'.date("d/m/Y h:i:s A", strtotime($chatroom['created_on'])).'

``` C:\xampp\htdocs\chatroom\action.php ``` setLoginStatus(0); $objUser->setLastLogin(date('Y-m-d h:i:s')); $objUser->setId($_POST['userId']); if($objUser->updateLoginStatus()) { unset($_SESSION['user']); session_destroy(); echo json_encode(['status'=>1, 'msg'=>"Logout.."]); } else { echo json_encode(['status'=>0, 'msg'=>"Somthing went wrong.."]); } } ?> ``` C:\xampp\htdocs\chatroom\src\Chat.php ``` clients = new \SplObjectStorage; echo "Server Started."; } public function onOpen(ConnectionInterface $conn) { // Store the new connection to send messages to later $this->clients->attach($conn); echo "New connection! ({$conn->resourceId})\n"; } public function onMessage(ConnectionInterface $from, $msg) { $numRecv = count($this->clients) - 1; echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n" , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's'); $data = json_decode($msg, true); $objChatroom = new \chatrooms; $objChatroom->setUserId($data['userId']); $objChatroom->setMsg($data['msg']); $objChatroom->setCreatedOn(date("Y-m-d h:i:s")); if ($objChatroom->saveChatRoom()) { $objUser = new \users; $objUser->setId($data['userId']); $user = $objUser->getUserById(); $data['from'] = $user['name']; $data['msg'] = $data['msg']; $data['dt'] = date("d-m-Y h:i:s"); } foreach ($this->clients as $client) { if ($from == $client) { $data['from'] = "Me"; } else { $data['from'] = $user['name']; } $client->send(json_encode($data)); } } public function onClose(ConnectionInterface $conn) { // The connection is closed, remove it, as we can no longer send it messages $this->clients->detach($conn); echo "Connection {$conn->resourceId} has disconnected\n"; } public function onError(ConnectionInterface $conn, \Exception $e) { echo "An error has occurred: {$e->getMessage()}\n"; $conn->close(); } } ``` C:\xampp\htdocs\chatroom\db\chatrooms.php ``` id = $id;} function getId() {return $this->id;} function setUserId($userId) {$this->userId = $userId;} function getUserId() {return $this->userId;} function setMsg($msg) {$this->msg = $msg;} function getMsg() {return $this->msg;} function setCreatedOn($createdOn) {$this->createdOn = $createdOn;} function getCreatedOn() {return $this->createdOn;} public function __construct() { require_once 'DbConnect.php'; $db = new DbConnect(); $this->dbConn = $db->connect(); } public function saveChatRoom() { $stmt = $this->dbConn->prepare('INSERT INTO chatrooms VALUES(null, :userid, :msg, :createdOn)'); $stmt->bindParam(':userid', $this->userId); $stmt->bindParam(':msg', $this->msg); $stmt->bindParam(':createdOn', $this->createdOn); if ($stmt->execute()) { return true; } else { return false; } } public function getAllChatRooms() { $stmt = $this->dbConn->prepare("SELECT c.*, u.name FROM chatrooms c JOIN users u ON(c.userid = u.id) ORDER BY c.id DESC"); $stmt->execute(); $chatrooms = $stmt->fetchAll(PDO::FETCH_ASSOC); return $chatrooms; } } ?> ``` C:\xampp\htdocs\chatroom\db\DbConnect.php ``` host . '; dbname=' . $this->dbName, $this->user, $this->pass); $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); return $conn; } catch (PDOException $e) { echo 'Database Error: ' . $e->getMessage(); } } } ?> ``` C:\xampp\htdocs\chatroom\db\users.php ``` id = $id; } function getId() { return $this->id; } function setName($name) { $this->name = $name; } function getName() { return $this->name; } function setEmail($email) { $this->email = $email; } function getEmail() { return $this->email; } function setLoginStatus($loginStatus) { $this->loginStatus = $loginStatus; } function getLoginStatus() { return $this->loginStatus; } function setLastLogin($lastLogin) { $this->lastLogin = $lastLogin; } function getLastLogin() { return $this->lastLogin; } public function __construct() { require_once("DbConnect.php"); $db = new DbConnect(); $this->dbConn = $db->connect(); } public function save() { $sql = "INSERT INTO `users`(`id`, `name`, `email`, `login_status`, `last_login`) VALUES (null, :name, :email, :loginStatus, :lastLogin)"; $stmt = $this->dbConn->prepare($sql); $stmt->bindParam(":name", $this->name); $stmt->bindParam(":email", $this->email); $stmt->bindParam(":loginStatus", $this->loginStatus); $stmt->bindParam(":lastLogin", $this->lastLogin); try { if($stmt->execute()) { return true; } else { return false; } } catch (Exception $e) { echo $e->getMessage(); } } public function getUserByEmail() { $stmt = $this->dbConn->prepare('SELECT * FROM users WHERE email = :email'); $stmt->bindParam(':email', $this->email); try { if($stmt->execute()) { $user = $stmt->fetch(PDO::FETCH_ASSOC); } } catch (Exception $e) { echo $e->getMessage(); } return $user; } public function getUserById() { $stmt = $this->dbConn->prepare('SELECT * FROM users WHERE id = :id'); $stmt->bindParam(':id', $this->id); try { if($stmt->execute()) { $user = $stmt->fetch(PDO::FETCH_ASSOC); } } catch (Exception $e) { echo $e->getMessage(); } return $user; } public function updateLoginStatus() { $stmt = $this->dbConn->prepare('UPDATE users SET login_status = :loginStatus, last_login = :lastLogin WHERE id = :id'); $stmt->bindParam(':loginStatus', $this->loginStatus); $stmt->bindParam(':lastLogin', $this->lastLogin); $stmt->bindParam(':id', $this->id); try { if($stmt->execute()) { return true; } else { return false; } } catch (Exception $e) { echo $e->getMessage(); } } public function getAllUsers() { $stmt = $this->dbConn->prepare("SELECT * FROM users"); $stmt->execute(); $users = $stmt->fetchAll(PDO::FETCH_ASSOC); return $users; } } ``` C:\xampp\htdocs\chatroom\bin\server.php ``` run(); ``` {% file src="/files/-MUJJml82nvs-OJl75u8" %} --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://learnphp.gitbook.io/learnphp/advanced/chat-application-in-php-and-mysql-using-ratchet-library-ok.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.