forked from jenkinsci/multiple-scms-plugin
-
Notifications
You must be signed in to change notification settings - Fork 0
/
MultiSCMChangeLogSet.java
125 lines (101 loc) · 3.08 KB
/
MultiSCMChangeLogSet.java
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package org.jenkinsci.plugins.multiplescms;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import hudson.model.AbstractBuild;
import hudson.scm.ChangeLogSet;
import hudson.scm.ChangeLogSet.Entry;
import java.util.HashSet;
import java.util.Set;
public class MultiSCMChangeLogSet extends ChangeLogSet<Entry> {
private final HashMap<String, ChangeLogSetWrapper> changes;
private final Set<String> kinds;
protected MultiSCMChangeLogSet(AbstractBuild<?, ?> build) {
super(build);
changes = new HashMap<String, ChangeLogSetWrapper>();
kinds = new HashSet<String>();
}
public static class ChangeLogSetWrapper {
private AbstractBuild build;
private List<Entry> logs;
private Class clazz;
private String friendlyName;
public ChangeLogSetWrapper(AbstractBuild build, String friendlyName, Class handler) {
this.build = build;
this.logs = new ArrayList<Entry>();
this.clazz = handler;
this.friendlyName = friendlyName;
}
public AbstractBuild getBuild() {
return build;
}
public Class getHandlerClass() {
return clazz;
}
public String getName() {
return friendlyName;
}
public List<Entry> getLogs() {
return logs;
}
public void addChanges(ChangeLogSet<? extends Entry> cls) {
for(Entry e : cls)
logs.add(e);
}
}
private static class MultiSCMChangeLogSetIterator implements Iterator<Entry> {
MultiSCMChangeLogSet set;
Iterator<String> scmIter = null;
String currentScm = null;
Iterator<Entry> logIter = null;
public MultiSCMChangeLogSetIterator(MultiSCMChangeLogSet set) {
this.set = set;
scmIter = set.changes.keySet().iterator();
}
public boolean hasNext() {
if(logIter == null || !logIter.hasNext())
return scmIter.hasNext();
return true;
}
public Entry next() {
if(logIter == null || !logIter.hasNext()) {
currentScm = scmIter.next();
logIter = set.changes.get(currentScm).logs.iterator();
}
return logIter.next();
}
public void remove() {
throw new UnsupportedOperationException("Cannot remove changeset items");
}
}
public Iterator<Entry> iterator() {
return new MultiSCMChangeLogSetIterator(this);
}
@Override
public boolean isEmptySet() {
return changes.isEmpty();
}
public void add(String scmClass, String scmFriendlyName, ChangeLogSet<? extends Entry> cls) {
if(!cls.isEmptySet()) {
ChangeLogSetWrapper wrapper = changes.get(scmClass);
if(wrapper == null) {
wrapper = new ChangeLogSetWrapper(build, scmFriendlyName, cls.getClass());
changes.put(scmClass, wrapper);
}
wrapper.addChanges(cls);
}
kinds.add(cls.getKind());
}
public Collection<ChangeLogSetWrapper> getChangeLogSetWrappers() {
return changes.values();
}
@Override public String getKind() {
if (kinds.size() == 1) {
return kinds.iterator().next();
} else {
return "Multi" + kinds;
}
}
}