package pl.mperor.lab.java;

import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import pl.mperor.lab.java.jndi.CustomInitialContextFactory;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sound.sampled.*;
import java.io.File;
import java.io.IOException;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * Java 1.3 (May 2000)
 */
public class Java3 {

    @Test
    public void testJavaNamingAndDirectoryInterfaceAkaJNDILookup() throws NamingException {
        System.setProperty(InitialContext.INITIAL_CONTEXT_FACTORY, CustomInitialContextFactory.class.getName());
        String bindingName = "hello";
        String bindingResult = "Hello World!";

        Context ctx = new InitialContext();
        ctx.bind(bindingName, bindingResult);
        String lookupResult = (String) ctx.lookup(bindingName);
        Assertions.assertEquals(bindingResult, lookupResult);

        ctx.unbind(bindingName);
        Assertions.assertThrows(NamingException.class, () -> {
            ctx.lookup(bindingName);
        });
    }

    @Test
    public void testJavaSoundAPI() throws UnsupportedAudioFileException, IOException, LineUnavailableException, InterruptedException {
        if (AudioSystem.getMixerInfo().length == 0) {
            return;
        }

        try (AudioInputStream audioInputStream = AudioSystem.getAudioInputStream(new File("src/test/resources/beep.wav"))) {
            Clip clip = AudioSystem.getClip();
            clip.open(audioInputStream);
            CountDownLatch latch = new CountDownLatch(1);
            clip.addLineListener(event -> {
                if (event.getType() == LineEvent.Type.STOP) {
                    clip.close();
                    latch.countDown();
                }
            });
            clip.start();
            latch.await();
        }
    }

    @Test
    public void testScheduledTask() throws InterruptedException {
        var schedulerCounter = new AtomicInteger(0);
        var latch = new CountDownLatch(2);

        var scheduler = new TimerTask() {
            @Override
            public void run() {
                schedulerCounter.getAndIncrement();
                latch.countDown();
            }
        };
        var timer = new Timer();
        timer.scheduleAtFixedRate(scheduler, 0, 100);

        boolean completed = latch.await(300, TimeUnit.MILLISECONDS);
        Assertions.assertTrue(completed, "Scheduler did not run twice in time");
        Assertions.assertEquals(2, schedulerCounter.get());
        timer.cancel();
    }
}