main.go

package main

import (
	"flag"
	"fmt"
	"log/slog"
	"net/http"
	"os"
	"os/signal"
	"time"

	"github.com/damonto/telegram-sms/internal/app"
	"github.com/damonto/telegram-sms/internal/pkg/config"
	"github.com/damonto/telegram-sms/internal/pkg/modem"
	"github.com/damonto/telegram-sms/internal/pkg/util"
	"github.com/maltegrosse/go-modemmanager"
	"gopkg.in/telebot.v3"
)

var Version string

func init() {
	flag.StringVar(&config.C.BotToken, "bot-token", "", "telegram bot token")
	flag.Var(&config.C.AdminId, "admin-id", "telegram admin id")
	flag.StringVar(&config.C.Endpoint, "endpoint", "https://api.telegram.org", "telegram endpoint")
	flag.BoolVar(&config.C.Verbose, "verbose", false, "enable verbose mode")
	flag.Parse()
}

func main() {
	if config.C.Verbose {
		slog.SetLogLoggerLevel(slog.LevelDebug)
	}
	if os.Geteuid() != 0 {
		slog.Error("please run as root")
		os.Exit(1)
	}

	if err := config.C.IsValid(); err != nil {
		slog.Error("config is invalid", "error", err)
		os.Exit(1)
	}

	slog.Info("you are using", "version", Version)

	bot, err := telebot.NewBot(telebot.Settings{
		Token: config.C.BotToken,
		URL:   config.C.Endpoint,
		Client: &http.Client{
			Timeout: 30 * time.Second,
			Transport: &http.Transport{
				Proxy: http.ProxyFromEnvironment,
			},
		},
		Poller: &telebot.LongPoller{Timeout: 30 * time.Second},
	})
	if err != nil {
		slog.Error("failed to create bot", "error", err)
		panic(err)
	}

	mmgr, err := modem.NewManager()
	if err != nil {
		slog.Error("failed to create modem manager", "error", err)
		panic(err)
	}

	go func() {
		mmgr.SubscribeMessaging(func(modem *modem.Modem, sms modemmanager.Sms) {
			subscribe(bot, modem, sms)
		})
	}()

	go app.NewApp(bot).Start()

	sig := make(chan os.Signal, 1)
	signal.Notify(sig, os.Interrupt)
	<-sig
}

func subscribe(bot *telebot.Bot, modem *modem.Modem, sms modemmanager.Sms) {
	sender, _ := sms.GetNumber()
	operatorName, _ := modem.GetOperatorName()
	text, _ := sms.GetText()
	slog.Info("new SMS received", "operatorName", operatorName, "sender", sender, "text", text)

	template := `
*\[%s\] \- %s*
%s
`
	message := fmt.Sprintf(
		template,
		util.EscapeText(operatorName),
		util.EscapeText(sender),
		fmt.Sprintf("`%s`", util.EscapeText(text)),
	)
	for _, adminId := range config.C.AdminId.ToInt64() {
		if _, err := bot.Send(
			telebot.ChatID(adminId),
			message,
			&telebot.SendOptions{
				ParseMode:             telebot.ModeMarkdownV2,
				DisableWebPagePreview: true,
			}); err != nil {
			slog.Error("failed to send message", "error", err)
		}
	}
}