diff --git a/.github/agents/devops.agent.md b/.github/agents/devops.agent.md
new file mode 100644
index 00000000..b9840084
--- /dev/null
+++ b/.github/agents/devops.agent.md
@@ -0,0 +1,14 @@
+---
+description: "Use when: publishing packages, managing DevOps feed availability, troubleshooting CI failures, or working with Fabric.Mcp.Server integration."
+name: "DevOps"
+model: "Claude Opus 4.6 (copilot)"
+tools: [execute, read, memory, todo]
+user-invocable: true
+argument-hint: "Describe the DevOps/CI task: publish package, check feed, fix CI failure"
+---
+
+You manage DevOps workflows, CI pipelines, and package publishing. You do NOT modify source code.
+
+Load the `devops.fabric-mcp-integration` skill for feed configuration, publishing workflow, and troubleshooting.
+
+Always run from the repo root.
diff --git a/.github/copilot-instructions.md b/.github/copilot-instructions.md
index 4c944a17..8f95c8d5 100644
--- a/.github/copilot-instructions.md
+++ b/.github/copilot-instructions.md
@@ -30,3 +30,5 @@ When these topics come up, reference the corresponding file in `docs/datafactory
| Fast Copy, Action.Sequence, Modern Evaluator | `advanced.md` |
For connection management (creating/listing connections, supported types, UI form), reference `docs/connection-management.md`.
+
+For DevOps/CI integration with Fabric.Mcp.Server (feed caching, publishing, trim safety), reference the `devops.fabric-mcp-integration` skill.
diff --git a/.github/skills/devops.fabric-mcp-integration/SKILL.md b/.github/skills/devops.fabric-mcp-integration/SKILL.md
new file mode 100644
index 00000000..77bd1724
--- /dev/null
+++ b/.github/skills/devops.fabric-mcp-integration/SKILL.md
@@ -0,0 +1,127 @@
+---
+name: devops.fabric-mcp-integration
+description: "DevOps and CI integration with microsoft/mcp (Fabric.Mcp.Server). Use when publishing packages, managing feed availability, or troubleshooting CI failures."
+---
+
+# DevOps Integration with Fabric.Mcp.Server
+
+## Overview
+
+The `microsoft/mcp` repo consumes `Microsoft.DataFactory.MCP.Core` as a NuGet package
+in `Fabric.Mcp.Tools.DataFactory`. CI builds use a DevOps feed with upstream caching
+from nuget.org — packages are **not** immediately available after publishing.
+
+## Feed Configuration
+
+The Fabric.Mcp.Server `NuGet.config` uses a single feed:
+
+```xml
+
+
+
+
+```
+
+- **Feed UI:** https://dev.azure.com/azure-sdk/public/_artifacts/feed/azure-sdk-for-net
+- **No direct nuget.org access** — all packages must come through this feed
+- The feed has an **upstream** to nuget.org that caches packages on-demand
+
+## How Upstream Caching Works
+
+1. A new version is published to **nuget.org**
+2. It is **NOT** immediately available on the DevOps feed
+3. A Collaborator runs `dotnet restore` against the DevOps feed
+4. The feed fetches and caches the package from nuget.org
+5. Subsequent Fabric.Mcp.Server CI builds can then resolve it
+
+> **Important:** The `nuget list` search index can lag behind actual availability.
+> If `dotnet restore` succeeds, the package IS available for CI even if `nuget list` doesn't show it yet.
+
+## After Publishing a New Version
+
+### Step 1: Verify on nuget.org
+
+```bash
+nuget list Microsoft.DataFactory.MCP.Core \
+ -Source "https://api.nuget.org/v3/index.json" \
+ -PreRelease -AllVersions
+```
+
+### Step 2: Trigger the DevOps feed to cache it
+
+Run from the `microsoft/mcp` repo root:
+
+```bash
+dotnet restore tools/Fabric.Mcp.Tools.DataFactory/src/Fabric.Mcp.Tools.DataFactory.csproj \
+ --source "https://pkgs.dev.azure.com/azure-sdk/public/_packaging/azure-sdk-for-net/nuget/v3/index.json"
+```
+
+If restore succeeds, the package is cached and Fabric.Mcp.Server CI will find it.
+
+### Step 3: Verify (optional)
+
+```bash
+nuget list Microsoft.DataFactory.MCP.Core \
+ -Source "https://pkgs.dev.azure.com/azure-sdk/public/_packaging/azure-sdk-for-net/nuget/v3/index.json" \
+ -PreRelease -AllVersions
+```
+
+> The search index may lag — restore success is the definitive proof.
+
+## Version Management
+
+### DataFactory.MCP side (this repo)
+
+Version is in `Directory.Build.props`:
+
+```xml
+0
+20
+0
+beta
+```
+
+### Fabric.Mcp.Server side (consumer repo)
+
+Version is in `Directory.Packages.props` (Central Package Management):
+
+```xml
+
+```
+
+The project reference is in:
+`tools/Fabric.Mcp.Tools.DataFactory/src/Fabric.Mcp.Tools.DataFactory.csproj`
+
+## Credential Provider Setup
+
+To authenticate to the DevOps feed locally, install the credential provider:
+https://go.microsoft.com/fwlink/?linkid=2099625
+
+Once installed, `dotnet restore` triggers an auth challenge and grants Collaborator access.
+The feed is public — anyone can pull packages that are already cached.
+Collaborators can also trigger the feed to ingest new packages from nuget.org.
+
+## Trim Safety Requirements
+
+Fabric.Mcp.Server publishes with IL trimming enabled:
+
+```bash
+dotnet publish servers/Fabric.Mcp.Server/src/Fabric.Mcp.Server.csproj \
+ --runtime linux-x64 --self-contained \
+ /p:PublishTrimmed=true /p:PublishSingleFile=true /p:TreatWarningsAsErrors=true
+```
+
+All code consumed from `Microsoft.DataFactory.MCP.Core` must be trim-safe:
+- Use source-generated JSON (`DataFactoryJsonContext`) instead of reflection-based serialization
+- Mark reflection-dependent APIs with `[RequiresUnreferencedCode]`
+- Test with the publish command above before submitting version bumps
+
+## Troubleshooting
+
+| Issue | Cause | Fix |
+|-------|-------|-----|
+| `NU1102: Unable to find package` | Version not cached on DevOps feed | Run `dotnet restore` locally to trigger upstream cache |
+| `nuget list` doesn't show new version | Search index lag | Check with `dotnet restore` instead — success = available |
+| 401 Unauthorized on restore | Missing credential provider | Install cred provider (link above) |
+| IL2026 trim warnings on publish | Reflection-based JSON in consumed code | Use `DataFactoryJsonContext` source-gen JSON |
diff --git a/.pipelines/pack-and-sign-nugets.yaml b/.pipelines/pack-and-sign-nugets.yaml
index 501ff345..ca07420c 100644
--- a/.pipelines/pack-and-sign-nugets.yaml
+++ b/.pipelines/pack-and-sign-nugets.yaml
@@ -15,6 +15,7 @@ trigger:
paths:
include:
- DataFactory.MCP/*
+ - DataFactory.MCP.Core/*
pr:
branches:
@@ -24,6 +25,7 @@ pr:
paths:
include:
- DataFactory.MCP/*
+ - DataFactory.MCP.Core/*
parameters:
- name: "debug"
@@ -155,6 +157,45 @@ extends:
Get-ChildItem "$mcpAppsDir/dist" -Recurse | Select-Object FullName | Format-Table -AutoSize | Out-String | Write-Host
pwsh: true
+ # --- DataFactory.MCP.Core (library package) ---
+ - task: DotNetCoreCLI@2
+ displayName: "Restore Core packages"
+ inputs:
+ command: "restore"
+ projects: "$(Build.SourcesDirectory)/DataFactory.MCP.Core/DataFactory.MCP.Core.csproj"
+ feedsToUse: "config"
+ nugetConfigPath: "$(Build.SourcesDirectory)/nuget.private.config"
+ verbosityRestore: "Normal"
+ noCache: true
+ retryCountOnTaskFailure: 3
+
+ - task: DotNetCoreCLI@2
+ displayName: "Build Core project"
+ inputs:
+ command: "build"
+ projects: "$(Build.SourcesDirectory)/DataFactory.MCP.Core/DataFactory.MCP.Core.csproj"
+ arguments: "--configuration $(BuildConfiguration) --no-restore"
+
+ - task: onebranch.pipeline.signing@1
+ displayName: "Sign Core binary files"
+ inputs:
+ command: "sign"
+ signing_profile: "external_distribution"
+ files_to_sign: |
+ **/DataFactory.MCP.Core.dll;
+ search_root: "$(Build.SourcesDirectory)\\DataFactory.MCP.Core\\bin\\$(BuildConfiguration)\\net10.0"
+
+ - task: DotNetCoreCLI@2
+ displayName: "Pack Core NuGet package"
+ inputs:
+ command: "pack"
+ packagesToPack: "$(Build.SourcesDirectory)/DataFactory.MCP.Core/DataFactory.MCP.Core.csproj"
+ configuration: "$(BuildConfiguration)"
+ outputDir: "$(OUTPUTROOT)"
+ nobuild: true
+ includeSymbols: true
+
+ # --- DataFactory.MCP (tool package) ---
- task: DotNetCoreCLI@2
displayName: "Restore packages"
inputs:
diff --git a/DataFactory.MCP.Core/Abstractions/FabricServiceBase.cs b/DataFactory.MCP.Core/Abstractions/FabricServiceBase.cs
index cb1ff518..941fbd98 100644
--- a/DataFactory.MCP.Core/Abstractions/FabricServiceBase.cs
+++ b/DataFactory.MCP.Core/Abstractions/FabricServiceBase.cs
@@ -20,6 +20,15 @@ public abstract class FabricServiceBase
protected readonly IValidationService ValidationService;
protected static JsonSerializerOptions JsonOptions => JsonSerializerOptionsProvider.FabricApi;
+ ///
+ /// Serializes a request object using source-generated JSON context for AOT compatibility.
+ /// All request types must be registered in DataFactoryJsonContext.
+ ///
+ private static string SerializeRequest(object request)
+ {
+ return JsonSerializer.Serialize(request, request.GetType(), DataFactoryJsonContext.Default);
+ }
+
protected FabricServiceBase(
IHttpClientFactory httpClientFactory,
ILogger logger,
@@ -61,7 +70,7 @@ protected void ValidateGuids(params (string value, string name)[] guids)
.Build();
Logger.LogInformation("Posting to: {Url}", url);
- var jsonContent = JsonSerializer.Serialize(request, JsonOptions);
+ var jsonContent = SerializeRequest(request);
Logger.LogDebug("Request body: {Body}", jsonContent);
var content = new StringContent(jsonContent, Encoding.UTF8, "application/json");
@@ -79,7 +88,7 @@ protected void ValidateGuids(params (string value, string name)[] guids)
.Build();
Logger.LogInformation("Patching: {Url}", url);
- var jsonContent = JsonSerializer.Serialize(request, JsonOptions);
+ var jsonContent = SerializeRequest(request);
var content = new StringContent(jsonContent, Encoding.UTF8, "application/json");
var httpRequest = new HttpRequestMessage(HttpMethod.Patch, url) { Content = content };
@@ -97,7 +106,7 @@ protected async Task PostAsBytesAsync(string endpoint, object request)
.Build();
Logger.LogInformation("Posting to: {Url}", url);
- var jsonContent = JsonSerializer.Serialize(request, JsonOptions);
+ var jsonContent = SerializeRequest(request);
var content = new StringContent(jsonContent, Encoding.UTF8, "application/json");
var response = await HttpClient.PostAsync(url, content);
@@ -115,7 +124,7 @@ protected async Task PostAsBytesAsync(string endpoint, object request)
.Build();
Logger.LogInformation("Posting to: {Url}", url);
- var jsonContent = request != null ? JsonSerializer.Serialize(request, JsonOptions) : null;
+ var jsonContent = request != null ? SerializeRequest(request) : null;
var content = jsonContent != null ? new StringContent(jsonContent, Encoding.UTF8, "application/json") : null;
var response = await HttpClient.PostAsync(url, content);
@@ -135,7 +144,7 @@ protected async Task PostNoContentAsync(string endpoint, object request)
.Build();
Logger.LogInformation("Posting to: {Url}", url);
- var jsonContent = JsonSerializer.Serialize(request, JsonOptions);
+ var jsonContent = SerializeRequest(request);
var content = new StringContent(jsonContent, Encoding.UTF8, "application/json");
var response = await HttpClient.PostAsync(url, content);
@@ -145,9 +154,9 @@ protected async Task PostNoContentAsync(string endpoint, object request)
return true;
}
- var (_, _, error) = await response.TryReadAsJsonAsync