BBend-Test-JWT/manage.py

#啟動和管理項目
from distutils.log import error
from encodings import utf_8
from multiprocessing import Value
from app import create_app
from flask import render_template, request, session
import paramiko
import git
import shutil
from time import sleep as sl
from threading import Lock
import threading
from concurrent.futures import ThreadPoolExecutor
import csv
import os
import stat
import time


# app, db, mqtt, socketio = create_app() # Rita 0428
app, db, mqtt = create_app()
thread = None
thread_lock = Lock()

# Rita 0428
# @socketio.on('connect_event', namespace='/test_conn')
# def connected_msg(msg):
#     print("connect success")
#     print(msg)
#     socketio.emit('stdout', 'success', namespace='/test_conn')
#     print(socketio)

D = {"item_name":0, "command":0}

# 0411 shutil-rmtree 刪除 .get 唯讀檔
# https://stackoverflow.com/questions/21261132/shutil-rmtree-to-remove-readonly-files
def remove_readonly(func, path, _):
    os.chmod(path, stat.S_IWRITE)
    func(path)
    
# # 建置伺服器的訪問路徑 -- 舊 保留 0413 測試
# @app.route('/add_server', methods=['POST', 'GET'])
# def add_server_views():
#     username = session['uname']
#     L = []
#     if request.method == 'GET':
#         # 0407 測試註解一下
#         # repo = git.Repo.init(path='.')
#         # new_repo = git.Repo.clone_from(url='http://60.250.156.230:3000/benson/TestSSH.git', to_path='../new')
#         # new_repo = git.Repo.clone_from(url='http://60.250.156.230:3000/rita/CoffeeProject.git', to_path='../new')
#         os.system('git clone -b sh --single-branch http://60.250.156.230:3000/Automatic_build_system/Automatically_install_files.git C:\\Users\\USER\\Rita\\operating\\sixthproject\\new')
#         # with open('/home/benson/Project/new/All_installv3.2.sh') as f:
#         with open('../new/coffeesystem.sh', encoding='utf-8') as f:
#             # content = f.read().split('-Dividing line-')
#             # D['item_name'] = content[0].split('\n')[1:]
#             # D['command'] = content[1].split('\n')
#             D['command'] = f.read().split('\n')
#         # print("D['command']: ", D['command'])

#         # # 0407 測試中暫時註解
#         # # with open('/home/benson/Project/new/Item.txt') as f:
#         # with open('../new/Item.txt') as f:
#         #     D['item_name'] = f.read().split('\n')
#         #     for item in D['item_name']:
#         #         L.append('.'.join(item.split('.')[1:]))         # 拿掉 '.'.join 的話會變成 [['python3', '8'], ['python3-pip'],
        
        
#         # os.remove('C:/Users/USER/Rita/operating/sixthproject/new/.git')
#         # os.system('rm -rf ../new/.git')
#         # os.chmod('../new/.git', stat.S_IWRITE)
#         # os.unlink('../new/.git')
#         # sl(6)
#         # shutil.rmtree('../new', ignore_errors=True, onerror=del_rw)
#         sl(3)
#         shutil.rmtree('../new', onerror=remove_readonly)
#         sl(3)
#         # os.rmdir('../new')
#         # sl(6)
#         # #刪除非空資料夾
#         # try:
#         #     shutil.rmtree('../new', ignore_errors=True, onerror=del_rw)
#         #     # os.remove('../new')
#         #     print("=== DELETE ===")
#         #     sl(1)
#         # except OSError as e:
#         #     print(f"OSError:{e.strerror}")      # Error:存取被拒。
#         # # print("L: ", L)                         # L:  ['python3.8', 'python3-pip', 'git', ... , 'ROS-ubuntu-18.04-melodic']
        


#         # 0407 測試註解一下
#         # for i in range(0, len(D['item_name'])):
#         #     item = D['item_name'][i].split('=')[-1].replace('"','')
#         #     L.append(item)
#         # L = L[:-1]

#         # # 0411 測試
#         # D['command'] = [
#         #                 # 'cd /tmp/; pwd; sudo wget https://files.phpmyadmin.net/phpMyAdmin/5.1.0/phpMyAdmin-5.1.0-all-languages.tar.gz;tar -zxvf phpMyAdmin-5.1.0-all-languages.tar.gz;sudo rm phpMyAdmin-5.1.0-all-languages.tar.gz; sudo mv phpMyAdmin-5.1.0-all-languages /var/www/html/phpmyadmin;',
#         #                 'cd /var/www/html/phpmyadmin; pwd; mkdir tmp;',
#         #                 'cd /var/www/html/phpmyadmin; pwd; mkdir tmp;',
#         #                 'cd; pwd;',
#         #                 'pwd']

