add simple webhook server

Author: ba0f3

examples/webhook_simple.nim

@@ -0,0 +1,35 @@
+import ../telebot, asyncdispatch, logging, options, sam
+from strutils import strip
+
+var L = newConsoleLogger(fmtStr="$levelname, [$time] ")
+addHandler(L)
+
+const API_KEY = slurp("secret.key").strip()
+
+proc updateHandler(b: Telebot, u: Update) {.async.} =
+  if not u.message.isSome:
+    return
+  var response = u.message.get
+  if response.text.isSome:
+    let text = response.text.get
+    var message = newMessage(response.chat.id, text)
+    message.disableNotification = true
+    message.replyToMessageId = response.messageId
+    message.parseMode = "markdown"
+    discard await b.send(message)
+
+
+proc greatingHandler(b: Telebot, c: Command) {.async.} =
+  var message = newMessage(c.message.chat.id, "hello " & c.message.fromUser.get().firstName)
+  message.disableNotification = true
+  message.replyToMessageId = c.message.messageId
+  message.parseMode = "markdown"
+  discard b.send(message)
+
+when isMainModule:
+  let bot = newTeleBot(API_KEY)
+
+  bot.onUpdate(updateHandler)
+  bot.onCommand("hello", greatingHandler)
+
+  bot.startWebhook("rNFRWJqqmxteVtjciNFxuNoznphWzxYFNscicjrYPHVjrnYrFVtdKNkckk3hjAYH", "https://0899ba14.ngrok.io/rNFRWJqqmxteVtjciNFxuNoznphWzxYFNscicjrYPHVjrnYrFVtdKNkckk3hjAYH")

telebot/api.nim

@@ -1,4 +1,6 @@
 import httpclient, sam, asyncdispatch, utils, strutils, options, strtabs
+from tables import hasKey, `[]`
+import types, keyboard
 
 magic Message:
   chatId: int64

telebot/keyboard.nim

@@ -1,4 +1,4 @@
-import types, sam, strutils, utils, options, tables
+import types, strutils, utils, options
 
 proc initKeyBoardButton*(text: string): KeyboardButton =
   result.text = text

telebot/webhook.nim

@@ -1,5 +1,5 @@
-import asyncdispatch, httpclient, strutils, sam
-import utils, types
+import asyncdispatch, asynchttpserver, httpclient, strutils, sam, options
+import utils, types, api
 
 type
   WebhookInfo* = object
@@ -50,3 +50,27 @@ proc getWebhookInfo*(b: TeleBot): Future[WebhookInfo] {.async.} =
   END_POINT("getWebhookInfo")
   let res = await makeRequest(b, endpoint % b.token)
   result = getWebhookInfo(res)
+
+
+proc startWebhook*(b: Telebot, secret, url: string, port = 8080) =
+  try:
+    let me = waitFor b.getMe()
+    if me.username.isSome:
+      b.username = me.username.get().toLowerAscii()
+  except IOError, OSError:
+    d("Unable to fetch my info ", getCurrentExceptionMsg())
+
+  waitFor b.setWebhook(url)
+
+  proc callback(req: Request) {.async, gcsafe.} =
+    if req.url.path == "/" & secret:
+      let
+        json = parse(req.body)
+        update = unmarshal(json, Update)
+      await b.handleUpdate(update)
+      await req.respond(Http200, "OK")
+    else:
+      await req.respond(Http404, "Not Found")
+
+  var server = newAsyncHttpServer()
+  waitFor server.serve(port=port.Port, callback=callback)