Skip to content

Commit 6b28610

Browse files
streamichstreamich
committed
style(reactive-rpc): 💄 run Prettier
1 parent 5e11985 commit 6b28610

File tree

4 files changed

+67
-100
lines changed

4 files changed

+67
-100
lines changed

‎src/reactive-rpc/common/testing/buildE2eClient.ts‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,5 +130,5 @@ type UnTypeRouter<T> = T extends TypeRouter<infer R> ? R : never;
130130
type UnwrapFunction<F> = F extends FunctionType<infer Req, infer Res>
131131
? (req: ResolveType<Req>) => Promise<ResolveType<Res>>
132132
: F extends FunctionStreamingType<infer Req, infer Res>
133-
? (req$: Observable<ResolveType<Req>>) => Observable<ResolveType<Res>>
134-
: never;
133+
? (req$: Observable<ResolveType<Req>>) => Observable<ResolveType<Res>>
134+
: never;

‎src/server/__tests__/blocks.spec.ts‎

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ describe('blocks.*', () => {
99
test('can create an empty block', async () => {
1010
const {call} = setup();
1111
await call('blocks.create', {id: 'my-block', patches: []});
12-
const {block} = (await call('blocks.get', {id: 'my-block'}));
12+
const {block} = await call('blocks.get', {id: 'my-block'});
1313
expect(block).toMatchObject({
1414
id: 'my-block',
1515
seq: -1,
@@ -295,7 +295,10 @@ describe('blocks.*', () => {
295295
const patch1 = model.api.flush();
296296
await tick(12);
297297
expect(emits.length).toBe(0);
298-
await client.call('blocks.edit', {id: 'my-block', patches: [{seq: 0, created: Date.now(), blob: patch1.toBinary()}]});
298+
await client.call('blocks.edit', {
299+
id: 'my-block',
300+
patches: [{seq: 0, created: Date.now(), blob: patch1.toBinary()}],
301+
});
299302
await until(() => emits.length === 1);
300303
expect(emits.length).toBe(1);
301304
expect(emits[0].patches.length).toBe(1);
@@ -306,7 +309,10 @@ describe('blocks.*', () => {
306309
const patch2 = model.api.flush();
307310
await tick(12);
308311
expect(emits.length).toBe(1);
309-
await client.call('blocks.edit', {id: 'my-block', patches: [{seq: 1, created: Date.now(), blob: patch2.toBinary()}]});
312+
await client.call('blocks.edit', {
313+
id: 'my-block',
314+
patches: [{seq: 1, created: Date.now(), blob: patch2.toBinary()}],
315+
});
310316
await until(() => emits.length === 2);
311317
expect(emits.length).toBe(2);
312318
expect(emits[1].patches.length).toBe(1);

‎src/server/__tests__/presence.spec.ts‎

Lines changed: 24 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -8,16 +8,13 @@ describe('presence', () => {
88
call$('presence.listen', {room: 'my-room'}).subscribe((res) => {
99
emits.push(res);
1010
});
11-
await call(
12-
'presence.update',
13-
{
14-
room: 'my-room',
15-
id: 'user-1',
16-
data: {
17-
hello: 'world',
18-
},
11+
await call('presence.update', {
12+
room: 'my-room',
13+
id: 'user-1',
14+
data: {
15+
hello: 'world',
1916
},
20-
);
17+
});
2118
await until(() => emits.length === 1);
2219
expect(emits[0]).toMatchObject({
2320
time: expect.any(Number),
@@ -40,16 +37,13 @@ describe('presence', () => {
4037
call$('presence.listen', {room: 'my-room'}).subscribe((res) => {
4138
emits.push(res);
4239
});
43-
await call(
44-
'presence.update',
45-
{
46-
room: 'my-room',
47-
id: 'user-1',
48-
data: {
49-
hello: 'world',
50-
},
40+
await call('presence.update', {
41+
room: 'my-room',
42+
id: 'user-1',
43+
data: {
44+
hello: 'world',
5145
},
52-
);
46+
});
5347
await until(() => emits.length === 1);
5448
const emits2: any[] = [];
5549
call$('presence.listen', {room: 'my-room'}).subscribe((res) => {
@@ -77,16 +71,13 @@ describe('presence', () => {
7771
call$('presence.listen', {room: 'my-room'}).subscribe((res) => {
7872
emits.push(res);
7973
});
80-
await call(
81-
'presence.update',
82-
{
83-
room: 'my-room',
84-
id: 'user-1',
85-
data: {
86-
hello: 'world',
87-
},
74+
await call('presence.update', {
75+
room: 'my-room',
76+
id: 'user-1',
77+
data: {
78+
hello: 'world',
8879
},
89-
);
80+
});
9081
await until(() => emits.length === 1);
9182
await call('presence.remove', {room: 'my-room', id: 'user-1'});
9283
await until(() => emits.length === 2);
@@ -100,16 +91,13 @@ describe('presence', () => {
10091

10192
test('emits entry deletion messages', async () => {
10293
const {call, call$} = setup();
103-
await call(
104-
'presence.update',
105-
{
106-
room: 'my-room',
107-
id: 'user-1',
108-
data: {
109-
hello: 'world',
110-
},
94+
await call('presence.update', {
95+
room: 'my-room',
96+
id: 'user-1',
97+
data: {
98+
hello: 'world',
11199
},
112-
);
100+
});
113101
const emits: any[] = [];
114102
call$('presence.listen', {room: 'my-room'}).subscribe((res) => {
115103
emits.push(res);

‎src/server/__tests__/pubsub.spec.ts‎

Lines changed: 32 additions & 59 deletions
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,10 @@ describe('pubsub', () => {
2121
call$('pubsub.listen', {channel: 'my-channel'}).subscribe((res) => {
2222
emits.push(res.message);
2323
});
24-
await call(
25-
'pubsub.publish',
26-
{
27-
channel: 'my-channel',
28-
message: 'hello world',
29-
},
30-
);
24+
await call('pubsub.publish', {
25+
channel: 'my-channel',
26+
message: 'hello world',
27+
});
3128
await until(() => emits.length === 1);
3229
expect(emits).toStrictEqual(['hello world']);
3330
});
@@ -38,30 +35,21 @@ describe('pubsub', () => {
3835
const sub = call$('pubsub.listen', {channel: 'my-channel'}).subscribe((res) => {
3936
emits.push(res.message);
4037
});
41-
await call(
42-
'pubsub.publish',
43-
{
44-
channel: 'my-channel',
45-
message: 'msg1',
46-
},
47-
);
48-
await call(
49-
'pubsub.publish',
50-
{
51-
channel: 'my-channel',
52-
message: 'msg2',
53-
},
54-
);
38+
await call('pubsub.publish', {
39+
channel: 'my-channel',
40+
message: 'msg1',
41+
});
42+
await call('pubsub.publish', {
43+
channel: 'my-channel',
44+
message: 'msg2',
45+
});
5546
await until(() => emits.length === 2);
5647
sub.unsubscribe();
5748
await tick(25);
58-
await call(
59-
'pubsub.publish',
60-
{
61-
channel: 'my-channel',
62-
message: 'msg3',
63-
},
64-
);
49+
await call('pubsub.publish', {
50+
channel: 'my-channel',
51+
message: 'msg3',
52+
});
6553
await tick(50);
6654
expect(emits.indexOf('msg1') > -1).toBe(true);
6755
expect(emits.indexOf('msg2') > -1).toBe(true);
@@ -84,33 +72,22 @@ describe('pubsub', () => {
8472
call$('pubsub.listen', {channel: 'channel-2'}).subscribe((res) => {
8573
user3.push(res.message);
8674
});
87-
await call(
88-
'pubsub.publish',
89-
{
90-
channel: 'my-channel',
91-
message: 'hello world',
92-
},
93-
);
75+
await call('pubsub.publish', {
76+
channel: 'my-channel',
77+
message: 'hello world',
78+
});
9479
await tick(50);
9580
expect(user1).toStrictEqual([]);
9681
expect(user2).toStrictEqual([]);
9782
expect(user3).toStrictEqual([]);
98-
call(
99-
'pubsub.publish',
100-
{
101-
channel: 'channel-1',
102-
message: 'msg1',
103-
},
104-
)
105-
.catch(() => {});
106-
call(
107-
'pubsub.publish',
108-
{
109-
channel: 'channel-2',
110-
message: 'msg2',
111-
},
112-
)
113-
.catch(() => {});
83+
call('pubsub.publish', {
84+
channel: 'channel-1',
85+
message: 'msg1',
86+
}).catch(() => {});
87+
call('pubsub.publish', {
88+
channel: 'channel-2',
89+
message: 'msg2',
90+
}).catch(() => {});
11491
await until(() => user1.length === 1);
11592
await until(() => user2.length === 1);
11693
await until(() => user3.length === 2);
@@ -119,14 +96,10 @@ describe('pubsub', () => {
11996
expect(user3.indexOf('msg1') > -1).toBe(true);
12097
expect(user3.indexOf('msg2') > -1).toBe(true);
12198
sub2.unsubscribe();
122-
call(
123-
'pubsub.publish',
124-
{
125-
channel: 'channel-2',
126-
message: 'msg3',
127-
},
128-
)
129-
.catch(() => {});
99+
call('pubsub.publish', {
100+
channel: 'channel-2',
101+
message: 'msg3',
102+
}).catch(() => {});
130103
await until(() => user3.length === 3);
131104
expect(user1).toStrictEqual(['msg1']);
132105
expect(user2).toStrictEqual(['msg2']);

0 commit comments

Comments
 (0)