Skip to content

Commit 549e2c4

Browse files
authored
Merge pull request #1304 from jhivandb/task/mcp-proxy-resource-server-scopes
Add per-proxy resource-server scopes for MCP proxies
2 parents 949344d + c8fc31e commit 549e2c4

55 files changed

Lines changed: 5718 additions & 3934 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

agent-manager-service/api/app.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ func MakeHTTPHandler(params *wiring.AppParams, extraAPIRoutes func(*http.ServeMu
8080
RegisterMonitorPublisherRoutes(rr, params.MonitorScoresPublisherController)
8181
RegisterGitSecretRoutes(rr, params.GitSecretController)
8282
registerIdentityRoutes(rr, params.IdentityController)
83-
registerScopeRoutes(rr, params.ScopeController)
83+
registerMCPProxyScopeRoutes(rr, params.MCPProxyScopeController)
8484
registerAgentIdentityRoutes(rr, params.AgentIdentityController)
8585

8686
if extraAPIRoutes != nil {

agent-manager-service/api/scope_routes.go renamed to agent-manager-service/api/mcp_proxy_scope_routes.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,10 @@ import (
2222
"github.com/wso2/agent-manager/agent-manager-service/rbac"
2323
)
2424

25-
func registerScopeRoutes(rr *middleware.RouteRegistrar, ctrl controllers.ScopeController) {
26-
rr.HandleFuncWithValidationAndAuthz("GET /orgs/{orgName}/scopes", rbac.ScopeRead, ctrl.ListScopes)
27-
rr.HandleFuncWithValidationAndAuthz("POST /orgs/{orgName}/scopes", rbac.ScopeCreate, ctrl.CreateScope)
28-
rr.HandleFuncWithValidationAndAuthz("PUT /orgs/{orgName}/scopes/{scopeName}", rbac.ScopeUpdate, ctrl.UpdateScope)
29-
rr.HandleFuncWithValidationAndAuthz("DELETE /orgs/{orgName}/scopes/{scopeName}", rbac.ScopeDelete, ctrl.DeleteScope)
25+
func registerMCPProxyScopeRoutes(rr *middleware.RouteRegistrar, ctrl controllers.MCPProxyScopeController) {
26+
rr.HandleFuncWithValidationAndAuthz("GET /orgs/{orgName}/mcp-proxies/{proxyId}/scopes", rbac.ScopeRead, ctrl.ListMCPProxyScopes)
27+
rr.HandleFuncWithValidationAndAuthz("POST /orgs/{orgName}/mcp-proxies/{proxyId}/scopes", rbac.ScopeCreate, ctrl.CreateMCPProxyScope)
28+
rr.HandleFuncWithValidationAndAuthz("PUT /orgs/{orgName}/mcp-proxies/{proxyId}/scopes/{scopeAction}", rbac.ScopeUpdate, ctrl.UpdateMCPProxyScope)
29+
rr.HandleFuncWithValidationAndAuthz("DELETE /orgs/{orgName}/mcp-proxies/{proxyId}/scopes/{scopeAction}", rbac.ScopeDelete, ctrl.DeleteMCPProxyScope)
30+
rr.HandleFuncWithValidationAndAuthz("GET /orgs/{orgName}/environments/{envName}/agent-identities/scopes", rbac.AgentIdentityRead, ctrl.ListAgentIdentityScopes)
3031
}

agent-manager-service/clients/clientmocks/env_identity_client_mock.go

Lines changed: 186 additions & 68 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

agent-manager-service/clients/thundersvc/client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ type thunderClient struct {
8585
tokenExpiry time.Time
8686
tokenSfg singleflight.Group // deduplicates concurrent token fetches
8787

88-
ensureScopeResourceServerMu sync.Mutex // serializes EnsureScopeResourceServer's check-then-create paths
88+
ensureResourceServerMu sync.Mutex // serializes resource-server check-then-create paths (scope + proxy)
8989
}
9090

9191
const httpClientTimeout = 30 * time.Second

0 commit comments

Comments
 (0)