Method WalkFileInfos

private/bufpkg/bufmodule/module_read_bucket.go:806–845

(
	ctx context.Context,
	fn func(FileInfo) error,
	options ...WalkFileInfosOption,
)

}

func (m *multiProtoFileModuleReadBucket[T, S]) WalkFileInfos(
	ctx context.Context,
	fn func(FileInfo) error,
	options ...WalkFileInfosOption,
) error {
	seenPathToFileInfo := make(map[string]FileInfo)
	protoFileTracker := newProtoFileTracker()
	for _, delegate := range m.delegates {
		if err := delegate.WalkFileInfos(
			ctx,
			func(fileInfo FileInfo) error {
				if fileInfo.FileType() != FileTypeProto {
					return nil
				}
				path := fileInfo.Path()
				protoFileTracker.trackFileInfo(fileInfo)
				if existingFileInfo, ok := seenPathToFileInfo[path]; ok {
					// If we detected the same .proto file, this is an error.
					if err := protoFileTracker.validate(); err != nil {
						return err
					}
					// 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.
					//
					// This does not return all paths that are matching, unlike GetFile and StatFileInfo.
					// We do not want to continue iterating, as calling WalkFileInfos on the same path
					// could cause errors downstream as callers expect a single call per path.
					return newExistsMultipleModulesError(path, existingFileInfo, fileInfo)
				}
				seenPathToFileInfo[path] = fileInfo
				return fn(fileInfo)
			},
			options...,
		); err != nil {
			return err
		}
	}
	return nil
}

func (m *multiProtoFileModuleReadBucket[T, S]) ShouldBeSelfContained() bool {
	return m.shouldBeSelfContained