|
1 | 1 | package org.jenkinsci.plugins.gwt.jobfinder;
|
2 | 2 |
|
3 | 3 | import hudson.Extension;
|
| 4 | +import hudson.XmlFile; |
4 | 5 | import hudson.model.Item;
|
| 6 | +import hudson.model.Saveable; |
5 | 7 | import hudson.model.listeners.ItemListener;
|
| 8 | +import hudson.model.listeners.SaveableListener; |
6 | 9 | import hudson.security.ACL;
|
7 | 10 | import java.util.ArrayList;
|
8 | 11 | import java.util.List;
|
|
16 | 19 | import org.acegisecurity.context.SecurityContext;
|
17 | 20 | import org.acegisecurity.context.SecurityContextHolder;
|
18 | 21 |
|
19 |
| -@Extension |
20 |
| -public class JobFinderImpersonater extends ItemListener { |
| 22 | +public class JobFinderImpersonater { |
21 | 23 | private static Logger LOGGER = Logger.getLogger(JobFinderImpersonater.class.getName());
|
22 | 24 | private static final Map<String, ParameterizedJob> JOBS_WITH_GWT = new ConcurrentHashMap<>();
|
23 | 25 |
|
| 26 | + @Extension |
| 27 | + public static class JobItemListener extends ItemListener { |
| 28 | + @Override |
| 29 | + public void onLoaded() { |
| 30 | + for (final ParameterizedJob job : doGetAllParameterizedJobs(true)) { |
| 31 | + JobFinderImpersonater.putJob(job); |
| 32 | + } |
| 33 | + LOGGER.info("Loaded " + JOBS_WITH_GWT.size() + " jobs in cache"); |
| 34 | + } |
| 35 | + |
| 36 | + @Override |
| 37 | + public void onUpdated(final Item job) { |
| 38 | + JobFinderImpersonater.putJob(job); |
| 39 | + } |
| 40 | + |
| 41 | + @Override |
| 42 | + public void onCreated(final Item job) { |
| 43 | + JobFinderImpersonater.putJob(job); |
| 44 | + } |
| 45 | + |
| 46 | + @Override |
| 47 | + public void onDeleted(final Item job) { |
| 48 | + JobFinderImpersonater.deleteJob(job); |
| 49 | + } |
| 50 | + |
| 51 | + @Override |
| 52 | + public void onCopied(final Item src, final Item job) { |
| 53 | + JobFinderImpersonater.putJob(job); |
| 54 | + } |
| 55 | + |
| 56 | + @Override |
| 57 | + public void onLocationChanged( |
| 58 | + final Item item, final String oldFullName, final String newFullName) { |
| 59 | + JOBS_WITH_GWT.remove(oldFullName); |
| 60 | + JobFinderImpersonater.putJob(item); |
| 61 | + } |
| 62 | + } |
| 63 | + |
| 64 | + @Extension |
| 65 | + public static class JobItemSaveListener extends SaveableListener { |
| 66 | + @Override |
| 67 | + public void onChange(final Saveable o, final XmlFile file) { |
| 68 | + if (o instanceof ParameterizedJob) { |
| 69 | + final ParameterizedJob<?, ?> job = (ParameterizedJob<?, ?>) o; |
| 70 | + LOGGER.finest("Saving " + job.getFullName()); |
| 71 | + JobFinderImpersonater.putJob(job); |
| 72 | + } |
| 73 | + } |
| 74 | + } |
| 75 | + |
24 | 76 | public List<ParameterizedJob> getAllParameterizedJobs(final boolean impersonate) {
|
25 | 77 | if (LOGGER.isLoggable(Level.FINEST)) {
|
26 | 78 | LOGGER.finest("There are " + this.JOBS_WITH_GWT.size() + " jobs in cache:");
|
@@ -55,53 +107,18 @@ private static List<ParameterizedJob> doGetAllParameterizedJobs(final boolean im
|
55 | 107 | }
|
56 | 108 | }
|
57 | 109 |
|
58 |
| - @Override |
59 |
| - public void onLoaded() { |
60 |
| - for (final ParameterizedJob job : doGetAllParameterizedJobs(true)) { |
61 |
| - this.putJob(job); |
62 |
| - } |
63 |
| - LOGGER.info("Loaded " + this.JOBS_WITH_GWT.size() + " jobs in cache"); |
64 |
| - } |
65 |
| - |
66 |
| - @Override |
67 |
| - public void onUpdated(final Item job) { |
68 |
| - this.putJob(job); |
69 |
| - } |
70 |
| - |
71 |
| - @Override |
72 |
| - public void onCreated(final Item job) { |
73 |
| - this.putJob(job); |
74 |
| - } |
75 |
| - |
76 |
| - @Override |
77 |
| - public void onDeleted(final Item job) { |
78 |
| - this.deleteJob(job); |
79 |
| - } |
80 |
| - |
81 |
| - @Override |
82 |
| - public void onCopied(final Item src, final Item job) { |
83 |
| - this.putJob(job); |
84 |
| - } |
85 |
| - |
86 |
| - @Override |
87 |
| - public void onLocationChanged( |
88 |
| - final Item item, final String oldFullName, final String newFullName) { |
89 |
| - this.JOBS_WITH_GWT.remove(oldFullName); |
90 |
| - this.putJob(item); |
91 |
| - } |
92 |
| - |
93 |
| - private void putJob(final Item job) { |
| 110 | + private static void putJob(final Item job) { |
94 | 111 | if (job instanceof ParameterizedJob) {
|
95 | 112 | final ParameterizedJob parameterizedJob = (ParameterizedJob) job;
|
96 | 113 | final boolean hasGenericTrigger =
|
97 | 114 | GenericTriggerFinder.findGenericTrigger(parameterizedJob.getTriggers()) != null;
|
98 | 115 | if (hasGenericTrigger) {
|
99 |
| - this.JOBS_WITH_GWT.put(parameterizedJob.getFullName(), parameterizedJob); |
| 116 | + JOBS_WITH_GWT.put(parameterizedJob.getFullName(), parameterizedJob); |
100 | 117 | }
|
101 | 118 | }
|
102 | 119 | }
|
103 | 120 |
|
104 |
| - private void deleteJob(final Item job) { |
105 |
| - this.JOBS_WITH_GWT.remove(job.getFullName()); |
| 121 | + private static void deleteJob(final Item job) { |
| 122 | + JOBS_WITH_GWT.remove(job.getFullName()); |
106 | 123 | }
|
107 | 124 | }
|
0 commit comments