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