Method checkChanges

drive/drive.go:98–215

(firstCheck bool)

}

func (d *Client) checkChanges(firstCheck bool) {
	d.lock.Lock()
	if d.changesChecking {
		return
	}
	d.changesChecking = true
	d.lock.Unlock()
	defer func() {
		d.lock.Lock()
		d.changesChecking = false
		d.lock.Unlock()
	}()

	Log.Debugf("Checking for changes")

	client, err := d.getClient()
	if nil != err {
		Log.Debugf("%v", err)
		Log.Warningf("Could not get Google Drive client to watch for changes")
		return
	}

	// get the last token
	pageToken, err := d.cache.GetStartPageToken()
	if nil != err {
		pageToken = "1"
		Log.Info("No last change id found, starting from beginning...")
	} else {
		Log.Debugf("Last change id found, continuing getting changes (%v)", pageToken)
	}

	if firstCheck {
		Log.Infof("First cache build process started...")
	}

	deletedItems := 0
	updatedItems := 0
	processedItems := 0
	for {
		query := client.Changes.
			List(pageToken).
			Fields(googleapi.Field(fmt.Sprintf("nextPageToken, newStartPageToken, changes(changeType, removed, fileId, file(%v))", fields))).
			PageSize(1000).
			SupportsAllDrives(true).
			IncludeItemsFromAllDrives(true).
			IncludeCorpusRemovals(true)

		if d.driveID != "" {
			query = query.DriveId(d.driveID)
		}

		results, err := query.Do()
		if nil != err {
			Log.Debugf("%v", err)
			Log.Warningf("Could not get changes")
			break
		}