blob: 6c51f00797c61ef53d17fa3e59e3ebd3400decba (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
// SDLProtocolReceivedMessageRouter.m
//
// This class gets handed the SDLProtocol messages as they are received and decides what happens to them and where they are sent on to.
#import "SDLProtocolReceivedMessageRouter.h"
#import "SDLLogMacros.h"
#import "SDLProtocolMessage.h"
#import "SDLProtocolMessageAssembler.h"
NS_ASSUME_NONNULL_BEGIN
@interface SDLProtocolReceivedMessageRouter ()
@property (strong, nonatomic) NSMutableDictionary<NSNumber *, SDLProtocolMessageAssembler *> *messageAssemblers;
@end
@implementation SDLProtocolReceivedMessageRouter
- (instancetype)init {
if (self = [super init]) {
self.messageAssemblers = [NSMutableDictionary dictionaryWithCapacity:2];
}
return self;
}
- (void)handleReceivedMessage:(SDLProtocolMessage *)message protocol:(SDLProtocol *)protocol {
SDLFrameType frameType = message.header.frameType;
switch (frameType) {
case SDLFrameTypeSingle: {
[self sdl_dispatchProtocolMessage:message protocol:protocol];
} break;
case SDLFrameTypeControl: {
[self sdl_dispatchControlMessage:message protocol:protocol];
} break;
case SDLFrameTypeFirst: // fallthrough
case SDLFrameTypeConsecutive: {
[self sdl_dispatchMultiPartMessage:message protocol:protocol];
} break;
default: break;
}
}
- (void)sdl_dispatchProtocolMessage:(SDLProtocolMessage *)message protocol:(SDLProtocol *)protocol {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveMessage:)]) {
[self.delegate protocol:protocol didReceiveMessage:message];
}
}
- (void)sdl_dispatchControlMessage:(SDLProtocolMessage *)message protocol:(SDLProtocol *)protocol {
switch (message.header.frameData) {
case SDLFrameInfoStartServiceACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveStartServiceACK:)]) {
[self.delegate protocol:protocol didReceiveStartServiceACK:message];
}
} break;
case SDLFrameInfoStartServiceNACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveStartServiceNAK:)]) {
[self.delegate protocol:protocol didReceiveStartServiceNAK:message];
}
} break;
case SDLFrameInfoEndServiceACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveEndServiceACK:)]) {
[self.delegate protocol:protocol didReceiveEndServiceACK:message];
}
} break;
case SDLFrameInfoEndServiceNACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveEndServiceNAK:)]) {
[self.delegate protocol:protocol didReceiveEndServiceNAK:message];
}
} break;
case SDLFrameInfoRegisterSecondaryTransportACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveRegisterSecondaryTransportACK:)]) {
[self.delegate protocol:protocol didReceiveRegisterSecondaryTransportACK:message];
}
} break;
case SDLFrameInfoRegisterSecondaryTransportNACK: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveRegisterSecondaryTransportNAK:)]) {
[self.delegate protocol:protocol didReceiveRegisterSecondaryTransportNAK:message];
}
} break;
case SDLFrameInfoHeartbeat: {
if ([self.delegate respondsToSelector:@selector(handleHeartbeatForSession:)]) {
[self.delegate handleHeartbeatForSession:message.header.sessionID];
}
} break;
case SDLFrameInfoHeartbeatACK: {
if ([self.delegate respondsToSelector:@selector(handleHeartbeatACK)]) {
[self.delegate handleHeartbeatACK];
}
} break;
case SDLFrameInfoTransportEventUpdate: {
if ([self.delegate respondsToSelector:@selector(protocol:didReceiveTransportEventUpdate:)]) {
[self.delegate protocol:protocol didReceiveTransportEventUpdate:message];
}
} break;
default: break; // Other frame data is possible, but we don't care about them
}
}
- (void)sdl_dispatchMultiPartMessage:(SDLProtocolMessage *)message protocol:(SDLProtocol *)protocol {
// Pass multipart messages to an assembler and call delegate when done.
NSNumber *sessionID = [NSNumber numberWithUnsignedChar:message.header.sessionID];
SDLProtocolMessageAssembler *assembler = self.messageAssemblers[sessionID];
if (assembler == nil) {
assembler = [[SDLProtocolMessageAssembler alloc] initWithSessionID:message.header.sessionID];
self.messageAssemblers[sessionID] = assembler;
}
SDLMessageAssemblyCompletionHandler completionHandler = ^void(BOOL done, SDLProtocolMessage *assembledMessage) {
if (done) {
[self sdl_dispatchProtocolMessage:assembledMessage protocol:protocol];
}
};
[assembler handleMessage:message withCompletionHandler:completionHandler];
}
@end
NS_ASSUME_NONNULL_END
|
