CatsChainedSimulation.scala

package mock

import com.intuit.karate.gatling.PreDef._
import io.gatling.core.Predef._

import scala.concurrent.duration._
import scala.util.Random

class CatsChainedSimulation extends Simulation {

  MockUtils.startServer(0)

  val protocol = karateProtocol(
    "/cats/{id}" -> Nil
  )

  val feeder = Iterator.continually(Map("name" -> (Random.alphanumeric.take(20).mkString + "-name")))

  val feederToKarate = scenario("feederToKarate")
    .exec(karateSet("name", session => session("name").as[String]))

  val create = scenario("create").exec(karateFeature("classpath:mock/cats-chained.feature@name=create"))

  val read = scenario("read").exec(karateFeature("classpath:mock/cats-chained.feature@name=read")).exec(session => {
    println("*** id in gatling: " + session("id").as[String])
    println("*** session status in gatling: " + session.status)
    session
  })

  val createAndRead = scenario("createAndRead").group("createAndRead") {
    feed(feeder)
      .exec(feederToKarate)
      .exec(create)
      // for demo: injecting a new variable name expected by the 'read' feature
      .exec(karateSet("expectedName", session => session("name").as[String]))
      .exec(read)
  }

  setUp(
    createAndRead.inject(rampUsers(10) during (5 seconds)).protocols(protocol)
  ).assertions(details("createAndRead").failedRequests.percent.is(0))

}