<gh_stars>100-1000
#  Copyright 2008-2015 Nokia Networks
#  Copyright 2016-     Robot Framework Foundation
#
#  Licensed under the Apache License, Version 2.0 (the "License");
#  you may not use this file except in compliance with the License.
#  You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

import os

import wx


class _RideFSWatcherHandler:

    def __init__(self):
        self._fs_watcher = None
        self._is_workspace_dirty = False
        self._initial_watched_path = None
        self._watched_path = set()

    def create_fs_watcher(self, path):
        if self._fs_watcher:
            return
        self._initial_watched_path = path
        self._fs_watcher = wx.FileSystemWatcher()
        self._fs_watcher.Bind(wx.EVT_FSWATCHER, self._on_fs_event)
        # print(f"DEBUG: FileSystemWatcher create_fs_watcher CREATED")

    def start_listening(self, path):
        self.stop_listening()
        if os.path.isdir(path):
            # only watch folders
            # MSW do not support watch single file
            path = os.path.join(path, '')
            result = self._fs_watcher.AddTree(path)  #, filter="*.r*o*")
            # print(f"DEBUG: FileSystemWatcher start_listening DIR result is ={result}")
            # Add all files to the monitoring list
            from wx import FileSystem
            fs = FileSystem()
            fs.ChangePathTo(path, True)
            file_search = fs.FindFirst("*")
            while file_search:
                if self._is_valid_file_format(file_search):
                    # print(f"DEBUG: FileSystemWatcher start_listening file_search={file_search}")
                    self._watched_path.add(fs.URLToFileName(file_search))
                file_search = fs.FindNext()
            self._watched_path.add(path)
        else:
            self._watched_path.add(path)  # Here we add the file path
            path = os.path.join(os.path.dirname(path), '')
            result = self._fs_watcher.Add(path)  # Here we only add the file parent directory
            # print(f"DEBUG: FileSystemWatcher start_listening FILE result is ={result}")
        # print(f"DEBUG: FileSystemWatcher start_listening self._watched_path={self._watched_path}")


    def stop_listening(self):
        # print(f"DEBUG: FileSystemWatcher stop_listening")
        self._is_workspace_dirty = False
        self._fs_watcher.RemoveAll()
        self._watched_path = set()

    def is_workspace_dirty(self):
        # print(f"DEBUG: is_workspace_dirty self._watched_path = {self._watched_path}")
        if self._watched_path:
            return self._is_workspace_dirty
        else:
            return False

    def is_watcher_created(self):
        return self._fs_watcher is not None

    def get_workspace_new_path(self):
        return self._initial_watched_path  # self._watched_path.pop()  # Returning file or directory name

    def _on_fs_event(self, event):
        if self._is_mark_dirty_needed(event):
            self._is_workspace_dirty = True

    def _is_mark_dirty_needed(self, event):
        new_path = event.GetNewPath()
        previous_path = event.GetPath()
        change_type = event.GetChangeType()

        if change_type == wx.FSW_EVENT_MODIFY: # DEBUG  or change_type == wx.FSW_EVENT_ACCESS
            """
            paths = list()
            count = self._fs_watcher.GetWatchedPaths(paths)  # DEBUG This is always empty
            print(f"DEBUG: FSW_EVENT_MODIFY count={count} paths={paths}")
            for file in paths:
                # print(f"DEBUG: FileSystemWatcher count files {count} event wx.FSW_EVENT_MODIFY file = {file}")
                if file == previous_path:
                    return True
            """
            if previous_path in self._watched_path:
                return True
            return False

        if change_type == wx.FSW_EVENT_CREATE:
            if os.path.isdir(previous_path):
                return True
            elif os.path.isfile(previous_path):
                return self._is_valid_file_format(previous_path)
        elif change_type == wx.FSW_EVENT_DELETE:
            if previous_path in self._watched_path:
                # workspace root folder / suite file is deleted
                self._watched_path.remove(previous_path)
                return True
            if previous_path.endswith(os.sep):
                return True
            else:
                return self._is_valid_file_format(previous_path)
        elif change_type == wx.FSW_EVENT_RENAME:
            if previous_path in self._watched_path:
                # workspace root folder / suite file is renamed
                self._watched_path.remove(previous_path)
                self._watched_path.add(new_path)
                return True
            if os.path.isdir(new_path):
                return True
            elif os.path.isfile(new_path):
                return self._is_valid_file_format(new_path)
        else:
            return False

    @staticmethod
    def _is_valid_file_format(file_path):
        # only watch files with certain extensions
        suffixes = ('.robot', '.txt', '.resource', '.tsv')
        return os.path.splitext(file_path)[-1].lower() in suffixes


RideFSWatcherHandler = _RideFSWatcherHandler()

#  Copyright 2008-2015 Nokia Networks
#  Copyright 2016-     Robot Framework Foundation
#
#  Licensed under the Apache License, Version 2.0 (the "License");
#  you may not use this file except in compliance with the License.
#  You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
#  Unless required by applicable law or agreed to in writing, software
#  distributed under the License is distributed on an "AS IS" BASIS,
#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#  See the License for the specific language governing permissions and
#  limitations under the License.

import os

import wx


