Simple BotThread Telegram

[Swarlog]

Un pequeño ejemplo de manejo de actualizaciones básicas bot puesta en común. Creado por UnAfraid.

Código [Seleccionar] Expandir

diff --git a/src/main/java/org/codespartans/telegram/bot/BotThread.java b/src/main/java/org/codespartans/telegram/bot/BotThread.java
new file mode 100644
index 0000000..2ad198d
--- /dev/null
+++ b/src/main/java/org/codespartans/telegram/bot/BotThread.java
@@ -0,0 +1,100 @@
+package org.codespartans.telegram.bot;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.prefs.Preferences;
+
+import org.codespartans.telegram.bot.models.Update;
+
+/**
+ * @author UnAfraid
+ */
+public final class BotThread extends Thread {
+	private static final Preferences PREFERENCES = Preferences.userRoot();
+	private static final String UPDATE_OFFSET_KEY = "updateOffset";
+	private final Set<ITelegramListener> _listeners = ConcurrentHashMap.newKeySet();
+
+	private final TelegramBot _bot;
+	private final int _limit;
+	private final int _timeout;
+
+	/**
+	 * Initializes new BotThread that will handle the message receiving 
+	 * @param token Each bot is given a unique authentication token <a href="https://core.telegram.org/bots#botfather">when it is created</a>.
+	 *              The token looks something like 123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11,
+	 *              but we'll use simply <token> in this document instead.
+	 *              You can learn about obtaining tokens and generating new ones in <a href="https://core.telegram.org/bots#botfather">this document</a>.
+	 */
+	public BotThread(String token) {
+		this(token, 100, 0);
+	}
+	
+	/**
+	 * Initializes new BotThread that will handle the message receiving 
+	 * @param token Each bot is given a unique authentication token <a href="https://core.telegram.org/bots#botfather">when it is created</a>.
+	 *              The token looks something like 123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11,
+	 *              but we'll use simply <token> in this document instead.
+	 *              You can learn about obtaining tokens and generating new ones in <a href="https://core.telegram.org/bots#botfather">this document</a>.
+	 * @param limit   Limits the number of updates to be retrieved. Values between 1-100 are accepted. Defaults to 100
+	 * @param timeout Timeout in seconds for long polling. Defaults to 0, i.e. usual short polling
+	 */
+	public BotThread(String token, int limit, int timeout) {
+		super("Bot Thread");
+		_limit = limit;
+		_timeout = timeout;
+		_bot = TelegramBot.getInstance(token);
+		start();
+	}
+
+	@Override
+	public void run() {
+		try {
+			while (!isInterrupted()) {
+				try {
+					final int currentOffset = PREFERENCES.getInt(UPDATE_OFFSET_KEY, 0);
+					final List<Update> updates = _bot.getUpdates(currentOffset, _limit, _timeout);
+					for (Update update : updates) {
+						PREFERENCES.putInt(UPDATE_OFFSET_KEY, update.getUpdate_id() + 1);
+						_listeners.forEach(listener -> listener.onMessageReceived(_bot, update.getMessage()));
+					}
+				} catch (Exception e) {
+					_listeners.forEach(listener -> listener.onExceptionCaught(_bot, e));
+				}
+
+				try {
+					Thread.sleep(100);
+				} catch (Exception e) {
+				}
+			}
+		} catch (Exception e) {
+			_listeners.forEach(listener -> listener.onExceptionCaught(_bot, e));
+		}
+	}
+
+	/**
+	 * Attaches listener that will be used to notify upon new message received
+	 * 
+	 * @param listener
+	 */
+	public void addListener(ITelegramListener listener) {
+		_listeners.add(listener);
+	}
+
+	/**
+	 * Removes attached listener
+	 * 
+	 * @param listener
+	 */
+	public void removeListener(ITelegramListener listener) {
+		_listeners.remove(listener);
+	}
+
+	/**
+	 * Interrupts the thread and stops the thread
+	 */
+	public void shutdown() {
+		interrupt();
+	}
+}
diff --git a/src/main/java/org/codespartans/telegram/bot/ITelegramListener.java b/src/main/java/org/codespartans/telegram/bot/ITelegramListener.java
new file mode 100644
index 0000000..35e1e6c
--- /dev/null
+++ b/src/main/java/org/codespartans/telegram/bot/ITelegramListener.java
@@ -0,0 +1,22 @@
+package org.codespartans.telegram.bot;
+
+import org.codespartans.telegram.bot.models.Message;
+
+/**
+ * @author UnAfraid
+ */
+public interface ITelegramListener {
+	/**
+	 * Invoked as soon as new message is received.
+	 * @param bot
+	 * @param message
+	 */
+	void onMessageReceived(TelegramBot bot, Message message);
+	
+	/**
+	 * Invoked as soon as an exception is caught
+	 * @param bot
+	 * @param e
+	 */
+	void onExceptionCaught(TelegramBot bot, Exception e);
+}