#         L2= []
#         for i in range(0, len(D['command'])):
#             if D['command'][i] == "'" or D['command'][i] == '' or "#" in D['command'][i] or D['command'][i] == ' ':
#                 continue
#             L2.append(D['command'][i])
#         D['command'] = L2
#         # print("D['command'] = L2: ", D['command'])

#         # print("=============== D['item_name'] ===============")
#         # print(D['item_name'])
#         # print("=============== D['command'] ===============")
#         # print(D['command'])
#         # print("=============== CODE CHECK 3 ===============")

#         # content = D['item_name'] + D['command']
#         # for i in content:
#         #     print(i)
#         return render_template('add_server.html', params=locals())
#     else:
#         item_install_fail = 0
#         d = request.form.to_dict()
#         ip = d['ip']
#         loginname = d['loginname']
#         username = d['username']
#         password = d['password']
#         print(ip)
#         print(loginname)
#         print(username)
#         print(password)
#         try:
#             # 建立一個sshclient物件
#             ssh = paramiko.SSHClient()
#             # 允許將信任的主機自動加入到host_allow 列表，此方法必須放在connect方法的前面
#             ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
#             # 指定本地的RSA私鑰檔案,如果建立金鑰對時設定的有密碼，password為設定的密碼，如無不用指定password引數
#             # pkey = paramiko.RSAKey.from_private_key_file('/home/super/.ssh/id_rsa', password='12345')
#             # pkey = paramiko.RSAKey.from_private_key_file('/home/ptop/topicjie/scripts/keys/id_rsa')
#             # 建立連線
#             # ssh.connect(hostname=ip,
#             #             port=22,
#             #             username='gs1801',
#             #             pkey=pkey)
#             # with open('/home/benson/test11.sh') as f:
#             #     content = f.read().split('\n')[0:-1]
#             # print(content)
#             # L = []
#             # for i in range(0, len(D['ssh_content'])):
#             #     if "#" in D['ssh_content'][i] or D['ssh_content'][i] == '' or D['ssh_content'][i] == ' ':
#             #         continue
#             #     L.append(D['ssh_content'][i])
#             # for i in L:
#             #     print(i)

#             ssh.connect(hostname=ip,
#                         port=22,
#                         username=loginname,
#                         password=password)
#             # 假如帳號密碼正確沒有被捕捉到異常，傳送訊息給前端
#             socketio.emit('user-confirm', 'pass', namespace='/test_conn')
#             # os.system("scp /home/benson/test10.sh gs1801@" + ip + ":/home/gs1801/")
#             # 執行命令
#             # stdin, stdout, stderr = ssh.exec_command("ls -l /home/gs1801;touch test7.py")
#             # stdin, stdout, stderr = ssh.exec_command("touch test10.sh;echo '" + content + "' >> test10.sh;bash test10.sh")
#             # print('test1')
#             # print(stdout.read().decode())
#             # print('test2')
#             # print(stderr.read().decode())

#             # content = D['item_name'] + D['command']
#             with open('ItemFile.csv', 'w', newline='') as csvFile:
#                 csvWriter = csv.writer(csvFile)
#                 csvWriter.writerow(['Command', 'Install Content', 'Time', 'Status'])

