*/
package org.opendaylight.controller.cluster.access.commands;
+import static org.junit.Assert.assertArrayEquals;
+import static org.junit.Assert.assertEquals;
+
import akka.actor.ActorRef;
import akka.actor.ActorSelection;
import akka.actor.ActorSystem;
import akka.testkit.TestProbe;
import com.google.common.base.MoreObjects;
import com.google.common.collect.ImmutableList;
-import java.util.Collection;
import java.util.List;
import java.util.Optional;
-import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.controller.cluster.access.ABIVersion;
-import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree;
-import org.opendaylight.yangtools.yang.data.api.schema.tree.TreeType;
-import org.opendaylight.yangtools.yang.data.impl.schema.tree.InMemoryDataTreeFactory;
+import org.opendaylight.yangtools.yang.data.tree.api.DataTree;
+import org.opendaylight.yangtools.yang.data.tree.api.DataTreeConfiguration;
+import org.opendaylight.yangtools.yang.data.tree.api.ReadOnlyDataTree;
+import org.opendaylight.yangtools.yang.data.tree.impl.di.InMemoryDataTreeFactory;
public class ConnectClientSuccessTest extends AbstractRequestSuccessTest<ConnectClientSuccess> {
-
- private static final DataTree TREE = InMemoryDataTreeFactory.getInstance().create(TreeType.OPERATIONAL);
+ private static final DataTree TREE = new InMemoryDataTreeFactory().create(
+ DataTreeConfiguration.DEFAULT_OPERATIONAL);
private static final ActorSystem SYSTEM = ActorSystem.create("test");
private static final ActorRef ACTOR_REF = TestProbe.apply(SYSTEM).ref();
private static final ActorSelection ACTOR_SELECTION = ActorSelection.apply(ACTOR_REF, "foo");
private static final List<ActorSelection> ALTERNATES = ImmutableList.of(ACTOR_SELECTION);
private static final int MAX_MESSAGES = 10;
- private static final ConnectClientSuccess OBJECT = new ConnectClientSuccess(
- CLIENT_IDENTIFIER, 0, ACTOR_REF, ALTERNATES, TREE, MAX_MESSAGES);
+ private static final ConnectClientSuccess OBJECT = new ConnectClientSuccess(CLIENT_IDENTIFIER, 0, ACTOR_REF,
+ ALTERNATES, TREE, MAX_MESSAGES);
- @Override
- protected ConnectClientSuccess object() {
- return OBJECT;
+ public ConnectClientSuccessTest() {
+ super(OBJECT, 146 + ACTOR_REF.path().toSerializationFormat().length());
}
@Before
@Test
public void testGetAlternates() {
- final Collection<ActorSelection> alternates = OBJECT.getAlternates();
- Assert.assertArrayEquals(ALTERNATES.toArray(), alternates.toArray());
+ final var alternates = OBJECT.getAlternates();
+ assertArrayEquals(ALTERNATES.toArray(), alternates.toArray());
}
@Test
public void testGetBackend() {
final ActorRef actorRef = OBJECT.getBackend();
- Assert.assertEquals(ACTOR_REF, actorRef);
+ assertEquals(ACTOR_REF, actorRef);
}
@Test
public void testGetDataTree() {
- final DataTree tree = OBJECT.getDataTree().get();
- Assert.assertEquals(TREE, tree);
+ final ReadOnlyDataTree tree = OBJECT.getDataTree().orElseThrow();
+ assertEquals(TREE, tree);
}
@Test
public void testGetMaxMessages() {
- final int maxMessages = OBJECT.getMaxMessages();
- Assert.assertEquals(MAX_MESSAGES, maxMessages);
+ assertEquals(MAX_MESSAGES, OBJECT.getMaxMessages());
}
@Test
- public void cloneAsVersionTest() throws Exception {
- final ConnectClientSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
- Assert.assertEquals(OBJECT, clone);
+ public void cloneAsVersionTest() {
+ final var clone = OBJECT.cloneAsVersion(ABIVersion.TEST_FUTURE_VERSION);
+ assertEquals(OBJECT.getSequence(), clone.getSequence());
+ assertEquals(OBJECT.getTarget(), clone.getTarget());
+ assertEquals(OBJECT.getAlternates(), clone.getAlternates());
+ assertEquals(OBJECT.getBackend(), clone.getBackend());
+ assertEquals(OBJECT.getDataTree(), clone.getDataTree());
+ assertEquals(OBJECT.getMaxMessages(), clone.getMaxMessages());
}
@Test
- public void addToStringAttributes() throws Exception {
- final MoreObjects.ToStringHelper result = OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
- Assert.assertTrue(result.toString().contains("alternates=" + ALTERNATES));
- Assert.assertTrue(result.toString().contains("dataTree=" + TREE));
- Assert.assertTrue(result.toString().contains("maxMessages=" + MAX_MESSAGES));
+ public void addToStringAttributes() {
+ // Just verify it doesn't throw an exception.
+ OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
}
@Override
- protected void doAdditionalAssertions(final Object deserialize) {
- Assert.assertTrue(deserialize instanceof ConnectClientSuccess);
- Assert.assertEquals(OBJECT.getAlternates().size(), ((ConnectClientSuccess) deserialize).getAlternates().size());
- Assert.assertEquals(OBJECT.getBackend(), ((ConnectClientSuccess) deserialize).getBackend());
- Assert.assertEquals(Optional.empty(), ((ConnectClientSuccess) deserialize).getDataTree());
- Assert.assertEquals(OBJECT.getMaxMessages(), ((ConnectClientSuccess) deserialize).getMaxMessages());
+ protected void doAdditionalAssertions(final ConnectClientSuccess deserialize) {
+ assertEquals(OBJECT.getAlternates().size(), deserialize.getAlternates().size());
+ assertEquals(OBJECT.getBackend(), deserialize.getBackend());
+ assertEquals(Optional.empty(), deserialize.getDataTree());
+ assertEquals(OBJECT.getMaxMessages(), deserialize.getMaxMessages());
}
}