last2014/uwuzu-mirror
1
0
Fork 0
mirror of https://github.com/Daichimarukana/uwuzu.git synced 2026-06-04 19:14:41 +00:00
Code Activity

uwuzu v1.6.0 Hapuego

Browse Source
This commit is contained in:
だいちまる
2025-08-05 13:46:18 +09:00
parent 0d7c0a8879
commit e15b52a205
70 changed files with 7406 additions and 5172 deletions
Download Patch File Download Diff File Expand all files Collapse all files
user/outbox/index.php
+92 -85
View File
@@ -5,107 +5,114 @@ blockedIP($_SERVER['REMOTE_ADDR']);
$serversettings_file = "../../server/serversettings.ini";
$serversettings = parse_ini_file($serversettings_file, true);
if(safetext($serversettings["serverinfo"]["server_activitypub"]) === "true"){
if (safetext($serversettings["serverinfo"]["server_activitypub"]) === "true") {
header("Content-Type: application/activity+json; charset=utf-8");
header("Access-Control-Allow-Origin: *");
$domain = $_SERVER['HTTP_HOST'];
require('../../db.php');
// データベースに接続
try {
$option = array(
$pdo = new PDO('mysql:charset=utf8mb4;dbname=' . DB_NAME . ';host=' . DB_HOST, DB_USER, DB_PASS, [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::MYSQL_ATTR_MULTI_STATEMENTS => false
);
$pdo = new PDO('mysql:charset=utf8mb4;dbname=' . DB_NAME . ';host=' . DB_HOST, DB_USER, DB_PASS, $option);
]);
} catch (PDOException $e) {
// 接続エラーのときエラー内容を取得する
$error_message[] = $e->getMessage();
http_response_code(500);
echo json_encode(['error' => $e->getMessage()]);
exit;
}
$user = safetext($_GET['actor']);
$user = safetext($_GET['actor'] ?? '');
$userid = str_replace('@', '', str_replace('@' . $domain, '', $user));
$page = isset($_GET['page']) ? (int)$_GET['page'] : 0;
$itemsPerPage = 10;
$offset = ($page > 0 ? ($page - 1) : 0) * $itemsPerPage;
$userid = str_replace('@','', str_replace('@'.$domain.'', '', $user));
if( !empty($pdo) ) {
$dbh = new PDO('mysql:charset=utf8mb4;dbname='.DB_NAME.';host='.DB_HOST, DB_USER, DB_PASS, array(
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
));
$userQuery = $dbh->prepare("SELECT username, userid, profile, follower, iconname FROM account WHERE userid = :userid");
$userQuery->bindValue(':userid', $userid);
$userQuery->execute();
$userData = $userQuery->fetch();
$dbh = new PDO('mysql:charset=utf8mb4;dbname=' . DB_NAME . ';host=' . DB_HOST, DB_USER, DB_PASS, [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true,
]);
$messageQuery = $dbh->prepare("SELECT * FROM ueuse WHERE account = :userid AND rpuniqid = '' ORDER BY datetime DESC");
$messageQuery->bindValue(':userid', $userid);
$messageQuery->execute();
$message_array = $messageQuery->fetchAll();
$messages = array();
foreach ($message_array as $row) {
$messages[] = $row;
}
$userQuery = $dbh->prepare("SELECT * FROM account WHERE userid = :userid");
$userQuery->bindValue(':userid', $userid);
$userQuery->execute();
$userData = $userQuery->fetch();
if (!$userData) {
echo json_encode(["type" => "user_not_found"]);
exit;
}
if (!empty($userData)) {
if (!empty($messages)) {
$orderedItems = array();
foreach ($messages as $value) {
$activity = array(
"type" => "Create",
"id" => "https://" . $domain . "/ueuse/activity/?ueuse=" . $value["uniqid"],
"url" => "https://" . $domain . "/ueuse/activity/?ueuse=" . $value["uniqid"],
"published" => date(DATE_ATOM, strtotime($value["datetime"])),
"to" => [
"https://www.w3.org/ns/activitystreams#Public",
],
"actor" => "https://" . $domain . "/actor/?actor=@" . $userid,
"object" => array(
"type" => "Note",
"@context" => "https://www.w3.org/ns/activitystreams",
"id" => "https://" . $domain . "/!" . $value["uniqid"],
"url" => "https://" . $domain . "/!" . $value["uniqid"],
"published" => date(DATE_ATOM, strtotime($value["datetime"])),
"to" => [
"https://www.w3.org/ns/activitystreams#Public",
],
"attributedTo" => "https://" . $domain . "/@" . $value["account"],
"content" => "".nl2br($value["ueuse"])."",
),
);
$orderedItems[] = $activity;
}
$item = array(
"type" => "OrderedCollection",
// 全投稿数取得
$countQuery = $dbh->prepare("SELECT COUNT(*) as cnt FROM ueuse WHERE account = :userid AND rpuniqid = ''");
$countQuery->bindValue(':userid', $userid);
$countQuery->execute();
$totalItems = (int)$countQuery->fetch()['cnt'];
if ($page === 0) {
// OrderedCollection（firstのみ）
echo json_encode([
"@context" => "https://www.w3.org/ns/activitystreams",
"id" => "https://{$domain}/user/outbox/?actor=@{$userid}",
"type" => "OrderedCollection",
"totalItems" => $totalItems,
"first" => "https://{$domain}/user/outbox/?actor=@{$userid}&page=1"
], JSON_UNESCAPED_UNICODE);
exit;
}
// ページ投稿取得
$messageQuery = $dbh->prepare("SELECT * FROM ueuse WHERE account = :userid AND rpuniqid = '' ORDER BY datetime DESC LIMIT :offset, :limit");
$messageQuery->bindValue(':userid', $userid);
$messageQuery->bindValue(':offset', $offset, PDO::PARAM_INT);
$messageQuery->bindValue(':limit', $itemsPerPage, PDO::PARAM_INT);
$messageQuery->execute();
$messages = $messageQuery->fetchAll();
$orderedItems = [];
foreach ($messages as $value) {
$id = $value["uniqid"];
$url = "https://{$domain}/ueuse/activity/?id={$id}";
$orderedItems[] = [
"type" => "Create",
"id" => $url,
"url" => $url,
"published" => date(DATE_ATOM, strtotime($value["datetime"])),
"to" => ["https://www.w3.org/ns/activitystreams#Public"],
"actor" => "https://{$domain}/actor/?actor=@{$userid}",
"object" => [
"type" => "Note",
"@context" => "https://www.w3.org/ns/activitystreams",
"id" => "https://" . $domain . "/user/outbox/?actor=@" . $userid . "&page=true",
"summary" => "outbox of " . $userid,
"totalItems" => count($messages),
"orderedItems" => $orderedItems,
);
echo json_encode($item, JSON_UNESCAPED_UNICODE);
} else {
$item = array(
"type" => "item_not_found",
);
echo json_encode($item, JSON_UNESCAPED_UNICODE);
}
} else {
$item = array(
"type" => "user_not_found",
);
echo json_encode($item, JSON_UNESCAPED_UNICODE);
}
"id" => $url,
"url" => $url,
"published" => date(DATE_ATOM, strtotime($value["datetime"])),
"to" => ["https://www.w3.org/ns/activitystreams#Public"],
"attributedTo" => "https://{$domain}/@{$value["account"]}",
"content" => preg_replace('/\r\n/i', "", nl2br($value["ueuse"])),
]
];
}
}else{
// prev/next リンク
$base_url = "https://{$domain}/user/outbox/?actor=@{$userid}";
$prev_page = $page > 1 ? $base_url . "&page=" . ($page - 1) : null;
$next_page = ($offset + $itemsPerPage < $totalItems) ? $base_url . "&page=" . ($page + 1) : null;
$response = [
"@context" => "https://www.w3.org/ns/activitystreams",
"id" => "{$base_url}&page={$page}",
"type" => "OrderedCollectionPage",
"partOf" => $base_url,
"totalItems" => $totalItems,
"orderedItems" => $orderedItems,
];
if ($prev_page) $response["prev"] = $prev_page;
if ($next_page) $response["next"] = $next_page;
echo json_encode($response, JSON_UNESCAPED_UNICODE);
} else {
header("HTTP/1.1 410 Gone");
}
?>
?>