feat(plugin): add dummy stream plugin

commands/stream.go

@@ -0,0 +1,54 @@
+package commands
+
+import (
+	"fmt"
+
+	"EverythingSuckz/fsb/config"
+	"EverythingSuckz/fsb/utils"
+
+	"github.com/celestix/gotgproto/dispatcher"
+	"github.com/celestix/gotgproto/dispatcher/handlers"
+	"github.com/celestix/gotgproto/dispatcher/handlers/filters"
+	"github.com/celestix/gotgproto/ext"
+	"github.com/gotd/td/tg"
+)
+
+func (m *command) LoadStream(dispatcher dispatcher.Dispatcher) {
+	defer m.log.Sugar().Info("Loaded stream command")
+	dispatcher.AddHandler(
+		handlers.NewMessage(filters.Message.Media, sendLink),
+	)
+}
+
+func sendLink(ctx *ext.Context, u *ext.Update) error {
+	if u.EffectiveMessage.Media == nil {
+		return dispatcher.EndGroups
+	}
+	if len(u.Entities.Chats) != 0 {
+		return dispatcher.EndGroups
+	}
+	chatId := u.EffectiveChat().GetID()
+	update, err := ctx.ForwardMessages(
+		chatId,
+		config.ValueOf.LogChannelID,
+		&tg.MessagesForwardMessagesRequest{
+			FromPeer: &tg.InputPeerChat{ChatID: chatId},
+			ID:       []int{u.EffectiveMessage.ID},
+			ToPeer:   &tg.InputPeerChannel{ChannelID: config.ValueOf.LogChannelID, AccessHash: 0},
+		},
+	)
+	if err != nil {
+		utils.Logger.Sugar().Error(err)
+		ctx.Reply(u, fmt.Sprintf("Error - %s", err.Error()), nil)
+		return dispatcher.EndGroups
+	}
+	messageID := update.(*tg.Updates).Updates[0].(*tg.UpdateMessageID).ID
+	if err != nil {
+		utils.Logger.Sugar().Error(err)
+		ctx.Reply(u, fmt.Sprintf("Error - %s", err.Error()), nil)
+		return dispatcher.EndGroups
+	}
+	link := fmt.Sprintf("%s/stream/%d", config.ValueOf.Host, messageID)
+	ctx.Reply(u, link, nil)
+	return dispatcher.EndGroups
+}

config/config.go

@@ -18,6 +18,7 @@ type config struct {
 	LogChannelID int64  `envconfig:"LOG_CHANNEL" required:"false"`
 	Dev          bool   `envconfig:"DEV" default:"false"`
 	Port         int    `envconfig:"PORT" default:"8080"`
+	Host         string `envconfig:"HOST" default:"http://localhost:8080"`
 }
 
 func (c *config) setupEnvVars() {