import request from '@/utils/request'

// ===== Flow 管理 =====
export function saveFlow(data) {
  return request({ url: '/api/orchestration/flow/save', method: 'post', data })
}

export function publishFlow(flowId) {
  return request({ url: '/api/orchestration/flow/publish', method: 'post', data: { flowId } })
}

export function listFlows(params) {
  return request({ url: '/api/orchestration/flow/list', method: 'post', data: params })
}

export function getFlowDetail(flowId) {
  return request({ url: '/api/orchestration/flow/detail', method: 'post', data: { flowId } })
}

export function archiveFlow(flowId) {
  return request({ url: '/api/orchestration/flow/archive', method: 'post', data: { flowId } })
}

export function deleteFlow(flowId) {
  return request({ url: '/api/orchestration/flow/delete', method: 'post', data: { flowId } })
}

// ===== Execution 管理 =====
export function startExecution(data) {
  return request({ url: '/api/orchestration/execution/start', method: 'post', data })
}

export function pauseExecution(executionId) {
  return request({ url: '/api/orchestration/execution/pause', method: 'post', data: { executionId } })
}

export function resumeExecution(executionId) {
  return request({ url: '/api/orchestration/execution/resume', method: 'post', data: { executionId } })
}

export function terminateExecution(data) {
  return request({ url: '/api/orchestration/execution/terminate', method: 'post', data })
}

export function getExecutionDetail(executionId) {
  return request({ url: '/api/orchestration/execution/detail', method: 'post', data: { executionId } })
}

export function listExecutions(params) {
  return request({ url: '/api/orchestration/execution/list', method: 'post', data: params })
}

// ===== 节点管理 =====
export function failNode(nodeInstanceId, reason) {
  return request({ url: '/api/orchestration/node/fail', method: 'post', data: { nodeInstanceId, reason } })
}

export function restartNode(nodeInstanceId) {
  return request({ url: '/api/orchestration/node/restart', method: 'post', data: { nodeInstanceId } })
}

export function markConditionMet(nodeInstanceId) {
  return request({ url: '/api/orchestration/node/condition-met', method: 'post', data: { nodeInstanceId } })
}