From 3fbee39579b4b2232fc98d50f6b16ec4f9f33022 Mon Sep 17 00:00:00 2001
From: Daniel Gultsch <daniel@gultsch.de>
Date: Sat, 23 Jul 2016 16:12:45 +0200
Subject: refactored deleted file detection to monitor entire sd card. fixes
 #1968

---
 .../utils/ConversationsFileObserver.java           | 72 ++++++++++++++++++++++
 1 file changed, 72 insertions(+)
 create mode 100644 src/main/java/eu/siacs/conversations/utils/ConversationsFileObserver.java

(limited to 'src/main/java/eu/siacs/conversations/utils/ConversationsFileObserver.java')

diff --git a/src/main/java/eu/siacs/conversations/utils/ConversationsFileObserver.java b/src/main/java/eu/siacs/conversations/utils/ConversationsFileObserver.java
new file mode 100644
index 000000000..e6993bfe5
--- /dev/null
+++ b/src/main/java/eu/siacs/conversations/utils/ConversationsFileObserver.java
@@ -0,0 +1,72 @@
+package eu.siacs.conversations.utils;
+
+
+import android.os.FileObserver;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Stack;
+
+/**
+ * Copyright (C) 2012 Bartek Przybylski
+ * Copyright (C) 2015 ownCloud Inc.
+ * Copyright (C) 2016 Daniel Gultsch
+ */
+
+public abstract class ConversationsFileObserver {
+
+    private final String path;
+    private final List<SingleFileObserver> mObservers = new ArrayList<>();
+
+    public ConversationsFileObserver(String path) {
+        this.path = path;
+    }
+
+    public synchronized void startWatching() {
+        Stack<String> stack = new Stack<>();
+        stack.push(path);
+
+        while (!stack.empty()) {
+            String parent = stack.pop();
+            mObservers.add(new SingleFileObserver(parent, FileObserver.DELETE));
+            final File path = new File(parent);
+            final File[] files = path.listFiles();
+            if (files == null) {
+                continue;
+            }
+            for(File file : files) {
+                if (file.isDirectory() && !file.getName().equals(".") && !file.getName().equals("..")) {
+                    stack.push(file.getPath());
+                }
+            }
+        }
+        for(FileObserver observer : mObservers) {
+            observer.startWatching();
+        }
+    }
+
+    public synchronized void stopWatching() {
+        for(FileObserver observer : mObservers) {
+            observer.stopWatching();
+        }
+        mObservers.clear();
+    }
+
+    abstract public void onEvent(int event, String path);
+
+    private class SingleFileObserver extends FileObserver {
+        private final String path;
+
+        public SingleFileObserver(String path, int mask) {
+            super(path, mask);
+            this.path = path;
+        }
+
+        @Override
+        public void onEvent(int event, String filename) {
+            ConversationsFileObserver.this.onEvent(event, path+'/'+filename);
+        }
+
+    }
+}
-- 
cgit v1.2.3