blob: 2d00f4919a7bb02a36c35bb444a38c693e042ef3 (
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
|
// SDLProtocolRecievedMessageRouter.m
//
//
// This class gets handed the SDLProtocol messages as they are recieved
// and decides what happens to them and where they are sent on to.
#import "SDLProtocolRecievedMessageRouter.h"
#import "SDLProtocolMessage.h"
#import "SDLProtocolMessageAssembler.h"
#import "SDLDebugTool.h"
@interface SDLProtocolRecievedMessageRouter ()
@property (strong) NSMutableDictionary *messageAssemblers;
- (void)dispatchProtocolMessage:(SDLProtocolMessage *)message;
- (void)dispatchControlMessage:(SDLProtocolMessage *)message;
- (void)dispatchMultiPartMessage:(SDLProtocolMessage *)message;
@end
@implementation SDLProtocolRecievedMessageRouter
- (id)init {
if (self = [super init]) {
self.messageAssemblers = [NSMutableDictionary dictionaryWithCapacity:2];
}
return self;
}
- (void)handleRecievedMessage:(SDLProtocolMessage *)message {
SDLFrameType frameType = message.header.frameType;
switch (frameType) {
case SDLFrameType_Single:
[self dispatchProtocolMessage:message];
break;
case SDLFrameType_Control:
[self dispatchControlMessage:message];
break;
case SDLFrameType_First:
case SDLFrameType_Consecutive:
[self dispatchMultiPartMessage:message];
break;
default:
break;
}
}
- (void)dispatchProtocolMessage:(SDLProtocolMessage *)message {
[self.delegate onProtocolMessageReceived:message];
}
- (void)dispatchControlMessage:(SDLProtocolMessage *)message {
if (message.header.frameData == SDLFrameData_StartSessionACK) {
[self.delegate handleProtocolSessionStarted:message.header.serviceType
sessionID:message.header.sessionID
version:message.header.version];
}
}
- (void)dispatchMultiPartMessage:(SDLProtocolMessage *)message {
// 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 dispatchProtocolMessage:assembledMessage];
}
};
[assembler handleMessage:message withCompletionHandler:completionHandler];
}
@end
|
