fix(cli): use renamed backend APIs
This commit is contained in:
@@ -13,7 +13,7 @@ function analysisBurst(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
|||||||
const schemeName = resolveScheme(ctx, optionalString(values, "scheme"), true)!;
|
const schemeName = resolveScheme(ctx, optionalString(values, "scheme"), true)!;
|
||||||
return emitApi(ctx, "爆管分析执行成功", {
|
return emitApi(ctx, "爆管分析执行成功", {
|
||||||
method: "GET",
|
method: "GET",
|
||||||
path: "/burst_analysis/",
|
path: "/burst-analysis",
|
||||||
params: {
|
params: {
|
||||||
network: requireNetwork(ctx),
|
network: requireNetwork(ctx),
|
||||||
modify_pattern_start_time: parseTime(requiredString(values, "start-time"), "--start-time"),
|
modify_pattern_start_time: parseTime(requiredString(values, "start-time"), "--start-time"),
|
||||||
@@ -50,7 +50,7 @@ function analysisValve(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
|||||||
if (!elements) throw new CliError("CLI 参数错误", "INVALID_VALVE_ISOLATION_ARGS", "isolation mode requires at least one --element", 2);
|
if (!elements) throw new CliError("CLI 参数错误", "INVALID_VALVE_ISOLATION_ARGS", "isolation mode requires at least one --element", 2);
|
||||||
return emitApi(ctx, "阀门隔离分析执行成功", {
|
return emitApi(ctx, "阀门隔离分析执行成功", {
|
||||||
method: "GET",
|
method: "GET",
|
||||||
path: "/valve_isolation_analysis/",
|
path: "/valve-isolation-analysis",
|
||||||
params: { network: requireNetwork(ctx), accident_element: elements, disabled_valves: optionalStringArray(values, "disabled-valve") },
|
params: { network: requireNetwork(ctx), accident_element: elements, disabled_valves: optionalStringArray(values, "disabled-valve") },
|
||||||
requireNetworkCtx: true,
|
requireNetworkCtx: true,
|
||||||
});
|
});
|
||||||
@@ -61,7 +61,7 @@ function analysisFlushing(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
|||||||
const [valves, openings] = parseValveSettingFile(requiredString(values, "valve-setting-file"));
|
const [valves, openings] = parseValveSettingFile(requiredString(values, "valve-setting-file"));
|
||||||
return emitApi(ctx, "冲洗分析执行成功", {
|
return emitApi(ctx, "冲洗分析执行成功", {
|
||||||
method: "GET",
|
method: "GET",
|
||||||
path: "/flushing_analysis/",
|
path: "/flushing-analysis",
|
||||||
params: {
|
params: {
|
||||||
network: requireNetwork(ctx),
|
network: requireNetwork(ctx),
|
||||||
start_time: parseTime(requiredString(values, "start-time"), "--start-time"),
|
start_time: parseTime(requiredString(values, "start-time"), "--start-time"),
|
||||||
@@ -98,7 +98,7 @@ function analysisContaminant(ctx: RuntimeContext, argv: string[]): Promise<void>
|
|||||||
};
|
};
|
||||||
const pattern = optionalString(values, "pattern");
|
const pattern = optionalString(values, "pattern");
|
||||||
if (pattern) params.pattern = pattern;
|
if (pattern) params.pattern = pattern;
|
||||||
return emitApi(ctx, "污染物模拟执行成功", { method: "GET", path: "/contaminant_simulation/", params, requireNetworkCtx: true });
|
return emitApi(ctx, "污染物模拟执行成功", { method: "GET", path: "/contaminant-simulation", params, requireNetworkCtx: true });
|
||||||
}
|
}
|
||||||
|
|
||||||
function sensorKmeans(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
function sensorKmeans(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
||||||
|
|||||||
@@ -163,5 +163,5 @@ export const dataHandlers: HandlerMap = {
|
|||||||
"data scada list": dataScadaList,
|
"data scada list": dataScadaList,
|
||||||
"data scheme schema": (ctx) => emitApi(ctx, "读取方案 schema 成功", { method: "GET", path: "/getschemeschema/", params: { network: requireNetwork(ctx) }, requireNetworkCtx: true }),
|
"data scheme schema": (ctx) => emitApi(ctx, "读取方案 schema 成功", { method: "GET", path: "/getschemeschema/", params: { network: requireNetwork(ctx) }, requireNetworkCtx: true }),
|
||||||
"data scheme get": dataSchemeGet,
|
"data scheme get": dataSchemeGet,
|
||||||
"data scheme list": (ctx) => emitApi(ctx, "读取方案列表成功", { method: "GET", path: "/getallschemes/", params: { network: requireNetwork(ctx) }, requireNetworkCtx: true }),
|
"data scheme list": (ctx) => emitApi(ctx, "读取方案列表成功", { method: "GET", path: "/schemes", params: { network: requireNetwork(ctx) }, requireNetworkCtx: true }),
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -13,7 +13,7 @@ function simulationRun(ctx: RuntimeContext, argv: string[]): Promise<void> {
|
|||||||
return emitApi(
|
return emitApi(
|
||||||
ctx,
|
ctx,
|
||||||
"触发模拟成功",
|
"触发模拟成功",
|
||||||
{ method: "POST", path: "/runsimulationmanuallybydate/", body: { name: network, start_time: start.replace(/\.\d+/, ""), duration }, requireNetworkCtx: true },
|
{ method: "POST", path: "/simulations/run-by-date", body: { name: network, start_time: start.replace(/\.\d+/, ""), duration }, requireNetworkCtx: true },
|
||||||
[
|
[
|
||||||
`tjwater-cli data timeseries realtime links --start-time ${start} --end-time ${end}`,
|
`tjwater-cli data timeseries realtime links --start-time ${start} --end-time ${end}`,
|
||||||
`tjwater-cli data timeseries realtime nodes --start-time ${start} --end-time ${end}`,
|
`tjwater-cli data timeseries realtime nodes --start-time ${start} --end-time ${end}`,
|
||||||
|
|||||||
@@ -212,7 +212,7 @@ test("sends auth headers and simulation body through the backend API contract",
|
|||||||
|
|
||||||
assert.equal(result.exitCode, 0, result.stderr);
|
assert.equal(result.exitCode, 0, result.stderr);
|
||||||
assert.equal(server.seen[0].method, "POST");
|
assert.equal(server.seen[0].method, "POST");
|
||||||
assert.equal(server.seen[0].url, "/api/v1/runsimulationmanuallybydate/");
|
assert.equal(server.seen[0].url, "/api/v1/simulations/run-by-date");
|
||||||
assert.equal(server.seen[0].headers.authorization, "Bearer token-1");
|
assert.equal(server.seen[0].headers.authorization, "Bearer token-1");
|
||||||
assert.equal(server.seen[0].headers["x-extra"], "extra");
|
assert.equal(server.seen[0].headers["x-extra"], "extra");
|
||||||
assert.deepEqual(server.seen[0].body, {
|
assert.deepEqual(server.seen[0].body, {
|
||||||
|
|||||||
Reference in New Issue
Block a user