feat: add Telegram channel support

cmd/handlers.go

@@ -198,6 +198,9 @@ func initHandlers(g *fastglue.Fastglue, hub *ws.Hub) {
 	g.PUT("/api/v1/webhooks/{id}/toggle", perm(handleToggleWebhook, "webhooks:manage"))
 	g.POST("/api/v1/webhooks/{id}/test", perm(handleTestWebhook, "webhooks:manage"))
 
+	// Telegram webhook (public endpoint, no auth required - Telegram sends updates here).
+	g.POST("/api/v1/inboxes/telegram/{id}/webhook", handleTelegramWebhook)
+
 	// Context Links.
 	g.GET("/api/v1/context-links", perm(handleGetContextLinks, "context_links:manage"))
 	g.GET("/api/v1/context-links/active", auth(handleGetActiveContextLinks))

cmd/inboxes.go

@@ -13,6 +13,7 @@ import (
 	"github.com/abhinavxd/libredesk/internal/inbox"
 	"github.com/abhinavxd/libredesk/internal/inbox/channel/email/oauth"
 	"github.com/abhinavxd/libredesk/internal/inbox/channel/livechat"
+	"github.com/abhinavxd/libredesk/internal/inbox/channel/telegram"
 	imodels "github.com/abhinavxd/libredesk/internal/inbox/models"
 	"github.com/valyala/fasthttp"
 	"github.com/zerodha/fastglue"
@@ -340,6 +341,13 @@ func validateInbox(app *App, inbox imodels.Inbox) error {
 			return err
 		}
 	}
+
+	// Validate telegram channel config.
+	if inbox.Channel == telegram.ChannelTelegram {
+		if err := validateTelegramConfig(app, inbox.Config); err != nil {
+			return err
+		}
+	}
 	return nil
 }
 
@@ -453,3 +461,17 @@ func trimEmailConfig(cfg *imodels.Config) {
 		cfg.OAuth.TenantID = strings.TrimSpace(cfg.OAuth.TenantID)
 	}
 }
+
+// validateTelegramConfig validates the Telegram inbox configuration.
+func validateTelegramConfig(app *App, configJSON json.RawMessage) error {
+	var cfg telegram.Config
+	if err := json.Unmarshal(configJSON, &cfg); err != nil {
+		return envelope.NewError(envelope.InputError, app.i18n.T("globals.messages.somethingWentWrong"), nil)
+	}
+
+	if cfg.BotToken == "" {
+		return envelope.NewError(envelope.InputError, app.i18n.Ts("globals.messages.empty", "name", "bot_token"), nil)
+	}
+
+	return nil
+}

cmd/init.go

