package com.Bit4Tat; 

 

import java.io.BufferedReader; 

import java.io.DataOutputStream; 

import java.io.IOException; 

import java.io.InputStreamReader; 

import java.io.UnsupportedEncodingException; 

import java.net.MalformedURLException; 

import java.net.URL; 

import java.net.URLEncoder; 

import java.security.KeyManagementException; 

import java.security.NoSuchAlgorithmException; 

import java.security.SecureRandom; 

import java.security.cert.CertificateException; 

import java.security.cert.X509Certificate; 

 

import javax.net.ssl.HostnameVerifier; 

import javax.net.ssl.HttpsURLConnection; 

import javax.net.ssl.KeyManager; 

import javax.net.ssl.SSLContext; 

import javax.net.ssl.SSLSession; 

import javax.net.ssl.TrustManager; 

import javax.net.ssl.X509TrustManager; 

 

//import com.Bit4Tat.PaymentService.DefaultTrustManager; 

 

public class PaymentProcessorForTradehill extends PaymentService 

{ 

 private static final String CHECK_BALANCE   = "https://api.tradehill.com/APIv1/USD/GetBalance?"; 

 private static final String BUY_ORDER    = "https://api.tradehill.com/APIv1/USD/BuyBTC?"; 

 private static final String SELL_ORDER    = "https://api.tradehill.com/APIv1/USD/SellBTC?"; 

 private static final String GET_ORDERS    = "https://api.tradehill.com/APIv1/USD/GetOrders?"; 

 private static final String CANCEL_ORDER   = "https://api.tradehill.com/APIv1/USD/CancelOrder?"; 

 // private static final String SEND_BTC    = " // not implemented yet by TradeHill 

  

 public String user; 

 public String pass; 

  

 private ResponseContainer response; 

  

 public PaymentProcessorForTradehill(String username, String password)  

 { 

     //TODO change to TradeHill response object 

      

  user = username; 

  pass = password; 

 } 

   

 @Override 

 public void buy(double amount, double price)  

 { 

  // Uses user credentials (user, pass) to purchase an amount of bitcoins. 

  // Set up connection 

  HttpsURLConnection conn = setupConnection(BUY_ORDER); 

  try  

  { 

   // Assemble the user, pass, amount, and price to tack onto conn 

   String data = URLEncoder.encode("name", "UTF-8") + "=" + URLEncoder.encode(user, "UTF-8"); 

   data += "&" + URLEncoder.encode("pass", "UTF-8") + "=" + URLEncoder.encode(pass, "UTF-8"); 

   data += "&" + URLEncoder.encode("amount", "UTF-8") + "="  

    + URLEncoder.encode(new java.text.DecimalFormat("0.00").format(amount), "UTF-8"); 

   data += "&" + URLEncoder.encode("price", "UTF-8") + "="  

    + URLEncoder.encode(new java.text.DecimalFormat("0.00").format(price), "UTF-8"); 

   // Pass to TradeHill 

   getResponse(data, conn); 

  } 

  // if there are errors, print a stack trace 

  catch (Exception e)  

  { 

   e.printStackTrace(); 

  } 

  // disconnect 

  conn.disconnect(); 

   

  // TODO figure out what to return 

   

 } 

 @Override 

 public ResponseContainer checkBalance()  

 { 

  HttpsURLConnection conn = setupConnection(CHECK_BALANCE); 

 

  try { 

  // Construct data 

  String data = URLEncoder.encode("name", "UTF-8") + "=" + URLEncoder.encode(user, "UTF-8"); 

  data += "&" + URLEncoder.encode("pass", "UTF-8") + "=" + URLEncoder.encode(pass, "UTF-8"); 

 

  /*//Diagnostics

  System.out.println("post_string:"); 

  System.out.println(data); 

  */ 

 

  getResponse(data, conn); 

  }  

  catch (Exception e)  

  { 

   e.printStackTrace(); 

  } 

  conn.disconnect();  

  // TODO figure out what to return 

  return response; 

 } 

 @Override 

 // Place an ask order for "amount" number of bitcoins, at "price" per bitcoin 

 public void sell(double amount, double price) { 

  HttpsURLConnection conn = setupConnection(SELL_ORDER); 

   

  try { 

  // Construct data 

  String data = URLEncoder.encode("name", "UTF-8") + "=" + URLEncoder.encode(user, "UTF-8"); 

  data += "&" + URLEncoder.encode("pass", "UTF-8") + "=" + URLEncoder.encode(pass, "UTF-8"); 

  data += "&" + URLEncoder.encode("amount", "UTF-8") + "=" +  

    URLEncoder.encode(new java.text.DecimalFormat("0.00").format(amount), "UTF-8"); 

  data += "&" + URLEncoder.encode("price", "UTF-8") + "=" +  

    URLEncoder.encode(new java.text.DecimalFormat("0.00").format(price), "UTF-8"); 

 

  getResponse(data, conn); 

  } catch (Exception e) { 

  e.printStackTrace(); 

  } 

  conn.disconnect(); 

  // TODO figure out what to return 

 } 

  

