Adam Van Ymeren
7a04f298d2
- update to latest telegram layer - remove some references to fields in tg.Entities that don't exist in the schema - originally added here: https://github.com/beeper/td/commit/820929062a2ba0104397bc01235ab58a9cff780e - referenced here - https://github.com/mautrix/telegramgo/commit/124f0967ed195b5a380c9bd02e170ada9710dde3 - https://github.com/mautrix/telegramgo/commit/4205047aab2e0639217148b5d125bfaab668bd8e
111 lines
2.6 KiB
Go
111 lines
2.6 KiB
Go
package message
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/go-faster/errors"
|
|
|
|
"go.mau.fi/mautrix-telegram/pkg/gotd/tg"
|
|
)
|
|
|
|
// ScheduledManager is a scheduled messages manager.
|
|
type ScheduledManager struct {
|
|
peer peerPromise
|
|
sender *Sender
|
|
}
|
|
|
|
// Send sends scheduled messages.
|
|
func (m *ScheduledManager) Send(ctx context.Context, id int, ids ...int) (tg.UpdatesClass, error) {
|
|
p, err := m.peer(ctx)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "peer")
|
|
}
|
|
|
|
upd, err := m.sender.sendScheduledMessages(ctx, &tg.MessagesSendScheduledMessagesRequest{
|
|
Peer: p,
|
|
ID: append([]int{id}, ids...),
|
|
})
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "send scheduled messages")
|
|
}
|
|
|
|
return upd, nil
|
|
}
|
|
|
|
// Delete deletes scheduled messages.
|
|
func (m *ScheduledManager) Delete(ctx context.Context, id int, ids ...int) (tg.UpdatesClass, error) {
|
|
p, err := m.peer(ctx)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "peer")
|
|
}
|
|
|
|
upd, err := m.sender.deleteScheduledMessages(ctx, &tg.MessagesDeleteScheduledMessagesRequest{
|
|
Peer: p,
|
|
ID: append([]int{id}, ids...),
|
|
})
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "delete scheduled messages")
|
|
}
|
|
|
|
return upd, nil
|
|
}
|
|
|
|
// Get gets scheduled messages.
|
|
func (m *ScheduledManager) Get(ctx context.Context, id int, ids ...int) (tg.ModifiedMessagesMessages, error) {
|
|
p, err := m.peer(ctx)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "peer")
|
|
}
|
|
|
|
msgs, err := m.sender.getScheduledMessages(ctx, &tg.MessagesGetScheduledMessagesRequest{
|
|
Peer: p,
|
|
ID: append([]int{id}, ids...),
|
|
})
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "get scheduled messages")
|
|
}
|
|
|
|
modified, ok := msgs.AsModified()
|
|
if !ok {
|
|
return nil, errors.Errorf("unexpected type %T", msgs)
|
|
}
|
|
|
|
return modified, nil
|
|
}
|
|
|
|
// HistoryWithHash gets scheduled messages history.
|
|
func (m *ScheduledManager) HistoryWithHash(ctx context.Context, hash int64) (tg.ModifiedMessagesMessages, error) {
|
|
p, err := m.peer(ctx)
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "peer")
|
|
}
|
|
|
|
msgs, err := m.sender.getScheduledHistory(ctx, &tg.MessagesGetScheduledHistoryRequest{
|
|
Peer: p,
|
|
Hash: hash,
|
|
})
|
|
if err != nil {
|
|
return nil, errors.Wrap(err, "get scheduled messages history")
|
|
}
|
|
|
|
modified, ok := msgs.AsModified()
|
|
if !ok {
|
|
return nil, errors.Errorf("unexpected type %T", msgs)
|
|
}
|
|
|
|
return modified, nil
|
|
}
|
|
|
|
// History gets scheduled messages history.
|
|
func (m *ScheduledManager) History(ctx context.Context) (tg.ModifiedMessagesMessages, error) {
|
|
return m.HistoryWithHash(ctx, 0)
|
|
}
|
|
|
|
// Scheduled creates new ScheduledManager using resolved peer.
|
|
func (b *RequestBuilder) Scheduled() *ScheduledManager {
|
|
return &ScheduledManager{
|
|
peer: b.peer,
|
|
sender: b.sender,
|
|
}
|
|
}
|