@@ -31,6 +31,7 @@ import (
 	"github.com/abhinavxd/libredesk/internal/inbox"
 	"github.com/abhinavxd/libredesk/internal/inbox/channel/email"
 	"github.com/abhinavxd/libredesk/internal/inbox/channel/livechat"
+	"github.com/abhinavxd/libredesk/internal/inbox/channel/telegram"
 	imodels "github.com/abhinavxd/libredesk/internal/inbox/models"
 	"github.com/abhinavxd/libredesk/internal/macro"
 	"github.com/abhinavxd/libredesk/internal/media"
@@ -740,6 +741,34 @@ func initLiveChatInbox(inboxRecord imodels.Inbox, msgStore inbox.MessageStore, u
 	return inbox, nil
 }
 
+// initTelegramInbox initializes the Telegram bot inbox.
+func initTelegramInbox(inboxRecord imodels.Inbox, msgStore inbox.MessageStore, usrStore inbox.UserStore) (inbox.Inbox, error) {
+	var config telegram.Config
+
+	// Load JSON data into Koanf.
+	if err := ko.Load(rawbytes.Provider([]byte(inboxRecord.Config)), kjson.Parser()); err != nil {
+		return nil, fmt.Errorf("loading config: %w", err)
+	}
+
+	if err := ko.UnmarshalWithConf("", &config, koanf.UnmarshalConf{Tag: "json"}); err != nil {
+		return nil, fmt.Errorf("unmarshalling `%s` %s config: %w", inboxRecord.Channel, inboxRecord.Name, err)
+	}
+
+	inb, err := telegram.New(msgStore, usrStore, telegram.Opts{
+		ID:     inboxRecord.ID,
+		Config: config,
+		Lo:     initLogger("telegram_inbox"),
+	})
+
+	if err != nil {
+		return nil, fmt.Errorf("initializing `%s` inbox: `%s` error : %w", inboxRecord.Channel, inboxRecord.Name, err)
+	}
+
+	log.Printf("`%s` inbox successfully initialized", inboxRecord.Name)
+
+	return inb, nil
+}
+
 // makeInboxInitializer creates an inbox initializer function.
 func makeInboxInitializer(mgr *inbox.Manager, signAvatarURL func(*null.String)) func(imodels.Inbox, inbox.MessageStore, inbox.UserStore) (inbox.Inbox, error) {
 	return func(inboxR imodels.Inbox, msgStore inbox.MessageStore, usrStore inbox.UserStore) (inbox.Inbox, error) {
@@ -748,6 +777,8 @@ func makeInboxInitializer(mgr *inbox.Manager, signAvatarURL func(*null.String))
 			return initEmailInbox(inboxR, msgStore, usrStore, mgr)
 		case inbox.ChannelLiveChat:
 			return initLiveChatInbox(inboxR, msgStore, usrStore, signAvatarURL)
+		case inbox.ChannelTelegram:
+			return initTelegramInbox(inboxR, msgStore, usrStore)
 		default:
 			return nil, fmt.Errorf("unknown inbox channel: %s", inboxR.Channel)
 		}

cmd/telegram.go

@@ -0,0 +1,58 @@
+package main
+
+import (
+	"encoding/json"
+	"strconv"
+
+	"github.com/abhinavxd/libredesk/internal/inbox"
+	"github.com/abhinavxd/libredesk/internal/inbox/channel/telegram"
+	"github.com/valyala/fasthttp"
+	"github.com/zerodha/fastglue"
+)
+
+func handleTelegramWebhook(r *fastglue.Request) error {
+	var app = r.Context.(*App)
+
+	inboxID, err := strconv.Atoi(r.RequestCtx.UserValue("id").(string))
+	if err != nil || inboxID == 0 {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusBadRequest)
+		return nil
+	}
+
+	inb, err := app.inbox.Get(inboxID)
+	if err != nil {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusNotFound)
+		return nil
+	}
+
+	if inb.Channel() != inbox.ChannelTelegram {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusBadRequest)
+		return nil
+	}
+
+	tgInbox, ok := inb.(*telegram.Telegram)
+	if !ok {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusInternalServerError)
+		return nil
+	}
+
+	// Verify webhook authenticity using X-Telegram-Bot-Api-Secret-Token header.
+	secretToken := string(r.RequestCtx.Request.Header.Peek("X-Telegram-Bot-Api-Secret-Token"))
+	if !tgInbox.VerifyWebhook(secretToken) {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusUnauthorized)
+		return nil
+	}
+
+	var update telegram.Update
+	if err := json.Unmarshal(r.RequestCtx.PostBody(), &update); err != nil {
+		r.RequestCtx.SetStatusCode(fasthttp.StatusBadRequest)
+		return nil
+	}
+
+	if err := tgInbox.ProcessWebhookUpdate(update); err != nil {
+		app.lo.Error("telegram webhook: error processing update", "error", err)
+	}
+
+	r.RequestCtx.SetStatusCode(fasthttp.StatusOK)
+	return nil
+}

cmd/upgrade.go

@@ -42,6 +42,7 @@ var migList = []migFunc{
 	{"v1.0.1", migrations.V1_0_1},
 	{"v2.0.0", migrations.V2_0_0},
 	{"v2.2.0", migrations.V2_2_0},
+	{"v2.3.0", migrations.V2_3_0},
 }
 
 // upgrade upgrades the database to the current version by running SQL migration files

frontend/apps/main/src/features/admin/inbox/TelegramInboxForm.vue

