Method parseSpec

backend/api/mcp/openapi_index.go:102–177

()

var permissionRegex = regexp.MustCompile(`Permissions required:\s*([^\n]+)`)

func (idx *OpenAPIIndex) parseSpec() {
	serviceSet := make(map[string]bool)

	if idx.doc.Model.Paths == nil {
		return
	}

	for pair := idx.doc.Model.Paths.PathItems.First(); pair != nil; pair = pair.Next() {
		path := pair.Key()
		pathItem := pair.Value()

		// Connect RPC uses POST for all endpoints
		op := pathItem.Post
		if op == nil {
			continue
		}

		// Extract service and method from path
		// /bytebase.v1.SQLService/Query -> service=SQLService, method=Query
		trimmed := strings.TrimPrefix(path, "/bytebase.v1.")
		parts := strings.Split(trimmed, "/")
		if len(parts) != 2 {
			continue
		}

		service := parts[0]
		method := parts[1]

		endpoint := EndpointInfo{
			OperationID: op.OperationId,
			Path:        path,
			Service:     service,
			Method:      method,
			Summary:     op.Summary,
			Description: op.Description,
			Permissions: extractPermissions(op.Description),
		}

		// Extract request schema reference
		if op.RequestBody != nil {
			content := op.RequestBody.Content
			if content != nil {
				if jsonContent, ok := content.Get("application/json"); ok && jsonContent.Schema != nil {
					endpoint.RequestSchemaRef = jsonContent.Schema.GetReference()
				}
			}
		}

		// Extract response schema reference (from 200 response)
		if op.Responses != nil {
			if resp, ok := op.Responses.Codes.Get("200"); ok && resp != nil {
				if resp.Content != nil {
					if jsonContent, ok := resp.Content.Get("application/json"); ok && jsonContent.Schema != nil {
						endpoint.ResponseSchemaRef = jsonContent.Schema.GetReference()
					}
				}
			}
		}