VisClient/org/hfbk/vis/visnode/VisScanDir.java

Go to the documentation of this file.

package org.hfbk.vis.visnode;

import java.awt.AWTEvent;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileFilter;
import java.io.FileReader;
import java.io.IOException;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

import org.dronus.graph.Node;
import org.hfbk.util.Sleeper;
import org.hfbk.vis.Prefs;
import org.lwjgl.util.vector.Vector3f;

public class VisScanDir extends VisNodeDraggable {

        private String path;
        private File filesArray [];
        private HashMap<File,Long> dir = new HashMap<File,Long>();
        private DirFilterWatcher dfw;


        final int DELAY = 1000;

        // if something was sampled but not yet visualised.
        boolean dirty = true;

        public VisScanDir(Node n, Vector3f position) {
                super(null, position);

                if (n.text.length()==0) path=Prefs.current.watchdir;
                
//              String filter= new String("txt");
                String filter=Prefs.current.suffixesImage;

                
//              if (Prefs.current.verbose)
                        System.out.println("watching "+path);
                
                dfw = new DirFilterWatcher(filter);

                filesArray = new File(path).listFiles(dfw);

                // transfer to the hashmap be used a reference and keep the
                // lastModfied value
                if (filesArray!=null)
                {for(int i = 0; i < filesArray.length; i++) {
                        dir.put(filesArray[i], new Long(filesArray[i].lastModified()));
                        System.out.println(filesArray[i].getName());
                }

                }

                final String start = n.text;
                Thread scanner = new Thread() {

                        public void run() {
                                setName("VisScanner");
                                while (true) {
                                        scanfile(start, null);
                                        Sleeper.sleep(DELAY);
                                }
                        }
                };
                scanner.start();

        }

        @SuppressWarnings("unchecked")
        void scanfile(String startatdir, Node parentnode) {
                HashSet<File> checkedFiles = new HashSet<File>();
                filesArray = new File(path).listFiles(dfw);
                if (filesArray!=null)
                {
                        // scan the files and check for modification/addition
                        for(int i = 0; i < filesArray.length; i++) {
                                Long current = (Long)dir.get(filesArray[i]);
                                checkedFiles.add(filesArray[i]);
                                if (current == null) {
                                        // new file
                                        dir.put(filesArray[i], new Long(filesArray[i].lastModified()));
                                        if (Prefs.current.verbose) System.out.println(filesArray[i].getName()+ " added");
                                        dirty=true;
                                }
                                else if (current.longValue() != filesArray[i].lastModified()){
                                        // modified file
                                        dir.put(filesArray[i], new Long(filesArray[i].lastModified()));
                                        if (Prefs.current.verbose) System.out.println(filesArray[i].getName()+ " modified");
                                        dirty=true;
                                }
                        }

                        // now check for deleted files
                        Set<Object> ref = ((HashMap)dir.clone()).keySet();
                        ref.removeAll((Set)checkedFiles);
                        Iterator it = ref.iterator();
                        while (it.hasNext()) {
                                File deletedFile = (File)it.next();
                                dir.remove(deletedFile);
                                if (Prefs.current.verbose) System.out.println(deletedFile.getName()+ " deleted");
                                dirty=true;
                        }
                }
        }


        void transform() {      
                super.transform();

        }

        void renderSelf() {
                if (dirty && (filesArray!=null))
                {               
                        System.out.println("updating contents from "+path);
                        this.children.clear();
                        //      if (parent instanceof VisRoot)
                        if (true){
                                VisNode struct=parent.findNode(VisStructure.class);
                                struct.remove(this);
                                if (struct!=null){
                                        parent.remove(this);

                                        VisNode finddir=struct.findNode(VisScanDir.class);
                                        if (finddir!=null)parent.remove(finddir);

                                        struct.add(this);

                                        for (int i=0;i<filesArray.length;i++)
                                        {
                                                String content="";
                                                try {
                                                        content=load(path+"/"+filesArray[i].getName());
                                                } catch (IOException e) {
                                                        // TODO Auto-generated catch block
                                                        e.printStackTrace();
                                                }
                                                Vector3f pe=new Vector3f();
                                                pe.x=(float)Math.random()*30;
                                                pe.y=(float)Math.random()*10;
                                                pe.z=(float)Math.random()*30;
                                                VisNode um=new VisText(new Node(content), pe);
                                                this.add(um);
                                        }

                                }}
                        dirty=false;}

        }

        String load(String filename) throws IOException{
                BufferedReader r=new BufferedReader(new FileReader(new File(filename)));
                String line,content;
                content="";

                while ((line=r.readLine())!=null)
                {content+="\n"+line;}

                return content;

        }


        public void render(List<AWTEvent> events) {
                //      GL11.glEnable(GL11.GL_CULL_FACE);
                super.render(events);
                //GL11.glDisable(GL11.GL_CULL_FACE);
        }
        class DirFilterWatcher implements FileFilter {
                private String filter;

                public DirFilterWatcher() {
                        this.filter = "";
                }

                public DirFilterWatcher(String filter) {
                        this.filter = filter;
                }

                public boolean accept(File file) {
                        if ("".equals(filter)) {
                                return true;
                        }
                        return (file.getName().endsWith(filter));
                }
        }

}

---