PrivateBoxiOS/创维盒子/双子星云手机/connectDeviceManager/connectDeviceManager.m

//
//  connectDeviceManager.m
//  隐私保护
//
//  Created by xd h on 2023/10/9.
//

//第三方  瑞云 的链接服务
#import "connectDeviceManager.h"

#import <RayProxy/RaylinkProxy.h>
#import <CocoaAsyncSocket/GCDAsyncSocket.h>

#import "WHPingTester.h"
#import "RSATool.h"

@interface connectDeviceManager ()<
GCDAsyncSocketDelegate,
RaylinkProxyDelegate,
WHPingDelegate
>
{
    dispatch_queue_t initProxyQueue;
    
    WHPingTester *whPingTester;
}

@property (nonatomic, strong) NSTimer *connectCheckTimer;

@property (nonatomic, strong) GCDAsyncSocket *socket;

@property (nonatomic, strong) GCDAsyncSocket *serverSocket;

@property (nonatomic, assign) BOOL sdnConnected;
@property (nonatomic, assign) BOOL peerConnected;

@property (nonatomic, assign) NSInteger tcpPort;


@end

@implementation connectDeviceManager
static connectDeviceManager *connectDeviceManagerInstance = nil;
+(connectDeviceManager *)shareInstance;
{
    static dispatch_once_t onceToken;
    
    dispatch_once(&onceToken, ^{
        connectDeviceManagerInstance = [[connectDeviceManager alloc] init];
        connectDeviceManagerInstance.curConnectDeviceState = DeviceConnectUnknown;
    });
    
    return connectDeviceManagerInstance;
}


#pragma mark 根据扫码的sn获取第三方信息
-(void)getThridMsgBySN:(NSString*)snStr needReconnect:(BOOL)needReconnect didNetEnd:(netWork_DidEndByOK)didNetEndIsOK
{
    if(needReconnect){
        _curConnectDeviceState = DeviceConnectGetThridMsging;
    }
    
    NSMutableDictionary *paraDict = [NSMutableDictionary new];
    [paraDict setValue:snStr forKey:@"sn"];
    
    KWeakSelf
    [[netWorkManager shareInstance] CommonGetWithCallBackCode:getThirdIdBySn Parameters:paraDict success:^(id  _Nonnull responseObject) {
        
        DeviceThirdIdModel *model = [[DeviceThirdIdModel alloc] initWithDictionary:responseObject error:nil];

        if(model && model.data){
            weakSelf.DeviceThirdIdMod = model;
        }
       
        if(weakSelf.DeviceThirdIdMod.status == 0
           && weakSelf.DeviceThirdIdMod.data)
        {
            
            NSString*desPwdstr = [RSATool AES128Decrypt:weakSelf.DeviceThirdIdMod.data.password key:AESCODEKEEYY];
            
            didNetEndIsOK(YES);
            
            /*密码保持在本地*/
            NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
            NSMutableDictionary *dict = [[NSMutableDictionary alloc] initWithDictionary:deviceDict];
            [dict setObject:desPwdstr forKey:Const_Have_Add_Device_PWD];
            [HWDataManager setObjectWithKey:Const_Have_Add_Device value:dict];
            
            //
            bool connected = [RaylinkProxy.sharedManager isSdnConnected];
            if(!connected || needReconnect){
                weakSelf.curConnectDeviceState = DeviceConnectGetThridOK;
//                NSString *ipStr = weakSelf.DeviceThirdIdMod.data.ip;
//                [weakSelf startPingDeviceIp:ipStr];
                [weakSelf initRuiyunSDKFun];
            }
            
        }
        else{
            didNetEndIsOK(NO);
        }
        
        
    } failure:^(NSError * _Nonnull error) {
        HLog("网络报错");
        didNetEndIsOK(NO);
    }];
}

