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;
    
    BOOL didRuiYunInitOkType;
    
    BOOL disconnected_cb_type;//瑞云回调链接断开了
}

@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;

@property (nonatomic, copy) NSString *Pre_sdnId;//上一个sdn好
@property (nonatomic, assign) BOOL isGetThridMsgType;
@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(_isGetThridMsgType){
        didNetEndIsOK(-1);
        return;
    }
    
    if(needReconnect){
        _curConnectDeviceState = DeviceConnectGetThridMsging;

        //更换设备
//        NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId;
//        if(curSdnId){
//            _Pre_sdnId = curSdnId;
//        }
        
    }
    
    NSMutableDictionary *paraDict = [NSMutableDictionary new];
    [paraDict setValue:snStr forKey:@"sn"];
    _isGetThridMsgType = YES;
    KWeakSelf
    [[netWorkManager shareInstance] CommonGetWithCallBackCode:getThirdIdBySn Parameters:paraDict success:^(id  _Nonnull responseObject) {
        self->_isGetThridMsgType = NO;
        DeviceThirdIdModel *model = [[DeviceThirdIdModel alloc] initWithDictionary:responseObject error:nil];

        if(model.status == 0
           && model.data)
        {
            weakSelf.DeviceThirdIdMod = model;
            
            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];
           
            
            NSString *sdnid = model.data.sdnId;
            
            if(sdnid){
                [dict setObject:sdnid forKey:Const_Have_Add_Device_sdnid];
            }
            
            [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("网络报错");
        self->_isGetThridMsgType = NO;
        didNetEndIsOK(NO);
    }];
}

#pragma mark 刷新扫码的sn获取第三方信息 是否需要重连
-(void)RefreshThridMsg
{
    /*先判断本地有无设备 无设备时需要先扫码添加设备*/
    NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
    if (deviceDict && [[deviceDict allKeys] containsObject:Const_Have_Add_Device_SN]){
        //有设备了先去做链接准备  // 80bec9c5
        NSString *SNStr = deviceDict[@"Const_Have_Add_Device_SN"];
        
        if(SNStr){
            [[connectDeviceManager shareInstance] getThridMsgBySN:SNStr needReconnect:NO  didNetEnd:^(NSInteger didSuc) {
                
            }];
        }
    }
}

#pragma mark 初始化瑞云的SDK等
- (void)initRuiyunSDKFun{
    
    if(didRuiYunInitOkType){
        [self onConnectFun];
        return;
    }
        
    HLog(@"initRuiyunSDKFun");
    
    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];
    }
    
    KWeakSelf
    dispatch_async(initProxyQueue, ^{
        NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
        
        /// 1. 初始化代理库
        [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
        
        self->didRuiYunInitOkType = YES;
        
        /// 启动定时器监听 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) {
                
                [weakSelf onConnectFun];
                [self->_connectCheckTimer invalidate];
                
                //self.sdnConnectStateLab.text = @"SDN state: Connected";
                //self.sdnIDLab.text = [@"My SDN ID: " stringByAppendingString:[RaylinkProxy.sharedManager getSdnId]];
                
                    
            } else {
                //self.sdnConnectStateLab.text = @"SDN state: Connectting";
            }
            
            
        }];
        
        [[NSRunLoop currentRunLoop] addTimer:self.connectCheckTimer forMode:NSRunLoopCommonModes];
        [[NSRunLoop currentRunLoop] run];
        
    });
    
    
    /// 作为服务端时，启动端口监听
    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);
    }
    
}


- (void)onConnectFun{
    
    if (self.peerConnected == YES
        && _Pre_sdnId
        && ![_Pre_sdnId isEqualToString:self.DeviceThirdIdMod.data.sdnId]) {
        //[self disconnect];

        //return;
    }
    
    _curConnectDeviceState = DeviceConnectDeciceing;

    NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId; //@"3dfe7c1f";
    
    if(!curSdnId){
        NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
        
        if(deviceDict && [[deviceDict allKeys] containsObject:Const_Have_Add_Device_sdnid])
        {
            curSdnId = deviceDict[Const_Have_Add_Device_sdnid];
        }
    }
    
    /// 3. 根据对端的 SDN ID 创建连接
    [RaylinkProxy.sharedManager createNewConnection:curSdnId];
    

    
    self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
    

   
    
    //[self.connectBtn setEnabled:NO];
    
    //[self.connectBtn setTitle:@"连接中..." forState:UIControlStateDisabled];
    
}

