TXTWRK

<?php header("Content-Type: application/json"); header("Access-Control-Allow-Origin: *"); header("Access-Control-Allow-Methods: GET, POST, OPTIONS"); header("Access-Control-Allow-Headers: Content-Type"); if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') { http_response_code(200); exit; } /* ---------------- INPUT ---------------- */ $action = $_GET['action'] ?? "list"; /* ===================================================== SERVER SETTINGS ===================================================== */ if ($action === "settings") { echo json_encode([ "success"=>true, "settings"=>[ "request_poll_interval"=>15000, // 15 seconds TUNE CODE "autosave_delay"=>7000 // 7 seconds TUNE CODE ] ]); exit; } /* ---------------- ROOT ---------------- */ $root = realpath(__DIR__ . "/../../"); if (!$root) { echo json_encode(["success"=>false,"error"=>"Invalid server root"]); exit; } /* ---------------- INPUT ---------------- */ $path = $_GET['path'] ?? ""; $path = trim($path, "/"); $target = $root; if ($path !== "") { $target = realpath($root . "/" . $path); } if ($target === false || strpos($target, $root) !== 0) { echo json_encode(["success"=>false,"error"=>"Invalid path"]); exit; } /* ===================================================== LIST DIRECTORY ===================================================== */ if ($action === "list") { $folders = []; $files = []; $items = @scandir($target); if ($items === false) { echo json_encode(["success"=>false,"error"=>"Cannot read directory"]); exit; } foreach ($items as $item) { if ($item === "." || $item === "..") continue; $full = $target . "/" . $item; if (is_dir($full)) { $folders[] = $item; } else { $files[] = $item; } } sort($folders); sort($files); echo json_encode([ "success"=>true, "path"=>$path, "folders"=>$folders, "files"=>$files ]); exit; } /* ===================================================== CREATE FOLDER ===================================================== */ if ($action === "mkdir") { $name = $_POST['name'] ?? ""; if (!$name) { echo json_encode(["success"=>false,"error"=>"Missing folder name"]); exit; } $new = $target . "/" . basename($name); if (mkdir($new)) { echo json_encode(["success"=>true]); } else { echo json_encode(["success"=>false,"error"=>"Cannot create folder"]); } exit; } /* ===================================================== CREATE FILE ===================================================== */ if ($action === "create_file") { $name = $_POST['name'] ?? ""; if (!$name) { echo json_encode(["success"=>false,"error"=>"Missing file name"]); exit; } $file = $target . "/" . basename($name); if (file_put_contents($file, "") !== false) { echo json_encode(["success"=>true]); } else { echo json_encode(["success"=>false,"error"=>"Cannot create file"]); } exit; } /* ===================================================== DELETE FILE / FOLDER ===================================================== */ if ($action === "delete") { $name = $_POST['name'] ?? ""; if (!$name) { echo json_encode(["success"=>false,"error"=>"Missing target"]); exit; } $full = $target . "/" . basename($name); if (is_dir($full)) { $ok = rmdir($full); } else { $ok = unlink($full); } echo json_encode(["success"=>$ok]); exit; } /* ===================================================== FILE UPLOAD ===================================================== */ if ($action === "upload") { if (!isset($_FILES['file'])) { echo json_encode(["success"=>false,"error"=>"No file uploaded"]); exit; } $name = basename($_FILES['file']['name']); $dest = $target . "/" . $name; if (move_uploaded_file($_FILES['file']['tmp_name'], $dest)) { echo json_encode(["success"=>true]); } else { echo json_encode(["success"=>false,"error"=>"Upload failed"]); } exit; } /* ===================================================== ENSURE EDIT FILE + MEMBER LOCK ===================================================== */ if ($action === "ensure_edit") { $file = $_POST['file'] ?? ""; $memberID = (int)($_POST['memberID'] ?? 0); if (!$file || !$memberID) { echo json_encode(["success"=>false,"error"=>"Missing params"]); exit; } $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false,"error"=>"Invalid file"]); exit; } $editFile = $base . ".txtwrk"; $lockFile = $base . "." . $memberID; /* create edit buffer if missing */ if (!file_exists($editFile)) { $content = file_get_contents($base); $init = [ "history" => [ [ "content" => $content, "cursor" => 0, "time" => time() ] ] ]; file_put_contents($editFile, json_encode($init, JSON_PRETTY_PRINT)); } /* check if another member is editing */ $locks = glob($base . ".*"); foreach ($locks as $l) { if (preg_match('/\.\d+$/',$l) && $l !== $lockFile) { echo json_encode([ "success"=>true, "readonly"=>true ]); exit; } } /* create my lock */ if (!file_exists($lockFile)) { file_put_contents($lockFile,""); } echo json_encode([ "success"=>true, "readonly"=>false ]); exit; } /* ===================================================== LOAD EDIT FILE ===================================================== */ if ($action === "load_edit") { $file = $_GET['file'] ?? ""; $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false]); exit; } $editFile = $base . ".txtwrk"; if (!file_exists($editFile)) { $content = file_get_contents($base); $init = [ "history" => [ [ "content" => $content, "cursor" => 0, "time" => time() ] ] ]; file_put_contents($editFile, json_encode($init, JSON_PRETTY_PRINT)); } $json = json_decode(file_get_contents($editFile), true); $history = []; if ($json && isset($json["history"])) { $history = $json["history"]; } $last = end($history); echo json_encode([ "success"=>true, "history"=>$history, "content"=>$last["content"] ?? "", "cursor"=>$last["cursor"] ?? 0 ]); exit; } if ($action === "save_edit") { $file = $_POST['file'] ?? ""; $content = $_POST['content'] ?? ""; $cursor = intval($_POST['cursor'] ?? 0); $memberID = (int)($_POST['memberID'] ?? 0); if (!$file || !$memberID) { echo json_encode(["success"=>false,"error"=>"Missing parameters"]); exit; } $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false,"error"=>"Invalid file"]); exit; } /* VERIFY LOCK OWNERSHIP */ $lockFile = $base . "." . $memberID; if (!file_exists($lockFile)) { echo json_encode([ "success"=>false, "error"=>"You do not own the edit lock for this file" ]); exit; } $editFile = $base . ".txtwrk"; $history = []; /* LOAD EXISTING HISTORY */ if (file_exists($editFile)) { $json = json_decode(file_get_contents($editFile), true); if ($json && isset($json["history"])) { $history = $json["history"]; } } /* APPEND NEW EDIT */ $history[] = [ "content" => $content, "cursor" => $cursor, "memberID" => $memberID, "time" => time() ]; /* WRITE HISTORY WITH FILE LOCK */ $fp = fopen($editFile, "c+"); if ($fp) { flock($fp, LOCK_EX); ftruncate($fp, 0); fwrite($fp, json_encode([ "history"=>$history ], JSON_PRETTY_PRINT)); fflush($fp); flock($fp, LOCK_UN); fclose($fp); } else { echo json_encode([ "success"=>false, "error"=>"Unable to write edit history" ]); exit; } /* UPDATE REAL FILE */ file_put_contents($base, $content); echo json_encode([ "success"=>true ]); exit; } /* ===================================================== REQUEST FILE ACCESS ===================================================== */ if ($action === "request_file") { $file = $_POST['file'] ?? ""; $memberID = (int)($_POST['memberID'] ?? 0); if (!$file || !$memberID) { echo json_encode(["success"=>false,"error"=>"Missing params"]); exit; } $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false,"error"=>"Invalid file"]); exit; } /* ---------------- FIND CURRENT OWNER ---------------- */ $locks = glob($base . ".*"); $currentOwner = null; foreach ($locks as $l) { if (preg_match('/\.(\d+)$/',$l,$m)) { $currentOwner = (int)$m[1]; break; } } if (!$currentOwner) { echo json_encode(["success"=>false,"error"=>"No current owner"]); exit; } /* ---------------- REQUEST QUEUE ---------------- */ $requestFile = $base . "." . $currentOwner; $list = []; if (file_exists($requestFile)) { $json = json_decode(file_get_contents($requestFile), true); if (is_array($json)) { $list = $json; } } foreach ($list as $r) { if ($r["user"] == $memberID && $r["status"] === "pending") { echo json_encode(["success"=>false,"error"=>"Already requested"]); exit; } } $list[] = [ "user"=>$memberID, "status"=>"pending", "time"=>time() ]; file_put_contents($requestFile, json_encode($list, JSON_PRETTY_PRINT)); /* UPDATE FLAG FILE */ $flag = $root . "/server/txtwrk/manage.php.txtwrk"; $data = [ "messages" => [], "requests" => [] ]; if (file_exists($flag)) { $json = json_decode(file_get_contents($flag), true); if ($json) { $data = $json; } } $found = false; foreach ($data["requests"] as &$r) { if ($r["user"] == $memberID && $r["file"] === $file) { $r["count"]++; $found = true; break; } } if (!$found) { $data["requests"][] = [ "user"=>$memberID, "file"=>$file, "count"=>1 ]; } /* WRITE FLAG WITH LOCK */ $fp = fopen($flag,"c+"); if ($fp) { flock($fp, LOCK_EX); ftruncate($fp,0); fwrite($fp,json_encode($data,JSON_PRETTY_PRINT)); fflush($fp); flock($fp, LOCK_UN); fclose($fp); } echo json_encode(["success"=>true]); exit; } /* ===================================================== POLL REQUEST FLAG ===================================================== */ if ($action === "poll_requests") { $flag = $root . "/server/txtwrk/manage.php.txtwrk"; if (!file_exists($flag)) { file_put_contents($flag,json_encode([ "messages"=>[], "requests"=>[] ],JSON_PRETTY_PRINT)); } $data = json_decode(file_get_contents($flag),true); echo json_encode([ "success"=>true, "data"=>$data ]); exit; } /* ===================================================== GRANT FILE ACCESS ===================================================== */ if ($action === "grant_request") { $file = $_POST['file'] ?? ""; $memberID = (int)($_POST['memberID'] ?? 0); if (!$file || !$memberID) { echo json_encode(["success"=>false,"error"=>"Missing params"]); exit; } $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false,"error"=>"Invalid file"]); exit; } /* ---------------- FIND CURRENT OWNER ---------------- */ $locks = glob($base . ".*"); $currentOwner = null; $currentLockFile = null; foreach ($locks as $l) { if (preg_match('/\.(\d+)$/',$l,$m)) { $currentOwner = (int)$m[1]; $currentLockFile = $l; break; } } if (!$currentOwner) { echo json_encode(["success"=>false,"error"=>"No current owner"]); exit; } /* ---------------- LOAD REQUEST QUEUE ---------------- */ $requestFile = $base . "." . $currentOwner; $queue = []; if (file_exists($requestFile)) { $json = json_decode(file_get_contents($requestFile), true); if (is_array($json)) { $queue = $json; } } /* remove granted user from queue */ $queue = array_filter($queue,function($r) use ($memberID){ return $r["user"] != $memberID; }); file_put_contents($requestFile,json_encode(array_values($queue),JSON_PRETTY_PRINT)); /* ---------------- TRANSFER LOCK ---------------- */ $newLock = $base . "." . $memberID; if (!rename($currentLockFile,$newLock)) { echo json_encode([ "success"=>false, "error"=>"Failed transferring ownership" ]); exit; } /* ---------------- UPDATE FLAG FILE ---------------- */ $flag = $root . "/server/txtwrk/manage.php.txtwrk"; if (!file_exists($flag)) { file_put_contents($flag,json_encode([ "messages"=>[], "requests"=>[] ],JSON_PRETTY_PRINT)); } $data = json_decode(file_get_contents($flag),true); foreach ($data["requests"] as $k => $r) { if ($r["file"] === $file) { unset($data["requests"][$k]); } } $fp = fopen($flag,"c+"); if ($fp) { flock($fp,LOCK_EX); ftruncate($fp,0); fwrite($fp,json_encode($data,JSON_PRETTY_PRINT)); fflush($fp); flock($fp,LOCK_UN); fclose($fp); } echo json_encode([ "success"=>true, "new_owner"=>$memberID ]); exit; } /* ===================================================== CHECK FILE OWNER ===================================================== */ if ($action === "check_file_owner") { $file = $_GET['file'] ?? ""; if (!$file) { echo json_encode(["success"=>false,"error"=>"Missing file"]); exit; } $base = realpath($root . "/" . $file); if (!$base || strpos($base,$root)!==0) { echo json_encode(["success"=>false,"error"=>"Invalid file"]); exit; } $locks = glob($base . ".*"); $owner = null; foreach ($locks as $l) { if (preg_match('/\.(\d+)$/',$l,$m)) { $owner = (int)$m[1]; break; } } echo json_encode([ "success"=>true, "owner"=>$owner ]); exit; } /* ===================================================== CLOSE SESSION (REMOVE LOCK) ===================================================== */ if ($action === "close_session") { $memberID = (int)($_POST['memberID'] ?? 0); if (!$memberID) { echo json_encode(["success"=>false]); exit; } $locks = glob($root . "/*." . $memberID); foreach ($locks as $l) { unlink($l); } echo json_encode(["success"=>true]); exit; } /* ===================================================== CHAT COUNT - INCREMENT (only count, no messages stored) ===================================================== */ if ($action === "increment_chat_count") { $flag = $root . "/server/txtwrk/manage.php.txtwrk"; $data = [ "messages" => [], "requests" => [], "chat_count" => 0 ]; if (file_exists($flag)) { $json = json_decode(file_get_contents($flag), true); if ($json) $data = $json; } $data["chat_count"] = (int)($data["chat_count"] ?? 0) + 1; /* WRITE WITH LOCK */ $fp = fopen($flag, "c+"); if ($fp) { flock($fp, LOCK_EX); ftruncate($fp, 0); fwrite($fp, json_encode($data, JSON_PRETTY_PRINT)); fflush($fp); flock($fp, LOCK_UN); fclose($fp); } echo json_encode(["success"=>true]); exit; } /* ===================================================== CHAT COUNT - GET (only returns the number) ===================================================== */ if ($action === "get_chat_count") { $flag = $root . "/server/txtwrk/manage.php.txtwrk"; $count = 0; if (file_exists($flag)) { $json = json_decode(file_get_contents($flag), true); $count = (int)($json["chat_count"] ?? 0); } echo json_encode([ "success" => true, "count" => $count ]); exit; } echo json_encode(["success"=>false,"error"=>"Unknown action"]); ?>