#94 mockito up

yegor256 · Aug 5, 2020 · 7ded4bd · 7ded4bd
1 parent bc3a0a7
commit 7ded4bd
Show file tree

Hide file tree

Showing 7 changed files with 163 additions and 164 deletions.
diff --git a/nginx.conf.sigil b/nginx.conf.sigil
diff --git a/pom.xml b/pom.xml
@@ -33,7 +33,7 @@ OF THE POSSIBILITY OF SUCH DAMAGE.
   <parent>
     <groupId>com.jcabi</groupId>
     <artifactId>parent</artifactId>
-    <version>0.50.6</version>
+    <version>0.50.7</version>
   </parent>
   <groupId>io.wring</groupId>
   <artifactId>wring</artifactId>
@@ -100,6 +100,11 @@ OF THE POSSIBILITY OF SUCH DAMAGE.
       <artifactId>sentry</artifactId>
       <version>1.3.0</version>
     </dependency>
+    <dependency>
+      <groupId>com.github.pengrad</groupId>
+      <artifactId>java-telegram-bot-api</artifactId>
+      <version>4.9.0</version>
+    </dependency>
     <dependency>
       <groupId>jakarta.xml.bind</groupId>
       <artifactId>jakarta.xml.bind-api</artifactId>

diff --git a/src/main/java/io/wring/agents/Cycle.java b/src/main/java/io/wring/agents/Cycle.java
@@ -29,6 +29,7 @@
  */
 package io.wring.agents;
 
+import com.pengrad.telegrambot.TelegramBot;
 import io.wring.model.Base;
 import io.wring.model.Events;
 import io.wring.model.Pipe;
@@ -58,12 +59,26 @@ final class Cycle implements Proc<Pipe> {
      */
     private final transient Base base;
 
+    /**
+     * Telegram.
+     */
+    private final transient TelegramBot telegram;
+
     /**
      * Ctor.
      * @param bse Base
      */
     Cycle(final Base bse) {
+        this(bse, new TelegramBot(""));
+    }
+
+    /**
+     * Ctor.
+     * @param bse Base
+     */
+    Cycle(final Base bse, final TelegramBot bot) {
         this.base = bse;
+        this.telegram = bot;
     }
 
     @Override
@@ -91,7 +106,14 @@ json, new TextOf(new BytesOf(error)).asString()
                     if (obj != null) {
                         new Exec(
                             new JsonAgent(this.base, obj),
-                            new IgnoreEvents(new BoostEvents(events, obj), obj),
+                            new IgnoreEvents(
+                                new TelegramEvents(
+                                    new BoostEvents(events, obj),
+                                    this.telegram,
+                                    obj
+                                ),
+                                obj
+                            ),
                             pipe
                         ).run();
                     }

diff --git a/src/main/java/io/wring/agents/Routine.java b/src/main/java/io/wring/agents/Routine.java
@@ -33,6 +33,10 @@
 import com.jcabi.log.VerboseRunnable;
 import com.jcabi.log.VerboseThreads;
 import com.jcabi.manifests.Manifests;
+import com.pengrad.telegrambot.TelegramBot;
+import com.pengrad.telegrambot.UpdatesListener;
+import com.pengrad.telegrambot.model.Update;
+import com.pengrad.telegrambot.request.SendMessage;
 import io.sentry.Sentry;
 import io.wring.model.Base;
 import io.wring.model.Pipe;
@@ -86,6 +90,11 @@ public final class Routine implements Callable<Integer>, AutoCloseable {
      */
     private final transient ExecutorService executor;
 
+    /**
+     * Telegram.
+     */
+    private final transient TelegramBot telegram;
+
     /**
      * Ctor.
      * @param bse Base
@@ -115,12 +124,25 @@ public Routine(final Base bse, final int total) {
                 )
             )
         );
+        this.telegram = new TelegramBot(Manifests.read("Wring-TelegramToken"));
     }
 
     /**
      * Start it.
      */
     public void start() {
+        this.telegram.setUpdatesListener(updates -> {
+            for (final Update update : updates) {
+                final long chat = update.message().chat().id();
+                this.telegram.execute(
+                    new SendMessage(
+                        chat,
+                        String.format("Your chat ID is %d", chat)
+                    )
+                );
+            }
+            return UpdatesListener.CONFIRMED_UPDATES_ALL;
+        });
         Sentry.init(Manifests.read("Wring-SentryDsn"));
         this.ticker.scheduleWithFixedDelay(
             new VerboseRunnable(
@@ -237,7 +259,7 @@ private static void close(final ExecutorService svc)
     private Runnable job(final Pipe pipe) {
         return new RunnableOf<>(
             new FuncWithFallback<Pipe, Boolean>(
-                new FuncOf<>(new Cycle(this.base)),
+                new FuncOf<>(new Cycle(this.base, this.telegram)),
                 new FuncOf<>(
                     error -> {
                         Sentry.capture(error);