diff options
author | Vitaly Takmazov | 2018-03-21 16:33:12 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2018-03-21 16:33:12 +0300 |
commit | 01818b95286bc2bf96a4adad42c2194e487f373a (patch) | |
tree | 8d61ec1527dfd74f6cac6d560c44b20eb01d2a36 /juick-xmpp-wip/src/test/java/com | |
parent | 77c7232a3ca354e009dfdd5a5eb0d390d7e627f5 (diff) |
drop xmpp-wip
Diffstat (limited to 'juick-xmpp-wip/src/test/java/com')
-rw-r--r-- | juick-xmpp-wip/src/test/java/com/juick/xmpp/XMPPTests.java | 98 |
1 files changed, 0 insertions, 98 deletions
diff --git a/juick-xmpp-wip/src/test/java/com/juick/xmpp/XMPPTests.java b/juick-xmpp-wip/src/test/java/com/juick/xmpp/XMPPTests.java deleted file mode 100644 index a9c6904c..00000000 --- a/juick-xmpp-wip/src/test/java/com/juick/xmpp/XMPPTests.java +++ /dev/null @@ -1,98 +0,0 @@ -/* - * Copyright (C) 2008-2017, Juick - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU Affero General Public License as - * published by the Free Software Foundation, either version 3 of the - * License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Affero General Public License for more details. - * - * You should have received a copy of the GNU Affero General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - */ - -package com.juick.xmpp; - -import com.juick.components.XMPPRouter; -import com.juick.components.configuration.BotAppConfiguration; -import com.juick.configuration.DataConfiguration; -import com.juick.service.ImagesService; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.boot.test.mock.mockito.MockBean; -import org.springframework.test.context.junit4.SpringRunner; -import rocks.xmpp.addr.Jid; -import rocks.xmpp.core.XmppException; -import rocks.xmpp.core.session.ConnectionEvent; -import rocks.xmpp.core.session.Extension; -import rocks.xmpp.core.session.XmppSessionConfiguration; -import rocks.xmpp.core.session.debug.LogbackDebugger; -import rocks.xmpp.core.stanza.model.Message; -import rocks.xmpp.extensions.component.accept.ExternalComponent; - -import javax.inject.Inject; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.ExecutorService; - -import static org.hamcrest.MatcherAssert.assertThat; -import static org.hamcrest.Matchers.equalTo; - -@RunWith(SpringRunner.class) -@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT, - classes = { BotAppConfiguration.class, DataConfiguration.class}) -public class XMPPTests { - @MockBean - ImagesService imagesService; - @Inject - XMPPRouter router; - @Inject - ExecutorService executorService; - @Test - public void routerHandshake() throws InterruptedException { - XmppSessionConfiguration configuration = XmppSessionConfiguration.builder() - .extensions(Extension.of(com.juick.Message.class)) - .debugger(LogbackDebugger.class) - .build(); - ExternalComponent routerClient = ExternalComponent.create("test.localhost", - "secret", configuration, "localhost", 5347); - CountDownLatch lock = new CountDownLatch(1); - routerClient.addConnectionListener(connectionEvent -> { - if (connectionEvent.equals(ConnectionEvent.Type.RECONNECTION_SUCCEEDED)) { - lock.countDown(); - } - }); - ExternalComponent routerClient2 = ExternalComponent.create("bot.localhost", - "secret", configuration, "localhost", 5347); - CountDownLatch lock2 = new CountDownLatch(1); - routerClient2.addConnectionListener(connectionEvent -> { - if (connectionEvent.equals(ConnectionEvent.Type.RECONNECTION_SUCCEEDED)) { - lock2.countDown(); - } - }); - executorService.submit(() -> { - try { - Thread.sleep(3000); - routerClient.connect(); - routerClient2.connect(); - } catch (XmppException | InterruptedException e) { - e.printStackTrace(); - } - lock.countDown(); - lock2.countDown(); - }); - lock.await(); - CountDownLatch lock3 = new CountDownLatch(2); - routerClient2.sendMessage(new Message(Jid.of("yoyo@test.localhost"), Message.Type.CHAT, "test" )); - routerClient2.sendMessage(new Message(Jid.of("yoyo@test.localhost"), Message.Type.CHAT, "test" )); - routerClient.addInboundMessageListener(messageEvent -> { - assertThat(messageEvent.getMessage().getBody(), equalTo("test")); - lock3.countDown(); - }); - lock3.await(); - } -} |