blob: 0aee96929278aebe9e9b4adf239a040ae7c1ea1a [file] [log] [blame]
/*
*
* Copyright (c) 2021 Project CHIP Authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#import "MTRBaseDevice.h"
#import "MTRCluster_internal.h"
#import "NSDataSpanConversion.h"
#import "NSStringSpanConversion.h"
using namespace ::chip;
@implementation MTRCluster
- (instancetype)initWithQueue:(dispatch_queue_t)queue
{
if (self = [super init]) {
_callbackQueue = queue;
}
return self;
}
- (chip::ByteSpan)asByteSpan:(NSData *)value
{
return AsByteSpan(value);
}
- (chip::CharSpan)asCharSpan:(NSString *)value
{
return AsCharSpan(value);
}
@end
@implementation MTRWriteParams
- (instancetype)init
{
if (self = [super init]) {
_timedWriteTimeout = nil;
}
return self;
}
- (id)copyWithZone:(NSZone * _Nullable)zone
{
auto other = [[MTRWriteParams alloc] init];
other.timedWriteTimeout = self.timedWriteTimeout;
other.dataVersion = self.dataVersion;
return other;
}
@end
@implementation MTRReadParams
- (instancetype)init
{
if (self = [super init]) {
_filterByFabric = YES;
}
return self;
}
- (id)copyWithZone:(NSZone * _Nullable)zone
{
auto other = [[MTRReadParams alloc] init];
other.filterByFabric = self.filterByFabric;
return other;
}
- (void)toReadPrepareParams:(chip::app::ReadPrepareParams &)readPrepareParams
{
readPrepareParams.mIsFabricFiltered = self.filterByFabric;
}
@end
@implementation MTRSubscribeParams
- (instancetype)initWithMinInterval:(NSNumber *)minInterval maxInterval:(NSNumber *)maxInterval
{
if (self = [super init]) {
_replaceExistingSubscriptions = YES;
_resubscribeIfLost = YES;
_minInterval = [minInterval copy];
_maxInterval = [maxInterval copy];
}
return self;
}
- (id)copyWithZone:(NSZone * _Nullable)zone
{
auto other = [[MTRSubscribeParams alloc] initWithMinInterval:self.minInterval maxInterval:self.maxInterval];
other.filterByFabric = self.filterByFabric;
other.replaceExistingSubscriptions = self.replaceExistingSubscriptions;
other.resubscribeIfLost = self.resubscribeIfLost;
return other;
}
- (void)toReadPrepareParams:(chip::app::ReadPrepareParams &)readPrepareParams
{
[super toReadPrepareParams:readPrepareParams];
readPrepareParams.mMinIntervalFloorSeconds = self.minInterval.unsignedShortValue;
readPrepareParams.mMaxIntervalCeilingSeconds = self.maxInterval.unsignedShortValue;
readPrepareParams.mKeepSubscriptions = !self.replaceExistingSubscriptions;
}
@end
@implementation MTRReadParams (Deprecated)
- (void)setFabricFiltered:(nullable NSNumber *)fabricFiltered
{
if (fabricFiltered == nil) {
self.filterByFabric = YES;
} else {
self.filterByFabric = [fabricFiltered boolValue];
}
}
- (nullable NSNumber *)fabricFiltered
{
return @(self.filterByFabric);
}
@end
@implementation MTRSubscribeParams (Deprecated)
- (instancetype)init
{
if (self = [super init]) {
_replaceExistingSubscriptions = YES;
_resubscribeIfLost = YES;
_minInterval = @(1);
_maxInterval = @(0);
}
return self;
}
+ (instancetype)new
{
return [[self alloc] init];
}
- (void)setKeepPreviousSubscriptions:(nullable NSNumber *)keepPreviousSubscriptions
{
if (keepPreviousSubscriptions == nil) {
self.replaceExistingSubscriptions = YES;
} else {
self.replaceExistingSubscriptions = ![keepPreviousSubscriptions boolValue];
}
}
- (nullable NSNumber *)keepPreviousSubscriptions
{
return @(!self.replaceExistingSubscriptions);
}
- (void)setAutoResubscribe:(nullable NSNumber *)autoResubscribe
{
if (autoResubscribe == nil) {
self.resubscribeIfLost = YES;
} else {
self.resubscribeIfLost = [autoResubscribe boolValue];
}
}
- (nullable NSNumber *)autoResubscribe
{
return @(self.resubscribeIfLost);
}
@end