ci: fix compilation

eclipse-edc · Nov 6, 2024 · ef9032c · ef9032c
1 parent 164055c
commit ef9032c
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 46 deletions.
diff --git a/...ne-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSinkFactory.java b/...ne-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSinkFactory.java
@@ -77,11 +77,6 @@ public String supportedType() {
         return S3BucketSchema.TYPE;
     }
 
-    @Override
-    public boolean canHandle(DataFlowStartMessage request) {
-        return S3BucketSchema.TYPE.equals(request.getDestinationDataAddress().getType());
-    }
-
     @Override
     public DataSink createSink(DataFlowStartMessage request) {
         var validationResult = validateRequest(request);

diff --git a/...-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSourceFactory.java b/...-aws-s3/src/main/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSourceFactory.java
@@ -71,11 +71,6 @@ public String supportedType() {
         return S3BucketSchema.TYPE;
     }
 
-    @Override
-    public boolean canHandle(DataFlowStartMessage request) {
-        return S3BucketSchema.TYPE.equals(request.getSourceDataAddress().getType());
-    }
-
     @Override
     public DataSource createSource(DataFlowStartMessage request) {
         var validationResult = validateRequest(request);

diff --git a/...ws-s3/src/test/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSinkFactoryTest.java b/...ws-s3/src/test/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSinkFactoryTest.java
@@ -53,24 +53,6 @@ class S3DataSinkFactoryTest {
     private final S3DataSinkFactory factory = new S3DataSinkFactory(clientProvider, mock(), mock(),
             vault, typeManager.getMapper(), 1024, validator);
 
-    @Test
-    void canHandle_returnsTrueWhenExpectedType() {
-        var dataAddress = DataAddress.Builder.newInstance().type(S3BucketSchema.TYPE).build();
-
-        var result = factory.canHandle(createRequest(dataAddress));
-
-        assertThat(result).isTrue();
-    }
-
-    @Test
-    void canHandle_returnsFalseWhenUnexpectedType() {
-        var dataAddress = DataAddress.Builder.newInstance().type("any").build();
-
-        var result = factory.canHandle(createRequest(dataAddress));
-
-        assertThat(result).isFalse();
-    }
-
     @Test
     void validate_shouldSucceed_whenValidatorSucceeds() {
         when(validator.validateDestination(any())).thenReturn(ValidationResult.success());

diff --git a/...-s3/src/test/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSourceFactoryTest.java b/...-s3/src/test/java/org/eclipse/edc/connector/dataplane/aws/s3/S3DataSourceFactoryTest.java
@@ -54,24 +54,6 @@ class S3DataSourceFactoryTest {
     private final S3DataSourceFactory factory = new S3DataSourceFactory(clientProvider, mock(),
             vault, typeManager.getMapper(), validator);
 
-    @Test
-    void canHandle_returnsTrueWhenExpectedType() {
-        var dataAddress = DataAddress.Builder.newInstance().type(S3BucketSchema.TYPE).build();
-
-        var result = factory.canHandle(createRequest(dataAddress));
-
-        assertThat(result).isTrue();
-    }
-
-    @Test
-    void canHandle_returnsFalseWhenUnexpectedType() {
-        var dataAddress = DataAddress.Builder.newInstance().type("any").build();
-
-        var result = factory.canHandle(createRequest(dataAddress));
-
-        assertThat(result).isFalse();
-    }
-
     @Test
     void validate_shouldSucceed_whenValidatorSucceeds() {
         when(validator.validateSource(any())).thenReturn(ValidationResult.success());