#             # # Rita 0406 TEST
#             D['command'] = [
#                             # 'sudo pip3 install cryptography==3.3.2',
#                             # 'sudo -H pip3 install --upgrade pip',
#                             # 'sudo pip3 install gitpython',
#                             # 'cd /tmp/;pwd;sudo wget https://files.phpmyadmin.net/phpMyAdmin/5.1.0/phpMyAdmin-5.1.0-all-languages.tar.gz -q;tar -zxvf phpMyAdmin-5.1.0-all-languages.tar.gz;sudo rm phpMyAdmin-5.1.0-all-languages.tar.gz;sudo mv phpMyAdmin-5.1.0-all-languages /var/www/html/phpmyadmin',
#                             # 'cd /var/www/html/phpmyadmin;pwd;mkdir tmp;',
#                             # # 'sudo mysql -u root -e \"ALTER USER \'root\'@\'localhost\' IDENTIFIED WITH mysql_native_password BY \'Gold@53743001\';\"',
#                             # 'sudo -H pip3 install paho-mqtt',
#                             # 'cd /home/gs1802;sudo git clone -b mosquitto --single-branch http://60.250.156.230:3000/fatwolf/mqtt_server_setting.git /home/gs1802/mosquitto/;sudo git clone -b passwd --single-branch http://60.250.156.230:3000/fatwolf/mqtt_server_setting.git /home/gs1802/passwd/;sudo mv /mosquitto/mosquitto.conf /etc/mosquitto/;sudo mv /passwd/passwd /etc/mosquitto/;sudo rm -rf /mosquitto/;sudo rm -rf /passwd/',
#                             # 'cd /home/gs1802;pwd;sudo git clone -b procwdtdconf --single-branch http://60.250.156.230:3000/fatwolf/proc.git /home/gs1802/procwdtdconf/;sudo git clone -b procwdtd --single-branch http://60.250.156.230:3000/fatwolf/proc.git /home/gs1802/procwdtd/;sudo git clone -b rclocal --single-branch http://60.250.156.230:3000/fatwolf/proc.git /home/gs1802/rclocal/;sudo mv /procwdtdconf/proc-wdtd.conf /etc/;sudo mv /procwdtd/proc-wdtd /usr/sbin/;sudo mv /rclocal/rc.local /etc/;sudo rm -rf /procwdtdconf/;sudo rm -rf /procwdtd/;sudo rm -rf /rclocal/',
#                             # 'cd /home/gs1802;pwd;git clone http://60.250.156.230:3000/fatwolf/gogsfile.git /home/gs1802/gogs;mv gogs/gogs_0.12.3_linux_amd64.tar.gz /home/gs1802/;rm -rf gogs/;tar -C /home/gs1802 -zxvf gogs_0.12.3_linux_amd64.tar.gz',
#                             # 'cd /home/gs1802;pwd;git clone -b package --single-branch http://60.250.156.230:3000/Automatic_build_system/Automatically_install_files.git;cd Automatically_install_files/;pwd;sudo pip3 install -r requirements.txt',
#                             # 'cd /home/gs1802;pwd;sudo git clone http://60.250.156.230:3000/rita/CoffeeProject.git /home/gs1802/CoffeeProject/',
#                             # 'sudo apt-key adv --keyserver "hkp://keyserver.ubuntu.com:80" --recv-key C1CF6E31E6BADE8868B172B4F42ED6FBAB17C654',
#                             # 'sudo apt install ros-melodic-desktop-full -y',
#                             # 'rosdep update',
#                             # 'cd /home/gs1802;pwd;mkdir -p ~/catkin_ws/src;pwd;cd ~/catkin_ws/;pwd;catkin_make',
#                             # 'source ~/catkin_ws/devel/setup.bash'
#                             # 'cd /tmp/;pwd;sudo wget https://files.phpmyadmin.net/phpMyAdmin/5.1.0/phpMyAdmin-5.1.0-all-languages.tar.gz -q;tar -zxvf phpMyAdmin-5.1.0-all-languages.tar.gz;sudo rm phpMyAdmin-5.1.0-all-languages.tar.gz;sudo mv phpMyAdmin-5.1.0-all-languages /var/www/html/phpmyadmin'
#                             'sudo apt install python3-catkin-tools -y',
#                             'cd /home/使用者;pwd;mkdir -p ~/catkin_ws/src;pwd;cd /home/使用者/catkin_ws/;pwd;catkin_make'
#                             # 'cd /home/使用者;pwd;catkin_make',
#                             # 'cd ~/catkin_ws/src;pwd;catkin_make '
#                         ]

#             for command in D['command']:
#                 if '使用者' in command :
#                     command = command.replace('使用者', username)
#                 print(command)
#                 stdin, stdout, stderr = ssh.exec_command(command)
#                 command_start_time = time.time()
#                 # sl(6)      # Rita 原本為 sl(6) 增加後觀察是否 clone 輸出會改變
#                 # Rita 0406 stdout(success)、stderr(error) 每次只會輸出其中一個, 以此做為判斷, 例如：
#                 # print('=========================================')
#                 # print('stdout: ', stdout.read().decode())
#                 # print('stderr: ', stderr.read().decode())
#                 # print('=========================================')
#                 # 輸出為：
#                 # =========================================
#                 # stdout:  正在讀取套件清單...
#                 # 正在重建相依關係...
#                 # 正在讀取狀態資料...
#                 # python3.8 is already the newest version (3.8.0-3ubuntu1~18.04.2).
#                 # 升級 0 個，新安裝 0 個，移除 0 個，有 208 個未被升級。
#                 # stderr:
#                 # =========================================
                
