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

fixed #73

pull/78/head
ltxhhz 2024-07-03 18:30:38 +08:00
parent d46dab4fdd
commit 22ebcd4dd1
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -77,7 +77,7 @@ export class AsyncSsh2Client {
reject(err);
return;
}
let data: string = null;
let data: string = '';
stream
.on('close', (code: any, signal: any) => {
this.logger.info(`[${this.connConf.host}][close]:code:${code}`);
@ -88,12 +88,14 @@ export class AsyncSsh2Client {
}
})
.on('data', (ret: Buffer) => {
data = this.convert(ret)
this.logger.info(`[${this.connConf.host}][info]: ` + data);
const out = this.convert(ret)
data += out
this.logger.info(`[${this.connConf.host}][info]: ` + out.trimEnd());
})
.stderr.on('data', (ret:Buffer) => {
data = this.convert(ret)
this.logger.info(`[${this.connConf.host}][error]: ` + data);
const err = this.convert(ret)
data += err
this.logger.info(`[${this.connConf.host}][error]: ` + err.trimEnd());
});
});
});
@ -167,7 +169,12 @@ export class SshClient {
this.logger.info("请注意：windows下，文件目录分隔应该写成\\而不是/")
this.logger.info("--------------------------")
}
mkdirCmd = `if not exist "${filePath}" mkdir ${filePath} `
const spec = await conn.exec(`echo %COMSPEC%`);
if (spec.toString().trim() === '%COMSPEC%') {
mkdirCmd = `New-Item -ItemType Directory -Path "${filePath}" -Force`;
} else {
mkdirCmd = `if not exist "${filePath}" mkdir "${filePath}"`;
}
}
await conn.exec(mkdirCmd);
await conn.fastPut({ sftp, ...transport });