Merge pull request #76 from bright-room/claude/issue-60-20260309-1819

Close #60: Add WebFlux custom provider database (R2DBC) example

Author: kukv

examples/webflux/custom-provider-database/build.gradle.kts

@@ -0,0 +1,12 @@
+plugins {
+    id("example-base")
+    id("spotless-java")
+}
+
+dependencies {
+    implementation(project(":spring:spring-webflux"))
+    implementation(libs.spring.boot.starter.webflux)
+    implementation("org.springframework.boot:spring-boot-starter-data-r2dbc")
+    runtimeOnly("org.postgresql:r2dbc-postgresql")
+    implementation("org.springframework.boot:spring-boot-docker-compose")
+}

examples/webflux/custom-provider-database/src/main/java/net/brightroom/example/customprovider/CustomProviderDatabaseExampleApplication.java

@@ -0,0 +1,12 @@
+package net.brightroom.example.customprovider;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class CustomProviderDatabaseExampleApplication {
+
+  public static void main(String[] args) {
+    SpringApplication.run(CustomProviderDatabaseExampleApplication.class, args);
+  }
+}

examples/webflux/custom-provider-database/src/main/java/net/brightroom/example/customprovider/DatabaseReactiveEndpointGateProvider.java

@@ -0,0 +1,20 @@
+package net.brightroom.example.customprovider;
+
+import net.brightroom.endpointgate.reactive.core.provider.ReactiveEndpointGateProvider;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Mono;
+
+@Component
+public class DatabaseReactiveEndpointGateProvider implements ReactiveEndpointGateProvider {
+
+  private final GateManagementRepository repository;
+
+  public DatabaseReactiveEndpointGateProvider(GateManagementRepository repository) {
+    this.repository = repository;
+  }
+
+  @Override
+  public Mono<Boolean> isGateEnabled(String gateId) {
+    return repository.findById(gateId).map(GateManagementEntity::isEnabled);
+  }
+}

examples/webflux/custom-provider-database/src/main/java/net/brightroom/example/customprovider/ExperimentalController.java

@@ -0,0 +1,22 @@
+package net.brightroom.example.customprovider;
+
+import net.brightroom.endpointgate.core.annotation.EndpointGate;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+@RestController
+public class ExperimentalController {
+
+  @EndpointGate("experimental")
+  @GetMapping("/api/experimental")
+  public Mono<String> experimental() {
+    return Mono.just("Experimental feature");
+  }
+
+  @EndpointGate("development")
+  @GetMapping("/api/development")
+  public Mono<String> development() {
+    return Mono.just("Development feature");
+  }
+}

examples/webflux/custom-provider-database/src/main/java/net/brightroom/example/customprovider/GateManagementEntity.java

@@ -0,0 +1,32 @@
+package net.brightroom.example.customprovider;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Column;
+import org.springframework.data.relational.core.mapping.Table;
+
+@Table("gate_management")
+public class GateManagementEntity {
+
+  @Id
+  @Column("gate_id")
+  private String gateId;
+
+  @Column("enabled")
+  private boolean enabled;
+
+  public String getGateId() {
+    return gateId;
+  }
+
+  public void setGateId(String gateId) {
+    this.gateId = gateId;
+  }
+
+  public boolean isEnabled() {
+    return enabled;
+  }
+
+  public void setEnabled(boolean enabled) {
+    this.enabled = enabled;
+  }
+}

examples/webflux/custom-provider-database/src/main/java/net/brightroom/example/customprovider/GateManagementRepository.java

@@ -0,0 +1,8 @@
+package net.brightroom.example.customprovider;
+
+import org.springframework.data.repository.reactive.ReactiveCrudRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface GateManagementRepository
+    extends ReactiveCrudRepository<GateManagementEntity, String> {}

examples/webflux/custom-provider-database/src/main/resources/application.yml

@@ -0,0 +1,11 @@
+spring:
+  docker:
+    compose:
+      file: ../../docker/compose.yaml
+  r2dbc:
+    url: r2dbc:postgresql://localhost:5432/postgres
+    username: postgres
+    password: postgres
+
+endpoint-gate:
+  default-enabled: false

settings.gradle.kts

@@ -53,6 +53,7 @@ include(
     "examples:webflux:fail-behavior",
     "examples:webflux:error-handling",
     "examples:webflux:custom-provider",
+    "examples:webflux:custom-provider-database",
     "examples:webflux:actuator-endpoint",
     "examples:webflux:health-indicator",
     "examples:webflux:basic-usage",