#                 error = stderr.read().decode()
#                 success = stdout.read().decode()
#                 # print('error: ', error, '\nlen(error): ', len(error))
#                 print('error: ', error, '\nlen(error): ')
#                 print('success: ', success, '\nlen(success): ')
#                 if len(success) > 200000:
#                     success = success[0:20000] + '... etc'

#                 execution_time = round(time.time() - command_start_time, 3)
#                 if error:
#                     print('error')
#                     print(error)
#                     if item_install_fail == 0:
#                         item_install_fail = 1
#                     with open('ItemFile.csv', 'a', newline='') as csvFile:
#                         csvWriter = csv.writer(csvFile)
#                         csvWriter.writerow([command.replace(';', ';\n'), 
#                                             'success: \n' + success + '\n' + 'error: \n' + error, 
#                                             # 'success: \n' + success, 
#                                             # 'error: \n' + error, 
#                                             execution_time, 
#                                             'error'])
#                     socketio.emit('stderr', error, namespace='/test_conn')
#                 else:
#                     print('success')
#                     print(success)
#                     with open('ItemFile.csv', 'a', newline='') as csvFile:
#                         csvWriter = csv.writer(csvFile)
#                         csvWriter.writerow([command.replace(';', ';\n'), 
#                                             'success: \n' + success + '\nerror: \n' + error, 
#                                             execution_time, 
#                                             'success'])
#                     socketio.emit('stdout', success, namespace='/test_conn')

#                 sl(1)
#                 print('-----------------------------------------------------------------------------')

#             # Rita 0406 本來就註解
#             # def sshJob():
#             #     for command in content:
#             #         stdin, stdout, stderr = ssh.exec_command(command)
#             #     #
#             #     #     # print(stdout.read().decode())
#             #     #     # print('----------------------------------------')
#             #     #     # print(stderr.read().decode())
#             #     #
#             #         print(stdin)
#             #         if stderr.read().decode():
#             #             L.append(0)
#             #             print('error')
#             #             socketio.emit('stderr', stderr.read().decode())
#             #         else:
#             #             L.append(1)
#             #             print('success')
#             #             socketio.emit('stdout', stdout.read().decode())
#             #         sl(5)
#             #     ssh.close()

#             # Rita 0406 本來就註解
#             # def sshJob():
#             #     sl(5)
#             #     i = 0
#             #     total = len(content)
#             #     while True:
#             #         stdin, stdout, stderr = ssh.exec_command(content[i])
#             #     #
#             #     #     # print(stdout.read().decode())
#             #     #     # print('----------------------------------------')
#             #     #     # print(stderr.read().decode())
#             #     #
#             #         if stderr.read().decode():
#             #             L.append(0)
#             #             print('error')
#             #             socketio.emit('stderr', stderr.read().decode())
#             #         else:
#             #             L.append(1)
#             #             print('success')
#             #             socketio.emit('stdout', stdout.read().decode())
#             #         sl(5)
#             #         i += 1
#             #         if i == total:
#             #             break
#             #     ssh.close()

#             # ssh_thread = threading.Thread(target=sshJob)
#             # ssh_thread.daemon = True
#             # ssh_thread.start()

#             # global thread
#             # with thread_lock:
#             #     if thread is None:
#             #         thread = socketio.start_background_task(target=sshJob)

#             # print(L)
#             #
#             # item_list = ItemList()
#             # item_list.ip = ip
#             # item_list.pymysql = L[0]
#             # item_list.eventlet = L[1]
#             # datetime = dt.now()
#             # item_list.datetime = datetime
#             # db.session.add(item_list)
#             # db.session.commit()

#             # 關閉寫入的 CSV 檔案
#             csvFile.close()

#             # 關閉連線
#             ssh.close()
#             if item_install_fail:
#                 res = '有套件未安裝完成!'
#             else:
#                 res = '建置完成!'
#             return res
#         except Exception as e:
#             print(e)
#             return str(e)

