larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minimize page size, require user input per page

Browse Source
This commit is contained in:
ryanfkeepers 2023-11-14 11:34:10 -07:00
parent 6bc49530a4
commit bb9771b108
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/pkg/services/m365/api/drive_pager.go
View File

@ -148,7 +148,7 @@ func (c Drives) newDriveItemDeltaPager(
options := &drives.ItemItemsItemDeltaRequestBuilderGetRequestConfiguration{ options := &drives.ItemItemsItemDeltaRequestBuilderGetRequestConfiguration{
Headers: newPreferHeaders(preferHeaderItems...), Headers: newPreferHeaders(preferHeaderItems...),
QueryParameters: &drives.ItemItemsItemDeltaRequestBuilderGetQueryParameters{ QueryParameters: &drives.ItemItemsItemDeltaRequestBuilderGetQueryParameters{
Top: ptr.To(maxDeltaPageSize), Top: ptr.To[int32](5),
}, },
} }

9
src/pkg/services/m365/api/pagers/pagers.go
View File

@ -1,8 +1,10 @@
package pagers package pagers
import ( import (
"bufio"
"context" "context"
"fmt" "fmt"
"os"
"strings" "strings"
"time" "time"
@ -277,6 +279,13 @@ func DeltaEnumerateItems[T any](
// Loop through all pages returned by Graph API. // Loop through all pages returned by Graph API.
for len(nextLink) > 0 { for len(nextLink) > 0 {
fmt.Printf("\n\033[0;33mPress enter when you're ready for the next page...\033[0m\n")
reader := bufio.NewReader(os.Stdin)
// ReadString will block until the user enters a newline
if _, err := reader.ReadString('\n'); err != nil {
fmt.Printf("\n\033[0;31mSomething went wrong:\033[0m [%v]\n", err)
}
page, err := pager.GetPage(graph.ConsumeNTokens(ctx, consume)) page, err := pager.GetPage(graph.ConsumeNTokens(ctx, consume))
if graph.IsErrDeltaNotSupported(err) { if graph.IsErrDeltaNotSupported(err) {
logger.Ctx(ctx).Infow("delta queries not supported") logger.Ctx(ctx).Infow("delta queries not supported")