CREATE DATABASE flatchat;
USE flatchat;
CREATE TABLE users (
id INT AUTO_INCREMENT PRIMARY KEY,
username VARCHAR(50) UNIQUE,
password VARCHAR(255),
role ENUM('admin','dj','user') DEFAULT 'user',
xp INT DEFAULT 0,
level INT DEFAULT 1
);
CREATE TABLE messages (
id INT AUTO_INCREMENT PRIMARY KEY,
user_id INT,
message TEXT,
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
CREATE TABLE radio_status (
id INT AUTO_INCREMENT PRIMARY KEY,
is_live TINYINT DEFAULT 0,
dj_name VARCHAR(50),
current_song VARCHAR(255),
listeners INT DEFAULT 0
);
set_charset("utf8mb4");
?>
session_start();
require "db.php";
$username = $_POST['username'];
$password = $_POST['password'];
$user = $conn->query("SELECT * FROM users WHERE username='$username'")->fetch_assoc();
if($user && password_verify($password, $user['password'])){
$_SESSION['user'] = $user['username'];
$_SESSION['id'] = $user['id'];
echo "OK";
const io = require("socket.io")(3000,{
cors:{origin:"*"}
});
let users = {};
io.on("connection",(socket)=>{
socket.on("join",(user)=>{
users[socket.id]=user;
io.emit("system",user+" giriş yaptı");
});
socket.on("message",(msg)=>{
io.emit("message",{user:users[socket.id],text:msg});
});
socket.on("disconnect",()=>{
io.emit("system",users[socket.id]+" çıktı");
delete users[socket.id];
});
});
console.log("Chat server running");
http://localhost:8000/stream
}
$conn->query("
UPDATE radio_status
SET is_live=1, dj_name='DJ', current_song='Şarkı'
");