Automatic_Build_System = {
    'python3.8': '0',
    'python3-pip': '0',
    'cryptography': '0',
    'upgrade': '0',
    'grep': '0',
    'git': '0',
    'gitpython': '0',
    'python3-tk': '0',
    'wget': '0',
    'python3-dev': '0',
    'default-libmysqlclient-dev': '0',
    'build-essential': '0',
    'tasksel': '0',
    'lamp-server': '0',
    'phpMyAdmin-5.1.0-all-languages.tar.gz': '0',
    'openssl': '0',
    'php-common': '0',
    'php-curl': '0',
    'php-json': '0',
    'php-mbstring': '0',
    'php-mysql': '0',
    'php-xml': '0',
    'php-zip': '0',
    'php7.2-mbstring': '0',
    'php7.2-xml': '0',
    'php7.2-mysql': '0',
    'php7.2-common': '0',
    'php7.2-curl': '0',
    'php7.2-json': '0',
    'php7.2-zip': '0',
    'apache2': '0',
    'paho-mqtt': '0',
    'mosquitto': '0',
    'mqtt_server_setting': '0',
    'rclocal/rc.local': '0',
    'golang': '0',
    'gogsfile.git': '0',
    'requirements': '0',
    'CoffeeProject.git': '0',
    'BBend-Test-JWT.git': '0',
    'Coffee_MySQL.sql': '0',
    'chrony': '0',
    'ntpdate': '0',
    '--keyserver': '0',
    'update': '0',
    'ros-melodic-desktop-full': '0',
    'ros-melodic-rqt*': '0',
    'python-rosdep': '0',
    'python-rosinstall': '0',
    'python-rosinstall-generator': '0',
    'python-wstool': '0',
    'catkin_make': '0'
}

@app.route('/ABS_update', methods=['POST', 'GET'])
def ABS_update():
    return Automatic_Build_System

