package lab.synchronizator;

import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

public class Synchronizator {

	private AtomicBoolean monitor;

	public Synchronizator() {
		monitor = new AtomicBoolean(true);
		start();
	}

	private void start() {
		Runnable task = () -> {
			while(monitor.get()) {
				synchronizuj();

				try {
					TimeUnit.SECONDS.sleep(1);
				} catch (InterruptedException e) {
					System.out.println("Oczekiwanie przerwane!");
				}
			}
		};
		Thread worker = new Thread(task);
		worker.start();
	}

	public void stop() {
		monitor.set(false);
	}

	private void synchronizuj() {
		try {
			Path pathA = Paths.get("A/");
			Path pathB = Paths.get("B/");

			boolean existsA = Files.exists(pathA);

			boolean isDirectoryA = Files.isDirectory(pathA);

			File dirA = pathA.toFile();
			File dirB = pathB.toFile();

			String[] listA = dirA.list();
			String[] listB = dirB.list();

			//wyszukiwanie plików do skopiowania lub usunięcia

			String fileToCopy = listA[0];
			Path src = Paths.get(pathA.toString(), fileToCopy);
			Path dst = Paths.get(pathB.toString(), fileToCopy);
			if(!Files.isDirectory(src)) {
				Files.copy(src, dst);
				System.out.println("Skopiowano plik" + fileToCopy);
			} else {
				Files.createDirectory(dst);
			}

			String fileToDelete = listA[0];
			Path file = Paths.get(pathB.toString(), fileToDelete);
			Files.delete(file);
			System.out.println("Usunięto plik" + fileToDelete);

		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}