@@ -0,0 +1,183 @@
+<template>
+  <form @submit="onSubmit" class="space-y-6 w-full max-w-lg">
+    <FormField v-slot="{ componentField }" name="name">
+      <FormItem>
+        <FormLabel>{{ $t('globals.terms.name') }}</FormLabel>
+        <FormControl>
+          <Input type="text" placeholder="My Telegram Bot" v-bind="componentField" />
+        </FormControl>
+        <FormDescription>
+          {{ $t('admin.inbox.telegram.name.description') }}
+        </FormDescription>
+        <FormMessage />
+      </FormItem>
+    </FormField>
+
+    <FormField v-slot="{ componentField }" name="bot_token">
+      <FormItem>
+        <FormLabel>{{ $t('admin.inbox.telegram.botToken') }}</FormLabel>
+        <FormControl>
+          <Input type="password" placeholder="123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11" v-bind="componentField" />
+        </FormControl>
+        <FormDescription>
+          {{ $t('admin.inbox.telegram.botToken.description') }}
+        </FormDescription>
+        <FormMessage />
+      </FormItem>
+    </FormField>
+
+    <FormField v-slot="{ componentField }" name="bot_name">
+      <FormItem>
+        <FormLabel>{{ $t('admin.inbox.telegram.botName') }}</FormLabel>
+        <FormControl>
+          <Input type="text" placeholder="@my_support_bot" v-bind="componentField" />
+        </FormControl>
+        <FormDescription>
+          {{ $t('admin.inbox.telegram.botName.description') }}
+        </FormDescription>
+        <FormMessage />
+      </FormItem>
+    </FormField>
+
+    <FormField v-slot="{ componentField, handleChange }" name="enabled">
+      <FormItem>
+        <SwitchField
+          :title="$t('globals.terms.enabled')"
+          :checked="componentField.modelValue"
+          @update:checked="handleChange"
+        />
+      </FormItem>
+    </FormField>
+
+    <FormField v-slot="{ componentField, handleChange }" name="csat_enabled">
+      <FormItem>
+        <SwitchField
+          :title="$t('admin.inbox.csatSurveys')"
+          :description="$t('admin.inbox.csatSurveys.description_1')"
+          :checked="componentField.modelValue"
+          @update:checked="handleChange"
+        />
+      </FormItem>
+    </FormField>
+
+    <FormField v-slot="{ componentField, handleChange }" name="prompt_tags_on_reply">
+      <FormItem>
+        <SwitchField
+          :title="$t('admin.inbox.promptTagsOnReply')"
+          :description="$t('admin.inbox.promptTagsOnReply.description')"
+          :checked="componentField.modelValue"
+          @update:checked="handleChange"
+        />
+      </FormItem>
+    </FormField>
+
+    <!-- Webhook URL info (shown only in edit mode) -->
+    <div v-if="!isNewForm && webhookUrl" class="rounded-md border p-4 space-y-2">
+      <p class="text-sm font-medium">{{ $t('admin.inbox.telegram.webhookUrl') }}</p>
+      <div class="flex items-center gap-2">
+        <code class="text-xs bg-muted px-2 py-1 rounded flex-1 break-all">{{ webhookUrl }}</code>
+        <Button type="button" variant="outline" size="sm" @click="copyWebhookUrl">
+          {{ $t('globals.terms.copy') }}
+        </Button>
+      </div>
+      <p class="text-xs text-muted-foreground">
+        {{ $t('admin.inbox.telegram.webhookUrl.description') }}
+      </p>
+    </div>
+
+    <Button type="submit" :disabled="isLoading">
+      <Loader2 v-if="isLoading" class="w-4 h-4 mr-2 animate-spin" />
+      {{ isNewForm ? $t('globals.messages.create') : $t('globals.messages.save') }}
+    </Button>
+  </form>
+</template>
+
+<script setup>
+import { computed } from 'vue'
+import { useForm } from 'vee-validate'
+import { toTypedSchema } from '@vee-validate/zod'
+import * as z from 'zod'
+import { Button } from '@shared-ui/components/ui/button/index.js'
+import { Input } from '@shared-ui/components/ui/input/index.js'
+import {
+  FormControl,
+  FormDescription,
+  FormField,
+  FormItem,
+  FormLabel,
+  FormMessage
+} from '@shared-ui/components/ui/form/index.js'
+import SwitchField from '@shared-ui/components/SwitchField.vue'
+import { Loader2 } from 'lucide-vue-next'
+import { useI18n } from 'vue-i18n'
+import { EMITTER_EVENTS } from '@/constants/emitterEvents.js'
+import { useEmitter } from '@/composables/useEmitter'
+
+const { t } = useI18n()
+const emitter = useEmitter()
+
+const props = defineProps({
+  initialValues: {
+    type: Object,
+    default: () => ({})
+  },
+  submitForm: {
+    type: Function,
+    required: true
+  },
+  isLoading: {
+    type: Boolean,
+    default: false
+  },
+  isNewForm: {
+    type: Boolean,
+    default: false
+  }
+})
+
+const formSchema = toTypedSchema(
+  z.object({
+    name: z.string().min(1, t('globals.messages.required')),
+    bot_token: z.string().min(1, t('globals.messages.required')),
+    bot_name: z.string().optional().default(''),
+    enabled: z.boolean().default(true),
+    csat_enabled: z.boolean().default(false),
+    prompt_tags_on_reply: z.boolean().default(false)
+  })
+)
+
+const form = useForm({
+  validationSchema: formSchema,
+  initialValues: {
+    name: props.initialValues?.name || '',
+    bot_token: props.initialValues?.config?.bot_token || '',
+    bot_name: props.initialValues?.config?.bot_name || '',
+    enabled: props.initialValues?.enabled ?? true,
+    csat_enabled: props.initialValues?.csat_enabled ?? false,
+    prompt_tags_on_reply: props.initialValues?.prompt_tags_on_reply ?? false
+  }
+})
+
+const webhookUrl = computed(() => {
+  if (props.initialValues?.id) {
+    const baseUrl = window.location.origin
+    return `${baseUrl}/api/v1/inboxes/telegram/${props.initialValues.id}/webhook`
+  }
+  return ''
+})
+
+const copyWebhookUrl = async () => {
+  try {
+    await navigator.clipboard.writeText(webhookUrl.value)
+    emitter.emit(EMITTER_EVENTS.SHOW_TOAST, {
+      description: t('globals.messages.savedSuccessfully')
+    })
+  } catch (error) {
+    console.error('Failed to copy:', error)
+  }
+}
+
+const onSubmit = form.handleSubmit(async (values) => {
+  await props.submitForm(values)
+})
+</script>