fix(news): restore publication flow and deduplicate dashboard friends
This commit is contained in:
1 parent
ef94646d60
commit
9b0ea2fb16
22 files changed
+614
-171
No files matched your search
@@ -0,0 +1,7 @@
|
||||
-- Existing articles remain published. Preserve any publication settings already present.
|
||||
ALTER TABLE website_articles
|
||||
ADD COLUMN IF NOT EXISTS status VARCHAR(20) NOT NULL DEFAULT 'published',
|
||||
ADD COLUMN IF NOT EXISTS publish_at TIMESTAMP NULL DEFAULT NULL,
|
||||
ADD COLUMN IF NOT EXISTS published_at TIMESTAMP NULL DEFAULT NULL;
|
||||
CREATE INDEX IF NOT EXISTS idx_website_articles_publication
|
||||
ON website_articles (status, publish_at, created_at);
|
||||
@@ -12,6 +12,7 @@ import { logger } from "../src/lib/logger";
|
||||
import { redis } from "../src/lib/redis";
|
||||
import { emulatorOffline, healthDegraded } from "../src/lib/services/alert";
|
||||
import { runCatalogExport } from "../src/lib/services/catalog-git-export";
|
||||
import { invalidateNewsCache } from "../src/lib/services/news-cache";
|
||||
import { rcon } from "../src/lib/services/rcon";
|
||||
|
||||
function captureWorkerError(err: unknown, context: string): void {
|
||||
@@ -246,12 +247,10 @@ async function publishScheduledArticles(): Promise<void> {
|
||||
lte(WebsiteArticles.publishAt, now),
|
||||
),
|
||||
);
|
||||
const info = result as unknown as {
|
||||
affectedRows?: number;
|
||||
rowsAffected?: number;
|
||||
};
|
||||
const published = info.affectedRows ?? info.rowsAffected ?? 0;
|
||||
const [info] = result;
|
||||
const published = info.affectedRows ?? 0;
|
||||
if (published > 0) {
|
||||
await invalidateNewsCache();
|
||||
logger.info(`Published ${published} scheduled article(s)`, {
|
||||
module: "jobs",
|
||||
});
|
||||
|
||||
File diff suppressed because it is too large.
Load diff
+98
-103
File diff suppressed because it is too large.
Load diff
@@ -99,13 +99,7 @@ export default async function MePage({
|
||||
);
|
||||
const canClaim = referralTotal >= needed;
|
||||
const remaining = Math.max(0, needed - referralTotal);
|
||||
const onlineFriends = [
|
||||
...new Map(
|
||||
friends
|
||||
.filter((friend) => friend.online === "1")
|
||||
.map((friend) => [friend.id, friend]),
|
||||
).values(),
|
||||
];
|
||||
const onlineFriends = friends.filter((friend) => friend.online === "1");
|
||||
const date = (value: number) =>
|
||||
value
|
||||
? format.dateTime(new Date(value * 1000), { dateStyle: "medium" })
|
||||
|
||||
@@ -8,8 +8,8 @@ import { toggleReaction } from "@/actions/article-reactions";
|
||||
import Link from "@/components/link";
|
||||
import { ContentCard, EmptyState } from "@/components/public/ui";
|
||||
import { SanitizedHtml } from "@/components/shared/sanitized-html";
|
||||
import { articleSlug } from "@/lib/article-input";
|
||||
import { auth } from "@/lib/auth";
|
||||
import { cachedQuery } from "@/lib/cached-db";
|
||||
import {
|
||||
db,
|
||||
User,
|
||||
@@ -20,6 +20,7 @@ import {
|
||||
import { excerpt } from "@/lib/format";
|
||||
import { formatDate } from "@/lib/format-date";
|
||||
import { sanitize } from "@/lib/sanitize";
|
||||
import { cacheNews } from "@/lib/services/news-cache";
|
||||
|
||||
type SearchParams = Promise<{
|
||||
comment?: string;
|
||||
@@ -46,10 +47,10 @@ function feedbackStyle(tone: "success" | "error"): CSSProperties {
|
||||
export async function generateMetadata({
|
||||
params,
|
||||
}: {
|
||||
params: Promise<{ slug: string }>;
|
||||
params: Promise<{ slug: string[] }>;
|
||||
}): Promise<Metadata> {
|
||||
const appUrl = process.env.APP_URL ?? "http://localhost:3000";
|
||||
const { slug } = await params;
|
||||
const slug = articleSlug((await params).slug);
|
||||
const [article] = await db
|
||||
.select({
|
||||
title: WebsiteArticles.title,
|
||||
@@ -95,16 +96,14 @@ export default async function ArticlePage({
|
||||
params,
|
||||
searchParams,
|
||||
}: {
|
||||
params: Promise<{ slug: string }>;
|
||||
params: Promise<{ slug: string[] }>;
|
||||
searchParams: SearchParams;
|
||||
}) {
|
||||
const { slug } = await params;
|
||||
const slug = articleSlug((await params).slug);
|
||||
const { comment, reaction, error } = await searchParams;
|
||||
const t = await getTranslations("pages.article");
|
||||
|
||||
const article = await cachedQuery(
|
||||
`article:slug:${slug}`,
|
||||
async () => {
|
||||
const article = await cacheNews(`article:slug:${slug}`, 60_000, async () => {
|
||||
const [row] = await db
|
||||
.select({
|
||||
id: WebsiteArticles.id,
|
||||
@@ -130,9 +129,7 @@ export default async function ArticlePage({
|
||||
.limit(1)
|
||||
.catch(() => []);
|
||||
return row ?? null;
|
||||
},
|
||||
60,
|
||||
);
|
||||
});
|
||||
if (!article) notFound();
|
||||
|
||||
const articleId = article.id;
|
||||
|
||||
@@ -31,6 +31,8 @@ export default async function EditArticle({
|
||||
title: WebsiteArticles.title,
|
||||
shortStory: WebsiteArticles.shortStory,
|
||||
fullStory: WebsiteArticles.fullStory,
|
||||
status: WebsiteArticles.status,
|
||||
publishAt: WebsiteArticles.publishAt,
|
||||
image: WebsiteArticles.image,
|
||||
})
|
||||
.from(WebsiteArticles)
|
||||
@@ -63,7 +65,7 @@ export default async function EditArticle({
|
||||
action={async (fd) => {
|
||||
"use server";
|
||||
fd.set("id", String(article.id));
|
||||
await updateArticle(fd);
|
||||
return updateArticle(fd);
|
||||
}}
|
||||
defaultValues={{
|
||||
title: article.title,
|
||||
@@ -71,6 +73,8 @@ export default async function EditArticle({
|
||||
image: article.image,
|
||||
shortStory: article.shortStory,
|
||||
fullStory: article.fullStory,
|
||||
status: article.status,
|
||||
publishAt: article.publishAt?.toISOString(),
|
||||
}}
|
||||
/>
|
||||
<form action={deleteArticle} style={{ marginTop: "1rem" }}>
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
import { and, eq, or, sql } from "drizzle-orm";
|
||||
import { apiJson } from "@/lib/api";
|
||||
import { db, WebsiteArticles } from "@/lib/db";
|
||||
import { apiCacheKey, cacheSafe, redisCache } from "@/lib/redis-cache";
|
||||
import { logger } from "@/lib/logger";
|
||||
import { apiCacheKey, cacheSafe } from "@/lib/redis-cache";
|
||||
import { cacheNews } from "@/lib/services/news-cache";
|
||||
|
||||
/**
|
||||
* GET /api/articles/:slug — single website_article by slug, including the
|
||||
@@ -14,9 +16,9 @@ export async function GET(
|
||||
const { slug } = await params;
|
||||
|
||||
try {
|
||||
const data = await redisCache(
|
||||
const data = await cacheNews(
|
||||
apiCacheKey(`articles:${slug}`),
|
||||
60,
|
||||
60_000,
|
||||
async () => {
|
||||
const [article] = await db
|
||||
.select({
|
||||
@@ -55,7 +57,8 @@ export async function GET(
|
||||
}
|
||||
|
||||
return apiJson(data);
|
||||
} catch {
|
||||
} catch (error) {
|
||||
logger.error("Public news query failed", { module: "news", error });
|
||||
// DB unavailable — treat as not found rather than a 500.
|
||||
return apiJson({ error: "Article not found" }, { status: 200 });
|
||||
}
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
import { and, count, desc, eq, or, sql } from "drizzle-orm";
|
||||
import { apiJson, pagination } from "@/lib/api";
|
||||
import { db, WebsiteArticles } from "@/lib/db";
|
||||
import { apiCacheKey, cacheSafe, redisCache } from "@/lib/redis-cache";
|
||||
import { logger } from "@/lib/logger";
|
||||
import { apiCacheKey, cacheSafe } from "@/lib/redis-cache";
|
||||
import { cacheNews } from "@/lib/services/news-cache";
|
||||
|
||||
/**
|
||||
* GET /api/articles — paginated list of website_articles, newest first.
|
||||
@@ -13,9 +15,9 @@ export async function GET(req: Request) {
|
||||
const { page, perPage, skip, take } = pagination(sp);
|
||||
|
||||
try {
|
||||
const data = await redisCache(
|
||||
const data = await cacheNews(
|
||||
apiCacheKey(`articles:${page}:${perPage}`),
|
||||
60,
|
||||
60_000,
|
||||
async () => {
|
||||
const publishedFilter = and(
|
||||
eq(WebsiteArticles.status, "published"),
|
||||
@@ -60,7 +62,8 @@ export async function GET(req: Request) {
|
||||
);
|
||||
|
||||
return apiJson(data);
|
||||
} catch {
|
||||
} catch (error) {
|
||||
logger.error("Public news query failed", { module: "news", error });
|
||||
// DB unavailable — return an empty payload instead of a 500.
|
||||
return apiJson(
|
||||
{ data: [], meta: { page, perPage, total: 0, lastPage: 1 } },
|
||||
|
||||
@@ -3,7 +3,9 @@ import { env } from "@/env";
|
||||
import { apiJson } from "@/lib/api";
|
||||
import { db, User, WebsiteArticles } from "@/lib/db";
|
||||
import { resolveHotelName } from "@/lib/hotel-name";
|
||||
import { apiCacheKey, cacheSafe, redisCache } from "@/lib/redis-cache";
|
||||
import { logger } from "@/lib/logger";
|
||||
import { apiCacheKey, cacheSafe } from "@/lib/redis-cache";
|
||||
import { cacheNews } from "@/lib/services/news-cache";
|
||||
|
||||
/**
|
||||
* GET /api/home — combined landing payload: the latest 4 website_articles and
|
||||
@@ -12,7 +14,7 @@ import { apiCacheKey, cacheSafe, redisCache } from "@/lib/redis-cache";
|
||||
*/
|
||||
export async function GET(_req: Request) {
|
||||
try {
|
||||
const data = await redisCache(apiCacheKey("home"), 15, async () => {
|
||||
const data = await cacheNews(apiCacheKey("home"), 15_000, async () => {
|
||||
const [articles, onlineRows, hotelName] = await Promise.all([
|
||||
db
|
||||
.select({
|
||||
@@ -45,7 +47,8 @@ export async function GET(_req: Request) {
|
||||
});
|
||||
});
|
||||
return apiJson(data);
|
||||
} catch {
|
||||
} catch (error) {
|
||||
logger.error("Public news query failed", { module: "news", error });
|
||||
return apiJson(
|
||||
{ articles: [], online: 0, hotelName: env.HOTEL_NAME },
|
||||
{ status: 200 },
|
||||
|
||||
File diff suppressed because it is too large.
Load diff
@@ -1,4 +1,5 @@
|
||||
"use client";
|
||||
import { useTranslations } from "next-intl";
|
||||
import {
|
||||
Dialog,
|
||||
DialogContent,
|
||||
@@ -28,6 +29,7 @@ export function ArticlePreview({
|
||||
data: ArticlePreviewData | null;
|
||||
onClose: () => void;
|
||||
}) {
|
||||
const t = useTranslations("pages.admin.articles.form");
|
||||
const document = data
|
||||
? `<!doctype html><html><head><meta http-equiv="Content-Security-Policy" content="default-src 'none'; img-src https: http: data:; style-src 'unsafe-inline'"><meta name="viewport" content="width=device-width, initial-scale=1"><style>:root{color-scheme:light;background:Canvas;color:CanvasText}body{font:16px/1.6 system-ui;padding:20px;margin:auto;max-width:760px;overflow-wrap:anywhere}img{max-width:100%;height:auto}h1{line-height:1.2}pre{white-space:pre-wrap}</style></head><body><h1>${escapeHtml(data.title)}</h1>${data.image ? `<img src="${escapeHtml(data.image)}" alt="">` : ""}<p>${escapeHtml(data.summary)}</p>${data.body}</body></html>`
|
||||
: "";
|
||||
@@ -40,13 +42,13 @@ export function ArticlePreview({
|
||||
>
|
||||
<DialogContent className="sm:max-w-4xl h-[85dvh] flex flex-col min-h-0">
|
||||
<DialogHeader>
|
||||
<DialogTitle>Article preview</DialogTitle>
|
||||
<DialogTitle>{t("previewTitle")}</DialogTitle>
|
||||
</DialogHeader>
|
||||
<p className="text-xs text-muted-foreground">
|
||||
Content preview. The published page applies the site theme.
|
||||
{t("previewDescription")}
|
||||
</p>
|
||||
<iframe
|
||||
title="Article content preview"
|
||||
title={t("previewFrame")}
|
||||
sandbox=""
|
||||
srcDoc={document}
|
||||
className="min-h-0 flex-1 w-full bg-background rounded border"
|
||||
|
||||
@@ -0,0 +1,27 @@
|
||||
import { readFileSync } from "node:fs";
|
||||
import { expect, it } from "vitest";
|
||||
import { articleSlug, readArticleInput } from "./article-input";
|
||||
|
||||
it("normalizes Next catch-all slug parameters", () => {
|
||||
expect(articleSlug(["welcome"])).toBe("welcome");
|
||||
expect(articleSlug("welcome")).toBe("welcome");
|
||||
});
|
||||
it("keeps the selected timezone instant when scheduling", () => {
|
||||
const form = new FormData();
|
||||
form.set("title", "News");
|
||||
form.set("status", "scheduled");
|
||||
form.set("publishAt", "2026-09-06T20:00:00+02:00");
|
||||
expect(readArticleInput(form).publishAt?.toISOString()).toBe(
|
||||
"2026-09-06T18:00:00.000Z",
|
||||
);
|
||||
});
|
||||
it("ships additive publication columns for existing installations", () => {
|
||||
const sql = readFileSync(
|
||||
"drizzle/migrations/0025_article_publication.sql",
|
||||
"utf8",
|
||||
);
|
||||
for (const column of ["status", "publish_at", "published_at"])
|
||||
expect(sql).toContain(`ADD COLUMN IF NOT EXISTS ${column}`);
|
||||
expect(sql).toContain("DEFAULT 'published'");
|
||||
expect(sql).not.toMatch(/DROP|UPDATE\s+website_articles/i);
|
||||
});
|
||||
@@ -0,0 +1,47 @@
|
||||
import type { ActionResult } from "./safe-action-shared";
|
||||
export type ArticleSaveResult = ActionResult<{ redirectTo: string }>;
|
||||
export class ArticleInputError extends Error {
|
||||
constructor(
|
||||
public readonly code:
|
||||
| "titleRequired"
|
||||
| "titleTooLong"
|
||||
| "summaryTooLong"
|
||||
| "imageTooLong"
|
||||
| "invalidStatus"
|
||||
| "publishDateRequired",
|
||||
) {
|
||||
super(code);
|
||||
}
|
||||
}
|
||||
export function readArticleInput(form: FormData) {
|
||||
const text = (key: string) =>
|
||||
String(form.get(key) ?? "")
|
||||
.normalize("NFC")
|
||||
.trim();
|
||||
const title = text("title"),
|
||||
shortStory = text("shortStory"),
|
||||
fullStory = text("fullStory"),
|
||||
image = text("image");
|
||||
if (!title) throw new ArticleInputError("titleRequired");
|
||||
if (title.length > 255) throw new ArticleInputError("titleTooLong");
|
||||
if (shortStory.length > 255) throw new ArticleInputError("summaryTooLong");
|
||||
if (image.length > 255) throw new ArticleInputError("imageTooLong");
|
||||
const status = text("status") || "published";
|
||||
if (status !== "published" && status !== "draft" && status !== "scheduled")
|
||||
throw new ArticleInputError("invalidStatus");
|
||||
const publishAt = status === "scheduled" ? new Date(text("publishAt")) : null;
|
||||
if (publishAt && Number.isNaN(publishAt.getTime()))
|
||||
throw new ArticleInputError("publishDateRequired");
|
||||
return {
|
||||
title,
|
||||
shortStory,
|
||||
fullStory,
|
||||
image,
|
||||
status,
|
||||
publishAt,
|
||||
rawSlug: text("slug"),
|
||||
};
|
||||
}
|
||||
export function articleSlug(value: string | string[]): string {
|
||||
return Array.isArray(value) ? value.join("/") : value;
|
||||
}
|
||||
@@ -0,0 +1,67 @@
|
||||
import { beforeEach, expect, it, vi } from "vitest";
|
||||
|
||||
const state = vi.hoisted(() => ({
|
||||
revision: "0",
|
||||
values: new Map<string, unknown>(),
|
||||
get: vi.fn(),
|
||||
set: vi.fn(),
|
||||
status: "ready",
|
||||
}));
|
||||
vi.mock("@/lib/redis", () => ({ redis: state }));
|
||||
vi.mock("@/lib/logger", () => ({ logger: { error: vi.fn() } }));
|
||||
vi.mock("@/lib/cache", () => ({
|
||||
cached: async (key: string, _ttl: number, query: () => Promise<unknown>) => {
|
||||
if (state.values.has(key)) return state.values.get(key);
|
||||
const result = await query();
|
||||
state.values.set(key, result);
|
||||
return result;
|
||||
},
|
||||
}));
|
||||
|
||||
import { cacheNews, invalidateNewsCache } from "./news-cache";
|
||||
|
||||
beforeEach(() => {
|
||||
state.values.clear();
|
||||
state.revision = "0";
|
||||
state.status = "ready";
|
||||
state.get.mockReset().mockImplementation(async () => state.revision);
|
||||
state.set
|
||||
.mockReset()
|
||||
.mockImplementation(async (_key: string, value: string) => {
|
||||
state.revision = value;
|
||||
});
|
||||
});
|
||||
it("invalidates a previously cached public list", async () => {
|
||||
const query = vi
|
||||
.fn()
|
||||
.mockResolvedValueOnce([])
|
||||
.mockResolvedValueOnce(["new article"]);
|
||||
expect(await cacheNews("list", 60000, query)).toEqual([]);
|
||||
await invalidateNewsCache();
|
||||
expect(await cacheNews("list", 60000, query)).toEqual(["new article"]);
|
||||
});
|
||||
it("does not let a stale in-flight read replace a newer revision", async () => {
|
||||
let finish!: (value: string[]) => void;
|
||||
const old = cacheNews(
|
||||
"list",
|
||||
60000,
|
||||
() =>
|
||||
new Promise<string[]>((resolve) => {
|
||||
finish = resolve;
|
||||
}),
|
||||
);
|
||||
await vi.waitFor(() => expect(finish).toBeDefined());
|
||||
await invalidateNewsCache();
|
||||
expect(await cacheNews("list", 60000, async () => ["new"])).toEqual(["new"]);
|
||||
finish([]);
|
||||
await old;
|
||||
expect(await cacheNews("list", 60000, async () => ["wrong"])).toEqual([
|
||||
"new",
|
||||
]);
|
||||
});
|
||||
it("reads fresh data when Redis is unavailable", async () => {
|
||||
state.get.mockRejectedValue(Error("offline"));
|
||||
expect(await cacheNews("list", 60000, async () => ["fresh"])).toEqual([
|
||||
"fresh",
|
||||
]);
|
||||
});
|
||||
@@ -0,0 +1,32 @@
|
||||
import "server-only";
|
||||
import { randomUUID } from "node:crypto";
|
||||
import { cached } from "@/lib/cache";
|
||||
import { logger } from "@/lib/logger";
|
||||
import { redis } from "@/lib/redis";
|
||||
|
||||
const REVISION_KEY = "cms:news:revision";
|
||||
export async function cacheNews<T>(
|
||||
key: string,
|
||||
ttlMs: number,
|
||||
query: () => Promise<T>,
|
||||
): Promise<T> {
|
||||
if (!redis || redis.status === "end") return query();
|
||||
let revision: string;
|
||||
try {
|
||||
revision = (await redis.get(REVISION_KEY)) ?? "0";
|
||||
} catch {
|
||||
return query();
|
||||
}
|
||||
return cached(`news:${revision}:${key}`, ttlMs, query);
|
||||
}
|
||||
export async function invalidateNewsCache(): Promise<void> {
|
||||
if (!redis || redis.status === "end") return;
|
||||
try {
|
||||
await redis.set(REVISION_KEY, randomUUID());
|
||||
} catch (error) {
|
||||
logger.error("News saved but public cache invalidation failed", {
|
||||
module: "news",
|
||||
error,
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -1,7 +1,8 @@
|
||||
import { logger } from "@/lib/logger";
|
||||
import { cacheNews } from "@/lib/services/news-cache";
|
||||
import "server-only";
|
||||
|
||||
import { and, desc, eq, or, sql } from "drizzle-orm";
|
||||
import { cached } from "@/lib/cache";
|
||||
import { db, WebsiteArticles } from "@/lib/db";
|
||||
|
||||
export interface NewsListItem {
|
||||
@@ -32,7 +33,7 @@ const FETCH_LIMIT = 30;
|
||||
*/
|
||||
export async function getNewsList(limit: number): Promise<NewsListItem[]> {
|
||||
try {
|
||||
const rows = await cached<NewsListRow[]>(CACHE_KEY, TTL_MS, () =>
|
||||
const rows = await cacheNews<NewsListRow[]>(CACHE_KEY, TTL_MS, () =>
|
||||
db
|
||||
.select({
|
||||
slug: WebsiteArticles.slug,
|
||||
@@ -60,7 +61,8 @@ export async function getNewsList(limit: number): Promise<NewsListItem[]> {
|
||||
createdAt: a.createdAt ? new Date(a.createdAt) : null,
|
||||
}))
|
||||
.slice(0, limit);
|
||||
} catch {
|
||||
} catch (error) {
|
||||
logger.error("Public news query failed", { module: "news", error });
|
||||
return [];
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,78 @@
|
||||
import { beforeEach, describe, expect, it, vi } from "vitest";
|
||||
|
||||
const state = vi.hoisted(() => ({
|
||||
friends: [] as { id: number; username: string; online: string }[],
|
||||
}));
|
||||
vi.mock("@/lib/hotel-name", () => ({ resolveHotelName: async () => "Hotel" }));
|
||||
vi.mock("./site-settings", () => ({
|
||||
siteSettings: {
|
||||
get: async (_key: string, fallback: string) => fallback,
|
||||
getMany: async () => ({}),
|
||||
},
|
||||
}));
|
||||
vi.mock("@/lib/db", async () => {
|
||||
const schema = await import("@/db/schema");
|
||||
return {
|
||||
...schema,
|
||||
db: {
|
||||
select: (fields: Record<string, unknown>) => {
|
||||
let rows: unknown[] = [];
|
||||
const chain = {
|
||||
from: (table: unknown) => {
|
||||
if (table === schema.MessengerFriendships)
|
||||
rows =
|
||||
"value" in fields
|
||||
? [{ value: state.friends.length }]
|
||||
: state.friends;
|
||||
return chain;
|
||||
},
|
||||
where: () => chain,
|
||||
innerJoin: () => chain,
|
||||
orderBy: () => chain,
|
||||
limit: () => chain,
|
||||
catch: () => Promise.resolve(rows),
|
||||
// biome-ignore lint/suspicious/noThenProperty: Drizzle query builders are intentionally awaitable.
|
||||
then: (resolve: (value: unknown[]) => unknown) =>
|
||||
Promise.resolve(rows).then(resolve),
|
||||
};
|
||||
return chain;
|
||||
},
|
||||
},
|
||||
};
|
||||
});
|
||||
|
||||
import { loadUserDashboard } from "./user-dashboard";
|
||||
|
||||
describe("dashboard friendships", () => {
|
||||
beforeEach(() => {
|
||||
state.friends = [];
|
||||
});
|
||||
it("counts each friend once when both directional rows are returned", async () => {
|
||||
const wait = { id: 2, username: "wait", online: "1" };
|
||||
const other = { id: 3, username: "YouKnowMe", online: "1" };
|
||||
state.friends = [wait, other, { ...wait }, { ...other }];
|
||||
const data = await loadUserDashboard(1);
|
||||
expect(data.friends.map((friend) => friend.id)).toEqual([2, 3]);
|
||||
expect(data.friendCountRows).toEqual([{ value: 2 }]);
|
||||
});
|
||||
it("preserves single-direction and offline friendships", async () => {
|
||||
state.friends = [
|
||||
{ id: 2, username: "wait", online: "1" },
|
||||
{ id: 3, username: "offline", online: "0" },
|
||||
];
|
||||
const data = await loadUserDashboard(1);
|
||||
expect(data.friends).toEqual(state.friends);
|
||||
expect(data.friendCountRows).toEqual([{ value: 2 }]);
|
||||
});
|
||||
it("excludes self friendships", async () => {
|
||||
state.friends = [{ id: 1, username: "me", online: "1" }];
|
||||
const data = await loadUserDashboard(1);
|
||||
expect(data.friends).toEqual([]);
|
||||
expect(data.friendCountRows).toEqual([{ value: 0 }]);
|
||||
});
|
||||
it("returns zero for an empty friends list", async () => {
|
||||
const data = await loadUserDashboard(1);
|
||||
expect(data.friends).toEqual([]);
|
||||
expect(data.friendCountRows).toEqual([{ value: 0 }]);
|
||||
});
|
||||
});
|
||||
@@ -24,7 +24,6 @@ export async function loadUserDashboard(userId: number) {
|
||||
recentRooms,
|
||||
badges,
|
||||
userSettingsRows,
|
||||
friendCountRows,
|
||||
unreadCountRows,
|
||||
referralsRows,
|
||||
friends,
|
||||
@@ -82,16 +81,6 @@ export async function loadUserDashboard(userId: number) {
|
||||
.where(eq(UsersSettings.userId, userId))
|
||||
.limit(1)
|
||||
.catch(() => []),
|
||||
db
|
||||
.select({ value: count() })
|
||||
.from(MessengerFriendships)
|
||||
.where(
|
||||
or(
|
||||
eq(MessengerFriendships.userOneId, userId),
|
||||
eq(MessengerFriendships.userTwoId, userId),
|
||||
),
|
||||
)
|
||||
.catch(() => [{ value: 0 }]),
|
||||
db
|
||||
.select({ value: count() })
|
||||
.from(MessengerOffline)
|
||||
@@ -145,6 +134,15 @@ export async function loadUserDashboard(userId: number) {
|
||||
.catch(() => null),
|
||||
]);
|
||||
|
||||
// Each friendship can have two directional rows; expose users, not edges.
|
||||
const uniqueFriends = [
|
||||
...new Map(
|
||||
friends
|
||||
.filter((friend) => friend.id !== userId)
|
||||
.map((friend) => [friend.id, friend]),
|
||||
).values(),
|
||||
];
|
||||
|
||||
return {
|
||||
userRows,
|
||||
hotelName,
|
||||
@@ -155,10 +153,10 @@ export async function loadUserDashboard(userId: number) {
|
||||
recentRooms,
|
||||
badges,
|
||||
userSettingsRows,
|
||||
friendCountRows,
|
||||
friendCountRows: [{ value: uniqueFriends.length }],
|
||||
unreadCountRows,
|
||||
referralsRows,
|
||||
friends,
|
||||
friends: uniqueFriends,
|
||||
currencyRows,
|
||||
};
|
||||
}
|
||||
+15
-1
@@ -1161,7 +1161,21 @@
|
||||
"statusScheduled": "Scheduled",
|
||||
"statusPublished": "Published",
|
||||
"publishAt": "Publish at",
|
||||
"publishedAt": "Published at"
|
||||
"publishedAt": "Published at",
|
||||
"titleRequired": "Enter a title.",
|
||||
"titleTooLong": "The title must be at most 255 characters.",
|
||||
"summaryTooLong": "The summary must be at most 255 characters.",
|
||||
"imageTooLong": "The image URL must be at most 255 characters.",
|
||||
"invalidStatus": "Select a valid publication status.",
|
||||
"publishDateRequired": "Choose a valid publication date.",
|
||||
"saveFailedReference": "Could not save the article. Your content is preserved. Error reference: {reference}",
|
||||
"articleNotFound": "Article not found.",
|
||||
"summary": "Summary",
|
||||
"imageNotFound": "Image not found. Enter a valid URL or browse.",
|
||||
"imagePreview": "Article image preview",
|
||||
"previewTitle": "Article preview",
|
||||
"previewDescription": "Content preview. The published page applies the site theme.",
|
||||
"previewFrame": "Article content preview"
|
||||
},
|
||||
"articlesShown": "Articles shown",
|
||||
"latest": "Latest article",
|
||||
|
||||
+15
-1
@@ -1135,7 +1135,21 @@
|
||||
"statusScheduled": "Programmato",
|
||||
"statusPublished": "Pubblicato",
|
||||
"publishAt": "Data di pubblicazione",
|
||||
"publishedAt": "Pubblicato il"
|
||||
"publishedAt": "Pubblicato il",
|
||||
"titleRequired": "Inserisci un titolo.",
|
||||
"titleTooLong": "Il titolo può contenere al massimo 255 caratteri.",
|
||||
"summaryTooLong": "Il sommario può contenere al massimo 255 caratteri.",
|
||||
"imageTooLong": "L’URL dell’immagine può contenere al massimo 255 caratteri.",
|
||||
"invalidStatus": "Seleziona uno stato di pubblicazione valido.",
|
||||
"publishDateRequired": "Scegli una data di pubblicazione valida.",
|
||||
"saveFailedReference": "Impossibile salvare la news. Il contenuto è conservato. Riferimento errore: {reference}",
|
||||
"articleNotFound": "News non trovata.",
|
||||
"summary": "Sommario",
|
||||
"imageNotFound": "Immagine non trovata. Inserisci un URL valido o sfoglia i media.",
|
||||
"imagePreview": "Anteprima immagine della news",
|
||||
"previewTitle": "Anteprima news",
|
||||
"previewDescription": "Anteprima del contenuto. La pagina pubblicata usa il tema del sito.",
|
||||
"previewFrame": "Anteprima contenuto della news"
|
||||
},
|
||||
"articlesShown": "Articoli mostrati",
|
||||
"latest": "Ultimo articolo",
|
||||
|
||||
+15
-1
@@ -1123,7 +1123,21 @@
|
||||
"saving": "Opslaan…",
|
||||
"deleteArticle": "Artikel verwijderen",
|
||||
"deleteConfirm": "Deze actie kan niet ongedaan worden gemaakt. Het artikel wordt permanent verwijderd.",
|
||||
"cancel": "Annuleren"
|
||||
"cancel": "Annuleren",
|
||||
"titleRequired": "Voer een titel in.",
|
||||
"titleTooLong": "De titel mag maximaal 255 tekens bevatten.",
|
||||
"summaryTooLong": "De samenvatting mag maximaal 255 tekens bevatten.",
|
||||
"imageTooLong": "De afbeeldings-URL mag maximaal 255 tekens bevatten.",
|
||||
"invalidStatus": "Selecteer een geldige publicatiestatus.",
|
||||
"publishDateRequired": "Kies een geldige publicatiedatum.",
|
||||
"saveFailedReference": "Het artikel kon niet worden opgeslagen. Je inhoud blijft bewaard. Foutreferentie: {reference}",
|
||||
"articleNotFound": "Artikel niet gevonden.",
|
||||
"summary": "Samenvatting",
|
||||
"imageNotFound": "Afbeelding niet gevonden. Voer een geldige URL in of blader door media.",
|
||||
"imagePreview": "Voorbeeld van artikelafbeelding",
|
||||
"previewTitle": "Artikelvoorbeeld",
|
||||
"previewDescription": "Voorbeeld van de inhoud. De gepubliceerde pagina gebruikt het sitethema.",
|
||||
"previewFrame": "Voorbeeld van artikelinhoud"
|
||||
}
|
||||
},
|
||||
"events": {
|
||||
|
||||
Reference in new issue
Block a user