mirror of
https://github.com/iyear/tdl
synced 2025-01-07 03:16:41 +08:00
42 lines
1.6 KiB
Go
42 lines
1.6 KiB
Go
package cmd
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/gotd/td/telegram"
|
|
"github.com/spf13/cobra"
|
|
|
|
"github.com/iyear/tdl/app/forward"
|
|
"github.com/iyear/tdl/core/forwarder"
|
|
"github.com/iyear/tdl/core/logctx"
|
|
"github.com/iyear/tdl/core/storage"
|
|
)
|
|
|
|
func NewForward() *cobra.Command {
|
|
var opts forward.Options
|
|
|
|
cmd := &cobra.Command{
|
|
Use: "forward",
|
|
Short: "Forward messages with automatic fallback and message routing",
|
|
GroupID: groupTools.ID,
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
return tRun(cmd.Context(), func(ctx context.Context, c *telegram.Client, kvd storage.Storage) error {
|
|
return forward.Run(logctx.Named(ctx, "forward"), c, kvd, opts)
|
|
})
|
|
},
|
|
}
|
|
|
|
cmd.Flags().StringArrayVar(&opts.From, "from", []string{}, "messages to be forwarded, can be links or exported JSON files")
|
|
cmd.Flags().StringVar(&opts.To, "to", "", "destination peer, can be a CHAT or router based on expression engine")
|
|
cmd.Flags().StringVar(&opts.Edit, "edit", "", "edit message or caption with expression engine. Empty means no edit")
|
|
cmd.Flags().Var(&opts.Mode, "mode", fmt.Sprintf("forward mode: [%s]", strings.Join(forwarder.ModeNames(), ", ")))
|
|
cmd.Flags().BoolVar(&opts.Silent, "silent", false, "send messages silently")
|
|
cmd.Flags().BoolVar(&opts.DryRun, "dry-run", false, "do not actually send messages, just show how they would be sent")
|
|
cmd.Flags().BoolVar(&opts.Single, "single", false, "do not automatically detect and forward grouped messages")
|
|
cmd.Flags().BoolVar(&opts.Desc, "desc", false, "forward messages in reverse order for each input peer")
|
|
|
|
return cmd
|
|
}
|