mirror of
https://github.com/langgenius/dify.git
synced 2026-06-07 16:32:01 +08:00
e35d23c3cb
Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com> Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>
60 lines
2.3 KiB
Python
60 lines
2.3 KiB
Python
"""Agent App access & sharing endpoints (read-only workflow references).
|
|
|
|
An Agent App is backed by a roster Agent that workflow Agent nodes may also
|
|
reference. This exposes the read-only "Workflow access" surface from the PRD:
|
|
which workflow apps use this Agent, without leaking the workflows' internals.
|
|
"""
|
|
|
|
from flask_restx import Resource
|
|
from pydantic import Field
|
|
|
|
from controllers.common.schema import register_response_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, setup_required
|
|
from extensions.ext_database import db
|
|
from fields.base import ResponseModel
|
|
from libs.login import current_account_with_tenant, login_required
|
|
from models.model import App, AppMode
|
|
from services.agent.roster_service import AgentRosterService
|
|
|
|
|
|
class AgentReferencingWorkflowResponse(ResponseModel):
|
|
app_id: str
|
|
app_name: str
|
|
app_mode: str
|
|
workflow_id: str
|
|
node_ids: list[str] = Field(default_factory=list)
|
|
|
|
|
|
class AgentReferencingWorkflowsResponse(ResponseModel):
|
|
data: list[AgentReferencingWorkflowResponse] = Field(default_factory=list)
|
|
|
|
|
|
register_response_schema_models(console_ns, AgentReferencingWorkflowsResponse)
|
|
|
|
|
|
@console_ns.route("/apps/<uuid:app_id>/agent-referencing-workflows")
|
|
class AgentAppReferencingWorkflowsResource(Resource):
|
|
@console_ns.doc("list_agent_app_referencing_workflows")
|
|
@console_ns.doc(description="List workflow apps that reference this Agent App's bound Agent (read-only)")
|
|
@console_ns.doc(params={"app_id": "Application ID"})
|
|
@console_ns.response(
|
|
200,
|
|
"Referencing workflows listed successfully",
|
|
console_ns.models[AgentReferencingWorkflowsResponse.__name__],
|
|
)
|
|
@console_ns.response(404, "App not found")
|
|
@setup_required
|
|
@login_required
|
|
@account_initialization_required
|
|
@get_app_model(mode=[AppMode.AGENT])
|
|
def get(self, app_model: App):
|
|
_, tenant_id = current_account_with_tenant()
|
|
workflows = AgentRosterService(db.session).list_workflows_referencing_app_agent(
|
|
tenant_id=tenant_id, app_id=app_model.id
|
|
)
|
|
return AgentReferencingWorkflowsResponse(
|
|
data=[AgentReferencingWorkflowResponse.model_validate(workflow) for workflow in workflows]
|
|
).model_dump(mode="json")
|