270
}
271
272
>
function sshExec(client: SSHClient, command: string, opts?: { ignoreExitCode?: boolean }): Promise<{ stdout: string; stderr: string; code: number }> {
sshRemoteAgentHostService.ts
273
>
return new Promise<{ stdout: string; stderr: string; code: number }>((resolve, reject) => {
274
>
client.exec(command, (err: Error | undefined, stream: SSHChannel) => {
275
>
if (err) {
276
reject(err);
277
return;
278
}
280
>
let stdout = '';
281
>
let stderr = '';
282
>
let settled = false;
283
>
284
>
const finish = (error: Error | undefined, code: number | undefined) => {
285
>
if (settled) {
286
return;
287
}
289
>
if (error) {
290
reject(error);
291
return;
292
}
294
reject(new Error(`SSH command failed (exit ${code}): ${command}\nstderr: ${stderr}`));
296
>
resolve({ stdout, stderr, code: code ?? 0 });
297
>
}
298
>
};
299
>
300
>
stream.on('data', (data: Buffer) => { stdout += data.toString(); });
301
>
stream.stderr.on('data', (data: Buffer) => { stderr += data.toString(); });
302
>
stream.on('error', (streamErr: Error) => finish(streamErr, undefined));
303
>
stream.on('close', (code: number) => finish(undefined, code));
304
>
});
305
>
});
306
>
}
307
308
/** Create a bound exec function for the given SSH client. */
309
>
function bindSshExec(client: SSHClient): (command: string, opts?: { ignoreExitCode?: boolean }) => Promise<{ stdout: string; stderr: string; code: number }> {
sshRemoteAgentHostService.ts
310
>
return (command, opts) => sshExec(client, command, opts);
311
>
}
312
313
function startRemoteAgentHost(