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 package info.magnolia.module.rssaggregator.field;
35
36 import info.magnolia.context.Context;
37 import info.magnolia.context.MgnlContext;
38 import info.magnolia.i18nsystem.SimpleTranslator;
39 import info.magnolia.module.ModuleRegistry;
40 import info.magnolia.module.rssaggregator.RSSAggregator;
41 import info.magnolia.module.rssaggregator.RSSJob;
42 import info.magnolia.module.rssaggregator.command.LaunchSingleRSSCommand;
43 import info.magnolia.objectfactory.Components;
44
45 import java.util.Collection;
46
47 import org.slf4j.Logger;
48 import org.slf4j.LoggerFactory;
49
50 import com.vaadin.ui.Alignment;
51 import com.vaadin.ui.Button;
52 import com.vaadin.ui.Button.ClickEvent;
53 import com.vaadin.ui.Component;
54 import com.vaadin.ui.CustomField;
55 import com.vaadin.ui.VerticalLayout;
56
57
58
59
60 public class RunEveryRSSImportButtonField extends CustomField<String> {
61
62 private static final Logger log = LoggerFactory.getLogger(RunEveryRSSImportButtonField.class);
63
64 private final VerticalLayout rootLayout = new VerticalLayout();
65 private final Button runButton = new Button();
66
67 private SimpleTranslator simpleTranslator;
68
69 public RunEveryRSSImportButtonField(SimpleTranslator simpleTranslator) {
70 this.simpleTranslator = simpleTranslator;
71 }
72
73 @Override
74 protected Component initContent() {
75 setImmediate(true);
76 rootLayout.setSizeFull();
77 rootLayout.setSpacing(true);
78
79 runButton.addStyleName("commit");
80 runButton.setCaption(simpleTranslator.translate("rssAggregator.manual.rss.import.all.run"));
81 runButton.addClickListener(createButtonClickListener());
82
83 rootLayout.addComponent(runButton);
84 rootLayout.setExpandRatio(runButton, 0);
85 rootLayout.setComponentAlignment(runButton, Alignment.MIDDLE_CENTER);
86
87 return rootLayout;
88 }
89
90 @Override
91 public Class<String> getType() {
92 return String.class;
93 }
94
95 private Button.ClickListener createButtonClickListener() {
96 return new Button.ClickListener() {
97 @Override
98 public void buttonClick(ClickEvent event) {
99 runImport();
100 }
101 };
102 }
103
104 private void runImport() {
105 Context ctx = MgnlContext.getInstance();
106 Collection<RSSJob> jobs = ((RSSAggregator) Components.getComponent(ModuleRegistry.class).getModuleInstance("rssaggregator")).getJobs().values();
107 for (RSSJob job : jobs) {
108 LaunchSingleRSSCommand command = new LaunchSingleRSSCommand(job);
109 try {
110 command.execute(ctx);
111 } catch (Exception e) {
112 log.debug("RSS feed import failed for job: " + job.getName() + e.getMessage(), e);
113 }
114 }
115 }
116
117 }