Code-First Federation 2 Support

.github/workflows/test-code.yml

@@ -109,12 +109,24 @@ jobs:
  - name: Build Sample2
  working-directory: src
  run: dotnet build GraphQL.Federation.SchemaFirst.Sample2
+ - name: Build Sample3
+ working-directory: src
+ run: dotnet build GraphQL.Federation.CodeFirst.Sample3
+ - name: Build Sample4
+ working-directory: src
+ run: dotnet build GraphQL.Federation.TypeFirst.Sample4
  - name: Start Sample1 on port 5601
  working-directory: src
  run: dotnet run --no-build --project GraphQL.Federation.SchemaFirst.Sample1 &
  - name: Start Sample2 on port 5602
  working-directory: src
  run: dotnet run --no-build --project GraphQL.Federation.SchemaFirst.Sample2 &
+ - name: Start Sample3 on port 5603
+ working-directory: src
+ run: dotnet run --no-build --project GraphQL.Federation.CodeFirst.Sample3 &
+ - name: Start Sample4 on port 5604
+ working-directory: src
+ run: dotnet run --no-build --project GraphQL.Federation.TypeFirst.Sample4 &
  - name: Install Apollo Rover CLI
  run: |
  curl -sSL https://rover.apollo.dev/nix/latest | sh
@@ -152,6 +164,36 @@ jobs:
  done
  echo "Timed out after 30 seconds, step failed."
  exit 1
