#3 change sessions impl

.gitignore

@@ -3,6 +3,9 @@ target/
 !**/src/main/**/target/
 !**/src/test/**/target/
 
+# maven shade plugin
+dependency-reduced-pom.xml
+
 ### STS ###
 .apt_generated
 .classpath
@@ -17,3 +20,4 @@ target/
 *.iws
 *.iml
 *.ipr
+

LICENSE.txt

@@ -0,0 +1,202 @@
+
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright (c) 2021 Ruslan Penkrat <penkrat@gmail.com>
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.

pom.xml

@@ -6,10 +6,24 @@
 
     <groupId>ru.penkrat.stbf</groupId>
     <artifactId>stbf-parent</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
+    <version>0.0.2-SNAPSHOT</version>
     <name>stbf-parent</name>
 
     <description>Simple Telegram Bot Facade</description>
+
+    <scm>
+        <connection>scm:git:https://git.penkrat.ru/ruslan/stbf.git</connection>
+        <developerConnection>scm:git:https://git.penkrat.ru/ruslan/stbf.git</developerConnection>
+      <tag>HEAD</tag>
+  </scm>
+
+    <licenses>
+        <license>
+            <name>Apache License, Version 2.0</name>
+            <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
+        </license>
+    </licenses>
+
     <properties>
         <java.version>1.8</java.version>
         <lombok.version>1.18.6</lombok.version>
@@ -23,6 +37,7 @@
         <module>stbf-common</module>
         <module>stbf-rubenlagus</module>
         <module>stbf-templates</module>
+        <module>stbf-demo</module>
     </modules>
 
     <dependencies>
@@ -50,6 +65,11 @@
                     <target>${java.version}</target>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-release-plugin</artifactId>
+                <version>3.0.0-M4</version>
+            </plugin>
         </plugins>
     </build>
 

stbf-api/pom.xml

@@ -1,13 +1,11 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 
 	<parent>
 		<groupId>ru.penkrat.stbf</groupId>
 		<artifactId>stbf-parent</artifactId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
   	</parent>
 
 	<artifactId>stbf-api</artifactId>

stbf-api/src/main/java/ru/penkrat/stbf/api/Action.java

@@ -7,7 +7,7 @@ import lombok.ToString;
 
 @Getter
 @Builder
