${ subject }
@@ -147,7 +138,18 @@ export class EmailService { ${ this.config.host } -`, +`; + + const inlinedHtml = juice(htmlContent); + + try { + // TODO: htmlサニタイズ + const info = await transporter.sendMail({ + from: this.meta.email!, + to: to, + subject: subject, + text: text, + html: inlinedHtml, }); this.logger.info(`Message sent: ${info.messageId}`); @@ -162,8 +164,6 @@ export class EmailService { available: boolean; reason: null | 'used' | 'format' | 'disposable' | 'mx' | 'smtp' | 'banned' | 'network' | 'blacklist'; }> { - const meta = await this.metaService.fetch(); - const exist = await this.userProfilesRepository.countBy({ emailVerified: true, email: emailAddress, @@ -181,11 +181,11 @@ export class EmailService { reason?: string | null, } = { valid: true, reason: null }; - if (meta.enableActiveEmailValidation) { - if (meta.enableVerifymailApi && meta.verifymailAuthKey != null) { - validated = await this.verifyMail(emailAddress, meta.verifymailAuthKey); - } else if (meta.enableTruemailApi && meta.truemailInstance && meta.truemailAuthKey != null) { - validated = await this.trueMail(meta.truemailInstance, emailAddress, meta.truemailAuthKey); + if (this.meta.enableActiveEmailValidation) { + if (this.meta.enableVerifymailApi && this.meta.verifymailAuthKey != null) { + validated = await this.verifyMail(emailAddress, this.meta.verifymailAuthKey); + } else if (this.meta.enableTruemailApi && this.meta.truemailInstance && this.meta.truemailAuthKey != null) { + validated = await this.trueMail(this.meta.truemailInstance, emailAddress, this.meta.truemailAuthKey); } else { validated = await validateEmail({ email: emailAddress, @@ -215,7 +215,7 @@ export class EmailService { } const emailDomain: string = emailAddress.split('@')[1]; - const isBanned = this.utilityService.isBlockedHost(meta.bannedEmailDomains, emailDomain); + const isBanned = this.utilityService.isBlockedHost(this.meta.bannedEmailDomains, emailDomain); if (isBanned) { return { @@ -312,6 +312,7 @@ export class EmailService { Accept: 'application/json', Authorization: truemailAuthKey, }, + isLocalAddressAllowed: true, }); const json = (await res.json()) as { diff --git a/packages/backend/src/core/FederatedInstanceService.ts b/packages/backend/src/core/FederatedInstanceService.ts index 7aeeb78178..73bbf03b26 100644 --- a/packages/backend/src/core/FederatedInstanceService.ts +++ b/packages/backend/src/core/FederatedInstanceService.ts @@ -47,7 +47,7 @@ export class FederatedInstanceService implements OnApplicationShutdown { } @bindThis - public async fetch(host: string): Promise'); + const text = message.join('\n'); + + return { + subject, + html, + text, + }; +} + +function generateInvitationOnlyChangedMail() { + const subject = 'Change to Invitation-Only / 招待制に変更されました'; + + const message = [ + 'To Moderators,', + '', + `Changed to invitation only because no moderator activity was detected for ${MODERATOR_INACTIVITY_LIMIT_DAYS} days.`, + 'To cancel the invitation only, you need to access the control panel.', + '', + '---------------', + '', + 'To モデレーター各位', + '', + `モデレーターの活動が${MODERATOR_INACTIVITY_LIMIT_DAYS}日間検出されなかったため、招待制に変更されました。`, + '招待制を解除するには、コントロールパネルにアクセスする必要があります。', + '', + ]; + + const html = message.join('
'); + const text = message.join('\n'); + + return { + subject, + html, + text, + }; +} + +@Injectable() +export class CheckModeratorsActivityProcessorService { + private logger: Logger; + + constructor( + @Inject(DI.userProfilesRepository) + private userProfilesRepository: UserProfilesRepository, + private metaService: MetaService, + private roleService: RoleService, + private emailService: EmailService, + private announcementService: AnnouncementService, + private systemWebhookService: SystemWebhookService, + private queueLoggerService: QueueLoggerService, + ) { + this.logger = this.queueLoggerService.logger.createSubLogger('check-moderators-activity'); + } + + @bindThis + public async process(): Promise
読み込みに失敗しました
+ Failed to initialize Misskey
+ Error Code: ${code}
+ `;
+ addStyle(`
+ #misskey_app,
+ #splash {
+ display: none !important;
+ }
+
+ html,
+ body {
+ margin: 0;
+ }
+
+ body {
+ position: relative;
+ color: #dee7e4;
+ font-family: Hiragino Maru Gothic Pro, BIZ UDGothic, Roboto, HelveticaNeue, Arial, sans-serif;
+ line-height: 1.35;
+ display: flex;
+ flex-direction: column;
+ align-items: center;
+ justify-content: center;
+ min-height: 100vh;
+ margin: 0;
+ padding: 24px;
+ box-sizing: border-box;
+ overflow: hidden;
+
+ border-radius: var(--radius, 12px);
+ border: 1px solid rgba(231, 255, 251, 0.14);
+ }
+
+ body::before {
+ content: '';
+ position: fixed;
+ top: 0;
+ left: 0;
+ width: 100%;
+ height: 100%;
+ background: #192320;
+ border-radius: var(--radius, 12px);
+ z-index: -1;
+ }
+
+ html.embed.norounded body,
+ html.embed.norounded body::before {
+ border-radius: 0;
+ }
+
+ html.embed.noborder body {
+ border: none;
+ }
+
+ .icon {
+ max-width: 60px;
+ width: 100%;
+ height: auto;
+ margin-bottom: 20px;
+ color: #dec340;
+ }
+
+ .message {
+ text-align: center;
+ font-size: 20px;
+ font-weight: 700;
+ margin-bottom: 20px;
+ }
+
+ .submessage {
+ text-align: center;
+ font-size: 90%;
+ margin-bottom: 7.5px;
+ }
+
+ .submessage:last-of-type {
+ margin-bottom: 20px;
+ }
+
+ button {
+ padding: 7px 14px;
+ min-width: 100px;
+ font-weight: 700;
+ font-family: Hiragino Maru Gothic Pro, BIZ UDGothic, Roboto, HelveticaNeue, Arial, sans-serif;
+ line-height: 1.35;
+ border-radius: 99rem;
+ background-color: #b4e900;
+ color: #192320;
+ border: none;
+ cursor: pointer;
+ -webkit-tap-highlight-color: transparent;
+ }
+
+ button:hover {
+ background-color: #c6ff03;
+ }`);
+ }
+})();
diff --git a/packages/backend/src/server/web/boot.js b/packages/backend/src/server/web/boot.js
index 5283596316..a04640d993 100644
--- a/packages/backend/src/server/web/boot.js
+++ b/packages/backend/src/server/web/boot.js
@@ -3,17 +3,6 @@
* SPDX-License-Identifier: AGPL-3.0-only
*/
-/**
- * BOOT LOADER
- * サーバーからレスポンスされるHTMLに埋め込まれるスクリプトで、以下の役割を持ちます。
- * - 翻訳ファイルをフェッチする。
- * - バージョンに基づいて適切なメインスクリプトを読み込む。
- * - キャッシュされたコンパイル済みテーマを適用する。
- * - クライアントの設定値に基づいて対応するHTMLクラス等を設定する。
- * テーマをこの段階で設定するのは、メインスクリプトが読み込まれる間もテーマを適用したいためです。
- * 注: webpackは介さないため、このファイルではrequireやimportは使えません。
- */
-
'use strict';
// ブロックの中に入れないと、定義した変数がブラウザのグローバルスコープに登録されてしまい邪魔なので
@@ -109,7 +98,7 @@
const theme = localStorage.getItem('theme');
if (theme) {
for (const [k, v] of Object.entries(JSON.parse(theme))) {
- document.documentElement.style.setProperty(`--${k}`, v.toString());
+ document.documentElement.style.setProperty(`--MI_THEME-${k}`, v.toString());
// HTMLの theme-color 適用
if (k === 'htmlThemeColor') {
diff --git a/packages/backend/src/server/web/style.css b/packages/backend/src/server/web/style.css
index e4723c24fd..5d81f2bed0 100644
--- a/packages/backend/src/server/web/style.css
+++ b/packages/backend/src/server/web/style.css
@@ -5,8 +5,8 @@
*/
html {
- background-color: var(--bg);
- color: var(--fg);
+ background-color: var(--MI_THEME-bg);
+ color: var(--MI_THEME-fg);
}
#splash {
@@ -17,7 +17,7 @@ html {
width: 100vw;
height: 100vh;
cursor: wait;
- background-color: var(--bg);
+ background-color: var(--MI_THEME-bg);
opacity: 1;
transition: opacity 0.5s ease;
}
@@ -45,8 +45,9 @@ html {
width: 28px;
height: 28px;
transform: translateY(70px);
- color: var(--accent);
+ color: var(--MI_THEME-accent);
}
+
#splashSpinner > .spinner {
position: absolute;
top: 0;
diff --git a/packages/backend/src/server/web/style.embed.css b/packages/backend/src/server/web/style.embed.css
new file mode 100644
index 0000000000..5e8786cc4e
--- /dev/null
+++ b/packages/backend/src/server/web/style.embed.css
@@ -0,0 +1,99 @@
+/*
+ * SPDX-FileCopyrightText: syuilo and misskey-project
+ *
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+html {
+ background-color: var(--MI_THEME-bg);
+ color: var(--MI_THEME-fg);
+}
+
+html.embed {
+ box-sizing: border-box;
+ background-color: transparent;
+ color-scheme: light dark;
+ max-width: 500px;
+}
+
+#splash {
+ position: fixed;
+ z-index: 10000;
+ top: 0;
+ left: 0;
+ width: 100vw;
+ height: 100vh;
+ cursor: wait;
+ background-color: var(--MI_THEME-bg);
+ opacity: 1;
+ transition: opacity 0.5s ease;
+}
+
+html.embed #splash {
+ box-sizing: border-box;
+ min-height: 300px;
+ border-radius: var(--radius, 12px);
+ border: 1px solid var(--MI_THEME-divider, #e8e8e8);
+}
+
+html.embed.norounded #splash {
+ border-radius: 0;
+}
+
+html.embed.noborder #splash {
+ border: none;
+}
+
+#splashIcon {
+ position: absolute;
+ top: 0;
+ right: 0;
+ bottom: 0;
+ left: 0;
+ margin: auto;
+ width: 64px;
+ height: 64px;
+ pointer-events: none;
+}
+
+#splashSpinner {
+ position: absolute;
+ top: 0;
+ right: 0;
+ bottom: 0;
+ left: 0;
+ margin: auto;
+ display: inline-block;
+ width: 28px;
+ height: 28px;
+ transform: translateY(70px);
+ color: var(--MI_THEME-accent);
+}
+
+#splashSpinner > .spinner {
+ position: absolute;
+ top: 0;
+ left: 0;
+ width: 28px;
+ height: 28px;
+ fill-rule: evenodd;
+ clip-rule: evenodd;
+ stroke-linecap: round;
+ stroke-linejoin: round;
+ stroke-miterlimit: 1.5;
+}
+#splashSpinner > .spinner.bg {
+ opacity: 0.275;
+}
+#splashSpinner > .spinner.fg {
+ animation: splashSpinner 0.5s linear infinite;
+}
+
+@keyframes splashSpinner {
+ 0% {
+ transform: rotate(0deg);
+ }
+ 100% {
+ transform: rotate(360deg);
+ }
+}
diff --git a/packages/backend/src/server/web/views/announcement.pug b/packages/backend/src/server/web/views/announcement.pug
new file mode 100644
index 0000000000..7a4052e8a4
--- /dev/null
+++ b/packages/backend/src/server/web/views/announcement.pug
@@ -0,0 +1,21 @@
+extends ./base
+
+block vars
+ - const title = announcement.title;
+ - const description = announcement.text.length > 100 ? announcement.text.slice(0, 100) + '…' : announcement.text;
+ - const url = `${config.url}/announcements/${announcement.id}`;
+
+block title
+ = `${title} | ${instanceName}`
+
+block desc
+ meta(name='description' content=description)
+
+block og
+ meta(property='og:type' content='article')
+ meta(property='og:title' content= title)
+ meta(property='og:description' content= description)
+ meta(property='og:url' content= url)
+ if announcement.imageUrl
+ meta(property='og:image' content=announcement.imageUrl)
+ meta(property='twitter:card' content='summary_large_image')
diff --git a/packages/backend/src/server/web/views/base-embed.pug b/packages/backend/src/server/web/views/base-embed.pug
new file mode 100644
index 0000000000..baa0909676
--- /dev/null
+++ b/packages/backend/src/server/web/views/base-embed.pug
@@ -0,0 +1,72 @@
+block vars
+
+block loadClientEntry
+ - const entry = config.frontendEmbedEntry;
+
+doctype html
+
+html(class='embed')
+
+ head
+ meta(charset='utf-8')
+ meta(name='application-name' content='Misskey')
+ meta(name='referrer' content='origin')
+ meta(name='theme-color' content= themeColor || '#86b300')
+ meta(name='theme-color-orig' content= themeColor || '#86b300')
+ meta(property='og:site_name' content= instanceName || 'Misskey')
+ meta(property='instance_url' content= instanceUrl)
+ meta(name='viewport' content='width=device-width, initial-scale=1')
+ meta(name='format-detection' content='telephone=no,date=no,address=no,email=no,url=no')
+ link(rel='icon' href= icon || '/favicon.ico')
+ link(rel='apple-touch-icon' href= appleTouchIcon || '/apple-touch-icon.png')
+ link(rel='modulepreload' href=`/embed_vite/${entry.file}`)
+
+ if !config.frontendEmbedManifestExists
+ script(type="module" src="/embed_vite/@vite/client")
+
+ if Array.isArray(entry.css)
+ each href in entry.css
+ link(rel='stylesheet' href=`/embed_vite/${href}`)
+
+ title
+ block title
+ = title || 'Misskey'
+
+ block meta
+ meta(name='robots' content='noindex')
+
+ style
+ include ../style.embed.css
+
+ script.
+ var VERSION = "#{version}";
+ var CLIENT_ENTRY = "#{entry.file}";
+
+ script(type='application/json' id='misskey_meta' data-generated-at=now)
+ != metaJson
+
+ script(type='application/json' id='misskey_embedCtx' data-generated-at=now)
+ != embedCtx
+
+ script
+ include ../boot.embed.js
+
+ body
+ noscript: p
+ | JavaScriptを有効にしてください
+ br
+ | Please turn on your JavaScript
+ div#splash
+ img#splashIcon(src= icon || '/static-assets/splash.png')
+ div#splashSpinner
+
+
+ block content
diff --git a/packages/backend/src/server/web/views/base.pug b/packages/backend/src/server/web/views/base.pug
index da6d1eafd3..3883b5e5ab 100644
--- a/packages/backend/src/server/web/views/base.pug
+++ b/packages/backend/src/server/web/views/base.pug
@@ -1,7 +1,8 @@
block vars
block loadClientEntry
- - const clientEntry = config.clientEntry;
+ - const entry = config.frontendEntry;
+ - const baseUrl = config.url;
doctype html
@@ -32,17 +33,17 @@ html
link(rel='icon' href= icon || '/favicon.ico')
link(rel='apple-touch-icon' href= appleTouchIcon || '/apple-touch-icon.png')
link(rel='manifest' href='/manifest.json')
- link(rel='search' type='application/opensearchdescription+xml' title=(title || "Misskey") href=`${url}/opensearch.xml`)
+ link(rel='search' type='application/opensearchdescription+xml' title=(title || "Misskey") href=`${baseUrl}/opensearch.xml`)
link(rel='prefetch' href=serverErrorImageUrl)
link(rel='prefetch' href=infoImageUrl)
link(rel='prefetch' href=notFoundImageUrl)
- link(rel='modulepreload' href=`/vite/${clientEntry.file}`)
+ link(rel='modulepreload' href=`/vite/${entry.file}`)
- if !config.clientManifestExists
+ if !config.frontendManifestExists
script(type="module" src="/vite/@vite/client")
- if Array.isArray(clientEntry.css)
- each href in clientEntry.css
+ if Array.isArray(entry.css)
+ each href in entry.css
link(rel='stylesheet' href=`/vite/${href}`)
title
@@ -68,11 +69,14 @@ html
script.
var VERSION = "#{version}";
- var CLIENT_ENTRY = "#{clientEntry.file}";
+ var CLIENT_ENTRY = "#{entry.file}";
script(type='application/json' id='misskey_meta' data-generated-at=now)
!= metaJson
+ script(type='application/json' id='misskey_clientCtx' data-generated-at=now)
+ != clientCtx
+
script
include ../boot.js
diff --git a/packages/backend/src/types.ts b/packages/backend/src/types.ts
index e852cf5ae2..df3cfee171 100644
--- a/packages/backend/src/types.ts
+++ b/packages/backend/src/types.ts
@@ -16,6 +16,8 @@
* followRequestAccepted - 自分の送ったフォローリクエストが承認された
* roleAssigned - ロールが付与された
* achievementEarned - 実績を獲得
+ * exportCompleted - エクスポートが完了
+ * login - ログイン
* app - アプリ通知
* test - テスト通知（サーバー側）
*/
@@ -32,6 +34,8 @@ export const notificationTypes = [
'followRequestAccepted',
'roleAssigned',
'achievementEarned',
+ 'exportCompleted',
+ 'login',
'app',
'test',
] as const;
@@ -51,6 +55,20 @@ export const mutedNoteReasons = ['word', 'manual', 'spam', 'other'] as const;
export const followingVisibilities = ['public', 'followers', 'private'] as const;
export const followersVisibilities = ['public', 'followers', 'private'] as const;
+/**
+ * ユーザーがエクスポートできるものの種類
+ *
+ * （主にエクスポート完了通知で使用するものであり、既存のDBの名称等と必ずしも一致しない）
+ */
+export const userExportableEntities = ['antenna', 'blocking', 'clip', 'customEmoji', 'favorite', 'following', 'muting', 'note', 'userList'] as const;
+
+/**
+ * ユーザーがインポートできるものの種類
+ *
+ * （主にインポート完了通知で使用するものであり、既存のDBの名称等と必ずしも一致しない）
+ */
+export const userImportableEntities = ['antenna', 'blocking', 'customEmoji', 'following', 'muting', 'userList'] as const;
+
export const moderationLogTypes = [
'updateServerSettings',
'suspend',
@@ -81,6 +99,8 @@ export const moderationLogTypes = [
'markSensitiveDriveFile',
'unmarkSensitiveDriveFile',
'resolveAbuseReport',
+ 'forwardAbuseReport',
+ 'updateAbuseReportNote',
'createInvitation',
'createAd',
'updateAd',
@@ -249,7 +269,18 @@ export type ModerationLogPayloads = {
resolveAbuseReport: {
reportId: string;
report: any;
- forwarded: boolean;
+ forwarded?: boolean;
+ resolvedAs?: string | null;
+ };
+ forwardAbuseReport: {
+ reportId: string;
+ report: any;
+ };
+ updateAbuseReportNote: {
+ reportId: string;
+ report: any;
+ before: string;
+ after: string;
};
createInvitation: {
invitations: any[];
diff --git a/packages/backend/test-federation/.config/example.conf b/packages/backend/test-federation/.config/example.conf
new file mode 100644
index 0000000000..83d04eb39d
--- /dev/null
+++ b/packages/backend/test-federation/.config/example.conf
@@ -0,0 +1,70 @@
+# based on https://github.com/misskey-dev/misskey-hub/blob/7071f63a1c80ee35c71f0fd8a6d8722c118c7574/src/docs/admin/nginx.md
+
+# For WebSocket
+map $http_upgrade $connection_upgrade {
+ default upgrade;
+ '' close;
+}
+
+proxy_cache_path /tmp/nginx_cache levels=1:2 keys_zone=cache1:16m max_size=1g inactive=720m use_temp_path=off;
+
+server {
+ listen 80;
+ listen [::]:80;
+ server_name ${HOST};
+
+ # For SSL domain validation
+ root /var/www/html;
+ location /.well-known/acme-challenge/ { allow all; }
+ location /.well-known/pki-validation/ { allow all; }
+ location / { return 301 https://$server_name$request_uri; }
+}
+
+server {
+ listen 443 ssl;
+ listen [::]:443 ssl;
+ http2 on;
+ server_name ${HOST};
+
+ ssl_session_timeout 1d;
+ ssl_session_cache shared:ssl_session_cache:10m;
+ ssl_session_tickets off;
+
+ ssl_trusted_certificate /etc/nginx/certificates/rootCA.crt;
+ ssl_certificate /etc/nginx/certificates/$server_name.crt;
+ ssl_certificate_key /etc/nginx/certificates/$server_name.key;
+
+ # SSL protocol settings
+ ssl_protocols TLSv1.2 TLSv1.3;
+ ssl_ciphers ECDHE-ECDSA-AES128-GCM-SHA256:ECDHE-RSA-AES128-GCM-SHA256:ECDHE-ECDSA-AES256-GCM-SHA384:ECDHE-RSA-AES256-GCM-SHA384:ECDHE-ECDSA-CHACHA20-POLY1305:ECDHE-RSA-CHACHA20-POLY1305:DHE-RSA-AES128-GCM-SHA256:DHE-RSA-AES256-GCM-SHA384;
+ ssl_prefer_server_ciphers off;
+ ssl_stapling on;
+ ssl_stapling_verify on;
+
+ # Change to your upload limit
+ client_max_body_size 80m;
+
+ # Proxy to Node
+ location / {
+ proxy_pass http://misskey.${HOST}:3000;
+ proxy_set_header Host $host;
+ proxy_http_version 1.1;
+ proxy_redirect off;
+
+ # If it's behind another reverse proxy or CDN, remove the following.
+ proxy_set_header X-Real-IP $remote_addr;
+ proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+ proxy_set_header X-Forwarded-Proto https;
+
+ # For WebSocket
+ proxy_set_header Upgrade $http_upgrade;
+ proxy_set_header Connection $connection_upgrade;
+
+ # Cache settings
+ proxy_cache cache1;
+ proxy_cache_lock on;
+ proxy_cache_use_stale updating;
+ proxy_force_ranges on;
+ add_header X-Cache $upstream_cache_status;
+ }
+}
diff --git a/packages/backend/test-federation/.config/example.default.yml b/packages/backend/test-federation/.config/example.default.yml
new file mode 100644
index 0000000000..28d51ac86e
--- /dev/null
+++ b/packages/backend/test-federation/.config/example.default.yml
@@ -0,0 +1,24 @@
+url: https://${HOST}/
+port: 3000
+db:
+ host: db.${HOST}
+ port: 5432
+ db: misskey
+ user: postgres
+ pass: postgres
+dbReplications: false
+redis:
+ host: redis.test
+ port: 6379
+id: 'aidx'
+proxyBypassHosts:
+ - api.deepl.com
+ - api-free.deepl.com
+ - www.recaptcha.net
+ - hcaptcha.com
+ - challenges.cloudflare.com
+proxyRemoteFiles: true
+signToActivityPubGet: true
+allowedPrivateNetworks:
+ - 127.0.0.1/32
+ - 172.20.0.0/16
diff --git a/packages/backend/test-federation/.config/example.docker.env b/packages/backend/test-federation/.config/example.docker.env
new file mode 100644
index 0000000000..a8af7cce49
--- /dev/null
+++ b/packages/backend/test-federation/.config/example.docker.env
@@ -0,0 +1,5 @@
+NODE_EXTRA_CA_CERTS=/usr/local/share/ca-certificates/rootCA.crt
+POSTGRES_DB=misskey
+POSTGRES_USER=postgres
+POSTGRES_PASSWORD=postgres
+MK_VERBOSE=true
diff --git a/packages/backend/test-federation/.gitignore b/packages/backend/test-federation/.gitignore
new file mode 100644
index 0000000000..e00f952cb5
--- /dev/null
+++ b/packages/backend/test-federation/.gitignore
@@ -0,0 +1,6 @@
+certificates
+volumes
+.env
+docker.env
+*.test.conf
+*.test.default.yml
diff --git a/packages/backend/test-federation/README.md b/packages/backend/test-federation/README.md
new file mode 100644
index 0000000000..967d51f085
--- /dev/null
+++ b/packages/backend/test-federation/README.md
@@ -0,0 +1,24 @@
+## test-federation
+Test federation between two Misskey servers: `a.test` and `b.test`.
+
+Before testing, you need to build the entire project, and change working directory to here:
+```sh
+pnpm build
+cd packages/backend/test-federation
+```
+
+First, you need to start servers by executing following commands:
+```sh
+bash ./setup.sh
+docker compose up --scale tester=0
+```
+
+Then you can run all tests by a following command:
+```sh
+docker compose run --no-deps --rm tester
+```
+
+For testing a specific file, run a following command:
+```sh
+docker compose run --no-deps --rm tester -- pnpm -F backend test:fed packages/backend/test-federation/test/user.test.ts
+```
diff --git a/packages/backend/test-federation/compose.a.yml b/packages/backend/test-federation/compose.a.yml
new file mode 100644
index 0000000000..6a305b404c
--- /dev/null
+++ b/packages/backend/test-federation/compose.a.yml
@@ -0,0 +1,64 @@
+services:
+ a.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: nginx
+ depends_on:
+ misskey.a.test:
+ condition: service_healthy
+ networks:
+ - internal_network_a
+ volumes:
+ - type: bind
+ source: ./.config/a.test.conf
+ target: /etc/nginx/conf.d/a.test.conf
+ read_only: true
+ - type: bind
+ source: ./certificates/a.test.crt
+ target: /etc/nginx/certificates/a.test.crt
+ read_only: true
+ - type: bind
+ source: ./certificates/a.test.key
+ target: /etc/nginx/certificates/a.test.key
+ read_only: true
+
+ misskey.a.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: misskey
+ depends_on:
+ db.a.test:
+ condition: service_healthy
+ redis.test:
+ condition: service_healthy
+ setup:
+ condition: service_completed_successfully
+ networks:
+ - internal_network_a
+ volumes:
+ - type: bind
+ source: ./.config/a.test.default.yml
+ target: /misskey/.config/default.yml
+ read_only: true
+
+ db.a.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: db
+ networks:
+ - internal_network_a
+ volumes:
+ - type: bind
+ source: ./volumes/db.a
+ target: /var/lib/postgresql/data
+ bind:
+ create_host_path: true
+
+networks:
+ internal_network_a:
+ internal: true
+ driver: bridge
+ ipam:
+ config:
+ - subnet: 172.21.0.0/16
+ ip_range: 172.21.0.0/24
diff --git a/packages/backend/test-federation/compose.b.yml b/packages/backend/test-federation/compose.b.yml
new file mode 100644
index 0000000000..1158b53bae
--- /dev/null
+++ b/packages/backend/test-federation/compose.b.yml
@@ -0,0 +1,64 @@
+services:
+ b.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: nginx
+ depends_on:
+ misskey.b.test:
+ condition: service_healthy
+ networks:
+ - internal_network_b
+ volumes:
+ - type: bind
+ source: ./.config/b.test.conf
+ target: /etc/nginx/conf.d/b.test.conf
+ read_only: true
+ - type: bind
+ source: ./certificates/b.test.crt
+ target: /etc/nginx/certificates/b.test.crt
+ read_only: true
+ - type: bind
+ source: ./certificates/b.test.key
+ target: /etc/nginx/certificates/b.test.key
+ read_only: true
+
+ misskey.b.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: misskey
+ depends_on:
+ db.b.test:
+ condition: service_healthy
+ redis.test:
+ condition: service_healthy
+ setup:
+ condition: service_completed_successfully
+ networks:
+ - internal_network_b
+ volumes:
+ - type: bind
+ source: ./.config/b.test.default.yml
+ target: /misskey/.config/default.yml
+ read_only: true
+
+ db.b.test:
+ extends:
+ file: ./compose.tpl.yml
+ service: db
+ networks:
+ - internal_network_b
+ volumes:
+ - type: bind
+ source: ./volumes/db.b
+ target: /var/lib/postgresql/data
+ bind:
+ create_host_path: true
+
+networks:
+ internal_network_b:
+ internal: true
+ driver: bridge
+ ipam:
+ config:
+ - subnet: 172.22.0.0/16
+ ip_range: 172.22.0.0/24
diff --git a/packages/backend/test-federation/compose.override.yaml b/packages/backend/test-federation/compose.override.yaml
new file mode 100644
index 0000000000..60a7631ab5
--- /dev/null
+++ b/packages/backend/test-federation/compose.override.yaml
@@ -0,0 +1,117 @@
+services:
+ setup:
+ volumes:
+ - type: volume
+ source: node_modules
+ target: /misskey/node_modules
+ - type: volume
+ source: node_modules_backend
+ target: /misskey/packages/backend/node_modules
+ - type: volume
+ source: node_modules_misskey-js
+ target: /misskey/packages/misskey-js/node_modules
+ - type: volume
+ source: node_modules_misskey-reversi
+ target: /misskey/packages/misskey-reversi/node_modules
+
+ tester:
+ networks:
+ external_network:
+ internal_network:
+ ipv4_address: 172.20.1.1
+ volumes:
+ - type: volume
+ source: node_modules_dev
+ target: /misskey/node_modules
+ - type: volume
+ source: node_modules_backend_dev
+ target: /misskey/packages/backend/node_modules
+ - type: volume
+ source: node_modules_misskey-js_dev
+ target: /misskey/packages/misskey-js/node_modules
+
+ daemon:
+ networks:
+ - external_network
+ - internal_network_a
+ - internal_network_b
+ volumes:
+ - type: volume
+ source: node_modules_dev
+ target: /misskey/node_modules
+ - type: volume
+ source: node_modules_backend_dev
+ target: /misskey/packages/backend/node_modules
+
+ redis.test:
+ networks:
+ - internal_network_a
+ - internal_network_b
+
+ a.test:
+ networks:
+ - internal_network
+
+ misskey.a.test:
+ networks:
+ - external_network
+ - internal_network
+ volumes:
+ - type: volume
+ source: node_modules
+ target: /misskey/node_modules
+ - type: volume
+ source: node_modules_backend
+ target: /misskey/packages/backend/node_modules
+ - type: volume
+ source: node_modules_misskey-js
+ target: /misskey/packages/misskey-js/node_modules
+ - type: volume
+ source: node_modules_misskey-reversi
+ target: /misskey/packages/misskey-reversi/node_modules
+
+ b.test:
+ networks:
+ - internal_network
+
+ misskey.b.test:
+ networks:
+ - external_network
+ - internal_network
+ volumes:
+ - type: volume
+ source: node_modules
+ target: /misskey/node_modules
+ - type: volume
+ source: node_modules_backend
+ target: /misskey/packages/backend/node_modules
+ - type: volume
+ source: node_modules_misskey-js
+ target: /misskey/packages/misskey-js/node_modules
+ - type: volume
+ source: node_modules_misskey-reversi
+ target: /misskey/packages/misskey-reversi/node_modules
+
+networks:
+ external_network:
+ driver: bridge
+ ipam:
+ config:
+ - subnet: 172.23.0.0/16
+ ip_range: 172.23.0.0/24
+ internal_network:
+ internal: true
+ driver: bridge
+ ipam:
+ config:
+ - subnet: 172.20.0.0/16
+ ip_range: 172.20.0.0/24
+
+volumes:
+ node_modules:
+ node_modules_dev:
+ node_modules_backend:
+ node_modules_backend_dev:
+ node_modules_misskey-js:
+ node_modules_misskey-js_dev:
+ node_modules_misskey-reversi:
diff --git a/packages/backend/test-federation/compose.tpl.yml b/packages/backend/test-federation/compose.tpl.yml
new file mode 100644
index 0000000000..8c38f16919
--- /dev/null
+++ b/packages/backend/test-federation/compose.tpl.yml
@@ -0,0 +1,101 @@
+services:
+ nginx:
+ image: nginx:1.27
+ volumes:
+ - type: bind
+ source: ./certificates/rootCA.crt
+ target: /etc/nginx/certificates/rootCA.crt
+ read_only: true
+ healthcheck:
+ test: service nginx status
+ interval: 5s
+ retries: 20
+
+ misskey:
+ image: node:20
+ env_file:
+ - ./.config/docker.env
+ environment:
+ - NODE_ENV=production
+ volumes:
+ - type: bind
+ source: ../../../built
+ target: /misskey/built
+ read_only: true
+ - type: bind
+ source: ../assets
+ target: /misskey/packages/backend/assets
+ read_only: true
+ - type: bind
+ source: ../built
+ target: /misskey/packages/backend/built
+ read_only: true
+ - type: bind
+ source: ../migration
+ target: /misskey/packages/backend/migration
+ read_only: true
+ - type: bind
+ source: ../ormconfig.js
+ target: /misskey/packages/backend/ormconfig.js
+ read_only: true
+ - type: bind
+ source: ../package.json
+ target: /misskey/packages/backend/package.json
+ read_only: true
+ - type: bind
+ source: ../../misskey-js/built
+ target: /misskey/packages/misskey-js/built
+ read_only: true
+ - type: bind
+ source: ../../misskey-js/package.json
+ target: /misskey/packages/misskey-js/package.json
+ read_only: true
+ - type: bind
+ source: ../../misskey-reversi/built
+ target: /misskey/packages/misskey-reversi/built
+ read_only: true
+ - type: bind
+ source: ../../misskey-reversi/package.json
+ target: /misskey/packages/misskey-reversi/package.json
+ read_only: true
+ - type: bind
+ source: ../../../healthcheck.sh
+ target: /misskey/healthcheck.sh
+ read_only: true
+ - type: bind
+ source: ../../../package.json
+ target: /misskey/package.json
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-lock.yaml
+ target: /misskey/pnpm-lock.yaml
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-workspace.yaml
+ target: /misskey/pnpm-workspace.yaml
+ read_only: true
+ - type: bind
+ source: ./certificates/rootCA.crt
+ target: /usr/local/share/ca-certificates/rootCA.crt
+ read_only: true
+ working_dir: /misskey
+ command: >
+ bash -c "
+ corepack enable && corepack prepare
+ pnpm -F backend migrate
+ pnpm -F backend start
+ "
+ healthcheck:
+ test: bash /misskey/healthcheck.sh
+ interval: 5s
+ retries: 20
+
+ db:
+ image: postgres:15-alpine
+ env_file:
+ - ./.config/docker.env
+ volumes:
+ healthcheck:
+ test: pg_isready -U $$POSTGRES_USER -d $$POSTGRES_DB
+ interval: 5s
+ retries: 20
diff --git a/packages/backend/test-federation/compose.yml b/packages/backend/test-federation/compose.yml
new file mode 100644
index 0000000000..62d7e977c0
--- /dev/null
+++ b/packages/backend/test-federation/compose.yml
@@ -0,0 +1,133 @@
+include:
+ - ./compose.a.yml
+ - ./compose.b.yml
+
+services:
+ setup:
+ extends:
+ file: ./compose.tpl.yml
+ service: misskey
+ command: >
+ bash -c "
+ corepack enable && corepack prepare
+ pnpm -F backend i
+ pnpm -F misskey-js i
+ pnpm -F misskey-reversi i
+ "
+
+ tester:
+ image: node:20
+ depends_on:
+ a.test:
+ condition: service_healthy
+ b.test:
+ condition: service_healthy
+ environment:
+ - NODE_ENV=development
+ - NODE_EXTRA_CA_CERTS=/usr/local/share/ca-certificates/rootCA.crt
+ volumes:
+ - type: bind
+ source: ../package.json
+ target: /misskey/packages/backend/package.json
+ read_only: true
+ - type: bind
+ source: ../test/resources
+ target: /misskey/packages/backend/test/resources
+ read_only: true
+ - type: bind
+ source: ./test
+ target: /misskey/packages/backend/test-federation/test
+ read_only: true
+ - type: bind
+ source: ../jest.config.cjs
+ target: /misskey/packages/backend/jest.config.cjs
+ read_only: true
+ - type: bind
+ source: ../jest.config.fed.cjs
+ target: /misskey/packages/backend/jest.config.fed.cjs
+ read_only: true
+ - type: bind
+ source: ../../misskey-js/built
+ target: /misskey/packages/misskey-js/built
+ read_only: true
+ - type: bind
+ source: ../../misskey-js/package.json
+ target: /misskey/packages/misskey-js/package.json
+ read_only: true
+ - type: bind
+ source: ../../../package.json
+ target: /misskey/package.json
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-lock.yaml
+ target: /misskey/pnpm-lock.yaml
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-workspace.yaml
+ target: /misskey/pnpm-workspace.yaml
+ read_only: true
+ - type: bind
+ source: ./certificates/rootCA.crt
+ target: /usr/local/share/ca-certificates/rootCA.crt
+ read_only: true
+ working_dir: /misskey
+ entrypoint: >
+ bash -c '
+ corepack enable && corepack prepare
+ pnpm -F misskey-js i --frozen-lockfile
+ pnpm -F backend i --frozen-lockfile
+ exec "$0" "$@"
+ '
+ command: pnpm -F backend test:fed
+
+ daemon:
+ image: node:20
+ depends_on:
+ redis.test:
+ condition: service_healthy
+ volumes:
+ - type: bind
+ source: ../package.json
+ target: /misskey/packages/backend/package.json
+ read_only: true
+ - type: bind
+ source: ./daemon.ts
+ target: /misskey/packages/backend/test-federation/daemon.ts
+ read_only: true
+ - type: bind
+ source: ./tsconfig.json
+ target: /misskey/packages/backend/test-federation/tsconfig.json
+ read_only: true
+ - type: bind
+ source: ../../../package.json
+ target: /misskey/package.json
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-lock.yaml
+ target: /misskey/pnpm-lock.yaml
+ read_only: true
+ - type: bind
+ source: ../../../pnpm-workspace.yaml
+ target: /misskey/pnpm-workspace.yaml
+ read_only: true
+ working_dir: /misskey
+ command: >
+ bash -c "
+ corepack enable && corepack prepare
+ pnpm -F backend i --frozen-lockfile
+ pnpm exec tsc -p ./packages/backend/test-federation
+ node ./packages/backend/test-federation/built/daemon.js
+ "
+
+ redis.test:
+ image: redis:7-alpine
+ volumes:
+ - type: bind
+ source: ./volumes/redis
+ target: /data
+ bind:
+ create_host_path: true
+ healthcheck:
+ test: redis-cli ping
+ interval: 5s
+ retries: 20
diff --git a/packages/backend/test-federation/daemon.ts b/packages/backend/test-federation/daemon.ts
new file mode 100644
index 0000000000..46b6963c79
--- /dev/null
+++ b/packages/backend/test-federation/daemon.ts
@@ -0,0 +1,38 @@
+import IPCIDR from 'ip-cidr';
+import { Redis } from 'ioredis';
+
+const TESTER_IP_ADDRESS = '172.20.1.1';
+
+/**
+ * This should be same as {@link file://./../src/misc/get-ip-hash.ts}.
+ */
+function getIpHash(ip: string) {
+ const prefix = IPCIDR.createAddress(ip).mask(64);
+ return `ip-${BigInt('0b' + prefix).toString(36)}`;
+}
+
+/**
+ * This prevents hitting rate limit when login.
+ */
+export async function purgeLimit(host: string, client: Redis) {
+ const ipHash = getIpHash(TESTER_IP_ADDRESS);
+ const key = `${host}:limit:${ipHash}:signin`;
+ const res = await client.zrange(key, 0, -1);
+ if (res.length !== 0) {
+ console.log(`${key} - ${JSON.stringify(res)}`);
+ await client.del(key);
+ }
+}
+
+console.log('Daemon started running');
+
+{
+ const redisClient = new Redis({
+ host: 'redis.test',
+ });
+
+ setInterval(() => {
+ purgeLimit('a.test', redisClient);
+ purgeLimit('b.test', redisClient);
+ }, 200);
+}
diff --git a/packages/backend/test-federation/eslint.config.js b/packages/backend/test-federation/eslint.config.js
new file mode 100644
index 0000000000..e3bcf4c0fe
--- /dev/null
+++ b/packages/backend/test-federation/eslint.config.js
@@ -0,0 +1,21 @@
+import globals from 'globals';
+import tsParser from '@typescript-eslint/parser';
+import sharedConfig from '../../shared/eslint.config.js';
+
+export default [
+ ...sharedConfig,
+ {
+ files: ['**/*.ts', '**/*.tsx'],
+ languageOptions: {
+ globals: {
+ ...globals.node,
+ },
+ parserOptions: {
+ parser: tsParser,
+ project: ['./tsconfig.json'],
+ sourceType: 'module',
+ tsconfigRootDir: import.meta.dirname,
+ },
+ },
+ },
+];
diff --git a/packages/backend/test-federation/setup.sh b/packages/backend/test-federation/setup.sh
new file mode 100644
index 0000000000..1bc3a2a87c
--- /dev/null
+++ b/packages/backend/test-federation/setup.sh
@@ -0,0 +1,35 @@
+#!/bin/bash
+mkdir certificates
+
+# rootCA
+openssl genrsa -des3 \
+ -passout pass:rootCA \
+ -out certificates/rootCA.key 4096
+openssl req -x509 -new -nodes -batch \
+ -key certificates/rootCA.key \
+ -sha256 \
+ -days 1024 \
+ -passin pass:rootCA \
+ -out certificates/rootCA.crt
+
+# domain
+function generate {
+ openssl req -new -newkey rsa:2048 -sha256 -nodes \
+ -keyout certificates/$1.key \
+ -subj "/CN=$1/emailAddress=admin@$1/C=JP/ST=/L=/O=Misskey Tester/OU=Some Unit" \
+ -out certificates/$1.csr
+ openssl x509 -req -sha256 \
+ -in certificates/$1.csr \
+ -CA certificates/rootCA.crt \
+ -CAkey certificates/rootCA.key \
+ -CAcreateserial \
+ -passin pass:rootCA \
+ -out certificates/$1.crt \
+ -days 500
+ if [ ! -f .config/docker.env ]; then cp .config/example.docker.env .config/docker.env; fi
+ if [ ! -f .config/$1.conf ]; then sed "s/\${HOST}/$1/g" .config/example.conf > .config/$1.conf; fi
+ if [ ! -f .config/$1.default.yml ]; then sed "s/\${HOST}/$1/g" .config/example.default.yml > .config/$1.default.yml; fi
+}
+
+generate a.test
+generate b.test
diff --git a/packages/backend/test-federation/test/abuse-report.test.ts b/packages/backend/test-federation/test/abuse-report.test.ts
new file mode 100644
index 0000000000..b54d6222b4
--- /dev/null
+++ b/packages/backend/test-federation/test/abuse-report.test.ts
@@ -0,0 +1,52 @@
+import { rejects, strictEqual } from 'node:assert';
+import * as Misskey from 'misskey-js';
+import { createAccount, createModerator, resolveRemoteUser, sleep, type LoginUser } from './utils.js';
+
+describe('Abuse report', () => {
+ describe('Forwarding report', () => {
+ let alice: LoginUser, bob: LoginUser, aModerator: LoginUser, bModerator: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [aModerator, bModerator] = await Promise.all([
+ createModerator('a.test'),
+ createModerator('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ test('Alice reports Bob, moderator in A forwards it, and B moderator receives it', async () => {
+ const comment = crypto.randomUUID();
+ await alice.client.request('users/report-abuse', { userId: bobInA.id, comment });
+ const reports = await aModerator.client.request('admin/abuse-user-reports', {});
+ const report = reports.filter(report => report.comment === comment)[0];
+ await aModerator.client.request('admin/forward-abuse-user-report', { reportId: report.id });
+ await sleep();
+
+ const reportsInB = await bModerator.client.request('admin/abuse-user-reports', {});
+ const reportInB = reportsInB.filter(report => report.comment.includes(comment))[0];
+ // NOTE: reporter is not Alice, and is not moderator in A
+ strictEqual(reportInB.reporter.url, 'https://a.test/@instance.actor');
+ strictEqual(reportInB.targetUserId, bob.id);
+
+ // NOTE: cannot forward multiple times
+ await rejects(
+ async () => await aModerator.client.request('admin/forward-abuse-user-report', { reportId: report.id }),
+ (err: any) => {
+ strictEqual(err.code, 'INTERNAL_ERROR');
+ strictEqual(err.info.e.message, 'The report has already been forwarded.');
+ return true;
+ },
+ );
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/block.test.ts b/packages/backend/test-federation/test/block.test.ts
new file mode 100644
index 0000000000..ef910eeaea
--- /dev/null
+++ b/packages/backend/test-federation/test/block.test.ts
@@ -0,0 +1,224 @@
+import { deepStrictEqual, rejects, strictEqual } from 'node:assert';
+import * as Misskey from 'misskey-js';
+import { assertNotificationReceived, createAccount, type LoginUser, resolveRemoteNote, resolveRemoteUser, sleep } from './utils.js';
+
+describe('Block', () => {
+ describe('Check follow', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ test('Cannot follow if blocked', async () => {
+ await alice.client.request('blocking/create', { userId: bobInA.id });
+ await sleep();
+ await rejects(
+ async () => await bob.client.request('following/create', { userId: aliceInB.id }),
+ (err: any) => {
+ strictEqual(err.code, 'BLOCKED');
+ return true;
+ },
+ );
+
+ const following = await bob.client.request('users/following', { userId: bob.id });
+ strictEqual(following.length, 0);
+ const followers = await alice.client.request('users/followers', { userId: alice.id });
+ strictEqual(followers.length, 0);
+ });
+
+ // FIXME: this is invalid case
+ test('Cannot follow even if unblocked', async () => {
+ // unblock here
+ await alice.client.request('blocking/delete', { userId: bobInA.id });
+ await sleep();
+
+ // TODO: why still being blocked?
+ await rejects(
+ async () => await bob.client.request('following/create', { userId: aliceInB.id }),
+ (err: any) => {
+ strictEqual(err.code, 'BLOCKED');
+ return true;
+ },
+ );
+ });
+
+ test.skip('Can follow if unblocked', async () => {
+ await alice.client.request('blocking/delete', { userId: bobInA.id });
+ await sleep();
+
+ await bob.client.request('following/create', { userId: aliceInB.id });
+ await sleep();
+
+ const following = await bob.client.request('users/following', { userId: bob.id });
+ strictEqual(following.length, 1);
+ const followers = await alice.client.request('users/followers', { userId: alice.id });
+ strictEqual(followers.length, 1);
+ });
+
+ test.skip('Remove follower when block them', async () => {
+ test('before block', async () => {
+ const following = await bob.client.request('users/following', { userId: bob.id });
+ strictEqual(following.length, 1);
+ const followers = await alice.client.request('users/followers', { userId: alice.id });
+ strictEqual(followers.length, 1);
+ });
+
+ await alice.client.request('blocking/create', { userId: bobInA.id });
+ await sleep();
+
+ test('after block', async () => {
+ const following = await bob.client.request('users/following', { userId: bob.id });
+ strictEqual(following.length, 0);
+ const followers = await alice.client.request('users/followers', { userId: alice.id });
+ strictEqual(followers.length, 0);
+ });
+ });
+ });
+
+ describe('Check reply', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ test('Cannot reply if blocked', async () => {
+ await alice.client.request('blocking/create', { userId: bobInA.id });
+ await sleep();
+
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ await rejects(
+ async () => await bob.client.request('notes/create', { text: 'b', replyId: resolvedNote.id }),
+ (err: any) => {
+ strictEqual(err.code, 'YOU_HAVE_BEEN_BLOCKED');
+ return true;
+ },
+ );
+ });
+
+ test('Can reply if unblocked', async () => {
+ await alice.client.request('blocking/delete', { userId: bobInA.id });
+ await sleep();
+
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ const reply = (await bob.client.request('notes/create', { text: 'b', replyId: resolvedNote.id })).createdNote;
+
+ await resolveRemoteNote('b.test', reply.id, alice);
+ });
+ });
+
+ describe('Check reaction', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ test('Cannot reaction if blocked', async () => {
+ await alice.client.request('blocking/create', { userId: bobInA.id });
+ await sleep();
+
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ await rejects(
+ async () => await bob.client.request('notes/reactions/create', { noteId: resolvedNote.id, reaction: '😅' }),
+ (err: any) => {
+ strictEqual(err.code, 'YOU_HAVE_BEEN_BLOCKED');
+ return true;
+ },
+ );
+ });
+
+ // FIXME: this is invalid case
+ test('Cannot reaction even if unblocked', async () => {
+ // unblock here
+ await alice.client.request('blocking/delete', { userId: bobInA.id });
+ await sleep();
+
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+
+ // TODO: why still being blocked?
+ await rejects(
+ async () => await bob.client.request('notes/reactions/create', { noteId: resolvedNote.id, reaction: '😅' }),
+ (err: any) => {
+ strictEqual(err.code, 'YOU_HAVE_BEEN_BLOCKED');
+ return true;
+ },
+ );
+ });
+
+ test.skip('Can reaction if unblocked', async () => {
+ await alice.client.request('blocking/delete', { userId: bobInA.id });
+ await sleep();
+
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ await bob.client.request('notes/reactions/create', { noteId: resolvedNote.id, reaction: '😅' });
+
+ const _note = await alice.client.request('notes/show', { noteId: note.id });
+ deepStrictEqual(_note.reactions, { '😅': 1 });
+ });
+ });
+
+ describe('Check mention', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ /** NOTE: You should mute the target to stop receiving notifications */
+ test('Can mention and notified even if blocked', async () => {
+ await alice.client.request('blocking/create', { userId: bobInA.id });
+ await sleep();
+
+ const text = `@${alice.username}@a.test plz unblock me!`;
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/create', { text }),
+ notification => notification.type === 'mention' && notification.userId === bobInA.id && notification.note.text === text,
+ true,
+ );
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/drive.test.ts b/packages/backend/test-federation/test/drive.test.ts
new file mode 100644
index 0000000000..f755183b4d
--- /dev/null
+++ b/packages/backend/test-federation/test/drive.test.ts
@@ -0,0 +1,175 @@
+import assert, { strictEqual } from 'node:assert';
+import * as Misskey from 'misskey-js';
+import { createAccount, deepStrictEqualWithExcludedFields, fetchAdmin, type LoginUser, resolveRemoteNote, resolveRemoteUser, sleep, uploadFile } from './utils.js';
+
+const bAdmin = await fetchAdmin('b.test');
+
+describe('Drive', () => {
+ describe('Upload image in a.test and resolve from b.test', () => {
+ let uploader: LoginUser;
+
+ beforeAll(async () => {
+ uploader = await createAccount('a.test');
+ });
+
+ let image: Misskey.entities.DriveFile, imageInB: Misskey.entities.DriveFile;
+
+ describe('Upload', () => {
+ beforeAll(async () => {
+ image = await uploadFile('a.test', uploader);
+ const noteWithImage = (await uploader.client.request('notes/create', { fileIds: [image.id] })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', noteWithImage.id, bAdmin);
+ assert(noteInB.files != null);
+ strictEqual(noteInB.files.length, 1);
+ imageInB = noteInB.files[0];
+ });
+
+ test('Check consistency of DriveFile', () => {
+ // console.log(`a.test: ${JSON.stringify(image, null, '\t')}`);
+ // console.log(`b.test: ${JSON.stringify(imageInB, null, '\t')}`);
+
+ deepStrictEqualWithExcludedFields(image, imageInB, [
+ 'id',
+ 'createdAt',
+ 'size',
+ 'url',
+ 'thumbnailUrl',
+ 'userId',
+ ]);
+ });
+ });
+
+ let updatedImage: Misskey.entities.DriveFile, updatedImageInB: Misskey.entities.DriveFile;
+
+ describe('Update', () => {
+ beforeAll(async () => {
+ updatedImage = await uploader.client.request('drive/files/update', {
+ fileId: image.id,
+ name: 'updated_192.jpg',
+ isSensitive: true,
+ });
+
+ updatedImageInB = await bAdmin.client.request('drive/files/show', {
+ fileId: imageInB.id,
+ });
+ });
+
+ test('Check consistency', () => {
+ // console.log(`a.test: ${JSON.stringify(updatedImage, null, '\t')}`);
+ // console.log(`b.test: ${JSON.stringify(updatedImageInB, null, '\t')}`);
+
+ // FIXME: not updated with `drive/files/update`
+ strictEqual(updatedImage.isSensitive, true);
+ strictEqual(updatedImage.name, 'updated_192.jpg');
+ strictEqual(updatedImageInB.isSensitive, false);
+ strictEqual(updatedImageInB.name, '192.jpg');
+ });
+ });
+
+ let reupdatedImageInB: Misskey.entities.DriveFile;
+
+ describe('Re-update with attaching to Note', () => {
+ beforeAll(async () => {
+ const noteWithUpdatedImage = (await uploader.client.request('notes/create', { fileIds: [updatedImage.id] })).createdNote;
+ const noteWithUpdatedImageInB = await resolveRemoteNote('a.test', noteWithUpdatedImage.id, bAdmin);
+ assert(noteWithUpdatedImageInB.files != null);
+ strictEqual(noteWithUpdatedImageInB.files.length, 1);
+ reupdatedImageInB = noteWithUpdatedImageInB.files[0];
+ });
+
+ test('Check consistency', () => {
+ // console.log(`b.test: ${JSON.stringify(reupdatedImageInB, null, '\t')}`);
+
+ // `isSensitive` is updated
+ strictEqual(reupdatedImageInB.isSensitive, true);
+ // FIXME: but `name` is not updated
+ strictEqual(reupdatedImageInB.name, '192.jpg');
+ });
+ });
+ });
+
+ describe('Sensitive flag', () => {
+ describe('isSensitive is federated in delivering to followers', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+
+ await bob.client.request('following/create', { userId: aliceInB.id });
+ await sleep();
+ });
+
+ test('Alice uploads sensitive image and it is shown as sensitive from Bob', async () => {
+ const file = await uploadFile('a.test', alice);
+ await alice.client.request('drive/files/update', { fileId: file.id, isSensitive: true });
+ await alice.client.request('notes/create', { text: 'sensitive', fileIds: [file.id] });
+ await sleep();
+
+ const notes = await bob.client.request('notes/timeline', {});
+ strictEqual(notes.length, 1);
+ const noteInB = notes[0];
+ assert(noteInB.files != null);
+ strictEqual(noteInB.files.length, 1);
+ strictEqual(noteInB.files[0].isSensitive, true);
+ });
+ });
+
+ describe('isSensitive is federated in resolving', () => {
+ let alice: LoginUser, bob: LoginUser;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+ });
+
+ test('Alice uploads sensitive image and it is shown as sensitive from Bob', async () => {
+ const file = await uploadFile('a.test', alice);
+ await alice.client.request('drive/files/update', { fileId: file.id, isSensitive: true });
+ const note = (await alice.client.request('notes/create', { text: 'sensitive', fileIds: [file.id] })).createdNote;
+
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ assert(noteInB.files != null);
+ strictEqual(noteInB.files.length, 1);
+ strictEqual(noteInB.files[0].isSensitive, true);
+ });
+ });
+
+ /** @see https://github.com/misskey-dev/misskey/issues/12208 */
+ describe('isSensitive is federated in replying', () => {
+ let alice: LoginUser, bob: LoginUser;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+ });
+
+ test('Alice uploads sensitive image and it is shown as sensitive from Bob', async () => {
+ const bobNote = (await bob.client.request('notes/create', { text: 'I\'m Bob' })).createdNote;
+
+ const file = await uploadFile('a.test', alice);
+ await alice.client.request('drive/files/update', { fileId: file.id, isSensitive: true });
+ const bobNoteInA = await resolveRemoteNote('b.test', bobNote.id, alice);
+ const note = (await alice.client.request('notes/create', { text: 'sensitive', fileIds: [file.id], replyId: bobNoteInA.id })).createdNote;
+ await sleep();
+
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ assert(noteInB.files != null);
+ strictEqual(noteInB.files.length, 1);
+ strictEqual(noteInB.files[0].isSensitive, true);
+ });
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/emoji.test.ts b/packages/backend/test-federation/test/emoji.test.ts
new file mode 100644
index 0000000000..3119ca6e4d
--- /dev/null
+++ b/packages/backend/test-federation/test/emoji.test.ts
@@ -0,0 +1,97 @@
+import assert, { deepStrictEqual, strictEqual } from 'assert';
+import * as Misskey from 'misskey-js';
+import { addCustomEmoji, createAccount, type LoginUser, resolveRemoteUser, sleep } from './utils.js';
+
+describe('Emoji', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+
+ await bob.client.request('following/create', { userId: aliceInB.id });
+ await sleep();
+ });
+
+ test('Custom emoji are delivered with Note delivery', async () => {
+ const emoji = await addCustomEmoji('a.test');
+ await alice.client.request('notes/create', { text: `I love :${emoji.name}:` });
+ await sleep();
+
+ const notes = await bob.client.request('notes/timeline', {});
+ const noteInB = notes[0];
+
+ strictEqual(noteInB.text, `I love \u200b:${emoji.name}:\u200b`);
+ assert(noteInB.emojis != null);
+ assert(emoji.name in noteInB.emojis);
+ strictEqual(noteInB.emojis[emoji.name], emoji.url);
+ });
+
+ test('Custom emoji are delivered with Reaction delivery', async () => {
+ const emoji = await addCustomEmoji('a.test');
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ await sleep();
+
+ await alice.client.request('notes/reactions/create', { noteId: note.id, reaction: `:${emoji.name}:` });
+ await sleep();
+
+ const noteInB = (await bob.client.request('notes/timeline', {}))[0];
+ deepStrictEqual(noteInB.reactions[`:${emoji.name}@a.test:`], 1);
+ deepStrictEqual(noteInB.reactionEmojis[`${emoji.name}@a.test`], emoji.url);
+ });
+
+ test('Custom emoji are delivered with Profile delivery', async () => {
+ const emoji = await addCustomEmoji('a.test');
+ const renewedAlice = await alice.client.request('i/update', { name: `:${emoji.name}:` });
+ await sleep();
+
+ const renewedaliceInB = await bob.client.request('users/show', { userId: aliceInB.id });
+ strictEqual(renewedaliceInB.name, renewedAlice.name);
+ assert(emoji.name in renewedaliceInB.emojis);
+ strictEqual(renewedaliceInB.emojis[emoji.name], emoji.url);
+ });
+
+ test('Local-only custom emoji aren\'t delivered with Note delivery', async () => {
+ const emoji = await addCustomEmoji('a.test', { localOnly: true });
+ await alice.client.request('notes/create', { text: `I love :${emoji.name}:` });
+ await sleep();
+
+ const notes = await bob.client.request('notes/timeline', {});
+ const noteInB = notes[0];
+
+ strictEqual(noteInB.text, `I love \u200b:${emoji.name}:\u200b`);
+ // deepStrictEqual(noteInB.emojis, {}); // TODO: this fails (why?)
+ deepStrictEqual({ ...noteInB.emojis }, {});
+ });
+
+ test('Local-only custom emoji aren\'t delivered with Reaction delivery', async () => {
+ const emoji = await addCustomEmoji('a.test', { localOnly: true });
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ await sleep();
+
+ await alice.client.request('notes/reactions/create', { noteId: note.id, reaction: `:${emoji.name}:` });
+ await sleep();
+
+ const noteInB = (await bob.client.request('notes/timeline', {}))[0];
+ deepStrictEqual({ ...noteInB.reactions }, { '❤': 1 });
+ deepStrictEqual({ ...noteInB.reactionEmojis }, {});
+ });
+
+ test('Local-only custom emoji aren\'t delivered with Profile delivery', async () => {
+ const emoji = await addCustomEmoji('a.test', { localOnly: true });
+ const renewedAlice = await alice.client.request('i/update', { name: `:${emoji.name}:` });
+ await sleep();
+
+ const renewedaliceInB = await bob.client.request('users/show', { userId: aliceInB.id });
+ strictEqual(renewedaliceInB.name, renewedAlice.name);
+ deepStrictEqual({ ...renewedaliceInB.emojis }, {});
+ });
+});
diff --git a/packages/backend/test-federation/test/move.test.ts b/packages/backend/test-federation/test/move.test.ts
new file mode 100644
index 0000000000..56a57de8a4
--- /dev/null
+++ b/packages/backend/test-federation/test/move.test.ts
@@ -0,0 +1,52 @@
+import assert, { strictEqual } from 'node:assert';
+import { createAccount, type LoginUser, sleep } from './utils.js';
+
+describe('Move', () => {
+ test('Minimum move', async () => {
+ const [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ await bob.client.request('i/update', { alsoKnownAs: [`@${alice.username}@a.test`] });
+ await alice.client.request('i/move', { moveToAccount: `@${bob.username}@b.test` });
+ });
+
+ /** @see https://github.com/misskey-dev/misskey/issues/11320 */
+ describe('Following relation is transferred after move', () => {
+ let alice: LoginUser, bob: LoginUser, carol: LoginUser;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+ carol = await createAccount('a.test');
+
+ // Follow @carol@a.test ==> @alice@a.test
+ await carol.client.request('following/create', { userId: alice.id });
+
+ // Move @alice@a.test ==> @bob@b.test
+ await bob.client.request('i/update', { alsoKnownAs: [`@${alice.username}@a.test`] });
+ await alice.client.request('i/move', { moveToAccount: `@${bob.username}@b.test` });
+ await sleep();
+ });
+
+ test('Check from follower', async () => {
+ const following = await carol.client.request('users/following', { userId: carol.id });
+ strictEqual(following.length, 2);
+ const followees = following.map(({ followee }) => followee);
+ assert(followees.every(followee => followee != null));
+ assert(followees.some(({ id, url }) => id === alice.id && url === null));
+ assert(followees.some(({ url }) => url === `https://b.test/@${bob.username}`));
+ });
+
+ test('Check from followee', async () => {
+ const followers = await bob.client.request('users/followers', { userId: bob.id });
+ strictEqual(followers.length, 1);
+ const follower = followers[0].follower;
+ assert(follower != null);
+ strictEqual(follower.url, `https://a.test/@${carol.username}`);
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/note.test.ts b/packages/backend/test-federation/test/note.test.ts
new file mode 100644
index 0000000000..bacc4cc54f
--- /dev/null
+++ b/packages/backend/test-federation/test/note.test.ts
@@ -0,0 +1,317 @@
+import assert, { rejects, strictEqual } from 'node:assert';
+import * as Misskey from 'misskey-js';
+import { addCustomEmoji, createAccount, createModerator, deepStrictEqualWithExcludedFields, type LoginUser, resolveRemoteNote, resolveRemoteUser, sleep, uploadFile } from './utils.js';
+
+describe('Note', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ describe('Note content', () => {
+ test('Consistency of Public Note', async () => {
+ const image = await uploadFile('a.test', alice);
+ const note = (await alice.client.request('notes/create', {
+ text: 'I am Alice!',
+ fileIds: [image.id],
+ poll: {
+ choices: ['neko', 'inu'],
+ multiple: false,
+ expiredAfter: 60 * 60 * 1000,
+ },
+ })).createdNote;
+
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ deepStrictEqualWithExcludedFields(note, resolvedNote, [
+ 'id',
+ 'emojis',
+ /** Consistency of files is checked at {@link file://./drive.test.ts}, so let's skip. */
+ 'fileIds',
+ 'files',
+ /** @see https://github.com/misskey-dev/misskey/issues/12409 */
+ 'reactionAcceptance',
+ 'userId',
+ 'user',
+ 'uri',
+ ]);
+ strictEqual(aliceInB.id, resolvedNote.userId);
+ });
+
+ test('Consistency of reply', async () => {
+ const _replyedNote = (await alice.client.request('notes/create', {
+ text: 'a',
+ })).createdNote;
+ const note = (await alice.client.request('notes/create', {
+ text: 'b',
+ replyId: _replyedNote.id,
+ })).createdNote;
+ // NOTE: the repliedCount is incremented, so fetch again
+ const replyedNote = await alice.client.request('notes/show', { noteId: _replyedNote.id });
+ strictEqual(replyedNote.repliesCount, 1);
+
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ deepStrictEqualWithExcludedFields(note, resolvedNote, [
+ 'id',
+ 'emojis',
+ 'reactionAcceptance',
+ 'replyId',
+ 'reply',
+ 'userId',
+ 'user',
+ 'uri',
+ ]);
+ assert(resolvedNote.replyId != null);
+ assert(resolvedNote.reply != null);
+ deepStrictEqualWithExcludedFields(replyedNote, resolvedNote.reply, [
+ 'id',
+ // TODO: why clippedCount loses consistency?
+ 'clippedCount',
+ 'emojis',
+ 'userId',
+ 'user',
+ 'uri',
+ // flaky because this is parallelly incremented, so let's check it below
+ 'repliesCount',
+ ]);
+ strictEqual(aliceInB.id, resolvedNote.userId);
+
+ await sleep();
+
+ const resolvedReplyedNote = await bob.client.request('notes/show', { noteId: resolvedNote.replyId });
+ strictEqual(resolvedReplyedNote.repliesCount, 1);
+ });
+
+ test('Consistency of Renote', async () => {
+ // NOTE: the renoteCount is not incremented, so no need to fetch again
+ const renotedNote = (await alice.client.request('notes/create', {
+ text: 'a',
+ })).createdNote;
+ const note = (await alice.client.request('notes/create', {
+ text: 'b',
+ renoteId: renotedNote.id,
+ })).createdNote;
+
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ deepStrictEqualWithExcludedFields(note, resolvedNote, [
+ 'id',
+ 'emojis',
+ 'reactionAcceptance',
+ 'renoteId',
+ 'renote',
+ 'userId',
+ 'user',
+ 'uri',
+ ]);
+ assert(resolvedNote.renoteId != null);
+ assert(resolvedNote.renote != null);
+ deepStrictEqualWithExcludedFields(renotedNote, resolvedNote.renote, [
+ 'id',
+ 'emojis',
+ 'userId',
+ 'user',
+ 'uri',
+ ]);
+ strictEqual(aliceInB.id, resolvedNote.userId);
+ });
+ });
+
+ describe('Other props', () => {
+ test('localOnly', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a', localOnly: true })).createdNote;
+ rejects(
+ async () => await bob.client.request('ap/show', { uri: `https://a.test/notes/${note.id}` }),
+ (err: any) => {
+ /**
+ * FIXME: this error is not handled
+ * @see https://github.com/misskey-dev/misskey/issues/12736
+ */
+ strictEqual(err.code, 'INTERNAL_ERROR');
+ return true;
+ },
+ );
+ });
+ });
+
+ describe('Deletion', () => {
+ describe('Check Delete consistency', () => {
+ let carol: LoginUser;
+
+ beforeAll(async () => {
+ carol = await createAccount('a.test');
+
+ await carol.client.request('following/create', { userId: bobInA.id });
+ await sleep();
+ });
+
+ test('Delete is derivered to followers', async () => {
+ const note = (await bob.client.request('notes/create', { text: 'I\'m Bob.' })).createdNote;
+ const noteInA = await resolveRemoteNote('b.test', note.id, carol);
+ await bob.client.request('notes/delete', { noteId: note.id });
+ await sleep();
+
+ await rejects(
+ async () => await carol.client.request('notes/show', { noteId: noteInA.id }),
+ (err: any) => {
+ strictEqual(err.code, 'NO_SUCH_NOTE');
+ return true;
+ },
+ );
+ });
+ });
+
+ describe('Deletion of remote user\'s note for moderation', () => {
+ let note: Misskey.entities.Note;
+
+ test('Alice post is deleted in B', async () => {
+ note = (await alice.client.request('notes/create', { text: 'Hello' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const bMod = await createModerator('b.test');
+ await bMod.client.request('notes/delete', { noteId: noteInB.id });
+ await rejects(
+ async () => await bob.client.request('notes/show', { noteId: noteInB.id }),
+ (err: any) => {
+ strictEqual(err.code, 'NO_SUCH_NOTE');
+ return true;
+ },
+ );
+ });
+
+ /**
+ * FIXME: implement soft deletion as well as user?
+ * @see https://github.com/misskey-dev/misskey/issues/11437
+ */
+ test.failing('Not found even if resolve again', async () => {
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ await rejects(
+ async () => await bob.client.request('notes/show', { noteId: noteInB.id }),
+ (err: any) => {
+ strictEqual(err.code, 'NO_SUCH_NOTE');
+ return true;
+ },
+ );
+ });
+ });
+ });
+
+ describe('Reaction', () => {
+ describe('Consistency', () => {
+ test('Unicode reaction', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ const reaction = '😅';
+ await bob.client.request('notes/reactions/create', { noteId: resolvedNote.id, reaction });
+ await sleep();
+
+ const reactions = await alice.client.request('notes/reactions', { noteId: note.id });
+ strictEqual(reactions.length, 1);
+ strictEqual(reactions[0].type, reaction);
+ strictEqual(reactions[0].user.id, bobInA.id);
+ });
+
+ test('Custom emoji reaction', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const resolvedNote = await resolveRemoteNote('a.test', note.id, bob);
+ const emoji = await addCustomEmoji('b.test');
+ await bob.client.request('notes/reactions/create', { noteId: resolvedNote.id, reaction: `:${emoji.name}:` });
+ await sleep();
+
+ const reactions = await alice.client.request('notes/reactions', { noteId: note.id });
+ strictEqual(reactions.length, 1);
+ strictEqual(reactions[0].type, `:${emoji.name}@b.test:`);
+ strictEqual(reactions[0].user.id, bobInA.id);
+ });
+ });
+
+ describe('Acceptance', () => {
+ test('Even if likeOnly, remote users can react with custom emoji, but it is converted to like', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a', reactionAcceptance: 'likeOnly' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const emoji = await addCustomEmoji('b.test');
+ await bob.client.request('notes/reactions/create', { noteId: noteInB.id, reaction: `:${emoji.name}:` });
+ await sleep();
+
+ const reactions = await alice.client.request('notes/reactions', { noteId: note.id });
+ strictEqual(reactions.length, 1);
+ strictEqual(reactions[0].type, '❤');
+ });
+
+ /**
+ * TODO: this may be unexpected behavior?
+ * @see https://github.com/misskey-dev/misskey/issues/12409
+ */
+ test('Even if nonSensitiveOnly, remote users can react with sensitive emoji, and it is not converted', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a', reactionAcceptance: 'nonSensitiveOnly' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const emoji = await addCustomEmoji('b.test', { isSensitive: true });
+ await bob.client.request('notes/reactions/create', { noteId: noteInB.id, reaction: `:${emoji.name}:` });
+ await sleep();
+
+ const reactions = await alice.client.request('notes/reactions', { noteId: note.id });
+ strictEqual(reactions.length, 1);
+ strictEqual(reactions[0].type, `:${emoji.name}@b.test:`);
+ });
+ });
+ });
+
+ describe('Poll', () => {
+ describe('Any remote user\'s vote is delivered to the author', () => {
+ let carol: LoginUser;
+
+ beforeAll(async () => {
+ carol = await createAccount('a.test');
+ });
+
+ test('Bob creates poll and receives a vote from Carol', async () => {
+ const note = (await bob.client.request('notes/create', { poll: { choices: ['inu', 'neko'] } })).createdNote;
+ const noteInA = await resolveRemoteNote('b.test', note.id, carol);
+ await carol.client.request('notes/polls/vote', { noteId: noteInA.id, choice: 0 });
+ await sleep();
+
+ const noteAfterVote = await bob.client.request('notes/show', { noteId: note.id });
+ assert(noteAfterVote.poll != null);
+ strictEqual(noteAfterVote.poll.choices[0].votes, 1);
+ strictEqual(noteAfterVote.poll.choices[1].votes, 0);
+ });
+ });
+
+ describe('Local user\'s vote is delivered to the author\'s remote followers', () => {
+ let bobRemoteFollower: LoginUser, localVoter: LoginUser;
+
+ beforeAll(async () => {
+ [
+ bobRemoteFollower,
+ localVoter,
+ ] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ await bobRemoteFollower.client.request('following/create', { userId: bobInA.id });
+ await sleep();
+ });
+
+ test('A vote in Bob\'s server is delivered to Bob\'s remote followers', async () => {
+ const note = (await bob.client.request('notes/create', { poll: { choices: ['inu', 'neko'] } })).createdNote;
+ // NOTE: resolve before voting
+ const noteInA = await resolveRemoteNote('b.test', note.id, bobRemoteFollower);
+ await localVoter.client.request('notes/polls/vote', { noteId: note.id, choice: 0 });
+ await sleep();
+
+ const noteAfterVote = await bobRemoteFollower.client.request('notes/show', { noteId: noteInA.id });
+ assert(noteAfterVote.poll != null);
+ strictEqual(noteAfterVote.poll.choices[0].votes, 1);
+ strictEqual(noteAfterVote.poll.choices[1].votes, 0);
+ });
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/notification.test.ts b/packages/backend/test-federation/test/notification.test.ts
new file mode 100644
index 0000000000..6d55353653
--- /dev/null
+++ b/packages/backend/test-federation/test/notification.test.ts
@@ -0,0 +1,107 @@
+import * as Misskey from 'misskey-js';
+import { assertNotificationReceived, createAccount, type LoginUser, resolveRemoteNote, resolveRemoteUser, sleep } from './utils.js';
+
+describe('Notification', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+ });
+
+ describe('Follow', () => {
+ test('Get notification when follow', async () => {
+ await assertNotificationReceived(
+ 'b.test', bob,
+ async () => await bob.client.request('following/create', { userId: aliceInB.id }),
+ notification => notification.type === 'followRequestAccepted' && notification.userId === aliceInB.id,
+ true,
+ );
+
+ await bob.client.request('following/delete', { userId: aliceInB.id });
+ await sleep();
+ });
+
+ test('Get notification when get followed', async () => {
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('following/create', { userId: aliceInB.id }),
+ notification => notification.type === 'follow' && notification.userId === bobInA.id,
+ true,
+ );
+ });
+
+ afterAll(async () => await bob.client.request('following/delete', { userId: aliceInB.id }));
+ });
+
+ describe('Note', () => {
+ test('Get notification when get a reaction', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const reaction = '😅';
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/reactions/create', { noteId: noteInB.id, reaction }),
+ notification =>
+ notification.type === 'reaction' && notification.note.id === note.id && notification.userId === bobInA.id && notification.reaction === reaction,
+ true,
+ );
+ });
+
+ test('Get notification when replied', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const text = crypto.randomUUID();
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/create', { text, replyId: noteInB.id }),
+ notification =>
+ notification.type === 'reply' && notification.note.reply!.id === note.id && notification.userId === bobInA.id && notification.note.text === text,
+ true,
+ );
+ });
+
+ test('Get notification when renoted', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/create', { renoteId: noteInB.id }),
+ notification =>
+ notification.type === 'renote' && notification.note.renote!.id === note.id && notification.userId === bobInA.id,
+ true,
+ );
+ });
+
+ test('Get notification when quoted', async () => {
+ const note = (await alice.client.request('notes/create', { text: 'a' })).createdNote;
+ const noteInB = await resolveRemoteNote('a.test', note.id, bob);
+ const text = crypto.randomUUID();
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/create', { text, renoteId: noteInB.id }),
+ notification =>
+ notification.type === 'quote' && notification.note.renote!.id === note.id && notification.userId === bobInA.id && notification.note.text === text,
+ true,
+ );
+ });
+
+ test('Get notification when mentioned', async () => {
+ const text = `@${alice.username}@a.test`;
+ await assertNotificationReceived(
+ 'a.test', alice,
+ async () => await bob.client.request('notes/create', { text }),
+ notification => notification.type === 'mention' && notification.userId === bobInA.id && notification.note.text === text,
+ true,
+ );
+ });
+ });
+});
diff --git a/packages/backend/test-federation/test/timeline.test.ts b/packages/backend/test-federation/test/timeline.test.ts
new file mode 100644
index 0000000000..2250bf4a42
--- /dev/null
+++ b/packages/backend/test-federation/test/timeline.test.ts
@@ -0,0 +1,328 @@
+import { strictEqual } from 'assert';
+import * as Misskey from 'misskey-js';
+import { createAccount, fetchAdmin, isNoteUpdatedEventFired, isFired, type LoginUser, type Request, resolveRemoteUser, sleep, createRole } from './utils.js';
+
+const bAdmin = await fetchAdmin('b.test');
+
+describe('Timeline', () => {
+ let alice: LoginUser, bob: LoginUser;
+ let bobInA: Misskey.entities.UserDetailedNotMe, aliceInB: Misskey.entities.UserDetailedNotMe;
+
+ beforeAll(async () => {
+ [alice, bob] = await Promise.all([
+ createAccount('a.test'),
+ createAccount('b.test'),
+ ]);
+
+ [bobInA, aliceInB] = await Promise.all([
+ resolveRemoteUser('b.test', bob.id, alice),
+ resolveRemoteUser('a.test', alice.id, bob),
+ ]);
+
+ await bob.client.request('following/create', { userId: aliceInB.id });
+ await sleep();
+ });
+
+ type TimelineChannel = keyof Misskey.Channels & (`${string}Timeline` | 'antenna' | 'userList' | 'hashtag');
+ type TimelineEndpoint = keyof Misskey.Endpoints & (`${string}timeline` | 'antennas/notes' | 'roles/notes' | 'notes/search-by-tag');
+ const timelineMap = new Map