code-server/src/node/coder_cloud.ts

42 lines
1.1 KiB
TypeScript
Raw Normal View History

2020-09-09 07:39:17 +08:00
import { logger } from "@coder/logger"
2020-09-09 12:06:28 +08:00
import { spawn } from "child_process"
import path from "path"
import split2 from "split2"
2020-09-09 12:03:01 +08:00
2020-10-10 00:57:48 +08:00
// https://github.com/cdr/coder-cloud
2020-09-09 12:03:01 +08:00
const coderCloudAgent = path.resolve(__dirname, "../../lib/coder-cloud-agent")
2020-09-09 07:39:17 +08:00
function runAgent(...args: string[]): Promise<void> {
logger.debug(`running agent with ${args}`)
const agent = spawn(coderCloudAgent, args, {
2020-09-09 07:39:17 +08:00
stdio: ["inherit", "inherit", "pipe"],
})
2020-09-09 12:06:28 +08:00
agent.stderr.pipe(split2()).on("data", (line) => {
2020-09-09 07:39:17 +08:00
line = line.replace(/^[0-9-]+ [0-9:]+ [^ ]+\t/, "")
logger.info(line)
})
return new Promise((res, rej) => {
agent.on("error", rej)
2020-09-09 12:06:28 +08:00
agent.on("close", (code) => {
2020-09-09 07:39:17 +08:00
if (code !== 0) {
rej({
message: `coder cloud agent exited with ${code}`,
})
return
}
res()
})
})
}
2020-09-09 12:03:01 +08:00
export function coderCloudBind(csAddr: string, serverName = ""): Promise<void> {
2020-09-09 12:03:01 +08:00
// addr needs to be in host:port format.
// So we trim the protocol.
csAddr = csAddr.replace(/^https?:\/\//, "")
return runAgent("bind", `--code-server-addr=${csAddr}`, serverName)
2020-09-09 12:03:01 +08:00
}