1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for license information.
package link
import (
"context"
"fmt"
"log"
"path/filepath"
"strings"
"github.com/Azure/azure-sdk-for-go/eng/tools/generator/cmd/issue/query"
"github.com/ahmetb/go-linq/v3"
)
func init() {
cache = make(map[Readme]bool)
}
const (
mgmtSegment = "resource-manager"
)
// Readme represents a readme filepath
type Readme string
// IsMgmt returns true when the readme belongs to a mgmt plane package
func (r Readme) IsMgmt() bool {
return strings.Contains(string(r), mgmtSegment)
}
// GetReadmePathFromChangedFiles ...
func GetReadmePathFromChangedFiles(ctx context.Context, client *query.Client, files []string) (Readme, error) {
// find readme files one by one
readmeFiles := make(map[Readme]bool)
for _, file := range files {
readme, err := GetReadmeFromPath(ctx, client, file)
if err != nil {
log.Printf("Changed file '%s' does not belong to any RP, ignoring", file)
continue
}
readmeFiles[readme] = true
}
if len(readmeFiles) > 1 {
return "", fmt.Errorf("cannot determine which RP to release because we have the following readme files involved: %+v", getMapKeys(readmeFiles))
}
if len(readmeFiles) == 0 {
return "", fmt.Errorf("cannot get any readme files from these changed files: [%s]", strings.Join(files, ", "))
}
// we only have one readme file
return getMapKeys(readmeFiles)[0], nil
}
func getMapKeys(m map[Readme]bool) []Readme {
var result []Readme
linq.From(m).Select(func(kv interface{}) interface{} {
return kv.(linq.KeyValue).Key
}).ToSlice(&result)
return result
}
var (
cache map[Readme]bool
)
// GetReadmeFromPath ...
func GetReadmeFromPath(ctx context.Context, client *query.Client, path string) (Readme, error) {
// we do not need to determine this is a path of file or directory
// we could always assume this is a directory path even if it is a file path - just waste a try in the first attempt if it is a filepath
return getReadmeFromDirectoryPath(ctx, client, path)
}
func getReadmeFromDirectoryPath(ctx context.Context, client *query.Client, dir string) (Readme, error) {
if len(dir) == 0 || dir == "." {
return "", fmt.Errorf("cannot determine the readme.md path")
}
file := tryReadmePath(dir)
// use cache to short cut
if y, ok := cache[file]; ok {
if y {
return file, nil
} else {
return getReadmeFromDirectoryPath(ctx, client, filepathDir(dir))
}
}
_, _, resp, err := client.Repositories.GetContents(ctx, SpecOwner, SpecRepo, string(file), nil)
if err == nil {
cache[file] = true
return file, nil
}
if resp != nil && resp.StatusCode == 404 {
cache[file] = false
return getReadmeFromDirectoryPath(ctx, client, filepathDir(dir))
}
return "", err
}
func tryReadmePath(base string) Readme {
return Readme(fmt.Sprintf("%s/readme.md", base))
}
func filepathDir(path string) string {
return strings.ReplaceAll(filepath.Dir(path), "\\", "/")
}
|
