Michael Li
af8655ec45
* test(e2e): Update imports to match boundary-http conventions * test(e2e): Remove cli from method name
111 lines
2.7 KiB
JavaScript
111 lines
2.7 KiB
JavaScript
/**
|
|
* Copyright (c) HashiCorp, Inc.
|
|
* SPDX-License-Identifier: BUSL-1.1
|
|
*/
|
|
|
|
import { execSync } from 'node:child_process';
|
|
import { nanoid } from 'nanoid';
|
|
|
|
/**
|
|
* Creates a TCP target.
|
|
* @param {string} projectId ID of the project under which the target will be created.
|
|
* @returns {Promise<string>} new target's ID
|
|
*/
|
|
export async function createTcpTarget(projectId) {
|
|
const targetName = 'target-' + nanoid();
|
|
const defaultPort = 22;
|
|
let target;
|
|
try {
|
|
target = JSON.parse(
|
|
execSync(
|
|
`boundary targets create tcp \
|
|
-default-port ${defaultPort} \
|
|
-name ${targetName} \
|
|
-scope-id ${projectId} \
|
|
-format json`,
|
|
),
|
|
).item;
|
|
} catch (e) {
|
|
console.log(`${e.stderr}`);
|
|
}
|
|
return target.id;
|
|
}
|
|
|
|
/**
|
|
* Creates a SSH target
|
|
* @param {string} projectId ID of the project under which the target will be created.
|
|
* @returns {Promise<string>} new target's ID
|
|
*/
|
|
export async function createSshTarget(projectId) {
|
|
const targetName = 'target-' + nanoid();
|
|
const defaultPort = 22;
|
|
let target;
|
|
try {
|
|
target = JSON.parse(
|
|
execSync(
|
|
`boundary targets create ssh \
|
|
-default-port ${defaultPort} \
|
|
-name ${targetName} \
|
|
-scope-id ${projectId} \
|
|
-format json`,
|
|
),
|
|
).item;
|
|
} catch (e) {
|
|
console.log(`${e.stderr}`);
|
|
}
|
|
return target.id;
|
|
}
|
|
|
|
/**
|
|
* Authorizes a session given an alias
|
|
* @param {string} alias alias of the target to be connected to
|
|
* @returns Session information
|
|
*/
|
|
export async function authorizeSessionByAlias(alias) {
|
|
let session;
|
|
try {
|
|
session = JSON.parse(
|
|
execSync(`boundary targets authorize-session ${alias} -format json`),
|
|
);
|
|
} catch (e) {
|
|
throw new Error(`Failed to connect to alias: ${e.stderr}`);
|
|
}
|
|
return session;
|
|
}
|
|
|
|
/**
|
|
* Authorizes a session given a target id
|
|
* @param {string} targetId Id of the target to be connected to
|
|
* @returns Session information
|
|
*/
|
|
export async function authorizeSessionByTargetId(targetId) {
|
|
let session;
|
|
try {
|
|
session = JSON.parse(
|
|
execSync(
|
|
`boundary targets authorize-session -id ${targetId} -format json`,
|
|
),
|
|
);
|
|
} catch (e) {
|
|
throw new Error(`Failed to connect to target: ${e.stderr}`);
|
|
}
|
|
return session;
|
|
}
|
|
|
|
/**
|
|
* Gets Target ID from Target Name
|
|
* @param {string} projectId ID of the project under which the target exists
|
|
* @param {string} targetName Name of the target
|
|
* @returns {Promise<string>} ID of the target
|
|
*/
|
|
export async function getTargetIdFromName(projectId, targetName) {
|
|
const targets = JSON.parse(
|
|
execSync(`boundary targets list -scope-id ${projectId} -format json`),
|
|
);
|
|
const target = targets.items.filter((obj) => obj.name == targetName)[0];
|
|
if (target) {
|
|
return target.id;
|
|
}
|
|
return null;
|
|
}
|