-
Notifications
You must be signed in to change notification settings - Fork 1.8k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Daniel Widdis <widdis@gmail.com>
- Loading branch information
Showing
6 changed files
with
140 additions
and
64 deletions.
There are no files selected for viewing
41 changes: 0 additions & 41 deletions
41
server/src/main/java/org/opensearch/extensions/rest/RegisterRestActionsResponse.java
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
51 changes: 51 additions & 0 deletions
51
server/src/test/java/org/opensearch/extensions/ExtensionResponseTests.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,51 @@ | ||
| /* | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * The OpenSearch Contributors require contributions made to | ||
| * this file be licensed under the Apache-2.0 license or a | ||
| * compatible open source license. | ||
| */ | ||
|
|
||
| package org.opensearch.extensions; | ||
|
|
||
| import org.opensearch.common.bytes.BytesReference; | ||
| import org.opensearch.common.io.stream.BytesStreamInput; | ||
| import org.opensearch.common.io.stream.BytesStreamOutput; | ||
| import org.opensearch.test.OpenSearchTestCase; | ||
|
|
||
| public class ExtensionResponseTests extends OpenSearchTestCase { | ||
|
|
||
| public void testExtensionBooleanResponse() throws Exception { | ||
| boolean response = true; | ||
| ExtensionBooleanResponse booleanRsponse = new ExtensionBooleanResponse(response); | ||
|
|
||
| assertEquals(response, booleanRsponse.getStatus()); | ||
|
|
||
| try (BytesStreamOutput out = new BytesStreamOutput()) { | ||
| booleanRsponse.writeTo(out); | ||
| out.flush(); | ||
| try (BytesStreamInput in = new BytesStreamInput(BytesReference.toBytes(out.bytes()))) { | ||
| booleanRsponse = new ExtensionBooleanResponse(in); | ||
|
|
||
| assertEquals(response, booleanRsponse.getStatus()); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| public void testExtensionStringResponse() throws Exception { | ||
| String response = "This is a response"; | ||
| ExtensionStringResponse stringResponse = new ExtensionStringResponse(response); | ||
|
|
||
| assertEquals(response, stringResponse.getResponse()); | ||
|
|
||
| try (BytesStreamOutput out = new BytesStreamOutput()) { | ||
| stringResponse.writeTo(out); | ||
| out.flush(); | ||
| try (BytesStreamInput in = new BytesStreamInput(BytesReference.toBytes(out.bytes()))) { | ||
| stringResponse = new ExtensionStringResponse(in); | ||
|
|
||
| assertEquals(response, stringResponse.getResponse()); | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
56 changes: 56 additions & 0 deletions
56
server/src/test/java/org/opensearch/extensions/settings/RegisterSettingsTests.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,56 @@ | ||
| /* | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| * | ||
| * The OpenSearch Contributors require contributions made to | ||
| * this file be licensed under the Apache-2.0 license or a | ||
| * compatible open source license. | ||
| */ | ||
|
|
||
| package org.opensearch.extensions.settings; | ||
|
|
||
| import java.util.List; | ||
| import java.util.concurrent.TimeUnit; | ||
|
|
||
| import org.opensearch.common.bytes.BytesReference; | ||
| import org.opensearch.common.io.stream.BytesStreamInput; | ||
| import org.opensearch.common.io.stream.BytesStreamOutput; | ||
| import org.opensearch.common.settings.Setting; | ||
| import org.opensearch.common.settings.Setting.Property; | ||
| import org.opensearch.common.unit.ByteSizeUnit; | ||
| import org.opensearch.common.unit.ByteSizeValue; | ||
| import org.opensearch.common.unit.TimeValue; | ||
| import org.opensearch.test.OpenSearchTestCase; | ||
|
|
||
| public class RegisterSettingsTests extends OpenSearchTestCase { | ||
|
|
||
| public void testRegisterSettingsRequest() throws Exception { | ||
| String uniqueIdStr = "uniqueid1"; | ||
| List<Setting<?>> expected = List.of( | ||
| Setting.boolSetting("falseSetting", false, Property.IndexScope, Property.NodeScope), | ||
| Setting.simpleString("fooSetting", "foo", Property.Dynamic), | ||
| Setting.timeSetting("timeSetting", new TimeValue(5, TimeUnit.MILLISECONDS), Property.Dynamic), | ||
| Setting.byteSizeSetting("byteSizeSetting", new ByteSizeValue(10, ByteSizeUnit.KB), Property.Dynamic) | ||
| ); | ||
| RegisterSettingsRequest registerSettingsRequest = new RegisterSettingsRequest(uniqueIdStr, expected); | ||
|
|
||
| assertEquals(uniqueIdStr, registerSettingsRequest.getUniqueId()); | ||
| List<Setting<?>> settings = registerSettingsRequest.getSettings(); | ||
| assertEquals(expected.size(), settings.size()); | ||
| assertTrue(settings.containsAll(expected)); | ||
| assertTrue(expected.containsAll(settings)); | ||
|
|
||
| try (BytesStreamOutput out = new BytesStreamOutput()) { | ||
| registerSettingsRequest.writeTo(out); | ||
| out.flush(); | ||
| try (BytesStreamInput in = new BytesStreamInput(BytesReference.toBytes(out.bytes()))) { | ||
| registerSettingsRequest = new RegisterSettingsRequest(in); | ||
|
|
||
| assertEquals(uniqueIdStr, registerSettingsRequest.getUniqueId()); | ||
| settings = registerSettingsRequest.getSettings(); | ||
| assertEquals(expected.size(), settings.size()); | ||
| assertTrue(settings.containsAll(expected)); | ||
| assertTrue(expected.containsAll(settings)); | ||
| } | ||
| } | ||
| } | ||
| } |