#pragma mark 初始化瑞云的SDK等
- (void)initRuiyunSDKFun{
   
    [self disconnect];
        
    self.sdnConnected = NO;
    self.peerConnected = NO;
    
    //self.sendBtn.enabled = NO;
    
    //self.sdnConnectStateLab.text = @"SDN state: Connectting";
    //self.sdnIDLab.text = @"My SDN ID:";
    
    RaylinkProxy.sharedManager.delegate = self;
    
    initProxyQueue = dispatch_queue_create("init_proxy", 0);
    
    NSURL *logUrl = [[NSFileManager.defaultManager URLsForDirectory:NSDocumentDirectory inDomains:NSUserDomainMask].firstObject URLByAppendingPathComponent:@"logs"];
    
    if (![NSFileManager.defaultManager fileExistsAtPath:logUrl.path]) {
        [NSFileManager.defaultManager createDirectoryAtURL:logUrl withIntermediateDirectories:YES attributes:NULL error:NULL];
    }
    
    dispatch_async(initProxyQueue, ^{
        NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
        
        /// 1. 初始化代理库
        [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
    });
    
    
    /// 作为服务端时，启动端口监听
    self.serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
    
    if ([self.serverSocket acceptOnPort:0 error:NULL]) {
        //self.serverPortLab.text = [NSString stringWithFormat: @"server port: %d", self.serverSocket.localPort];
        NSLog(@"accept ok %d",self.serverSocket.localPort);
    }
    
    
    /// 启动定时器监听 SND 连接状态
    self.connectCheckTimer = [NSTimer scheduledTimerWithTimeInterval:0.5 repeats:YES block:^(NSTimer * _Nonnull timer) {
        
        /// 2. 监听SDN 连接状态
        bool connected = [RaylinkProxy.sharedManager isSdnConnected];
        if (self.sdnConnected == connected) {
            return;
        }
        
        self.sdnConnected = connected;
        
        if (self.sdnConnected) {
            
            //self.sdnConnectStateLab.text = @"SDN state: Connected";
            //self.sdnIDLab.text = [@"My SDN ID: " stringByAppendingString:[RaylinkProxy.sharedManager getSdnId]];
            
                
        } else {
            //self.sdnConnectStateLab.text = @"SDN state: Connectting";
        }
        
        
    }];
    
    
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2.0 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        mainBlock(^{
            [self onConnectFun];
        });
    });
}


- (void)onConnectFun{
    
    // 2. 监听SDN 连接状态
    bool connected = [RaylinkProxy.sharedManager isSdnConnected];
    
    HLog(@"协助瑞云看日志onConnectFun isSdnConnected：%d",connected);
    
    if(!connected){
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.0 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
            mainBlock(^{
                [self onConnectFun];
            });
        });
        
        return;
    }
    
    if (self.peerConnected == YES) {
        [self disconnect];
        return;
    }
    
    _curConnectDeviceState = DeviceConnectDeciceing;

    NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId; //@"3dfe7c1f";
    
    /// 3. 根据对端的 SDN ID 创建连接
    [RaylinkProxy.sharedManager createNewConnection:curSdnId];
    
    /// 4. 创建 HttpService
    self.tcpPort = [RaylinkProxy.sharedManager createHttpService:curSdnId];
    self.tcpPortStr = [[NSString alloc] initWithFormat:@"%ld",self.tcpPort];
    
    self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
    
    /// 6. 添加端口防火墙
    [RaylinkProxy.sharedManager addSdnId:curSdnId allowPort:9300];
    [RaylinkProxy.sharedManager addSdnId:curSdnId allowPort:9100];
   
    
    //[self.connectBtn setEnabled:NO];
    
    //[self.connectBtn setTitle:@"连接中..." forState:UIControlStateDisabled];
    
}

- (void)disconnect {
    NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId;
    if(curSdnId){
        [RaylinkProxy.sharedManager closeConnection:curSdnId];
        [RaylinkProxy.sharedManager closeHttpService:curSdnId];
        //[self.connectBtn setTitle:@"连接" forState:UIControlStateNormal];
        self.peerConnected = NO;
    }
}