 @Override 

 // Cancel the order signified by orderID 

 public void cancelOrder(int orderID) { 

  HttpsURLConnection conn = setupConnection(CANCEL_ORDER); 

   

  try { 

  // Construct data 

  String data = URLEncoder.encode("name", "UTF-8") + "=" + URLEncoder.encode(user, "UTF-8"); 

  data += "&" + URLEncoder.encode("pass", "UTF-8") + "=" + URLEncoder.encode(pass, "UTF-8"); 

  data += "&" + URLEncoder.encode("orderID", "UTF-8") + "=" + URLEncoder.encode(Integer.toString(orderID), "UTF-8"); 

 

  getResponse(data, conn); 

  } catch (Exception e) { 

  e.printStackTrace(); 

  } 

  conn.disconnect(); 

 

  // TODO figure out what to return 

 } 

  

 @Override 

 // TODO Returns a collection of orders. Exact type current unknown; check with Ben. 

 public void getOrders() { 

  HttpsURLConnection conn = setupConnection(GET_ORDERS); 

   

  try { 

  // Construct data 

  String data = URLEncoder.encode("name", "UTF-8") + "=" + URLEncoder.encode(user, "UTF-8"); 

  data += "&" + URLEncoder.encode("pass", "UTF-8") + "=" + URLEncoder.encode(pass, "UTF-8"); 

 

  getResponse(data, conn); 

  } catch (Exception e) { 

  e.printStackTrace(); 

  } 

  conn.disconnect();   

  // TODO figure out what to return 

 } 

 // Read and return website responses 

 String getResponse (String data, HttpsURLConnection conn)  

 { 

  StringBuffer returnString = new StringBuffer(); 

  try { 

   // open up the output stream of the connection 

   DataOutputStream wr = new DataOutputStream( conn.getOutputStream() ); 

   int queryLength = data.length(); 

   wr.writeBytes( data); 

    //OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream()); 

   //wr.write(data); 

   //wr.flush(); 

   // Get the response 

  BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream())); 

    

  String line; 

  while ((line = rd.readLine()) != null) 

  { 

  // Process line... 

  System.out.println(line); 

  returnString.append(line); 

   } 

  wr.close(); 

   rd.close(); 

  } catch (Exception e) { 

   e.printStackTrace(); 

  } 

  return returnString.toString(); 

 } 

  

 // Something or other. Ben, Josh: What does this do? --Max 

 static class DefaultTrustManager implements X509TrustManager 

 { 

  @Override 

  public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {} 

  

  

  @Override 

  public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {} 

  

  @Override 

  public X509Certificate[] getAcceptedIssuers() {return null;} 

 } 

  

 // Sets up a connection to a URL 

 HttpsURLConnection setupConnection(String urlString) 

 { 

  SSLContext ctx = null; 

 

  try { 

   ctx = SSLContext.getInstance("TLS"); 

  } catch (NoSuchAlgorithmException e1) { 

  e1.printStackTrace(); 

  } 

  try { 

   ctx.init(new KeyManager[0], new TrustManager[] {new DefaultTrustManager()}, new SecureRandom()); 

  } catch (KeyManagementException e) { 

  e.printStackTrace(); 

  } 

  SSLContext.setDefault(ctx); 

 

 

  URL url = null; 

 

  try { 

   url = new URL(urlString); 

  } catch (MalformedURLException e) { 

  e.printStackTrace(); 

  } 

  HttpsURLConnection conn = null; 

 

  try { 

   conn = (HttpsURLConnection) url.openConnection(); 

  } catch (IOException e1) { 

  e1.printStackTrace(); 

  } 

  conn.setDoOutput(true); 

 

  conn.setDoInput(true); 

 

  conn.setHostnameVerifier(new HostnameVerifier()  

  { 

   @Override 

   public boolean verify(String arg0, SSLSession arg1)  

   { 

    return true; 

   } 

  }); 

 

 /*

 try { 

 

 System.out.println(conn.getResponseCode()); 

 } catch (IOException e) { 

 

 // TODO Auto-generated catch block 

 e.printStackTrace(); 

 

 } 

 */ 

  return conn; 

 } 

 

 @Override 

 public ResponseContainer checkTicker() { 

  // TODO Auto-generated method stub 

  return null; 

 }