{"id":416,"date":"2011-07-26T23:46:42","date_gmt":"2011-07-26T22:46:42","guid":{"rendered":"http:\/\/www.xenonique.co.uk\/blog\/?p=416"},"modified":"2011-07-29T23:54:58","modified_gmt":"2011-07-29T22:54:58","slug":"scalafication-of-an-equity-quote-application-part-3","status":"publish","type":"post","link":"https:\/\/www.xenonique.co.uk\/blog\/2011\/07\/26\/scalafication-of-an-equity-quote-application-part-3\/","title":{"rendered":"Scalafication of an Equity Quote Application Part 3"},"content":{"rendered":"

This is the final part in a series of article about porting an existing Java application to Scala. The application calls the Yahoo! Financial web service<\/strong><\/a> and retrieve stock quotes for the user, storing them in a local repository. The original Java project was described in the part one<\/a>.<\/p>\n

In the part two<\/a> of this series, we looked at the unit test, and in particular the behaviour driven development (BDD) styles in the ScalaTest framework.<\/p>\n

We will look at the Scala implementation of this business application. The easiest task is to simply convert the exceptions. Here are the Exceptions.scala<\/code> file:<\/p>\n

 <\/p>\n

\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nclass ConnectionException( msg: String, root: Exception ) \r\nextends RuntimeException( msg, root ) {\r\n   def this( msg: String ) = this( msg, null )\r\n}\r\n\r\nclass DataRetrievalException( msg: String, root: Exception ) \r\nextends RuntimeException( msg, root ) {\r\n   def this( msg: String ) = this( msg, null )\r\n}\r\n\r\nclass UnknownStockSymbolException( msg: String, root: Exception ) \r\nextends RuntimeException( msg, root ) {\r\n   def this( msg: String ) = this( msg, null )\r\n}\r\n<\/pre>\n
 <\/p>\n
We have more than one public class in a single source file. It is sort of allow Scala to look like a dynamic scripting language like Python or Ruby.<\/p>\n
Next, we port the quote repository over to Scala. We remove the semi-colons, reverse the declarations of the variable types on the way. We take advantage of Scala support for Option<\/code> types, we retrieve the stock quote by symbol name. The Scala library has two types of collections: immutable<\/em> and mutable<\/em>. By default, immutable collections are those that imported into the compiler as a predefinition. The QuoteRepositoryKeyValueStore <\/code> imports a mutable Map <\/code>collection for storing symbol associated with stock quotes.\u00a0<\/p>\n
Here is the QuoteRepository.scala<\/code> file:<\/p>\n
 <\/p>\n
\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nimport scala.collection.mutable.Map\r\n\r\ntrait QuoteRepository {\r\n  def isEmpty(): Boolean\r\n  def size(): Int\r\n  def clear(): Unit\r\n  def store( quote: StockQuote  ): Unit\r\n  def get( symbol: String ): Option[StockQuote] \r\n  def contains( symbol: String ): Boolean\r\n  def getSymbols(): List[String]\r\n}\r\n\r\nclass QuoteRepositoryKeyValueStore extends QuoteRepository {\r\n\r\n  private var store: Map[String, StockQuote] = Map()\r\n\r\n  def clear(): Unit = { store.clear() }\r\n\r\n  def contains(symbol: String): Boolean = store.contains(symbol)\r\n\r\n  def get(symbol: String ): Option[StockQuote] = store.get(symbol)\r\n\r\n  def isEmpty(): Boolean = store.isEmpty\r\n\t\r\n  def size(): Int = store.size\r\n\r\n  def store(quote: StockQuote ): Unit = {\r\n    store.put(quote.symbol, quote)\r\n  }\r\n\r\n  def getSymbols(): List[String] = {\r\n    \/\/ We use a tuple to iterate through the map, which return mutable list\r\n    \/\/ then we use "toList" to convert to an immutable list.\r\n    ( for ( (key,value ) <- store ) yield (key)  ).toList\r\n  }\r\n\r\n}\r\n<\/pre>\n
 <\/p>\n
In above implementation class, we can write, in Scala, methods such as size()<\/code> as one-liner methods. <\/p>\n
We can convert the Java stock quotes to a case class<\/strong> and get the benefits of an implicit equalsTo()<\/code>, hashCode()<\/code> and toString()<\/code> methods; and even get a handy copy()<\/code> method too. Note: That we override the definition of the toString()<\/code> class specifically for better formatting and, of course, debugging, but we did not need to do this for a case class.<\/p>\n
Here is the StockQuote.scala<\/code> file:<\/p>\n
 <\/p>\n
\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nimport java.math.RoundingMode\r\nimport java.math.BigDecimal\r\n\r\ncase class StockQuote( symbol: String, askPrice: BigDecimal, bidPrice: BigDecimal ) {\r\n\r\n  \/\/ Auxiliary (convenience) constructor\r\n  def this( symbol: String, askPriceStr: String, bidPriceStr: String ) =\r\n    this ( symbol, new BigDecimal(askPriceStr).setScale(2, RoundingMode.DOWN ), new BigDecimal(bidPriceStr).setScale(2, RoundingMode.DOWN ) )\r\n\r\n  \/\/ Auxiliary (copy) constructor\r\n  def this( ref: StockQuote ) = this ( ref.symbol, ref.askPrice, ref.bidPrice )\r\n\r\n  def meanPrice: BigDecimal = bidPrice.add( askPrice.subtract(bidPrice).divide( StockQuote.TWO ).setScale(2, RoundingMode.DOWN ) )\r\n\r\n  override def toString(): String = {\r\n    return "StockQuote [ symbol=" + symbol +", askPrice=" + askPrice +\r\n      ", bidPrice=" + bidPrice + ", meanPrice="+meanPrice+"]";\r\n  }\r\n}\r\n\r\nobject StockQuote {\r\n  def TWO = new BigDecimal("2.0")\r\n}\r\n<\/pre>\n
 <\/p>\n
The real hard part of the quote retriever service is get information from the Internet, by calling the web service. Luckily calling the Yahoo! Finance service is a simple REST GET request in comparison to other more complicated SOAP or REST web services.<\/p>\n
Here is the QuoteRetriever.scala<\/code> file:<\/p>\n
 <\/p>\n
\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nimport java.lang.NumberFormatException\r\nimport java.io._\r\nimport java.net._\r\n\r\ntrait QuoteRetriever {\r\n  def getStockQuote( symbol: String ): StockQuote\r\n}\r\n\r\nobject QuoteRetrieverYahooImpl {\r\n   val TOKEN_SYMBOL="@SYMBOL@"\r\n   val DEFAULT_URL_FRAGMENT="https:\/\/finance.yahoo.com\/d\/quotes.csv?s="+TOKEN_SYMBOL+"&f=sb2b3"\r\n\r\n}\r\n\r\nclass QuoteRetrieverYahooImpl( var urlFragment: String = QuoteRetrieverYahooImpl.DEFAULT_URL_FRAGMENT ) \r\nextends QuoteRetriever {\r\n  \r\n  def getStockQuote( symbol: String ): StockQuote = {\r\n\r\n    val queryUrl: String = urlFragment.replace(QuoteRetrieverYahooImpl .TOKEN_SYMBOL, symbol)\r\n\r\n    try {\r\n      val url: URL = new URL( queryUrl )\r\n      val connection: HttpURLConnection  = url.openConnection().asInstanceOf[HttpURLConnection]\r\n      connection.setRequestMethod("GET")\r\n      connection.connect()\r\n\r\n      val is: InputStream = connection.getInputStream()\r\n      val reader: BufferedReader = new BufferedReader( new InputStreamReader(is) )\r\n\r\n      try {\r\n        val line = reader.readLine()\r\n        if ( line != null ) {\r\n          val tokens = line.split(",").toList\r\n          if ( tokens.length < 3 ) {\r\n            throw new DataRetrievalException(\r\n              "Data service at URL=["+queryUrl+"] does not supply enough fields (3 != "+tokens.length+")")\r\n          }\r\n          var stockSymbol = tokens(0)\r\n          if ( stockSymbol.length() > 0 &&\r\n              stockSymbol.charAt(0) == '"' && stockSymbol.charAt(stockSymbol.length()-1) == '"') {\r\n            stockSymbol = stockSymbol.substring(1, stockSymbol.length()-1 )\r\n          }\r\n          val askPrice = tokens(1)\r\n          if ( "N\/A".equals(askPrice)) {\r\n            throw new UnknownStockSymbolException(\r\n              "Unknown stock quote symbol ["+stockSymbol+"] price not available")\r\n          }\r\n          val bidPrice = tokens(2)\r\n          if ( "N\/A".equals(bidPrice)) {\r\n            throw new UnknownStockSymbolException(\r\n              "Unknown stock quote symbol ["+stockSymbol+"] price not available")\r\n          }\r\n\r\n          try {\r\n            return new StockQuote(stockSymbol, askPrice, bidPrice)\r\n          }\r\n          catch {\r\n            case e:NumberFormatException =>\r\n              throw new DataRetrievalException(\r\n                "Unable to read numerical data from quote service URL=["+queryUrl+"]", e)\r\n          }\r\n        }\r\n        else {\r\n          throw new DataRetrievalException(\r\n            "Data unavailable from quote service URL=["+queryUrl+"]")\r\n        }\r\n      }\r\n      finally  {\r\n        if ( reader != null) {\r\n          try {\r\n            reader.close()\r\n          }\r\n          catch  {\r\n            case e: IOException => null\r\n          }\r\n        }\r\n        if ( is != null) {\r\n          try {\r\n            is.close()\r\n          } \r\n          catch {\r\n            case e: IOException => null\r\n          }\r\n        }\r\n      }\r\n    }\r\n    catch {\r\n      case e: MalformedURLException  =>\r\n        throw new ConnectionException("unable to connect to the remote quote service URL=["+queryUrl+"]", e)\r\n\r\n      case e: IOException =>\r\n        throw new ConnectionException("I\/O failure reading service URL=["+queryUrl+"]", e)\r\n    }\r\n  }\r\n}\r\n<\/pre>\n
 <\/p>\n
Effectively, we could have left the QuoteRetriever<\/code> as a simple Java interface, because we gained nothing. If however we wanted to define a default implementation in a Scala trait we could do so, where it would be not possible with the current version of Java 6 \/ 7.<\/p>\n
We make use of the companion object QuoteRetrieverYahooImpl<\/code> to define Scala constants. Essentially this would be same as declaring a Java variable as public final static String<\/code>.<\/p>\n
Inside the QuoteRetrieverYahooImpl<\/code> class, let us look at the implementation method getStockQuote()<\/code>. We chucked away Java standard library StringTokenizer<\/code> and replaced it with the nicer Scala equivalent. We split a String into Array[String]<\/code> of fragments using the split<\/code> method, and then convert the array into a list collection by calling toList<\/code>. Since Scala 2.8, these methods toList()<\/code>, toSet()<\/code> and toArray()<\/code> are ubiquitous across the Scala collections.<\/p>\n
There is probably a more object functional way of building the temporary variables using functions and closures, however for intermediate Java developer this is easier to follow. The rest of the code is just boiler plate to tackle the exception handling of the Java I\/O library. See the last part of this article for an improvement.<\/p>\n
Last, but not least is the main application class in the StockQuoteApp.scala<\/code> file.<\/p>\n
 <\/p>\n
\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nimport java.lang.System\r\n\r\nclass StockQuoteApp( retriever: QuoteRetriever, repo: QuoteRepository ) {\r\n  \r\n\r\n  def this() = this( new QuoteRetrieverYahooImpl(), new QuoteRepositoryKeyValueStore() )\r\n\r\n  def doInteractive(): Unit = {\r\n\r\n    println("=======================================================")\r\n    println("   Welcome Peter Pilgrim's Stock Quote Application")\r\n    println("=======================================================")\r\n\r\n    var quit = false\r\n    while ( !quit) {\r\n      println("Type in a stock symbol or `:repo' to list the repository or `:quit' to quit")\r\n      println("or `:clear' to clear the repository")\r\n      var line = readLine("$ ")\r\n      if ( line != "" ) {\r\n        line = line.trim()\r\n        if ( line.startsWith(":r") || line.startsWith(":p")) {\r\n          val symbols  = repo.getSymbols()\r\n          printf("%10s  %9s %9s %9s\\n", "SYMBOL", "MEAN", "ASK", "BID")\r\n          printf("%10s  %9s %9s %9s\\n", "--------", "------", "-----", "-----")\r\n          for ( symbol <- symbols ) {\r\n            val quote = repo.get(symbol).get\r\n            printf("%10s: %9.2f %9.2f %9.2f\\n", quote.symbol, quote.meanPrice, quote.askPrice, quote.bidPrice )\r\n          }\r\n        }\r\n        else if ( line.startsWith(":c")) {\r\n          repo.clear()\r\n          println("Repository cleared.")\r\n        }\r\n        else if ( line.startsWith(":q")) {\r\n          quit = true\r\n        }\r\n        else {\r\n          if ( line.length() > 0 ) {\r\n            try {\r\n              val quote = findAndUpdateStockQuote(line)\r\n              printf("%s: %7.2f\\n", quote.symbol, quote.meanPrice)\r\n            }\r\n            catch {\r\n              case e:ConnectionException =>\r\n                System.err.println("CONNECTION ERROR : "+e.getMessage())\r\n\r\n              case e: UnknownStockSymbolException =>\r\n                System.err.println("STOCK SYMBOL NOT FOUND : "+e.getMessage())\r\n            }\r\n          }\r\n        }\r\n      }\r\n    }\r\n\r\n    \/\/ Prints name and age to the console\r\n    println("Goodbye.")\r\n  }\r\n\r\n\r\n  def  findAndUpdateStockQuote(symbol: String): StockQuote = {\r\n    val quote = retriever.getStockQuote(symbol)\r\n    repo.store(quote)\r\n    quote\r\n  }\r\n\r\n}\r\n\r\nobject StockQuoteApp {\r\n  val CONNECTION_PROPERTIES_FILENAME: String = "connection.properties"\r\n\r\n  def main( args: Array[String] ): Unit = {\r\n    println("Hello world. This is the Scala application!")\r\n    new StockQuoteApp().doInteractive\r\n  }\r\n}\r\n<\/pre>\n
 <\/p>\n
It should be fairly self-explanatory that this program is interactive one. It reads a symbol at the command line and invokes the quote retriever to find the stock quote for the symbol.<\/p>\n
There is one other improvement to QuoteRetrieverYahooImpl<\/code> we could make use of. Scala supports function objects; functions calling other functions and returning a different (or the same input) function. Scala methods on class or object types can have more than one parameter list in order to support currying<\/em> of parameters. Scala language has the feature of partial functions that enable this facility.<\/p>\n
Here is a class called TryResource<\/code>, which closes an InputStream<\/code> resource.<\/p>\n
 <\/p>\n
\r\npackage uk.co.xenonique.stockquoteapp_scala\r\n\r\nimport java.io.InputStream\r\nimport java.io.FileInputStream\r\nimport java.io.InputStreamReader\r\nimport java.io.BufferedReader\r\nimport java.io.IOException\r\nimport java.lang.System\r\n\r\n\/\/ Needs to be generic\r\nclass TryResource[T <: InputStream]( inputStream: T ) {\r\n\r\n  private val is: T = inputStream\r\n\r\n  def execute( body: ( InputStream => Unit ) ): Unit = {\r\n    try {\r\n      body(is)\r\n    }\r\n    finally {\r\n      if ( is != null ) {\r\n        try {\r\n          is.close()\r\n        }\r\n        catch {\r\n          case e:IOException => System.err.println(e)\r\n        }\r\n      }\r\n    }\r\n  }\r\n}\r\n\r\nobject TryResource {\r\n\r\n  def tryResource[T <: InputStream]( inputStream: T )( body: ( InputStream => Unit ) ) {\r\n    val construct = new TryResource( inputStream)\r\n    construct.execute( body )\r\n  }\r\n\r\n  def demo1() {\r\n    val construct = new TryResource( new FileInputStream("pom.xml") )\r\n    construct.execute( (is: InputStream ) => {\r\n      val reader = new BufferedReader( new InputStreamReader(is))\r\n      var count = 1\r\n      var line: String = null\r\n      do {\r\n          line = reader.readLine()\r\n          if ( line != null ) {\r\n            printf("demo1 %5d %s\\n", count, line)\r\n            count = count + 1\r\n          }\r\n      }\r\n      while ( line != null  )\r\n    } )\r\n    println("==== Done it ====")\r\n  }\r\n\r\n  def demo2() {\r\n    tryResource ( new FileInputStream("pom.xml") ) ( ( is: InputStream ) =>  {\r\n      val reader = new BufferedReader( new InputStreamReader(is))\r\n      var count = 1\r\n      var line: String = null\r\n      do {\r\n          line = reader.readLine()\r\n          if ( line != null ) {\r\n            printf("demo2 %5d %s\\n", count, line)\r\n            count = count + 1\r\n          }\r\n      }\r\n      while ( line != null  )\r\n    } )\r\n    println("==== Done it ====")\r\n  }\r\n\r\n  def main( args: Array[String]): Unit = {\r\n    demo2()\r\n  }\r\n}\r\n<\/pre>\n
 <\/p>\n
The method tryResource<\/code> takes two parameter lists. The first parameter list is a argument list of one, the input stream resource. The second parameter list is also a argument of one, except it is a so-called called-by-name<\/em> type, by which the function call is delayed, evaluated after<\/em> inside the method. In other words, we call tryResource()()<\/code> by passing a block of code that operates on the InputStream<\/code> and the library function will automatically close the resource for us, regardless of whether block of code completes with normal or abnormal termination. Java 7 now has a similar acquire-release mechanism as a language feature, whereas in Scala, we implemented this a library feature. Scala is scalable language after all.<\/p>\n
It would be straight forward now to use tryResource<\/code> in the QuoteRetrieverYahooImpl<\/code> directly. This is an exercise for you, the reader. Hint: You should have a good read about Scala’s structured types!<\/p>\n
Good Luck!<\/p>\n","protected":false},"excerpt":{"rendered":"
This is the final part in a series of article about porting an existing Java application to Scala. The application calls the Yahoo! Financial web service and retrieve stock quotes for the user, storing them in a local repository. The original Java project was described in the part one. In the part two of this […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[50,37,44,40,6,105],"tags":[],"_links":{"self":[{"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/posts\/416"}],"collection":[{"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/comments?post=416"}],"version-history":[{"count":5,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/posts\/416\/revisions"}],"predecessor-version":[{"id":421,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/posts\/416\/revisions\/421"}],"wp:attachment":[{"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/media?parent=416"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/categories?post=416"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.xenonique.co.uk\/blog\/wp-json\/wp\/v2\/tags?post=416"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}