# 0413 測試中, 原版在上方
@app.route('/add_server', methods=['POST', 'GET'])
def add_server_views():
    username = session['uname']
    L = []
    if request.method == 'GET':
        # ============================================================================================
        # # 232 路徑
        Users = os.popen("getent passwd 1000 | cut -d: -f1")
        UserFile = Users.read().strip()
        print("UserFile:", UserFile)

        os.system('git clone -b sh --single-branch http://60.250.156.230:3000/Automatic_build_system/Automatically_install_files.git /home/' + UserFile + '/BBend-Test-JWT/newSH')
        with open('/home/' + UserFile + '/BBend-Test-JWT/newSH/coffeesystem.sh', encoding='utf-8') as f:
            D['command'] = f.read().split('\n')
        sl(3)
        shutil.rmtree('/home/' + UserFile + '/BBend-Test-JWT/newSH', onerror=remove_readonly)
        with open('/home/' + UserFile + '/BBend-Test-JWT/Item.txt') as f:
            D['item_name'] = f.read().split('\n')
            for item in D['item_name']:
                L.append('.'.join(item.split('.')[1:]))         # 拿掉 '.'.join 的話會變成 [['python3', '8'], ['python3-pip'],
    
        # ============================================================================================
        # # # 本機 路徑
        # os.system('git clone -b sh --single-branch http://60.250.156.230:3000/Automatic_build_system/Automatically_install_files.git C:/Users/USER/Rita/operating/sixthproject/BBend-Test-JWT/newSH')
        # with open('C:/Users/USER/Rita/operating/sixthproject/BBend-Test-JWT/newSH/coffeesystem.sh', encoding='utf-8') as f:
        #     D['command'] = f.read().split('\n')
        # # print("D['command']: ", D['command'])
        # sl(3)
        # shutil.rmtree('newSH', onerror=remove_readonly)
        # with open('Item.txt') as f:
        #     D['item_name'] = f.read().split('\n')
        #     for item in D['item_name']:
        #         L.append('.'.join(item.split('.')[1:]))         # 拿掉 '.'.join 的話會變成 [['python3', '8'], ['python3-pip'],
        # # ============================================================================================

        sl(3)
        L2= []
        for i in range(0, len(D['command'])):
            if D['command'][i] == "'" or D['command'][i] == '' or "#" in D['command'][i] or D['command'][i] == ' ':
                continue
            L2.append(D['command'][i])
        D['command'] = L2

        # # ===========================================================================================================

        
        return render_template('add_server.html', params=locals())
    else:
        item_install_fail = 0
        d = request.form.to_dict()
        ip = d['ip']
        loginname = d['loginname']
        username = d['username']
        password = d['password']
        print(ip)
        print(loginname)
        print(username)
        print(password)
        try:
            # Rita 0428 測試
            # 建立一個sshclient物件
            ssh = paramiko.SSHClient()
            # 允許將信任的主機自動加入到host_allow 列表，此方法必須放在connect方法的前面
            ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
            # 指定本地的RSA私鑰檔案,如果建立金鑰對時設定的有密碼，password為設定的密碼，如無不用指定password引數
            # pkey = paramiko.RSAKey.from_private_key_file('/home/super/.ssh/id_rsa', password='12345')
            # pkey = paramiko.RSAKey.from_private_key_file('/home/ptop/topicjie/scripts/keys/id_rsa')
            # 建立連線
            ssh.connect(hostname=ip,
                        port=22,
                        username=loginname,
                        password=password)
            # 假如帳號密碼正確沒有被捕捉到異常，傳送訊息給前端
            # socketio.emit('user-confirm', 'pass', namespace='/test_conn')

            # content = D['item_name'] + D['command']
            with open('../ItemFile.csv', 'w', newline='') as csvFile:
                csvWriter = csv.writer(csvFile)
                csvWriter.writerow(['Command', 'Install Content', 'Time', 'Status'])
            
            # # # Rita TEST
            # D['command'] = [
            #     "sudo apt-get install tasksel -y",
            #     "sudo DEBIAN_FRONTEND=noninteractive tasksel install lamp-server",
            #     "sudo -H pip3 install paho-mqtt",
            #     "sudo apt-get install mosquitto -y",
                
            # ]

            for command in D['command']:
                if '使用者' in command :
                    command = command.replace('使用者', username)
                if 'sudo apt-get install' in command :
                    command = command.replace('sudo apt-get install', "sudo DEBIAN_FRONTEND=noninteractive apt-get install")
                print(command)
                # 判斷若此 command 符合 Automatic_Build_System 的 Key, 則改變狀態
                for key, value in Automatic_Build_System.items():
                    if key in command and value == '0':
                        print('key: ', key, ' / command: ', command)
                        Automatic_Build_System[key] = "Install"

                        # # 0429 測試用
                        # import random
                        # tt = round(random.uniform(10.0,20.0), 3)
                        # sl(tt)
                        # Automatic_Build_System[key] = tt

                sl(1)
                command_start_time = time.time()

                # 0504 Rita 測試
                stdin, stdout, stderr = ssh.exec_command(command)
                error = stderr.read().decode()
                success = stdout.read().decode()
                # print('error: ', error, '\nlen(error): ', len(error))
                print('error: ', error)
                print('success: ', success)
                if len(success) > 200000:
                    success = success[0:20000] + '... etc'
                    
                execution_time = round(time.time() - command_start_time, 3)

                if error:
                    # 排除 錯誤訊息中的 警告訊息
                    Warning_list = [
                        "WARNING: Running pip as the 'root' user can result in broken permissions and conflicting behaviour with the system package manager.", 
                        "Cloning into", 
                        "Warning: apt-key output should not be parsed (stdout is not a terminal)", 
                        "gpg", 
                        "Warning: running 'rosdep update' as root is not recommended.", 
                        "You should run",
                        "[Warning] Using a password on the command line interface can be insecure."
                    ]
                    error_command_list = error.split('\n')
                    for_error_command_list = error_command_list.copy()
                    # print("a: ", a)
                    # print("a[0]: ", a[0])
                    for cl in range(0, len(error_command_list)):
                        # print("=================================")
                        # print("error_command_list[cl]: ", error_command_list[cl])
                        for W in range(len(Warning_list)):
                        # for W in range(len(error_command_list)):
                            try:
                                if Warning_list[W] in error_command_list[cl]:
                                    # print("AA: ", Warning_list[W])
                                    # print("BB: ", error_command_list[cl])
                                    # #  and error_command_list.index(Warning_list[W]) != -1
                                    # # command_index = error_command_list[0].index(Warning_list[W])
                                    # # print(command_index)
                                    for_error_command_list.remove(error_command_list[cl])
                                    # print(error_command_list)
                                    # print(for_error_command_list)
                            except IndexError:
                                pass
                    if for_error_command_list == [''] or for_error_command_list == []:
                        print('=== Warning ===')
                        with open('../ItemFile.csv', 'a', newline='') as csvFile:
                            csvWriter = csv.writer(csvFile)
                            csvWriter.writerow([command.replace(';', ';\n'), 
                                                'success: \n' + success + '\n' + 'error: \n' + error, 
                                                # 'success: \n' + success, 
                                                # 'error: \n' + error, 
                                                execution_time, 
                                                'warning'])
                        # socketio.emit('stderr', error, namespace='/test_conn')
                        # 判斷若此 command 符合 Automatic_Build_System 的 Key, 則改變狀態
                        for key, value in Automatic_Build_System.items():
                            if key in command:
                                Automatic_Build_System[key] = execution_time
                    else:
                        print('for_error_command_list: ', for_error_command_list)
                        print('=== error ===')

                        if item_install_fail == 0:
                            item_install_fail = 1
                        with open('../ItemFile.csv', 'a', newline='') as csvFile:
                            csvWriter = csv.writer(csvFile)
                            csvWriter.writerow([command.replace(';', ';\n'), 
                                                'success: \n' + success + '\n' + 'error: \n' + error, 
                                                # 'success: \n' + success, 
                                                # 'error: \n' + error, 
                                                execution_time, 
                                                'error'])
                        # socketio.emit('stderr', error, namespace='/test_conn')
                        # 判斷若此 command 符合 Automatic_Build_System 的 Key, 則改變狀態
                        for key, value in Automatic_Build_System.items():
                            if key in command:
                                Automatic_Build_System[key] = "Error"
                else:
                    print('=== success ===')

                    with open('../ItemFile.csv', 'a', newline='') as csvFile:
                        csvWriter = csv.writer(csvFile)
                        csvWriter.writerow([command.replace(';', ';\n'), 
                                            'success: \n' + success + '\nerror: \n' + error, 
                                            execution_time, 
                                            'success'])
                    # socketio.emit('stdout', success, namespace='/test_conn')
                    # 判斷若此 command 符合 Automatic_Build_System 的 Key, 則改變狀態
                    for key, value in Automatic_Build_System.items():
                        if key in command:
                            Automatic_Build_System[key] = execution_time
                
                sl(5)     # Rita 原本為 sl(6) 增加後觀察是否 clone 輸出會改變
                print('-----------------------------------------------------------------------------')
                
            # print("Automatic_Build_System: ")
            # print(Automatic_Build_System)
            with open('../ItemFile.csv', 'a', newline='') as csvFile:
                csvWriter = csv.writer(csvFile)
                csvWriter.writerow(['',
                                    'Automatic_Build_System: \n' + str(Automatic_Build_System),  
                                    '', 
                                    ''])

            # 關閉連線
            ssh.close()
            if item_install_fail:
                res = '有套件未安裝完成!'
            else:
                res = '建置完成!'
            return res
        except Exception as e:
            print(e)
            return str(e)



