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
|
package syncpki
import (
"errors"
"fmt"
"strings"
)
type Logger interface {
Infof(string, ...interface{})
Info(...interface{})
Debugf(string, ...interface{})
Debug(...interface{})
Errorf(string, ...interface{})
Error(...interface{})
}
type SubMap struct {
Subitem map[string]SubMap
Count int
}
func ExtractRsyncDomainModule(rsync string) (string, string, error) {
if len(rsync) > len("rsync://") {
rsyncDomain := strings.Split(rsync[8:], "/")
if len(rsyncDomain) < 2 {
return "", "", errors.New("rsync url does not contain module")
}
return fmt.Sprintf("rsync://%s/%s", rsyncDomain[0], rsyncDomain[1]), fmt.Sprintf("rsync://%s/", rsyncDomain[0]), nil
} else {
return "", "", errors.New("Wrong size")
}
}
func AddInMap(item string, m map[string]SubMap) {
if !(len(item) > 8 && item[0:8] == "rsync://") {
return
}
itemSplit := strings.Split(item[8:len(item)], "/")
curm := m
for i, s := range itemSplit {
mm, ok := curm[s]
if i == len(itemSplit)-1 {
mm.Count++
}
if !ok {
mm.Subitem = make(map[string]SubMap)
curm[s] = mm
}
curm = mm.Subitem
}
}
func ReduceMap(m map[string]SubMap) []string {
explore := make([]map[string]SubMap, 1)
explore[0] = m
explorePath := make([]string, 1)
explorePath[0] = "rsync:/"
exploreDepth := make([]int, 1)
exploreDepth[0] = 0
final := make([]string, 0)
for len(explore) > 0 {
curExplore := explore[0]
explore = explore[1:len(explore)]
curPath := explorePath[0]
explorePath = explorePath[1:len(explorePath)]
curDepth := exploreDepth[0]
exploreDepth = exploreDepth[1:len(exploreDepth)]
for pathItem, pathMap := range curExplore {
pathMapC := pathMap.Subitem
curPathComputed := curPath + "/" + pathItem
if len(pathMapC) == 1 && pathMap.Count == 0 || curDepth < 1 {
explorePath = append(explorePath, curPathComputed)
explore = append(explore, pathMapC)
exploreDepth = append(exploreDepth, curDepth+1)
} else {
final = append(final, curPathComputed)
}
}
}
return final
}
|
