|
5 | 5 | // Created by Guilherme Souza on 26/06/24. |
6 | 6 | // |
7 | 7 |
|
8 | | -@testable import Realtime |
9 | 8 | import XCTest |
10 | 9 |
|
| 10 | +@testable import Realtime |
| 11 | + |
11 | 12 | final class RealtimeMessageV2Tests: XCTestCase { |
12 | 13 | func testStatus() { |
13 | | - var message = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "ok"]) |
| 14 | + var message = RealtimeMessageV2( |
| 15 | + joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "ok"]) |
14 | 16 | XCTAssertEqual(message.status, .ok) |
15 | 17 |
|
16 | | - message = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "timeout"]) |
| 18 | + message = RealtimeMessageV2( |
| 19 | + joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "timeout"]) |
17 | 20 | XCTAssertEqual(message.status, .timeout) |
18 | 21 |
|
19 | | - message = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "error"]) |
| 22 | + message = RealtimeMessageV2( |
| 23 | + joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "error"]) |
20 | 24 | XCTAssertEqual(message.status, .error) |
21 | 25 |
|
22 | | - message = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "invalid"]) |
| 26 | + message = RealtimeMessageV2( |
| 27 | + joinRef: nil, ref: nil, topic: "heartbeat", event: "event", payload: ["status": "invalid"]) |
23 | 28 | XCTAssertNil(message.status) |
24 | 29 | } |
25 | 30 |
|
26 | 31 | func testEventType() { |
27 | | - let payloadWithTokenExpiredMessage: JSONObject = ["message": "access token has expired"] |
28 | 32 | let payloadWithStatusOK: JSONObject = ["status": "ok"] |
29 | 33 | let payloadWithNoStatus: JSONObject = [:] |
30 | 34 |
|
31 | | - let systemEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.system, payload: payloadWithStatusOK) |
32 | | - let postgresChangesEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.postgresChanges, payload: payloadWithNoStatus) |
33 | | - let tokenExpiredEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.system, payload: payloadWithTokenExpiredMessage) |
| 35 | + let systemEventMessage = RealtimeMessageV2( |
| 36 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.system, |
| 37 | + payload: payloadWithStatusOK) |
| 38 | + let postgresChangesEventMessage = RealtimeMessageV2( |
| 39 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.postgresChanges, |
| 40 | + payload: payloadWithNoStatus) |
34 | 41 |
|
35 | | - XCTAssertEqual(systemEventMessage.eventType, .system) |
36 | | - XCTAssertEqual(postgresChangesEventMessage.eventType, .postgresChanges) |
37 | | - XCTAssertEqual(tokenExpiredEventMessage.eventType, .tokenExpired) |
| 42 | + XCTAssertEqual(systemEventMessage._eventType, .system) |
| 43 | + XCTAssertEqual(postgresChangesEventMessage._eventType, .postgresChanges) |
38 | 44 |
|
39 | | - let broadcastEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.broadcast, payload: payloadWithNoStatus) |
40 | | - XCTAssertEqual(broadcastEventMessage.eventType, .broadcast) |
| 45 | + let broadcastEventMessage = RealtimeMessageV2( |
| 46 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.broadcast, |
| 47 | + payload: payloadWithNoStatus) |
| 48 | + XCTAssertEqual(broadcastEventMessage._eventType, .broadcast) |
41 | 49 |
|
42 | | - let closeEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.close, payload: payloadWithNoStatus) |
43 | | - XCTAssertEqual(closeEventMessage.eventType, .close) |
| 50 | + let closeEventMessage = RealtimeMessageV2( |
| 51 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.close, |
| 52 | + payload: payloadWithNoStatus) |
| 53 | + XCTAssertEqual(closeEventMessage._eventType, .close) |
44 | 54 |
|
45 | | - let errorEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.error, payload: payloadWithNoStatus) |
46 | | - XCTAssertEqual(errorEventMessage.eventType, .error) |
| 55 | + let errorEventMessage = RealtimeMessageV2( |
| 56 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.error, |
| 57 | + payload: payloadWithNoStatus) |
| 58 | + XCTAssertEqual(errorEventMessage._eventType, .error) |
47 | 59 |
|
48 | | - let presenceDiffEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.presenceDiff, payload: payloadWithNoStatus) |
49 | | - XCTAssertEqual(presenceDiffEventMessage.eventType, .presenceDiff) |
| 60 | + let presenceDiffEventMessage = RealtimeMessageV2( |
| 61 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.presenceDiff, |
| 62 | + payload: payloadWithNoStatus) |
| 63 | + XCTAssertEqual(presenceDiffEventMessage._eventType, .presenceDiff) |
50 | 64 |
|
51 | | - let presenceStateEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.presenceState, payload: payloadWithNoStatus) |
52 | | - XCTAssertEqual(presenceStateEventMessage.eventType, .presenceState) |
| 65 | + let presenceStateEventMessage = RealtimeMessageV2( |
| 66 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.presenceState, |
| 67 | + payload: payloadWithNoStatus) |
| 68 | + XCTAssertEqual(presenceStateEventMessage._eventType, .presenceState) |
53 | 69 |
|
54 | | - let replyEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.reply, payload: payloadWithNoStatus) |
55 | | - XCTAssertEqual(replyEventMessage.eventType, .reply) |
| 70 | + let replyEventMessage = RealtimeMessageV2( |
| 71 | + joinRef: nil, ref: nil, topic: "topic", event: ChannelEvent.reply, |
| 72 | + payload: payloadWithNoStatus) |
| 73 | + XCTAssertEqual(replyEventMessage._eventType, .reply) |
56 | 74 |
|
57 | | - let unknownEventMessage = RealtimeMessageV2(joinRef: nil, ref: nil, topic: "topic", event: "unknown_event", payload: payloadWithNoStatus) |
58 | | - XCTAssertNil(unknownEventMessage.eventType) |
| 75 | + let unknownEventMessage = RealtimeMessageV2( |
| 76 | + joinRef: nil, ref: nil, topic: "topic", event: "unknown_event", payload: payloadWithNoStatus) |
| 77 | + XCTAssertNil(unknownEventMessage._eventType) |
59 | 78 | } |
60 | 79 | } |
0 commit comments