Pithos_GSS » Java GSS CLI Client

	GSSCmdFactory factory = GSSCmdFactory.getInstance();

	if (factory == null) {

	    System.err.println("Command not found");

	    return;

	}

	GSSCmd cmd = (GSSCmd) factory.getGSSCmdInstance(args, 

	    System.out.println(statusCode 

		    + " " + HttpStatus.getStatusText(statusCode));

	} else {

	    System.err.println("Command could not be created");

import gssclient.commands.MkDirCmd;

    private static final String MKDIR = "mkdir";

	COMMANDS.put(MKDIR, MkDirCmdFactory.getInstance());

	GSSCmdFactory factory = COMMANDS.get(args[0]);

	if (factory != null) {

	    return factory.getGSSCmdInstance(args, 

		    client, userInfo);

	} else {

	    return null;

	}

    /**

     * Class for creating MkDirCmd objects.

     */

    private static class MkDirCmdFactory extends GSSCmdFactory {

	private static final MkDirCmdFactory INSTANCE = 

	    new MkDirCmdFactory();

	private MkDirCmdFactory() { }

	public static MkDirCmdFactory getInstance() {

	    return INSTANCE;

	}

	public GSSCmd getGSSCmdInstance(String[] args, 

		HttpClient client, UserInfo userInfo) {

	    MkDirCmd cmd = new MkDirCmd(client, userInfo, new Date(), 

		    args[1], null);

	    return cmd;

	}

    }

package gssclient.commands;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.util.Date;

import gssclient.NaiveTrustProvider;

import gssclient.ShibAuth;

import gssclient.ShibAuthException;

import gssclient.UserInfo;

import gssclient.httpmethods.HttpMethodFactory;

import gssclient.httpmethods.PostMethodFactory;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.HttpException;

import org.apache.commons.httpclient.HttpStatus;

import org.apache.commons.httpclient.methods.PostMethod;

import org.apache.commons.io.FilenameUtils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

public class MkDirCmd implements GSSCmd {

    private HttpClient client;

    private UserInfo userInfo;

    private Date date;

    private String path;

    private String localPath;

    private String dir;

    private Log log;

    public MkDirCmd(HttpClient client, UserInfo userInfo, Date date, 

	    String path, String localPath) {

	this.log = LogFactory.getLog(this.getClass());

	this.client = client;

	this.userInfo = userInfo;

	this.date = date;

	this.path = FilenameUtils.getPath(path);

	this.dir = FilenameUtils.getName(path);

	this.localPath = localPath;

    }

    public int execute() {

	int statusCode = -1;

	PostMethod method = PostMethodFactory.getInstance()

		.generateMethod(HttpMethodFactory.Scheme.HTTP,

			GSSUtils.GSS_HOME,

			date, userInfo, path, localPath);

	method.addParameter("new", this.dir);

	try {

	    // Execute the method.

	    log.debug("Start method execution...");

	    log.debug("Creating directory " + method.getParameter("new"));

	    statusCode = client.executeMethod(method);

	    log.debug("End method execution.");

	    // Read the response body.

	    InputStream in = method.getResponseBodyAsStream();

	    if (localPath != null) {

		FileOutputStream out = new FileOutputStream(localPath);

		byte[] buffer = new byte[1024];

		int count = -1;

		while ((count = in.read(buffer)) != -1) {

		    out.write(buffer, 0, count);

		}	

		out.flush();

		out.close();

	    }

	} catch (HttpException e) {

	    System.err.println("Fatal protocol violation: " + e.getMessage());

	    e.printStackTrace();

	} catch (IOException e) {

	    System.err.println("Fatal transport error: " + e.getMessage());

	    e.printStackTrace();

	} finally {

	    // Release the connection.

	    method.releaseConnection();

	}

	return statusCode;

    }

    public static void main(String[] args) throws ShibAuthException {

	NaiveTrustProvider.setAlwaysTrust(Boolean.TRUE);

	ShibAuth shibAuth = new ShibAuth();

	UserInfo userInfo = shibAuth.open(args[0], args[1], args[2]);

        HttpClient client = new HttpClient();

	MkDirCmd cmd = new MkDirCmd(client, userInfo, new Date(), 

		"temp", null);

	int statusCode = cmd.execute();

	System.out.println(HttpStatus.getStatusText(statusCode));

    }

}

	    encodedPath = encodedPath.replace("%3F", "?");

	    encodedPath = encodedPath.replace("%3D", "=");

package gssclient.httpmethods;

import java.io.File;

import org.apache.commons.httpclient.methods.FileRequestEntity;

import org.apache.commons.httpclient.methods.PostMethod;

import org.apache.commons.httpclient.HttpMethod;

public class PostMethodFactory extends HttpMethodFactory {

    private static PostMethodFactory INSTANCE = new PostMethodFactory(); 

    private PostMethodFactory() {

	super();

    }

    public static PostMethodFactory getInstance() {

	return INSTANCE;

    }

    /**

     * Generates a put method given the specified URI.

     * @param uri The method URI.

     * @param localPath The local path to the file implicated in the method;

     * it may be null.

     * @return The generated method. It can then be used to actually carry

     * out the call.

     */

    public <M extends HttpMethod> M generateSpecificMethod(String uri, 

	    String localPath) {

	PostMethod method = new PostMethod(uri);

	if (localPath != null) {

	    File file = new File(localPath);

	    method.setRequestEntity(new FileRequestEntity(file, ""));

	}

	// As we know that PutMethod is indeed a subclass of HttpMethod,

	// we can safely suppress the cast-related warning.

	@SuppressWarnings("unchecked")

	M returnVal = (M) method;

	return returnVal;

    }

}