Subversion Repositories XServices

/*

 *   Copyright 2013 Brian Rosenberger (Brutex Network)

 *

 *   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.

 */

package net.brutex.xservices.ws.rs;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.net.URI;

import java.nio.file.DirectoryStream;

import java.nio.file.FileSystems;

import java.nio.file.FileVisitOption;

import java.nio.file.FileVisitResult;

import java.nio.file.Files;

import java.nio.file.Path;

import java.nio.file.PathMatcher;

import java.nio.file.SimpleFileVisitor;

import java.nio.file.attribute.BasicFileAttributeView;

import java.nio.file.attribute.BasicFileAttributes;

import java.util.ArrayList;

import java.util.EnumSet;

import java.util.List;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import javax.ws.rs.NotAuthorizedException;

import javax.ws.rs.WebApplicationException;

import javax.ws.rs.core.GenericEntity;

import javax.ws.rs.core.HttpHeaders;

import javax.ws.rs.core.MediaType;

import javax.ws.rs.core.Response;

import javax.ws.rs.core.StreamingOutput;

import javax.ws.rs.core.UriInfo;

import lombok.extern.slf4j.Slf4j;

import net.brutex.xservices.security.DirectoryPermission;

import net.brutex.xservices.types.FileInfoType;

import net.brutex.xservices.util.FileWalker;

import org.apache.commons.jcs.JCS;

import org.apache.commons.jcs.access.CacheAccess;

import org.apache.commons.jcs.access.exception.CacheException;

import org.apache.shiro.SecurityUtils;

import org.apache.shiro.authz.UnauthorizedException;

/**

 * The Class FileInfoImpl.

 *

 * @author Brian Rosenberger, bru(at)brutex.de

 */

@Slf4j

public class FileInfoImpl  implements FileInfo {

  /* (non-Javadoc)

   * @see net.brutex.xservices.ws.rs.FileInfo#getFiles(javax.ws.rs.core.HttpHeaders, java.lang.String, boolean, boolean, int, java.lang.String, int, int)

   */

  public Response getFiles(HttpHeaders h, UriInfo uriInfo, String dir, boolean withDir, boolean withFiles, int level, String search, int count, int page, boolean useCache)

  {

	if(dir==null) {

		dir = "c:/";

		log.warn("No directory specified. Default is 'c:/'.");

		}

	isPermitted(dir);

    URI baseuri = URI.create(uriInfo.getBaseUri()+FileInfo.BASE_PATH+"getFile?file=");

    log.info(String.format("Listing directory '%s'.", dir));

    if (level <= 0) level = 1;

    if ((!withDir) && (!withFiles)) withFiles = true;

    String cachekey = level + "||" + withFiles + "||" + withDir + "||" + search + "||" + dir;

    try {

      log.debug(String.format("Hitting cache with cachekey '%s'", cachekey));

      CacheAccess<Object, Object> jcs = JCS.getInstance("FileCache");

      /*Try to retrieve the file list from the cache*/

      List<FileInfoType> list = (List<FileInfoType>)jcs.get(cachekey);

      if (list == null || !useCache) {

        list = setDirectory(baseuri, dir, withDir, withFiles, level, search);

        jcs.put(cachekey, list);

        log.debug("Stored in Cache: " + list.toString());

      } else {

        log.debug("Got from Cache: " + list.toString());

      }

      int fromIndex = 0;

      int toIndex = 0;

      fromIndex = (page - 1) * count;

      toIndex = page * count;

      if (toIndex > list.size()) toIndex = list.size();

      if (fromIndex > toIndex) fromIndex = toIndex;

      GenericEntity<List<FileInfoType>> sublist = new GenericEntity<List<FileInfoType>>(list.subList(fromIndex, toIndex)) {};

      log.info(String.format("Returning items %s to %s from total of %s items in the list.", fromIndex, toIndex, list.size()));

      return Response.ok(sublist).build();

    } catch (CacheException e) {

      return Response.serverError().build();

    }

  }

  /**

   * Sets the directory.

   *

   * @param list the list

   * @param dir the dir

   * @param withDirectories the with directories

   * @param withFiles the with files

   * @param depth the depth

   * @param search the search

   */

  private void setDirectory(final URI baseuri, final List<FileInfoType> list, File dir, boolean withDirectories, boolean withFiles, final int depth, String search)

