package com.pubnub.api;

import org.junit.Before;

import org.junit.Test;

import java.util.UUID;

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.TimeUnit;

import static org.junit.Assert.assertEquals;

public class PresenceTest {

Pubnub pubnub = new Pubnub("demo", "demo");

Pubnub pubnub2 = new Pubnub("demo", "demo");

String random;

@Before

public void setUp() throws PubnubException {

pubnub.setCacheBusting(false);

pubnub2.setCacheBusting(false);

random = UUID.randomUUID().toString().substring(0, 8);

}

@Test

public void testPresenceOnCurrentClient() throws InterruptedException, PubnubException {

String channel = "java-unittest-" + Math.random();

CountDownLatch latch = new CountDownLatch(1);

TestHelper.PresenceCallback presenceCb = new TestHelper.PresenceCallback(latch);

pubnub.presence(channel, presenceCb);

pubnub.subscribe(channel, new Callback() {

});

latch.await(10, TimeUnit.SECONDS);

assertEquals(pubnub.getUUID(), presenceCb.getUUID());

}

@Test

public void testPresenceOnOtherClient() throws InterruptedException, PubnubException {

String channel = "java-unittest-" + Math.random();

CountDownLatch latch = new CountDownLatch(1);

TestHelper.PresenceCallback presenceCb = new TestHelper.PresenceCallback(latch);

pubnub.presence(channel, presenceCb);

pubnub2.subscribe(channel, new Callback() {

});

latch.await(10, TimeUnit.SECONDS);

assertEquals(pubnub2.getUUID(), presenceCb.getUUID());

}

}