(ctx *ext.Context, fromChatId, toChatId int64, messageID int)
| 177 | } |
| 178 | |
| 179 | func ForwardMessages(ctx *ext.Context, fromChatId, toChatId int64, messageID int) (*tg.Updates, error) { |
| 180 | fromPeer := ctx.PeerStorage.GetInputPeerById(fromChatId) |
| 181 | if fromPeer.Zero() { |
| 182 | return nil, fmt.Errorf("fromChatId: %d is not a valid peer", fromChatId) |
| 183 | } |
| 184 | toPeer, err := GetLogChannelPeer(ctx, ctx.Raw, ctx.PeerStorage) |
| 185 | if err != nil { |
| 186 | return nil, err |
| 187 | } |
| 188 | update, err := ctx.Raw.MessagesForwardMessages(ctx, &tg.MessagesForwardMessagesRequest{ |
| 189 | RandomID: []int64{rand.Int63()}, |
| 190 | FromPeer: fromPeer, |
| 191 | ID: []int{messageID}, |
| 192 | ToPeer: &tg.InputPeerChannel{ChannelID: toPeer.ChannelID, AccessHash: toPeer.AccessHash}, |
| 193 | }) |
| 194 | if err != nil { |
| 195 | return nil, err |
| 196 | } |
| 197 | return update.(*tg.Updates), nil |
| 198 | } |
no test coverage detected