summaryrefslogtreecommitdiff
path: root/packages/misskey-js/test
diff options
context:
space:
mode:
authorKagami Sascha Rosylight <saschanaz@outlook.com>2023-03-25 08:20:41 +0100
committerKagami Sascha Rosylight <saschanaz@outlook.com>2023-03-25 08:20:41 +0100
commit772e05e8351900c346fef04e8db714c027bf65c5 (patch)
treecdd994b982255bf80b2af2f7bfdf384a712f6e14 /packages/misskey-js/test
parentRevert "Additional changes for the merge" (diff)
downloadmisskey-772e05e8351900c346fef04e8db714c027bf65c5.tar.gz
misskey-772e05e8351900c346fef04e8db714c027bf65c5.tar.bz2
misskey-772e05e8351900c346fef04e8db714c027bf65c5.zip
Revert "Subtree merged in packages/misskey-js"
This reverts commit 3b524f32bfadfa76d28ef26600642bd190118da3, reversing changes made to 5be54451a8b4ac06f2f54d947bb920605dddff55.
Diffstat (limited to 'packages/misskey-js/test')
-rw-r--r--packages/misskey-js/test/api.ts212
-rw-r--r--packages/misskey-js/test/streaming.ts165
2 files changed, 0 insertions, 377 deletions
diff --git a/packages/misskey-js/test/api.ts b/packages/misskey-js/test/api.ts
deleted file mode 100644
index 47c8378014..0000000000
--- a/packages/misskey-js/test/api.ts
+++ /dev/null
@@ -1,212 +0,0 @@
-import { APIClient, isAPIError } from '../src/api';
-import { enableFetchMocks } from 'jest-fetch-mock';
-
-enableFetchMocks();
-
-function getFetchCall(call: any[]) {
- const { body, method } = call[1];
- if (body != null && typeof body != 'string') {
- throw new Error('invalid body');
- }
- return {
- url: call[0],
- method: method,
- body: JSON.parse(body as any)
- };
-}
-
-describe('API', () => {
- test('success', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- const body = await req.json();
- if (req.method == 'POST' && req.url == 'https://misskey.test/api/i') {
- if (body.i === 'TOKEN') {
- return JSON.stringify({ id: 'foo' });
- } else {
- return { status: 400 };
- }
- } else {
- return { status: 404 };
- }
- });
-
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- const res = await cli.request('i');
-
- expect(res).toEqual({
- id: 'foo'
- });
-
- expect(getFetchCall(fetchMock.mock.calls[0])).toEqual({
- url: 'https://misskey.test/api/i',
- method: 'POST',
- body: { i: 'TOKEN' }
- });
- });
-
- test('with params', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- const body = await req.json();
- if (req.method == 'POST' && req.url == 'https://misskey.test/api/notes/show') {
- if (body.i === 'TOKEN' && body.noteId === 'aaaaa') {
- return JSON.stringify({ id: 'foo' });
- } else {
- return { status: 400 };
- }
- } else {
- return { status: 404 };
- }
- });
-
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- const res = await cli.request('notes/show', { noteId: 'aaaaa' });
-
- expect(res).toEqual({
- id: 'foo'
- });
-
- expect(getFetchCall(fetchMock.mock.calls[0])).toEqual({
- url: 'https://misskey.test/api/notes/show',
- method: 'POST',
- body: { i: 'TOKEN', noteId: 'aaaaa' }
- });
- });
-
- test('204 No Content で null が返る', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- if (req.method == 'POST' && req.url == 'https://misskey.test/api/reset-password') {
- return { status: 204 };
- } else {
- return { status: 404 };
- }
- });
-
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- const res = await cli.request('reset-password', { token: 'aaa', password: 'aaa' });
-
- expect(res).toEqual(null);
-
- expect(getFetchCall(fetchMock.mock.calls[0])).toEqual({
- url: 'https://misskey.test/api/reset-password',
- method: 'POST',
- body: { i: 'TOKEN', token: 'aaa', password: 'aaa' }
- });
- });
-
- test('インスタンスの credential が指定されていても引数で credential が null ならば null としてリクエストされる', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- const body = await req.json();
- if (req.method == 'POST' && req.url == 'https://misskey.test/api/i') {
- if (typeof body.i === 'string') {
- return JSON.stringify({ id: 'foo' });
- } else {
- return {
- status: 401,
- body: JSON.stringify({
- error: {
- message: 'Credential required.',
- code: 'CREDENTIAL_REQUIRED',
- id: '1384574d-a912-4b81-8601-c7b1c4085df1',
- }
- })
- };
- }
- } else {
- return { status: 404 };
- }
- });
-
- try {
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- await cli.request('i', {}, null);
- } catch (e) {
- expect(isAPIError(e)).toEqual(true);
- }
- });
-
- test('api error', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- return {
- status: 500,
- body: JSON.stringify({
- error: {
- message: 'Internal error occurred. Please contact us if the error persists.',
- code: 'INTERNAL_ERROR',
- id: '5d37dbcb-891e-41ca-a3d6-e690c97775ac',
- kind: 'server',
- },
- })
- };
- });
-
- try {
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- await cli.request('i');
- } catch (e: any) {
- expect(isAPIError(e)).toEqual(true);
- expect(e.id).toEqual('5d37dbcb-891e-41ca-a3d6-e690c97775ac');
- }
- });
-
- test('network error', async () => {
- fetchMock.resetMocks();
- fetchMock.mockAbort();
-
- try {
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- await cli.request('i');
- } catch (e) {
- expect(isAPIError(e)).toEqual(false);
- }
- });
-
- test('json parse error', async () => {
- fetchMock.resetMocks();
- fetchMock.mockResponse(async (req) => {
- return {
- status: 500,
- body: '<html>I AM NOT JSON</html>'
- };
- });
-
- try {
- const cli = new APIClient({
- origin: 'https://misskey.test',
- credential: 'TOKEN',
- });
-
- await cli.request('i');
- } catch (e) {
- expect(isAPIError(e)).toEqual(false);
- }
- });
-});
diff --git a/packages/misskey-js/test/streaming.ts b/packages/misskey-js/test/streaming.ts
deleted file mode 100644
index 913db8b287..0000000000
--- a/packages/misskey-js/test/streaming.ts
+++ /dev/null
@@ -1,165 +0,0 @@
-import WS from 'jest-websocket-mock';
-import Stream from '../src/streaming';
-
-describe('Streaming', () => {
- test('useChannel', async () => {
- const server = new WS('wss://misskey.test/streaming');
- const stream = new Stream('https://misskey.test', { token: 'TOKEN' });
- const mainChannelReceived: any[] = [];
- const main = stream.useChannel('main');
- main.on('meUpdated', payload => {
- mainChannelReceived.push(payload);
- });
-
- const ws = await server.connected;
- expect(new URLSearchParams(new URL(ws.url).search).get('i')).toEqual('TOKEN');
-
- const msg = JSON.parse(await server.nextMessage as string);
- const mainChannelId = msg.body.id;
- expect(msg.type).toEqual('connect');
- expect(msg.body.channel).toEqual('main');
- expect(mainChannelId != null).toEqual(true);
-
- server.send(JSON.stringify({
- type: 'channel',
- body: {
- id: mainChannelId,
- type: 'meUpdated',
- body: {
- id: 'foo'
- }
- }
- }));
-
- expect(mainChannelReceived[0]).toEqual({
- id: 'foo'
- });
-
- stream.close();
- server.close();
- });
-
- test('useChannel with parameters', async () => {
- const server = new WS('wss://misskey.test/streaming');
- const stream = new Stream('https://misskey.test', { token: 'TOKEN' });
- const messagingChannelReceived: any[] = [];
- const messaging = stream.useChannel('messaging', { otherparty: 'aaa' });
- messaging.on('message', payload => {
- messagingChannelReceived.push(payload);
- });
-
- const ws = await server.connected;
- expect(new URLSearchParams(new URL(ws.url).search).get('i')).toEqual('TOKEN');
-
- const msg = JSON.parse(await server.nextMessage as string);
- const messagingChannelId = msg.body.id;
- expect(msg.type).toEqual('connect');
- expect(msg.body.channel).toEqual('messaging');
- expect(msg.body.params).toEqual({ otherparty: 'aaa' });
- expect(messagingChannelId != null).toEqual(true);
-
- server.send(JSON.stringify({
- type: 'channel',
- body: {
- id: messagingChannelId,
- type: 'message',
- body: {
- id: 'foo'
- }
- }
- }));
-
- expect(messagingChannelReceived[0]).toEqual({
- id: 'foo'
- });
-
- stream.close();
- server.close();
- });
-
- test('ちゃんとチャンネルごとにidが異なる', async () => {
- const server = new WS('wss://misskey.test/streaming');
- const stream = new Stream('https://misskey.test', { token: 'TOKEN' });
-
- stream.useChannel('messaging', { otherparty: 'aaa' });
- stream.useChannel('messaging', { otherparty: 'bbb' });
-
- const ws = await server.connected;
- expect(new URLSearchParams(new URL(ws.url).search).get('i')).toEqual('TOKEN');
-
- const msg = JSON.parse(await server.nextMessage as string);
- const messagingChannelId = msg.body.id;
- const msg2 = JSON.parse(await server.nextMessage as string);
- const messagingChannelId2 = msg2.body.id;
-
- expect(messagingChannelId != null).toEqual(true);
- expect(messagingChannelId2 != null).toEqual(true);
- expect(messagingChannelId).not.toEqual(messagingChannelId2);
-
- stream.close();
- server.close();
- });
-
- test('Connection#send', async () => {
- const server = new WS('wss://misskey.test/streaming');
- const stream = new Stream('https://misskey.test', { token: 'TOKEN' });
-
- const messaging = stream.useChannel('messaging', { otherparty: 'aaa' });
- messaging.send('read', { id: 'aaa' });
-
- const ws = await server.connected;
- expect(new URLSearchParams(new URL(ws.url).search).get('i')).toEqual('TOKEN');
-
- const connectMsg = JSON.parse(await server.nextMessage as string);
- const channelId = connectMsg.body.id;
- const msg = JSON.parse(await server.nextMessage as string);
-
- expect(msg.type).toEqual('ch');
- expect(msg.body.id).toEqual(channelId);
- expect(msg.body.type).toEqual('read');
- expect(msg.body.body).toEqual({ id: 'aaa' });
-
- stream.close();
- server.close();
- });
-
- test('Connection#dispose', async () => {
- const server = new WS('wss://misskey.test/streaming');
- const stream = new Stream('https://misskey.test', { token: 'TOKEN' });
- const mainChannelReceived: any[] = [];
- const main = stream.useChannel('main');
- main.on('meUpdated', payload => {
- mainChannelReceived.push(payload);
- });
-
- const ws = await server.connected;
- expect(new URLSearchParams(new URL(ws.url).search).get('i')).toEqual('TOKEN');
-
- const msg = JSON.parse(await server.nextMessage as string);
- const mainChannelId = msg.body.id;
- expect(msg.type).toEqual('connect');
- expect(msg.body.channel).toEqual('main');
- expect(mainChannelId != null).toEqual(true);
- main.dispose();
-
- server.send(JSON.stringify({
- type: 'channel',
- body: {
- id: mainChannelId,
- type: 'meUpdated',
- body: {
- id: 'foo'
- }
- }
- }));
-
- expect(mainChannelReceived.length).toEqual(0);
-
- stream.close();
- server.close();
- });
-
- // TODO: SharedConnection#dispose して一定時間経ったら disconnect メッセージがサーバーに送られてくるかのテスト
-
- // TODO: チャンネル接続が使いまわされるかのテスト
-});