import time
import threading
import subprocess
from settings import settings
import logging
import collections
import util
from state import State

# Watchdog lib: https://github.com/gorakhargosh/watchdog
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler

WATCHED = {}
LOG = logging.getLogger("backend")

class Sync:
    def __init__(self, directory, targets, ripe_age, active_wait):
        self.backend_log = logging.getLogger("backend")
        self.backend_log.info("Creating Sync")
        self.directory = directory
        self.backend_log.info("Creating Sync - done")

    def start(self):
        self.backend_log.info("Starting Sync")
        self.should_stop = False
        self.stopped = False

        LOG.info("Started sync for {}".format(self.directory))

        event_handler = Handler()
        self.observer = Observer()
        self.observer.schedule(event_handler, self.directory, recursive=False)
        self.observer.start()
        self.backend_log.info("Starting Sync - done")

class Handler(FileSystemEventHandler):

    @staticmethod
    def on_any_event(event):
        print event
        print event.is_directory

        if event.is_directory:
            return None

        print event.event_type
        print event.event_type == 'created'
        print event.event_type == 'modified'
        print event.src_path not in WATCHED

        if event.event_type == 'created' or event.event_type == 'modified':
            if not event.src_path in WATCHED:
                print "Sync watching {}".format(event.src_path)




sync = Sync('/home/isb/runs/', [], 0, 0)
sync.start()

while True:
    time.sleep(1000);