Digimer
2 years ago
committed by
GitHub
commit
f9c5a30ea4
320 changed files with 20465 additions and 1912 deletions
@ -0,0 +1,5 @@ |
|||||||
|
# dependencies |
||||||
|
node_modules |
||||||
|
|
||||||
|
# output |
||||||
|
out |
||||||
@ -0,0 +1,14 @@ |
|||||||
|
{ |
||||||
|
"env": { |
||||||
|
"es2022": true, |
||||||
|
"node": true |
||||||
|
}, |
||||||
|
"extends": [ |
||||||
|
"eslint:recommended", |
||||||
|
"plugin:import/errors", |
||||||
|
"plugin:import/typescript", |
||||||
|
"plugin:import/warnings", |
||||||
|
"prettier" |
||||||
|
], |
||||||
|
"plugins": ["import"] |
||||||
|
} |
||||||
@ -0,0 +1,5 @@ |
|||||||
|
# dependencies |
||||||
|
node_modules |
||||||
|
|
||||||
|
# output |
||||||
|
out |
||||||
@ -1,18 +0,0 @@ |
|||||||
const cors = require('cors'); |
|
||||||
const express = require('express'); |
|
||||||
const path = require('path'); |
|
||||||
|
|
||||||
const API_ROOT_PATH = require('./lib/consts/API_ROOT_PATH'); |
|
||||||
|
|
||||||
const echoRouter = require('./routes/echo'); |
|
||||||
const filesRouter = require('./routes/files'); |
|
||||||
|
|
||||||
const app = express(); |
|
||||||
|
|
||||||
app.use(express.json()); |
|
||||||
app.use(cors()); |
|
||||||
|
|
||||||
app.use(path.join(API_ROOT_PATH, 'echo'), echoRouter); |
|
||||||
app.use(path.join(API_ROOT_PATH, 'files'), filesRouter); |
|
||||||
|
|
||||||
module.exports = app; |
|
||||||
@ -1,94 +0,0 @@ |
|||||||
const { spawnSync } = require('child_process'); |
|
||||||
|
|
||||||
const SERVER_PATHS = require('./consts/SERVER_PATHS'); |
|
||||||
|
|
||||||
const execStrikerAccessDatabase = ( |
|
||||||
args, |
|
||||||
options = { |
|
||||||
timeout: 10000, |
|
||||||
encoding: 'utf-8', |
|
||||||
}, |
|
||||||
) => { |
|
||||||
const { error, stdout, stderr } = spawnSync( |
|
||||||
SERVER_PATHS.usr.sbin['striker-access-database'].self, |
|
||||||
args, |
|
||||||
options, |
|
||||||
); |
|
||||||
|
|
||||||
if (error) { |
|
||||||
throw error; |
|
||||||
} |
|
||||||
|
|
||||||
if (stderr) { |
|
||||||
throw new Error(stderr); |
|
||||||
} |
|
||||||
|
|
||||||
let output; |
|
||||||
|
|
||||||
try { |
|
||||||
output = JSON.parse(stdout); |
|
||||||
} catch (stdoutParseError) { |
|
||||||
output = stdout; |
|
||||||
|
|
||||||
console.warn( |
|
||||||
`Failed to parse striker-access-database output [${output}]; error: [${stdoutParseError}]`, |
|
||||||
); |
|
||||||
} |
|
||||||
|
|
||||||
return { |
|
||||||
stdout: output, |
|
||||||
}; |
|
||||||
}; |
|
||||||
|
|
||||||
const execDatabaseModuleSubroutine = (subName, subParams, options) => { |
|
||||||
const args = ['--sub', subName]; |
|
||||||
|
|
||||||
if (subParams) { |
|
||||||
args.push('--sub-params', JSON.stringify(subParams)); |
|
||||||
} |
|
||||||
|
|
||||||
const { stdout } = execStrikerAccessDatabase(args, options); |
|
||||||
|
|
||||||
return { |
|
||||||
stdout: stdout['sub_results'], |
|
||||||
}; |
|
||||||
}; |
|
||||||
|
|
||||||
const accessDB = { |
|
||||||
dbJobAnvilSyncShared: ( |
|
||||||
jobName, |
|
||||||
jobData, |
|
||||||
jobTitle, |
|
||||||
jobDescription, |
|
||||||
{ jobHostUUID } = { jobHostUUID: undefined }, |
|
||||||
) => { |
|
||||||
const subParams = { |
|
||||||
file: __filename, |
|
||||||
line: 0, |
|
||||||
job_command: SERVER_PATHS.usr.sbin['anvil-sync-shared'].self, |
|
||||||
job_data: jobData, |
|
||||||
job_name: `storage::${jobName}`, |
|
||||||
job_title: `job_${jobTitle}`, |
|
||||||
job_description: `job_${jobDescription}`, |
|
||||||
job_progress: 0, |
|
||||||
}; |
|
||||||
|
|
||||||
if (jobHostUUID) { |
|
||||||
subParams.job_host_uuid = jobHostUUID; |
|
||||||
} |
|
||||||
|
|
||||||
console.log(JSON.stringify(subParams, null, 2)); |
|
||||||
|
|
||||||
return execDatabaseModuleSubroutine('insert_or_update_jobs', subParams) |
|
||||||
.stdout; |
|
||||||
}, |
|
||||||
dbQuery: (query, options) => |
|
||||||
execStrikerAccessDatabase(['--query', query], options), |
|
||||||
dbSub: execDatabaseModuleSubroutine, |
|
||||||
dbSubRefreshTimestamp: () => |
|
||||||
execDatabaseModuleSubroutine('refresh_timestamp').stdout, |
|
||||||
dbWrite: (query, options) => |
|
||||||
execStrikerAccessDatabase(['--query', query, '--mode', 'write'], options), |
|
||||||
}; |
|
||||||
|
|
||||||
module.exports = accessDB; |
|
||||||
@ -1,3 +0,0 @@ |
|||||||
const API_ROOT_PATH = '/api'; |
|
||||||
|
|
||||||
module.exports = API_ROOT_PATH; |
|
||||||
@ -1,34 +0,0 @@ |
|||||||
const path = require('path'); |
|
||||||
|
|
||||||
const SERVER_PATHS = { |
|
||||||
mnt: { |
|
||||||
shared: { |
|
||||||
incoming: {}, |
|
||||||
}, |
|
||||||
}, |
|
||||||
usr: { |
|
||||||
sbin: { |
|
||||||
'anvil-sync-shared': {}, |
|
||||||
'striker-access-database': {}, |
|
||||||
}, |
|
||||||
}, |
|
||||||
}; |
|
||||||
|
|
||||||
const generatePaths = ( |
|
||||||
currentObject, |
|
||||||
parents = path.parse(process.cwd()).root, |
|
||||||
) => { |
|
||||||
Object.keys(currentObject).forEach((pathKey) => { |
|
||||||
const currentPath = path.join(parents, pathKey); |
|
||||||
|
|
||||||
currentObject[pathKey].self = currentPath; |
|
||||||
|
|
||||||
if (pathKey !== 'self') { |
|
||||||
generatePaths(currentObject[pathKey], currentPath); |
|
||||||
} |
|
||||||
}); |
|
||||||
}; |
|
||||||
|
|
||||||
generatePaths(SERVER_PATHS); |
|
||||||
|
|
||||||
module.exports = SERVER_PATHS; |
|
||||||
@ -1,29 +0,0 @@ |
|||||||
const { dbQuery } = require('../../accessDB'); |
|
||||||
|
|
||||||
const buildGetFiles = (query) => (request, response) => { |
|
||||||
console.log('Calling CLI script to get data.'); |
|
||||||
|
|
||||||
let queryStdout; |
|
||||||
|
|
||||||
try { |
|
||||||
({ stdout: queryStdout } = dbQuery( |
|
||||||
typeof query === 'function' ? query(request) : query, |
|
||||||
)); |
|
||||||
} catch (queryError) { |
|
||||||
console.log(`Query error: ${queryError}`); |
|
||||||
|
|
||||||
response.status(500).send(); |
|
||||||
} |
|
||||||
|
|
||||||
console.log( |
|
||||||
`Query stdout (type=[${typeof queryStdout}]): ${JSON.stringify( |
|
||||||
queryStdout, |
|
||||||
null, |
|
||||||
2, |
|
||||||
)}`,
|
|
||||||
); |
|
||||||
|
|
||||||
response.json(queryStdout); |
|
||||||
}; |
|
||||||
|
|
||||||
module.exports = buildGetFiles; |
|
||||||
@ -1,25 +0,0 @@ |
|||||||
const buildGetFiles = require('./buildGetFiles'); |
|
||||||
|
|
||||||
const getFileDetail = buildGetFiles( |
|
||||||
(request) => |
|
||||||
`SELECT
|
|
||||||
fil.file_uuid, |
|
||||||
fil.file_name, |
|
||||||
fil.file_size, |
|
||||||
fil.file_type, |
|
||||||
fil.file_md5sum, |
|
||||||
fil_loc.file_location_uuid, |
|
||||||
fil_loc.file_location_active, |
|
||||||
anv.anvil_uuid, |
|
||||||
anv.anvil_name, |
|
||||||
anv.anvil_description |
|
||||||
FROM files AS fil |
|
||||||
JOIN file_locations AS fil_loc |
|
||||||
ON fil.file_uuid = fil_loc.file_location_file_uuid |
|
||||||
JOIN anvils AS anv |
|
||||||
ON fil_loc.file_location_anvil_uuid = anv.anvil_uuid |
|
||||||
WHERE fil.file_uuid = '${request.params.fileUUID}' |
|
||||||
AND fil.file_type != 'DELETED';`,
|
|
||||||
); |
|
||||||
|
|
||||||
module.exports = getFileDetail; |
|
||||||
@ -1,13 +0,0 @@ |
|||||||
const buildGetFiles = require('./buildGetFiles'); |
|
||||||
|
|
||||||
const getFilesOverview = buildGetFiles(` |
|
||||||
SELECT |
|
||||||
file_uuid, |
|
||||||
file_name, |
|
||||||
file_size, |
|
||||||
file_type, |
|
||||||
file_md5sum |
|
||||||
FROM files |
|
||||||
WHERE file_type != 'DELETED';`);
|
|
||||||
|
|
||||||
module.exports = getFilesOverview; |
|
||||||
File diff suppressed because one or more lines are too long
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,8 @@ |
|||||||
|
{ |
||||||
|
"extends": ["../.eslintrc.json", "plugin:@typescript-eslint/recommended"], |
||||||
|
"parser": "@typescript-eslint/parser", |
||||||
|
"parserOptions": { |
||||||
|
"project": "./tsconfig.json" |
||||||
|
}, |
||||||
|
"plugins": ["@typescript-eslint"] |
||||||
|
} |
||||||
@ -0,0 +1,18 @@ |
|||||||
|
import cors from 'cors'; |
||||||
|
import express from 'express'; |
||||||
|
import path from 'path'; |
||||||
|
|
||||||
|
import API_ROOT_PATH from './lib/consts/API_ROOT_PATH'; |
||||||
|
|
||||||
|
import routes from './routes'; |
||||||
|
|
||||||
|
const app = express(); |
||||||
|
|
||||||
|
app.use(express.json()); |
||||||
|
app.use(cors()); |
||||||
|
|
||||||
|
Object.entries(routes).forEach(([route, router]) => { |
||||||
|
app.use(path.join(API_ROOT_PATH, route), router); |
||||||
|
}); |
||||||
|
|
||||||
|
export default app; |
||||||
@ -1,6 +1,6 @@ |
|||||||
const app = require('./app'); |
import app from './app'; |
||||||
|
|
||||||
const SERVER_PORT = require('./lib/consts/SERVER_PORT'); |
import SERVER_PORT from './lib/consts/SERVER_PORT'; |
||||||
|
|
||||||
app.listen(SERVER_PORT, () => { |
app.listen(SERVER_PORT, () => { |
||||||
console.log(`Listening on localhost:${SERVER_PORT}.`); |
console.log(`Listening on localhost:${SERVER_PORT}.`); |
||||||
@ -0,0 +1,207 @@ |
|||||||
|
import { spawnSync, SpawnSyncOptions } from 'child_process'; |
||||||
|
|
||||||
|
import SERVER_PATHS from './consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { stderr as sherr, stdout as shout } from './shell'; |
||||||
|
|
||||||
|
const formatQuery = (query: string) => query.replace(/\s+/g, ' '); |
||||||
|
|
||||||
|
const execAnvilAccessModule = ( |
||||||
|
args: string[], |
||||||
|
options: SpawnSyncOptions = { |
||||||
|
encoding: 'utf-8', |
||||||
|
timeout: 10000, |
||||||
|
}, |
||||||
|
) => { |
||||||
|
const { error, stdout, stderr } = spawnSync( |
||||||
|
SERVER_PATHS.usr.sbin['anvil-access-module'].self, |
||||||
|
args, |
||||||
|
options, |
||||||
|
); |
||||||
|
|
||||||
|
if (error) { |
||||||
|
throw error; |
||||||
|
} |
||||||
|
|
||||||
|
if (stderr.length > 0) { |
||||||
|
throw new Error(stderr.toString()); |
||||||
|
} |
||||||
|
|
||||||
|
let output; |
||||||
|
|
||||||
|
try { |
||||||
|
output = JSON.parse(stdout.toString()); |
||||||
|
} catch (stdoutParseError) { |
||||||
|
output = stdout; |
||||||
|
|
||||||
|
sherr( |
||||||
|
`Failed to parse anvil-access-module output [${output}]; CAUSE: [${stdoutParseError}]`, |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
return { |
||||||
|
stdout: output, |
||||||
|
}; |
||||||
|
}; |
||||||
|
|
||||||
|
const execModuleSubroutine = ( |
||||||
|
subName: string, |
||||||
|
{ |
||||||
|
spawnSyncOptions, |
||||||
|
subModuleName, |
||||||
|
subParams, |
||||||
|
}: ExecModuleSubroutineOptions = {}, |
||||||
|
) => { |
||||||
|
const args = ['--sub', subName]; |
||||||
|
|
||||||
|
// Defaults to "Database" in anvil-access-module.
|
||||||
|
if (subModuleName) { |
||||||
|
args.push('--sub-module', subModuleName); |
||||||
|
} |
||||||
|
|
||||||
|
if (subParams) { |
||||||
|
args.push('--sub-params', JSON.stringify(subParams)); |
||||||
|
} |
||||||
|
|
||||||
|
shout( |
||||||
|
`...${subModuleName}->${subName} with params: ${JSON.stringify( |
||||||
|
subParams, |
||||||
|
null, |
||||||
|
2, |
||||||
|
)}`,
|
||||||
|
); |
||||||
|
|
||||||
|
const { stdout } = execAnvilAccessModule(args, spawnSyncOptions); |
||||||
|
|
||||||
|
return { |
||||||
|
stdout: stdout['sub_results'], |
||||||
|
}; |
||||||
|
}; |
||||||
|
|
||||||
|
const dbInsertOrUpdateJob = ( |
||||||
|
{ job_progress = 0, line = 0, ...rest }: DBJobParams, |
||||||
|
{ spawnSyncOptions }: DBInsertOrUpdateJobOptions = {}, |
||||||
|
) => |
||||||
|
execModuleSubroutine('insert_or_update_jobs', { |
||||||
|
spawnSyncOptions, |
||||||
|
subParams: { job_progress, line, ...rest }, |
||||||
|
}).stdout; |
||||||
|
|
||||||
|
const dbInsertOrUpdateVariable: DBInsertOrUpdateVariableFunction = ( |
||||||
|
subParams, |
||||||
|
{ spawnSyncOptions } = {}, |
||||||
|
) => |
||||||
|
execModuleSubroutine('insert_or_update_variables', { |
||||||
|
spawnSyncOptions, |
||||||
|
subParams, |
||||||
|
}).stdout; |
||||||
|
|
||||||
|
const dbJobAnvilSyncShared = ( |
||||||
|
jobName: string, |
||||||
|
jobData: string, |
||||||
|
jobTitle: string, |
||||||
|
jobDescription: string, |
||||||
|
{ jobHostUUID }: DBJobAnvilSyncSharedOptions = { jobHostUUID: undefined }, |
||||||
|
) => { |
||||||
|
const subParams: DBJobParams = { |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-sync-shared'].self, |
||||||
|
job_data: jobData, |
||||||
|
job_name: `storage::${jobName}`, |
||||||
|
job_title: `job_${jobTitle}`, |
||||||
|
job_description: `job_${jobDescription}`, |
||||||
|
}; |
||||||
|
|
||||||
|
if (jobHostUUID) { |
||||||
|
subParams.job_host_uuid = jobHostUUID; |
||||||
|
} |
||||||
|
|
||||||
|
return dbInsertOrUpdateJob(subParams); |
||||||
|
}; |
||||||
|
|
||||||
|
const dbQuery = (query: string, options?: SpawnSyncOptions) => { |
||||||
|
shout(formatQuery(query)); |
||||||
|
|
||||||
|
return execAnvilAccessModule(['--query', query], options); |
||||||
|
}; |
||||||
|
|
||||||
|
const dbSubRefreshTimestamp = () => |
||||||
|
execModuleSubroutine('refresh_timestamp').stdout; |
||||||
|
|
||||||
|
const dbWrite = (query: string, options?: SpawnSyncOptions) => { |
||||||
|
shout(formatQuery(query)); |
||||||
|
|
||||||
|
return execAnvilAccessModule(['--query', query, '--mode', 'write'], options); |
||||||
|
}; |
||||||
|
|
||||||
|
const getAnvilData = ( |
||||||
|
dataStruct: AnvilDataStruct, |
||||||
|
{ predata, ...spawnSyncOptions }: GetAnvilDataOptions = {}, |
||||||
|
) => |
||||||
|
execAnvilAccessModule( |
||||||
|
[ |
||||||
|
'--predata', |
||||||
|
JSON.stringify(predata), |
||||||
|
'--data', |
||||||
|
JSON.stringify(dataStruct), |
||||||
|
], |
||||||
|
spawnSyncOptions, |
||||||
|
).stdout; |
||||||
|
|
||||||
|
const getLocalHostUUID = () => { |
||||||
|
let result: string; |
||||||
|
|
||||||
|
try { |
||||||
|
result = execModuleSubroutine('host_uuid', { |
||||||
|
subModuleName: 'Get', |
||||||
|
}).stdout; |
||||||
|
} catch (subError) { |
||||||
|
throw new Error(`Failed to get localhost UUID; CAUSE: ${subError}`); |
||||||
|
} |
||||||
|
|
||||||
|
shout(`localHostUUID=[${result}]`); |
||||||
|
|
||||||
|
return result; |
||||||
|
}; |
||||||
|
|
||||||
|
const getPeerData: GetPeerDataFunction = ( |
||||||
|
target, |
||||||
|
{ password, port, ...restOptions } = {}, |
||||||
|
) => { |
||||||
|
const [ |
||||||
|
rawIsConnected, |
||||||
|
{ |
||||||
|
host_name: hostName, |
||||||
|
host_os: hostOS, |
||||||
|
host_uuid: hostUUID, |
||||||
|
internet: rawIsInetConnected, |
||||||
|
os_registered: rawIsOSRegistered, |
||||||
|
}, |
||||||
|
] = execModuleSubroutine('get_peer_data', { |
||||||
|
subModuleName: 'Striker', |
||||||
|
subParams: { password, port, target }, |
||||||
|
...restOptions, |
||||||
|
}).stdout as [connected: string, data: PeerDataHash]; |
||||||
|
|
||||||
|
return { |
||||||
|
hostName, |
||||||
|
hostOS, |
||||||
|
hostUUID, |
||||||
|
isConnected: rawIsConnected === '1', |
||||||
|
isInetConnected: rawIsInetConnected === '1', |
||||||
|
isOSRegistered: rawIsOSRegistered === 'yes', |
||||||
|
}; |
||||||
|
}; |
||||||
|
|
||||||
|
export { |
||||||
|
dbInsertOrUpdateJob as job, |
||||||
|
dbInsertOrUpdateVariable as variable, |
||||||
|
dbJobAnvilSyncShared, |
||||||
|
dbQuery, |
||||||
|
dbSubRefreshTimestamp, |
||||||
|
dbWrite, |
||||||
|
getAnvilData, |
||||||
|
getLocalHostUUID, |
||||||
|
getPeerData, |
||||||
|
execModuleSubroutine as sub, |
||||||
|
}; |
||||||
@ -0,0 +1,38 @@ |
|||||||
|
import call from './call'; |
||||||
|
import join from './join'; |
||||||
|
import { sanitize } from './sanitize'; |
||||||
|
|
||||||
|
const buildIDCondition = ( |
||||||
|
keys: Parameters<JoinFunction>[0], |
||||||
|
conditionPrefix: string, |
||||||
|
{ |
||||||
|
onFallback, |
||||||
|
beforeReturn = (result) => |
||||||
|
result |
||||||
|
? `${conditionPrefix} IN (${result})` |
||||||
|
: call(onFallback, { notCallableReturn: '' }), |
||||||
|
}: Pick<JoinOptions, 'beforeReturn'> & { onFallback?: () => string } = {}, |
||||||
|
) => |
||||||
|
join(keys, { |
||||||
|
beforeReturn, |
||||||
|
elementWrapper: "'", |
||||||
|
separator: ', ', |
||||||
|
}) as string; |
||||||
|
|
||||||
|
export const buildUnknownIDCondition = ( |
||||||
|
keys: unknown, |
||||||
|
conditionPrefix: string, |
||||||
|
{ onFallback }: { onFallback?: () => string }, |
||||||
|
): { after: string; before: string[] } => { |
||||||
|
const before = sanitize(keys, 'string[]', { |
||||||
|
modifierType: 'sql', |
||||||
|
}); |
||||||
|
const after = buildIDCondition(before, conditionPrefix, { onFallback }); |
||||||
|
|
||||||
|
return { after, before }; |
||||||
|
}; |
||||||
|
|
||||||
|
export const buildKnownIDCondition = ( |
||||||
|
keys: string[] | '*' = '*', |
||||||
|
conditionPrefix: string, |
||||||
|
) => (keys[0] === '*' ? '' : buildIDCondition(keys, conditionPrefix)); |
||||||
@ -0,0 +1,14 @@ |
|||||||
|
type QueryField = string; |
||||||
|
|
||||||
|
export const buildQueryResultModifier = |
||||||
|
<T>(mod: (output: QueryField[][]) => T): QueryResultModifierFunction => |
||||||
|
(output) => |
||||||
|
output instanceof Array ? mod(output) : output; |
||||||
|
|
||||||
|
export const buildQueryResultReducer = <T>( |
||||||
|
reduce: (previous: T, row: QueryField[]) => T, |
||||||
|
initialValue: T, |
||||||
|
) => |
||||||
|
buildQueryResultModifier<T>((output) => |
||||||
|
output.reduce<T>(reduce, initialValue), |
||||||
|
); |
||||||
@ -0,0 +1,7 @@ |
|||||||
|
const call = <T = unknown>( |
||||||
|
toCall: unknown, |
||||||
|
{ parameters = [], notCallableReturn }: CallOptions = {}, |
||||||
|
): T => |
||||||
|
typeof toCall === 'function' ? toCall(...parameters) : notCallableReturn; |
||||||
|
|
||||||
|
export default call; |
||||||
@ -0,0 +1,4 @@ |
|||||||
|
export const cap = ( |
||||||
|
value: string, |
||||||
|
{ locales }: { locales?: string | string[] } = {}, |
||||||
|
) => `${value[0].toLocaleUpperCase(locales)}${value.slice(1)}`; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
const API_ROOT_PATH = '/api'; |
||||||
|
|
||||||
|
export default API_ROOT_PATH; |
||||||
@ -0,0 +1 @@ |
|||||||
|
export const HOST_KEY_CHANGED_PREFIX = 'host_key_changed::'; |
||||||
@ -0,0 +1 @@ |
|||||||
|
export const LOCAL = 'local'; |
||||||
@ -0,0 +1,4 @@ |
|||||||
|
// Unit: bytes
|
||||||
|
const NODE_AND_DR_RESERVED_MEMORY_SIZE = 8589934592; |
||||||
|
|
||||||
|
export default NODE_AND_DR_RESERVED_MEMORY_SIZE; |
||||||
@ -0,0 +1,26 @@ |
|||||||
|
import { execSync } from 'child_process'; |
||||||
|
|
||||||
|
import SERVER_PATHS from './SERVER_PATHS'; |
||||||
|
|
||||||
|
type OSKeyMapToName = Record<string, string>; |
||||||
|
|
||||||
|
const osList: string[] = execSync( |
||||||
|
`${SERVER_PATHS.usr.sbin['striker-parse-os-list'].self} | ${SERVER_PATHS.usr.bin['sed'].self} -E 's/^.*name="os_list_([^"]+).*CDATA[[]([^]]+).*$/\\1,\\2/'`, |
||||||
|
{ |
||||||
|
encoding: 'utf-8', |
||||||
|
timeout: 10000, |
||||||
|
}, |
||||||
|
).split('\n'); |
||||||
|
|
||||||
|
osList.pop(); |
||||||
|
|
||||||
|
const osKeyMapToName: OSKeyMapToName = osList.reduce((map, csv) => { |
||||||
|
const [osKey, osName] = csv.split(',', 2); |
||||||
|
|
||||||
|
map[osKey] = osName; |
||||||
|
|
||||||
|
return map; |
||||||
|
}, {} as OSKeyMapToName); |
||||||
|
|
||||||
|
export const OS_LIST: Readonly<string[]> = osList; |
||||||
|
export const OS_LIST_MAP: Readonly<OSKeyMapToName> = osKeyMapToName; |
||||||
@ -0,0 +1,23 @@ |
|||||||
|
const hex = '[0-9a-f]'; |
||||||
|
const octet = '(?:25[0-5]|(?:2[0-4]|1[0-9]|[1-9]|)[0-9])'; |
||||||
|
const alphanumeric = '[a-z0-9]'; |
||||||
|
const alphanumericDash = '[a-z0-9-]'; |
||||||
|
const ipv4 = `(?:${octet}[.]){3}${octet}`; |
||||||
|
|
||||||
|
export const REP_DOMAIN = new RegExp( |
||||||
|
`^(?:${alphanumeric}(?:${alphanumericDash}{0,61}${alphanumeric})?[.])+${alphanumeric}${alphanumericDash}{0,61}${alphanumeric}$`, |
||||||
|
); |
||||||
|
|
||||||
|
export const REP_INTEGER = /^\d+$/; |
||||||
|
|
||||||
|
export const REP_IPV4 = new RegExp(`^${ipv4}$`); |
||||||
|
|
||||||
|
export const REP_IPV4_CSV = new RegExp(`(?:${ipv4},)*${ipv4}`); |
||||||
|
|
||||||
|
// Peaceful string is temporarily defined as a string without single-quote, double-quote, slash (/), backslash (\\), angle brackets (< >), and curly brackets ({ }).
|
||||||
|
export const REP_PEACEFUL_STRING = /^[^'"/\\><}{]+$/; |
||||||
|
|
||||||
|
export const REP_UUID = new RegExp( |
||||||
|
`^${hex}{8}-${hex}{4}-[1-5]${hex}{3}-[89ab]${hex}{3}-${hex}{12}$`, |
||||||
|
'i', |
||||||
|
); |
||||||
@ -0,0 +1,54 @@ |
|||||||
|
import path from 'path'; |
||||||
|
|
||||||
|
const EMPTY_SERVER_PATHS: ServerPath = { |
||||||
|
mnt: { |
||||||
|
shared: { |
||||||
|
incoming: {}, |
||||||
|
}, |
||||||
|
}, |
||||||
|
tmp: {}, |
||||||
|
usr: { |
||||||
|
bin: { |
||||||
|
date: {}, |
||||||
|
mkfifo: {}, |
||||||
|
psql: {}, |
||||||
|
rm: {}, |
||||||
|
sed: {}, |
||||||
|
}, |
||||||
|
sbin: { |
||||||
|
'anvil-access-module': {}, |
||||||
|
'anvil-configure-host': {}, |
||||||
|
'anvil-get-server-screenshot': {}, |
||||||
|
'anvil-manage-keys': {}, |
||||||
|
'anvil-manage-power': {}, |
||||||
|
'anvil-provision-server': {}, |
||||||
|
'anvil-sync-shared': {}, |
||||||
|
'anvil-update-system': {}, |
||||||
|
'striker-initialize-host': {}, |
||||||
|
'striker-manage-install-target': {}, |
||||||
|
'striker-manage-peers': {}, |
||||||
|
'striker-parse-os-list': {}, |
||||||
|
}, |
||||||
|
}, |
||||||
|
}; |
||||||
|
|
||||||
|
const generatePaths = ( |
||||||
|
currentObject: ServerPath, |
||||||
|
parents = path.parse(process.cwd()).root, |
||||||
|
) => { |
||||||
|
Object.keys(currentObject).forEach((pathKey) => { |
||||||
|
if (pathKey !== 'self') { |
||||||
|
const currentPath = path.join(parents, pathKey); |
||||||
|
|
||||||
|
currentObject[pathKey].self = currentPath; |
||||||
|
|
||||||
|
generatePaths(currentObject[pathKey], currentPath); |
||||||
|
} |
||||||
|
}); |
||||||
|
|
||||||
|
return currentObject as ReadonlyServerPath; |
||||||
|
}; |
||||||
|
|
||||||
|
const SERVER_PATHS = generatePaths(EMPTY_SERVER_PATHS); |
||||||
|
|
||||||
|
export default SERVER_PATHS; |
||||||
@ -1,3 +1,3 @@ |
|||||||
const SERVER_PORT = process.env.SERVER_PORT ?? 8080; |
const SERVER_PORT = process.env.SERVER_PORT ?? 8080; |
||||||
|
|
||||||
module.exports = SERVER_PORT; |
export default SERVER_PORT; |
||||||
@ -0,0 +1,13 @@ |
|||||||
|
import { LOCAL } from './consts/LOCAL'; |
||||||
|
|
||||||
|
import { getLocalHostUUID } from './accessModule'; |
||||||
|
|
||||||
|
export const toHostUUID = ( |
||||||
|
hostUUID: string, |
||||||
|
localHostUUID: string = getLocalHostUUID(), |
||||||
|
) => (hostUUID === LOCAL ? localHostUUID : hostUUID); |
||||||
|
|
||||||
|
export const toLocal = ( |
||||||
|
hostUUID: string, |
||||||
|
localHostUUID: string = getLocalHostUUID(), |
||||||
|
) => (hostUUID === localHostUUID ? LOCAL : hostUUID); |
||||||
@ -0,0 +1,2 @@ |
|||||||
|
export const getShortHostName = (hostName: string) => |
||||||
|
hostName.replace(/[.].*$/, ''); |
||||||
@ -0,0 +1,27 @@ |
|||||||
|
import call from './call'; |
||||||
|
|
||||||
|
const join: JoinFunction = ( |
||||||
|
elements, |
||||||
|
{ beforeReturn, elementWrapper = '', onEach, separator = '' } = {}, |
||||||
|
) => { |
||||||
|
const joinSeparator = `${elementWrapper}${separator}${elementWrapper}`; |
||||||
|
|
||||||
|
const toReturn = |
||||||
|
elements instanceof Array && elements.length > 0 |
||||||
|
? `${elementWrapper}${elements.slice(1).reduce<string>( |
||||||
|
(previous, element) => |
||||||
|
`${previous}${joinSeparator}${call<string>(onEach, { |
||||||
|
notCallableReturn: element, |
||||||
|
parameters: [element], |
||||||
|
})}`,
|
||||||
|
elements[0], |
||||||
|
)}${elementWrapper}` |
||||||
|
: undefined; |
||||||
|
|
||||||
|
return call<string | undefined>(beforeReturn, { |
||||||
|
notCallableReturn: toReturn, |
||||||
|
parameters: [toReturn], |
||||||
|
}); |
||||||
|
}; |
||||||
|
|
||||||
|
export default join; |
||||||
@ -0,0 +1,5 @@ |
|||||||
|
export const match = ( |
||||||
|
value: string, |
||||||
|
regexp: string | RegExp, |
||||||
|
{ fallbackResult = [] }: { fallbackResult?: string[] } = {}, |
||||||
|
) => value.match(regexp) ?? fallbackResult; |
||||||
@ -0,0 +1,323 @@ |
|||||||
|
import NODE_AND_DR_RESERVED_MEMORY_SIZE from '../../consts/NODE_AND_DR_RESERVED_MEMORY_SIZE'; |
||||||
|
import { OS_LIST } from '../../consts/OS_LIST'; |
||||||
|
|
||||||
|
import join from '../../join'; |
||||||
|
|
||||||
|
const buildQueryAnvilDetail = ({ |
||||||
|
anvilUUIDs = ['*'], |
||||||
|
isForProvisionServer, |
||||||
|
}: { |
||||||
|
anvilUUIDs?: string[] | '*'; |
||||||
|
isForProvisionServer?: boolean; |
||||||
|
}) => { |
||||||
|
const condAnvilsUUID = ['all', '*'].includes(anvilUUIDs[0]) |
||||||
|
? '' |
||||||
|
: join(anvilUUIDs, { |
||||||
|
beforeReturn: (toReturn) => |
||||||
|
toReturn ? `WHERE anv.anvil_uuid IN (${toReturn})` : '', |
||||||
|
elementWrapper: "'", |
||||||
|
separator: ', ', |
||||||
|
}); |
||||||
|
|
||||||
|
console.log(`condAnvilsUUID=[${condAnvilsUUID}]`); |
||||||
|
|
||||||
|
const buildHostQuery = ({ |
||||||
|
isSummary = false, |
||||||
|
}: { isSummary?: boolean } = {}) => { |
||||||
|
let fieldsToSelect = ` |
||||||
|
host_uuid, |
||||||
|
host_name, |
||||||
|
scan_hardware_cpu_cores, |
||||||
|
scan_hardware_ram_total`;
|
||||||
|
let groupByPhrase = ''; |
||||||
|
|
||||||
|
if (isSummary) { |
||||||
|
fieldsToSelect = ` |
||||||
|
MIN(scan_hardware_cpu_cores) AS anvil_total_cpu_cores, |
||||||
|
MIN(scan_hardware_ram_total) AS anvil_total_memory`;
|
||||||
|
|
||||||
|
groupByPhrase = 'GROUP BY anvil_uuid'; |
||||||
|
} |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
anvil_uuid, |
||||||
|
${fieldsToSelect} |
||||||
|
FROM anvils AS anv |
||||||
|
JOIN hosts AS hos |
||||||
|
ON host_uuid IN ( |
||||||
|
anvil_node1_host_uuid, |
||||||
|
anvil_node2_host_uuid, |
||||||
|
anvil_dr1_host_uuid |
||||||
|
) |
||||||
|
JOIN scan_hardware AS sca_har |
||||||
|
ON host_uuid = scan_hardware_host_uuid |
||||||
|
${groupByPhrase}`;
|
||||||
|
}; |
||||||
|
|
||||||
|
const buildServerQuery = ({ |
||||||
|
isSummary = false, |
||||||
|
}: { isSummary?: boolean } = {}) => { |
||||||
|
let fieldsToSelect = ` |
||||||
|
server_uuid, |
||||||
|
server_name, |
||||||
|
server_cpu_cores, |
||||||
|
server_memory`;
|
||||||
|
let groupByPhrase = ''; |
||||||
|
|
||||||
|
if (isSummary) { |
||||||
|
fieldsToSelect = ` |
||||||
|
SUM(server_cpu_cores) AS anvil_total_allocated_cpu_cores, |
||||||
|
SUM(server_memory) AS anvil_total_allocated_memory`;
|
||||||
|
|
||||||
|
groupByPhrase = 'GROUP BY server_anvil_uuid'; |
||||||
|
} |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
server_anvil_uuid, |
||||||
|
${fieldsToSelect} |
||||||
|
FROM servers AS ser |
||||||
|
JOIN ( |
||||||
|
SELECT |
||||||
|
server_definition_server_uuid, |
||||||
|
server_cpu_cores, |
||||||
|
CASE server_memory_unit |
||||||
|
WHEN 'KiB' THEN server_memory_value * 1024 |
||||||
|
ELSE server_memory_value |
||||||
|
END AS server_memory |
||||||
|
FROM ( |
||||||
|
SELECT |
||||||
|
server_definition_server_uuid, |
||||||
|
CAST( |
||||||
|
SUBSTRING( |
||||||
|
server_definition_xml, '%cores=''#"[0-9]+#"''%', '#' |
||||||
|
) AS INTEGER |
||||||
|
) AS server_cpu_cores, |
||||||
|
CAST( |
||||||
|
SUBSTRING( |
||||||
|
server_definition_xml, '%memory%>#"[0-9]+#"</memory%', '#' |
||||||
|
) AS BIGINT |
||||||
|
) AS server_memory_value, |
||||||
|
SUBSTRING( |
||||||
|
server_definition_xml, '%memory%unit=''#"[A-Za-z]+#"''%', '#' |
||||||
|
) AS server_memory_unit |
||||||
|
FROM server_definitions AS ser_def |
||||||
|
) AS ser_def_memory_converted |
||||||
|
) AS pos_ser_def |
||||||
|
ON server_uuid = server_definition_server_uuid |
||||||
|
${groupByPhrase}`;
|
||||||
|
}; |
||||||
|
|
||||||
|
const buildStorageGroupQuery = () => ` |
||||||
|
SELECT |
||||||
|
storage_group_anvil_uuid, |
||||||
|
storage_group_uuid, |
||||||
|
storage_group_name, |
||||||
|
MIN(scan_lvm_vg_size) AS storage_group_size, |
||||||
|
MIN(scan_lvm_vg_free) AS storage_group_free |
||||||
|
FROM storage_groups AS sto_gro |
||||||
|
JOIN storage_group_members AS sto_gro_mem |
||||||
|
ON storage_group_uuid = storage_group_member_storage_group_uuid |
||||||
|
JOIN scan_lvm_vgs AS sca_lvm_vgs |
||||||
|
ON storage_group_member_vg_uuid = scan_lvm_vg_internal_uuid |
||||||
|
GROUP BY |
||||||
|
storage_group_anvil_uuid, |
||||||
|
storage_group_uuid, |
||||||
|
storage_group_name`;
|
||||||
|
|
||||||
|
const buildFileQuery = () => ` |
||||||
|
SELECT |
||||||
|
file_location_anvil_uuid, |
||||||
|
file_uuid, |
||||||
|
file_name |
||||||
|
FROM file_locations as fil_loc |
||||||
|
JOIN files as fil |
||||||
|
ON file_location_file_uuid = file_uuid |
||||||
|
WHERE |
||||||
|
file_type = 'iso' |
||||||
|
AND file_location_active = 't'`;
|
||||||
|
|
||||||
|
const buildQueryForProvisionServer = () => ` |
||||||
|
SELECT |
||||||
|
anv.anvil_uuid, |
||||||
|
anv.anvil_name, |
||||||
|
anv.anvil_description, |
||||||
|
host_list.host_uuid, |
||||||
|
host_list.host_name, |
||||||
|
host_list.scan_hardware_cpu_cores, |
||||||
|
host_list.scan_hardware_ram_total, |
||||||
|
host_summary.anvil_total_cpu_cores, |
||||||
|
host_summary.anvil_total_memory, |
||||||
|
server_list.server_uuid, |
||||||
|
server_list.server_name, |
||||||
|
server_list.server_cpu_cores, |
||||||
|
server_list.server_memory, |
||||||
|
server_summary.anvil_total_allocated_cpu_cores, |
||||||
|
server_summary.anvil_total_allocated_memory, |
||||||
|
(host_summary.anvil_total_cpu_cores |
||||||
|
- server_summary.anvil_total_allocated_cpu_cores |
||||||
|
) AS anvil_total_available_cpu_cores, |
||||||
|
(host_summary.anvil_total_memory |
||||||
|
- server_summary.anvil_total_allocated_memory |
||||||
|
- ${NODE_AND_DR_RESERVED_MEMORY_SIZE} |
||||||
|
) AS anvil_total_available_memory, |
||||||
|
storage_group_list.storage_group_uuid, |
||||||
|
storage_group_list.storage_group_name, |
||||||
|
storage_group_list.storage_group_size, |
||||||
|
storage_group_list.storage_group_free, |
||||||
|
file_list.file_uuid, |
||||||
|
file_list.file_name |
||||||
|
FROM anvils AS anv |
||||||
|
JOIN (${buildHostQuery()}) AS host_list |
||||||
|
ON anv.anvil_uuid = host_list.anvil_uuid |
||||||
|
JOIN (${buildHostQuery({ isSummary: true })}) AS host_summary |
||||||
|
ON anv.anvil_uuid = host_summary.anvil_uuid |
||||||
|
LEFT JOIN (${buildServerQuery()}) AS server_list |
||||||
|
ON anv.anvil_uuid = server_list.server_anvil_uuid |
||||||
|
LEFT JOIN (${buildServerQuery({ isSummary: true })}) AS server_summary |
||||||
|
ON anv.anvil_uuid = server_summary.server_anvil_uuid |
||||||
|
LEFT JOIN (${buildStorageGroupQuery()}) AS storage_group_list |
||||||
|
ON anv.anvil_uuid = storage_group_list.storage_group_anvil_uuid |
||||||
|
LEFT JOIN (${buildFileQuery()}) AS file_list |
||||||
|
ON anv.anvil_uuid = file_list.file_location_anvil_uuid |
||||||
|
;`;
|
||||||
|
|
||||||
|
let query = ` |
||||||
|
SELECT |
||||||
|
* |
||||||
|
FROM anvils AS anv |
||||||
|
${condAnvilsUUID} |
||||||
|
;`;
|
||||||
|
let afterQueryReturn = undefined; |
||||||
|
|
||||||
|
if (isForProvisionServer) { |
||||||
|
query = buildQueryForProvisionServer(); |
||||||
|
|
||||||
|
afterQueryReturn = (queryStdout: unknown) => { |
||||||
|
let results = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
let rowStage: AnvilDetailForProvisionServer | undefined; |
||||||
|
|
||||||
|
const anvils = queryStdout.reduce<AnvilDetailForProvisionServer[]>( |
||||||
|
( |
||||||
|
reducedRows, |
||||||
|
[ |
||||||
|
anvilUUID, |
||||||
|
anvilName, |
||||||
|
anvilDescription, |
||||||
|
hostUUID, |
||||||
|
hostName, |
||||||
|
hostCPUCores, |
||||||
|
hostMemory, |
||||||
|
anvilTotalCPUCores, |
||||||
|
anvilTotalMemory, |
||||||
|
serverUUID, |
||||||
|
serverName, |
||||||
|
serverCPUCores, |
||||||
|
serverMemory, |
||||||
|
anvilTotalAllocatedCPUCores, |
||||||
|
anvilTotalAllocatedMemory, |
||||||
|
anvilTotalAvailableCPUCores, |
||||||
|
anvilTotalAvailableMemory, |
||||||
|
storageGroupUUID, |
||||||
|
storageGroupName, |
||||||
|
storageGroupSize, |
||||||
|
storageGroupFree, |
||||||
|
fileUUID, |
||||||
|
fileName, |
||||||
|
], |
||||||
|
) => { |
||||||
|
if (!rowStage || anvilUUID !== rowStage.anvilUUID) { |
||||||
|
rowStage = { |
||||||
|
anvilUUID, |
||||||
|
anvilName, |
||||||
|
anvilDescription, |
||||||
|
anvilTotalCPUCores: parseInt(anvilTotalCPUCores), |
||||||
|
anvilTotalMemory: String(anvilTotalMemory), |
||||||
|
anvilTotalAllocatedCPUCores: parseInt( |
||||||
|
anvilTotalAllocatedCPUCores, |
||||||
|
), |
||||||
|
anvilTotalAllocatedMemory: String(anvilTotalAllocatedMemory), |
||||||
|
anvilTotalAvailableCPUCores: parseInt( |
||||||
|
anvilTotalAvailableCPUCores, |
||||||
|
), |
||||||
|
anvilTotalAvailableMemory: String(anvilTotalAvailableMemory), |
||||||
|
hosts: [], |
||||||
|
servers: [], |
||||||
|
storageGroups: [], |
||||||
|
files: [], |
||||||
|
}; |
||||||
|
|
||||||
|
reducedRows.push(rowStage); |
||||||
|
} |
||||||
|
|
||||||
|
if ( |
||||||
|
!rowStage.hosts.find(({ hostUUID: added }) => added === hostUUID) |
||||||
|
) { |
||||||
|
rowStage.hosts.push({ |
||||||
|
hostUUID, |
||||||
|
hostName, |
||||||
|
hostCPUCores: parseInt(hostCPUCores), |
||||||
|
hostMemory: String(hostMemory), |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
if ( |
||||||
|
!rowStage.servers.find( |
||||||
|
({ serverUUID: added }) => added === serverUUID, |
||||||
|
) |
||||||
|
) { |
||||||
|
rowStage.servers.push({ |
||||||
|
serverUUID, |
||||||
|
serverName, |
||||||
|
serverCPUCores: parseInt(serverCPUCores), |
||||||
|
serverMemory: String(serverMemory), |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
if ( |
||||||
|
!rowStage.storageGroups.find( |
||||||
|
({ storageGroupUUID: added }) => added === storageGroupUUID, |
||||||
|
) |
||||||
|
) { |
||||||
|
rowStage.storageGroups.push({ |
||||||
|
storageGroupUUID, |
||||||
|
storageGroupName, |
||||||
|
storageGroupSize: String(storageGroupSize), |
||||||
|
storageGroupFree: String(storageGroupFree), |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
if ( |
||||||
|
!rowStage.files.find(({ fileUUID: added }) => added === fileUUID) |
||||||
|
) { |
||||||
|
rowStage.files.push({ |
||||||
|
fileUUID, |
||||||
|
fileName, |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
return reducedRows; |
||||||
|
}, |
||||||
|
[], |
||||||
|
); |
||||||
|
|
||||||
|
results = { |
||||||
|
anvils, |
||||||
|
osList: OS_LIST, |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return results; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return { |
||||||
|
query, |
||||||
|
afterQueryReturn, |
||||||
|
}; |
||||||
|
}; |
||||||
|
|
||||||
|
export default buildQueryAnvilDetail; |
||||||
@ -0,0 +1,81 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import buildQueryAnvilDetail from './buildQueryAnvilDetail'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
|
||||||
|
const getAnvil: RequestHandler = buildGetRequestHandler( |
||||||
|
(request, buildQueryOptions) => { |
||||||
|
const { anvilUUIDs, isForProvisionServer } = request.query; |
||||||
|
|
||||||
|
let query = ` |
||||||
|
SELECT |
||||||
|
anv.anvil_name, |
||||||
|
anv.anvil_uuid, |
||||||
|
hos.host_name, |
||||||
|
hos.host_uuid |
||||||
|
FROM anvils AS anv |
||||||
|
JOIN hosts AS hos |
||||||
|
ON hos.host_uuid IN ( |
||||||
|
anv.anvil_node1_host_uuid, |
||||||
|
anv.anvil_node2_host_uuid, |
||||||
|
anv.anvil_dr1_host_uuid |
||||||
|
) |
||||||
|
ORDER BY anv.anvil_uuid;`;
|
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = (queryStdout) => { |
||||||
|
let results = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
let rowStage: AnvilOverview | undefined; |
||||||
|
|
||||||
|
results = queryStdout.reduce<AnvilOverview[]>( |
||||||
|
(reducedRows, [anvilName, anvilUUID, hostName, hostUUID]) => { |
||||||
|
if (!rowStage || anvilUUID !== rowStage.anvilUUID) { |
||||||
|
{ |
||||||
|
rowStage = { |
||||||
|
anvilName, |
||||||
|
anvilUUID, |
||||||
|
hosts: [], |
||||||
|
}; |
||||||
|
|
||||||
|
reducedRows.push(rowStage); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
rowStage.hosts.push({ hostName, hostUUID }); |
||||||
|
|
||||||
|
return reducedRows; |
||||||
|
}, |
||||||
|
[], |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
return results; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
if (anvilUUIDs) { |
||||||
|
const { |
||||||
|
query: anvilDetailQuery, |
||||||
|
afterQueryReturn: anvilDetailAfterQueryReturn, |
||||||
|
} = buildQueryAnvilDetail({ |
||||||
|
anvilUUIDs: sanitize(anvilUUIDs, 'string[]', { |
||||||
|
modifierType: 'sql', |
||||||
|
}), |
||||||
|
isForProvisionServer: sanitize(isForProvisionServer, 'boolean'), |
||||||
|
}); |
||||||
|
|
||||||
|
query = anvilDetailQuery; |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = anvilDetailAfterQueryReturn; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}, |
||||||
|
); |
||||||
|
|
||||||
|
export default getAnvil; |
||||||
@ -0,0 +1,34 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { sanitize } from '../sanitize'; |
||||||
|
import { stderr, stdout } from '../shell'; |
||||||
|
|
||||||
|
export const buildBranchRequestHandler: (map: { |
||||||
|
[handler: string]: RequestHandler | undefined; |
||||||
|
}) => RequestHandler = |
||||||
|
(map) => |
||||||
|
(...args) => { |
||||||
|
const [ |
||||||
|
{ |
||||||
|
query: { handler: rawHandler }, |
||||||
|
}, |
||||||
|
response, |
||||||
|
] = args; |
||||||
|
|
||||||
|
const handlerKey = sanitize(rawHandler, 'string'); |
||||||
|
|
||||||
|
stdout(`Create host handler: ${handlerKey}`); |
||||||
|
|
||||||
|
// Ensure each handler sends a response at the end of any branch.
|
||||||
|
const handler = map[handlerKey]; |
||||||
|
|
||||||
|
if (handler) { |
||||||
|
handler(...args); |
||||||
|
} else { |
||||||
|
stderr(`Handler is not registered; got [${handlerKey}]`); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
}; |
||||||
@ -0,0 +1,64 @@ |
|||||||
|
import { Request, Response } from 'express'; |
||||||
|
|
||||||
|
import { dbQuery } from '../accessModule'; |
||||||
|
import call from '../call'; |
||||||
|
|
||||||
|
const buildGetRequestHandler = |
||||||
|
( |
||||||
|
query: string | BuildQueryFunction, |
||||||
|
{ beforeRespond }: BuildGetRequestHandlerOptions = {}, |
||||||
|
) => |
||||||
|
(request: Request, response: Response) => { |
||||||
|
console.log('Calling CLI script to get data.'); |
||||||
|
|
||||||
|
const buildQueryOptions: BuildQueryOptions = {}; |
||||||
|
|
||||||
|
let queryStdout; |
||||||
|
|
||||||
|
try { |
||||||
|
({ stdout: queryStdout } = dbQuery( |
||||||
|
call<string>(query, { |
||||||
|
parameters: [request, buildQueryOptions], |
||||||
|
notCallableReturn: query, |
||||||
|
}), |
||||||
|
)); |
||||||
|
} catch (queryError) { |
||||||
|
console.log(`Failed to execute query; CAUSE: ${queryError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
console.log( |
||||||
|
`Query stdout pre-hooks (type=[${typeof queryStdout}]): ${JSON.stringify( |
||||||
|
queryStdout, |
||||||
|
null, |
||||||
|
2, |
||||||
|
)}`,
|
||||||
|
); |
||||||
|
|
||||||
|
const { afterQueryReturn } = buildQueryOptions; |
||||||
|
|
||||||
|
queryStdout = call(afterQueryReturn, { |
||||||
|
parameters: [queryStdout], |
||||||
|
notCallableReturn: queryStdout, |
||||||
|
}); |
||||||
|
|
||||||
|
queryStdout = call(beforeRespond, { |
||||||
|
parameters: [queryStdout], |
||||||
|
notCallableReturn: queryStdout, |
||||||
|
}); |
||||||
|
|
||||||
|
console.log( |
||||||
|
`Query stdout post-hooks (type=[${typeof queryStdout}]): ${JSON.stringify( |
||||||
|
queryStdout, |
||||||
|
null, |
||||||
|
2, |
||||||
|
)}`,
|
||||||
|
); |
||||||
|
|
||||||
|
response.json(queryStdout); |
||||||
|
}; |
||||||
|
|
||||||
|
export default buildGetRequestHandler; |
||||||
@ -0,0 +1,53 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
type DistinctDBJobParams = Omit< |
||||||
|
DBJobParams, |
||||||
|
'file' | 'line' | 'job_data' | 'job_progress' |
||||||
|
>; |
||||||
|
|
||||||
|
const MANAGE_HOST_POWER_JOB_PARAMS: { |
||||||
|
poweroff: DistinctDBJobParams; |
||||||
|
reboot: DistinctDBJobParams; |
||||||
|
} = { |
||||||
|
poweroff: { |
||||||
|
job_command: `${SERVER_PATHS.usr.sbin['anvil-manage-power'].self} --poweroff -y`, |
||||||
|
job_name: 'poweroff::system', |
||||||
|
job_title: 'job_0010', |
||||||
|
job_description: 'job_0008', |
||||||
|
}, |
||||||
|
reboot: { |
||||||
|
job_command: `${SERVER_PATHS.usr.sbin['anvil-manage-power'].self} --reboot -y`, |
||||||
|
job_name: 'reboot::system', |
||||||
|
job_title: 'job_0009', |
||||||
|
job_description: 'job_0006', |
||||||
|
}, |
||||||
|
}; |
||||||
|
|
||||||
|
export const buildHostPowerHandler: ( |
||||||
|
task?: 'poweroff' | 'reboot', |
||||||
|
) => RequestHandler = |
||||||
|
(task = 'reboot') => |
||||||
|
(request, response) => { |
||||||
|
const subParams: DBJobParams = { |
||||||
|
file: __filename, |
||||||
|
|
||||||
|
...MANAGE_HOST_POWER_JOB_PARAMS[task], |
||||||
|
}; |
||||||
|
|
||||||
|
try { |
||||||
|
job(subParams); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to ${task} host; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(204).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,88 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { HOST_KEY_CHANGED_PREFIX } from '../../consts/HOST_KEY_CHANGED_PREFIX'; |
||||||
|
|
||||||
|
import { dbQuery, getLocalHostUUID, getPeerData } from '../../accessModule'; |
||||||
|
import { sanitizeSQLParam } from '../../sanitizeSQLParam'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
export const getHostSSH: RequestHandler< |
||||||
|
unknown, |
||||||
|
{ |
||||||
|
badSSHKeys?: DeleteSSHKeyConflictRequestBody; |
||||||
|
hostName: string; |
||||||
|
hostOS: string; |
||||||
|
hostUUID: string; |
||||||
|
isConnected: boolean; |
||||||
|
isInetConnected: boolean; |
||||||
|
isOSRegistered: boolean; |
||||||
|
}, |
||||||
|
{ |
||||||
|
password: string; |
||||||
|
port?: number; |
||||||
|
ipAddress: string; |
||||||
|
} |
||||||
|
> = (request, response) => { |
||||||
|
const { |
||||||
|
body: { password, port = 22, ipAddress: target }, |
||||||
|
} = request; |
||||||
|
|
||||||
|
let hostName: string; |
||||||
|
let hostOS: string; |
||||||
|
let hostUUID: string; |
||||||
|
let isConnected: boolean; |
||||||
|
let isInetConnected: boolean; |
||||||
|
let isOSRegistered: boolean; |
||||||
|
|
||||||
|
const localHostUUID = getLocalHostUUID(); |
||||||
|
|
||||||
|
try { |
||||||
|
({ |
||||||
|
hostName, |
||||||
|
hostOS, |
||||||
|
hostUUID, |
||||||
|
isConnected, |
||||||
|
isInetConnected, |
||||||
|
isOSRegistered, |
||||||
|
} = getPeerData(target, { password, port })); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to get peer data; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
let badSSHKeys: DeleteSSHKeyConflictRequestBody | undefined; |
||||||
|
|
||||||
|
if (!isConnected) { |
||||||
|
const rows = dbQuery(` |
||||||
|
SELECT sta.state_note, sta.state_uuid |
||||||
|
FROM states AS sta |
||||||
|
WHERE sta.state_host_uuid = '${localHostUUID}' |
||||||
|
AND sta.state_name = '${HOST_KEY_CHANGED_PREFIX}${sanitizeSQLParam( |
||||||
|
target, |
||||||
|
)}';`).stdout as [stateNote: string, stateUUID: string][];
|
||||||
|
|
||||||
|
if (rows.length > 0) { |
||||||
|
badSSHKeys = rows.reduce<DeleteSSHKeyConflictRequestBody>( |
||||||
|
(previous, [, stateUUID]) => { |
||||||
|
previous[localHostUUID].push(stateUUID); |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, |
||||||
|
{ [localHostUUID]: [] }, |
||||||
|
); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
response.status(200).send({ |
||||||
|
badSSHKeys, |
||||||
|
hostName, |
||||||
|
hostOS, |
||||||
|
hostUUID, |
||||||
|
isConnected, |
||||||
|
isInetConnected, |
||||||
|
isOSRegistered, |
||||||
|
}); |
||||||
|
}; |
||||||
@ -0,0 +1,4 @@ |
|||||||
|
export * from './getHostSSH'; |
||||||
|
export * from './poweroffHost'; |
||||||
|
export * from './rebootHost'; |
||||||
|
export * from './updateSystem'; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
import { buildHostPowerHandler } from './buildHostPowerHandler'; |
||||||
|
|
||||||
|
export const poweroffHost = buildHostPowerHandler('poweroff'); |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
import { buildHostPowerHandler } from './buildHostPowerHandler'; |
||||||
|
|
||||||
|
export const rebootHost = buildHostPowerHandler('reboot'); |
||||||
@ -0,0 +1,26 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
export const updateSystem: RequestHandler = (request, response) => { |
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-update-system'].self, |
||||||
|
job_description: 'job_0004', |
||||||
|
job_name: 'update::system', |
||||||
|
job_title: 'job_0003', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to initiate system update; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(204).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,40 @@ |
|||||||
|
import join from '../../join'; |
||||||
|
|
||||||
|
const buildQueryFileDetail = ({ |
||||||
|
fileUUIDs = ['*'], |
||||||
|
}: { |
||||||
|
fileUUIDs?: string[] | '*'; |
||||||
|
}) => { |
||||||
|
const condFileUUIDs = ['all', '*'].includes(fileUUIDs[0]) |
||||||
|
? '' |
||||||
|
: join(fileUUIDs, { |
||||||
|
beforeReturn: (toReturn) => |
||||||
|
toReturn ? `AND fil.file_uuid IN (${toReturn})` : '', |
||||||
|
elementWrapper: "'", |
||||||
|
separator: ', ', |
||||||
|
}); |
||||||
|
|
||||||
|
console.log(`condFilesUUID=[${condFileUUIDs}]`); |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
fil.file_uuid, |
||||||
|
fil.file_name, |
||||||
|
fil.file_size, |
||||||
|
fil.file_type, |
||||||
|
fil.file_md5sum, |
||||||
|
fil_loc.file_location_uuid, |
||||||
|
fil_loc.file_location_active, |
||||||
|
anv.anvil_uuid, |
||||||
|
anv.anvil_name, |
||||||
|
anv.anvil_description |
||||||
|
FROM files AS fil |
||||||
|
JOIN file_locations AS fil_loc |
||||||
|
ON fil.file_uuid = fil_loc.file_location_file_uuid |
||||||
|
JOIN anvils AS anv |
||||||
|
ON fil_loc.file_location_anvil_uuid = anv.anvil_uuid |
||||||
|
WHERE fil.file_type != 'DELETED' |
||||||
|
${condFileUUIDs};`;
|
||||||
|
}; |
||||||
|
|
||||||
|
export default buildQueryFileDetail; |
||||||
@ -0,0 +1,31 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import buildQueryFileDetail from './buildQueryFileDetail'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
|
||||||
|
const getFile: RequestHandler = buildGetRequestHandler((request) => { |
||||||
|
const { fileUUIDs } = request.query; |
||||||
|
|
||||||
|
let query = ` |
||||||
|
SELECT |
||||||
|
file_uuid, |
||||||
|
file_name, |
||||||
|
file_size, |
||||||
|
file_type, |
||||||
|
file_md5sum |
||||||
|
FROM files |
||||||
|
WHERE file_type != 'DELETED';`;
|
||||||
|
|
||||||
|
if (fileUUIDs) { |
||||||
|
query = buildQueryFileDetail({ |
||||||
|
fileUUIDs: sanitize(fileUUIDs, 'string[]', { |
||||||
|
modifierType: 'sql', |
||||||
|
}), |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}); |
||||||
|
|
||||||
|
export default getFile; |
||||||
@ -0,0 +1,12 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import buildQueryFileDetail from './buildQueryFileDetail'; |
||||||
|
import { sanitizeSQLParam } from '../../sanitizeSQLParam'; |
||||||
|
|
||||||
|
const getFileDetail: RequestHandler = buildGetRequestHandler( |
||||||
|
({ params: { fileUUID } }) => |
||||||
|
buildQueryFileDetail({ fileUUIDs: [sanitizeSQLParam(fileUUID)] }), |
||||||
|
); |
||||||
|
|
||||||
|
export default getFileDetail; |
||||||
@ -0,0 +1,68 @@ |
|||||||
|
import { buildKnownIDCondition } from '../../buildCondition'; |
||||||
|
import { buildQueryResultModifier } from '../../buildQueryResultModifier'; |
||||||
|
import { cap } from '../../cap'; |
||||||
|
import { getShortHostName } from '../../getShortHostName'; |
||||||
|
import { stdout } from '../../shell'; |
||||||
|
|
||||||
|
type ExtractVariableKeyFunction = (parts: string[]) => string; |
||||||
|
|
||||||
|
const MAP_TO_EXTRACTOR: { [prefix: string]: ExtractVariableKeyFunction } = { |
||||||
|
form: ([, part2]) => { |
||||||
|
const [head, ...rest] = part2.split('_'); |
||||||
|
|
||||||
|
return rest.reduce<string>( |
||||||
|
(previous, part) => `${previous}${cap(part)}`, |
||||||
|
head, |
||||||
|
); |
||||||
|
}, |
||||||
|
'install-target': () => 'installTarget', |
||||||
|
}; |
||||||
|
|
||||||
|
export const buildQueryHostDetail: BuildQueryDetailFunction = ({ |
||||||
|
keys: hostUUIDs = '*', |
||||||
|
} = {}) => { |
||||||
|
const condHostUUIDs = buildKnownIDCondition(hostUUIDs, 'AND hos.host_uuid'); |
||||||
|
|
||||||
|
stdout(`condHostUUIDs=[${condHostUUIDs}]`); |
||||||
|
|
||||||
|
const query = ` |
||||||
|
SELECT |
||||||
|
hos.host_name, |
||||||
|
hos.host_uuid, |
||||||
|
var.variable_name, |
||||||
|
var.variable_value |
||||||
|
FROM variables AS var |
||||||
|
JOIN hosts AS hos |
||||||
|
ON var.variable_source_uuid = hos.host_uuid |
||||||
|
WHERE ( |
||||||
|
variable_name LIKE 'form::config_%' |
||||||
|
OR variable_name = 'install-target::enabled' |
||||||
|
) |
||||||
|
${condHostUUIDs};`;
|
||||||
|
|
||||||
|
const afterQueryReturn: QueryResultModifierFunction = |
||||||
|
buildQueryResultModifier((output) => { |
||||||
|
const [hostName, hostUUID] = output[0]; |
||||||
|
const shortHostName = getShortHostName(hostName); |
||||||
|
|
||||||
|
return output.reduce< |
||||||
|
{ hostName: string; hostUUID: string; shortHostName: string } & Record< |
||||||
|
string, |
||||||
|
string |
||||||
|
> |
||||||
|
>( |
||||||
|
(previous, [, , variableName, variableValue]) => { |
||||||
|
const [variablePrefix, ...restVariableParts] = |
||||||
|
variableName.split('::'); |
||||||
|
const key = MAP_TO_EXTRACTOR[variablePrefix](restVariableParts); |
||||||
|
|
||||||
|
previous[key] = variableValue; |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, |
||||||
|
{ hostName, hostUUID, shortHostName }, |
||||||
|
); |
||||||
|
}); |
||||||
|
|
||||||
|
return { query, afterQueryReturn }; |
||||||
|
}; |
||||||
@ -0,0 +1,164 @@ |
|||||||
|
import assert from 'assert'; |
||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
REP_DOMAIN, |
||||||
|
REP_INTEGER, |
||||||
|
REP_IPV4, |
||||||
|
REP_IPV4_CSV, |
||||||
|
} from '../../consts/REG_EXP_PATTERNS'; |
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
|
||||||
|
const fvar = (configStepCount: number, fieldName: string) => |
||||||
|
['form', `config_step${configStepCount}`, fieldName, 'value'].join('::'); |
||||||
|
|
||||||
|
const buildNetworkLinks = ( |
||||||
|
configStepCount: number, |
||||||
|
networkShortName: string, |
||||||
|
interfaces: InitializeStrikerNetworkForm['interfaces'], |
||||||
|
) => |
||||||
|
interfaces.reduce<string>((reduceContainer, iface, index) => { |
||||||
|
let result = reduceContainer; |
||||||
|
|
||||||
|
if (iface) { |
||||||
|
const { networkInterfaceMACAddress } = iface; |
||||||
|
|
||||||
|
result += ` |
||||||
|
${fvar( |
||||||
|
configStepCount, |
||||||
|
`${networkShortName}_link${index + 1}_mac_to_set`, |
||||||
|
)}=${networkInterfaceMACAddress}`;
|
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}, ''); |
||||||
|
|
||||||
|
export const configStriker: RequestHandler< |
||||||
|
unknown, |
||||||
|
undefined, |
||||||
|
InitializeStrikerForm |
||||||
|
> = ({ body }, response) => { |
||||||
|
console.log('Begin initialize Striker.'); |
||||||
|
console.dir(body, { depth: null }); |
||||||
|
|
||||||
|
const { |
||||||
|
adminPassword = '', |
||||||
|
domainName = '', |
||||||
|
hostName = '', |
||||||
|
hostNumber = 0, |
||||||
|
networkDNS = '', |
||||||
|
networkGateway = '', |
||||||
|
networks = [], |
||||||
|
organizationName = '', |
||||||
|
organizationPrefix = '', |
||||||
|
} = body || {}; |
||||||
|
|
||||||
|
const dataAdminPassword = String(adminPassword); |
||||||
|
const dataDomainName = String(domainName); |
||||||
|
const dataHostName = String(hostName); |
||||||
|
const dataHostNumber = String(hostNumber); |
||||||
|
const dataNetworkDNS = String(networkDNS); |
||||||
|
const dataNetworkGateway = String(networkGateway); |
||||||
|
const dataOrganizationName = String(organizationName); |
||||||
|
const dataOrganizationPrefix = String(organizationPrefix); |
||||||
|
|
||||||
|
try { |
||||||
|
assert( |
||||||
|
!/['"/\\><}{]/g.test(dataAdminPassword), |
||||||
|
`Data admin password cannot contain single-quote, double-quote, slash, backslash, angle brackets, and curly brackets; got [${dataAdminPassword}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_DOMAIN.test(dataDomainName), |
||||||
|
`Data domain name can only contain alphanumeric, hyphen, and dot characters; got [${dataDomainName}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_DOMAIN.test(dataHostName), |
||||||
|
`Data host name can only contain alphanumeric, hyphen, and dot characters; got [${dataHostName}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_INTEGER.test(dataHostNumber) && hostNumber > 0, |
||||||
|
`Data host number can only contain digits; got [${dataHostNumber}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_IPV4_CSV.test(dataNetworkDNS), |
||||||
|
`Data network DNS must be a comma separated list of valid IPv4 addresses; got [${dataNetworkDNS}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_IPV4.test(dataNetworkGateway), |
||||||
|
`Data network gateway must be a valid IPv4 address; got [${dataNetworkGateway}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
dataOrganizationName.length > 0, |
||||||
|
`Data organization name cannot be empty; got [${dataOrganizationName}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
/^[a-z0-9]{1,5}$/.test(dataOrganizationPrefix), |
||||||
|
`Data organization prefix can only contain 1 to 5 lowercase alphanumeric characters; got [${dataOrganizationPrefix}]`, |
||||||
|
); |
||||||
|
} catch (assertError) { |
||||||
|
console.log( |
||||||
|
`Failed to assert value when trying to initialize striker; CAUSE: ${assertError}.`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-configure-host'].self, |
||||||
|
job_data: `${fvar(1, 'domain')}=${domainName} |
||||||
|
${fvar(1, 'organization')}=${organizationName} |
||||||
|
${fvar(1, 'prefix')}=${organizationPrefix} |
||||||
|
${fvar(1, 'sequence')}=${hostNumber} |
||||||
|
${fvar(2, 'dns')}=${networkDNS} |
||||||
|
${fvar(2, 'gateway')}=${networkGateway} |
||||||
|
${fvar(2, 'host_name')}=${hostName} |
||||||
|
${fvar(2, 'striker_password')}=${adminPassword} |
||||||
|
${fvar(2, 'striker_user')}=admin${ |
||||||
|
networks.reduce<{ |
||||||
|
counters: Record<InitializeStrikerNetworkForm['type'], number>; |
||||||
|
result: string; |
||||||
|
}>( |
||||||
|
(reduceContainer, { interfaces, ipAddress, subnetMask, type }) => { |
||||||
|
const { counters } = reduceContainer; |
||||||
|
|
||||||
|
counters[type] = counters[type] ? counters[type] + 1 : 1; |
||||||
|
|
||||||
|
const networkShortName = `${type}${counters[type]}`; |
||||||
|
|
||||||
|
reduceContainer.result += ` |
||||||
|
${fvar(2, `${networkShortName}_ip`)}=${ipAddress} |
||||||
|
${fvar(2, `${networkShortName}_subnet_mask`)}=${subnetMask} |
||||||
|
${buildNetworkLinks(2, networkShortName, interfaces)}`;
|
||||||
|
|
||||||
|
return reduceContainer; |
||||||
|
}, |
||||||
|
{ counters: {}, result: '' }, |
||||||
|
).result |
||||||
|
}`,
|
||||||
|
job_name: 'configure::network', |
||||||
|
job_title: 'job_0001', |
||||||
|
job_description: 'job_0071', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
console.log(`Failed to queue striker initialization; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(200).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,8 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { buildBranchRequestHandler } from '../buildBranchRequestHandler'; |
||||||
|
import { configStriker } from './configStriker'; |
||||||
|
|
||||||
|
export const createHost: RequestHandler = buildBranchRequestHandler({ |
||||||
|
striker: configStriker, |
||||||
|
}); |
||||||
@ -0,0 +1,190 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { |
||||||
|
getAnvilData, |
||||||
|
getLocalHostUUID, |
||||||
|
getPeerData, |
||||||
|
job, |
||||||
|
sub, |
||||||
|
} from '../../accessModule'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
import { rm, stderr, stdoutVar } from '../../shell'; |
||||||
|
|
||||||
|
export const createHostConnection: RequestHandler< |
||||||
|
unknown, |
||||||
|
undefined, |
||||||
|
CreateHostConnectionRequestBody |
||||||
|
> = (request, response) => { |
||||||
|
const { |
||||||
|
body: { |
||||||
|
dbName = 'anvil', |
||||||
|
ipAddress, |
||||||
|
isPing = false, |
||||||
|
password, |
||||||
|
port = 5432, |
||||||
|
sshPort = 22, |
||||||
|
user = 'admin', |
||||||
|
}, |
||||||
|
} = request; |
||||||
|
|
||||||
|
const commonDBName = sanitize(dbName, 'string'); |
||||||
|
const commonIsPing = sanitize(isPing, 'boolean'); |
||||||
|
const commonPassword = sanitize(password, 'string'); |
||||||
|
const commonDBPort = sanitize(port, 'number'); |
||||||
|
const commonDBUser = sanitize(user, 'string'); |
||||||
|
const peerIPAddress = sanitize(ipAddress, 'string'); |
||||||
|
const peerSSHPort = sanitize(sshPort, 'number'); |
||||||
|
|
||||||
|
const commonPing = commonIsPing ? 1 : 0; |
||||||
|
|
||||||
|
let localDBPort: number; |
||||||
|
let localIPAddress: string; |
||||||
|
let isPeerReachable = false; |
||||||
|
let isPeerDBReachable = false; |
||||||
|
let peerHostUUID: string; |
||||||
|
|
||||||
|
try { |
||||||
|
({ hostUUID: peerHostUUID, isConnected: isPeerReachable } = getPeerData( |
||||||
|
peerIPAddress, |
||||||
|
{ password: commonPassword, port: peerSSHPort }, |
||||||
|
)); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to get peer data; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
stdoutVar({ peerHostUUID, isPeerReachable }); |
||||||
|
|
||||||
|
if (!isPeerReachable) { |
||||||
|
stderr( |
||||||
|
`Cannot connect to peer; please verify credentials and SSH keys validity.`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
localIPAddress = sub('find_matching_ip', { |
||||||
|
subModuleName: 'System', |
||||||
|
subParams: { host: peerIPAddress }, |
||||||
|
}).stdout; |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to get matching IP address; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
stdoutVar({ localIPAddress }); |
||||||
|
|
||||||
|
const pgpassFilePath = '/tmp/.pgpass'; |
||||||
|
const pgpassFileBody = `${peerIPAddress}:${commonDBPort}:${commonDBName}:${commonDBUser}:${commonPassword.replace( |
||||||
|
/:/g, |
||||||
|
'\\:', |
||||||
|
)}`;
|
||||||
|
|
||||||
|
stdoutVar({ pgpassFilePath, pgpassFileBody }); |
||||||
|
|
||||||
|
try { |
||||||
|
sub('write_file', { |
||||||
|
subModuleName: 'Storage', |
||||||
|
subParams: { |
||||||
|
body: pgpassFileBody, |
||||||
|
file: pgpassFilePath, |
||||||
|
mode: '0600', |
||||||
|
overwrite: 1, |
||||||
|
secure: 1, |
||||||
|
}, |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to write ${pgpassFilePath}; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
const [rawIsPeerDBReachable] = sub('call', { |
||||||
|
subModuleName: 'System', |
||||||
|
subParams: { |
||||||
|
shell_call: `PGPASSFILE="${pgpassFilePath}" ${SERVER_PATHS.usr.bin.psql.self} --host ${peerIPAddress} --port ${commonDBPort} --dbname ${commonDBName} --username ${commonDBUser} --no-password --tuples-only --no-align --command "SELECT 1"`, |
||||||
|
}, |
||||||
|
}).stdout as [output: string, returnCode: number]; |
||||||
|
|
||||||
|
isPeerDBReachable = rawIsPeerDBReachable === '1'; |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to test connection to peer database; CAUSE: ${subError}`); |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
rm(pgpassFilePath); |
||||||
|
} catch (fsError) { |
||||||
|
stderr(`Failed to remove ${pgpassFilePath}; CAUSE: ${fsError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
stdoutVar({ isPeerDBReachable }); |
||||||
|
|
||||||
|
if (!isPeerDBReachable) { |
||||||
|
stderr( |
||||||
|
`Cannot connect to peer database; please verify database credentials.`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
const localHostUUID = getLocalHostUUID(); |
||||||
|
|
||||||
|
try { |
||||||
|
const { |
||||||
|
database: { |
||||||
|
[localHostUUID]: { port: rawLocalDBPort }, |
||||||
|
}, |
||||||
|
} = getAnvilData({ database: true }) as { database: DatabaseHash }; |
||||||
|
|
||||||
|
localDBPort = sanitize(rawLocalDBPort, 'number'); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to get local database data from hash; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
const jobCommand = `${SERVER_PATHS.usr.sbin['striker-manage-peers'].self} --add --host-uuid ${peerHostUUID} --host ${peerIPAddress} --port ${commonDBPort} --ping ${commonPing}`; |
||||||
|
const peerJobCommand = `${SERVER_PATHS.usr.sbin['striker-manage-peers'].self} --add --host-uuid ${localHostUUID} --host ${localIPAddress} --port ${localDBPort} --ping ${commonPing}`; |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: jobCommand, |
||||||
|
job_data: `password=${commonPassword} |
||||||
|
peer_job_command=${peerJobCommand}`,
|
||||||
|
job_description: 'job_0012', |
||||||
|
job_name: 'striker-peer::add', |
||||||
|
job_title: 'job_0011', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to add peer ${peerHostUUID}; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(201).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,42 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
import { toHostUUID } from '../../convertHostUUID'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
export const deleteHostConnection: RequestHandler< |
||||||
|
unknown, |
||||||
|
undefined, |
||||||
|
DeleteHostConnectionRequestBody |
||||||
|
> = (request, response) => { |
||||||
|
const { body } = request; |
||||||
|
const hostUUIDs = Object.keys(body); |
||||||
|
|
||||||
|
hostUUIDs.forEach((key) => { |
||||||
|
const hostUUID = toHostUUID(key); |
||||||
|
const peerHostUUIDs = body[key]; |
||||||
|
|
||||||
|
peerHostUUIDs.forEach((peerHostUUID) => { |
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: `${SERVER_PATHS.usr.sbin['striker-manage-peers'].self} --remove --host-uuid ${peerHostUUID}`, |
||||||
|
job_description: 'job_0014', |
||||||
|
job_host_uuid: hostUUID, |
||||||
|
job_name: 'striker-peer::delete', |
||||||
|
job_title: 'job_0013', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to delete peer ${peerHostUUID}; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
}); |
||||||
|
}); |
||||||
|
|
||||||
|
response.status(204).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,48 @@ |
|||||||
|
import { getLocalHostUUID } from '../../accessModule'; |
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { buildQueryHostDetail } from './buildQueryHostDetail'; |
||||||
|
import { buildQueryResultReducer } from '../../buildQueryResultModifier'; |
||||||
|
import { toLocal } from '../../convertHostUUID'; |
||||||
|
import { getShortHostName } from '../../getShortHostName'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
|
||||||
|
export const getHost = buildGetRequestHandler((request, buildQueryOptions) => { |
||||||
|
const { hostUUIDs } = request.query; |
||||||
|
|
||||||
|
const localHostUUID: string = getLocalHostUUID(); |
||||||
|
|
||||||
|
let query = ` |
||||||
|
SELECT |
||||||
|
hos.host_name, |
||||||
|
hos.host_uuid |
||||||
|
FROM hosts AS hos;`;
|
||||||
|
let afterQueryReturn: QueryResultModifierFunction | undefined = |
||||||
|
buildQueryResultReducer<{ [hostUUID: string]: HostOverview }>( |
||||||
|
(previous, [hostName, hostUUID]) => { |
||||||
|
const key = toLocal(hostUUID, localHostUUID); |
||||||
|
|
||||||
|
previous[key] = { |
||||||
|
hostName, |
||||||
|
hostUUID, |
||||||
|
shortHostName: getShortHostName(hostName), |
||||||
|
}; |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, |
||||||
|
{}, |
||||||
|
); |
||||||
|
|
||||||
|
if (hostUUIDs) { |
||||||
|
({ query, afterQueryReturn } = buildQueryHostDetail({ |
||||||
|
keys: sanitize(hostUUIDs, 'string[]', { |
||||||
|
modifierType: 'sql', |
||||||
|
}), |
||||||
|
})); |
||||||
|
} |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = afterQueryReturn; |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}); |
||||||
@ -0,0 +1,128 @@ |
|||||||
|
import { getAnvilData, getLocalHostUUID } from '../../accessModule'; |
||||||
|
import { buildUnknownIDCondition } from '../../buildCondition'; |
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { toLocal } from '../../convertHostUUID'; |
||||||
|
import { match } from '../../match'; |
||||||
|
import { stdout } from '../../shell'; |
||||||
|
|
||||||
|
const buildHostConnections = ( |
||||||
|
fromHostUUID: string, |
||||||
|
databaseHash: DatabaseHash, |
||||||
|
{ |
||||||
|
defaultPort = 5432, |
||||||
|
defaultUser = 'admin', |
||||||
|
}: { defaultPort?: number; defaultUser?: string } = {}, |
||||||
|
) => |
||||||
|
Object.entries(databaseHash).reduce<HostConnectionOverview>( |
||||||
|
(previous, [hostUUID, { host: ipAddress, ping, port: rawPort, user }]) => { |
||||||
|
const port = parseInt(rawPort); |
||||||
|
|
||||||
|
if (hostUUID === fromHostUUID) { |
||||||
|
previous.inbound.port = port; |
||||||
|
previous.inbound.user = user; |
||||||
|
} else { |
||||||
|
previous.peer[ipAddress] = { |
||||||
|
hostUUID, |
||||||
|
ipAddress, |
||||||
|
isPing: ping === '1', |
||||||
|
port, |
||||||
|
user, |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, |
||||||
|
{ |
||||||
|
inbound: { ipAddress: {}, port: defaultPort, user: defaultUser }, |
||||||
|
peer: {}, |
||||||
|
}, |
||||||
|
); |
||||||
|
|
||||||
|
export const getHostConnection = buildGetRequestHandler( |
||||||
|
(request, buildQueryOptions) => { |
||||||
|
const { hostUUIDs: rawHostUUIDs } = request.query; |
||||||
|
|
||||||
|
let rawDatabaseData: DatabaseHash; |
||||||
|
|
||||||
|
const hostUUIDField = 'ip_add.ip_address_host_uuid'; |
||||||
|
const localHostUUID: string = getLocalHostUUID(); |
||||||
|
const { after: condHostUUIDs, before: beforeBuildIDCond } = |
||||||
|
buildUnknownIDCondition(rawHostUUIDs, hostUUIDField, { |
||||||
|
onFallback: () => `${hostUUIDField} = '${localHostUUID}'`, |
||||||
|
}); |
||||||
|
const hostUUIDs = |
||||||
|
beforeBuildIDCond.length > 0 ? beforeBuildIDCond : [localHostUUID]; |
||||||
|
|
||||||
|
const getConnectionKey = (hostUUID: string) => |
||||||
|
toLocal(hostUUID, localHostUUID); |
||||||
|
|
||||||
|
stdout(`condHostUUIDs=[${condHostUUIDs}]`); |
||||||
|
|
||||||
|
try { |
||||||
|
({ database: rawDatabaseData } = getAnvilData({ database: true })); |
||||||
|
} catch (subError) { |
||||||
|
throw new Error(`Failed to get anvil data; CAUSE: ${subError}`); |
||||||
|
} |
||||||
|
|
||||||
|
const connections = hostUUIDs.reduce<{ |
||||||
|
[hostUUID: string]: HostConnectionOverview; |
||||||
|
}>((previous, hostUUID) => { |
||||||
|
const connectionKey = getConnectionKey(hostUUID); |
||||||
|
|
||||||
|
previous[connectionKey] = buildHostConnections(hostUUID, rawDatabaseData); |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, {}); |
||||||
|
|
||||||
|
stdout(`connections=[${JSON.stringify(connections, null, 2)}]`); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = (queryStdout) => { |
||||||
|
let result = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
queryStdout.forEach( |
||||||
|
([ipAddressUUID, hostUUID, ipAddress, network]) => { |
||||||
|
const [, networkType, rawNetworkNumber, rawNetworkLinkNumber] = |
||||||
|
match(network, /^([^\s]+)(\d+)_[^\s]+(\d+)$/); |
||||||
|
const connectionKey = getConnectionKey(hostUUID); |
||||||
|
|
||||||
|
connections[connectionKey].inbound.ipAddress[ipAddress] = { |
||||||
|
hostUUID, |
||||||
|
ipAddress, |
||||||
|
ipAddressUUID, |
||||||
|
networkLinkNumber: parseInt(rawNetworkLinkNumber), |
||||||
|
networkNumber: parseInt(rawNetworkNumber), |
||||||
|
networkType, |
||||||
|
}; |
||||||
|
}, |
||||||
|
); |
||||||
|
|
||||||
|
result = connections; |
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return `SELECT
|
||||||
|
ip_add.ip_address_uuid, |
||||||
|
ip_add.ip_address_host_uuid, |
||||||
|
ip_add.ip_address_address, |
||||||
|
CASE |
||||||
|
WHEN ip_add.ip_address_on_type = 'interface' |
||||||
|
THEN net_int.network_interface_name |
||||||
|
ELSE bon.bond_active_interface |
||||||
|
END AS network_name |
||||||
|
FROM ip_addresses AS ip_add |
||||||
|
LEFT JOIN network_interfaces AS net_int |
||||||
|
ON ip_add.ip_address_on_uuid = net_int.network_interface_uuid |
||||||
|
LEFT JOIN bridges AS bri |
||||||
|
ON ip_add.ip_address_on_uuid = bri.bridge_uuid |
||||||
|
LEFT JOIN bonds AS bon |
||||||
|
ON bri.bridge_uuid = bon.bond_bridge_uuid |
||||||
|
OR ip_add.ip_address_on_uuid = bon.bond_uuid |
||||||
|
WHERE ${condHostUUIDs} |
||||||
|
AND ip_add.ip_address_note != 'DELETED';`;
|
||||||
|
}, |
||||||
|
); |
||||||
@ -0,0 +1,19 @@ |
|||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { buildQueryHostDetail } from './buildQueryHostDetail'; |
||||||
|
import { toHostUUID } from '../../convertHostUUID'; |
||||||
|
import { sanitizeSQLParam } from '../../sanitizeSQLParam'; |
||||||
|
|
||||||
|
export const getHostDetail = buildGetRequestHandler( |
||||||
|
({ params: { hostUUID: rawHostUUID } }, buildQueryOptions) => { |
||||||
|
const hostUUID = toHostUUID(rawHostUUID); |
||||||
|
const { afterQueryReturn, query } = buildQueryHostDetail({ |
||||||
|
keys: [sanitizeSQLParam(hostUUID)], |
||||||
|
}); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = afterQueryReturn; |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}, |
||||||
|
); |
||||||
@ -0,0 +1,8 @@ |
|||||||
|
export * from './createHost'; |
||||||
|
export * from './createHostConnection'; |
||||||
|
export * from './deleteHostConnection'; |
||||||
|
export * from './getHost'; |
||||||
|
export * from './getHostConnection'; |
||||||
|
export * from './getHostDetail'; |
||||||
|
export * from './prepareHost'; |
||||||
|
export * from './updateHost'; |
||||||
@ -0,0 +1,150 @@ |
|||||||
|
import assert from 'assert'; |
||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
REP_DOMAIN, |
||||||
|
REP_IPV4, |
||||||
|
REP_PEACEFUL_STRING, |
||||||
|
REP_UUID, |
||||||
|
} from '../../consts/REG_EXP_PATTERNS'; |
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job, variable } from '../../accessModule'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
export const prepareHost: RequestHandler< |
||||||
|
unknown, |
||||||
|
undefined, |
||||||
|
PrepareHostRequestBody |
||||||
|
> = (request, response) => { |
||||||
|
const { |
||||||
|
body: { |
||||||
|
enterpriseUUID, |
||||||
|
hostIPAddress, |
||||||
|
hostName, |
||||||
|
hostPassword, |
||||||
|
hostSSHPort, |
||||||
|
hostType, |
||||||
|
hostUser = 'root', |
||||||
|
hostUUID, |
||||||
|
redhatPassword, |
||||||
|
redhatUser, |
||||||
|
} = {}, |
||||||
|
} = request; |
||||||
|
|
||||||
|
const isEnterpriseUUIDProvided = Boolean(enterpriseUUID); |
||||||
|
const isHostUUIDProvided = Boolean(hostUUID); |
||||||
|
const isRedhatAccountProvided = |
||||||
|
Boolean(redhatPassword) || Boolean(redhatUser); |
||||||
|
|
||||||
|
const dataEnterpriseUUID = sanitize(enterpriseUUID, 'string'); |
||||||
|
const dataHostIPAddress = sanitize(hostIPAddress, 'string'); |
||||||
|
const dataHostName = sanitize(hostName, 'string'); |
||||||
|
const dataHostPassword = sanitize(hostPassword, 'string'); |
||||||
|
const dataHostSSHPort = sanitize(hostSSHPort, 'number') || 22; |
||||||
|
const dataHostType = sanitize(hostType, 'string'); |
||||||
|
// Host user is unused at the moment.
|
||||||
|
const dataHostUser = sanitize(hostUser, 'string'); |
||||||
|
const dataHostUUID = sanitize(hostUUID, 'string'); |
||||||
|
const dataRedhatPassword = sanitize(redhatPassword, 'string'); |
||||||
|
const dataRedhatUser = sanitize(redhatUser, 'string'); |
||||||
|
|
||||||
|
try { |
||||||
|
assert( |
||||||
|
REP_IPV4.test(dataHostIPAddress), |
||||||
|
`Data host IP address must be a valid IPv4 address; got [${dataHostIPAddress}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_DOMAIN.test(dataHostName), |
||||||
|
`Data host name can only contain alphanumeric, hyphen, and dot characters; got [${dataHostName}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_PEACEFUL_STRING.test(dataHostPassword), |
||||||
|
`Data host password must be peaceful string; got [${dataHostPassword}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
/^node|dr$/.test(dataHostType), |
||||||
|
`Data host type must be one of "node" or "dr"; got [${dataHostType}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_PEACEFUL_STRING.test(dataHostUser), |
||||||
|
`Data host user must be a peaceful string; got [${dataHostUser}]`, |
||||||
|
); |
||||||
|
|
||||||
|
if (isEnterpriseUUIDProvided) { |
||||||
|
assert( |
||||||
|
REP_UUID.test(dataEnterpriseUUID), |
||||||
|
`Data enterprise UUID must be a valid UUIDv4; got [${dataEnterpriseUUID}]`, |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
if (isHostUUIDProvided) { |
||||||
|
assert( |
||||||
|
REP_UUID.test(dataHostUUID), |
||||||
|
`Data host UUID must be a valid UUIDv4; got [${dataHostUUID}]`, |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
if (isRedhatAccountProvided) { |
||||||
|
assert( |
||||||
|
REP_PEACEFUL_STRING.test(dataRedhatPassword), |
||||||
|
`Data redhat password must be a peaceful string; got [${dataRedhatPassword}]`, |
||||||
|
); |
||||||
|
|
||||||
|
assert( |
||||||
|
REP_PEACEFUL_STRING.test(dataRedhatUser), |
||||||
|
`Data redhat user must be a peaceful string; got [${dataRedhatUser}]`, |
||||||
|
); |
||||||
|
} |
||||||
|
} catch (assertError) { |
||||||
|
stderr( |
||||||
|
`Failed to assert value when trying to prepare host; CAUSE: ${assertError}`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
if (isHostUUIDProvided) { |
||||||
|
variable({ |
||||||
|
file: __filename, |
||||||
|
update_value_only: 1, |
||||||
|
variable_name: 'system::configured', |
||||||
|
variable_source_table: 'hosts', |
||||||
|
variable_source_uuid: dataHostUUID, |
||||||
|
variable_value: 0, |
||||||
|
}); |
||||||
|
} |
||||||
|
|
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['striker-initialize-host'].self, |
||||||
|
job_data: `enterprise_uuid=${dataEnterpriseUUID} |
||||||
|
host_ip_address=${dataHostIPAddress} |
||||||
|
host_name=${dataHostName} |
||||||
|
password=${dataHostPassword} |
||||||
|
rh_password=${dataRedhatPassword} |
||||||
|
rh_user=${dataRedhatUser} |
||||||
|
ssh_port=${dataHostSSHPort} |
||||||
|
type=${dataHostType}`,
|
||||||
|
job_description: 'job_0022', |
||||||
|
job_name: `initialize::${dataHostType}::${dataHostIPAddress}`, |
||||||
|
job_title: `job_002${dataHostType === 'dr' ? '1' : '0'}`, |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to init host; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(200).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,39 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { LOCAL } from '../../consts/LOCAL'; |
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
import { stderr, stdout } from '../../shell'; |
||||||
|
|
||||||
|
export const setHostInstallTarget: RequestHandler = (request, response) => { |
||||||
|
stdout( |
||||||
|
`Begin set host install target.\n${JSON.stringify(request.body, null, 2)}`, |
||||||
|
); |
||||||
|
|
||||||
|
const { isEnableInstallTarget } = |
||||||
|
request.body as SetHostInstallTargetRequestBody; |
||||||
|
const { hostUUID: rawHostUUID } = request.params as UpdateHostParams; |
||||||
|
const hostUUID: string | undefined = |
||||||
|
rawHostUUID === LOCAL ? undefined : rawHostUUID; |
||||||
|
const task = isEnableInstallTarget ? 'enable' : 'disable'; |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: `${SERVER_PATHS.usr.sbin['striker-manage-install-target'].self} --${task}`, |
||||||
|
job_description: 'job_0016', |
||||||
|
job_host_uuid: hostUUID, |
||||||
|
job_name: `install-target::${task}`, |
||||||
|
job_title: 'job_0015', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to ${task} install target; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(200).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,8 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { buildBranchRequestHandler } from '../buildBranchRequestHandler'; |
||||||
|
import { setHostInstallTarget } from './setHostInstallTarget'; |
||||||
|
|
||||||
|
export const updateHost: RequestHandler = buildBranchRequestHandler({ |
||||||
|
'install-target': setHostInstallTarget, |
||||||
|
}); |
||||||
@ -0,0 +1,82 @@ |
|||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
import { date, stdout } from '../../shell'; |
||||||
|
|
||||||
|
export const getJob = buildGetRequestHandler((request, buildQueryOptions) => { |
||||||
|
const { start: rawStart } = request.query; |
||||||
|
|
||||||
|
const start = sanitize(rawStart, 'number'); |
||||||
|
|
||||||
|
let condModifiedDate = ''; |
||||||
|
|
||||||
|
try { |
||||||
|
const minDate = date('--date', `@${start}`, '--rfc-3339', 'ns'); |
||||||
|
|
||||||
|
condModifiedDate = `OR (job.job_progress = 100 AND job.modified_date >= '${minDate}')`; |
||||||
|
} catch (shellError) { |
||||||
|
throw new Error( |
||||||
|
`Failed to build date condition for job query; CAUSE: ${shellError}`, |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
stdout(`condModifiedDate=[${condModifiedDate}]`); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = (queryStdout) => { |
||||||
|
let result = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
result = queryStdout.reduce<{ |
||||||
|
[jobUUID: string]: { |
||||||
|
jobCommand: string; |
||||||
|
jobHostName: string; |
||||||
|
jobHostUUID: string; |
||||||
|
jobName: string; |
||||||
|
jobProgress: number; |
||||||
|
jobUUID: string; |
||||||
|
}; |
||||||
|
}>( |
||||||
|
( |
||||||
|
previous, |
||||||
|
[ |
||||||
|
jobUUID, |
||||||
|
jobName, |
||||||
|
jobHostUUID, |
||||||
|
jobHostName, |
||||||
|
jobCommand, |
||||||
|
rawJobProgress, |
||||||
|
], |
||||||
|
) => { |
||||||
|
previous[jobUUID] = { |
||||||
|
jobCommand, |
||||||
|
jobHostName, |
||||||
|
jobHostUUID, |
||||||
|
jobName, |
||||||
|
jobProgress: parseFloat(rawJobProgress), |
||||||
|
jobUUID, |
||||||
|
}; |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, |
||||||
|
{}, |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
job.job_uuid, |
||||||
|
job.job_name, |
||||||
|
job.job_host_uuid, |
||||||
|
hos.host_name, |
||||||
|
job.job_command, |
||||||
|
job.job_progress |
||||||
|
FROM jobs AS job |
||||||
|
JOIN hosts AS hos |
||||||
|
ON job.job_host_uuid = hos.host_uuid |
||||||
|
WHERE job.job_progress < 100 |
||||||
|
${condModifiedDate};`;
|
||||||
|
}); |
||||||
@ -0,0 +1 @@ |
|||||||
|
export * from './getJob'; |
||||||
@ -0,0 +1,54 @@ |
|||||||
|
import { getLocalHostUUID } from '../../accessModule'; |
||||||
|
|
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
|
||||||
|
export const getNetworkInterface = buildGetRequestHandler( |
||||||
|
(request, buildQueryOptions) => { |
||||||
|
const localHostUUID: string = getLocalHostUUID(); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = (queryStdout) => { |
||||||
|
let result = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
result = queryStdout.map<NetworkInterfaceOverview>( |
||||||
|
([ |
||||||
|
networkInterfaceUUID, |
||||||
|
networkInterfaceMACAddress, |
||||||
|
networkInterfaceName, |
||||||
|
networkInterfaceState, |
||||||
|
networkInterfaceSpeed, |
||||||
|
networkInterfaceOrder, |
||||||
|
]) => ({ |
||||||
|
networkInterfaceUUID, |
||||||
|
networkInterfaceMACAddress, |
||||||
|
networkInterfaceName, |
||||||
|
networkInterfaceState, |
||||||
|
networkInterfaceSpeed, |
||||||
|
networkInterfaceOrder, |
||||||
|
}), |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
network_interface_uuid, |
||||||
|
network_interface_mac_address, |
||||||
|
network_interface_name, |
||||||
|
CASE |
||||||
|
WHEN network_interface_link_state = '1' |
||||||
|
AND network_interface_operational = 'up' |
||||||
|
THEN 'up' |
||||||
|
ELSE 'down' |
||||||
|
END AS network_interface_state, |
||||||
|
network_interface_speed, |
||||||
|
ROW_NUMBER() OVER(ORDER BY modified_date ASC) AS network_interface_order |
||||||
|
FROM network_interfaces |
||||||
|
WHERE network_interface_operational != 'DELETE' |
||||||
|
AND network_interface_host_uuid = '${localHostUUID}';`;
|
||||||
|
}, |
||||||
|
); |
||||||
@ -0,0 +1 @@ |
|||||||
|
export { getNetworkInterface } from './getNetworkInterface'; |
||||||
@ -0,0 +1,158 @@ |
|||||||
|
import assert from 'assert'; |
||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import { OS_LIST_MAP } from '../../consts/OS_LIST'; |
||||||
|
import { REP_INTEGER, REP_UUID } from '../../consts/REG_EXP_PATTERNS'; |
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { dbQuery, job } from '../../accessModule'; |
||||||
|
import { stderr, stdout } from '../../shell'; |
||||||
|
|
||||||
|
export const createServer: RequestHandler = ({ body }, response) => { |
||||||
|
stdout(`Creating server.\n${JSON.stringify(body, null, 2)}`); |
||||||
|
|
||||||
|
const { |
||||||
|
serverName, |
||||||
|
cpuCores, |
||||||
|
memory, |
||||||
|
virtualDisks: [ |
||||||
|
{ storageSize = undefined, storageGroupUUID = undefined } = {}, |
||||||
|
] = [], |
||||||
|
installISOFileUUID, |
||||||
|
driverISOFileUUID, |
||||||
|
anvilUUID, |
||||||
|
optimizeForOS, |
||||||
|
} = body || {}; |
||||||
|
|
||||||
|
const dataServerName = String(serverName); |
||||||
|
const dataOS = String(optimizeForOS); |
||||||
|
const dataCPUCores = String(cpuCores); |
||||||
|
const dataRAM = String(memory); |
||||||
|
const dataStorageGroupUUID = String(storageGroupUUID); |
||||||
|
const dataStorageSize = String(storageSize); |
||||||
|
const dataInstallISO = String(installISOFileUUID); |
||||||
|
const dataDriverISO = String(driverISOFileUUID) || 'none'; |
||||||
|
const dataAnvilUUID = String(anvilUUID); |
||||||
|
|
||||||
|
try { |
||||||
|
assert( |
||||||
|
/^[0-9a-z_-]+$/i.test(dataServerName), |
||||||
|
`Data server name can only contain alphanumeric, underscore, and hyphen characters; got [${dataServerName}].`, |
||||||
|
); |
||||||
|
|
||||||
|
const [[serverNameCount]] = dbQuery( |
||||||
|
`SELECT COUNT(server_uuid) FROM servers WHERE server_name = '${dataServerName}'`, |
||||||
|
).stdout; |
||||||
|
|
||||||
|
assert( |
||||||
|
serverNameCount === 0, |
||||||
|
`Data server name already exists; got [${dataServerName}]`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
OS_LIST_MAP[dataOS] !== undefined, |
||||||
|
`Data OS not recognized; got [${dataOS}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_INTEGER.test(dataCPUCores), |
||||||
|
`Data CPU cores can only contain digits; got [${dataCPUCores}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_INTEGER.test(dataRAM), |
||||||
|
`Data RAM can only contain digits; got [${dataRAM}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_UUID.test(dataStorageGroupUUID), |
||||||
|
`Data storage group UUID must be a valid UUID; got [${dataStorageGroupUUID}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_INTEGER.test(dataStorageSize), |
||||||
|
`Data storage size can only contain digits; got [${dataStorageSize}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_UUID.test(dataInstallISO), |
||||||
|
`Data install ISO must be a valid UUID; got [${dataInstallISO}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
dataDriverISO === 'none' || REP_UUID.test(dataDriverISO), |
||||||
|
`Data driver ISO must be a valid UUID when provided; got [${dataDriverISO}].`, |
||||||
|
); |
||||||
|
assert( |
||||||
|
REP_UUID.test(dataAnvilUUID), |
||||||
|
`Data anvil UUID must be a valid UUID; got [${dataAnvilUUID}].`, |
||||||
|
); |
||||||
|
} catch (assertError) { |
||||||
|
stdout( |
||||||
|
`Failed to assert value when trying to provision a server; CAUSE: ${assertError}.`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(400).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
const provisionServerJobData = `server_name=${dataServerName} |
||||||
|
os=${dataOS} |
||||||
|
cpu_cores=${dataCPUCores} |
||||||
|
ram=${dataRAM} |
||||||
|
storage_group_uuid=${dataStorageGroupUUID} |
||||||
|
storage_size=${dataStorageSize} |
||||||
|
install_iso=${dataInstallISO} |
||||||
|
driver_iso=${dataDriverISO}`;
|
||||||
|
|
||||||
|
stdout(`provisionServerJobData=[${provisionServerJobData}]`); |
||||||
|
|
||||||
|
const [[provisionServerJobHostUUID]] = dbQuery( |
||||||
|
`SELECT
|
||||||
|
CASE |
||||||
|
WHEN pri_hos.primary_host_uuid IS NULL |
||||||
|
THEN nod_1.node1_host_uuid |
||||||
|
ELSE pri_hos.primary_host_uuid |
||||||
|
END AS host_uuid |
||||||
|
FROM ( |
||||||
|
SELECT |
||||||
|
1 AS phl, |
||||||
|
sca_clu_nod.scan_cluster_node_host_uuid AS primary_host_uuid |
||||||
|
FROM anvils AS anv |
||||||
|
JOIN scan_cluster_nodes AS sca_clu_nod |
||||||
|
ON sca_clu_nod.scan_cluster_node_host_uuid = anv.anvil_node1_host_uuid |
||||||
|
OR sca_clu_nod.scan_cluster_node_host_uuid = anv.anvil_node2_host_uuid |
||||||
|
WHERE sca_clu_nod.scan_cluster_node_in_ccm |
||||||
|
AND sca_clu_nod.scan_cluster_node_crmd_member |
||||||
|
AND sca_clu_nod.scan_cluster_node_cluster_member |
||||||
|
AND (NOT sca_clu_nod.scan_cluster_node_maintenance_mode) |
||||||
|
AND anv.anvil_uuid = '${dataAnvilUUID}' |
||||||
|
ORDER BY sca_clu_nod.scan_cluster_node_name |
||||||
|
LIMIT 1 |
||||||
|
) AS pri_hos |
||||||
|
RIGHT JOIN ( |
||||||
|
SELECT |
||||||
|
1 AS phr, |
||||||
|
anv.anvil_node1_host_uuid AS node1_host_uuid |
||||||
|
FROM anvils AS anv |
||||||
|
WHERE anv.anvil_uuid = '${dataAnvilUUID}' |
||||||
|
) AS nod_1 |
||||||
|
ON pri_hos.phl = nod_1.phr;`,
|
||||||
|
).stdout; |
||||||
|
|
||||||
|
stdout(`provisionServerJobHostUUID=[${provisionServerJobHostUUID}]`); |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-provision-server'].self, |
||||||
|
job_data: provisionServerJobData, |
||||||
|
job_name: 'server:provision', |
||||||
|
job_title: 'job_0147', |
||||||
|
job_description: 'job_0148', |
||||||
|
job_host_uuid: provisionServerJobHostUUID, |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to provision server; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
response.status(202).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,60 @@ |
|||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import join from '../../join'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
|
||||||
|
export const getServer = buildGetRequestHandler( |
||||||
|
(request, buildQueryOptions) => { |
||||||
|
const { anvilUUIDs } = request.query; |
||||||
|
|
||||||
|
const condAnvilUUIDs = join(sanitize(anvilUUIDs, 'string[]'), { |
||||||
|
beforeReturn: (toReturn) => |
||||||
|
toReturn ? `AND ser.server_anvil_uuid IN (${toReturn})` : '', |
||||||
|
elementWrapper: "'", |
||||||
|
separator: ', ', |
||||||
|
}); |
||||||
|
|
||||||
|
console.log(`condAnvilsUUID=[${condAnvilUUIDs}]`); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = (queryStdout) => { |
||||||
|
let result = queryStdout; |
||||||
|
|
||||||
|
if (queryStdout instanceof Array) { |
||||||
|
result = queryStdout.map<ServerOverview>( |
||||||
|
([ |
||||||
|
serverUUID, |
||||||
|
serverName, |
||||||
|
serverState, |
||||||
|
serverHostUUID, |
||||||
|
anvilUUID, |
||||||
|
anvilName, |
||||||
|
]) => ({ |
||||||
|
serverHostUUID, |
||||||
|
serverName, |
||||||
|
serverState, |
||||||
|
serverUUID, |
||||||
|
anvilUUID, |
||||||
|
anvilName, |
||||||
|
}), |
||||||
|
); |
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
return ` |
||||||
|
SELECT |
||||||
|
ser.server_uuid, |
||||||
|
ser.server_name, |
||||||
|
ser.server_state, |
||||||
|
ser.server_host_uuid, |
||||||
|
anv.anvil_uuid, |
||||||
|
anv.anvil_name |
||||||
|
FROM servers AS ser |
||||||
|
JOIN anvils AS anv |
||||||
|
ON ser.server_anvil_uuid = anv.anvil_uuid |
||||||
|
WHERE ser.server_state != 'DELETED' |
||||||
|
${condAnvilUUIDs};`;
|
||||||
|
}, |
||||||
|
); |
||||||
@ -0,0 +1,152 @@ |
|||||||
|
import assert from 'assert'; |
||||||
|
import { RequestHandler } from 'express'; |
||||||
|
import { createReadStream } from 'fs'; |
||||||
|
import path from 'path'; |
||||||
|
|
||||||
|
import { REP_UUID } from '../../consts/REG_EXP_PATTERNS'; |
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { dbQuery, getLocalHostUUID, job } from '../../accessModule'; |
||||||
|
import { sanitize } from '../../sanitize'; |
||||||
|
import { mkfifo, rm } from '../../shell'; |
||||||
|
|
||||||
|
export const getServerDetail: RequestHandler = (request, response) => { |
||||||
|
const { serverUUID } = request.params; |
||||||
|
const { ss, resize } = request.query; |
||||||
|
|
||||||
|
const epoch = Date.now(); |
||||||
|
const isScreenshot = sanitize(ss, 'boolean'); |
||||||
|
|
||||||
|
console.log( |
||||||
|
`serverUUID=[${serverUUID}],epoch=[${epoch}],isScreenshot=[${isScreenshot}]`, |
||||||
|
); |
||||||
|
|
||||||
|
try { |
||||||
|
assert( |
||||||
|
REP_UUID.test(serverUUID), |
||||||
|
`Server UUID must be a valid UUID; got [${serverUUID}]`, |
||||||
|
); |
||||||
|
} catch (assertError) { |
||||||
|
console.log( |
||||||
|
`Failed to assert value when trying to get server detail; CAUSE: ${assertError}.`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
if (isScreenshot) { |
||||||
|
let requestHostUUID: string, serverHostUUID: string; |
||||||
|
|
||||||
|
try { |
||||||
|
requestHostUUID = getLocalHostUUID(); |
||||||
|
} catch (subError) { |
||||||
|
console.log(subError); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
console.log(`requestHostUUID=[${requestHostUUID}]`); |
||||||
|
|
||||||
|
try { |
||||||
|
[[serverHostUUID]] = dbQuery(` |
||||||
|
SELECT server_host_uuid |
||||||
|
FROM servers |
||||||
|
WHERE server_uuid = '${serverUUID}';`).stdout;
|
||||||
|
} catch (queryError) { |
||||||
|
console.log(`Failed to get server host UUID; CAUSE: ${queryError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
console.log(`serverHostUUID=[${serverHostUUID}]`); |
||||||
|
|
||||||
|
const imageFileName = `${serverUUID}_screenshot_${epoch}`; |
||||||
|
const imageFilePath = path.join(SERVER_PATHS.tmp.self, imageFileName); |
||||||
|
|
||||||
|
try { |
||||||
|
mkfifo(imageFilePath); |
||||||
|
|
||||||
|
const namedPipeReadStream = createReadStream(imageFilePath, { |
||||||
|
autoClose: true, |
||||||
|
encoding: 'utf-8', |
||||||
|
}); |
||||||
|
|
||||||
|
let imageData = ''; |
||||||
|
|
||||||
|
namedPipeReadStream.once('close', () => { |
||||||
|
console.log(`On close; removing named pipe at ${imageFilePath}.`); |
||||||
|
|
||||||
|
try { |
||||||
|
rm(imageFilePath); |
||||||
|
} catch (cleanPipeError) { |
||||||
|
console.log( |
||||||
|
`Failed to clean up named pipe; CAUSE: ${cleanPipeError}`, |
||||||
|
); |
||||||
|
} |
||||||
|
}); |
||||||
|
|
||||||
|
namedPipeReadStream.once('end', () => { |
||||||
|
response.status(200).send({ screenshot: imageData }); |
||||||
|
}); |
||||||
|
|
||||||
|
namedPipeReadStream.on('data', (data) => { |
||||||
|
const imageChunk = data.toString().trim(); |
||||||
|
const chunkLogLength = 10; |
||||||
|
|
||||||
|
console.log( |
||||||
|
`${serverUUID} image chunk: ${imageChunk.substring( |
||||||
|
0, |
||||||
|
chunkLogLength, |
||||||
|
)}...${imageChunk.substring(imageChunk.length - chunkLogLength - 1)}`,
|
||||||
|
); |
||||||
|
|
||||||
|
imageData += imageChunk; |
||||||
|
}); |
||||||
|
} catch (prepPipeError) { |
||||||
|
console.log(`Failed to prepare named pipe; CAUSE: ${prepPipeError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
|
||||||
|
let resizeArgs = sanitize(resize, 'string'); |
||||||
|
|
||||||
|
if (!/^\d+x\d+$/.test(resizeArgs)) { |
||||||
|
resizeArgs = ''; |
||||||
|
} |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-get-server-screenshot'].self, |
||||||
|
job_data: `server-uuid=${serverUUID} |
||||||
|
request-host-uuid=${requestHostUUID} |
||||||
|
resize=${resizeArgs} |
||||||
|
out-file-id=${epoch}`,
|
||||||
|
job_name: `get_server_screenshot::${serverUUID}::${epoch}`, |
||||||
|
job_title: 'job_0356', |
||||||
|
job_description: 'job_0357', |
||||||
|
job_host_uuid: serverHostUUID, |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
console.log( |
||||||
|
`Failed to queue fetch server screenshot job; CAUSE: ${subError}`, |
||||||
|
); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
} else { |
||||||
|
// For getting sever detail data.
|
||||||
|
|
||||||
|
response.status(200).send(); |
||||||
|
} |
||||||
|
}; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
export { createServer } from './createServer'; |
||||||
|
export { getServer } from './getServer'; |
||||||
|
export { getServerDetail } from './getServerDetail'; |
||||||
@ -0,0 +1,41 @@ |
|||||||
|
import { RequestHandler } from 'express'; |
||||||
|
|
||||||
|
import SERVER_PATHS from '../../consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
import { job } from '../../accessModule'; |
||||||
|
import { toHostUUID } from '../../convertHostUUID'; |
||||||
|
import { stderr } from '../../shell'; |
||||||
|
|
||||||
|
export const deleteSSHKeyConflict: RequestHandler< |
||||||
|
unknown, |
||||||
|
undefined, |
||||||
|
DeleteSSHKeyConflictRequestBody |
||||||
|
> = (request, response) => { |
||||||
|
const { body } = request; |
||||||
|
const hostUUIDs = Object.keys(body); |
||||||
|
|
||||||
|
hostUUIDs.forEach((key) => { |
||||||
|
const hostUUID = toHostUUID(key); |
||||||
|
const stateUUIDs = body[key]; |
||||||
|
|
||||||
|
try { |
||||||
|
job({ |
||||||
|
file: __filename, |
||||||
|
job_command: SERVER_PATHS.usr.sbin['anvil-manage-keys'].self, |
||||||
|
job_data: stateUUIDs.join(','), |
||||||
|
job_description: 'job_0057', |
||||||
|
job_host_uuid: hostUUID, |
||||||
|
job_name: 'manage::broken_keys', |
||||||
|
job_title: 'job_0056', |
||||||
|
}); |
||||||
|
} catch (subError) { |
||||||
|
stderr(`Failed to delete bad SSH keys; CAUSE: ${subError}`); |
||||||
|
|
||||||
|
response.status(500).send(); |
||||||
|
|
||||||
|
return; |
||||||
|
} |
||||||
|
}); |
||||||
|
|
||||||
|
response.status(204).send(); |
||||||
|
}; |
||||||
@ -0,0 +1,66 @@ |
|||||||
|
import { HOST_KEY_CHANGED_PREFIX } from '../../consts/HOST_KEY_CHANGED_PREFIX'; |
||||||
|
|
||||||
|
import { getLocalHostUUID } from '../../accessModule'; |
||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { buildQueryResultReducer } from '../../buildQueryResultModifier'; |
||||||
|
import { toLocal } from '../../convertHostUUID'; |
||||||
|
import { match } from '../../match'; |
||||||
|
|
||||||
|
export const getSSHKeyConflict = buildGetRequestHandler( |
||||||
|
(request, buildQueryOptions) => { |
||||||
|
const localHostUUID: string = getLocalHostUUID(); |
||||||
|
|
||||||
|
const query = ` |
||||||
|
SELECT |
||||||
|
hos.host_name, |
||||||
|
hos.host_uuid, |
||||||
|
sta.state_name, |
||||||
|
sta.state_note, |
||||||
|
sta.state_uuid |
||||||
|
FROM states AS sta |
||||||
|
JOIN hosts AS hos |
||||||
|
ON sta.state_host_uuid = hos.host_uuid |
||||||
|
WHERE sta.state_name LIKE '${HOST_KEY_CHANGED_PREFIX}%';`;
|
||||||
|
const afterQueryReturn = buildQueryResultReducer<{ |
||||||
|
[hostUUID: string]: { |
||||||
|
[stateUUID: string]: { |
||||||
|
badFile: string; |
||||||
|
badLine: number; |
||||||
|
hostName: string; |
||||||
|
hostUUID: string; |
||||||
|
ipAddress: string; |
||||||
|
stateUUID: string; |
||||||
|
}; |
||||||
|
}; |
||||||
|
}>((previous, [hostName, hostUUID, stateName, stateNote, stateUUID]) => { |
||||||
|
const hostUUIDKey = toLocal(hostUUID, localHostUUID); |
||||||
|
|
||||||
|
if (previous[hostUUIDKey] === undefined) { |
||||||
|
previous[hostUUIDKey] = {}; |
||||||
|
} |
||||||
|
|
||||||
|
const ipAddress = stateName.slice(HOST_KEY_CHANGED_PREFIX.length); |
||||||
|
const [, badFile, badLine = '0'] = match( |
||||||
|
stateNote, |
||||||
|
/file=([^\s]+),line=(\d+)/, |
||||||
|
); |
||||||
|
|
||||||
|
previous[hostUUIDKey][stateUUID] = { |
||||||
|
badFile, |
||||||
|
badLine: parseInt(badLine), |
||||||
|
hostName, |
||||||
|
hostUUID, |
||||||
|
ipAddress, |
||||||
|
stateUUID, |
||||||
|
}; |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, {}); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = afterQueryReturn; |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}, |
||||||
|
); |
||||||
@ -0,0 +1,2 @@ |
|||||||
|
export * from './deleteSSHKeyConflict'; |
||||||
|
export * from './getSSHKeyConflict'; |
||||||
@ -0,0 +1,27 @@ |
|||||||
|
import buildGetRequestHandler from '../buildGetRequestHandler'; |
||||||
|
import { buildQueryResultReducer } from '../../buildQueryResultModifier'; |
||||||
|
|
||||||
|
export const getUser = buildGetRequestHandler((request, buildQueryOptions) => { |
||||||
|
const query = ` |
||||||
|
SELECT |
||||||
|
use.user_name, |
||||||
|
use.user_uuid |
||||||
|
FROM users AS use;`;
|
||||||
|
const afterQueryReturn: QueryResultModifierFunction | undefined = |
||||||
|
buildQueryResultReducer< |
||||||
|
Record<string, { userName: string; userUUID: string }> |
||||||
|
>((previous, [userName, userUUID]) => { |
||||||
|
previous[userUUID] = { |
||||||
|
userName, |
||||||
|
userUUID, |
||||||
|
}; |
||||||
|
|
||||||
|
return previous; |
||||||
|
}, {}); |
||||||
|
|
||||||
|
if (buildQueryOptions) { |
||||||
|
buildQueryOptions.afterQueryReturn = afterQueryReturn; |
||||||
|
} |
||||||
|
|
||||||
|
return query; |
||||||
|
}); |
||||||
@ -0,0 +1 @@ |
|||||||
|
export * from './getUser'; |
||||||
@ -0,0 +1,71 @@ |
|||||||
|
import call from './call'; |
||||||
|
import { sanitizeSQLParam } from './sanitizeSQLParam'; |
||||||
|
|
||||||
|
type MapToReturnType = { |
||||||
|
boolean: boolean; |
||||||
|
number: number; |
||||||
|
string: string; |
||||||
|
'string[]': string[]; |
||||||
|
}; |
||||||
|
|
||||||
|
type MapToReturnFunction = { |
||||||
|
[ReturnTypeName in keyof MapToReturnType]: ( |
||||||
|
value: unknown, |
||||||
|
modifier: (unmodified: unknown) => string, |
||||||
|
) => MapToReturnType[ReturnTypeName]; |
||||||
|
}; |
||||||
|
|
||||||
|
type ModifierFunction = (unmodified: string) => string; |
||||||
|
|
||||||
|
type MapToModifierFunction = { |
||||||
|
none: undefined; |
||||||
|
sql: ModifierFunction; |
||||||
|
}; |
||||||
|
|
||||||
|
const MAP_TO_MODIFIER_FUNCTION: MapToModifierFunction = { |
||||||
|
none: undefined, |
||||||
|
sql: sanitizeSQLParam, |
||||||
|
}; |
||||||
|
|
||||||
|
const MAP_TO_RETURN_FUNCTION: MapToReturnFunction = { |
||||||
|
boolean: (value) => value !== undefined, |
||||||
|
number: (value) => parseFloat(String(value)) || 0, |
||||||
|
string: (value, mod) => (value ? mod(value) : ''), |
||||||
|
'string[]': (value, mod) => { |
||||||
|
let result: string[] = []; |
||||||
|
|
||||||
|
if (value instanceof Array) { |
||||||
|
result = value.reduce<string[]>((reduceContainer, element) => { |
||||||
|
if (element) { |
||||||
|
reduceContainer.push(mod(element)); |
||||||
|
} |
||||||
|
|
||||||
|
return reduceContainer; |
||||||
|
}, []); |
||||||
|
} else if (value) { |
||||||
|
result = mod(value).split(/[,;]/); |
||||||
|
} |
||||||
|
|
||||||
|
return result; |
||||||
|
}, |
||||||
|
}; |
||||||
|
|
||||||
|
export const sanitize = <ReturnTypeName extends keyof MapToReturnType>( |
||||||
|
value: unknown, |
||||||
|
returnType: ReturnTypeName, |
||||||
|
{ |
||||||
|
modifierType = 'none', |
||||||
|
modifier = MAP_TO_MODIFIER_FUNCTION[modifierType], |
||||||
|
}: { |
||||||
|
modifier?: ModifierFunction; |
||||||
|
modifierType?: keyof MapToModifierFunction; |
||||||
|
} = {}, |
||||||
|
): MapToReturnType[ReturnTypeName] => |
||||||
|
MAP_TO_RETURN_FUNCTION[returnType](value, (unmodified: unknown) => { |
||||||
|
const input = String(unmodified); |
||||||
|
|
||||||
|
return call<string>(modifier, { |
||||||
|
notCallableReturn: input, |
||||||
|
parameters: [input], |
||||||
|
}); |
||||||
|
}) as MapToReturnType[ReturnTypeName]; |
||||||
@ -0,0 +1,2 @@ |
|||||||
|
export const sanitizeSQLParam = (variable: string): string => |
||||||
|
variable.replace(/[']/g, ''); |
||||||
@ -0,0 +1,46 @@ |
|||||||
|
import { spawnSync } from 'child_process'; |
||||||
|
|
||||||
|
import SERVER_PATHS from './consts/SERVER_PATHS'; |
||||||
|
|
||||||
|
const print = ( |
||||||
|
message: string, |
||||||
|
{ |
||||||
|
eol = '\n', |
||||||
|
stream = 'stdout', |
||||||
|
}: { eol?: string; stream?: 'stderr' | 'stdout' } = {}, |
||||||
|
) => process[stream].write(`${message}${eol}`); |
||||||
|
|
||||||
|
const systemCall = ( |
||||||
|
...[command, args = [], options = {}]: Parameters<typeof spawnSync> |
||||||
|
) => { |
||||||
|
const { error, stderr, stdout } = spawnSync(command, args, { |
||||||
|
...options, |
||||||
|
encoding: 'utf-8', |
||||||
|
}); |
||||||
|
|
||||||
|
if (error) { |
||||||
|
throw error; |
||||||
|
} |
||||||
|
|
||||||
|
if (stderr) { |
||||||
|
throw new Error(stderr); |
||||||
|
} |
||||||
|
|
||||||
|
return stdout; |
||||||
|
}; |
||||||
|
|
||||||
|
export const date = (...args: string[]) => |
||||||
|
systemCall(SERVER_PATHS.usr.bin.date.self, args); |
||||||
|
|
||||||
|
export const mkfifo = (...args: string[]) => |
||||||
|
systemCall(SERVER_PATHS.usr.bin.mkfifo.self, args); |
||||||
|
|
||||||
|
export const rm = (...args: string[]) => |
||||||
|
systemCall(SERVER_PATHS.usr.bin.rm.self, args); |
||||||
|
|
||||||
|
export const stderr = (message: string) => print(message, { stream: 'stderr' }); |
||||||
|
|
||||||
|
export const stdout = (message: string) => print(message); |
||||||
|
|
||||||
|
export const stdoutVar = (variable: { [name: string]: unknown }) => |
||||||
|
print(`Variables: ${JSON.stringify(variable, null, 2)}`); |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import getAnvil from '../lib/request_handlers/anvil/getAnvil'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router.get('/', getAnvil); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,18 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
getHostSSH, |
||||||
|
poweroffHost, |
||||||
|
rebootHost, |
||||||
|
updateSystem, |
||||||
|
} from '../lib/request_handlers/command'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router |
||||||
|
.put('/inquire-host', getHostSSH) |
||||||
|
.put('/poweroff-host', poweroffHost) |
||||||
|
.put('/reboot-host', rebootHost) |
||||||
|
.put('/update-system', updateSystem); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,28 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
createHost, |
||||||
|
createHostConnection, |
||||||
|
deleteHostConnection, |
||||||
|
getHost, |
||||||
|
getHostConnection, |
||||||
|
getHostDetail, |
||||||
|
prepareHost, |
||||||
|
updateHost, |
||||||
|
} from '../lib/request_handlers/host'; |
||||||
|
|
||||||
|
const CONNECTION_PATH = '/connection'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router |
||||||
|
.get('/', getHost) |
||||||
|
.get(CONNECTION_PATH, getHostConnection) |
||||||
|
.get('/:hostUUID', getHostDetail) |
||||||
|
.post('/', createHost) |
||||||
|
.post(CONNECTION_PATH, createHostConnection) |
||||||
|
.put('/prepare', prepareHost) |
||||||
|
.put('/:hostUUID', updateHost) |
||||||
|
.delete(CONNECTION_PATH, deleteHostConnection); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,27 @@ |
|||||||
|
import { Router } from 'express'; |
||||||
|
|
||||||
|
import anvilRouter from './anvil'; |
||||||
|
import commandRouter from './command'; |
||||||
|
import echoRouter from './echo'; |
||||||
|
import fileRouter from './file'; |
||||||
|
import hostRouter from './host'; |
||||||
|
import jobRouter from './job'; |
||||||
|
import networkInterfaceRouter from './network-interface'; |
||||||
|
import serverRouter from './server'; |
||||||
|
import sshKeyRouter from './ssh-key'; |
||||||
|
import userRouter from './user'; |
||||||
|
|
||||||
|
const routes: Readonly<Record<string, Router>> = { |
||||||
|
anvil: anvilRouter, |
||||||
|
command: commandRouter, |
||||||
|
echo: echoRouter, |
||||||
|
file: fileRouter, |
||||||
|
host: hostRouter, |
||||||
|
job: jobRouter, |
||||||
|
'network-interface': networkInterfaceRouter, |
||||||
|
server: serverRouter, |
||||||
|
'ssh-key': sshKeyRouter, |
||||||
|
user: userRouter, |
||||||
|
}; |
||||||
|
|
||||||
|
export default routes; |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { getJob } from '../lib/request_handlers/job'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router.get('/', getJob); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { getNetworkInterface } from '../lib/request_handlers/network-interface'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router.get('/', getNetworkInterface); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,16 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
createServer, |
||||||
|
getServer, |
||||||
|
getServerDetail, |
||||||
|
} from '../lib/request_handlers/server'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router |
||||||
|
.get('/', getServer) |
||||||
|
.get('/:serverUUID', getServerDetail) |
||||||
|
.post('/', createServer); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,14 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { |
||||||
|
deleteSSHKeyConflict, |
||||||
|
getSSHKeyConflict, |
||||||
|
} from '../lib/request_handlers/ssh-key'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router |
||||||
|
.get('/conflict', getSSHKeyConflict) |
||||||
|
.delete('/conflict', deleteSSHKeyConflict); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
import express from 'express'; |
||||||
|
|
||||||
|
import { getUser } from '../lib/request_handlers/user'; |
||||||
|
|
||||||
|
const router = express.Router(); |
||||||
|
|
||||||
|
router.get('/', getUser); |
||||||
|
|
||||||
|
export default router; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
interface AnvilDataStruct { |
||||||
|
[key: string]: AnvilDataStruct | boolean; |
||||||
|
} |
||||||
@ -0,0 +1,33 @@ |
|||||||
|
type AnvilDetailForProvisionServer = { |
||||||
|
anvilUUID: string; |
||||||
|
anvilName: string; |
||||||
|
anvilDescription: string; |
||||||
|
hosts: Array<{ |
||||||
|
hostUUID: string; |
||||||
|
hostName: string; |
||||||
|
hostCPUCores: number; |
||||||
|
hostMemory: string; |
||||||
|
}>; |
||||||
|
anvilTotalCPUCores: number; |
||||||
|
anvilTotalMemory: string; |
||||||
|
servers: Array<{ |
||||||
|
serverUUID: string; |
||||||
|
serverName: string; |
||||||
|
serverCPUCores: number; |
||||||
|
serverMemory: string; |
||||||
|
}>; |
||||||
|
anvilTotalAllocatedCPUCores: number; |
||||||
|
anvilTotalAllocatedMemory: string; |
||||||
|
anvilTotalAvailableCPUCores: number; |
||||||
|
anvilTotalAvailableMemory: string; |
||||||
|
storageGroups: Array<{ |
||||||
|
storageGroupUUID: string; |
||||||
|
storageGroupName: string; |
||||||
|
storageGroupSize: string; |
||||||
|
storageGroupFree: string; |
||||||
|
}>; |
||||||
|
files: Array<{ |
||||||
|
fileUUID: string; |
||||||
|
fileName: string; |
||||||
|
}>; |
||||||
|
}; |
||||||
@ -0,0 +1,8 @@ |
|||||||
|
type AnvilOverview = { |
||||||
|
anvilName: string; |
||||||
|
anvilUUID: string; |
||||||
|
hosts: Array<{ |
||||||
|
hostName: string; |
||||||
|
hostUUID: string; |
||||||
|
}>; |
||||||
|
}; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
type BuildGetRequestHandlerOptions = { |
||||||
|
beforeRespond?: (queryStdout: unknown) => unknown; |
||||||
|
}; |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
type BuildQueryDetailOptions = { keys?: string[] | '*' }; |
||||||
|
|
||||||
|
type BuildQueryDetailReturn = { |
||||||
|
query: string; |
||||||
|
} & Pick<BuildQueryOptions, 'afterQueryReturn'>; |
||||||
|
|
||||||
|
type BuildQueryDetailFunction = ( |
||||||
|
options?: BuildQueryDetailOptions, |
||||||
|
) => BuildQueryDetailReturn; |
||||||
@ -0,0 +1,10 @@ |
|||||||
|
type QueryResultModifierFunction = (output: unknown) => unknown; |
||||||
|
|
||||||
|
type BuildQueryOptions = { |
||||||
|
afterQueryReturn?: QueryResultModifierFunction; |
||||||
|
}; |
||||||
|
|
||||||
|
type BuildQueryFunction = ( |
||||||
|
request: import('express').Request, |
||||||
|
options?: BuildQueryOptions, |
||||||
|
) => string; |
||||||
@ -0,0 +1,4 @@ |
|||||||
|
type CallOptions = { |
||||||
|
parameters?: unknown[]; |
||||||
|
notCallableReturn?: unknown; |
||||||
|
}; |
||||||
@ -0,0 +1,11 @@ |
|||||||
|
type CreateHostConnectionRequestBody = { |
||||||
|
dbName?: string; |
||||||
|
ipAddress: string; |
||||||
|
isPing?: boolean; |
||||||
|
// Host password; same as database password.
|
||||||
|
password: string; |
||||||
|
port?: number; |
||||||
|
sshPort?: number; |
||||||
|
// database user.
|
||||||
|
user?: string; |
||||||
|
}; |
||||||
@ -0,0 +1,9 @@ |
|||||||
|
type DBInsertOrUpdateFunctionCommonParams = ModuleSubroutineCommonParams & { |
||||||
|
file: string; |
||||||
|
line?: number; |
||||||
|
}; |
||||||
|
|
||||||
|
type DBInsertOrUpdateFunctionCommonOptions = Omit< |
||||||
|
ExecModuleSubroutineOptions, |
||||||
|
'subParams' | 'subModuleName' |
||||||
|
>; |
||||||
@ -0,0 +1,11 @@ |
|||||||
|
type DBJobParams = DBInsertOrUpdateFunctionCommonParams & { |
||||||
|
job_command: string; |
||||||
|
job_data?: string; |
||||||
|
job_name: string; |
||||||
|
job_title: string; |
||||||
|
job_description: string; |
||||||
|
job_host_uuid?: string; |
||||||
|
job_progress?: number; |
||||||
|
}; |
||||||
|
|
||||||
|
type DBInsertOrUpdateJobOptions = DBInsertOrUpdateFunctionCommonOptions; |
||||||
@ -0,0 +1,18 @@ |
|||||||
|
type DBVariableParams = DBInsertOrUpdateFunctionCommonParams & { |
||||||
|
update_value_only?: 0 | 1; |
||||||
|
variable_default?: string; |
||||||
|
varaible_description?: string; |
||||||
|
variable_name?: string; |
||||||
|
variable_section?: string; |
||||||
|
variable_source_table?: string; |
||||||
|
variable_source_uuid?: string; |
||||||
|
variable_uuid?: string; |
||||||
|
variable_value?: number | string; |
||||||
|
}; |
||||||
|
|
||||||
|
type DBInsertOrUpdateVariableOptions = DBInsertOrUpdateFunctionCommonOptions; |
||||||
|
|
||||||
|
type DBInsertOrUpdateVariableFunction = ( |
||||||
|
subParams: DBVariableParams, |
||||||
|
options?: DBInsertOrUpdateVariableOptions, |
||||||
|
) => string; |
||||||
@ -0,0 +1,3 @@ |
|||||||
|
type DBJobAnvilSyncSharedOptions = { |
||||||
|
jobHostUUID?: string; |
||||||
|
}; |
||||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue