github
/
certd
mirror of https://github.com/certd/certd
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: doc

pull/78/head
xiaojunnuo 2024-06-26 13:58:17 +08:00
parent 6c9ed162e3
commit ae0f16bf35
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
packages/ui/certd-server/src/plugins/plugin-host/lib/ssh.ts
View File

@ -45,12 +45,13 @@ export class AsyncSsh2Client {
async fastPut(options: { sftp: any; localPath: string; remotePath: string }) { async fastPut(options: { sftp: any; localPath: string; remotePath: string }) {
const { sftp, localPath, remotePath } = options; const { sftp, localPath, remotePath } = options;
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
this.logger.info(`上传文件：${localPath} => ${remotePath}`); this.logger.info(`开始上传：${localPath} => ${remotePath}`);
sftp.fastPut(localPath, remotePath, (err: Error) => { sftp.fastPut(localPath, remotePath, (err: Error) => {
if (err) { if (err) {
reject(err); reject(err);
return; return;
} }
this.logger.info(`上传文件成功：${localPath} => ${remotePath}`);
resolve({}); resolve({});
}); });
}); });
@ -139,12 +140,12 @@ export class SshClient {
connectConf, connectConf,
callable: async (conn: AsyncSsh2Client) => { callable: async (conn: AsyncSsh2Client) => {
const sftp = await conn.getSftp(); const sftp = await conn.getSftp();
this.logger.info('开始上传');
for (const transport of transports) { for (const transport of transports) {
this.logger.info('上传文件：', JSON.stringify(transport));
await conn.exec(`mkdir -p ${path.dirname(transport.remotePath)} `); await conn.exec(`mkdir -p ${path.dirname(transport.remotePath)} `);
await conn.fastPut({ sftp, ...transport }); await conn.fastPut({ sftp, ...transport });
} }
this.logger.info('文件上传成功'); this.logger.info('文件全部上传成功');
}, },
}); });
} }