Add reset

src/internal/m365/onedrive/collection.go

@@ -401,6 +401,7 @@ func readItemContents(
 		return nil, err
 	}
 
+	logger.CtxErr(ctx, err).Info("item served from url cache")
 	return rc, nil
 }
 

src/internal/m365/onedrive/collections.go

@@ -327,6 +327,24 @@ func (c *Collections) Get(
 			"num_deltas_entries", numDeltas,
 			"delta_reset", delta.Reset)
 
+		numDriveItems := c.NumItems - numPrevItems
+		numPrevItems = c.NumItems
+
+		// Only create a drive cache if there are less than 300k items in the drive.
+		if numDriveItems < urlCacheDriveItemThreshold {
+			logger.Ctx(ictx).Info("adding url cache for drive ", driveID)
+			logger.Ctx(ictx).Info("url cache: new items in drive ", numDriveItems)
+
+			err = c.addURLCacheToDriveCollections(
+				ictx,
+				driveID,
+				prevDelta,
+				errs)
+			if err != nil {
+				return nil, false, err
+			}
+		}
+
 		// For both cases we don't need to do set difference on folder map if the
 		// delta token was valid because we should see all the changes.
 		if !delta.Reset {

src/internal/m365/onedrive/url_cache.go

@@ -177,6 +177,9 @@ func (uc *urlCache) deltaQuery(
 ) error {
 	logger.Ctx(ctx).Debug("starting delta query")
 
+	// Reset item pager to remove any previous state
+	uc.itemPager.Reset()
+
 	_, _, _, err := collectItems(
 		ctx,
 		uc.itemPager,