+ - name: Wait for Sample3 to spin up
+ run: |
+ for i in {1..60}
+ do
+ echo "Request $i to the URL..."
+ response=$(curl -s -o /dev/null -w "%{http_code}" http://localhost:5603)
+ if [ $response -eq 200 ]; then
+ echo "Received 200 response, step completed."
+ exit 0
+ fi
+ echo "Did not receive a 200 response, sleeping for 0.5 second..."
+ sleep 0.5
+ done
+ echo "Timed out after 30 seconds, step failed."
+ exit 1
+ - name: Wait for Sample4 to spin up
+ run: |
+ for i in {1..60}
+ do
+ echo "Request $i to the URL..."
+ response=$(curl -s -o /dev/null -w "%{http_code}" http://localhost:5604)
+ if [ $response -eq 200 ]; then
+ echo "Received 200 response, step completed."
+ exit 0
+ fi
+ echo "Did not receive a 200 response, sleeping for 0.5 second..."
+ sleep 0.5
+ done
+ echo "Timed out after 30 seconds, step failed."
+ exit 1
  - name: Build supergraph with federation-${{ matrix.federationversion }}-supergraph-config.yaml
  working-directory: src/Federation
  run: rover supergraph compose --config ./federation-${{ matrix.federationversion }}-supergraph-config.yaml --elv2-license=accept > supergraph.graphql
@@ -185,6 +227,11 @@ jobs:
  curl -X POST -H "Content-Type: application/json" -d @federation-request-1.json http://127.0.0.1:4000 > response-1.json
  curl -X POST -H "Content-Type: application/json" -d @federation-request-2.json http://127.0.0.1:4000 > response-2.json
  curl -X POST -H "Content-Type: application/json" -d @federation-request-3.json http://127.0.0.1:4000 > response-3.json
+ - name: Run additional GraphQL queries
+ if: matrix.federationversion == 2
+ working-directory: src/Federation
+ run: |
+ curl -X POST -H "Content-Type: application/json" -d @federation-request-4.json http://127.0.0.1:4000 > response-4.json
  - name: Print query result 1
  working-directory: src/Federation
  run: cat response-1.json
@@ -194,6 +241,10 @@ jobs:
  - name: Print query result 3
  working-directory: src/Federation
  run: cat response-3.json
+ - name: Print query result 4
+ if: matrix.federationversion == 2
+ working-directory: src/Federation
+ run: cat response-4.json
  - name: Compare query result 1 to expected response
  working-directory: src/Federation
  run: |
@@ -212,6 +263,13 @@ jobs:
  jq . response-3.json > actual-response-3.json
  jq . federation-response-3.json > expected-response-3.json
  diff -b actual-response-3.json expected-response-3.json
+ - name: Compare query result 4 to expected response
+ if: matrix.federationversion == 2
+ working-directory: src/Federation
+ run: |
+ jq . response-4.json > actual-response-4.json
+ jq . federation-response-4.json > expected-response-4.json
+ diff -b actual-response-4.json expected-response-4.json
 
  buildcheck:
  needs:

src/Federation/federation-2-supergraph-config.yaml

@@ -8,3 +8,11 @@ subgraphs:
  routing_url: http://localhost:5602/graphql
  schema:
  subgraph_url: http://localhost:5602/graphql
+ sample3:
+ routing_url: http://localhost:5603/graphql
+ schema:
+ subgraph_url: http://localhost:5603/graphql
+ sample4:
+ routing_url: http://localhost:5604/graphql
+ schema:
+ subgraph_url: http://localhost:5604/graphql

src/Federation/federation-request-4.json

@@ -0,0 +1,3 @@
+{
+ "query": "{ categories { id name products { id name category { id name } reviews { id content product { id name } author { id username reviews { id content } } } } } }"
+}

src/Federation/federation-response-4.json

@@ -0,0 +1,118 @@
+{
+ "data": {
+ "categories": [
+ {
+ "id": "1",
+ "name": "Category 1",
+ "products": [
+ {
+ "id": "1",
+ "name": "Product 1",
+ "category": {
+ "id": "1",
+ "name": "Category 1"
+ },
+ "reviews": [
+ {
+ "id": "1",
+ "content": "Review 1",
+ "product": {
+ "id": "1",
+ "name": "Product 1"
+ },
+ "author": {
+ "id": "1",
+ "username": "Username 1",
+ "reviews": [
+ {
+ "id": "1",
+ "content": "Review 1"
+ },
+ {
+ "id": "3",
+ "content": "Review 3"
+ }
+ ]
+ }
+ },
+ {
+ "id": "2",
+ "content": "Review 2",
+ "product": {
+ "id": "1",
+ "name": "Product 1"
+ },
+ "author": {
+ "id": "2",
+ "username": "Username 2",
+ "reviews": [
+ {
+ "id": "2",
+ "content": "Review 2"
+ }
+ ]
+ }
+ }
+ ]
+ },
+ {
+ "id": "2",
+ "name": "Product 2",
+ "category": {
+ "id": "1",
+ "name": "Category 1"
+ },
+ "reviews": [
+ {
+ "id": "3",
+ "content": "Review 3",
+ "product": {
+ "id": "2",
+ "name": "Product 2"
+ },
+ "author": {
+ "id": "1",
+ "username": "Username 1",
+ "reviews": [
+ {
+ "id": "1",
+ "content": "Review 1"
+ },
+ {
+ "id": "3",
+ "content": "Review 3"
+ }
+ ]
+ }
+ }
+ ]
+ }
+ ]
+ },
+ {
+ "id": "2",
+ "name": "Category 2",
+ "products": [
+ {
+ "id": "3",
+ "name": "Product 3",
+ "category": {
+ "id": "2",
+ "name": "Category 2"
+ },
+ "reviews": []
+ },
+ {
+ "id": "4",
+ "name": "Product 4",
+ "category": {
+ "id": "2",
+ "name": "Category 2"
+ },
+ "reviews": []
+ }
+ ]
+ }
+ ]
+ }
+}

src/GraphQL.Federation.CodeFirst.Sample3/Data.cs

@@ -0,0 +1,30 @@
+using GraphQL.Federation.CodeFirst.Sample3.Models;
+
+namespace GraphQL.Federation.CodeFirst.Sample3;
+
+public class Data
+{
+ private readonly List<Review> _reviews = new()
+ {
+ new Review { Id = 1, ProductId = 1, UserId = 1, Content = "Review 1" },
+ new Review { Id = 2, ProductId = 1, UserId = 2, Content = "Review 2" },
+ new Review { Id = 3, ProductId = 2, UserId = 1, Content = "Review 3" },
+ };
+
+ public Task<IEnumerable<Review>> GetReviewsAsync() => Task.FromResult<IEnumerable<Review>>(_reviews);
+
+ public Task<Review?> GetReviewByIdAsync(int id)
+ {
+ return Task.FromResult(_reviews.SingleOrDefault(x => x.Id == id));
+ }
+
+ public Task<IEnumerable<Review>> GetReviewsByProductIdAsync(int productId)
+ {
+ return Task.FromResult(_reviews.Where(x => x.ProductId == productId));
+ }
+
+ public Task<IEnumerable<Review>> GetReviewsByUserIdAsync(int userId)
+ {
+ return Task.FromResult(_reviews.Where(x => x.UserId == userId));
+ }
+}

src/GraphQL.Federation.CodeFirst.Sample3/GraphQL.Federation.CodeFirst.Sample3.csproj

@@ -0,0 +1,23 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+ <PropertyGroup>
+ <OutputType>Exe</OutputType>
+ <TargetFramework>net7.0</TargetFramework>
+ <ImplicitUsings>enable</ImplicitUsings>
+ <Nullable>enable</Nullable>
+ <IsPackable>false</IsPackable>
+ <NoWarn>$(NoWarn);CS1591</NoWarn>
+ </PropertyGroup>
+
+ <ItemGroup>
+ <PackageReference Include="GraphQL.Server.Ui.Playground" Version="7.*" />
+ <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="7.*" />
+ <PackageReference Include="Microsoft.Extensions.Options" Version="7.*" />
+ </ItemGroup>
+
+ <ItemGroup>
+ <ProjectReference Include="..\GraphQL.MicrosoftDI\GraphQL.MicrosoftDI.csproj" />
+ <ProjectReference Include="..\GraphQL.SystemTextJson\GraphQL.SystemTextJson.csproj" />
+ </ItemGroup>
+
+</Project>

src/GraphQL.Federation.CodeFirst.Sample3/Models/Product.cs

@@ -0,0 +1,6 @@
+namespace GraphQL.Federation.CodeFirst.Sample3.Models;
+
+public class Product
+{
+ public required int Id { get; set; }
+}

src/GraphQL.Federation.CodeFirst.Sample3/Models/Review.cs

@@ -0,0 +1,9 @@
+namespace GraphQL.Federation.CodeFirst.Sample3.Models;
+
+public class Review
+{
+ public required int Id { get; set; }
+ public required int ProductId { get; set; }
+ public required int UserId { get; set; }
+ public required string Content { get; set; }
+}

src/GraphQL.Federation.CodeFirst.Sample3/Models/User.cs

@@ -0,0 +1,6 @@
+namespace GraphQL.Federation.CodeFirst.Sample3.Models;
+
+public class User
+{
+ public required int Id { get; set; }
+}

src/GraphQL.Federation.CodeFirst.Sample3/Program.cs

@@ -0,0 +1,67 @@
+using GraphQL.Federation.CodeFirst.Sample3.Schema;
+using GraphQL.Transport;
+using GraphQL.Types;
+using GraphQL.Utilities;
+
+namespace GraphQL.Federation.CodeFirst.Sample3;
+
+public class Program
+{
+ public static async Task Main(string[] args)
+ {
+ // Configure services
+ var builder = WebApplication.CreateBuilder(args);
+ builder.Services.AddSingleton<Data>();
+ builder.Services.AddGraphQL(b => b
+ .AddSchema<Schema3>()
+ .AddSystemTextJson()
+ .AddGraphTypes()
+ .AddFederation());
+
+ // Build the web application
+ var app = builder.Build();
+
+ // Some simple GraphQL middleware (NOTE: it is suggested to use the GraphQL.Server.Transports.AspNetCore package instead)
+ app.MapPost("/graphql", GraphQLHttpMiddlewareAsync);
+
+ // Add a UI package for testing
+ app.UseGraphQLPlayground("/");
+
+ // Optional: ensure that the schema builds and initializes
+ {
+ var schema = app.Services.GetRequiredService<ISchema>();
+ schema.Initialize();
+ }
+
+ // Start the application
+ await app.RunAsync().ConfigureAwait(false);
+ }
+
+ private static async Task GraphQLHttpMiddlewareAsync(HttpContext context)
+ {
+ // NOTE: it is suggested to use the GraphQL.Server.Transports.AspNetCore package instead
+
+ // pull the serializer and executer from the DI container
+ var serializer = context.RequestServices.GetRequiredService<IGraphQLSerializer>();
+ var executer = context.RequestServices.GetRequiredService<IDocumentExecuter>();
+
+ // read the request (ignores the content-type header)
+ var request = await serializer.ReadAsync<GraphQLRequest>(context.Request.Body, context.RequestAborted).ConfigureAwait(false)
+ ?? throw new InvalidOperationException("Could not read request");
+
+ // execute the request
+ var result = await executer.ExecuteAsync(options =>
+ {
+ options.Query = request.Query;
+ options.OperationName = request.OperationName;
+ options.Variables = request.Variables;
+ options.RequestServices = context.RequestServices;
+ options.CancellationToken = context.RequestAborted;
+ }).ConfigureAwait(false);
+
+ // write the response
+ context.Response.StatusCode = 200; // always OK even for errors
+ context.Response.ContentType = "application/json";
+ await serializer.WriteAsync(context.Response.Body, result, context.RequestAborted).ConfigureAwait(false);
+ }
+}

src/GraphQL.Federation.CodeFirst.Sample3/Properties/launchSettings.json

@@ -0,0 +1,12 @@
+{
+ "profiles": {
+ "GraphQL.Federation.Sample3": {
+ "commandName": "Project",
+ "launchBrowser": true,
+ "environmentVariables": {
+ "ASPNETCORE_ENVIRONMENT": "Development"
+ },
+ "applicationUrl": "https://localhost:56847;http://localhost:56848"
+ }
+ }
+}