Skip to content

Commit

Permalink
test(query.messages): update
Browse files Browse the repository at this point in the history
  • Loading branch information
ernado committed Jan 1, 2024
1 parent f515503 commit fae138e
Showing 1 changed file with 35 additions and 30 deletions.
65 changes: 35 additions & 30 deletions telegram/query/messages/iter_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,36 +41,40 @@ func TestIterator(t *testing.T) {
raw := tg.NewClient(mock)

mock.ExpectCall(&tg.MessagesSearchRequest{
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
Limit: limit,
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
SavedPeerID: &tg.InputPeerEmpty{},
Limit: limit,
}).ThenResult(messagesClass(expected[2*limit:3*limit], totalMessages))
mock.ExpectCall(&tg.MessagesSearchRequest{
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 20,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
Limit: limit,
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 20,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
SavedPeerID: &tg.InputPeerEmpty{},
Limit: limit,
}).ThenResult(messagesClass(expected[limit:2*limit], totalMessages))
mock.ExpectCall(&tg.MessagesSearchRequest{
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 10,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
Limit: limit,
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 10,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
SavedPeerID: &tg.InputPeerEmpty{},
Limit: limit,
}).ThenResult(messagesClass(expected[:limit], totalMessages))
mock.ExpectCall(&tg.MessagesSearchRequest{
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
Limit: limit,
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
SavedPeerID: &tg.InputPeerEmpty{},
Limit: limit,
}).ThenResult(messagesClass(expected[:0], totalMessages))

iter := NewQueryBuilder(raw).Search(&tg.InputPeerSelf{}).
Expand All @@ -89,12 +93,13 @@ func TestIterator(t *testing.T) {
require.Equal(t, totalMessages, total)

mock.ExpectCall(&tg.MessagesSearchRequest{
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
Limit: 1,
Q: "query",
Peer: &tg.InputPeerSelf{},
OffsetID: 0,
FromID: &tg.InputPeerEmpty{},
Filter: &tg.InputMessagesFilterEmpty{},
SavedPeerID: &tg.InputPeerEmpty{},
Limit: 1,
}).ThenResult(messagesClass(expected[:0], totalMessages))
total, err = iter.FetchTotal(ctx)
require.NoError(t, err)
Expand Down

0 comments on commit fae138e

Please sign in to comment.