- (IBAction)onClickSend:(id)sender {
    
//    if (self.messageTF.text.length <= 0) {
//        return;
//    }
    
    [self.socket writeData:[@"111" dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
    
}

- (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket {
    
    NSLog(@"didAcceptNewSocket");
    
    
    [newSocket setDelegate:self delegateQueue:dispatch_get_main_queue()];
    
    NSThread *revcThread = [[NSThread alloc] initWithBlock:^{
        
        while (true) {
            [newSocket readDataWithTimeout:-1 tag:0];
            [NSThread sleepForTimeInterval:0.1];
        }
    }];
    
    [revcThread start];
    
}

- (void)onProxyConnected:(NSString *)sdnId status:(int)status {
    
    
    if (status == 0) {
        /// 6. 等待连接成功回调，创建 TCP socket 连接 HttpService 的端口
        [self.socket connectToHost:@"127.0.0.1" onPort:self.tcpPort error:NULL];
        
        _curConnectDeviceState = DeviceConnectDeciceOk;
//        [self.connectBtn setTitle:@"连接成功" forState:UIControlStateDisabled];
//        [self.sendBtn setEnabled:YES];
    } else {
//        [self.connectBtn setTitle:@"连接中..." forState:UIControlStateDisabled];
//        [self.sendBtn setEnabled:NO];
    }
}

- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port {
    
    NSLog(@"didConnectToHost %d", port);
    
    NSThread *thread = [[NSThread alloc] initWithBlock:^{
        while (true) {

            [self.socket readDataWithTimeout:-1 tag:0];
            [NSThread sleepForTimeInterval:0.1];

        }
    }];

    [thread start];
    
    /// 7. Socket 连接成功后，通过 socket  发送, self.peerPortTF 为对端服务端口
    [sock writeData:[[NSString stringWithFormat:@"CONNECT 127.0.0.1:%@ HTTP/1.0\r\n\r\n", @"9100"] dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];

    NSLog(@"readDataToData");
    
}

- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag
{
    NSLog(@"socket:%p didWriteDataWithTag:%ld", sock, tag);
}

- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag {
    
    
    if (tag == 0) {
        
        NSString *str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
        
        /// 8. 收到包含 `HTTP/1.0 200`的字符串，则认为连接成功。可以正常给对端发消息了
        if ([str containsString:@"HTTP/1.0 200"]) {
            NSLog(@"Connected");
            self.peerConnected = YES;
//            self.connectBtn.enabled = YES;
//            [self.connectBtn setTitle:@"断开连接" forState:UIControlStateNormal];
        }
        
    }
    
    //self.revcLab.text = [NSString stringWithFormat:@"接收：%@", [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]];
}




#pragma mark 保持卡密码
-(void)updateCardInfoBySN:(NSString*)snStr withPwdStr:(NSString*)pwd didNetEnd:(netWork_DidEndByOK)didNetEndIsOK
{
    
    NSMutableDictionary *paraDict = [NSMutableDictionary new];
    [paraDict setValue:snStr forKey:@"sn"];
    
    NSString* enPwdStr = [RSATool AES128Encrypt:pwd key:AESCODEKEEYY];
    if(enPwdStr){
        [paraDict setValue:enPwdStr forKey:@"password"];
    }
    
    KWeakSelf
    [[netWorkManager shareInstance] CommonPostCallBackCode:updateCardInfo Parameters:paraDict success:^(id  _Nonnull responseObject) {
        
        
        SuperModel*model = [[SuperModel alloc] initWithDictionary:responseObject error:nil];

        if(model && model.status == 0)
        {
            didNetEndIsOK(YES);
            
            [connectDeviceManager shareInstance].DeviceThirdIdMod.data.password = enPwdStr;
            /*密码保持在本地*/
            NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
            NSMutableDictionary *dict = [[NSMutableDictionary alloc] initWithDictionary:deviceDict];
            [dict setObject:pwd forKey:Const_Have_Add_Device_PWD];
            [HWDataManager setObjectWithKey:Const_Have_Add_Device value:dict];
            
        }
        else{
            didNetEndIsOK(NO);
        }
        
        
    } failure:^(NSError * _Nonnull error) {
        HLog("网络报错");
        didNetEndIsOK(NO);
    }];
}

#pragma mark ---ping-----站点 判断是否是局域网
- (void)startPingDeviceIp:(NSString *)roomInternetIp
{
    //roomInternetIp = @"www.baidu.com";
    if(!roomInternetIp || roomInternetIp.length < 7){
        self.DeviceThirdIdMod.data.isPingOk = NO;
        return;
    }
    
    if (self->whPingTester)
    {
        [self->whPingTester stopPing];
        self->whPingTester = nil;
    }
    
    self->whPingTester = [[WHPingTester alloc] initWithHostName:roomInternetIp];
    self->whPingTester.delegate = self;
    //self->whPingTester.countdownTime = 1; //1秒ping一次
    [self->whPingTester startPing];
    
    
    /// 启动定时器监听 10秒后 whPingTester的状态
    [NSTimer scheduledTimerWithTimeInterval:5 repeats:NO block:^(NSTimer * _Nonnull timer) {
        
        if(self->whPingTester){
            [self didGetPingStateIsOK:NO];
        }
    }];
    
}

#pragma mark ---ping---- 代理回调
- (void) didPingSucccessWithTime:(float)time withError:(NSError*) error
{
    HLog(@"time:%f \n error: %@",time,error)
    
    //if(error.code == 111 || time > 1000) //超时或者延时超过100ms，就要记录数据
    if(error != nil)
    {
        [self didGetPingStateIsOK:NO];
    }
    else if(time > 0){
        [self didGetPingStateIsOK:YES];
    }
    
}

- (void) didPingfialewithError:(NSError*)error
{
    HLog(@" error  error: %@",error)
    [self didGetPingStateIsOK:NO];
}

-(void)didGetPingStateIsOK:(BOOL)isOk
{
    self.DeviceThirdIdMod.data.isPingOk = isOk;
    [self->whPingTester stopPing];
    self->whPingTester = nil;
}

@end