This is an automated email from the ASF dual-hosted git repository.
harshitha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 7abe42a4e [ISSUE #4990] Add unit test for HttpConvertsUtils.java
(#5110)
7abe42a4e is described below
commit 7abe42a4efa1a9dfeb68902e1f6b441bb20e6459
Author: KrispauI <[email protected]>
AuthorDate: Tue Oct 8 21:43:36 2024 +0800
[ISSUE #4990] Add unit test for HttpConvertsUtils.java (#5110)
* add unit test for HttpConvertsUtils.java
* fix package error
* Bump com.gradle.develocity from 3.17.5 to 3.18.1 (#5121)
Bumps com.gradle.develocity from 3.17.5 to 3.18.1.
---
updated-dependencies:
- dependency-name: com.gradle.develocity
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* Bump software.amazon.awssdk:s3 from 2.27.17 to 2.28.12 (#5120)
Bumps software.amazon.awssdk:s3 from 2.27.17 to 2.28.12.
---
updated-dependencies:
- dependency-name: software.amazon.awssdk:s3
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* [ISSUE #4540] Add unit test for ThreadUtils (#5111)
* Bump com.rabbitmq:amqp-client from 5.21.0 to 5.22.0 (#5119)
Bumps
[com.rabbitmq:amqp-client](https://github.com/rabbitmq/rabbitmq-java-client)
from 5.21.0 to 5.22.0.
- [Release notes](https://github.com/rabbitmq/rabbitmq-java-client/releases)
-
[Commits](https://github.com/rabbitmq/rabbitmq-java-client/compare/v5.21.0...v5.22.0)
---
updated-dependencies:
- dependency-name: com.rabbitmq:amqp-client
dependency-type: direct:production
update-type: version-update:semver-minor
...
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
* fix CI errors
---------
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Melis Ölmez <[email protected]>
---
.../apache/eventmesh/common/stubs/HeaderStub.java | 35 +++++++++++
.../common/utils/HttpConvertsUtilsTest.java | 67 ++++++++++++++++++++++
2 files changed, 102 insertions(+)
diff --git
a/eventmesh-common/src/main/java/org/apache/eventmesh/common/stubs/HeaderStub.java
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/stubs/HeaderStub.java
new file mode 100644
index 000000000..1782d46dd
--- /dev/null
+++
b/eventmesh-common/src/main/java/org/apache/eventmesh/common/stubs/HeaderStub.java
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.common.stubs;
+
+import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
+import org.apache.eventmesh.common.protocol.http.header.Header;
+import org.apache.eventmesh.common.utils.HttpConvertsUtils;
+
+import java.util.Map;
+
+public class HeaderStub extends Header {
+
+ public String code;
+ public String eventmeshenv;
+
+ @Override
+ public Map<String, Object> toMap() {
+ return new HttpConvertsUtils().httpMapConverts(this, new
ProtocolKey(), new ProtocolKey.EventMeshInstanceKey());
+ }
+}
diff --git
a/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/HttpConvertsUtilsTest.java
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/HttpConvertsUtilsTest.java
new file mode 100644
index 000000000..253b1de92
--- /dev/null
+++
b/eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/HttpConvertsUtilsTest.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.common.utils;
+
+import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
+import
org.apache.eventmesh.common.protocol.http.common.ProtocolKey.EventMeshInstanceKey;
+import org.apache.eventmesh.common.protocol.http.header.Header;
+import org.apache.eventmesh.common.stubs.HeaderStub;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+class HttpConvertsUtilsTest {
+
+ private final HeaderStub headerStub = new HeaderStub();
+ private final ProtocolKey mockedProtocolKey = new ProtocolKey();
+ private final EventMeshInstanceKey mockedEventMeshProtocolKey = new
EventMeshInstanceKey();
+
+ @Test
+ void httpMapConverts() {
+ Map<String, Object> httpMapConverts = new
HttpConvertsUtils().httpMapConverts(headerStub, mockedProtocolKey);
+ Assertions.assertEquals(httpMapConverts.get(headerStub.code),
headerStub.code);
+ }
+
+ @Test
+ void testHttpMapConverts() {
+ Map<String, Object> httpMapConverts = new
HttpConvertsUtils().httpMapConverts(headerStub, mockedProtocolKey,
mockedEventMeshProtocolKey);
+ Assertions.assertEquals(httpMapConverts.get(headerStub.code),
headerStub.code);
+ Assertions.assertEquals(httpMapConverts.get(headerStub.eventmeshenv),
headerStub.eventmeshenv);
+ }
+
+ @Test
+ void httpHeaderConverts() {
+ HashMap<String, Object> headerParams = new HashMap<>();
+ String code = "test";
+ headerParams.put("code", code);
+ Header header = new HttpConvertsUtils().httpHeaderConverts(headerStub,
headerParams);
+ Assertions.assertEquals(code, header.toMap().get("code"));
+ }
+
+ @Test
+ void testHttpHeaderConverts() {
+ HashMap<String, Object> headerParams = new HashMap<>();
+ String env = "test";
+ headerParams.put("eventmeshenv", env);
+ Header header = new HttpConvertsUtils().httpHeaderConverts(headerStub,
headerParams, mockedEventMeshProtocolKey);
+ Assertions.assertEquals(env, header.toMap().get("eventmeshenv"));
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
