✨ 支持获取证书/初步添加对socket.io的支持

Author: Mxmilu666

inc/socketio.php

@@ -0,0 +1,100 @@
+<?php
+use Swoole\Coroutine;
+use Swoole\Coroutine\Http\Client;
+class socketio {
+    private $url;
+    private $token;
+    private $client;
+    private $data;
+    private $certdata;
+    private $Connected = false;
+    public function __construct($url,$token) {
+        $this->url = $url;
+        $this->token = $token;
+    }
+    public function connect() {
+        $this->client = $client = new Client($this->url, 443, true);
+        $ret = $client->upgrade('/socket.io/?EIO=4&transport=websocket');
+        $auth = [
+            'token' => $this->token
+        ];
+        if ($ret) {
+            $client->push('40'.json_encode($auth));
+        }
+
+        while(true) {
+            $alldata = $client->recv(1.5);
+            if (!is_bool($alldata)){
+            $this->data = $data = $alldata->data;
+            preg_match('/^\d+/', $data, $code);
+            if ($code[0] == '0'){
+                $jsondata = json_decode(substr($data, strlen($code[0])),true);
+                mlog("[socket.io]Connected sid:{$jsondata['sid']} pingInterval:{$jsondata['pingInterval']} pingTimeout:{$jsondata['pingTimeout']}",1);
+            }
+            if ($code[0] == '40'){
+                $jsondata = json_decode(substr($data, strlen($code[0])),true);
+                mlog("[socket.io]Connected sid:{$jsondata['sid']}",1);
+                mlog("已连接主控");
+                $this->Connected = true;
+            }
+            if ($code[0] == '42'){
+                $data = substr($data, strlen($code[0]));
+                mlog("[socket.io]Got data {$data}");
+            }
+            if ($code[0] == '2'){
+                $client->push('3');
+                mlog("[socket.io]Sending PONG",1);
+            }
+            if ($code[0] == '41'){
+                mlog("[socket.io]Close Connection");
+                $client->close();
+                return;
+            }
+            if ($code[0] == '430'){
+                $jsondata = json_decode(substr($data, strlen($code[0])),true);
+                $this->certdata = $jsondata;
+                //mlog("[socket.io]Got MESSAGE {$data}",1);
+            }
+            //var_dump($data);
+            Coroutine::sleep(0.1);
+        }
+        global $shouldExit;
+            if ($shouldExit) {
+                mlog("[socket.io]Close Connection");
+                $client->close();
+                return;
+            }
+    }
+    }
+    public function Getcert() {
+        $time = 0;
+        while ($time !== 30){
+            if(isset($this->certdata)){
+                return $this->certdata;
+            }
+        }
+        if ($time = 30){
+            mlog("Getcert Connected Overtime",2);
+            return(false);
+        }
+
+    }
+    public function ack($event,$data = "") {
+        $time = 0;
+        while ($time !== 30){
+            Coroutine::sleep(1);
+            $time++;
+            if ($this->Connected){
+                $senddata = json_encode([$event,$data]);
+                return($this->client->push('420'.$senddata));
+            }
+        }
+        if ($time = 30){
+            mlog("[socket.io]ACK Connected Overtime",2);
+            return(false);
+        }
+    }
+    public function Getclient() {
+        return $this->client;
+    }
+}

main.php

@@ -12,10 +12,10 @@
 const OPENBMCLAPIURL = 'openbmclapi.bangbang93.com';
 global $tokendata;
 $list = glob('./inc/*.php');
-    foreach ($list as $file) {
-        $file = explode('/', $file)['2'];
-        require './inc/' . $file;
-    }
+foreach ($list as $file) {
+    $file = explode('/', $file)['2'];
+    require './inc/' . $file;
+}
 echo"OpenBmclApionPHP v0.0.1-dev". PHP_EOL;
 run(function()use ($config){
     //注册信号处理器
@@ -77,4 +77,31 @@ function registerSigintHandler() {
             mlog("检查文件完毕,没有缺失/损坏");
         }
     }
+    global $shouldExit;
+    if (!is_array($Missfile) && !$shouldExit){//判断Missfile是否为空和是否是主动退出
+        $socketio = new socketio(OPENBMCLAPIURL,$tokendata['token']);
+        mlog("正在连接主控");
+        Coroutine::create(function () use ($socketio){
+            $socketio->connect();
+        });
+        Coroutine::sleep(1);
+        if (file_exists('./cert/'.$config['CLUSTER_ID'].'.cert') && file_exists('./cert/'.$config['CLUSTER_ID'].'.key')) {
+            
+        } else {
+            mlog("正在获取证书");
+            if (!file_exists("./cert")) {
+                mkdir("./cert",0777,true);
+            }
+            $socketio->ack("request-cert");
+            Coroutine::sleep(1);
+            $allcert = $socketio->Getcert();
+            mlog("已获取证书,到期时间{$allcert['0']['1']['expires']}");
+            $cert = fopen('./cert/'.$config['CLUSTER_ID'].'.cert', 'w');
+            $Writtencert = fwrite($cert, $allcert['0']['1']['cert']);
+            fclose($cert);
+            $cert = fopen('./cert/'.$config['CLUSTER_ID'].'.key', 'w');
+            $Writtencert = fwrite($cert, $allcert['0']['1']['key']);
+            fclose($cert);
+        }
+    }
 });