import asyncio

import asyncssh

basedir = '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/*'

stp_list = [
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/common', '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/common'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/core', '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/core'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/db', '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/db'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/rpc_api', '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/rpc_api'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/rpc_business',
     '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/rpc_business'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/softwares',
     '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/softwares'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/rpc_main.py',
     '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/rpc_main.py'),
    ('C:/Users/wuyuhang/PycharmProjects/PythonServiceDeployment/requirements.txt',
     '/home/pydep-user/PythonServiceDeployment/projects/PythonServiceDeployment/requirements.txt'),

]


async def run():
    async with asyncssh.connect(host='120.48.58.131', username='pydep-user', password='lhpffzy4', known_hosts=None) as conn:
        await conn.run(f'rm -rf {basedir}')
        async with conn.start_sftp_client() as sftp:
            for source, dist in stp_list:
                await sftp.put(source, dist, recurse=True)
                await sftp.open()
                print(f'{source}上传完成')


if __name__ == '__main__':
    asyncio.run(run())