  {

    if (depth <= 0) return;

    	if(search==null || search.equals("") ) {

    		search = "*";

    		log.info("No search pattern supplied, using default '*'.");

    	}

    	FileWalker finder = new FileWalker(search);

    	try {

			Files.walkFileTree(dir.toPath(), EnumSet.of(FileVisitOption.FOLLOW_LINKS), depth, finder);

			log.info("FileWalker returned '"+finder.getCount()+"' hits. '" + finder.getTotal() + "' files have been scanned.");

			List<Path> result = finder.getResult();

	    	for(Path f : result) {

	    		if(! withDirectories) {

	    			if(f.toFile().isDirectory()) continue;

	    		}

	    		if(! withFiles) {

	    			if(f.toFile().isFile()) continue;

	    		}

	    		list.add(new FileInfoType(f, baseuri));

	    	}

		} catch (IOException e2) {

			log.error(e2.getMessage(), e2);;

		}

  }

  /**

   * Sets the directory.

   *

   * @param dir the dir

   * @param withDirectories the with directories

   * @param withFiles the with files

   * @param depth the depth

   * @param search the search

   * @return the list

   */

  private List<FileInfoType> setDirectory(URI baseuri, String dir, boolean withDirectories, boolean withFiles, int depth, String search)

  {

    List<FileInfoType> list = new ArrayList<FileInfoType>();

    setDirectory(baseuri, list, new File(dir), withDirectories, withFiles, depth, search);

    return list;

  }

@Override

public Response getFile(HttpHeaders paramHttpHeaders, String file) {

	isPermitted(file);

	try {

	Path path = FileSystems.getDefault().getPath(file);

	BasicFileAttributeView basicView = Files.getFileAttributeView(path, BasicFileAttributeView.class);

	BasicFileAttributes basic;

	basic = basicView.readAttributes();

	//In case this is a directory

	//we zip it and return the zip stream

	if(basic.isDirectory()) return getDirectoryAsZip(path);

	MediaType mime = MediaType.APPLICATION_OCTET_STREAM_TYPE;

	try {

		mime = MediaType.valueOf(Files.probeContentType(path));

	} catch (IllegalArgumentException | IOException e) {

		//In case we can not find the media type for some reason

		//the default assignment is taken, so we can

		//ignore this error.

		log.debug(String.format("Could not probe media type for file '%s'. Default is '%s'", path.toString(), mime.getType()), e);

	}

	Response r = Response.ok(path.toFile(), mime).build();

	String fileName = path.getFileName().toString();

	if(mime == MediaType.APPLICATION_OCTET_STREAM_TYPE) r.getHeaders().add("Content-Disposition", "attachment; filename=\"" + fileName + "\"");

	return r;

		} catch (IOException e1) {

			// TODO Auto-generated catch block

			log.error(e1.getMessage(), e1);

			return Response.serverError().build();

		}

}

private Response getDirectoryAsZip(final Path path) {

	StreamingOutput output = new StreamingOutput() {

		@Override

		public void write(OutputStream os) throws IOException,

				WebApplicationException {

			ZipOutputStream zos = new ZipOutputStream(os);

			//read directory content (files only)

			try (DirectoryStream<Path> stream = Files.newDirectoryStream(path)) {

			    for (Path file: stream) {

			    	//skip anything not being a file

			        if(! file.toFile().isFile()) continue;

			        //ZipEntry

			        String filename = file.getFileName().toString();

			        ZipEntry ze = new ZipEntry(filename);

			        zos.putNextEntry( ze );

			        //read a file and put it into the output stream

			        FileInputStream fis = new FileInputStream(file.toFile());

			        byte[] buffer = new byte[1024];

			        int len;

			        while ((len = fis.read(buffer)) > 0) {

			        	zos.write(buffer, 0, len);

			        }

			        zos.flush();

			        fis.close();

			    }

			    zos.close();

			}

		}

	};

	Response r = Response.ok(output, MediaType.APPLICATION_OCTET_STREAM_TYPE).build();

	String zipname = (path.getFileName()==null) ? "null.zip" : path.getFileName().toString()+".zip";

	r.getHeaders().add("Content-Disposition", "attachment; filename=\"" + zipname + "\"");

	return r;

}

private boolean isPermitted(String dir) {

	if(! SecurityUtils.getSubject().isPermitted( new DirectoryPermission(dir))) {

		log.warn(String.format("User '%s' does not have permission to access '%s'.",SecurityUtils.getSubject().getPrincipal(), dir ));

		throw new NotAuthorizedException(new UnauthorizedException("User does not have permission to access "+ dir));

	}

	return true;

}

//http://stackoverflow.com/questions/3758606/how-to-convert-byte-size-into-human-readable-format-in-java

private static String humanReadableByteCount(long bytes, boolean si) {

    int unit = si ? 1000 : 1024;

    if (bytes < unit) return bytes + " B";

    int exp = (int) (Math.log(bytes) / Math.log(unit));

    String pre = (si ? "kMGTPE" : "KMGTPE").charAt(exp-1) + (si ? "" : "i");

    return String.format("%.1f %sB", bytes / Math.pow(unit, exp), pre);

}

}