diff --git a/core/src/main/java/expert/os/harperdb/HttpStatus.java b/core/src/main/java/expert/os/harperdb/HttpStatus.java index f490f98..8f5e76c 100644 --- a/core/src/main/java/expert/os/harperdb/HttpStatus.java +++ b/core/src/main/java/expert/os/harperdb/HttpStatus.java @@ -1,5 +1,6 @@ package expert.os.harperdb; +import java.net.http.HttpResponse; import java.util.function.Supplier; /** @@ -32,4 +33,8 @@ enum HttpStatus implements Supplier { public Integer get() { return status; } + + public boolean isEquals(HttpResponse response) { + return this.status == response.statusCode(); + } } diff --git a/core/src/main/java/expert/os/harperdb/Server.java b/core/src/main/java/expert/os/harperdb/Server.java index cf36355..7dffd8d 100644 --- a/core/src/main/java/expert/os/harperdb/Server.java +++ b/core/src/main/java/expert/os/harperdb/Server.java @@ -40,12 +40,12 @@ static Server of(URI host, Auth auth) { */ public boolean schema(String schema) { Objects.requireNonNull(schema, "schema is required"); - HttpRequest request = createRequest().POST(ofByteArray(INSTANCE.writeValueAsBytes(new CreateSchema("test")))) + HttpRequest request = createRequest().POST(ofByteArray(INSTANCE.writeValueAsBytes(new CreateSchema(schema)))) .build(); try { HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofInputStream()); - return response.statusCode() == HTTP_STATUS_OK; + return HttpStatus.OK.isEquals(response); } catch (IOException| InterruptedException e) { throw new HarperDBException("There is an issue to create the schema: " + schema, e); } diff --git a/core/src/test/java/expert/os/harperdb/ServerTest.java b/core/src/test/java/expert/os/harperdb/ServerTest.java index 3781ddf..6758a32 100644 --- a/core/src/test/java/expert/os/harperdb/ServerTest.java +++ b/core/src/test/java/expert/os/harperdb/ServerTest.java @@ -29,9 +29,9 @@ void shouldCreateSchema() { void shouldNotCreateSchemaDuplicated() { Server server = getServer(); - boolean schema = server.schema("test"); + boolean schema = server.schema("duplicated"); Assertions.assertTrue(schema); - Assertions.assertFalse(server.schema("test")); + Assertions.assertFalse(server.schema("duplicated")); } private Server getServer() {