import com.kolich.havalo.client.service.HavaloClient;
import java.util.UUID;

// Your Havalo API key
final UUID key = ...;

// Your Havalo API secret
final String secret = ...;

// Your Havalo API endpoint URL, usually something like
// http://localhost:8080/havalo/api
final String apiUrl = ...;

final HavaloClient client = new HavaloClient(key, secret, apiUrl);

import org.apache.http.client.HttpClient;

final HttpClient httpClient = ...; // Your own HttpClient instance

final HavaloClient client = new HavaloClient(httpClient, key, secret, apiUrl);

final Either<HttpFailure,KeyPair> auth =
  client.authenticate();

if(auth.success()) {
  // Success
} else {
  // Failed
}

final Either<HttpFailure,KeyPair> repo =
  client.createRepository();

final KeyPair kp;
if((kp = repo.right()) != null) {
  // Success
  System.out.println("Your new API key: " + kp.getKey());
  System.out.println("Your new API secret: " + kp.getSecret());
}

final UUID toDelete = ...; // The UUID of the repository to delete.

final Either<HttpFailure,Integer> del =
  client.deleteRepository(toDelete);

if(del.success()) {
  System.out.println("Deleted repository successfully, status code: " +
    del.right());
}

// List all objects whose key starts with "foobar/baz"
final Either<HttpFailure,ObjectList> list =
  client.listObjects("foobar", "baz");

if(list.success()) {
  final ObjectList objs = list.right();
  System.out.println("Found " + objs.size() + " objects.");
}

final OutputStream os = ...; // An existing and open OutputStream.

// Get the object whose key is "foobar/baz/0.json" and stream its
// bytes to the provided OutputStream.
final Either<HttpFailure,List<Header>> get =
  client.getObject(os, "foobar", "baz", "0.json");

if(get.success()) {
  // Success, object data was copied to provided OutputStream.
  // Here are the HTTP headers on the response.
  final List<Header> headers = get.right();
  for(final Header h : headers) {
    System.out.println(h.getName() + ": " + h.getValue());
  }
} else {
  // Object not found.
}

import com.kolich.http.blocking.helpers.definitions.CustomEntityConverter;

import org.apache.commons.io.IOUtils;

final ServletResponse response = ...; // From your Servlet container

client.getObject(new CustomEntityConverter<HttpFailure,Long>() {
  @Override
  public Long success(final HttpSuccess success) throws Exception {
    // Send down the HTTP Content-Type as fetched in the response
    // from the Havalo K,V store.
    final String contentType;
    if((contentType = success.getContentType()) != null) {
      response.setContentType(contentType);
    }
    // Send down the HTTP Content-Length as fetched in the response
    // from the Havalo K,V store.
    final String contentLength;
    if((contentLength = success.getContentLength()) != null) {
      response.setContentLength(Integer.parseInt(contentLength));
    }
    // Actually stream the bytes out to the caller.
    final ServletOutputStream os = response.getOutputStream();
    return IOUtils.copyLarge(success.getContent(), os);
  }
  @Override
  public HttpFailure failure(final HttpFailure failure) {
    // Handle failure, write out error response, do whatever is
    // appropriate on error.
    // ...
    return failure;
  }
}, "foobar", "baz", "0.json");

import com.kolich.http.blocking.helpers.definitions.CustomFailureEntityConverter;
import com.kolich.http.blocking.helpers.definitions.CustomSuccessEntityConverter;

client.getObject(
  // Success converter
  new CustomSuccessEntityConverter<S>() {
    @Override
    public S success(final HttpSuccess success) throws Exception {
      // Do something on success, return type 'S'
    }
  },
  // Failure converter
  new CustomFailureEntityConverter<F>() {
    @Override
    public F failure(final HttpFailure failure) {
      // Do something on failure, return type 'F' 
    }
  },
  // Path to object key
  "foobar", "baz", "0.json"
);

// Get the meta data for the object whose key is "foobar/baz/1.xml"
final Either<HttpFailure,List<Header>> meta =
  client.getObjectMetaData("foobar", "baz", "1.xml");

if(meta.success()) {
  final List<Header> headers = meta.right();
  for(final Header h : headers) {
    System.out.println(h.getName() + ": " + h.getValue());
  }
}

import static org.apache.http.HttpHeaders.CONTENT_TYPE;
import static org.apache.http.HttpHeaders.ETAG;

final InputStream is = ...; // An existing and open InputStream.

// Upload an object to path "baz/foobar.jpg" .. since it's a JPG
// image, also send the relevant Content-Type with the request.
final Either<HttpFailure,FileObject> upload =
  client.putObject(is,
    // The number of bytes in this object.
    1024L,
    // A Content-Type to be saved with the object.  This header is
    // sent back with the object when it's retrieved.
    new Header[]{new BasicHeader(CONTENT_TYPE, "image/jpeg")},
    // The path to the object.
    "baz", "foobar.jpg");

if(upload.success()) {
  // Success
  // The SHA-1 hash of the uploaded object can be found in the
  // ETag HTTP response header.
  final String hash = upload.right().getFirstHeader(ETAG);
  System.out.println("Uploaded object SHA-1 hash is: " + hash);
}

final byte[] data = ...; // Some byte[] array of data.

// Upload an object to path "cat"
final Either<HttpFailure,FileObject> upload =
  client.putObject(data, "cat");

if(upload.success()) {
  // Success
  // The SHA-1 hash of the uploaded object can be found in the
  // ETag HTTP response header.
  final String hash = upload.right().getFirstHeader("ETag");
  System.out.println("Uploaded object SHA-1 hash is: " + hash);
}

import static org.apache.http.HttpHeaders.IF_MATCH;

// An SHA-1 hash for the version of the object you want to delete.
final String myHash = "de9f2c7fd25e1b3afad3e85a0bd17d9b100db4b3";

// Delete the object at path "foobar/cat" only if that object's hash
// equals "de9f2c7fd25e1b3afad3e85a0bd17d9b100db4b3".
final Either<HttpFailure,Integer> delete =
  client.deleteObject(
    new Header[]{new BasicHeader(IF_MATCH, myHash)},
    "foobar", "cat");

if(delete.success()) {
  // Success
} else {
  // Failed, get the resulting HTTP status code so
  // we can see what happened.
  switch(delete.left().getStatusCode()) {
    case 404:
      // 404 Not Found
      // Object at provided path didn't exist.
      // ...
      break;
    case 409:
      // 409 Conflict
      // Object conflict, the sent SHA-1 hash did not match.
      // ...
      break;
    default:
      // Hmm, something else went wrong.
      // ...
      break;
  }
}

// Delete the object at path "foobar/cat".
final Either<HttpFailure,Integer> delete =
  client.deleteObject("foobar", "cat");

if(delete.success()) {
  // Success
} else {
  // Failed
  System.out.println("Oops, delete failed with status: " +
    delete.left().getStatusCode());
}