Paypal.scala

package controllers
 
import play.api._
import play.api.mvc._
import org.apache.commons.httpclient.HttpClient
import org.apache.commons.httpclient.methods.GetMethod
import models.Purchase
 
object Paypal extends Controller {
 
  val url = "https://www.paypal.com/cgi-bin/webscr?cmd=_notify-validate&";
  //val url = "https://www.sandbox.paypal.com/cgi-bin/webscr?cmd=_notify-validate&";
 
  def ipn = Action(parse.raw) {request =>
    request.body.asBytes() match {
      case Some(arrBytes) => {
        val queryString = new String(arrBytes);
        Logger.info("Paypal request: " + queryString)
        Logger.info("Verifying request: " + url + queryString)
 
        // for some reason I always get invalid if I use play.api.lib.ws.WS instead...
        val client = new HttpClient
        val methodGet: GetMethod = new GetMethod(url + queryString)
        client.executeMethod(methodGet)
        val response = methodGet.getResponseBodyAsString
        methodGet.releaseConnection
        if (response.trim != "VERIFIED") {
          logAndFail("Couldn't verify paypal call", "Verification response: " + response.trim)
        } else {
          val res = queryString.split('&') map { str =>
            val pair = str.split('=')
            if (pair.length == 2)
              (pair(0) -> pair(1))
            else
              (pair(0) -> "")
          } toMap;
          if (res.get("payment_status").exists(_ == "Completed")) {
            res.get("custom") match {
              case Some(custom) => custom.split("_").toList match {
                case List("purchase", "id", id) => {
                   Purchase.getById(id.toLong) match {
                     case Some(purchase) => {
                       purchase.setPaid()
                       // here email the purchase receipt or whatever
                       Ok
                     }
                     case None => logAndFail("Could not find purchase in DB")
                   }
                }
                case _ => throw new RuntimeException("invalid custom payload")
              }
              case None => logAndFail("custom var not available")
            }
          } else Ok
        } 
      }
      case None => logAndFail("Couldn't process paypal ipn")
    }
  }
 
  private def logAndFail(msg: String, extraMsg: String = "") = {
    Logger.warn(msg + " " + extraMsg)
    BadRequest(msg)
  }
}

Anyone have this for Java?