Release 0.5.0

cli/src/main/groovy/com/muwire/cli/Cli.groovy

@@ -35,7 +35,7 @@ class Cli {
 
         Core core
         try {
-            core = new Core(props, home, "0.4.16")
+            core = new Core(props, home, "0.5.0")
         } catch (Exception bad) {
             bad.printStackTrace(System.out)
             println "Failed to initialize core, exiting"

cli/src/main/groovy/com/muwire/cli/CliDownloader.groovy

@@ -53,7 +53,7 @@ class CliDownloader {
 
         Core core
         try {
-            core = new Core(props, home, "0.4.16")
+            core = new Core(props, home, "0.5.0")
         } catch (Exception bad) {
             bad.printStackTrace(System.out)
             println "Failed to initialize core, exiting"

core/src/main/groovy/com/muwire/core/Core.groovy

@@ -28,6 +28,7 @@ import com.muwire.core.files.FileSharedEvent
 import com.muwire.core.files.FileUnsharedEvent
 import com.muwire.core.files.HasherService
 import com.muwire.core.files.PersisterService
+import com.muwire.core.files.UIPersistFilesEvent
 import com.muwire.core.files.AllFilesLoadedEvent
 import com.muwire.core.files.DirectoryUnsharedEvent
 import com.muwire.core.files.DirectoryWatcher
@@ -223,6 +224,7 @@ public class Core {
         log.info "initializing persistence service"
         persisterService = new PersisterService(new File(home, "files.json"), eventBus, 60000, fileManager)
         eventBus.register(UILoadedEvent.class, persisterService)
+        eventBus.register(UIPersistFilesEvent.class, persisterService)
 
         log.info("initializing host cache")
         File hostStorage = new File(home, "hosts.json")
@@ -280,7 +282,7 @@ public class Core {
             i2pAcceptor, hostCache, trustService, searchManager, uploadManager, connectionEstablisher)
 
         log.info("initializing directory watcher")
-        directoryWatcher = new DirectoryWatcher(eventBus, fileManager)
+        directoryWatcher = new DirectoryWatcher(eventBus, fileManager, home, props)
         eventBus.register(FileSharedEvent.class, directoryWatcher)
         eventBus.register(AllFilesLoadedEvent.class, directoryWatcher)
         eventBus.register(DirectoryUnsharedEvent.class, directoryWatcher)
@@ -288,6 +290,8 @@ public class Core {
         log.info("initializing hasher service")
         hasherService = new HasherService(new FileHasher(), eventBus, fileManager)
         eventBus.register(FileSharedEvent.class, hasherService)
+        eventBus.register(FileUnsharedEvent.class, hasherService)
+        eventBus.register(DirectoryUnsharedEvent.class, hasherService)
 
         log.info("initializing trust subscriber")
         trustSubscriber = new TrustSubscriber(eventBus, i2pConnector, props)
@@ -362,7 +366,7 @@ public class Core {
             }
         }
 
-        Core core = new Core(props, home, "0.4.16")
+        Core core = new Core(props, home, "0.5.0")
         core.startServices()
 
         // ... at the end, sleep or execute script

core/src/main/groovy/com/muwire/core/MuWireSettings.groovy

@@ -6,6 +6,7 @@ import com.muwire.core.hostcache.CrawlerResponse
 import com.muwire.core.util.DataUtil
 
 import net.i2p.data.Base64
+import net.i2p.util.ConcurrentHashSet
 
 class MuWireSettings {
 
@@ -113,7 +114,7 @@ class MuWireSettings {
     }
     
     private static Set<String> readEncodedSet(Properties props, String property) {
-        Set<String> rv = new HashSet<>()
+        Set<String> rv = new ConcurrentHashSet<>()
         if (props.containsKey(property)) {
             String[] encoded = props.getProperty(property).split(",")
             encoded.each { rv << DataUtil.readi18nString(Base64.decode(it)) }

core/src/main/groovy/com/muwire/core/files/DirectoryWatcher.groovy

@@ -13,6 +13,7 @@ import java.nio.file.WatchService
 import java.util.concurrent.ConcurrentHashMap
 
 import com.muwire.core.EventBus
+import com.muwire.core.MuWireSettings
 import com.muwire.core.SharedFile
 
 import groovy.util.logging.Log
@@ -31,6 +32,8 @@ class DirectoryWatcher {
             kinds = [ENTRY_CREATE, ENTRY_MODIFY, ENTRY_DELETE]
     }
 
+    private final File home
+    private final MuWireSettings muOptions
     private final EventBus eventBus
     private final FileManager fileManager
     private final Thread watcherThread, publisherThread
@@ -39,7 +42,9 @@ class DirectoryWatcher {
     private WatchService watchService
     private volatile boolean shutdown
 
-    DirectoryWatcher(EventBus eventBus, FileManager fileManager) {
+    DirectoryWatcher(EventBus eventBus, FileManager fileManager, File home, MuWireSettings muOptions) {
+        this.home = home
+        this.muOptions = muOptions
         this.eventBus = eventBus
         this.fileManager = fileManager
         this.watcherThread = new Thread({watch() } as Runnable, "directory-watcher")
@@ -64,15 +69,28 @@ class DirectoryWatcher {
     void onFileSharedEvent(FileSharedEvent e) {
         if (!e.file.isDirectory())
             return
-        Path path = e.file.getCanonicalFile().toPath()
+        File canonical = e.file.getCanonicalFile()
+        Path path = canonical.toPath()
         WatchKey wk = path.register(watchService, kinds)
-        watchedDirectories.put(e.file, wk)
-
+        watchedDirectories.put(canonical, wk)
+        
+        if (muOptions.watchedDirectories.add(canonical.toString()))
+            saveMuSettings()
     }
 
     void onDirectoryUnsharedEvent(DirectoryUnsharedEvent e) {
         WatchKey wk = watchedDirectories.remove(e.directory)
         wk?.cancel()
+        
+        if (muOptions.watchedDirectories.remove(e.directory.toString()))
+            saveMuSettings()
+    }
+    
+    private void saveMuSettings() {
+        File muSettingsFile = new File(home, "MuWire.properties")
+        muSettingsFile.withOutputStream {
+            muOptions.write(it)
+        }
     }
 
     private void watch() {

core/src/main/groovy/com/muwire/core/files/HasherService.groovy

@@ -11,6 +11,7 @@ class HasherService {
     final FileHasher hasher
     final EventBus eventBus
     final FileManager fileManager
+    final Set<File> hashed = new HashSet<>()
     Executor executor
 
     HasherService(FileHasher hasher, EventBus eventBus, FileManager fileManager) {
@@ -24,13 +25,22 @@ class HasherService {
     }
 
     void onFileSharedEvent(FileSharedEvent evt) {
-        if (fileManager.fileToSharedFile.containsKey(evt.file.getCanonicalFile()))
+        File canonical = evt.file.getCanonicalFile()
+        if (fileManager.fileToSharedFile.containsKey(canonical)) 
             return
-        executor.execute( { -> process(evt.file) } as Runnable)
+        if (hashed.add(canonical))
+            executor.execute( { -> process(canonical) } as Runnable)
+    }
+    
+    void onFileUnsharedEvent(FileUnsharedEvent evt) {
+        hashed.remove(evt.unsharedFile.file)
+    }
+    
+    void onDirectoryUnsharedEvent(DirectoryUnsharedEvent evt) {
+        hashed.remove(evt.directory)
     }
 
     private void process(File f) {
-        f = f.getCanonicalFile()
         if (f.isDirectory()) {
             f.listFiles().each {eventBus.publish new FileSharedEvent(file: it) }
         } else {

core/src/main/groovy/com/muwire/core/files/PersisterService.groovy

@@ -3,6 +3,9 @@ package com.muwire.core.files
 import java.nio.file.CopyOption
 import java.nio.file.Files
 import java.nio.file.StandardCopyOption
+import java.util.concurrent.ExecutorService
+import java.util.concurrent.Executors
+import java.util.concurrent.ThreadFactory
 import java.util.logging.Level
 import java.util.stream.Collectors
 
@@ -28,13 +31,16 @@ class PersisterService extends Service {
     final int interval
     final Timer timer
     final FileManager fileManager
+    final ExecutorService persisterExecutor = Executors.newSingleThreadExecutor({ r -> 
+        new Thread(r, "file persister")
+    } as ThreadFactory)
 
     PersisterService(File location, EventBus listener, int interval, FileManager fileManager) {
         this.location = location
         this.listener = listener
         this.interval = interval
         this.fileManager = fileManager
-        timer = new Timer("file persister", true)
+        timer = new Timer("file persister timer", true)
     }
 
     void stop() {
@@ -44,6 +50,10 @@ class PersisterService extends Service {
     void onUILoadedEvent(UILoadedEvent e) {
         timer.schedule({load()} as TimerTask, 1)
     }
+    
+    void onUIPersistFilesEvent(UIPersistFilesEvent e) {
+        persistFiles()
+    }
 
     void load() {
         Thread.currentThread().setPriority(Thread.MIN_PRIORITY)
@@ -127,19 +137,21 @@ class PersisterService extends Service {
     }
 
     private void persistFiles() {
-        def sharedFiles = fileManager.getSharedFiles()
+        persisterExecutor.submit( {
+            def sharedFiles = fileManager.getSharedFiles()
 
-        File tmp = File.createTempFile("muwire-files", "tmp")
-        tmp.deleteOnExit()
-        tmp.withPrintWriter { writer ->
-            sharedFiles.each { k, v ->
-                def json = toJson(k,v)
-                json = JsonOutput.toJson(json)
-                writer.println json
+            File tmp = File.createTempFile("muwire-files", "tmp")
+            tmp.deleteOnExit()
+            tmp.withPrintWriter { writer ->
+                sharedFiles.each { k, v ->
+                    def json = toJson(k,v)
+                    json = JsonOutput.toJson(json)
+                    writer.println json
+                }
             }
-        }
-        Files.copy(tmp.toPath(), location.toPath(), StandardCopyOption.REPLACE_EXISTING)
-        tmp.delete()
+            Files.copy(tmp.toPath(), location.toPath(), StandardCopyOption.REPLACE_EXISTING)
+            tmp.delete()
+        } as Runnable)
     }
 
     private def toJson(File f, SharedFile sf) {

core/src/main/groovy/com/muwire/core/files/UIPersistFilesEvent.groovy

@@ -0,0 +1,6 @@
+package com.muwire.core.files
+
+import com.muwire.core.Event
+
+class UIPersistFilesEvent extends Event {
+}

core/src/main/groovy/com/muwire/core/search/ResultsSender.groovy

@@ -4,6 +4,7 @@ import com.muwire.core.SharedFile
 import com.muwire.core.connection.Endpoint
 import com.muwire.core.connection.I2PConnector
 import com.muwire.core.files.FileHasher
+import com.muwire.core.util.DataUtil
 import com.muwire.core.Persona
 
 import java.nio.charset.StandardCharsets
@@ -60,13 +61,18 @@ class ResultsSender {
                 Set<Destination> suggested = Collections.emptySet()
                 if (it instanceof DownloadedFile)
                     suggested = it.sources
+                def comment = null
+                if (it.getComment() != null) {
+                    comment = DataUtil.readi18nString(Base64.decode(it.getComment()))
+                }
                 def uiResultEvent = new UIResultEvent( sender : me,
                     name : it.getFile().getName(),
                     size : length,
                     infohash : it.getInfoHash(),
                     pieceSize : pieceSize,
                     uuid : uuid,
-                    sources : suggested
+                    sources : suggested,
+                    comment : comment
                     )
                     eventBus.publish(uiResultEvent)
             }

gradle.properties

@@ -1,5 +1,5 @@
 group         = com.muwire
-version       = 0.4.16
+version       = 0.5.0
 groovyVersion = 2.4.15
 slf4jVersion  = 1.7.25
 spockVersion  = 1.1-groovy-2.4

gui/griffon-app/controllers/com/muwire/gui/AddCommentController.groovy

@@ -27,7 +27,7 @@ class AddCommentController {
         model.selectedFiles.each {
             it.setComment(comment)
         }
-        mvcGroup.parentGroup.view.builder.getVariable("shared-files-table").model.fireTableDataChanged()
+        mvcGroup.parentGroup.view.refreshSharedFiles()
         cancel()
     }
     

gui/griffon-app/controllers/com/muwire/gui/MainFrameController.groovy

@@ -25,6 +25,7 @@ import com.muwire.core.download.UIDownloadPausedEvent
 import com.muwire.core.download.UIDownloadResumedEvent
 import com.muwire.core.files.DirectoryUnsharedEvent
 import com.muwire.core.files.FileUnsharedEvent
+import com.muwire.core.files.UIPersistFilesEvent
 import com.muwire.core.search.QueryEvent
 import com.muwire.core.search.SearchEvent
 import com.muwire.core.trust.RemoteTrustList
@@ -276,6 +277,7 @@ class MainFrameController {
         sf.each {  
             core.eventBus.publish(new FileUnsharedEvent(unsharedFile : it))
         }
+        core.eventBus.publish(new UIPersistFilesEvent())
     }
     
     @ControllerAction
@@ -289,18 +291,6 @@ class MainFrameController {
         mvcGroup.createMVCGroup("add-comment", "Add Comment", params)
     }
 
-    void stopWatchingDirectory() {
-        String directory = mvcGroup.view.getSelectedWatchedDirectory()
-        if (directory == null)
-            return
-        core.muOptions.watchedDirectories.remove(directory)
-        saveMuWireSettings()
-        core.eventBus.publish(new DirectoryUnsharedEvent(directory : new File(directory)))
-
-        model.watched.remove(directory)
-        builder.getVariable("watched-directories-table").model.fireTableDataChanged()
-    }
-
     void saveMuWireSettings() {
         File f = new File(core.home, "MuWire.properties")
         f.withOutputStream {

gui/griffon-app/controllers/com/muwire/gui/OptionsController.groovy

@@ -143,7 +143,7 @@ class OptionsController {
 //        boolean showSearchHashes = view.showSearchHashesCheckbox.model.isSelected()
 //        model.showSearchHashes = showSearchHashes
 //        uiSettings.showSearchHashes = showSearchHashes
-
+        
         File uiSettingsFile = new File(core.home, "gui.properties")
         uiSettingsFile.withOutputStream {
             uiSettings.write(it)
@@ -167,5 +167,5 @@ class OptionsController {
         int rv = chooser.showOpenDialog(null)
         if (rv == JFileChooser.APPROVE_OPTION)
             model.downloadLocation = chooser.getSelectedFile().getAbsolutePath()
-    }
+    }    
 }

gui/griffon-app/models/com/muwire/gui/MainFrameModel.groovy

@@ -1,6 +1,8 @@
 package com.muwire.gui
 
 import java.util.concurrent.ConcurrentHashMap
+import java.nio.file.Path
+import java.nio.file.Paths
 import java.util.Calendar
 import java.util.UUID
 
@@ -8,12 +10,16 @@ import javax.annotation.Nonnull
 import javax.inject.Inject
 import javax.swing.JOptionPane
 import javax.swing.JTable
+import javax.swing.tree.DefaultMutableTreeNode
+import javax.swing.tree.DefaultTreeModel
+import javax.swing.tree.TreeNode
 
 import com.muwire.core.Core
 import com.muwire.core.InfoHash
 import com.muwire.core.MuWireSettings
 import com.muwire.core.Persona
 import com.muwire.core.RouterDisconnectedEvent
+import com.muwire.core.SharedFile
 import com.muwire.core.connection.ConnectionAttemptStatus
 import com.muwire.core.connection.ConnectionEvent
 import com.muwire.core.connection.DisconnectionEvent
@@ -21,6 +27,7 @@ import com.muwire.core.content.ContentControlEvent
 import com.muwire.core.download.DownloadStartedEvent
 import com.muwire.core.download.Downloader
 import com.muwire.core.files.AllFilesLoadedEvent
+import com.muwire.core.files.DirectoryUnsharedEvent
 import com.muwire.core.files.FileDownloadedEvent
 import com.muwire.core.files.FileHashedEvent
 import com.muwire.core.files.FileHashingEvent
@@ -57,6 +64,8 @@ class MainFrameModel {
     FactoryBuilderSupport builder
     @MVCMember @Nonnull
     MainFrameController controller
+    @MVCMember @Nonnull
+    MainFrameView view
     @Inject @Nonnull GriffonApplication application
     @Observable boolean coreInitialized = false
     @Observable boolean routerPresent
@@ -64,8 +73,11 @@ class MainFrameModel {
     def results = new ConcurrentHashMap<>()
     def downloads = []
     def uploads = []
-    def shared = []
-    def watched = []
+    boolean treeVisible = true
+    def shared 
+    def sharedTree 
+    def treeRoot
+    final Map<SharedFile, TreeNode> fileToNode = new HashMap<>()
     def connectionList = []
     def searches = new LinkedList()
     def trusted = []
@@ -122,6 +134,10 @@ class MainFrameModel {
     void mvcGroupInit(Map<String, Object> args) {
 
         uiSettings = application.context.get("ui-settings")
+        
+        shared = []
+        treeRoot = new DefaultMutableTreeNode()
+        sharedTree = new DefaultTreeModel(treeRoot)
 
         Timer timer = new Timer("download-pumper", true)
         timer.schedule({
@@ -233,9 +249,7 @@ class MainFrameModel {
 
     void onAllFilesLoadedEvent(AllFilesLoadedEvent e) {
         runInsideUIAsync {
-            watched.addAll(core.muOptions.watchedDirectories)
-            builder.getVariable("watched-directories-table").model.fireTableDataChanged()
-            watched.each { core.eventBus.publish(new FileSharedEvent(file : new File(it))) }
+            core.muOptions.watchedDirectories.each { core.eventBus.publish(new FileSharedEvent(file : new File(it))) }
 
             core.muOptions.trustSubscriptions.each {
                 core.eventBus.publish(new TrustSubscriptionEvent(persona : it, subscribe : true))
@@ -303,7 +317,6 @@ class MainFrameModel {
 
     void onFileHashingEvent(FileHashingEvent e) {
         runInsideUIAsync {
-            loadedFiles = shared.size()
             hashingFile = e.hashingFile
         }
     }
@@ -319,6 +332,8 @@ class MainFrameModel {
             loadedFiles = shared.size()
             JTable table = builder.getVariable("shared-files-table")
             table.model.fireTableDataChanged()
+            insertIntoTree(e.sharedFile)
+            loadedFiles = fileToNode.size()
         }
     }
 
@@ -328,6 +343,8 @@ class MainFrameModel {
             loadedFiles = shared.size()
             JTable table = builder.getVariable("shared-files-table")
             table.model.fireTableDataChanged()
+            insertIntoTree(e.loadedFile)
+            loadedFiles = fileToNode.size()
         }
     }
 
@@ -335,8 +352,26 @@ class MainFrameModel {
         runInsideUIAsync {
             shared.remove(e.unsharedFile)
             loadedFiles = shared.size()
-            JTable table = builder.getVariable("shared-files-table")
-            table.model.fireTableDataChanged()
+            
+            def dmtn = fileToNode.remove(e.unsharedFile)
+            if (dmtn != null) {
+                loadedFiles = fileToNode.size()
+                while (true) {
+                    def parent = dmtn.getParent()
+                    parent.remove(dmtn)
+                    if (parent == treeRoot)
+                        break
+                    if (parent.getChildCount() == 0) {
+                        File file = parent.getUserObject().file
+                        if (core.muOptions.watchedDirectories.contains(file.toString()))
+                            core.eventBus.publish(new DirectoryUnsharedEvent(directory : parent.getUserObject().file))
+                        dmtn = parent
+                        continue
+                    }
+                    break
+                }
+            } 
+            view.refreshSharedFiles()
         }
     }
 
@@ -479,8 +514,44 @@ class MainFrameModel {
             shared << e.downloadedFile
             JTable table = builder.getVariable("shared-files-table")
             table.model.fireTableDataChanged()
+            insertIntoTree(e.downloadedFile)
+            loadedFiles = fileToNode.size()
         }
     }
+    
+    private void insertIntoTree(SharedFile file) {
+        List<File> parents = new ArrayList<>()
+        File tmp = file.file.getParentFile()
+        while(tmp.getParent() != null) {
+            parents << tmp
+            tmp = tmp.getParentFile()
+        }
+        Collections.reverse(parents)
+        TreeNode node = treeRoot
+        for(File path : parents) {
+            boolean exists = false
+            def children = node.children()
+            def child = null
+            while(children.hasMoreElements()) {
+                child = children.nextElement()
+                def userObject = child.getUserObject()
+                if (userObject != null && userObject.file == path) {
+                    exists = true
+                    break
+                }
+            }
+            if (!exists) {
+                child = new DefaultMutableTreeNode(new InterimTreeNode(path))
+                node.add(child)
+            }
+            node = child
+        }
+        
+        def dmtn = new DefaultMutableTreeNode(file)
+        fileToNode.put(file, dmtn)
+        node.add(dmtn)
+        view.refreshSharedFiles()
+    }
 
     private static class UIConnection {
         Destination destination

gui/griffon-app/views/com/muwire/gui/MainFrameView.groovy

@@ -16,11 +16,14 @@ import javax.swing.JMenuItem
 import javax.swing.JPopupMenu
 import javax.swing.JSplitPane
 import javax.swing.JTable
+import javax.swing.JTree
 import javax.swing.ListSelectionModel
 import javax.swing.SwingConstants
 import javax.swing.TransferHandler
 import javax.swing.border.Border
 import javax.swing.table.DefaultTableCellRenderer
+import javax.swing.tree.TreeNode
+import javax.swing.tree.TreePath
 
 import com.muwire.core.Constants
 import com.muwire.core.MuWireSettings
@@ -56,11 +59,12 @@ class MainFrameView {
     def downloadsTable
     def lastDownloadSortEvent
     def lastSharedSortEvent
-    def lastWatchedSortEvent
     def trustTablesSortEvents = [:]
 
+    UISettings settings
+    
     void initUI() {
-        UISettings settings = application.context.get("ui-settings")
+        settings = application.context.get("ui-settings")
         builder.with {
             application(size : [1024,768], id: 'main-frame',
             locationRelativeTo : null,
@@ -193,44 +197,46 @@ class MainFrameView {
                                 })
                             }
                             panel (border : etchedBorder(), constraints : BorderLayout.CENTER) {
-                                gridLayout(cols : 2, rows : 1)
-                                panel {
-                                    borderLayout()
-                                    scrollPane (constraints : BorderLayout.CENTER) {
-                                        table(id : "watched-directories-table", autoCreateRowSorter: true) {
-                                            tableModel(list : model.watched) {
-                                                closureColumn(header: "Watched Directories", type : String, read : { it })
+                                borderLayout()
+                                panel (id : "shared-files-panel", constraints : BorderLayout.CENTER){
+                                    cardLayout()
+                                    panel (constraints : "shared files table") {
+                                        borderLayout()
+                                        scrollPane(constraints : BorderLayout.CENTER) {
+                                            table(id : "shared-files-table", autoCreateRowSorter: true) {
+                                                tableModel(list : model.shared) {
+                                                    closureColumn(header : "Name", preferredWidth : 500, type : String, read : {row -> row.getCachedPath()})
+                                                    closureColumn(header : "Size", preferredWidth : 100, type : Long, read : {row -> row.getCachedLength() })
+                                                    closureColumn(header : "Comments", preferredWidth : 100, type : Boolean, read : {it.getComment() != null})
+                                                }
                                             }
                                         }
                                     }
-                                }
-                                panel {
-                                    borderLayout()
-                                    scrollPane(constraints : BorderLayout.CENTER) {
-                                        table(id : "shared-files-table", autoCreateRowSorter: true) {
-                                            tableModel(list : model.shared) {
-                                                closureColumn(header : "Name", preferredWidth : 500, type : String, read : {row -> row.getCachedPath()})
-                                                closureColumn(header : "Size", preferredWidth : 100, type : Long, read : {row -> row.getCachedLength() })
-                                                closureColumn(header : "Comments", preferredWidth : 100, type : Boolean, read : {it.getComment() != null})
-                                            }
+                                    panel (constraints : "shared files tree") {
+                                        borderLayout()
+                                        scrollPane(constraints : BorderLayout.CENTER) {
+                                            def jtree = new JTree(model.sharedTree)
+                                            jtree.setCellRenderer(new SharedTreeRenderer())
+                                            tree(id : "shared-files-tree", rootVisible : false, jtree)
                                         }
                                     }
                                 }
                             }
                             panel (constraints : BorderLayout.SOUTH) {
-                                gridLayout(rows:1, cols:2)
+                                gridLayout(rows:1, cols:3)
                                 panel {
-                                    button(text : "Add directories to watch", actionPerformed : watchDirectories)
-                                    button(text : "Share files", actionPerformed : shareFiles)
+                                    buttonGroup(id : "sharedViewType")
+                                    radioButton(text : "Tree", selected : true, buttonGroup : sharedViewType, actionPerformed : showSharedFilesTree)
+                                    radioButton(text : "Table", selected : false, buttonGroup : sharedViewType, actionPerformed : showSharedFilesTable)
+                                }
+                                panel {
+                                    button(text : "Share files", actionPerformed : shareFiles)
+                                    button(text : "Add Comment", enabled : bind {model.addCommentButtonEnabled}, addCommentAction)
                                 }
                                 panel {
-                                    gridLayout(rows : 1, cols : 2)
                                     panel {
                                         label("Shared:")
-                                        label(text : bind {model.loadedFiles.toString()})
-                                    }
-                                    panel {
-                                        button(text : "Add Comment", enabled : bind {model.addCommentButtonEnabled}, addCommentAction)
+                                        label(text : bind {model.loadedFiles}, id : "shared-files-count")
                                     }
                                 }
                             }
@@ -411,10 +417,7 @@ class MainFrameView {
                     public boolean importData(TransferHandler.TransferSupport support) {
                         def files = support.getTransferable().getTransferData(DataFlavor.javaFileListFlavor)
                         files.each {
-                            if (it.isDirectory())
-                                watchDirectory(it)
-                            else
-                                model.core.eventBus.publish(new FileSharedEvent(file : it))
+                            model.core.eventBus.publish(new FileSharedEvent(file : it))
                         }
                         showUploadsWindow.call()
                         true
@@ -489,13 +492,7 @@ class MainFrameView {
                     }
                 })
 
-        // shared files table
-        def sharedFilesTable = builder.getVariable("shared-files-table")
-        sharedFilesTable.columnModel.getColumn(1).setCellRenderer(new SizeRenderer())
-
-        sharedFilesTable.rowSorter.addRowSorterListener({evt -> lastSharedSortEvent = evt})
-        sharedFilesTable.rowSorter.setSortsOnUpdates(true)
-
+        // shared files menu
         JPopupMenu sharedFilesMenu = new JPopupMenu()
         JMenuItem copyHashToClipboard = new JMenuItem("Copy hash to clipboard")
         copyHashToClipboard.addActionListener({mvcGroup.view.copyHashToClipboard()})
@@ -506,7 +503,8 @@ class MainFrameView {
         JMenuItem commentSelectedFiles = new JMenuItem("Comment selected files")
         commentSelectedFiles.addActionListener({mvcGroup.controller.addComment()})
         sharedFilesMenu.add(commentSelectedFiles)
-        sharedFilesTable.addMouseListener(new MouseAdapter() {
+        
+        def sharedFilesMouseListener = new MouseAdapter() {
                     @Override
                     public void mouseReleased(MouseEvent e) {
                         if (e.isPopupTrigger())
@@ -517,7 +515,16 @@ class MainFrameView {
                         if (e.isPopupTrigger())
                             showPopupMenu(sharedFilesMenu, e)
                     }
-                })
+                }
+
+        // shared files table and tree
+        def sharedFilesTable = builder.getVariable("shared-files-table")
+        sharedFilesTable.columnModel.getColumn(1).setCellRenderer(new SizeRenderer())
+
+        sharedFilesTable.rowSorter.addRowSorterListener({evt -> lastSharedSortEvent = evt})
+        sharedFilesTable.rowSorter.setSortsOnUpdates(true)
+
+        sharedFilesTable.addMouseListener(sharedFilesMouseListener)
 
         selectionModel = sharedFilesTable.getSelectionModel()
         selectionModel.addListSelectionListener({
@@ -526,6 +533,14 @@ class MainFrameView {
                 return
             model.addCommentButtonEnabled = true
         })
+        def sharedFilesTree = builder.getVariable("shared-files-tree")
+        sharedFilesTree.addMouseListener(sharedFilesMouseListener)
+
+        sharedFilesTree.addTreeSelectionListener({
+            def selectedNode = sharedFilesTree.getLastSelectedPathComponent()
+            model.addCommentButtonEnabled = selectedNode != null
+
+        })
 
         // searches table
         def searchesTable = builder.getVariable("searches-table")
@@ -555,27 +570,6 @@ class MainFrameView {
                     }
                 })
 
-        // watched directories table
-        def watchedTable = builder.getVariable("watched-directories-table")
-        watchedTable.rowSorter.addRowSorterListener({evt -> lastWatchedSortEvent = evt})
-        watchedTable.rowSorter.setSortsOnUpdates(true)
-        JPopupMenu watchedMenu = new JPopupMenu()
-        JMenuItem stopWatching = new JMenuItem("Stop sharing")
-        stopWatching.addActionListener({mvcGroup.controller.stopWatchingDirectory()})
-        watchedMenu.add(stopWatching)
-        watchedTable.addMouseListener(new MouseAdapter() {
-                    @Override
-                    public void mouseReleased(MouseEvent e) {
-                        if (e.isPopupTrigger())
-                            showPopupMenu(watchedMenu, e)
-                    }
-                    @Override
-                    public void mousePressed(MouseEvent e) {
-                        if (e.isPopupTrigger())
-                            showPopupMenu(watchedMenu, e)
-                    }
-                })
-
         // subscription table
         def subscriptionTable = builder.getVariable("subscription-table")
         subscriptionTable.setDefaultRenderer(Integer.class, centerRenderer)
@@ -649,6 +643,9 @@ class MainFrameView {
                 model.markNeutralFromDistrustedButtonEnabled = true
             }
         })
+        
+        // show tree by default
+        showSharedFilesTree.call()
     }
 
     private static void showPopupMenu(JPopupMenu menu, MouseEvent event) {
@@ -656,22 +653,42 @@ class MainFrameView {
     }
 
     def selectedSharedFiles() {
-        def sharedFilesTable = builder.getVariable("shared-files-table")
-        int[] selected = sharedFilesTable.getSelectedRows()
-        if (selected.length == 0)
-            return null
-        List<SharedFile> rv = new ArrayList<>()
-        if (lastSharedSortEvent != null) {
-            for (int i = 0; i < selected.length; i ++) {
-                selected[i] = sharedFilesTable.rowSorter.convertRowIndexToModel(selected[i])
+        if (!model.treeVisible) {
+            def sharedFilesTable = builder.getVariable("shared-files-table")
+            int[] selected = sharedFilesTable.getSelectedRows()
+            if (selected.length == 0)
+                return null
+            List<SharedFile> rv = new ArrayList<>()
+            if (lastSharedSortEvent != null) {
+                for (int i = 0; i < selected.length; i ++) {
+                    selected[i] = sharedFilesTable.rowSorter.convertRowIndexToModel(selected[i])
+                }
             }
+            selected.each {
+                rv.add(model.shared[it])
+            }
+            return rv
+        } else {
+            def sharedFilesTree = builder.getVariable("shared-files-tree")
+            List<SharedFile> rv = new ArrayList<>()
+            for (TreePath path : sharedFilesTree.getSelectionPaths()) {
+                getLeafs(path.getLastPathComponent(), rv)
+            }
+            return rv
         }
-        selected.each {
-            rv.add(model.shared[it])
-        }
-        rv
     }
-
+    
+    private static void getLeafs(TreeNode node, List<SharedFile> dest) {
+        if (node.isLeaf()) {
+            dest.add(node.getUserObject())
+            return
+        }
+        def children = node.children()
+        while(children.hasMoreElements()) {
+            getLeafs(children.nextElement(), dest)
+        }
+    }
+    
     def copyHashToClipboard() {
         def selectedFiles = selectedSharedFiles()
         if (selectedFiles == null)
@@ -820,6 +837,18 @@ class MainFrameView {
         model.monitorPaneButtonEnabled = true
         model.trustPaneButtonEnabled = false
     }
+    
+    def showSharedFilesTable = {
+        model.treeVisible = false
+        def cardsPanel = builder.getVariable("shared-files-panel")
+        cardsPanel.getLayout().show(cardsPanel, "shared files table")
+    }
+    
+    def showSharedFilesTree = {
+        model.treeVisible = true
+        def cardsPanel = builder.getVariable("shared-files-panel")
+        cardsPanel.getLayout().show(cardsPanel, "shared files tree")
+    }
 
     def shareFiles = {
         def chooser = new JFileChooser()
@@ -830,43 +859,12 @@ class MainFrameView {
         int rv = chooser.showOpenDialog(null)
         if (rv == JFileChooser.APPROVE_OPTION) {
             chooser.getSelectedFiles().each {
-                model.core.eventBus.publish(new FileSharedEvent(file : it))
+                File canonical = it.getCanonicalFile()
+                model.core.eventBus.publish(new FileSharedEvent(file : canonical))
             }
         }
     }
 
-    def watchDirectories = {
-        def chooser = new JFileChooser()
-        chooser.setFileHidingEnabled(false)
-        chooser.setDialogTitle("Select directory to watch")
-        chooser.setFileSelectionMode(JFileChooser.DIRECTORIES_ONLY)
-        chooser.setMultiSelectionEnabled(true)
-        int rv = chooser.showOpenDialog(null)
-        if (rv == JFileChooser.APPROVE_OPTION) {
-            chooser.getSelectedFiles().each { f ->
-                watchDirectory(f)
-            }
-        }
-    }
-
-    private void watchDirectory(File f) {
-        model.watched << f.getAbsolutePath()
-        application.context.get("muwire-settings").watchedDirectories << f.getAbsolutePath()
-        mvcGroup.controller.saveMuWireSettings()
-        builder.getVariable("watched-directories-table").model.fireTableDataChanged()
-        model.core.eventBus.publish(new FileSharedEvent(file : f))
-    }
-
-    String getSelectedWatchedDirectory() {
-        def watchedTable = builder.getVariable("watched-directories-table")
-        int selectedRow = watchedTable.getSelectedRow()
-        if (selectedRow < 0)
-            return null
-        if (lastWatchedSortEvent != null)
-            selectedRow = watchedTable.rowSorter.convertRowIndexToModel(selectedRow)
-        model.watched[selectedRow]
-    }
-
     int getSelectedTrustTablesRow(String tableName) {
         def table = builder.getVariable(tableName)
         int selectedRow = table.getSelectedRow()
@@ -876,4 +874,9 @@ class MainFrameView {
             selectedRow = table.rowSorter.convertRowIndexToModel(selectedRow)
         selectedRow
     }
+    
+    public void refreshSharedFiles() {
+        model.sharedTree.nodeStructureChanged(model.treeRoot)
+        builder.getVariable("shared-files-table").model.fireTableDataChanged()
+    }
 }

gui/src/main/groovy/com/muwire/gui/InterimTreeNode.groovy

@@ -0,0 +1,18 @@
+package com.muwire.gui
+
+class InterimTreeNode {
+    private final File file
+    InterimTreeNode(File file) {
+        this.file = file
+    }
+    
+    public boolean equals(Object o) {
+        if (!(o instanceof InterimTreeNode))
+            return false
+        file == o.file
+    }
+    
+    public String toString() {
+        file.getName()
+    }
+}

gui/src/main/groovy/com/muwire/gui/SharedTreeRenderer.groovy

@@ -0,0 +1,44 @@
+package com.muwire.gui
+
+import java.awt.Component
+
+import javax.swing.ImageIcon
+import javax.swing.JTree
+import javax.swing.tree.DefaultTreeCellRenderer
+
+import com.muwire.core.SharedFile
+
+import net.i2p.data.DataHelper
+
+class SharedTreeRenderer extends DefaultTreeCellRenderer {
+    
+    private final ImageIcon commentIcon
+    
+    SharedTreeRenderer() {
+        commentIcon = new ImageIcon((URL) SharedTreeRenderer.class.getResource("/comment.png"))
+    }
+    
+    public Component getTreeCellRendererComponent(JTree tree, Object value,
+        boolean sel, boolean expanded, boolean leaf, int row, boolean hasFocus) {
+        
+        def userObject = value.getUserObject()
+        def defaultRenderer = super.getTreeCellRendererComponent(tree, value, sel, expanded, leaf, row, hasFocus) 
+        if (userObject instanceof InterimTreeNode || userObject == null)
+            return defaultRenderer
+            
+        
+        SharedFile sf = (SharedFile) userObject
+        String name = sf.getFile().getName()
+        long length = sf.getCachedLength()
+        String formatted = DataHelper.formatSize2Decimal(length, false)+"B"
+        
+        
+        setText("$name ($formatted)")
+        setEnabled(true)
+        if (sf.comment != null) {
+            setIcon(commentIcon)
+        }
+
+        this        
+    }
+}