#mqtt發布
@app.route('/mqtt', methods=['GET','POST'])
def mqtt_views():
    import json
    dict = request.args.to_dict()
    json = json.dumps(dict)
    print(json)
    mqtt.publish('AISKY/AppleFarm/MK-G/b8:27:eb:f8:24:92', json)
    return "Publish done"


#mqtt訂閱
@mqtt.on_connect()
def handle_connect(client, userdata, flags, rc):
    mqtt.subscribe('AISKY/AppleFarm/MK-G/b8:27:eb:f8:24:92/Log')

#處理mqtt訂閱的信息
@mqtt.on_message()
def handle_mqtt_message(client, userdata, message):
    payload = message.payload.decode()
    # p = json.loads(payload)
    # print("-------msg-------")
    # print('name  :', p['name'])
    # print('email :', p['email'])
    print(payload)

#調用日誌訊息
@mqtt.on_log()
def handle_logging(client, userdata, level, buf):
    print(level, buf)

#自動關閉所有未使用、掛著的連接
@app.teardown_appcontext
def shutdown_session(exception=None):
        db.session.remove()

if __name__ == '__main__':
    # Rita 0406 socketio.run(app, debug=True, host='0.0.0.0', port=5014)
    # Rita 0406 app.run(debug=True, host='0.0.0.0', port=5014)
    # print("===== BBend =====")
    # socketio.run(app, debug=True, host='0.0.0.0', port=5014)
    app.run(debug=True, host='0.0.0.0', port=5014)