-@ToString(of = "text")
+@ToString(of = {"text", "inline"})
 public class Action {
 
     public static Action simple(String text) {

stbf-api/src/main/java/ru/penkrat/stbf/api/BotCommandChain.java

@@ -1,6 +1,7 @@
 package ru.penkrat.stbf.api;
 
 import java.util.ArrayList;
+import java.util.Collection;
 import java.util.List;
 
 import lombok.AccessLevel;
@@ -22,7 +23,7 @@ public class BotCommandChain implements CommandChain {
 		if (!commands.isEmpty()) {
 			try {
 				Command command = commands.get(0);
-				log.debug("Run command {}", command.getClass().getSimpleName());
+				log.debug("Run command {} ({})", command.getClass().getSimpleName(), command);
 				command.process(botRequest, botResponse,
 						new BotCommandChain(commands.subList(1, commands.size())));
 			} catch (Exception e) {
@@ -36,4 +37,9 @@ public class BotCommandChain implements CommandChain {
 		return this;
 	}
 
+	public BotCommandChain addAll(Collection<Command> cmds) {
+		commands.addAll(cmds);
+		return this;
+	}
+
 }

stbf-api/src/main/java/ru/penkrat/stbf/api/BotRequest.java

@@ -14,4 +14,5 @@ public interface BotRequest {
 
 	Long getChatId();
 
+	BotSession getSession();
 }

stbf-api/src/main/java/ru/penkrat/stbf/api/BotSession.java

@@ -0,0 +1,9 @@
+package ru.penkrat.stbf.api;
+
+public interface BotSession {
+
+    Object getAttribute(String name);
+
+    void setAttribute(String name, Object value);
+
+}

stbf-api/src/main/java/ru/penkrat/stbf/api/Media.java

@@ -0,0 +1,31 @@
+package ru.penkrat.stbf.api;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.ToString;
+
+import java.util.function.Consumer;
+import java.util.function.Supplier;
+
+@Getter
+@Builder
+@ToString(of = {"mediaType", "url"})
+public class Media {
+
+    private MediaType mediaType;
+
+    private String url;
+
+    private String fileId;
+
+    private Supplier<byte[]> data;
+
+    private Integer duration;
+
+    private Integer width;
+
+    private Integer height;
+
+    private Consumer<String> fileIdConsumer;
+
+}

stbf-api/src/main/java/ru/penkrat/stbf/api/MediaType.java

@@ -0,0 +1,9 @@
+package ru.penkrat.stbf.api;
+
+public enum MediaType {
+    ANIMATION,
+    AUDIO,
+    PHOTO,
+    VIDEO,
+    VOICE
+}

stbf-api/src/main/java/ru/penkrat/stbf/api/RequestMatcher.java

@@ -1,8 +1,20 @@
 package ru.penkrat.stbf.api;
 
+import java.util.Objects;
+
 @FunctionalInterface
 public interface RequestMatcher {
 
     boolean match(BotRequest botRequest);
 
+    default RequestMatcher or(RequestMatcher other) {
+        Objects.requireNonNull(other);
+        return (botRequest) -> match(botRequest) || other.match(botRequest);
+    }
+
+    default RequestMatcher and(RequestMatcher other) {
+        Objects.requireNonNull(other);
+        return (botRequest) -> match(botRequest) && other.match(botRequest);
+    }
+
 }

stbf-api/src/main/java/ru/penkrat/stbf/api/Screen.java

@@ -4,6 +4,10 @@ public interface Screen {
 
     String getText();
 
+    default Media getMedia() {
+        return null;
+    }
+
     default Keyboard getKeyboard() {
         return null;
     }

stbf-api/src/main/java/ru/penkrat/stbf/api/SessionProvider.java

@@ -0,0 +1,8 @@
+package ru.penkrat.stbf.api;
+
+@FunctionalInterface
+public interface SessionProvider {
+
+    BotSession get(Long chatId);
+
+}

stbf-common/pom.xml

@@ -1,12 +1,10 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<artifactId>stbf-parent</artifactId>
 		<groupId>ru.penkrat.stbf</groupId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
 	</parent>
 
 	<artifactId>stbf-common</artifactId>
@@ -16,7 +14,7 @@
 		<dependency>
 			<groupId>ru.penkrat.stbf</groupId>
 			<artifactId>stbf-api</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>0.0.2-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>junit</groupId>

stbf-common/src/main/java/ru/penkrat/stbf/common/command/AbstractActionCommand.java

@@ -12,6 +12,10 @@ public abstract class AbstractActionCommand implements Command {
 
 	private RequestMatcher matcher;
 
+	public AbstractActionCommand(RequestMatcher matcher) {
+		this.matcher = matcher;
+	}
+
 	public AbstractActionCommand(Action action) {
 		matcher = RequestMatchers.action(action);
 	}

stbf-common/src/main/java/ru/penkrat/stbf/common/command/SessionAwareCommandChain.java

@@ -0,0 +1,20 @@
+package ru.penkrat.stbf.common.command;
+
+import lombok.RequiredArgsConstructor;
+import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotResponse;
+import ru.penkrat.stbf.api.CommandChain;
+import ru.penkrat.stbf.api.SessionProvider;
+import ru.penkrat.stbf.common.session.SessionAwareBotRequest;
+
+@RequiredArgsConstructor
+public class SessionAwareCommandChain implements CommandChain {
+
+	private final CommandChain delegate;
+	private final SessionProvider sessionProvider;
+
+	@Override
+	public void processCommand(BotRequest botRequest, BotResponse botResponse) {
+		delegate.processCommand(new SessionAwareBotRequest(botRequest, sessionProvider), botResponse);
+	}
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/command/SimpleCommand.java

@@ -1,5 +1,6 @@
 package ru.penkrat.stbf.common.command;
 
+import lombok.RequiredArgsConstructor;
 import ru.penkrat.stbf.api.Action;
 import ru.penkrat.stbf.api.BotRequest;
 import ru.penkrat.stbf.api.BotResponse;
@@ -10,6 +11,7 @@ import ru.penkrat.stbf.api.Screen;
 import ru.penkrat.stbf.common.screen.TextScreen;
 import ru.penkrat.stbf.tools.RequestMatchers;
 
+@RequiredArgsConstructor
 public class SimpleCommand implements Command {
 
 	private final RequestMatcher matcher;

stbf-common/src/main/java/ru/penkrat/stbf/common/command/ThreadPolledCommandChain.java

@@ -0,0 +1,31 @@
+package ru.penkrat.stbf.common.command;
+
+import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotResponse;
+import ru.penkrat.stbf.api.CommandChain;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+public class ThreadPolledCommandChain implements CommandChain {
+
+	private final CommandChain delegate;
+	private final ExecutorService executor;
+
+	public ThreadPolledCommandChain(CommandChain delegate) {
+		this(delegate, 4);
+	}
+
+	public ThreadPolledCommandChain(CommandChain delegate, int nThreads) {
+		this.delegate = delegate;
+		this.executor = Executors.newFixedThreadPool(nThreads);
+	}
+
+	@Override
+	public void processCommand(BotRequest botRequest, BotResponse botResponse) {
+		executor.execute(() -> {
+			delegate.processCommand(botRequest, botResponse);
+		});
+	}
+
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/screen/MediaScreen.java

@@ -0,0 +1,23 @@
+package ru.penkrat.stbf.common.screen;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import ru.penkrat.stbf.api.Keyboard;
+import ru.penkrat.stbf.api.Media;
+import ru.penkrat.stbf.api.Screen;
+
+@Getter
+@RequiredArgsConstructor
+public class MediaScreen implements Screen {
+
+    private final String text;
+
+    private final Media media;
+
+    private final Keyboard keyboard;
+
+    public MediaScreen(String text, Media media) {
+        this(text, media, null);
+    }
+
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/screen/RamFileIdStorageMediaScreen.java

@@ -0,0 +1,85 @@
+package ru.penkrat.stbf.common.screen;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import ru.penkrat.stbf.api.Keyboard;
+import ru.penkrat.stbf.api.Media;
+import ru.penkrat.stbf.api.Screen;
+import ru.penkrat.stbf.api.ScreenProperties;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Consumer;
+import java.util.function.Supplier;
+
+@Slf4j
+@RequiredArgsConstructor
+public class RamFileIdStorageMediaScreen implements Screen {
+
+    private static final Map<String, String> STORAGE = new ConcurrentHashMap<>();
+
+    private final Screen wrapped;
+
+    private Media wrappedMedia;
+
+    @Override
+    public Media getMedia() {
+        if (wrapped.getMedia() == null) {
+            return null;
+        }
+        if (wrappedMedia != null) {
+            return wrappedMedia;
+        }
+
+        final String url = wrapped.getMedia().getUrl();
+        wrappedMedia = Media.builder()
+                .data(getData(url))
+                .url(getUrl(url))
+                .fileId(STORAGE.get(url))
+                .fileIdConsumer(saveFileId(url))
+                .mediaType(wrapped.getMedia().getMediaType())
+                .duration(wrapped.getMedia().getDuration())
+                .height(wrapped.getMedia().getHeight())
+                .width(wrapped.getMedia().getWidth())
+                .duration(wrapped.getMedia().getDuration())
+                .build();
+
+        return wrappedMedia;
+    }
+
+    protected String getUrl(String url) {
+        return STORAGE.containsKey(url) ? null : url;
+    }
+
+    protected Supplier<byte[]> getData(String url) {
+        return null;
+    }
+
+    @Override
+    public String getText() {
+        return wrapped.getText();
+    }
+
+    @Override
+    public Keyboard getKeyboard() {
+        return wrapped.getKeyboard();
+    }
+
+    @Override
+    public ScreenProperties getScreenProperties() {
+        return wrapped.getScreenProperties();
+    }
+
+    private Consumer<String> saveFileId(String srcUrl) {
+        return fileId -> {
+            if (STORAGE.containsKey(srcUrl)) {
+                return;
+            }
+            log.debug("Store {} as {}", srcUrl, fileId);
+
+            STORAGE.put(srcUrl, fileId);
+            wrappedMedia = null;
+        };
+    }
+
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/session/InMemBotSessionProvider.java

@@ -0,0 +1,18 @@
+package ru.penkrat.stbf.common.session;
+
+import ru.penkrat.stbf.api.BotSession;
+import ru.penkrat.stbf.api.SessionProvider;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+public class InMemBotSessionProvider implements SessionProvider {
+
+    private static final Map<Long, BotSession> MAP = new ConcurrentHashMap<>();
+
+    @Override
+    public BotSession get(Long chatId) {
+        return MAP.computeIfAbsent(chatId, k -> new MapBackedBotSession(new ConcurrentHashMap<>()));
+    }
+
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/session/MapBackedBotSession.java

@@ -0,0 +1,22 @@
+package ru.penkrat.stbf.common.session;
+
+import lombok.RequiredArgsConstructor;
+import ru.penkrat.stbf.api.BotSession;
+
+import java.util.Map;
+
+@RequiredArgsConstructor
+class MapBackedBotSession implements BotSession {
+
+    private final Map<String, Object> map;
+
+    @Override
+    public Object getAttribute(String name) {
+        return map.get(name);
+    }
+
+    @Override
+    public void setAttribute(String name, Object value) {
+        map.put(name, value);
+    }
+}

stbf-common/src/main/java/ru/penkrat/stbf/common/session/SessionAwareBotRequest.java

@@ -0,0 +1,49 @@
+package ru.penkrat.stbf.common.session;
+
+import lombok.RequiredArgsConstructor;
+import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotSession;
+import ru.penkrat.stbf.api.SessionProvider;
+
+import java.util.Objects;
+import java.util.Optional;
+
+@RequiredArgsConstructor
+public class SessionAwareBotRequest implements BotRequest {
+
+	private final BotRequest delegate;
+
+	private final SessionProvider sessionProvider;
+
+	private BotSession botSession;
+
+	@Override
+	public BotSession getSession() {
+		if (botSession == null) {
+			botSession = sessionProvider.get(getChatId());
+			Objects.requireNonNull(botSession, "Session can not be null");
+		}
+		return botSession;
+	}
+
+	public Optional<String> getMessageText() {
+		return this.delegate.getMessageText();
+	}
+
+	public Optional<String> getPhoneNumber() {
+		return this.delegate.getPhoneNumber();
+	}
+
+	public Optional<String> getCallbackData() {
+		return this.delegate.getCallbackData();
+	}
+
+	public Optional<String> getCallbackMessageText() {
+		return this.delegate.getCallbackMessageText();
+	}
+
+	public Long getChatId() {
+		return this.delegate.getChatId();
+	}
+
+}

stbf-common/src/main/java/ru/penkrat/stbf/tools/RequestMatchers.java

@@ -4,6 +4,9 @@ import lombok.experimental.UtilityClass;
 import ru.penkrat.stbf.api.Action;
 import ru.penkrat.stbf.api.RequestMatcher;
 
+import java.util.Objects;
+import java.util.regex.Pattern;
+
 @UtilityClass
 public class RequestMatchers {
 
@@ -13,6 +16,41 @@ public class RequestMatchers {
                 .isPresent();
     }
 
+    public RequestMatcher cmd(Action action) {
+        return request -> request.getMessageText()
+                .filter(Objects::nonNull)
+                .filter(data -> Objects.equals(action.getCmd(), data))
+                .isPresent();
+    }
+
+    public RequestMatcher text(String callbackData) {
+        return request -> request.getCallbackData()
+                .filter(Objects::nonNull)
+                .filter(data -> Objects.equals(callbackData, data))
+                .isPresent();
+    }
+
+    public RequestMatcher callbackData(String callbackData) {
+        return request -> request.getCallbackData()
+                .filter(Objects::nonNull)
+                .filter(data -> Objects.equals(callbackData, data))
+                .isPresent();
+    }
+
+    public RequestMatcher callbackDataStartsWith(String callbackDataPrefix) {
+        return request -> request.getCallbackData()
+                .filter(Objects::nonNull)
+                .filter(data -> data.startsWith(callbackDataPrefix))
+                .isPresent();
+    }
+
+    public RequestMatcher callbackDataRegexp(String callbackDataPrefix) {
+        return request -> request.getCallbackData()
+                .filter(Objects::nonNull)
+                .filter(Pattern.compile(callbackDataPrefix).asPredicate())
+                .isPresent();
+    }
+
     private static boolean matchText(Action action, String inputText) {
         return inputText.equalsIgnoreCase(action.getText())
                 || (action.getCmd() != null && inputText.equalsIgnoreCase(action.getCmd()));

stbf-demo/README.MD

@@ -0,0 +1,56 @@
+## Демо приложение
+
+Позволяет запустить простого бота, который будет отвечать на заранее определенные команды, 
+без программирования логики.
+
+### Запуск
+
+Собрать fat-jar
+
+```shell
+mvn package
+```
+
+Запустить
+
+```shell
+java -jar stbf-demo.jar -t <bot:token> -f <полный путь к конфигу>
+```
+
+### Файл конфигурации
+
+Если запустить без указания файла конфигурации бота, то будет использована следующая:
+
+```xml
+
+<flow>
+    <actions>
+        <action id="10001" name="start-action" command="/start">Start</action>
+        <action id="10002" name="help-action" command="/help">Help</action>
+    </actions>
+    <screens>
+        <screen id="20001" name="on-start-screen">
+            <text>This is demo bot</text>
+            <keyboard>
+                <row>
+                    <button actionRef="help-action">Action.name</button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20001" name="on-help-screen">
+            <text>This is demo help</text>
+            <keyboard>
+                <row>
+                    <button actionRef="help-action">Action.name</button>
+                </row>
+            </keyboard>
+        </screen>
+    </screens>
+    <commands>
+        <command actionRef="start-action" screenRef="on-start-screen" id="30001" name="startCommand"/>
+        <command actionRef="help-action" screenRef="on-help-screen" id="30002" name="helpCommand"/>
+    </commands>
+</flow>
+```
+
+Ее можно использовать как базу для разработки своей.

stbf-demo/pom.xml

@@ -0,0 +1,130 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>stbf-parent</artifactId>
+        <groupId>ru.penkrat.stbf</groupId>
+        <version>0.0.2-SNAPSHOT</version>
+    </parent>
+
+    <groupId>ru.penkrat.stbf</groupId>
+    <artifactId>stbf-demo</artifactId>
+    <name>stbf-demo</name>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+        <maven.jar.plugin.version>3.0.2</maven.jar.plugin.version>
+        <maven-compiler-plugin-version>3.8.1</maven-compiler-plugin-version>
+        <junit.version>4.12</junit.version>
+        <assertj.version>3.9.0</assertj.version>
+        <mockito.version>2.13.0</mockito.version>
+        <jmustache.version>1.14</jmustache.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <artifactId>stbf-templates</artifactId>
+            <groupId>ru.penkrat.stbf</groupId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <artifactId>stbf-pengrad</artifactId>
+            <groupId>ru.penkrat.stbf</groupId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <artifactId>stbf-common</artifactId>
+            <groupId>ru.penkrat.stbf</groupId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>info.picocli</groupId>
+            <artifactId>picocli</artifactId>
+            <version>4.6.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.samskivert</groupId>
+            <artifactId>jmustache</artifactId>
+            <version>${jmustache.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-core</artifactId>
+            <version>1.2.5</version>
+        </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.2.5</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>${mockito.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <!-- annotationProcessorPaths requires maven-compiler-plugin version 3.5 or higher -->
+                <version>${maven-compiler-plugin-version}</version>
+                <configuration>
+                    <annotationProcessorPaths>
+                        <path>
+                            <groupId>info.picocli</groupId>
+                            <artifactId>picocli-codegen</artifactId>
+                            <version>4.6.1</version>
+                        </path>
+                    </annotationProcessorPaths>
+                    <compilerArgs>
+                        <arg>-Aproject=${project.groupId}/${project.artifactId}</arg>
+                    </compilerArgs>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.2.4</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <transformers>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>ru.penkrat.stbf.demo.App</mainClass>
+                                </transformer>
+                            </transformers>
+                            <artifactSet>
+                                <excludes>
+                                    <exclude>junit:junit</exclude>
+                                </excludes>
+                            </artifactSet>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

stbf-demo/src/main/java/ru/penkrat/stbf/demo/App.java

@@ -0,0 +1,71 @@
+package ru.penkrat.stbf.demo;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import picocli.CommandLine;
+import ru.penkrat.stbf.api.BotCommandChain;
+import ru.penkrat.stbf.api.CommandChain;
+import ru.penkrat.stbf.common.command.SessionAwareCommandChain;
+import ru.penkrat.stbf.common.command.ThreadPolledCommandChain;
+import ru.penkrat.stbf.common.session.InMemBotSessionProvider;
+import ru.penkrat.stbf.impl.pengrad.PengradTelegramBot;
+import ru.penkrat.stbf.templates.xml.XmlFlowResolver;
+
+import java.util.concurrent.atomic.AtomicReference;
+
+@CommandLine.Command(name = "java -jar stbf-demo.jar", mixinStandardHelpOptions = true, description = "Run bot",
+		version = "Simple Telegram bot framework Demo app v. 0.0.2")
+public class App implements Runnable {
+
+	private static final Logger log = LoggerFactory.getLogger(App.class);
+
+	private static AtomicReference<PengradTelegramBot> botAtomicReference = new AtomicReference<>();
+
+	@CommandLine.Option(names = {"-f", "--file"}, description = "The file with config.")
+	private String flowFile = "classpath:/flow.xml";
+
+	@CommandLine.Option(names = {"-t", "--token"}, required = true, description = "bot token 1234:abscdf...")
+	private String botToken = "";
+
+	public static void main(String[] args) {
+		new CommandLine(new App()).execute(args);
+	}
+
+	private CommandChain getCommandChain(String filename) {
+		XmlFlowResolver flow = new XmlFlowResolver(filename);
+
+		BotCommandChain chain = new BotCommandChain();
+		flow.getCommands().forEach(chain::add);
+
+		return new ThreadPolledCommandChain(new SessionAwareCommandChain(chain, new InMemBotSessionProvider()));
+	}
+
+	private Runnable start(String token, CommandChain chain) {
+		return () -> botAtomicReference.set(new PengradTelegramBot(token, chain));
+	}
+
+	private void onShutdown() {
+		try {
+			if (botAtomicReference.get() != null) {
+				botAtomicReference.get().close();
+				log.info("Bot finished.");
+			}
+		} catch (Exception e) {
+			log.error("Error:", e);
+		}
+	}
+
+	@Override
+	public void run() {
+		Thread botThread = new Thread(start(botToken, getCommandChain(flowFile)));
+		botThread.setDaemon(false);
+		botThread.setName("stbf-bot-thread");
+
+		Runtime.getRuntime().addShutdownHook(new Thread(this::onShutdown));
+
+		log.info("Starting bot...");
+		botThread.start();
+		log.info("Bot started.");
+		log.info("Press Ctrl+C to exit.");
+	}
+}

stbf-demo/src/main/resources/flow.xml

@@ -0,0 +1,114 @@
+<flow>
+    <media>
+        <video id="40001" url="http://techslides.com/demos/sample-videos/small.mp4"/>
+        <photo id="40002" url="https://telegram.org/img/t_logo.png"/>
+    </media>
+    <actions>
+        <action id="10001" name="start-action" command="/start">Start</action>
+        <action id="10002" name="help-action" command="/help">Help</action>
+        <action id="10003" name="to-inline-action" command="/inline">Inline</action>
+        <action id="10004" name="inline1-action" callbackData="cmd:inline1">🔞 Inline button #1</action>
+        <action id="10005" name="inline2-action" callbackData="cmd:inline2">🐱 Inline button #2</action>
+        <action id="10006" name="url-action" url="https://git.penkrat.ru/ruslan/stbf">💻 Git repo</action>
+        <action id="10007" name="photo-action" callbackData="cmd:sendPhoto">🖼 My photo</action>
+        <action id="10008" name="video-action" callbackData="cmd:sendVideo">🎞 My video</action>
+        <action id="10009" name="to-inline-back-action" callbackData="cmd:inline">🔙 Back</action>
+    </actions>
+    <screens>
+        <screen id="20001" name="on-start-screen">
+            <text>This is demo bot
+                use Help or /help to view help
+            </text>
+            <keyboard>
+                <row>
+                    <button actionRef="help-action">Action.name</button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20002" name="on-help-screen">
+            <text>This is demo help
+                use /inline to switch to inline mode
+            </text>
+            <keyboard>
+                <row>
+                    <button actionRef="help-action">Action.name</button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20003" name="inline-test-screen">
+            <text>This is inline buttons:</text>
+            <keyboard>
+                <row>
+                    <button actionRef="inline1-action"></button>
+                    <button actionRef="inline2-action"></button>
+                </row>
+                <row>
+                    <button actionRef="photo-action"></button>
+                    <button actionRef="video-action"></button>
+                </row>
+                <row>
+                    <button actionRef="url-action"></button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20004" name="inline-test-1-screen">
+            <text>Inline Screen #1</text>
+            <keyboard>
+                <row>
+                    <button actionRef="inline1-action"></button>
+                    <button actionRef="inline2-action"></button>
+                </row>
+                <row>
+                    <button actionRef="photo-action"></button>
+                    <button actionRef="video-action"></button>
+                </row>
+                <row>
+                    <button actionRef="url-action"></button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20005" name="inline-test-2-screen">
+            <text>Inline Screen #2
+                  ================</text>
+            <keyboard>
+                <row>
+                    <button actionRef="inline1-action"></button>
+                    <button actionRef="inline2-action"></button>
+                </row>
+                <row>
+                    <button actionRef="photo-action"></button>
+                    <button actionRef="video-action"></button>
+                </row>
+                <row>
+                    <button actionRef="url-action"></button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20006" name="inline-photo-screen" mediaRef="40002">
+            <text>My photo</text>
+            <keyboard>
+                <row>
+                    <button actionRef="to-inline-back-action"></button>
+                </row>
+            </keyboard>
+        </screen>
+        <screen id="20007" name="inline-video-screen" mediaRef="40001">
+            <text>My Video</text>
+            <keyboard>
+                <row>
+                    <button actionRef="to-inline-back-action"></button>
+                </row>
+            </keyboard>
+        </screen>
+    </screens>
+    <commands>
+        <command actionRef="start-action" screenRef="on-start-screen" id="30001" name="startCommand"/>
+        <command actionRef="help-action" screenRef="on-help-screen" id="30002" name="helpCommand"/>
+        <command actionRef="to-inline-action" screenRef="inline-test-screen" id="30003" name="inlineTestCommand"/>
+        <command actionRef="to-inline-back-action" screenRef="inline-test-screen" replace="true" id="30004" name="inlineTestCommand"/>
+        <command actionRef="inline1-action" screenRef="inline-test-1-screen" edit="true" id="30005" name="inlineTest1Command"/>
+        <command actionRef="inline2-action" screenRef="inline-test-2-screen" edit="true" id="30006" name="inlineTest2Command"/>
+        <command actionRef="photo-action" screenRef="inline-photo-screen" replace="true" id="30005" name="photoCommand"/>
+        <command actionRef="video-action" screenRef="inline-video-screen" replace="true" id="30006" name="videoCommand"/>
+    </commands>
+</flow>

stbf-demo/src/main/resources/logback.xml

@@ -0,0 +1,11 @@
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="debug">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>

stbf-pengrad/pom.xml

@@ -1,13 +1,11 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 
 	<parent>
 		<groupId>ru.penkrat.stbf</groupId>
 		<artifactId>stbf-parent</artifactId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
   	</parent>
 
 	<artifactId>stbf-pengrad</artifactId>
@@ -18,12 +16,12 @@
 		<dependency>
 			<groupId>ru.penkrat.stbf</groupId>
 			<artifactId>stbf-api</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>0.0.2-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>com.github.pengrad</groupId>
 			<artifactId>java-telegram-bot-api</artifactId>
-			<version>[4.9.0,5.2.0]</version>
+			<version>6.2.0</version>
 		</dependency>
 	</dependencies>
 

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/BotRequestImpl.java

@@ -1,17 +1,17 @@
 package ru.penkrat.stbf.impl.pengrad;
 
-import static lombok.AccessLevel.PROTECTED;
-
-import java.util.Optional;
-
 import com.pengrad.telegrambot.model.CallbackQuery;
 import com.pengrad.telegrambot.model.Contact;
 import com.pengrad.telegrambot.model.Message;
 import com.pengrad.telegrambot.model.Update;
-
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotSession;
+
+import java.util.Optional;
+
+import static lombok.AccessLevel.PROTECTED;
 
 @RequiredArgsConstructor
 public class BotRequestImpl implements BotRequest {
@@ -58,4 +58,9 @@ public class BotRequestImpl implements BotRequest {
 				.orElseGet(() -> update.message()).chat().id();
 	}
 
+	@Override
+	public BotSession getSession() {
+		throw new UnsupportedOperationException("Session is not supported");
+	}
+
 }

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/BotResponseImpl.java

@@ -2,11 +2,17 @@ package ru.penkrat.stbf.impl.pengrad;
 
 import com.pengrad.telegrambot.TelegramBot;
 import com.pengrad.telegrambot.model.Update;
-import com.pengrad.telegrambot.model.request.*;
+import com.pengrad.telegrambot.model.request.InlineKeyboardButton;
+import com.pengrad.telegrambot.model.request.InlineKeyboardMarkup;
+import com.pengrad.telegrambot.model.request.KeyboardButton;
+import com.pengrad.telegrambot.model.request.ParseMode;
+import com.pengrad.telegrambot.model.request.ReplyKeyboardMarkup;
+import com.pengrad.telegrambot.request.AbstractSendRequest;
 import com.pengrad.telegrambot.request.DeleteMessage;
 import com.pengrad.telegrambot.request.EditMessageText;
 import com.pengrad.telegrambot.request.SendDocument;
-import com.pengrad.telegrambot.request.SendMessage;
+import com.pengrad.telegrambot.response.BaseResponse;
+import com.pengrad.telegrambot.response.SendResponse;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import ru.penkrat.stbf.api.BotResponse;
@@ -22,20 +28,17 @@ public class BotResponseImpl implements BotResponse {
 
     @Override
     public void send(Screen screen) {
-        log.debug("Send message: \n============\n{}\n============", screen.getText().trim());
+        log.trace("Send trace: \n============\n{}\n============", screen.getText().trim());
 
-        SendMessage sendMessage = new SendMessage(chatId(), screen.getText().trim())
-                .parseMode(screen.getScreenProperties().isParseModeHtml() ? ParseMode.HTML : ParseMode.MarkdownV2)
-                .disableWebPagePreview(screen.getScreenProperties().isDisableWebPagePreview())
-                .disableNotification(screen.getScreenProperties().isDisableNotification());
+        AbstractSendRequest<? extends AbstractSendRequest> sendMessage = SendMethodUtils.createFromScreen(chatId(), screen);
 
         if (screen.getKeyboard() instanceof KeyboardImpl) {
             KeyboardImpl kk = (KeyboardImpl) screen.getKeyboard();
             KeyboardButton[][] keyboard = kk.getKeyboard();
             InlineKeyboardButton[][] inlineKeyboard = kk.getInlineKeyboard();
 
-            if (log.isDebugEnabled()) {
-                log.debug("{}", kk.toFriendlyString());
+            if (log.isTraceEnabled()) {
+                log.trace("{}", kk.toFriendlyString());
             }
 
             if (inlineKeyboard != null && inlineKeyboard.length > 0) {
@@ -43,11 +46,14 @@ public class BotResponseImpl implements BotResponse {
             } else if (keyboard != null && keyboard.length > 0) {
                 sendMessage = sendMessage.replyMarkup(new ReplyKeyboardMarkup(keyboard));
             } else {
-                log.debug("No keyboard");
+                log.trace("No keyboard");
             }
         }
 
-        telegramBot.execute(sendMessage);
+        final SendResponse sendResponse = telegramBot.execute(sendMessage);
+        SendMethodUtils.processResponse(screen, sendResponse);
+
+        log.debug("Response message = {}", sendResponse.message().messageId());
     }
 
     @Override
@@ -73,18 +79,23 @@ public class BotResponseImpl implements BotResponse {
             KeyboardImpl kk = (KeyboardImpl) screen.getKeyboard();
             InlineKeyboardButton[][] inlineKeyboard = kk.getInlineKeyboard();
 
-            if (log.isDebugEnabled()) {
-                log.debug("{}", kk.toFriendlyString());
+            if (log.isTraceEnabled()) {
+                log.trace("{}", kk.toFriendlyString());
             }
 
             if (inlineKeyboard != null && inlineKeyboard.length > 0) {
                 editMessage = editMessage.replyMarkup(new InlineKeyboardMarkup(inlineKeyboard));
             } else {
-                log.debug("No keyboard");
+                log.trace("No keyboard");
             }
         }
 
-        telegramBot.execute(editMessage);
+        final BaseResponse response = telegramBot.execute(editMessage);
+        if (response.isOk()) {
+            log.debug("Response ok, edit message = {}", messageId());
+        } else {
+            log.debug("Response error code {}", response.errorCode());
+        }
     }
 
     @Override

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/KeyboardImpl.java

@@ -1,6 +1,6 @@
 package ru.penkrat.stbf.impl.pengrad;
 
-import com.google.gson.internal.reflect.ReflectionAccessor;
+import com.google.gson.internal.reflect.ReflectionHelper;
 import com.pengrad.telegrambot.model.request.InlineKeyboardButton;
 import com.pengrad.telegrambot.model.request.KeyboardButton;
 import lombok.Value;
@@ -58,7 +58,7 @@ class KeyboardImpl implements Keyboard {
         return text.computeIfAbsent(btn, o -> {
             try {
                 Field text = btn.getClass().getDeclaredField("text");
-                ReflectionAccessor.getInstance().makeAccessible(text);
+                ReflectionHelper.makeAccessible(text);
                 return String.valueOf(text.get(btn));
             } catch (NoSuchFieldException | IllegalAccessException e) {
                 return "*error*";

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/NoKeyboard.java

@@ -0,0 +1,14 @@
+package ru.penkrat.stbf.impl.pengrad;
+
+import ru.penkrat.stbf.api.Keyboard;
+
+class NoKeyboard implements Keyboard {
+
+    @Override
+    public String toString() {
+        return "EmptyKeyboard(pengrad)";
+    }
+
+}
+
+

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/PengradKeyboardBuilder.java

@@ -2,7 +2,6 @@ package ru.penkrat.stbf.impl.pengrad;
 
 import com.pengrad.telegrambot.model.request.InlineKeyboardButton;
 import com.pengrad.telegrambot.model.request.KeyboardButton;
-
 import ru.penkrat.stbf.api.Action;
 import ru.penkrat.stbf.api.Keyboard;
 import ru.penkrat.stbf.api.KeyboardBuilder;
@@ -21,7 +20,13 @@ public class PengradKeyboardBuilder implements KeyboardBuilder {
 
     @Override
     public Keyboard build() {
-		return new KeyboardImpl(keyboard, inlineKeyboard);
+        if (keyboard != null) {
+            return new KeyboardImpl(keyboard, null);
+        }
+        if (inlineKeyboard != null) {
+            return new KeyboardImpl(null, inlineKeyboard);
+        }
+        return new NoKeyboard();
     }
 
     public KeyboardBuilder addGetContact(String text) {
@@ -53,7 +58,13 @@ public class PengradKeyboardBuilder implements KeyboardBuilder {
         for (int i = 0; i < buttons.length; i++) {
             put(buttons[i]);
         }
+        if (buttons.length > 0) {
+            if (buttons[0].isInline()) {
+                nextRowI();
+            } else {
                 nextRow();
+            }
+        }
         return self();
     }
 
@@ -91,14 +102,14 @@ public class PengradKeyboardBuilder implements KeyboardBuilder {
         KeyboardButton[][] n = new KeyboardButton[keyboard.length + 1][];
         System.arraycopy(keyboard, 0, n, 0, keyboard.length);
         keyboard = n;
-		keyboard[keyboard.length - 1] = new KeyboardButton[] {};
+        keyboard[keyboard.length - 1] = new KeyboardButton[]{};
     }
 
     private void nextRowI() {
         InlineKeyboardButton[][] n = new InlineKeyboardButton[inlineKeyboard.length + 1][];
         System.arraycopy(inlineKeyboard, 0, n, 0, inlineKeyboard.length);
         inlineKeyboard = n;
-		inlineKeyboard[inlineKeyboard.length - 1] = new InlineKeyboardButton[] {};
+        inlineKeyboard[inlineKeyboard.length - 1] = new InlineKeyboardButton[]{};
     }
 
     protected PengradKeyboardBuilder self() {
@@ -107,16 +118,20 @@ public class PengradKeyboardBuilder implements KeyboardBuilder {
 
     private void put(Action action) {
         if (action.isInline()) {
-			put(new InlineKeyboardButton(action.getText()).callbackData(action.getCallbackData()));
+            put(new InlineKeyboardButton(action.getText())
+                    .callbackData(action.getCallbackData())
+                    .url(action.getUrl()));
         } else {
-			put(new KeyboardButton(action.getText()).requestContact(action.isRequestContact()));
+            put(new KeyboardButton(action.getText())
+                    .requestContact(action.isRequestContact())
+                    .requestLocation(action.isRequestLocation()));
         }
     }
 
     private void put(KeyboardButton btn) {
         if (keyboard == null) {
-			keyboard = new KeyboardButton[][] {
-					new KeyboardButton[] { btn }
+            keyboard = new KeyboardButton[][]{
+                    new KeyboardButton[]{btn}
             };
         } else {
             KeyboardButton[] k = keyboard[keyboard.length - 1];
@@ -129,8 +144,8 @@ public class PengradKeyboardBuilder implements KeyboardBuilder {
 
     private void put(InlineKeyboardButton btn) {
         if (inlineKeyboard == null) {
-			inlineKeyboard = new InlineKeyboardButton[][] {
-					new InlineKeyboardButton[] { btn }
+            inlineKeyboard = new InlineKeyboardButton[][]{
+                    new InlineKeyboardButton[]{btn}
             };
         } else {
             InlineKeyboardButton[] k = inlineKeyboard[inlineKeyboard.length - 1];

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/PengradTelegramBot.java

@@ -2,11 +2,13 @@ package ru.penkrat.stbf.impl.pengrad;
 
 import com.pengrad.telegrambot.TelegramBot;
 import com.pengrad.telegrambot.UpdatesListener;
+import com.pengrad.telegrambot.model.CallbackQuery;
 import com.pengrad.telegrambot.model.Update;
-
 import lombok.extern.slf4j.Slf4j;
 import ru.penkrat.stbf.api.CommandChain;
 
+import java.util.Optional;
+
 @Slf4j
 public class PengradTelegramBot extends TelegramBot implements AutoCloseable {
 
@@ -15,6 +17,13 @@ public class PengradTelegramBot extends TelegramBot implements AutoCloseable {
 		this.setUpdatesListener(updates -> {
 			for (Update update : updates) {
 				try {
+					final Long chatId = Optional.of(update)
+							.map(Update::callbackQuery)
+							.map(CallbackQuery::message)
+							.orElseGet(() -> update.message()).chat().id();
+
+					log.debug("New message in chat {}", chatId);
+
 					commandChain.processCommand(
 							new BotRequestImpl(update),
 							new BotResponseImpl(update, this));

stbf-pengrad/src/main/java/ru/penkrat/stbf/impl/pengrad/SendMethodUtils.java

@@ -0,0 +1,186 @@
+package ru.penkrat.stbf.impl.pengrad;
+
+import com.pengrad.telegrambot.model.Message;
+import com.pengrad.telegrambot.model.request.ParseMode;
+import com.pengrad.telegrambot.request.AbstractSendRequest;
+import com.pengrad.telegrambot.request.SendAnimation;
+import com.pengrad.telegrambot.request.SendAudio;
+import com.pengrad.telegrambot.request.SendMessage;
+import com.pengrad.telegrambot.request.SendPhoto;
+import com.pengrad.telegrambot.request.SendVideo;
+import com.pengrad.telegrambot.request.SendVoice;
+import com.pengrad.telegrambot.response.SendResponse;
+import lombok.NonNull;
+import lombok.RequiredArgsConstructor;
+import lombok.experimental.UtilityClass;
+import org.jetbrains.annotations.NotNull;
+import ru.penkrat.stbf.api.Media;
+import ru.penkrat.stbf.api.Screen;
+
+import java.util.function.BiFunction;
+import java.util.function.Consumer;
+
+@UtilityClass
+class SendMethodUtils {
+
+    public AbstractSendRequest<? extends AbstractSendRequest> createFromScreen(@NonNull Object chatId, @NonNull Screen screen) {
+        if (isMedia(screen)) {
+            final Media media = screen.getMedia();
+            switch (media.getMediaType()) {
+                case ANIMATION:
+                    return Setter.to(createSendAnimation(chatId, media))
+                            .setNotNUll(SendAnimation::caption, screen.getText())
+                            .setNotNUll(SendAnimation::width, media.getWidth())
+                            .setNotNUll(SendAnimation::height, media.getHeight())
+                            .setNotNUll(SendAnimation::duration, media.getDuration())
+                            .set(SendAnimation::parseMode, screen.getScreenProperties().isParseModeHtml()
+                                    ? ParseMode.HTML
+                                    : ParseMode.MarkdownV2)
+                            .get();
+                case AUDIO:
+                    return Setter.to(createSendAudio(chatId, media))
+                            .setNotNUll(SendAudio::caption, screen.getText())
+                            .setNotNUll(SendAudio::duration, media.getDuration())
+                            .set(SendAudio::parseMode, screen.getScreenProperties().isParseModeHtml()
+                                    ? ParseMode.HTML
+                                    : ParseMode.MarkdownV2)
+                            .get();
+                case PHOTO:
+                    return Setter.to(createSendPhoto(chatId, media))
+                            .setNotNUll(SendPhoto::caption, screen.getText())
+                            .set(SendPhoto::parseMode, screen.getScreenProperties().isParseModeHtml()
+                                    ? ParseMode.HTML
+                                    : ParseMode.MarkdownV2)
+                            .get();
+                case VIDEO:
+                    return Setter.to(createSendVideo(chatId, media))
+                            .setNotNUll(SendVideo::caption, screen.getText())
+                            .setNotNUll(SendVideo::width, media.getWidth())
+                            .setNotNUll(SendVideo::height, media.getHeight())
+                            .setNotNUll(SendVideo::duration, media.getDuration())
+                            .set(SendVideo::parseMode, screen.getScreenProperties().isParseModeHtml()
+                                    ? ParseMode.HTML
+                                    : ParseMode.MarkdownV2)
+                            .get();
+                case VOICE:
+                    return Setter.to(createSendVoice(chatId, media))
+                            .setNotNUll(SendVoice::caption, screen.getText())
+                            .setNotNUll(SendVoice::duration, media.getDuration())
+                            .set(SendVoice::parseMode, screen.getScreenProperties().isParseModeHtml()
+                                    ? ParseMode.HTML
+                                    : ParseMode.MarkdownV2)
+                            .get();
+                default:
+                    throw new IllegalStateException("Unsupported media type " + media.getMediaType());
+            }
+        }
+
+        return new SendMessage(chatId, screen.getText().trim())
+                .parseMode(screen.getScreenProperties().isParseModeHtml() ? ParseMode.HTML : ParseMode.MarkdownV2)
+                .disableWebPagePreview(screen.getScreenProperties().isDisableWebPagePreview())
+                .disableNotification(screen.getScreenProperties().isDisableNotification());
+    }
+
+
+    public static void processResponse(Screen screen, SendResponse sendResponse) {
+        if (isMedia(screen)) {
+            final Consumer<String> fileIdConsumer = screen.getMedia().getFileIdConsumer();
+            if (fileIdConsumer != null) {
+                final Message message = sendResponse.message();
+                if (message.animation() != null)
+                    fileIdConsumer.accept(message.animation().fileId());
+                else if (message.audio() != null)
+                    fileIdConsumer.accept(message.audio().fileId());
+                else if (message.photo() != null && message.photo().length > 0)
+                    fileIdConsumer.accept(message.photo()[0].fileId());
+                else if (message.video() != null)
+                    fileIdConsumer.accept(message.video().fileId());
+                else if (message.voice() != null)
+                    fileIdConsumer.accept(message.voice().fileId());
+            }
+        }
+    }
+
+    @NotNull
+    private SendVoice createSendVoice(@NotNull Object chatId, Media media) {
+        if (media.getData() != null) {
+            return new SendVoice(chatId, media.getData().get());
+        }
+        if (media.getFileId() != null) {
+            return new SendVoice(chatId, media.getFileId());
+        }
+        return new SendVoice(chatId, media.getUrl());
+    }
+
+    @NotNull
+    private SendVideo createSendVideo(@NotNull Object chatId, Media media) {
+        if (media.getData() != null) {
+            return new SendVideo(chatId, media.getData().get());
+        }
+        if (media.getFileId() != null) {
+            return new SendVideo(chatId, media.getFileId());
+        }
+        return new SendVideo(chatId, media.getUrl());
+    }
+
+    @NotNull
+    private SendAudio createSendAudio(@NotNull Object chatId, Media media) {
+        if (media.getData() != null) {
+            return new SendAudio(chatId, media.getData().get());
+        }
+        if (media.getFileId() != null) {
+            return new SendAudio(chatId, media.getFileId());
+        }
+        return new SendAudio(chatId, media.getUrl());
+    }
+
+    @NotNull
+    private SendAnimation createSendAnimation(@NotNull Object chatId, Media media) {
+        if (media.getData() != null) {
+            return new SendAnimation(chatId, media.getData().get());
+        }
+        if (media.getFileId() != null) {
+            return new SendAnimation(chatId, media.getFileId());
+        }
+        return new SendAnimation(chatId, media.getUrl());
+    }
+
+    @NotNull
+    private SendPhoto createSendPhoto(@NotNull Object chatId, Media media) {
+        if (media.getData() != null) {
+            return new SendPhoto(chatId, media.getData().get());
+        }
+        if (media.getFileId() != null) {
+            return new SendPhoto(chatId, media.getFileId());
+        }
+        return new SendPhoto(chatId, media.getUrl());
+    }
+
+    private boolean isMedia(Screen screen) {
+        return screen.getMedia() != null;
+    }
+
+
+    @RequiredArgsConstructor(staticName = "to")
+    private static class Setter<T> {
+
+        private final T target;
+
+        <V> Setter<T> setNotNUll(BiFunction<T, V, T> setter, V value) {
+            if (value != null) {
+                setter.apply(target, value);
+            }
+            return this;
+        }
+
+        <V> Setter<T> set(BiFunction<T, V, T> setter, V value) {
+            setter.apply(target, value);
+            return this;
+        }
+
+        T get() {
+            return target;
+        }
+
+    }
+}

stbf-rubenlagus/pom.xml

@@ -1,12 +1,10 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<artifactId>stbf-parent</artifactId>
 		<groupId>ru.penkrat.stbf</groupId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
 	</parent>
 
 	<artifactId>stbf-rubenlagus</artifactId>
@@ -17,7 +15,7 @@
 		<dependency>
 			<groupId>ru.penkrat.stbf</groupId>
 			<artifactId>stbf-api</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>0.0.2-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>org.telegram</groupId>

stbf-rubenlagus/src/main/java/ru/penkrat/stbf/impl/rubenlagus/BotRequestImpl.java

@@ -1,17 +1,17 @@
 package ru.penkrat.stbf.impl.rubenlagus;
 
-import static lombok.AccessLevel.PROTECTED;
-
-import java.util.Optional;
-
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
 import org.telegram.telegrambots.meta.api.objects.CallbackQuery;
 import org.telegram.telegrambots.meta.api.objects.Contact;
 import org.telegram.telegrambots.meta.api.objects.Message;
 import org.telegram.telegrambots.meta.api.objects.Update;
-
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
 import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotSession;
+
+import java.util.Optional;
+
+import static lombok.AccessLevel.PROTECTED;
 
 @RequiredArgsConstructor
 class BotRequestImpl implements BotRequest {
@@ -52,7 +52,12 @@ class BotRequestImpl implements BotRequest {
 
 	@Override
 	public Long getChatId() {
-		return update.getMessage().getChatId();
+		return Utils.getChatId(update);
+	}
+
+	@Override
+	public BotSession getSession() {
+		throw new UnsupportedOperationException("Session is not supported");
 	}
 
 }

stbf-rubenlagus/src/main/java/ru/penkrat/stbf/impl/rubenlagus/RubenlagusTelegramBot.java

@@ -1,12 +1,11 @@
 package ru.penkrat.stbf.impl.rubenlagus;
 
+import lombok.extern.slf4j.Slf4j;
 import org.telegram.telegrambots.bots.TelegramLongPollingBot;
 import org.telegram.telegrambots.meta.TelegramBotsApi;
 import org.telegram.telegrambots.meta.api.objects.Update;
 import org.telegram.telegrambots.meta.exceptions.TelegramApiException;
 import org.telegram.telegrambots.updatesreceivers.DefaultBotSession;
-
-import lombok.extern.slf4j.Slf4j;
 import ru.penkrat.stbf.api.BotCommandChain;
 
 @Slf4j

stbf-rubenlagus/src/main/java/ru/penkrat/stbf/impl/rubenlagus/Utils.java

@@ -0,0 +1,21 @@
+package ru.penkrat.stbf.impl.rubenlagus;
+
+import lombok.experimental.UtilityClass;
+import org.telegram.telegrambots.meta.api.objects.Update;
+
+@UtilityClass
+class Utils {
+
+    Long getChatId(Update update) {
+        if (update.getMessage() != null) {
+            return update.getMessage().getChatId();
+        }
+
+        if (update.getCallbackQuery() != null) {
+            update.getCallbackQuery().getMessage().getChatId();
+        }
+
+        throw new IllegalStateException("Can't extract chatId from 'Update'");
+    }
+
+}

stbf-templates/README.MD

@@ -0,0 +1,112 @@
+## Поддержка шаблонов и конфигурации
+
+### Основные секции
+
+```xml
+<flow>
+    <actions>  </actions>
+    <screens>  </screens>
+    <commands> </commands>
+    <media>    </media>
+</flow>
+```
+
+### Actions
+
+Action - Это действие пользователя бота, которое бот должен обработать, а также соответсвующая кнопка или inline-кнопка.  
+
+```xml
+<action id="10002" name="help-action" command="/help">Help</action>
+```
+
+`id`, `name` - идентификаторы узла (экшена)
+
+`command` - команда Telegram, должна начинаться со знака "/"
+
+`requestContact="true|false"` - кнопка запроса контактных данных
+
+`requestLocation="true|false"` - кнопка запроса метоположения
+
+содержимое тега - вводимый текст, используется как экранная кнопка
+
+`url` - ссылка для inline-кнопки
+
+`callbackData` - callback данные для inline-кнопки
+
+`callbackDataRegexp` - regexp для обработки callback программным способом
+
+`callbackDataStartWith` - префикс, для обработки callback программным способом
+
+### Screens
+
+Screen - то, что бот ответит пользователю, обычно текст и набор кнопок с действиями. В качестве текста может задаваться шаблон, контекст передается при программной обработке при установленном `TemplateRenderer`
+
+```xml
+        <screen id="20001" name="on-start-screen">
+            <text>This is demo bot</text>
+            <keyboard>
+                <row>
+                    <button actionRef="help-action">Action.name</button>
+                </row>
+            </keyboard>
+        </screen>
+```
+
+`mediaRef` - ссылка на элемент медиа, который будет оправлен ботом
+
+`text` - выводимый текст
+
+`keyboard` - описание клавиатуры
+
+### Keyboard
+
+Описание клавиатуры
+
+#### Row
+
+Одна строка кнопок клавиатуры
+
+#### Button
+
+`if` - видимость кнопки, значение `true`, `false` или имя метода из контекста экрана (для программной обработки)
+
+`actionRef` - `id` или `name` action,  описанный в соответсвующей секции
+
+Если кнопка не ссылается на action, то можно задать следующие свойства:
+
+`url` - ссылка для inline-кнопки
+
+`callbackData` - callback данные для inline-кнопки
+
+`callbackDataRegexp` - regexp для обработки callback программным способом
+
+`callbackDataStartWith` - префикс, для обработки callback программным способом
+
+
+### Commands
+
+Простая команда, при совершении `action` будет выведен `screen`. Используется для простых действий, не требующей программной логики.
+
+```xml
+<command actionRef="start-action" screenRef="on-start-screen" id="30001" name="startCommand"/>
+```
+
+`actionRef` - ссылка на action, может использоваться id или name
+
+`screenRef` - ссылка на screen, может использоваться id или name
+
+`edit` = `true|false`- исходное сообщение будет отредактировано (актуально для callback)
+
+`replace` = `true|false`- исходное сообщение будет удалено, и отправлено новое (актуально для callback, 
+если меняется тип сообщения т.е. сообщение с фото, видео должно быть заменено на текстовое и наоборот)
+
+### Media
+
+Описывает медиа-ресурсы, доступные для отправки ботом
+
+```xml
+    <media>
+        <video id="40001" url="https://example.com/video.mp4"/>
+        <photo id="40002" url="https://example.com//photo.png"/>
+    </media>
+```

stbf-templates/pom.xml

@@ -1,12 +1,10 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<artifactId>stbf-parent</artifactId>
 		<groupId>ru.penkrat.stbf</groupId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
 	</parent>
 	<artifactId>stbf-templates</artifactId>
 	<properties>

stbf-templates/src/main/java/ru/penkrat/stbf/templates/ActionResolver.java

@@ -1,8 +1,11 @@
 package ru.penkrat.stbf.templates;
 
 import ru.penkrat.stbf.api.Action;
+import ru.penkrat.stbf.api.RequestMatcher;
 
 public interface ActionResolver {
 
     Action getAction(String name);
+
+    RequestMatcher getMatcher(String actionName);
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/CommandResolver.java

@@ -0,0 +1,11 @@
+package ru.penkrat.stbf.templates;
+
+import ru.penkrat.stbf.api.Command;
+
+import java.util.Collection;
+
+public interface CommandResolver {
+
+    Collection<Command> getCommands();
+
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/MediaResolver.java

@@ -0,0 +1,9 @@
+package ru.penkrat.stbf.templates;
+
+import ru.penkrat.stbf.api.Media;
+
+public interface MediaResolver {
+
+    Media getMedia(String name);
+
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/utils/StringUtils.java

@@ -2,9 +2,14 @@ package ru.penkrat.stbf.templates.utils;
 
 import lombok.experimental.UtilityClass;
 
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
 @UtilityClass
 public class StringUtils {
 
+    public static final String NL_DELIMITER = "\n";
+
     public boolean isEmpty(String string) {
         return string == null || string.isEmpty();
     }
@@ -12,4 +17,13 @@ public class StringUtils {
     public boolean isNotEmpty(String string) {
         return !isEmpty(string);
     }
+
+    public String ltrim(String text) {
+        if (text == null) {
+            return null;
+        }
+        return Stream.of(text.split(NL_DELIMITER))
+                .map(string -> string.trim())
+                .collect(Collectors.joining(NL_DELIMITER));
+    }
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/ActionItem.java

@@ -24,6 +24,12 @@ class ActionItem extends NamedItem {
     @JacksonXmlProperty(isAttribute = true)
     private String callbackData;
 
+    @JacksonXmlProperty(isAttribute = true)
+    private String callbackDataRegexp;
+
+    @JacksonXmlProperty(isAttribute = true)
+    private String callbackDataStartWith;
+
     @JacksonXmlProperty(isAttribute = true)
     private String url;
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/CommandItem.java

@@ -0,0 +1,30 @@
+package ru.penkrat.stbf.templates.xml;
+
+import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
+import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlRootElement;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@JacksonXmlRootElement(localName = "command")
+public class CommandItem extends NamedItem {
+
+    @JacksonXmlProperty(isAttribute = true)
+    private String actionRef;
+
+    @JacksonXmlProperty(isAttribute = true)
+    private String screenRef;
+
+    @JacksonXmlProperty(isAttribute = true, localName = "class")
+    private String clazz;
+
+    @JacksonXmlProperty(isAttribute = true)
+    private boolean edit;
+
+    @JacksonXmlProperty(isAttribute = true)
+    private boolean replace;
+
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowActionResolverDelegate.java

@@ -1,8 +1,10 @@
 package ru.penkrat.stbf.templates.xml;
 
 import ru.penkrat.stbf.api.Action;
+import ru.penkrat.stbf.api.RequestMatcher;
 import ru.penkrat.stbf.templates.ActionResolver;
 import ru.penkrat.stbf.templates.utils.StringUtils;
+import ru.penkrat.stbf.tools.RequestMatchers;
 
 class FlowActionResolverDelegate implements ActionResolver {
 
@@ -17,7 +19,7 @@ class FlowActionResolverDelegate implements ActionResolver {
         final ActionItem actionItem = resolver.get(key);
 
         boolean isInline = StringUtils.isNotEmpty(actionItem.getCallbackData())
-                && StringUtils.isNotEmpty(actionItem.getUrl());
+                || StringUtils.isNotEmpty(actionItem.getUrl());
 
         if (isInline) {
             if (StringUtils.isNotEmpty(actionItem.getCommand())) {
@@ -43,4 +45,21 @@ class FlowActionResolverDelegate implements ActionResolver {
                 .url(actionItem.getUrl())
                 .build();
     }
+
+    @Override
+    public RequestMatcher getMatcher(String actionName) {
+        final ActionItem actionItem = resolver.get(actionName);
+
+        if (StringUtils.isNotEmpty(actionItem.getCallbackDataRegexp())) {
+            return RequestMatchers.callbackDataRegexp(actionItem.getCallbackDataRegexp());
+        }
+        if (StringUtils.isNotEmpty(actionItem.getCallbackDataStartWith())) {
+            return RequestMatchers.callbackDataStartsWith(actionItem.getCallbackDataStartWith());
+        }
+        if (StringUtils.isNotEmpty(actionItem.getCallbackData())) {
+            return RequestMatchers.callbackData(actionItem.getCallbackData());
+        }
+
+        return RequestMatchers.action(getAction(actionName));
+    }
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowCommandResolverDelegate.java

@@ -0,0 +1,98 @@
+package ru.penkrat.stbf.templates.xml;
+
+import lombok.RequiredArgsConstructor;
+import ru.penkrat.stbf.api.Action;
+import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotResponse;
+import ru.penkrat.stbf.api.Command;
+import ru.penkrat.stbf.api.CommandChain;
+import ru.penkrat.stbf.api.RequestMatcher;
+import ru.penkrat.stbf.api.Screen;
+import ru.penkrat.stbf.templates.ActionResolver;
+import ru.penkrat.stbf.templates.CommandResolver;
+import ru.penkrat.stbf.templates.ScreenResolver;
+import ru.penkrat.stbf.templates.utils.StringUtils;
+
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Objects;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+@RequiredArgsConstructor
+public class FlowCommandResolverDelegate implements CommandResolver {
+
+    private final FlowRoot root;
+    private final ActionResolver actionResolver;
+    private final ScreenResolver screenResolver;
+
+    private boolean resolved;
+    private Collection<Command> commands;
+
+    @Override
+    public Collection<Command> getCommands() {
+        resolve();
+        return commands;
+    }
+
+    private void resolve() {
+        if (!resolved) {
+            Collection<Command> parsedCommands = Traversal.traverse(root, FlowRoot::getCommands)
+                    .stream()
+                    .map(this::createCommand)
+                    .filter(Objects::nonNull)
+                    .collect(Collectors.toList());
+
+            commands = Collections.unmodifiableCollection(parsedCommands);
+            resolved = true;
+        }
+    }
+
+    private Command createCommand(CommandItem commandItem) {
+        Action action = null;
+        RequestMatcher actionMatcher = null;
+        Screen screen = null;
+        Function<Object, Screen> screenFactory;
+        if (StringUtils.isNotEmpty(commandItem.getActionRef())) {
+            action = actionResolver.getAction(commandItem.getActionRef());
+            actionMatcher = actionResolver.getMatcher(commandItem.getActionRef());
+        }
+        if (StringUtils.isNotEmpty(commandItem.getScreenRef())) {
+            screen = screenResolver.getScreen(commandItem.getScreenRef());
+            screenFactory = screenResolver.getScreenFactory(commandItem.getScreenRef());
+        }
+        if (actionMatcher != null && screen != null) {
+            return simpleCommand(actionMatcher, screen, commandItem.isEdit(), commandItem.isReplace(), commandItem.getId(), commandItem.getName());
+        }
+
+        return null;
+    }
+
+    private Command simpleCommand(RequestMatcher matcher, Screen screen, boolean edit, boolean replace, String id, String name) {
+        return new Command() {
+
+            @Override
+            public void process(BotRequest botRequest, BotResponse botResponse, CommandChain chain) {
+                if (matcher.match(botRequest)) {
+                    if (replace) {
+                        botResponse.deleteMessage();
+                    }
+                    if (edit && !replace) {
+                        botResponse.edit(screen);
+                    } else {
+                        botResponse.send(screen);
+                    }
+                }
+                chain.processCommand(botRequest, botResponse);
+            }
+
+            @Override
+            public String toString() {
+                return "Command {" +
+                        "id=" + id +
+                        ", name=" + name +
+                        '}';
+            }
+        };
+    }
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowMediaResolverDelegate.java

@@ -0,0 +1,58 @@
+package ru.penkrat.stbf.templates.xml;
+
+import ru.penkrat.stbf.api.Media;
+import ru.penkrat.stbf.api.MediaType;
+import ru.penkrat.stbf.templates.MediaResolver;
+
+import java.util.Collection;
+import java.util.Optional;
+
+class FlowMediaResolverDelegate implements MediaResolver {
+
+    private final NamedItemResolver<MediaItem> videosResolver;
+    private final NamedItemResolver<MediaItem> photosResolver;
+
+    FlowMediaResolverDelegate(FlowRoot src) {
+        videosResolver = new NamedItemResolver<>(Traversal.traverse(src, FlowMediaResolverDelegate::videos));
+        photosResolver = new NamedItemResolver<>(Traversal.traverse(src, FlowMediaResolverDelegate::photos));
+    }
+
+    @Override
+    public Media getMedia(String name) {
+        Optional<Media> media = videosResolver.getOpt(name)
+                .map(FlowMediaResolverDelegate::toVideo);
+        if(media.isPresent()){
+            return media.get();
+        }
+
+        media = photosResolver.getOpt(name)
+                .map(FlowMediaResolverDelegate::toPhoto);
+        if(media.isPresent()){
+            return media.get();
+        }
+
+        throw new IllegalStateException("MediaElement not found by 'id' or 'name' " + name);
+    }
+
+    private static Media toVideo(MediaItem item) {
+        return Media.builder()
+                .mediaType(MediaType.VIDEO)
+                .url(item.getUrl())
+                .build();
+    }
+
+    private static Media toPhoto(MediaItem item) {
+        return Media.builder()
+                .mediaType(MediaType.PHOTO)
+                .url(item.getUrl())
+                .build();
+    }
+
+    private static Collection<MediaItem> videos(FlowRoot root) {
+        return root.getMedia().getVideos();
+    }
+
+    private static Collection<MediaItem> photos(FlowRoot root) {
+        return root.getMedia().getPhotos();
+    }
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowResolver.java

@@ -1,7 +1,8 @@
 package ru.penkrat.stbf.templates.xml;
 
 import ru.penkrat.stbf.templates.ActionResolver;
+import ru.penkrat.stbf.templates.CommandResolver;
 import ru.penkrat.stbf.templates.ScreenResolver;
 
-public interface FlowResolver extends ScreenResolver, ActionResolver {
+public interface FlowResolver extends ScreenResolver, ActionResolver, CommandResolver {
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowRoot.java

@@ -26,6 +26,15 @@ class FlowRoot {
     @JsonProperty("include")
     private List<IncludeItem> includes = new ArrayList<>();
 
+    @Getter
+    @JacksonXmlElementWrapper(localName = "commands")
+    @JsonProperty("command")
+    private List<CommandItem> commands = new ArrayList<>();
+
+    @Getter
+    @JsonProperty("media")
+    private MediaRoot media = new MediaRoot();
+
     @Getter
     private transient List<FlowRoot> included = new ArrayList<>();
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/FlowScreenResolverDelegate.java

@@ -6,10 +6,14 @@ import lombok.val;
 import ru.penkrat.stbf.api.Action;
 import ru.penkrat.stbf.api.Keyboard;
 import ru.penkrat.stbf.api.KeyboardBuilder;
+import ru.penkrat.stbf.api.Media;
 import ru.penkrat.stbf.api.Screen;
+import ru.penkrat.stbf.common.screen.MediaScreen;
+import ru.penkrat.stbf.common.screen.RamFileIdStorageMediaScreen;
 import ru.penkrat.stbf.common.screen.TextScreen;
 import ru.penkrat.stbf.templates.ActionResolver;
 import ru.penkrat.stbf.templates.KeyboardProvider;
+import ru.penkrat.stbf.templates.MediaResolver;
 import ru.penkrat.stbf.templates.ScreenResolver;
 import ru.penkrat.stbf.templates.TemplateRenderer;
 import ru.penkrat.stbf.templates.utils.ReflectionUtils;
@@ -25,11 +29,14 @@ class FlowScreenResolverDelegate implements ScreenResolver {
 
     private final ActionResolver actionResolver;
 
+    private final MediaResolver mediaResolver;
+
     @Setter
     private TemplateRenderer templateRenderer = new NoopTemplateRenderer();
 
-    FlowScreenResolverDelegate(FlowRoot src, ActionResolver actionResolver) {
+    FlowScreenResolverDelegate(FlowRoot src, ActionResolver actionResolver, MediaResolver mediaResolver) {
         this.actionResolver = actionResolver;
+        this.mediaResolver = mediaResolver;
         resolver = new NamedItemResolver<>(Traversal.traverse(src, FlowRoot::getScreens));
     }
 
@@ -37,14 +44,35 @@ class FlowScreenResolverDelegate implements ScreenResolver {
     public Screen getScreen(String name) {
         ScreenItem item = resolver.get(name);
 
-        return new TextScreen(item.getText(), buildKeyboard(item.getKeyboard(), null));
+        String text = item.getText();
+        if (!item.isPreserve()) {
+            text = StringUtils.ltrim(text);
+        }
+        if (StringUtils.isNotEmpty(item.getMediaRef())) {
+            final Media media = mediaResolver.getMedia(item.getMediaRef());
+            final MediaScreen mediaScreen = new MediaScreen(text, media, buildKeyboard(item.getKeyboard(), null));
+            return new RamFileIdStorageMediaScreen(mediaScreen);
+        }
+
+        return new TextScreen(text, buildKeyboard(item.getKeyboard(), null));
     }
 
     @Override
     public Screen getScreen(String name, Object context) {
         ScreenItem item = resolver.get(name);
 
-        return new TextScreen(templateRenderer.render(item.getText(), context),
+        String text = item.getText();
+        if (!item.isPreserve()) {
+            text = StringUtils.ltrim(text);
+        }
+        if (StringUtils.isNotEmpty(item.getMediaRef())) {
+            final Media media = mediaResolver.getMedia(item.getMediaRef());
+            final MediaScreen mediaScreen = new MediaScreen(templateRenderer.render(text, context), media,
+                    resolveKeyboard(item.getKeyboard(), context));
+            return new RamFileIdStorageMediaScreen(mediaScreen);
+        }
+
+        return new TextScreen(templateRenderer.render(text, context),
                 resolveKeyboard(item.getKeyboard(), context));
     }
 
@@ -81,6 +109,8 @@ class FlowScreenResolverDelegate implements ScreenResolver {
                         .map(btn -> getAction(btn))
                         .collect(Collectors.toList());
 
+                log.info("Keyboard: {}", buttons);
+
                 builder.row(buttons.toArray(new Action[buttons.size()]));
             }
 
@@ -97,6 +127,9 @@ class FlowScreenResolverDelegate implements ScreenResolver {
                 .text(btn.getText())
                 .requestContact(btn.isRequestContact())
                 .requestLocation(btn.isRequestLocation())
+                .url(btn.getUrl())
+                .callbackData(btn.getCallbackData())
+                .inline(StringUtils.isNotEmpty(btn.getUrl()) || StringUtils.isNotEmpty(btn.getCallbackData()))
                 .build();
     }
 

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/MediaItem.java

@@ -0,0 +1,14 @@
+package ru.penkrat.stbf.templates.xml;
+
+import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class MediaItem extends NamedItem {
+
+    @JacksonXmlProperty(isAttribute = true)
+    private String url;
+
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/MediaRoot.java

@@ -0,0 +1,21 @@
+package ru.penkrat.stbf.templates.xml;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlElementWrapper;
+import lombok.Getter;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class MediaRoot {
+
+    @Getter
+    @JacksonXmlElementWrapper(useWrapping = false)
+    @JsonProperty("video")
+    private List<MediaItem> videos = new ArrayList<>();
+
+    @Getter
+    @JacksonXmlElementWrapper(useWrapping = false)
+    @JsonProperty("photo")
+    private List<MediaItem> photos = new ArrayList<>();
+}

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/NamedItemResolver.java

@@ -5,6 +5,7 @@ import ru.penkrat.stbf.templates.utils.StringUtils;
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.stream.Collectors;
 
 class NamedItemResolver<T extends NamedItem> {
@@ -39,4 +40,22 @@ class NamedItemResolver<T extends NamedItem> {
         throw new IllegalStateException("Element not found by 'id' or 'name' " + key);
     }
 
+    Optional<T> getOpt(String key) {
+        List<T> list = byId.get(key);
+        if (list != null) {
+            if (list.size() > 1) {
+                throw new IllegalStateException("Non unique 'id' " + key);
+            }
+            return Optional.of(list.get(0));
+        }
+        list = byName.get(key);
+        if (list != null) {
+            if (list.size() > 1) {
+                throw new IllegalStateException("Non unique 'name' " + key);
+            }
+            return Optional.of(list.get(0));
+        }
+        return Optional.empty();
+    }
+
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/ScreenItem.java

@@ -1,5 +1,6 @@
 package ru.penkrat.stbf.templates.xml;
 
+import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -9,6 +10,12 @@ class ScreenItem extends NamedItem {
 
     private String text;
 
+    @JacksonXmlProperty(isAttribute = true)
+    private String mediaRef;
+
     private KeyboardWrapper keyboard = new KeyboardWrapper();
 
+    @JacksonXmlProperty(isAttribute = true)
+    private boolean preserve;
+
 }

stbf-templates/src/main/java/ru/penkrat/stbf/templates/xml/XmlFlowResolver.java

@@ -2,12 +2,13 @@ package ru.penkrat.stbf.templates.xml;
 
 import lombok.extern.slf4j.Slf4j;
 import ru.penkrat.stbf.api.Action;
+import ru.penkrat.stbf.api.Command;
+import ru.penkrat.stbf.api.RequestMatcher;
 import ru.penkrat.stbf.api.Screen;
 import ru.penkrat.stbf.templates.TemplateRenderer;
 
-import java.io.File;
-import java.io.IOException;
 import java.io.InputStream;
+import java.util.Collection;
 
 @Slf4j
 public class XmlFlowResolver implements FlowResolver {
@@ -16,17 +17,23 @@ public class XmlFlowResolver implements FlowResolver {
 
     private final FlowActionResolverDelegate actionDelegate;
     private final FlowScreenResolverDelegate screenDelegate;
+    private final FlowCommandResolverDelegate commandResolver;
+    private final FlowMediaResolverDelegate mediaResolver;
 
     public XmlFlowResolver(String filename) {
         FlowRoot flow = reader.read(filename);
         actionDelegate = new FlowActionResolverDelegate(flow);
-        screenDelegate = new FlowScreenResolverDelegate(flow, this);
+        mediaResolver = new FlowMediaResolverDelegate(flow);
+        screenDelegate = new FlowScreenResolverDelegate(flow, this, mediaResolver);
+        commandResolver = new FlowCommandResolverDelegate(flow, actionDelegate, screenDelegate);
     }
 
     public XmlFlowResolver(InputStream is) {
         FlowRoot flow = reader.read(is);
         actionDelegate = new FlowActionResolverDelegate(flow);
-        screenDelegate = new FlowScreenResolverDelegate(flow, this);
+        mediaResolver = new FlowMediaResolverDelegate(flow);
+        screenDelegate = new FlowScreenResolverDelegate(flow, this, mediaResolver);
+        commandResolver = new FlowCommandResolverDelegate(flow, actionDelegate, screenDelegate);
     }
 
     @Override
@@ -44,7 +51,17 @@ public class XmlFlowResolver implements FlowResolver {
         return actionDelegate.getAction(name);
     }
 
+    @Override
+    public RequestMatcher getMatcher(String actionName) {
+        return actionDelegate.getMatcher(actionName);
+    }
+
     public void setTemplateRenderer(TemplateRenderer templateRenderer) {
         screenDelegate.setTemplateRenderer(templateRenderer);
     }
+
+    @Override
+    public Collection<Command> getCommands() {
+        return commandResolver.getCommands();
+    }
 }

stbf-templates/src/test/java/ru/penkrat/stbf/templates/xml/FlowCommandsTest.java

@@ -0,0 +1,18 @@
+package ru.penkrat.stbf.templates.xml;
+
+import org.junit.Test;
+import ru.penkrat.stbf.api.Command;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class FlowCommandsTest {
+
+    @Test
+    public void testReadCommands() {
+        XmlFlowResolver resolver = new XmlFlowResolver("classpath:/ru/penkrat/stbf/templates/xml/flow.xml");
+        assertThat(resolver.getCommands()).hasSize(1);
+
+        final Command command = resolver.getCommands().iterator().next();
+        assertThat(command.toString()).contains("startCommand");
+    }
+}

stbf-templates/src/test/java/ru/penkrat/stbf/templates/xml/XmlWriterTest.java

@@ -1,10 +1,11 @@
 package ru.penkrat.stbf.templates.xml;
 
-import org.junit.Before;
-import org.junit.Test;
-
 import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.dataformat.xml.XmlMapper;
+import lombok.val;
+import org.junit.Before;
+import org.junit.Test;
+import ru.penkrat.stbf.api.Command;
 
 public class XmlWriterTest {
 
@@ -42,6 +43,7 @@ public class XmlWriterTest {
 		item2.setId("2");
 		item2.setName("screen-2");
 		item2.setText("Hello, {{ name }}");
+		item2.setMediaRef("12");
 
 		item2.getKeyboard().setFactoryMethod("getKeyboard");
 
@@ -52,6 +54,22 @@ public class XmlWriterTest {
 
 		root.getIncludes().add(new IncludeItem());
 
+		final CommandItem commandItem = new CommandItem();
+		commandItem.setActionRef("action-1");
+		commandItem.setScreenRef("screen-1");
+		commandItem.setClazz(Command.class.getCanonicalName());
+		root.getCommands().add(commandItem);
+
+
+		MediaItem video1 = new MediaItem();
+		video1.setId("11");
+		video1.setUrl("https://example.com/test.mpg");
+		MediaItem photo1 = new MediaItem();
+		photo1.setId("12");
+		photo1.setUrl("https://example.com/test.jpg");
+		root.getMedia().getVideos().add(video1);
+		root.getMedia().getPhotos().add(photo1);
+
 		String xml = mapper.writeValueAsString(root);
 
 		System.out.println(xml);

stbf-templates/src/test/resources/ru/penkrat/stbf/templates/xml/flow.xml

@@ -4,7 +4,7 @@
     <include file="/test/a.xml"/>
 
     <actions>
-        <action id="2001" requestContact="true">Send phone</action>
+        <action id="2001" name="start" command="/start">Start</action>
     </actions>
     <screens>
         <screen id="5001" name="screen-5001">
@@ -17,4 +17,7 @@
             </keyboard>
         </screen>
     </screens>
+    <commands>
+        <command actionRef="2001" screenRef="5001" id="5002" name="startCommand"/>
+    </commands>
 </flow>

stbf-test/pom.xml

@@ -1,12 +1,10 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 	<parent>
 		<artifactId>stbf-parent</artifactId>
 		<groupId>ru.penkrat.stbf</groupId>
-		<version>0.0.1-SNAPSHOT</version>
+		<version>0.0.2-SNAPSHOT</version>
 	</parent>
 
 	<artifactId>stbf-test</artifactId>
@@ -16,12 +14,12 @@
 		<dependency>
 			<groupId>ru.penkrat.stbf</groupId>
 			<artifactId>stbf-api</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>0.0.2-SNAPSHOT</version>
 		</dependency>
 		<dependency>
 			<groupId>ru.penkrat.stbf</groupId>
 			<artifactId>stbf-common</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>0.0.2-SNAPSHOT</version>
 			<scope>test</scope>
 		</dependency>
 		<dependency>

stbf-test/src/main/java/ru/penkrat/stbf/test/BotRequestImpl.java

@@ -6,6 +6,7 @@ import java.util.Random;
 import lombok.Builder;
 import lombok.Getter;
 import ru.penkrat.stbf.api.BotRequest;
+import ru.penkrat.stbf.api.BotSession;
 
 @Builder
 class BotRequestImpl implements BotRequest {
@@ -14,6 +15,7 @@ class BotRequestImpl implements BotRequest {
 	private String phoneNumber;
 	private String callbackData;
 	private String callbackMessageText;
+	private BotSession session;
 
 	@Getter
 	@Builder.Default
@@ -39,4 +41,9 @@ class BotRequestImpl implements BotRequest {
 		return Optional.ofNullable(callbackMessageText);
 	}
 
+	@Override
+	public BotSession getSession() {
+		return session;
+	}
+
 }