class _RideFSWatcherHandler:

    def __init__(self):
        self._fs_watcher = None
        self._is_workspace_dirty = False
        self._initial_watched_path = None
        self._watched_path = set()

    def create_fs_watcher(self, path):
        if self._fs_watcher:
            return
        self._initial_watched_path = path
        self._fs_watcher = wx.FileSystemWatcher()
        self._fs_watcher.Bind(wx.EVT_FSWATCHER, self._on_fs_event)
        # print(f"DEBUG: FileSystemWatcher create_fs_watcher CREATED")

    def start_listening(self, path):
        self.stop_listening()
        if os.path.isdir(path):
            # only watch folders
            # MSW do not support watch single file
            path = os.path.join(path, '')
            result = self._fs_watcher.AddTree(path)  #, filter="*.r*o*")
            # print(f"DEBUG: FileSystemWatcher start_listening DIR result is ={result}")
            # Add all files to the monitoring list
            from wx import FileSystem
            fs = FileSystem()
            fs.ChangePathTo(path, True)
            file_search = fs.FindFirst("*")
            while file_search:
                if self._is_valid_file_format(file_search):
                    # print(f"DEBUG: FileSystemWatcher start_listening file_search={file_search}")
                    self._watched_path.add(fs.URLToFileName(file_search))
                file_search = fs.FindNext()
            self._watched_path.add(path)
        else:
            self._watched_path.add(path)  # Here we add the file path
            path = os.path.join(os.path.dirname(path), '')
            result = self._fs_watcher.Add(path)  # Here we only add the file parent directory
            # print(f"DEBUG: FileSystemWatcher start_listening FILE result is ={result}")
        # print(f"DEBUG: FileSystemWatcher start_listening self._watched_path={self._watched_path}")


    def stop_listening(self):
        # print(f"DEBUG: FileSystemWatcher stop_listening")
        self._is_workspace_dirty = False
        self._fs_watcher.RemoveAll()
        self._watched_path = set()

    def is_workspace_dirty(self):
        # print(f"DEBUG: is_workspace_dirty self._watched_path = {self._watched_path}")
        if self._watched_path:
            return self._is_workspace_dirty
        else:
            return False

    def is_watcher_created(self):
        return self._fs_watcher is not None

    def get_workspace_new_path(self):
        return self._initial_watched_path  # self._watched_path.pop()  # Returning file or directory name

    def _on_fs_event(self, event):
        if self._is_mark_dirty_needed(event):
            self._is_workspace_dirty = True

    def _is_mark_dirty_needed(self, event):
        new_path = event.GetNewPath()
        previous_path = event.GetPath()
        change_type = event.GetChangeType()

        if change_type == wx.FSW_EVENT_MODIFY: # DEBUG  or change_type == wx.FSW_EVENT_ACCESS
            """
            paths = list()
            count = self._fs_watcher.GetWatchedPaths(paths)  # DEBUG This is always empty
            print(f"DEBUG: FSW_EVENT_MODIFY count={count} paths={paths}")
            for file in paths:
                # print(f"DEBUG: FileSystemWatcher count files {count} event wx.FSW_EVENT_MODIFY file = {file}")
                if file == previous_path:
                    return True
            """
            if previous_path in self._watched_path:
                return True
            return False

        if change_type == wx.FSW_EVENT_CREATE:
            if os.path.isdir(previous_path):
                return True
            elif os.path.isfile(previous_path):
                return self._is_valid_file_format(previous_path)
        elif change_type == wx.FSW_EVENT_DELETE:
            if previous_path in self._watched_path:
                # workspace root folder / suite file is deleted
                self._watched_path.remove(previous_path)
                return True
            if previous_path.endswith(os.sep):
                return True
            else:
                return self._is_valid_file_format(previous_path)
        elif change_type == wx.FSW_EVENT_RENAME:
            if previous_path in self._watched_path:
                # workspace root folder / suite file is renamed
                self._watched_path.remove(previous_path)
                self._watched_path.add(new_path)
                return True
            if os.path.isdir(new_path):
                return True
            elif os.path.isfile(new_path):
                return self._is_valid_file_format(new_path)
        else:
            return False

    @staticmethod
    def _is_valid_file_format(file_path):
        # only watch files with certain extensions
        suffixes = ('.robot', '.txt', '.resource', '.tsv')
        return os.path.splitext(file_path)[-1].lower() in suffixes


RideFSWatcherHandler = _RideFSWatcherHandler()
#  Copyright 2008-2015 Nokia Networks #  Copyright 2016-     Robot Framework Foundation # #  Licensed under the Apache License, Version 2.0 (the "License"); #  you may not use this file except in compliance with the License. #  You may obtain a copy of the License at # #      http://www.apache.org/licenses/LICENSE-2.0 # #  Unless required by applicable law or agreed to in writing, software #  distributed under the License is distributed on an "AS IS" BASIS, #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. #  See the License for the specific language governing permissions and #  limitations under the License. # print(f"DEBUG: FileSystemWatcher create_fs_watcher CREATED") # only watch folders # MSW do not support watch single file #, filter="*.r*o*") # print(f"DEBUG: FileSystemWatcher start_listening DIR result is ={result}") # Add all files to the monitoring list # print(f"DEBUG: FileSystemWatcher start_listening file_search={file_search}") # Here we add the file path # Here we only add the file parent directory # print(f"DEBUG: FileSystemWatcher start_listening FILE result is ={result}") # print(f"DEBUG: FileSystemWatcher start_listening self._watched_path={self._watched_path}") # print(f"DEBUG: FileSystemWatcher stop_listening") # print(f"DEBUG: is_workspace_dirty self._watched_path = {self._watched_path}") # self._watched_path.pop()  # Returning file or directory name # DEBUG  or change_type == wx.FSW_EVENT_ACCESS paths = list()             count = self._fs_watcher.GetWatchedPaths(paths)  # DEBUG This is always empty             print(f"DEBUG: FSW_EVENT_MODIFY count={count} paths={paths}")             for file in paths:                 # print(f"DEBUG: FileSystemWatcher count files {count} event wx.FSW_EVENT_MODIFY file = {file}")                 if file == previous_path:                     return True # workspace root folder / suite file is deleted # workspace root folder / suite file is renamed # only watch files with certain extensions