From 9acceabdbdbcc00dfab242e6c8dd4becc9dc7e5d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Maciej=20Pr=C3=B3chniak?= <mpr@touk.pl>
Date: Mon, 27 Apr 2020 16:16:46 +0200
Subject: [PATCH] [Demo] random errors in MeetingService - to test metrics
 (#887)

---
 .../sample/service/MeetingService.scala        | 18 ++++++++++++++----
 .../src/universal/conf/dev-application.conf    |  3 ++-
 2 files changed, 16 insertions(+), 5 deletions(-)

diff --git a/engine/flink/management/sample/src/main/scala/pl/touk/nussknacker/engine/management/sample/service/MeetingService.scala b/engine/flink/management/sample/src/main/scala/pl/touk/nussknacker/engine/management/sample/service/MeetingService.scala
index dc20acda665..4f5340efe88 100644
--- a/engine/flink/management/sample/src/main/scala/pl/touk/nussknacker/engine/management/sample/service/MeetingService.scala
+++ b/engine/flink/management/sample/src/main/scala/pl/touk/nussknacker/engine/management/sample/service/MeetingService.scala
@@ -7,10 +7,14 @@ import com.cronutils.model.Cron
 import javax.annotation.Nullable
 import pl.touk.nussknacker.engine.api.editor.{DualEditor, DualEditorMode, SimpleEditor, SimpleEditorType}
 import pl.touk.nussknacker.engine.api.{MethodToInvoke, ParamName, Service}
+import pl.touk.nussknacker.engine.flink.util.service.TimeMeasuringService
 
-import scala.concurrent.Future
+import scala.concurrent.{ExecutionContext, Future}
+
+object MeetingService extends Service with Serializable with TimeMeasuringService {
+
+  override protected def serviceName: String = "meetingService"
 
-object MeetingService extends Service with Serializable {
   @MethodToInvoke
   def invoke(@ParamName("Date") date: LocalDateTime,
              @ParamName("EndTime") endTime: LocalTime,
@@ -47,6 +51,12 @@ object MeetingService extends Service with Serializable {
              )
              @Nullable
              cronScheduler: Cron
-            ): Future[Unit]
-  = Future.successful(Unit)
+            )(implicit ec: ExecutionContext): Future[Unit] = measuring {
+              Thread.sleep((math.random * 10).toLong)
+              if (math.random < 0.25) {
+                Future.failed(new IllegalArgumentException("Bad luck, your meeting failed..."))
+              } else {
+                Future.successful(())
+              }
+  }
 }
diff --git a/nussknacker-dist/src/universal/conf/dev-application.conf b/nussknacker-dist/src/universal/conf/dev-application.conf
index c21d33872ac..245c7b897b8 100644
--- a/nussknacker-dist/src/universal/conf/dev-application.conf
+++ b/nussknacker-dist/src/universal/conf/dev-application.conf
@@ -2,7 +2,8 @@
 
 base: { include "base-application.conf" }
 
-environment: "test"
+//to be consistent with docker/demo
+environment: "demo"
 
 categoriesConfig: {
   "FraudDetection": "streaming-demo",