mirror of
https://github.com/langgenius/dify.git
synced 2026-07-16 09:58:42 +08:00
ba8ddff696
Hard rule (PRD: human involvement must be slash-referenced or save errors):
every configured human contact must appear as {{#human:<id>#}} in its surface's
prompt (matched via any identity alias: id/contact_id/human_id/email/name;
identity-less contacts are skipped). Error code human_involvement_not_referenced,
enforced on both the agent soul prompt and the workflow job prompt.
Soft findings (never block save), returned by validate and attached to save
responses as `validation`:
- knowledge_retrieval_placeholder: dangling {{#knowledge:<id>#}} mentions (not
in config, or configured-but-deleted in DB) are kept with a placeholder name
(mention label, fallback "Knowledge <id8>") per the 0522 consensus, instead of
being dropped or rejected; knowledge not referenced is fine.
- mention_target_missing: skill/file/tool/cli_tool/human/node_output/output
mentions whose id resolves to no configured item.
- mention_malformed: mention-shaped markers the strict grammar rejects
(degraded to plain text at runtime by the scrub pass).
Response models gain warnings/knowledge_retrieval_placeholder (validate) and
validation (save); validate endpoints now resolve dataset existence via the
tenant-scoped dataset lookup.
Design: Confluence 490012681 §5. Depends on the ENG-616 mention contract.
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
247 lines
9.8 KiB
Python
247 lines
9.8 KiB
Python
from flask_restx import Resource
|
|
|
|
from controllers.common.schema import register_response_schema_models, register_schema_models
|
|
from controllers.console import console_ns
|
|
from controllers.console.app.wraps import get_app_model
|
|
from controllers.console.wraps import (
|
|
account_initialization_required,
|
|
edit_permission_required,
|
|
setup_required,
|
|
with_current_tenant_id,
|
|
with_current_user_id,
|
|
)
|
|
from fields.agent_fields import (
|
|
AgentAppComposerResponse,
|
|
AgentComposerCandidatesResponse,
|
|
AgentComposerImpactResponse,
|
|
AgentComposerValidateResponse,
|
|
WorkflowAgentComposerResponse,
|
|
)
|
|
from libs.helper import dump_response
|
|
from libs.login import login_required
|
|
from models.model import App, AppMode
|
|
from services.agent.composer_service import AgentComposerService
|
|
from services.agent.composer_validator import ComposerConfigValidator
|
|
from services.entities.agent_entities import ComposerSavePayload
|
|
|
|
register_schema_models(console_ns, ComposerSavePayload)
|
|
register_response_schema_models(
|
|
console_ns,
|
|
AgentAppComposerResponse,
|
|
AgentComposerCandidatesResponse,
|
|
AgentComposerImpactResponse,
|
|
AgentComposerValidateResponse,
|
|
WorkflowAgentComposerResponse,
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/workflows/draft/nodes/<string:node_id>/agent-composer")
|
|
class WorkflowAgentComposerApi(Resource):
|
|
@console_ns.response(
|
|
200, "Workflow agent composer state", console_ns.models[WorkflowAgentComposerResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_tenant_id
|
|
def get(self, tenant_id: str, app_model: App, node_id: str):
|
|
return dump_response(
|
|
WorkflowAgentComposerResponse,
|
|
AgentComposerService.load_workflow_composer(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
node_id=node_id,
|
|
),
|
|
)
|
|
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(
|
|
200, "Workflow agent composer saved", console_ns.models[WorkflowAgentComposerResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@edit_permission_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_user_id
|
|
@with_current_tenant_id
|
|
def put(self, tenant_id: str, account_id: str, app_model: App, node_id: str):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
return dump_response(
|
|
WorkflowAgentComposerResponse,
|
|
AgentComposerService.save_workflow_composer(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
node_id=node_id,
|
|
account_id=account_id,
|
|
payload=payload,
|
|
),
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/workflows/draft/nodes/<string:node_id>/agent-composer/validate")
|
|
class WorkflowAgentComposerValidateApi(Resource):
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(
|
|
200, "Workflow agent composer validation result", console_ns.models[AgentComposerValidateResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_tenant_id
|
|
def post(self, tenant_id: str, app_model: App, node_id: str):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
ComposerConfigValidator.validate_save_payload(payload)
|
|
findings = AgentComposerService.collect_validation_findings(tenant_id=tenant_id, payload=payload)
|
|
return dump_response(AgentComposerValidateResponse, {"result": "success", "errors": [], **findings})
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/workflows/draft/nodes/<string:node_id>/agent-composer/candidates")
|
|
class WorkflowAgentComposerCandidatesApi(Resource):
|
|
@console_ns.response(
|
|
200, "Workflow agent composer candidates", console_ns.models[AgentComposerCandidatesResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_user_id
|
|
@with_current_tenant_id
|
|
def get(self, tenant_id: str, current_user_id: str, app_model: App, node_id: str):
|
|
return dump_response(
|
|
AgentComposerCandidatesResponse,
|
|
AgentComposerService.get_workflow_candidates(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
node_id=node_id,
|
|
user_id=current_user_id,
|
|
),
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/workflows/draft/nodes/<string:node_id>/agent-composer/impact")
|
|
class WorkflowAgentComposerImpactApi(Resource):
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(200, "Workflow agent composer impact", console_ns.models[AgentComposerImpactResponse.__name__])
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_tenant_id
|
|
def post(self, tenant_id: str, app_model: App, node_id: str):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
current_snapshot_id = payload.binding.current_snapshot_id if payload.binding else None
|
|
if not current_snapshot_id:
|
|
return dump_response(
|
|
AgentComposerImpactResponse, {"current_snapshot_id": None, "workflow_node_count": 0, "bindings": []}
|
|
)
|
|
return dump_response(
|
|
AgentComposerImpactResponse,
|
|
AgentComposerService.calculate_impact(tenant_id=tenant_id, current_snapshot_id=current_snapshot_id),
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/workflows/draft/nodes/<string:node_id>/agent-composer/save-to-roster")
|
|
class WorkflowAgentComposerSaveToRosterApi(Resource):
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(
|
|
200, "Workflow agent composer saved to roster", console_ns.models[WorkflowAgentComposerResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@edit_permission_required
|
|
@get_app_model(mode=[AppMode.WORKFLOW, AppMode.ADVANCED_CHAT])
|
|
@with_current_user_id
|
|
@with_current_tenant_id
|
|
def post(self, tenant_id: str, account_id: str, app_model: App, node_id: str):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
return dump_response(
|
|
WorkflowAgentComposerResponse,
|
|
AgentComposerService.save_workflow_composer(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
node_id=node_id,
|
|
account_id=account_id,
|
|
payload=payload,
|
|
),
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/agent-composer")
|
|
class AgentAppComposerApi(Resource):
|
|
@console_ns.response(200, "Agent app composer state", console_ns.models[AgentAppComposerResponse.__name__])
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model()
|
|
@with_current_tenant_id
|
|
def get(self, tenant_id: str, app_model: App):
|
|
return dump_response(
|
|
AgentAppComposerResponse,
|
|
AgentComposerService.load_agent_app_composer(tenant_id=tenant_id, app_id=app_model.id),
|
|
)
|
|
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(200, "Agent app composer saved", console_ns.models[AgentAppComposerResponse.__name__])
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@edit_permission_required
|
|
@get_app_model()
|
|
@with_current_user_id
|
|
@with_current_tenant_id
|
|
def put(self, tenant_id: str, account_id: str, app_model: App):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
return dump_response(
|
|
AgentAppComposerResponse,
|
|
AgentComposerService.save_agent_app_composer(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
account_id=account_id,
|
|
payload=payload,
|
|
),
|
|
)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/agent-composer/validate")
|
|
class AgentAppComposerValidateApi(Resource):
|
|
@console_ns.expect(console_ns.models[ComposerSavePayload.__name__])
|
|
@console_ns.response(
|
|
200, "Agent app composer validation result", console_ns.models[AgentComposerValidateResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model()
|
|
@with_current_tenant_id
|
|
def post(self, tenant_id: str, app_model: App):
|
|
payload = ComposerSavePayload.model_validate(console_ns.payload or {})
|
|
ComposerConfigValidator.validate_save_payload(payload)
|
|
findings = AgentComposerService.collect_validation_findings(tenant_id=tenant_id, payload=payload)
|
|
return dump_response(AgentComposerValidateResponse, {"result": "success", "errors": [], **findings})
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/agent-composer/candidates")
|
|
class AgentAppComposerCandidatesApi(Resource):
|
|
@console_ns.response(
|
|
200, "Agent app composer candidates", console_ns.models[AgentComposerCandidatesResponse.__name__]
|
|
)
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model()
|
|
@with_current_user_id
|
|
@with_current_tenant_id
|
|
def get(self, tenant_id: str, current_user_id: str, app_model: App):
|
|
return dump_response(
|
|
AgentComposerCandidatesResponse,
|
|
AgentComposerService.get_agent_app_candidates(
|
|
tenant_id=tenant_id,
|
|
app_id=app_model.id,
|
|
user_id=current_user_id,
|
|
),
|
|
)
|