Skip to content

Test long vals #717

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 15 commits into from
Apr 1, 2022
Merged

Test long vals #717

Changes from all commits
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
c759e2d
run IT test for long values
tanvigour Mar 23, 2022
afc31e6
Fix the class name
tanvigour Mar 23, 2022
b913cf9
Merge branch 'master' into tanvi/test_longvalues
mukundansundar Mar 23, 2022
fa8f19d
assert for all messages and fix class name
tanvigour Mar 23, 2022
52bcadc
Merge branch 'master' into tanvi/test_longvalues
tanvigour Mar 24, 2022
a31516f
test for Long.MAX_VALUE
tanvigour Mar 25, 2022
acd4a32
revert back long number and print
tanvigour Mar 25, 2022
bf825b1
fix the typo
tanvigour Mar 25, 2022
ba29451
update the latest dapr commit in workflow files
tanvigour Mar 25, 2022
4ba4859
log some more data to debug
tanvigour Mar 25, 2022
93a5943
debug
tanvigour Mar 25, 2022
09c52af
get the value from messages
tanvigour Mar 25, 2022
7fe8c65
fix long values assert
mukundansundar Mar 26, 2022
e35738c
Merge branch 'master' into test-long-vals
mukundansundar Mar 31, 2022
d826a39
increasing TTL
mukundansundar Mar 31, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
60 changes: 31 additions & 29 deletions sdk-tests/src/test/java/io/dapr/it/pubsub/http/PubSubIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@
import io.dapr.serializer.DaprObjectSerializer;
import io.dapr.utils.TypeRef;
import org.junit.After;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
Expand All @@ -35,12 +36,13 @@
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Random;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Objects;
import java.util.Random;
import java.util.Set;

import static io.dapr.it.Retry.callWithRetry;
import static io.dapr.it.TestUtils.assertThrowsDaprException;
Expand Down Expand Up @@ -426,29 +428,27 @@ public void testLongValues() throws Exception {
daprRun.switchToHTTP();
}

ConvertToLong toLong = new ConvertToLong();
HashSet<ConvertToLong> expected = new HashSet<>();
Random random = new Random();
Long randomLong = 590518626939830271L;
random.setSeed(randomLong);
toLong.setValue(randomLong);
expected.add(toLong);
for (int i = 1; i < NUM_MESSAGES; i++) {
ConvertToLong value = new ConvertToLong();
randomLong = random.nextLong();
value.setValue(randomLong);
expected.add(value);
System.out.println("expected value is : " +value);
Random random = new Random(590518626939830271L);
Set<ConvertToLong> values = new HashSet<>();
values.add(new ConvertToLong().setVal(590518626939830271L));
ConvertToLong val;
for (int i = 0; i < NUM_MESSAGES - 1; i++) {
do {
val = new ConvertToLong().setVal(random.nextLong());
} while (values.contains(val));
values.add(val);
}
Iterator expectVal = expected.iterator();
Iterator<ConvertToLong> valuesIt = values.iterator();
try (DaprClient client = new DaprClientBuilder().build()) {
while(expectVal.hasNext()) {
for (int i = 0; i < NUM_MESSAGES; i++) {
ConvertToLong value = valuesIt.next();
System.out.println("The long value sent " + value.getValue());
//Publishing messages
client.publishEvent(
PUBSUB_NAME,
LONG_TOPIC_NAME,
expectVal.next(),
Collections.singletonMap(Metadata.TTL_IN_SECONDS, "1")).block();
value,
Collections.singletonMap(Metadata.TTL_IN_SECONDS, "30")).block();

try {
Thread.sleep((long) (1000 * Math.random()));
Expand All @@ -460,7 +460,7 @@ public void testLongValues() throws Exception {
}
}

HashSet<ConvertToLong> actual = new HashSet<>();
Set<ConvertToLong> actual = new HashSet<>();
try (DaprClient client = new DaprClientBuilder().build()) {
callWithRetry(() -> {
System.out.println("Checking results for topic " + LONG_TOPIC_NAME);
Expand All @@ -469,12 +469,12 @@ public void testLongValues() throws Exception {
"messages/testinglongvalues",
null,
HttpExtension.GET, CLOUD_EVENT_LONG_LIST_TYPE_REF).block();
assertNotNull(messages);
for (int i = 0; i < NUM_MESSAGES; i++) {
actual.add(messages.get(i).getData());
Assert.assertNotNull(messages);
for (CloudEvent<ConvertToLong> message : messages) {
actual.add(message.getData());
}
assertEquals(expected,actual);
}, 2000);
Assert.assertEquals(values, actual);
}
}

Expand All @@ -493,15 +493,17 @@ public void setId(String id) {
public static class ConvertToLong {
private Long value;

public ConvertToLong setVal(Long value) {
this.value = value;
return this;
}

public Long getValue() {
return value;
}

public void setValue(Long value) {
this.value = value;
}

@Override
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
Expand Down