Skip to content

Commit

Permalink
[ISSUE #4990] Add unit test for HttpConvertsUtils.java (#5110)
Browse files Browse the repository at this point in the history
* 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](rabbitmq/rabbitmq-java-client@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]>
  • Loading branch information
3 people authored Oct 8, 2024
1 parent 092a397 commit 7abe42a
Show file tree
Hide file tree
Showing 2 changed files with 102 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -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());
}
}
Original file line number Diff line number Diff line change
@@ -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"));
}
}

0 comments on commit 7abe42a

Please sign in to comment.