Skip to content

Instantly share code, notes, and snippets.

@softprops

softprops/app.scala

Created January 28, 2012 18:44
Show Gist options
  • Save softprops/1695399 to your computer and use it in GitHub Desktop.
Save softprops/1695399 to your computer and use it in GitHub Desktop.
Download ZIP
netty uploads test app
Raw
app.scala
import unfiltered.request._
import unfiltered.response._
import unfiltered.netty._
import unfiltered.request.uploads.netty._
object App {
def main(a: Array[String]) {
Http(8080).chunked().handler(cycle.Planify{
case POST(Path("/cycle/disk")) & MultiPart(req) =>
val disk = MultiPartParams.Disk(req)
(disk.files("f"), disk.params("p")) match {
case (Seq(f, _*), p) =>
ResponseString(
"cycle disk read file f named %s with content type %s and param p %s" format(
f.name, f.contentType, p))
case _ => ResponseString("what's f?")
}
case POST(Path("/cycle/stream") & MultiPart(req)) =>
val stream = MultiPartParams.Streamed(req)
(stream.files("f"), stream.params("p")) match {
case (Seq(f, _*), p) => ResponseString(
"cycle stream read file f is named %s with content type %s and param p %s" format(
f.name, f.contentType, p))
case _ => ResponseString("what's f?")
}
case r@POST(Path("/cycle/mem") & MultiPart(req)) =>
val mem = MultiPartParams.Memory(req)
(mem.files("f"), mem.params("p")) match {
case (Seq(f, _*), p) => ResponseString(
"cycle memory read file f is named %s with content type %s and param p %s" format(
f.name, f.contentType, p))
case _ => ResponseString("what's f?")
}
}).handler(async.Planify{
case r @ POST(Path("/async/disk")) & MultiPart(req) =>
val disk = MultiPartParams.Disk(req)
(disk.files("f"), disk.params("p")) match {
case (Seq(f, _*), p) =>
r.respond(ResponseString(
"async disk read file f named %s with content type %s and param p" format(
f.name, f.contentType, p)))
case _ => r.respond(ResponseString("what's f?"))
}
case r @ POST(Path("/async/stream") & MultiPart(req)) =>
val stream = MultiPartParams.Streamed(req)
(stream.files("f"), stream.params("p")) match {
case (Seq(f, _*), p) => r.respond(ResponseString(
"async stream read file f is named %s with content type %s and param p %s" format(
f.name, f.contentType, p)))
case _ => r.respond(ResponseString("what's f?"))
}
case r @ POST(Path("/async/mem") & MultiPart(req)) =>
val mem = MultiPartParams.Memory(req)
(mem.files("f"), mem.params("p")) match {
case (Seq(f, _*), p) => r.respond(ResponseString(
"async memory read file f is named %s with content type %s and param p %s" format(
f.name, f.contentType, p)))
case _ => r.respond(ResponseString("what's f?"))
}
}).handler(cycle.Planify{
case Path("/") => Html(
<html>
<head><title>unfiltered file netty uploads test</title></head>
<body>
<h1>cycle disk upload</h1>
<form action="/cycle/disk" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
<h1>cycle stream upload</h1>
<form action="/cycle/stream" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
<h1>cycle mem upload</h1>
<form action="/cycle/mem" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
<h1>async disk upload</h1>
<form action="/async/disk" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
<h1>async stream upload</h1>
<form action="/async/stream" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
<h1>async mem upload</h1>
<form action="/async/mem" method="POST" enctype="multipart/form-data">
<input type="file" name="f" />
<input type="text" name="p"/>
<input type="submit"/>
</form>
</body>
</html>
)
}).run
}
}
Raw
build.sbt
libraryDependencies += "net.databinder" %% "unfiltered-netty-uploads" % "0.5.4-SNAPSHOT"
resolvers += "cloudbees" at "http://repository-netty.forge.cloudbees.com/snapshot"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment