update version

Karasiq · Mar 10, 2016 · 801d5d7 · 801d5d7
1 parent 7d6b352
commit 801d5d7
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 5 deletions.
diff --git a/README.MD b/README.MD
@@ -1,4 +1,4 @@
-# nanoboard [![Build Status](https://travis-ci.org/Karasiq/nanoboard.svg?branch=master)](https://travis-ci.org/Karasiq/nanoboard) [![Build status](https://ci.appveyor.com/api/projects/status/05l8dnixhn375kjm?svg=true)](https://ci.appveyor.com/project/Karasiq/nanoboard) [![Version](http://img.shields.io/badge/version-1.0.5-blue.svg?style=flat)](https://github.com/Karasiq/nanoboard/releases)
+# nanoboard [![Build Status](https://travis-ci.org/Karasiq/nanoboard.svg?branch=master)](https://travis-ci.org/Karasiq/nanoboard) [![Build status](https://ci.appveyor.com/api/projects/status/05l8dnixhn375kjm?svg=true)](https://ci.appveyor.com/project/Karasiq/nanoboard) [![Version](http://img.shields.io/badge/version-1.0.6-blue.svg?style=flat)](https://github.com/Karasiq/nanoboard/releases)
 Scala [nanoboard](https://github.com/nanoboard/nanoboard) implementation
 
 # Links

diff --git a/build.sbt b/build.sbt
@@ -2,7 +2,7 @@ import sbtassembly.Plugin.AssemblyKeys._
 
 lazy val commonSettings = Seq(
   organization := "com.github.karasiq",
-  version := "1.0.5",
+  version := "1.0.6",
   isSnapshot := version.value.endsWith("SNAPSHOT"),
   scalaVersion := "2.11.7"
 )

diff --git a/library/src/main/resources/reference.conf b/library/src/main/resources/reference.conf
@@ -1,5 +1,5 @@
 nanoboard {
-  version = 1.0.5
+  version = 1.0.6
   client-version = karasiq-nanoboard v${nanoboard.version}
   encryption-key = "nano"
   bitmessage {

diff --git a/library/src/main/scala/com/karasiq/nanoboard/sources/png/BoardPngSource.scala b/library/src/main/scala/com/karasiq/nanoboard/sources/png/BoardPngSource.scala
@@ -26,12 +26,14 @@ class BoardPngSource(encoding: DataEncodingStage)(implicit as: ActorSystem, am:
         val decoded: String = encoding.decode(data).utf8String
         NanoboardMessage.parseMessages(decoded)
       }
+      .recoverWith { case _ ⇒ Source.empty }
   }
 
   def imagesFromPage(url: String): Source[String, akka.NotUsed] = {
     Source.fromFuture(http.singleRequest(HttpRequest(uri = url)))
       .flatMapConcat(_.entity.dataBytes.fold(ByteString.empty)(_ ++ _))
       .flatMapConcat(data ⇒ imagesFromPage(Jsoup.parse(data.utf8String, url)))
+      .recoverWith { case _ ⇒ Source.empty }
   }
 
   protected def imagesFromPage(page: Document): Source[String, akka.NotUsed] = {

diff --git a/setup/setup.iss b/setup/setup.iss
@@ -1,6 +1,6 @@
 #define OutputName "nanoboard-server"
 #define MyAppName "Nanoboard"
-#define MyAppVersion "1.0.5"
+#define MyAppVersion "1.0.6"
 #define MyAppPublisher "Karasiq, Inc."
 #define MyAppURL "http://www.github.com/Karasiq/nanoboard"
 #define MyAppExeName "nanoboard.exe"

diff --git a/src/main/scala/com/karasiq/nanoboard/server/streaming/NanoboardMessageStream.scala b/src/main/scala/com/karasiq/nanoboard/server/streaming/NanoboardMessageStream.scala
@@ -66,8 +66,9 @@ private[server] final class NanoboardMessageStream extends GraphStage[FanInShape
 }
 
 private[server] object NanoboardMessageStream {
+  import NanoboardEvent._
   import NanoboardSubscription._
-
+  
   def flow = Flow.fromGraph(GraphDSL.create() { implicit b: GraphDSL.Builder[akka.NotUsed] ⇒
     import GraphDSL.Implicits._
     val in = b.add {