Function TestDuplicateProtoPathError

private/bufpkg/bufmodule/bufmodule_test.go:447–503

(t *testing.T)

}

func TestDuplicateProtoPathError(t *testing.T) {
	t.Parallel()

	ctx := t.Context()

	moduleSet, err := bufmoduletesting.NewOmniProvider(
		bufmoduletesting.ModuleData{
			Name: "buf.build/foo/a",
			PathToData: map[string][]byte{
				"a.proto": []byte(
					`syntax = proto3; package a; import "b.proto";`,
				),
			},
		},
		bufmoduletesting.ModuleData{
			Name: "buf.build/foo/b",
			PathToData: map[string][]byte{
				"a.proto": []byte(
					`syntax = proto3; package b;`,
				),
				"b.proto": []byte(
					`syntax = proto3; package b;`,
				),
			},
		},
	)
	require.NoError(t, err)

	moduleA := moduleSet.GetModuleForOpaqueID("buf.build/foo/a")
	require.NotNil(t, moduleA)

	checkError := func(err error) {
		require.Error(t, err)
		duplicateProtoPathError := &bufmodule.DuplicateProtoPathError{}
		require.True(t, errors.As(err, &duplicateProtoPathError), err.Error())
		require.Equal(
			t,
			"a.proto",
			duplicateProtoPathError.ProtoPath,
		)
		require.Equal(
			t,
			[]string{
				"buf.build/foo/a",
				"buf.build/foo/b",
			},
			duplicateProtoPathError.ModuleDescriptions,
		)
	}
	_, err = moduleA.ModuleDeps()
	checkError(err)
	moduleReadBucket := bufmodule.ModuleSetToModuleReadBucketWithOnlyProtoFiles(moduleSet)
	_, err = moduleReadBucket.StatFileInfo(ctx, "a.proto")
	checkError(err)
	err = moduleReadBucket.WalkFileInfos(ctx, func(bufmodule.FileInfo) error { return nil })
	checkError(err)
}