natty
/
calckey
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'develop' into fix/word-mutes

This commit is contained in:
naskya 2023-05-05 14:01:14 +00:00
parent db273318b8 dd777935cb
commit 069c789a78
18 changed files with 121 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
packages/backend/migration/1682891891317-AddHiddenPosts.js Normal file
View File

@ -0,0 +1,13 @@
export class AddHiddenPosts1682891891317 {
name = "AddHiddenPosts1682891891317";
async up(queryRunner) {
await queryRunner.query(
`ALTER TYPE note_visibility_enum ADD VALUE IF NOT EXISTS 'hidden'`,
);
}
async down(queryRunner) {
await queryRunner.query(`ALTER TYPE note_visibility_enum REMOVE VALUE IF EXISTS 'hidden'`);
}
}

1
packages/backend/src/models/entities/note.ts
View File

@ -111,6 +111,7 @@ export class Note {
/**
* public ... 公開
* home ... ホームタイムライン(ユーザーページのタイムライン含む)のみに流す
* hidden ... only visible on profile (doesnt federate, like local only, but can be fetched via AP like home) <- for now only used for post imports
* followers ... フォロワーのみ
* specified ... visibleUserIds で指定したユーザーのみ
*/

4
packages/backend/src/queue/processors/db/import-posts.ts
View File

@ -65,7 +65,7 @@ export async function importPosts(
renote: null,
cw: cw,
localOnly,
visibility: "public",
visibility: "hidden",
visibleUsers: [],
channel: null,
apMentions: new Array(0),
@ -109,7 +109,7 @@ export async function importPosts(
renote: null,
cw: post.sensitive,
localOnly: false,
visibility: "public",
visibility: "hidden",
visibleUsers: [],
channel: null,
apMentions: new Array(0),

4
packages/backend/src/remote/activitypub/models/note.ts
View File

@ -686,7 +686,7 @@ export async function updateNote(value: string | IObject, resolver?: Resolver) {
multiple: poll?.multiple,
votes: poll?.votes,
expiresAt: poll?.expiresAt,
noteVisibility: note.visibility,
noteVisibility: note.visibility === "hidden" ? "home" : note.visibility,
userId: actor.id,
userHost: actor.host,
});
@ -704,7 +704,7 @@ export async function updateNote(value: string | IObject, resolver?: Resolver) {
multiple: poll?.multiple,
votes: poll?.votes,
expiresAt: poll?.expiresAt,
noteVisibility: note.visibility,
noteVisibility: note.visibility === "hidden" ? "home" : note.visibility,
},
);
updating = true;

20
packages/backend/src/server/api/endpoints/notes/global-timeline.ts
View File

@ -32,6 +32,11 @@ export const meta = {
code: "GTL_DISABLED",
id: "0332fc13-6ab2-4427-ae80-a9fadffd1a6b",
},
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
@ -93,6 +98,7 @@ export default define(meta, paramDef, async (ps, user) => {
if (ps.withFiles) {
query.andWhere("note.fileIds != '{}'");
}
query.andWhere("note.visibility != 'hidden'");
//#endregion
process.nextTick(() => {
@ -106,11 +112,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

21
packages/backend/src/server/api/endpoints/notes/hybrid-timeline.ts
View File

@ -36,6 +36,11 @@ export const meta = {
code: "STL_DISABLED",
id: "620763f4-f621-4533-ab33-0577a1a3c342",
},
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
@ -151,6 +156,8 @@ export default define(meta, paramDef, async (ps, user) => {
if (ps.withFiles) {
query.andWhere("note.fileIds != '{}'");
}
query.andWhere("note.visibility != 'hidden'");
//#endregion
process.nextTick(() => {
@ -162,11 +169,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

20
packages/backend/src/server/api/endpoints/notes/local-timeline.ts
View File

@ -35,6 +35,11 @@ export const meta = {
code: "LTL_DISABLED",
id: "45a6eb02-7695-4393-b023-dd3be9aaaefd",
},
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
@ -123,6 +128,7 @@ export default define(meta, paramDef, async (ps, user) => {
);
}
}
query.andWhere("note.visibility != 'hidden'");
//#endregion
process.nextTick(() => {
@ -136,11 +142,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

20
packages/backend/src/server/api/endpoints/notes/recommended-timeline.ts
View File

@ -35,6 +35,11 @@ export const meta = {
code: "RTL_DISABLED",
id: "45a6eb02-7695-4393-b023-dd3be9aaaefe",
},
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
@ -126,6 +131,7 @@ export default define(meta, paramDef, async (ps, user) => {
);
}
}
query.andWhere("note.visibility != 'hidden'");
//#endregion
process.nextTick(() => {
@ -139,11 +145,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

25
packages/backend/src/server/api/endpoints/notes/timeline.ts
View File

@ -10,6 +10,7 @@ import { generateMutedNoteQuery } from "../../common/generate-muted-note-query.j
import { generateChannelQuery } from "../../common/generate-channel-query.js";
import { generateBlockedUserQuery } from "../../common/generate-block-query.js";
import { generateMutedUserRenotesQueryForNotes } from "../../common/generated-muted-renote-query.js";
import { ApiError } from "../../error.js";
export const meta = {
tags: ["notes"],
@ -27,6 +28,14 @@ export const meta = {
ref: "Note",
},
},
errors: {
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
export const paramDef = {
@ -143,6 +152,8 @@ export default define(meta, paramDef, async (ps, user) => {
if (ps.withFiles) {
query.andWhere("note.fileIds != '{}'");
}
query.andWhere("note.visibility != 'hidden'");
//#endregion
process.nextTick(() => {
@ -154,11 +165,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

19
packages/backend/src/server/api/endpoints/notes/user-list-timeline.ts
View File

@ -29,6 +29,11 @@ export const meta = {
code: "NO_SUCH_LIST",
id: "8fb1fbd5-e476-4c37-9fb0-43d55b63a2ff",
},
queryError: {
message: "Please follow more users.",
code: "QUERY_ERROR",
id: "620763f4-f621-4533-ab33-0577a1a3c343",
},
},
} as const;
@ -149,11 +154,15 @@ export default define(meta, paramDef, async (ps, user) => {
const found = [];
const take = Math.floor(ps.limit * 1.5);
let skip = 0;
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
try {
while (found.length < ps.limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...(await Notes.packMany(notes, user)));
skip += take;
if (notes.length < take) break;
}
} catch (error) {
throw new ApiError(meta.errors.queryError);
}
if (found.length > ps.limit) {

1
packages/backend/src/server/api/stream/channels/channel.ts
View File

@ -29,6 +29,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
if (note.channelId !== this.channelId) return;
// 流れてきたNoteがミュートしているユーザーが関わるものだったら無視する

1
packages/backend/src/server/api/stream/channels/hashtag.ts
View File

@ -24,6 +24,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
const noteTags = note.tags
? note.tags.map((t: string) => t.toLowerCase())
: [];

1
packages/backend/src/server/api/stream/channels/home-timeline.ts
View File

@ -20,6 +20,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
if (note.channelId) {
if (!this.followingChannels.has(note.channelId)) return;
} else {

1
packages/backend/src/server/api/stream/channels/hybrid-timeline.ts
View File

@ -29,6 +29,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
// チャンネルの投稿ではなく、自分自身の投稿 または
// チャンネルの投稿ではなく、その投稿のユーザーをフォローしている または
// チャンネルの投稿ではなく、全体公開のローカルの投稿 または

1
packages/backend/src/server/api/stream/channels/recommended-timeline.ts
View File

@ -29,6 +29,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
// チャンネルの投稿ではなく、自分自身の投稿 または
// チャンネルの投稿ではなく、その投稿のユーザーをフォローしている または
// チャンネルの投稿ではなく、全体公開のローカルの投稿 または

1
packages/backend/src/server/api/stream/channels/user-list.ts
View File

@ -49,6 +49,7 @@ export default class extends Channel {
}
private async onNote(note: Packed<"Note">) {
if (note.visibility === "hidden") return;
if (!this.listUsers.includes(note.userId)) return;
// 流れてきたNoteがミュートしているユーザーが関わるものだったら無視する

2
packages/backend/src/services/note/reaction/create.ts
View File

@ -144,7 +144,7 @@ export default async (
});
//#region deliver
if (Users.isLocalUser(user) && !note.localOnly) {
if (Users.isLocalUser(user) && !note.localOnly && note.visibility !== "hidden") {
const content = renderActivity(await renderLike(record, note));
const dm = new DeliverManager(user, content);
if (note.userHost !== null) {

1
packages/backend/src/types.ts
View File

@ -18,6 +18,7 @@ export const noteVisibilities = [
"home",
"followers",
"specified",
"hidden",
] as const;
export const mutedNoteReasons = ["word", "manual", "spam", "other"] as const;