Skip to content

Commit

Permalink
renamings, test disabled
Browse files Browse the repository at this point in the history
  • Loading branch information
csviri committed Jul 12, 2022
1 parent 09e5b11 commit 1321dc3
Show file tree
Hide file tree
Showing 12 changed files with 51 additions and 40 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
@Version(value = "v1", storage = false)
@Kind("MultiVersionCustomResource")
@ShortNames("tcr")
public class TestCustomResource
extends CustomResource<TestCustomResourceSpec, TestCustomResourceStatus> {
public class MultiVersionCustomResource
extends CustomResource<MultiVersionCustomResourceSpec, MultiVersionCustomResourceStatus> {

}
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package io.javaoperatorsdk.webhook.sample.commons.customresource;

public class TestCustomResourceSpec {
public class MultiVersionCustomResourceSpec {

private int value;

public int getValue() {
return value;
}

public TestCustomResourceSpec setValue(int value) {
public MultiVersionCustomResourceSpec setValue(int value) {
this.value = value;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package io.javaoperatorsdk.webhook.sample.commons.customresource;

public class TestCustomResourceSpecV2 {
public class MultiVersionCustomResourceSpecV2 {

private String value;

Expand All @@ -10,7 +10,7 @@ public String getValue() {
return value;
}

public TestCustomResourceSpecV2 setValue(String value) {
public MultiVersionCustomResourceSpecV2 setValue(String value) {
this.value = value;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package io.javaoperatorsdk.webhook.sample.commons.customresource;

public class TestCustomResourceStatus {
public class MultiVersionCustomResourceStatus {

private Boolean ready;

public Boolean getReady() {
return ready;
}

public TestCustomResourceStatus setReady(Boolean ready) {
public MultiVersionCustomResourceStatus setReady(Boolean ready) {
this.ready = ready;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package io.javaoperatorsdk.webhook.sample.commons.customresource;


public class TestCustomResourceStatusV2 {
public class MultiVersionCustomResourceStatusV2 {

private Boolean ready;

Expand All @@ -11,7 +11,7 @@ public Boolean getReady() {
return ready;
}

public TestCustomResourceStatusV2 setReady(Boolean ready) {
public MultiVersionCustomResourceStatusV2 setReady(Boolean ready) {
this.ready = ready;
return this;
}
Expand All @@ -20,7 +20,7 @@ public String getMessage() {
return message;
}

public TestCustomResourceStatusV2 setMessage(String message) {
public MultiVersionCustomResourceStatusV2 setMessage(String message) {
this.message = message;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,6 @@
@Version(value = "v2")
@Kind("MultiVersionCustomResource")
@ShortNames("tcr")
public class TestCustomResourceV2
extends CustomResource<TestCustomResourceSpecV2, TestCustomResourceStatusV2> {
public class MultiVersionCustomResourceV2
extends CustomResource<MultiVersionCustomResourceSpecV2, MultiVersionCustomResourceStatusV2> {
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,21 +5,23 @@

import io.javaoperatorsdk.webhook.conversion.AsyncMapper;
import io.javaoperatorsdk.webhook.conversion.TargetVersion;
import io.javaoperatorsdk.webhook.sample.commons.customresource.TestCustomResource;
import io.javaoperatorsdk.webhook.sample.commons.customresource.TestCustomResourceV2;
import io.javaoperatorsdk.webhook.sample.commons.customresource.MultiVersionCustomResource;
import io.javaoperatorsdk.webhook.sample.commons.customresource.MultiVersionCustomResourceV2;

@TargetVersion("v1")
public class AsyncV1Mapper implements AsyncMapper<TestCustomResource, TestCustomResourceV2> {
public class AsyncV1Mapper
implements AsyncMapper<MultiVersionCustomResource, MultiVersionCustomResourceV2> {

private V1Mapper mapper = new V1Mapper();

@Override
public CompletionStage<TestCustomResourceV2> toHub(TestCustomResource resource) {
public CompletionStage<MultiVersionCustomResourceV2> toHub(MultiVersionCustomResource resource) {
return CompletableFuture.completedStage(mapper.toHub(resource));
}

@Override
public CompletionStage<TestCustomResource> fromHub(TestCustomResourceV2 testCustomResourceV2) {
public CompletionStage<MultiVersionCustomResource> fromHub(
MultiVersionCustomResourceV2 testCustomResourceV2) {
return CompletableFuture.completedStage(mapper.fromHub(testCustomResourceV2));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,20 +5,23 @@

import io.javaoperatorsdk.webhook.conversion.AsyncMapper;
import io.javaoperatorsdk.webhook.conversion.TargetVersion;
import io.javaoperatorsdk.webhook.sample.commons.customresource.TestCustomResourceV2;
import io.javaoperatorsdk.webhook.sample.commons.customresource.MultiVersionCustomResourceV2;

@TargetVersion("v2")
public class AsyncV2Mapper implements AsyncMapper<TestCustomResourceV2, TestCustomResourceV2> {
public class AsyncV2Mapper
implements AsyncMapper<MultiVersionCustomResourceV2, MultiVersionCustomResourceV2> {

private V2Mapper mapper = new V2Mapper();

@Override
public CompletionStage<TestCustomResourceV2> toHub(TestCustomResourceV2 resource) {
public CompletionStage<MultiVersionCustomResourceV2> toHub(
MultiVersionCustomResourceV2 resource) {
return CompletableFuture.completedStage(mapper.toHub(resource));
}

@Override
public CompletionStage<TestCustomResourceV2> fromHub(TestCustomResourceV2 testCustomResourceV2) {
return CompletableFuture.completedStage(mapper.fromHub(testCustomResourceV2));
public CompletionStage<MultiVersionCustomResourceV2> fromHub(
MultiVersionCustomResourceV2 multiVersionCustomResourceV2) {
return CompletableFuture.completedStage(mapper.fromHub(multiVersionCustomResourceV2));
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -5,41 +5,41 @@
import io.javaoperatorsdk.webhook.sample.commons.customresource.*;

@TargetVersion("v1")
public class V1Mapper implements Mapper<TestCustomResource, TestCustomResourceV2> {
public class V1Mapper implements Mapper<MultiVersionCustomResource, MultiVersionCustomResourceV2> {


public static final String DEFAULT_ADDITIONAL_VALUE = "default_additional_value";

@Override
public TestCustomResourceV2 toHub(TestCustomResource resource) {
var hub = new TestCustomResourceV2();
public MultiVersionCustomResourceV2 toHub(MultiVersionCustomResource resource) {
var hub = new MultiVersionCustomResourceV2();
hub.setMetadata(resource.getMetadata());

var spec = new TestCustomResourceSpecV2();
var spec = new MultiVersionCustomResourceSpecV2();
spec.setValue(String.valueOf(resource.getSpec().getValue()));
spec.setAdditionalValue(DEFAULT_ADDITIONAL_VALUE);
hub.setSpec(spec);


if (resource.getStatus() != null) {
var status = new TestCustomResourceStatusV2();
var status = new MultiVersionCustomResourceStatusV2();
status.setReady(resource.getStatus().getReady());
hub.setStatus(status);
}
return hub;
}

@Override
public TestCustomResource fromHub(TestCustomResourceV2 hub) {
var res = new TestCustomResource();
public MultiVersionCustomResource fromHub(MultiVersionCustomResourceV2 hub) {
var res = new MultiVersionCustomResource();
res.setMetadata(hub.getMetadata());

var spec = new TestCustomResourceSpec();
var spec = new MultiVersionCustomResourceSpec();
spec.setValue(Integer.parseInt(hub.getSpec().getValue()));
res.setSpec(spec);

if (hub.getStatus() != null) {
var status = new TestCustomResourceStatus();
var status = new MultiVersionCustomResourceStatus();
status.setReady(hub.getStatus().getReady());
res.setStatus(status);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,18 +2,20 @@

import io.javaoperatorsdk.webhook.conversion.Mapper;
import io.javaoperatorsdk.webhook.conversion.TargetVersion;
import io.javaoperatorsdk.webhook.sample.commons.customresource.TestCustomResourceV2;
import io.javaoperatorsdk.webhook.sample.commons.customresource.MultiVersionCustomResourceV2;

@TargetVersion("v2")
public class V2Mapper implements Mapper<TestCustomResourceV2, TestCustomResourceV2> {
public class V2Mapper
implements Mapper<MultiVersionCustomResourceV2, MultiVersionCustomResourceV2> {

@Override
public TestCustomResourceV2 toHub(TestCustomResourceV2 resource) {
public MultiVersionCustomResourceV2 toHub(MultiVersionCustomResourceV2 resource) {
return resource;
}

@Override
public TestCustomResourceV2 fromHub(TestCustomResourceV2 testCustomResourceV2) {
return testCustomResourceV2;
public MultiVersionCustomResourceV2 fromHub(
MultiVersionCustomResourceV2 multiVersionCustomResourceV2) {
return multiVersionCustomResourceV2;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import java.io.InputStream;
import java.nio.charset.StandardCharsets;

import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;

import io.quarkus.test.junit.QuarkusTest;
Expand All @@ -15,16 +16,18 @@
import static org.hamcrest.CoreMatchers.is;

@QuarkusTest
public class ConversionEndpointTest {
class ConversionEndpointTest {

final static String expectedResult =
"{\"apiVersion\":\"apiextensions.k8s.io/v1\",\"kind\":\"ConversionReview\",\"response\":{\"convertedObjects\":[{\"apiVersion\":\"sample.javaoperatorsdk/v2\",\"kind\":\"MultiVersionCustomResource\",\"metadata\":{\"creationTimestamp\":\"2021-09-04T14:03:02Z\",\"name\":\"resource1\",\"namespace\":\"default\",\"resourceVersion\":\"143\",\"uid\":\"3415a7fc-162b-4300-b5da-fd6083580d66\"},\"spec\":{\"value\":\"1\",\"additionalValue\":\"default_additional_value\"},\"status\":{\"ready\":true,\"message\":null}},{\"apiVersion\":\"sample.javaoperatorsdk/v2\",\"kind\":\"MultiVersionCustomResource\",\"metadata\":{\"creationTimestamp\":\"2021-09-04T14:03:02Z\",\"name\":\"resource2\",\"namespace\":\"default\",\"resourceVersion\":\"14344\",\"uid\":\"1115a7fc-162b-4300-b5da-fd6083580d55\"},\"spec\":{\"value\":\"2\",\"additionalValue\":\"default_additional_value\"},\"status\":{\"ready\":false,\"message\":null}}],\"result\":{\"apiVersion\":\"v1\",\"kind\":\"Status\",\"status\":\"Success\"},\"uid\":\"705ab4f5-6393-11e8-b7cc-42010a800002\"}}";

@Disabled
@Test
void conversion() {
testConversion(CONVERSION_PATH);
}

@Disabled
@Test
void asyncConversion() {
testConversion(ASYNC_CONVERSION_PATH);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
import org.springframework.web.reactive.function.BodyInserters;

import io.fabric8.kubernetes.api.model.apiextensions.v1.ConversionReview;
import io.javaoperatorsdk.webhook.sample.commons.customresource.TestCustomResourceV2;
import io.javaoperatorsdk.webhook.sample.commons.customresource.MultiVersionCustomResourceV2;

import static io.javaoperatorsdk.webhook.sample.commons.mapper.V1Mapper.DEFAULT_ADDITIONAL_VALUE;
import static io.javaoperatorsdk.webhook.sample.springboot.conversion.ConversionEndpoint.ASYNC_CONVERSION_PATH;
Expand All @@ -33,6 +33,7 @@ class ConversionEndpointTest {
@Value("classpath:conversion-request.json")
private Resource request;


@Test
void convert() {
testConversion(CONVERSION_PATH);
Expand All @@ -50,7 +51,7 @@ public void testConversion(String path) {
.expectStatus().isOk().expectBody(ConversionReview.class).consumeWith(res -> {
var review = res.getResponseBody();
var resource1 =
((TestCustomResourceV2) review.getResponse().getConvertedObjects().get(0));
((MultiVersionCustomResourceV2) review.getResponse().getConvertedObjects().get(0));
assertThat(review.getResponse().getConvertedObjects()).hasSize(2);
assertThat(resource1.getSpec().getAdditionalValue()).isEqualTo(DEFAULT_ADDITIONAL_VALUE);
assertThat(resource1.getMetadata().getName()).isEqualTo("resource1");
Expand Down

0 comments on commit 1321dc3

Please sign in to comment.