Test cases for file upload using akka-http in Scala

May 21, 2016September 10, 2018 Rishi KhandelwalStudio-Scala4 Comments

Table of contents

Reading Time: < 1 minute

Hello folks, In my previous blog, i explained how to upload a file using akka-http in Scala. Later, i got the queries about the test cases for the same. Therefore, in this blog I am going to explain the way of writing test cases for file upload.

First we need to add test dependency :


"com.typesafe.akka" %% "akka-http-testkit" % "2.4.3",
"org.scalatest" %% "scalatest" % "2.2.6" % "test"

Full code :

package com.rishi

import java.io.File

import akka.http.scaladsl.model.{StatusCodes, Multipart, ContentTypes}
import akka.http.scaladsl.testkit.ScalatestRouteTest
import org.scalatest.{FlatSpec, Matchers}

class FileUploadSpec extends FlatSpec with Matchers with ScalatestRouteTest with FileUpload {
override def testConfigSource = "akka.loglevel = WARNING"

"File upload" should "not be able to upload file when file does not exist" in {
val file = new File("")
val formData = Multipart.FormData.fromFile("file", ContentTypes.`application/octet-stream`, file, 100000)
Post(s"/user/upload/file", formData) -> routes -> check {
status shouldBe StatusCodes.InternalServerError
responseAs[String] shouldBe "Error in file uploading"
}
}

it should "be able to upload file" in {
val file = new File(getClass.getResource("/testFile").toString)
val formData = Multipart.FormData.fromFile("file", ContentTypes.`application/octet-stream`, file, 100000)
Post(s"/user/upload/file", formData) -> routes -> check {
status shouldBe StatusCodes.OK
responseAs[String] contains "File successfully uploaded"
}
}
}

Get full code here.

It’s done. Hope you enjoy it. In my next blog, I will create a basic application to handle multipart formdata (file + form fields) using akka-http in Scala. So Stay tuned !!

Happy Blogging !!!

Written by Rishi Khandelwal

Rishi is a tech enthusiast with having around 10 years of experience who loves to solve complex problems with pure quality. He is a functional programmer and loves to learn new trending technologies. His leadership skill is well prooven and has delivered multiple distributed applications with high scalability and availability by keeping the Reactive principles in mind. He is well versed with Scala, Akka, Akka HTTP, Akka Streams, Java8, Reactive principles, Microservice architecture, Async programming, functional programming, distributed systems, AWS, docker.

4 thoughts on “Test cases for file upload using akka-http in Scala1 min read”

Rishi Khandelwal says:

May 23, 2016 at 9:55 AM

Reblogged this on Rishi Khandelwal.
Anand Kumar Singh says:

May 24, 2016 at 6:32 PM

Reblogged this on Play!ng with Scala.
Pingback: A basic application to handle multipart form data using akka-http with test cases in Scala | Knoldus
reddy sekhar says:

March 27, 2018 at 11:40 AM

Hi

I have an Akka HTTP service like

https://stackoverflow.com/q/48762297

path( “file-upload”) {
extractClientIP { ip =>
optionalHeaderValueByName(Constants.AUTH) { auth =>
(post & extractRequestContext) { request =>
extractRequestContext {
ctx => {
implicit val materializer = ctx.materializer
implicit val ec = ctx.executionContext
val currentTime = TimeObject.getCurrentTime()
fileUpload(“fileUpload”) {
case (fileInfo, fileStream) =>
val localPath = Configuration.excelFilePath
val uniqueidString = “12345”
val filename = uniqueidString + fileInfo.fileName
val sink = FileIO.toPath(Paths.get(localPath) resolve filename)
val writeResult = fileStream.runWith(sink)
onSuccess(writeResult) { result =>
result.status match {
case Success(_) =>
var excelPath = localPath + File.separator + uniqueidString + fileInfo.fileName
var doc_count = itemsExcelParse(excelPath, companyCode, subCompanyId, userId)
val currentTime2 = TimeObject.getCurrentTime()
var upload_time = currentTime2 – currentTime
val resp: JsValue = Json.toJson(doc_count)
complete {
val json: JsValue = Json.obj(“status” -> Constants.SUCCESS,
“status_details” -> “null”, “upload_details” -> resp)
HttpResponse(status = StatusCodes.OK, entity = HttpEntity(ContentType(MediaTypes.`application/json`), json.toString))
}

case Failure(e) =>
complete {
val json: JsValue = Json.obj(“status” -> Constants.ERROR)
HttpResponse(status = StatusCodes.BandwidthLimitExceeded, entity = HttpEntity(ContentType(MediaTypes.`application/json`), json.toString))
}
}
}
}
}
}
}
}
}
}

am using test code like

it should “be able to upload file” in {
val file = new File(getClass.getResource(“E:\\Excel\\1122 gr.xls”).toString)
val formData = Multipart.FormData.fromFile(“fileUpload”, ContentTypes.`application/octet-stream`, file, 100000)
Post(s”/api/file-upload”, formData).withHeaders(oauthHeader) ~> createPORoute -> check {
status shouldBe StatusCodes.OK
responseAs[String] contains “File successfully uploaded”
}
}

but am getting the issue

[info] – should be able to upload file *** FAILED ***
[info] java.lang.NullPointerException:
[info] at ExcelfileServiceSpec$$anonfun$1.apply$mcV$sp(ExcelfileServiceSpec.scala:34)
[info] at ExcelfileServiceSpec$$anonfun$1.apply(ExcelfileServiceSpec.scala:33)
[info] at ExcelfileServiceSpec$$anonfun$1.apply(ExcelfileServiceSpec.scala:33)
[info] at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
[info] at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
[info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
[info] at org.scalatest.Transformer.apply(Transformer.scala:22)
[info] at org.scalatest.Transformer.apply(Transformer.scala:20)
[info] at org.scalatest.FlatSpecLike$$anon$1.apply(FlatSpecLike.scala:1647)
[info] at org.scalatest.Suite$class.withFixture(Suite.scala:1122)

how can I resolve the above issue