- (void)disconnect {
    
    NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId;
    if(_Pre_sdnId){
        curSdnId = _Pre_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) {
        
        /// 4. 创建 HttpService
        self.tcpPort = [RaylinkProxy.sharedManager createHttpService:sdnId];
        self.tcpPortStr = [[NSString alloc] initWithFormat:@"%ld",self.tcpPort];
        
        /// 5. 添加端口防火墙
        [RaylinkProxy.sharedManager addSdnId:sdnId allowPort:9300];
        [RaylinkProxy.sharedManager addSdnId:sdnId allowPort:9100];
        
        [cachesFileManager writeLogsWithMsg:@"onProxyConnected connectToHost"];
        
        /// 6. 等待连接成功回调，创建 TCP socket 连接 HttpService 的端口
         NSError *error;
        
        NSString*log1 =  [[NSString alloc] initWithFormat:@"onProxyConnected connectToHost begin %ld", (long)self.tcpPort];
        [cachesFileManager writeLogsWithMsg:log1];
        
        [self.socket connectToHost:@"127.0.0.1" onPort:self.tcpPort error:&error];
        
        NSString*log2 =  [[NSString alloc] initWithFormat:@"onProxyConnected connectToHost end %ld, self.socket = %@ error = %@", (long)self.tcpPort, self.socket, error];
        [cachesFileManager writeLogsWithMsg:log2];
        
        _curConnectDeviceState = DeviceConnectDeciceOk;
        _Pre_sdnId = self.DeviceThirdIdMod.data.sdnId;
        
        disconnected_cb_type = NO;
    
//        [self.connectBtn setTitle:@"连接成功" forState:UIControlStateDisabled];
//        [self.sendBtn setEnabled:YES];
    } else {
//        [self.connectBtn setTitle:@"连接中..." forState:UIControlStateDisabled];
//        [self.sendBtn setEnabled:NO];
        
        HLog(@"瑞云链接断开");
    }
}

- (void)OnProxyDisconnected_cb:(NSString *)sdnId {
    [RaylinkProxy.sharedManager closeHttpService:sdnId];
    [cachesFileManager writeLogsWithMsg:@"OnProxyDisconnected_cb"];
    disconnected_cb_type = YES;
}

//瑞云sock 断开了 需要重连
- (void)tryReconnectFun{
    
    [cachesFileManager writeLogsWithMsg:@"tryReconnect"];
    if(!disconnected_cb_type){
        [cachesFileManager writeLogsWithMsg:@"tryReconnect return"];
        return;
    }
    
    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_queue_t reinitProxyQueue = dispatch_queue_create("reinit_proxy", 0);
    
    
    [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 0"];
    dispatch_async(reinitProxyQueue, ^{
        NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
        
        /// 1. 初始化代理库
        [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 1"];
        self->disconnected_cb_type = NO;
        [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
        [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 2"];
    });
    
//    //KWeakSelf
//    NSMutableDictionary *paraDict = [NSMutableDictionary new];
//    if(self.DeviceThirdIdMod.data.sn){
//        [paraDict setValue:self.DeviceThirdIdMod.data.sn forKey:@"sn"];
//    }
//
//    [cachesFileManager writeLogsWithMsg:@"tryReconnect CommonGetWithCallBackCode"];
//    [[netWorkManager shareInstance] CommonGetWithCallBackCode:getThirdIdBySn Parameters:paraDict success:^(id  _Nonnull responseObject) {
//
//        dispatch_async(self->initProxyQueue, ^{
//            NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
//
//            /// 1. 初始化代理库
//            [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
//            [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy"];
//        });
//
//
//    } failure:^(NSError * _Nonnull error) {
//        HLog("网络报错");
//    }];
    
}

- (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");
    
    [cachesFileManager writeLogsWithMsg:@"didConnectToHost writeData"];
}

- (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