Method getFileInfoAndDelegateIndex

private/bufpkg/bufmodule/module_read_bucket.go:859–897

(
	ctx context.Context,
	op string,
	path string,
)

}

func (m *multiProtoFileModuleReadBucket[T, S]) getFileInfoAndDelegateIndex(
	ctx context.Context,
	op string,
	path string,
) (FileInfo, int, error) {
	var fileInfos []FileInfo
	var delegateIndexes []int
	protoFileTracker := newProtoFileTracker()
	for i, delegate := range m.delegates {
		fileInfo, err := delegate.StatFileInfo(ctx, path)
		if err != nil {
			if errors.Is(err, fs.ErrNotExist) {
				continue
			}
			return nil, 0, err
		}
		if fileInfo.FileType() != FileTypeProto {
			continue
		}
		protoFileTracker.trackFileInfo(fileInfo)
		fileInfos = append(fileInfos, fileInfo)
		delegateIndexes = append(delegateIndexes, i)
	}
	// If we detected the same .proto file, this is an error.
	if err := protoFileTracker.validate(); err != nil {
		return nil, 0, err
	}
	switch len(fileInfos) {
	case 0:
		return nil, 0, &fs.PathError{Op: op, Path: path, Err: fs.ErrNotExist}
	case 1:
		return fileInfos[0], delegateIndexes[0], nil
	default:
		// If we detected a non-proto file duplicate, this means we constructed the multiProtoFileModuleReadBucket
		// incorrectly, as we should not do union buckets for non-proto files. It is totally valid
		// for LICENSE and README.md to be duplicated.
		return nil, 0, newExistsMultipleModulesError(path, fileInfos...)
	}
}

func (*multiProtoFileModuleReadBucket[T, S]) isModuleReadBucket() {}