fix start wg1

.gitignore

@@ -16,3 +16,5 @@
 .vscode/
 .idea/
 mirror/.env
+update/*
+!update/update.sh

app/bot.php

@@ -4,6 +4,7 @@ class Bot
 {
     public $input;
     public $adguard;
+    public $update;
 
     public function __construct($key, $i18n)
     {
@@ -19,6 +20,7 @@ class Bot
         $this->dns      = '1.1.1.1, 8.8.8.8';
         $this->limit    = $this->getPacConf()['limitpage'] ?: 5;
         $this->adguard  = '/config/AdGuardHome.yaml';
+        $this->update   = '/update/json';
     }
 
     public function input()
@@ -131,6 +133,9 @@ class Bot
             case preg_match('~^/mtproto$~', $this->input['callback'], $m):
                 $this->mtproto();
                 break;
+            case preg_match('~^/updatebot$~', $this->input['callback'], $m):
+                $this->updatebot();
+                break;
             case preg_match('~^/getMirror$~', $this->input['callback'], $m):
                 $this->getMirror();
                 break;
@@ -1005,10 +1010,14 @@ class Bot
         return json_encode($conf, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
     }
 
-    public function exportManual()
+    public function exportManual($file = false)
     {
+        $json = $this->export();
+        if (!empty($file)) {
+            file_put_contents($file, $json);
+        }
         $bot = $this->request('getMyName', [])['result']['name'];
-        return $this->upload("{$bot}_export_" . date('d_m_Y_H_i') . '.json', $this->export());
+        return $this->upload("{$bot}_export_" . date('d_m_Y_H_i') . '.json', $json);
     }
 
     public function import()
@@ -1027,10 +1036,14 @@ class Bot
         ];
     }
 
-    public function importFile()
+    public function importFile($file = false)
     {
-        $r    = $this->request('getFile', ['file_id' => $this->input['file_id']]);
+        if (!empty($file)) {
-        $json = json_decode(file_get_contents($this->file . $r['result']['file_path']), true);
+            $json = json_decode(file_get_contents($file), true);
+        } else {
+            $r    = $this->request('getFile', ['file_id' => $this->input['file_id']]);
+            $json = json_decode(file_get_contents($this->file . $r['result']['file_path']), true);
+        }
         if (empty($json) || !is_array($json)) {
             $this->answer($this->input['callback_id'], 'error', true);
         } else {
@@ -1145,8 +1158,12 @@ class Bot
 
             $out[] = "end import";
             $this->update($this->input['chat'], $this->input['message_id'], implode("\n", $out));
+            $this->language = $this->getPacConf()['language'] ?: 'en';
+            $this->limit    = $this->getPacConf()['limitpage'] ?: 5;
             sleep(3);
-            $this->menu();
+            if (empty($file)) {
+                $this->menu();
+            }
         }
     }
 
@@ -2942,7 +2959,7 @@ DNS-over-HTTPS with IP:
     {
         $menu = [
             'main' => [
-                'text' => $this->i18n('menu'),
+                'text' => 'v' . getenv('VER'),
                 'data' => [
                     [
                         [
@@ -3026,7 +3043,7 @@ DNS-over-HTTPS with IP:
             'lang'         => $type == 'lang'         ? $this->menuLang() : false,
             'oc'           => $type == 'oc'           ? $this->ocMenu() : false,
             'naive'        => $type == 'naive'        ? $this->naiveMenu() : false,
-            'mirror'       => $type == 'mirror'        ? $this->mirrorMenu() : false,
+            'mirror'       => $type == 'mirror'       ? $this->mirrorMenu() : false,
         ];
 
         $text = $menu[$type ?: 'main' ]['text'];
@@ -3478,6 +3495,15 @@ DNS-over-HTTPS with IP:
         return openssl_x509_parse($c)["validTo_time_t"] ?: false;
     }
 
+    public function updatebot()
+    {
+        $this->exportManual($this->update);
+        $r = $this->send($this->input['from'], 'update...');
+        file_put_contents('/update/reload_message', "{$this->input['from']}:{$r['result']['message_id']}");
+        file_put_contents('/update/pipe', '1');
+        $this->delete($this->input['from'], $this->input['message_id']);
+    }
+
     public function configMenu()
     {
         $conf = $this->getPacConf();
@@ -3588,6 +3614,12 @@ DNS-over-HTTPS with IP:
                 'callback_data' => "/debug",
             ],
         ];
+        $data[] = [
+            [
+                'text'          => $this->i18n('update bot'),
+                'callback_data' => "/updatebot",
+            ],
+        ];
         $data[] = [
             [
                 'text'          => $this->i18n('back'),
@@ -3797,7 +3829,6 @@ DNS-over-HTTPS with IP:
 
     public function readStatus()
     {
-        // $this->sd([$this->getWGType(), $this->getInstanceWG()]);
         $r = $this->ssh($this->getWGType(), $this->getInstanceWG());
         $r = explode(PHP_EOL, $r);
         $r = array_filter($r);
@@ -3970,14 +4001,21 @@ DNS-over-HTTPS with IP:
 
     public function syncPortClients()
     {
-        $endpoint = $this->ip . ':' . getenv('WGPORT');
+        $endpoint = [
-        $clients  = $this->readClients();
+            $this->ip . ':' . getenv('WGPORT'),
-        foreach ($clients as $k => $v) {
+            $this->ip . ':' . getenv('WG1PORT'),
-            foreach ($v['peers'] as $i => $j) {
+        ];
-                $clients[$k]['peers'][$i]['Endpoint'] = $endpoint;
+        for ($i=0; $i < 2; $i++) {
+            $this->wg = $i;
+            $clients  = $this->readClients();
+            foreach ($clients as $k => $v) {
+                foreach ($v['peers'] as $i => $j) {
+                    $clients[$k]['peers'][$i]['Endpoint'] = $endpoint[$i];
+                }
             }
+            $this->saveClients($clients);
         }
-        $this->saveClients($clients);
+        unset($this->wg);
     }
 
     public function saveClients(array $clients)
@@ -4072,7 +4110,7 @@ DNS-over-HTTPS with IP:
         if (!empty($r['result']) && $r['result'] == true) {
             file_put_contents('/start', 1);
         } else {
-            die('set webhook fail');
+            die("set webhook fail\n");
         }
     }
 

app/i18n.php

@@ -301,4 +301,8 @@ $i = [
         'en' => 'download',
         'ru' => 'скачать',
     ],
+    'update bot'  => [
+        'en' => 'update bot',
+        'ru' => 'обновить бота',
+    ],
 ];

app/init.php

@@ -11,9 +11,3 @@ $bot = new Bot($c['key'], $i);
 $bot->setwebhook();
 $bot->setcommands();
 $bot->syncPortClients();
-if (!empty($c['admin'])) {
-    $ip = getenv('IP');
-    foreach ($c['admin'] as $k => $v) {
-        $bot->send($v, "start $ip");
-    }
-}

app/service.php

@@ -0,0 +1,38 @@
+<?php
+
+require __DIR__ . '/timezone.php';
+
+// require __DIR__ . '/debug.php';
+require __DIR__ . '/bot.php';
+require __DIR__ . '/config.php';
+require __DIR__ . '/i18n.php';
+
+$bot = new Bot($c['key'], $i);
+
+if (!empty($c['admin'])) {
+    $ip = getenv('IP');
+    $rm = explode(':', trim(file_get_contents('/update/reload_message')));
+    $m  = file_get_contents('/update/message');
+    foreach ($c['admin'] as $k => $v) {
+        $r = $bot->send($v, "start $ip");
+        $bot->input['chat']        = $v;
+        $bot->input['message_id']  = $r['result']['message_id'];
+        if (file_exists($bot->update)) {
+            if (!empty($m)) {
+                $bot->send($v, "<pre>$m</pre>", $v == $rm[0] ? $rm[1] : 0);
+            }
+            $r = $bot->send($v, "import settings");
+            $bot->input['chat']        = $v;
+            $bot->input['message_id']  = $r['result']['message_id'];
+            $bot->input['callback_id'] = $r['result']['message_id'];
+            if (empty($flag)) {
+                $bot->importFile($bot->update);
+                unlink($bot->update);
+                $flag = true;
+            }
+        }
+    }
+}
+file_put_contents('/update/message', '');
+file_put_contents('/update/reload_message', '');
+$bot->menu();

docker-compose.yml

@@ -101,6 +101,7 @@ services:
             - ./version:/version
             - ./mirror:/mirror
             - ./.env:/mirror/.env
+            - ./update:/update
         environment:
             TZ: ${TZ}
             IP: ${IP}
@@ -110,6 +111,7 @@ services:
             WG1PORT: ${WG1PORT}
             SSPORT: ${SSPORT}
             TGPORT: ${TGPORT}
+            VER: ${VER}
         hostname: php
         container_name: php-${VER}
         restart: unless-stopped
@@ -127,6 +129,55 @@ services:
             interval: 5s
             timeout: 5s
             retries: 5
+    service:
+        image: mercurykd/vpnbot-php:1.1
+        build:
+            dockerfile: dockerfile/php.dockerfile
+            args:
+                image: ${IMAGE}
+        volumes:
+            - ./config/.profile:/root/.ashrc:ro
+            - ./config/php.ini:/etc/php81/php.ini
+            - ./config/:/config/
+            - ./certs/:/certs/
+            - ./ssh:/ssh
+            - ./app:/app
+            - ./logs/:/logs/
+            - ./update:/update
+            - ./scripts/start_service.sh:/start_service.sh
+        environment:
+            TZ: ${TZ}
+            IP: ${IP}
+            ADDRESS: ${WGADDRESS}
+            WGPORT: ${WGPORT}
+            WG1ADDRESS: ${WG1ADDRESS}
+            WG1PORT: ${WG1PORT}
+            SSPORT: ${SSPORT}
+            TGPORT: ${TGPORT}
+            VER: ${VER}
+        hostname: service
+        container_name: service-${VER}
+        # restart: unless-stopped
+        stop_grace_period: 1s
+        command: ["/bin/sh", "/start_service.sh"]
+        working_dir: /app
+        networks:
+            default:
+                ipv4_address: 10.10.0.15
+        logging: *default-logging
+        depends_on:
+            - up
+            - ng
+            - php
+            - proxy
+            - wg
+            - wg1
+            - ad
+            - ss
+            - tg
+            - xr
+            - oc
+            - np
     proxy:
         image: mercurykd/vpnbot-ss:1.1
         build:

makefile

@@ -1,8 +1,10 @@
 b:
 	docker compose build
 u: # запуск контейнеров
-	IP=$(shell ip -4 addr | sed -ne 's|^.* inet \([^/]*\)/.* scope global.*$$|\1|p' | awk '{print $1}' | head -1) VER=$(shell git describe --tags) docker compose up -d --force-recreate
+	bash ./update/update.sh &
+	IP=$(shell curl https://ipinfo.io/ip) VER=$(shell git describe --tags) docker compose up -d --force-recreate
 d: # остановка контейнеров
+	-kill -9 $(shell cat ./update/update_pid) > /dev/null
 	docker compose down --remove-orphans
 dv: # остановка контейнеров
 	docker compose down -v
@@ -46,17 +48,11 @@ cleanf:
 cleanall:
 	docker image prune -a -f
 	docker builder prune -a -f
-p:
-	git stash
-	git pull
-	git stash pop stash@{0}
-update: p r
-cn:
-	docker compose exec ng nginx -t
 push:
 	docker compose push
 s:
 	git status -su
 c:
 	git add config/
-	git checkout .
+	git checkout .
+	git reset

scripts/start_service.sh

@@ -0,0 +1 @@
+php service.php

scripts/start_wg.sh

@@ -1,3 +1,7 @@
+cat /ssh/key.pub > /root/.ssh/authorized_keys
+ssh-keygen -A
+exec /usr/sbin/sshd -D -e "$@" &
+
 INTERFACE=$(route | grep '^default' | grep -o '[^ ]*$')
 if [ $(cat /etc/wireguard/wg0.conf | wc -c) -eq 0 ]
 then
@@ -13,21 +17,36 @@ fi
 iptables -t nat -A POSTROUTING --destination 10.10.0.5 -j ACCEPT
 iptables -t nat -A POSTROUTING -o $INTERFACE -j MASQUERADE
 ln -s /etc/wireguard/wg0.conf /etc/amnezia/amneziawg/wg0.conf
-if [ $(cat /pac.json | jq .amnezia) -eq 1 ]
+if [ "$HOSTNAME" = "wireguard1" ]
 then
-    awg-quick up wg0
+    if [ $(cat /pac.json | jq .wg1_amnezia) -eq 1 ]
+    then
+        awg-quick up wg0
+    else
+        wg-quick up wg0
+    fi
+    if [ $(cat /pac.json | jq .wg1_blocktorrent) -eq 1 ]
+    then
+        sh /block_torrent.sh
+    fi
+    if [ $(cat /pac.json | jq .wg1_exchange) -eq 1 ]
+    then
+        sh /block_exchange.sh
+    fi
 else
-    wg-quick up wg0
+    if [ $(cat /pac.json | jq .amnezia) -eq 1 ]
-fi
+    then
-cat /ssh/key.pub > /root/.ssh/authorized_keys
+        awg-quick up wg0
-ssh-keygen -A
+    else
-exec /usr/sbin/sshd -D -e "$@" &
+        wg-quick up wg0
-if [ $(cat /pac.json | jq .blocktorrent) -eq 1 ]
+    fi
-then
+    if [ $(cat /pac.json | jq .blocktorrent) -eq 1 ]
-    sh /block_torrent.sh
+    then
-fi
+        sh /block_torrent.sh
-if [ $(cat /pac.json | jq .exchange) -eq 1 ]
+    fi
-then
+    if [ $(cat /pac.json | jq .exchange) -eq 1 ]
-    sh /block_exchange.sh
+    then
+        sh /block_exchange.sh
+    fi
 fi
 tail -f /dev/null

update/update.sh

@@ -0,0 +1,19 @@
+#!/bin/bash
+pwd=`pwd`
+> $pwd/update/pipe
+echo "$$" > $pwd/update/update_pid
+
+while true
+do
+    cmd=$(cat $pwd/update/pipe)
+    if [[ -n "$cmd" ]]
+    then
+        docker compose down --remove-orphans
+        git reset --hard
+        git pull > ./update/message
+        IP=$(curl https://ipinfo.io/ip) VER=$(git describe --tags) docker compose up -d --force-recreate
+        bash $pwd/update/update.sh &
+        exit 0
+    fi
+    sleep 1
+done

version

@@ -1,3 +1,5 @@
+03.03.2024 возможность обновления бота по кнопке из самого бота
+- <code>git pull && make r</code>
 02.03.2024 2 сервера wireguard, для возможности один запускать как wireguard а второй как amnezia
 - <code>git pull && make r</code>
 01.03.2024 фикс блокировок торрентов и обмена между пользователями