Method Do

pkg/filemanager/manager/fulltextindex.go:172–214

(ctx context.Context)

}

func (t *FullTextCopyTask) Do(ctx context.Context) (task.Status, error) {
	dep := dependency.FromContext(ctx)
	l := dep.Logger()
	fm := NewFileManager(dep, inventory.UserFromContext(ctx)).(*manager)

	if !fm.settings.FTSEnabled(ctx) {
		l.Debug("FTS disabled, skipping full text copy task.")
		return task.StatusCompleted, nil
	}

	var state FullTextCopyTaskState
	if err := json.Unmarshal([]byte(t.State()), &state); err != nil {
		return task.StatusError, fmt.Errorf("failed to unmarshal state: %s (%w)", err, queue.CriticalErr)
	}

	// Get fresh file to make sure task is not stale.
	file, err := fm.Get(ctx, state.Uri, dbfs.WithFilePublicMetadata())
	if err != nil {
		return task.StatusError, fmt.Errorf("failed to get latest file: %w", err)
	}

	if file.PrimaryEntityID() != state.EntityID {
		l.Debug("File %d entity changed, skipping copy index.", state.FileID)
		return task.StatusCompleted, nil
	}

	indexer := dep.SearchIndexer(ctx)
	if err := indexer.CopyByFileID(ctx, state.OriginalFileID, state.FileID, state.OwnerID, state.EntityID); err != nil {
		l.Warning("Failed to copy index from file %d to %d, falling back to full indexing: %s", state.OriginalFileID, state.FileID, err)
		return performIndexing(ctx, fm, state.Uri, state.EntityID, state.FileID, state.OwnerID, file.Name(), false)
	}

	// Patch metadata to mark file as indexed.
	if err := fm.fs.PatchMetadata(ctx, []*fs.URI{state.Uri}, fs.MetadataPatch{
		Key:   dbfs.FullTextIndexKey,
		Value: hashid.EncodeEntityID(fm.hasher, state.EntityID),
	}); err != nil {
		return task.StatusError, fmt.Errorf("failed to patch metadata: %w", err)
	}

	l.Debug("Successfully copied index from file %d to %d.", state.OriginalFileID, state.FileID)
	return task.StatusCompleted, nil
}

type (
	FullTextChangeOwnerTask struct {