vdichev

import scala.actors._
import Actor._

for (i <- 1 to 500) actor {
  println("Starting actor... " + i)
  Thread.sleep(5000L)
}

vdichev

import scala.actors._
import Actor._

case object DoIt

val worker = actor {
  loop {
    react {
      case DoIt => println("Time for work at " + new java.util.Date())
    }

vdichev

JettyTestServer.start

val baseUrl = "/twitter"

vdichev

  implicit val reportError = new ReportFailure {
    def fail(msg: String): Nothing = TwitterAPISpecs.this.fail(msg)
  }

vdichev

for {
  login <- get("/account/verify_credentials.xml", httpClient, Nil)
    !@ "Failed to log in"
  message <- login.post("/statuses/update.xml", "status" -> "test_msg1")
    !@ "Couldn't post message"
  xml <- message.xml
} {
  // Specs' xml matcher
  xml must \\(<text>test_msg1</text>)
}

vdichev

get("/account/verify_credentials.xml")
  ! (401, "Login should fail with Unauthorized status")

vdichev

  override def theHttpClient = {
    val theClient = buildBasicAuthClient(userName, password)
    theClient.getParams.setAuthenticationPreemptive(true)
    theClient
  }

vdichev

  trait XmlResponse {
    self: TestResponse =>
    def xmlMatch(f: Elem => Unit)
                (implicit errorFunc: ReportFailure): TestResponse = {
      if (this.asInstanceOf[SelfType].code != 200)
        errorFunc.fail("Response status is not 200!")
      xml match {
        case Full(xml) => f(xml); this
        case _ => errorFunc.fail("Response contains no XML!")
      }

vdichev

for {
  message <- post("/statuses/update.xml", "status" -> "test_msg1")
    !@ "Couldn't post message" if message.xml must notBeEmpty
  xml <- message.xml
} {
  xml must \\(<text>test_msg1</text>)
}

vdichev

post("/statuses/update.xml", "status" -> "test_msg1")
  \\(<text>test_msg1</text>)
  \\(<screen_name>vdichev</screen_name>)
get("/statuses/public_timeline.xml") \\(<text>test_msg1</text>)
get("/statuses/user_timeline.xml") \\(<text>test_msg1</text>)
get("/statuses/home_timeline.xml") \\(<text>test_msg1</text>)