Skip to content

Commit

Permalink
fix: 修改motan插件的e2e测试
Browse files Browse the repository at this point in the history
  • Loading branch information
lahmXu committed Jan 9, 2024
1 parent a2b8936 commit 3875a0c
Showing 1 changed file with 20 additions and 39 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,14 +24,14 @@
import org.apache.shenyu.e2e.client.gateway.GatewayClient;
import org.apache.shenyu.e2e.engine.annotation.ShenYuScenario;
import org.apache.shenyu.e2e.engine.annotation.ShenYuTest;
import org.apache.shenyu.e2e.engine.scenario.specification.AfterEachSpec;
import org.apache.shenyu.e2e.engine.scenario.specification.BeforeEachSpec;
import org.apache.shenyu.e2e.engine.scenario.specification.CaseSpec;
import org.apache.shenyu.e2e.enums.ServiceTypeEnum;
import org.apache.shenyu.e2e.model.ResourcesData;
import org.apache.shenyu.e2e.model.response.SelectorDTO;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;

Expand Down Expand Up @@ -87,45 +87,26 @@ static void setup(final AdminClient adminClient, final GatewayClient gatewayClie
RestAssured.registerParser("text/plain", Parser.JSON);
}

// @BeforeEach
// void before(final AdminClient client, final GatewayClient gateway, final BeforeEachSpec spec) {
// spec.getChecker().check(gateway);
//
// ResourcesData resources = spec.getResources();
// for (ResourcesData.Resource res : resources.getResources()) {
// SelectorDTO dto = client.create(res.getSelector());
// selectorIds.add(dto.getId());
//
// res.getRules().forEach(rule -> {
// rule.setSelectorId(dto.getId());
// client.create(rule);
// });
// }
//
// spec.getWaiting().waitFor(gateway);
// }
@BeforeEach
void before(final AdminClient client, final GatewayClient gateway, final BeforeEachSpec spec) {
spec.getChecker().check(gateway);

@ShenYuScenario(provider = MotanPluginCases.class)
void testMotan(final GatewayClient gateway, final CaseSpec spec) {
spec.getVerifiers().forEach(verifier -> verifier.verify(gateway.getHttpRequesterSupplier().get()));
}
ResourcesData resources = spec.getResources();
for (ResourcesData.Resource res : resources.getResources()) {
SelectorDTO dto = client.create(res.getSelector());
selectorIds.add(dto.getId());

@AfterEach
void after(final AdminClient client, final GatewayClient gateway, final AfterEachSpec spec) {
spec.getDeleter().delete(client, selectorIds);
spec.deleteWaiting().waitFor(gateway);
selectorIds = new ArrayList<>();
res.getRules().forEach(rule -> {
rule.setSelectorId(dto.getId());
client.create(rule);
});
}

spec.getWaiting().waitFor(gateway);
}

@AfterAll
static void teardown(final AdminClient client) {
client.deleteAllSelectors();
MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
formData.add("id", "17");
formData.add("name", "motan");
formData.add("enabled", "false");
formData.add("role", "Proxy");
formData.add("sort", "310");
client.changePluginStatus("17", formData);
@ShenYuScenario(provider = MotanPluginCases.class)
void testMotan(final GatewayClient gateway, final CaseSpec spec) {
spec.getVerifiers().forEach(verifier -> verifier.verify(gateway.getHttpRequesterSupplier().get()));
}
}

0 comments on commit 3875a0c

Please sign in to comment.