blob: fc00487363da445653e7a5bf98f7ec16f7d383c5 (
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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
|
//
// SDLVoiceCommandManager.m
// SmartDeviceLink
//
// Created by Joel Fischer on 4/23/18.
// Copyright © 2018 smartdevicelink. All rights reserved.
//
#import "SDLVoiceCommandManager.h"
#import "SDLAddCommand.h"
#import "SDLConnectionManagerType.h"
#import "SDLDeleteCommand.h"
#import "SDLError.h"
#import "SDLHMILevel.h"
#import "SDLLogMacros.h"
#import "SDLNotificationConstants.h"
#import "SDLOnCommand.h"
#import "SDLOnHMIStatus.h"
#import "SDLPredefinedWindows.h"
#import "SDLRPCNotificationNotification.h"
#import "SDLRPCRequest.h"
#import "SDLVoiceCommand.h"
#import "SDLVoiceCommandUpdateOperation.h"
NS_ASSUME_NONNULL_BEGIN
@interface SDLVoiceCommand()
@property (assign, nonatomic) UInt32 commandId;
@end
@interface SDLVoiceCommandManager()
@property (weak, nonatomic) id<SDLConnectionManagerType> connectionManager;
@property (strong, nonatomic) NSOperationQueue *transactionQueue;
@property (copy, nonatomic, nullable) SDLHMILevel currentLevel;
@property (assign, nonatomic) UInt32 lastVoiceCommandId;
@property (copy, nonatomic) NSArray<SDLVoiceCommand *> *currentVoiceCommands;
@end
UInt32 const VoiceCommandIdMin = 1900000000;
@implementation SDLVoiceCommandManager
- (instancetype)init {
self = [super init];
if (!self) { return nil; }
_lastVoiceCommandId = VoiceCommandIdMin;
_transactionQueue = [self sdl_newTransactionQueue];
_voiceCommands = @[];
_currentVoiceCommands = @[];
[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(sdl_hmiStatusNotification:) name:SDLDidChangeHMIStatusNotification object:nil];
[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(sdl_commandNotification:) name:SDLDidReceiveCommandNotification object:nil];
return self;
}
- (instancetype)initWithConnectionManager:(id<SDLConnectionManagerType>)connectionManager {
self = [self init];
if (!self) { return nil; }
_connectionManager = connectionManager;
return self;
}
- (void)stop {
_lastVoiceCommandId = VoiceCommandIdMin;
_voiceCommands = @[];
_currentVoiceCommands = @[];
_transactionQueue = [self sdl_newTransactionQueue];
_currentLevel = nil;
}
- (NSOperationQueue *)sdl_newTransactionQueue {
NSOperationQueue *queue = [[NSOperationQueue alloc] init];
queue.name = @"SDLVoiceCommandManager Transaction Queue";
queue.maxConcurrentOperationCount = 1;
queue.qualityOfService = NSQualityOfServiceUserInitiated;
queue.suspended = YES;
return queue;
}
/// Suspend the queue if the HMI level is NONE since we want to delay sending RPCs until we're in non-NONE
- (void)sdl_updateTransactionQueueSuspended {
if ([self.currentLevel isEqualToEnum:SDLHMILevelNone]) {
SDLLogD(@"Suspending the transaction queue. Current HMI level is NONE: %@", ([self.currentLevel isEqualToEnum:SDLHMILevelNone] ? @"YES" : @"NO"));
self.transactionQueue.suspended = YES;
} else {
SDLLogD(@"Starting the transaction queue");
self.transactionQueue.suspended = NO;
}
}
#pragma mark - Setters
- (void)setVoiceCommands:(NSArray<SDLVoiceCommand *> *)voiceCommands {
if (voiceCommands == self.voiceCommands) {
SDLLogD(@"New voice commands are equal to the existing voice commands, skipping...");
return;
}
// Set the ids
[self sdl_updateIdsOnVoiceCommands:voiceCommands];
// Set the new voice commands internally
_voiceCommands = voiceCommands;
// Create the operation, cancel previous ones and set this one
__weak typeof(self) weakSelf = self;
SDLVoiceCommandUpdateOperation *updateOperation = [[SDLVoiceCommandUpdateOperation alloc] initWithConnectionManager:self.connectionManager pendingVoiceCommands:voiceCommands oldVoiceCommands:_currentVoiceCommands updateCompletionHandler:^(NSArray<SDLVoiceCommand *> *newCurrentVoiceCommands, NSError * _Nullable error) {
weakSelf.currentVoiceCommands = newCurrentVoiceCommands;
[weakSelf sdl_updatePendingOperationsWithNewCurrentVoiceCommands:newCurrentVoiceCommands];
}];
[self.transactionQueue cancelAllOperations];
[self.transactionQueue addOperation:updateOperation];
}
/// Update currently pending operations with a new set of "current" voice commands (the current state of the head unit) based on a previous completed operation
/// @param currentVoiceCommands The new current voice commands
- (void)sdl_updatePendingOperationsWithNewCurrentVoiceCommands:(NSArray<SDLVoiceCommand *> *)currentVoiceCommands {
for (NSOperation *operation in self.transactionQueue.operations) {
if (operation.isExecuting) { continue; }
SDLVoiceCommandUpdateOperation *updateOp = (SDLVoiceCommandUpdateOperation *)operation;
updateOp.oldVoiceCommands = currentVoiceCommands;
}
}
#pragma mark - Helpers
#pragma mark IDs
- (void)sdl_updateIdsOnVoiceCommands:(NSArray<SDLVoiceCommand *> *)voiceCommands {
for (SDLVoiceCommand *voiceCommand in voiceCommands) {
voiceCommand.commandId = self.lastVoiceCommandId++;
}
}
#pragma mark - Observers
- (void)sdl_commandNotification:(SDLRPCNotificationNotification *)notification {
SDLOnCommand *onCommand = (SDLOnCommand *)notification.notification;
for (SDLVoiceCommand *voiceCommand in self.voiceCommands) {
if (onCommand.cmdID.unsignedIntegerValue != voiceCommand.commandId) { continue; }
voiceCommand.handler();
break;
}
}
- (void)sdl_hmiStatusNotification:(SDLRPCNotificationNotification *)notification {
SDLOnHMIStatus *hmiStatus = (SDLOnHMIStatus *)notification.notification;
if (hmiStatus.windowID != nil && hmiStatus.windowID.integerValue != SDLPredefinedWindowsDefaultWindow) {
return;
}
self.currentLevel = hmiStatus.hmiLevel;
[self sdl_updateTransactionQueueSuspended];
}
@end
NS_ASSUME_NONNULL_END
|
