package Tasks;

import duplicatefinder.DFile;
import duplicatefinder.FileList;
import java.io.File;
import java.util.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class DirectoryCrawler implements Runnable {
    private File node;
    private static BlockingQueue jobList; // folders
    private FileList fileList;
    private int noThreads;

    public DirectoryCrawler(String directory, int threads) {
        node = new File(directory);
        jobList = new LinkedBlockingQueue();
        noThreads = threads;
        fileList = new FileList();


    }

    @Override
    public void run() {
        for (int i = 0; i < noThreads; i++) {

        }
        traverse(node);
    }

    public void traverse(File node) {
        if (node.isDirectory()) {
            jobList.add(node);
            /*
            String[] subfolder = node.list();
            for (String filename : subfolder) {
                traverse(new File(node, filename));
            }*/
        } else {
            fileList.addFile(new DFile(node.getAbsolutePath()));
        }
    }
}