]> git.somenet.org - pub/jan/sbc.git/blob - src/main/java/at/ac/tuwien/sbc/valesriegler/pizzeria/PizzeriaAgent.java
XVSMConnector refactoring
[pub/jan/sbc.git] / src / main / java / at / ac / tuwien / sbc / valesriegler / pizzeria / PizzeriaAgent.java
1 package at.ac.tuwien.sbc.valesriegler.pizzeria;
2
3 import java.io.Serializable;
4 import java.util.ArrayList;
5 import java.util.List;
6
7 import javax.swing.SwingUtilities;
8
9 import org.mozartspaces.core.Entry;
10 import org.mozartspaces.notifications.Notification;
11 import org.mozartspaces.notifications.NotificationListener;
12 import org.mozartspaces.notifications.Operation;
13 import org.slf4j.Logger;
14 import org.slf4j.LoggerFactory;
15
16 import at.ac.tuwien.sbc.valesriegler.common.Util;
17 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.PizzeriaFrame;
18 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.tablemodels.GroupsOverviewModel;
19 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.tablemodels.OrdersOverviewModel;
20 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.tablemodels.PizzasOfOrderModel;
21 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.tablemodels.TablesOverviewModel;
22 import at.ac.tuwien.sbc.valesriegler.pizzeria.gui.tablemodels.WaitersOfOrderModel;
23 import at.ac.tuwien.sbc.valesriegler.types.GroupData;
24 import at.ac.tuwien.sbc.valesriegler.types.Table;
25 import at.ac.tuwien.sbc.valesriegler.xvsm.XVSMConnector;
26
27 /**
28  * The Main class of the Pizzeria compoment.
29  * <p />
30  * Start the communication and the Pizzeria GUI
31  * 
32  * @author Gregor Riegler <gregor DOT riegler AT gmail DOT com>
33  * @author jan
34  */
35 public class PizzeriaAgent {
36         private static final Logger log = LoggerFactory.getLogger(PizzeriaAgent.class);
37
38         private static final String USAGE = "Usage: java PizzeriaAgent XVSM|JMS";
39
40         private static PizzeriaAgent pizzeriaAgent;
41
42         private OrdersOverviewModel ordersModel;
43         private GroupsOverviewModel groupModel;
44         private TablesOverviewModel tablesModel;
45         private WaitersOfOrderModel waitersModel;
46         private PizzasOfOrderModel pizzasModel;
47
48         private XVSMConnector xvsm;
49
50         public static void main(String[] args) {// TODO: remove hardcoding of JMS.
51                 // if (args.length != 1) {
52                 // throw new IllegalArgumentException(USAGE);
53                 // } else {
54 //              String mom = "XVSM";// args[0];
55                 String mom = Util.useJMS ? "JMS" : "XVSM"; 
56                 log.info(mom);
57                 pizzeriaAgent = new PizzeriaAgent();
58                 switch (mom) {
59                 case "XVSM":
60                         pizzeriaAgent.createModels();
61                         pizzeriaAgent.initXVSM();
62                         pizzeriaAgent.initGUI();
63                         break;
64                 case "JMS":
65                         pizzeriaAgent.createModels();
66                         pizzeriaAgent.initJMS();
67                         pizzeriaAgent.initGUI();
68                         break;
69                 default:
70                         throw new IllegalArgumentException(USAGE);
71                 }
72
73                 // }
74         }
75
76         private void initJMS() {
77                 // do what you have to do
78         }
79
80         private void initXVSM() {
81                         xvsm = new XVSMConnector();
82                         xvsm.initSpaceCommunication();
83                         xvsm.useTablesContainer();
84                         xvsm.useGroupsContainer();
85                         
86                         NotificationListener tablesListener = new NotificationListener() {
87                     @Override
88                     public void entryOperationFinished(final Notification notification, final Operation operation, final List<? extends Serializable> entries) {
89                         
90                         final List<Table> tables = new ArrayList<>();
91                         List<Entry> entryList = (List<Entry>) entries;
92                         for (Entry entry : entryList) {
93                                                 tables.add((Table) entry.getValue());
94                                         }
95                         SwingUtilities.invokeLater(new Runnable() {
96                                                 @Override
97                                                 public void run() {
98                                                         PizzeriaAgent.getInstance().getTablesModel().addItems(tables);
99                                                 }
100                                         });
101                     }
102                 };
103                 
104                 NotificationListener groupsListener = new NotificationListener() {
105                     @Override
106                     public void entryOperationFinished(final Notification notification, final Operation operation, final List<? extends Serializable> entries) {
107                         List<GroupData> groups = (List<GroupData>) entries;
108                         PizzeriaAgent.getInstance().getGroupModel().addItems(groups);
109                     }
110                 };
111                         xvsm.initTablesNotifications(tablesListener);
112                         xvsm.initGroupNotifications(groupsListener);
113         }
114
115         private void initGUI() {
116                 PizzeriaGUI gui = new PizzeriaGUI();
117                 SwingUtilities.invokeLater(gui);
118         }
119
120         class PizzeriaGUI implements Runnable {
121                 @Override
122                 public void run() {
123                         PizzeriaFrame frame = new PizzeriaFrame();
124                         frame.setOnTablesCreatedHandler(new TablesCreatedHandler() {
125
126                                 @Override
127                                 public void freeTablesCreated(List<Table> tables) {
128                                          if(!Util.useJMS) {
129                                                  xvsm.sendTablesToSpace(tables);
130                                          }
131                                 }
132
133
134                         });
135                         frame.start();
136                         frame.pack();
137                         frame.setVisible(true);
138                 }
139         }
140
141         private void createModels() {
142                 ordersModel = new OrdersOverviewModel();
143                 groupModel = new GroupsOverviewModel();
144                 tablesModel = new TablesOverviewModel();
145                 waitersModel = new WaitersOfOrderModel();
146                 pizzasModel = new PizzasOfOrderModel();
147         }
148         
149         public static PizzeriaAgent getInstance() {
150                 return pizzeriaAgent;
151         }
152
153         public OrdersOverviewModel getOrdersModel() {
154                 return ordersModel;
155         }
156
157         public GroupsOverviewModel getGroupModel() {
158                 return groupModel;
159         }
160
161         public TablesOverviewModel getTablesModel() {
162                 return tablesModel;
163         }
164
165         public WaitersOfOrderModel getWaitersModel() {
166                 return waitersModel;
167         }
168
169         public PizzasOfOrderModel getPizzasModel() {
170                 return pizzasModel;
171         }
172         
173         public interface TablesCreatedHandler {
174                 public void freeTablesCreated(List<Table> tables);
175         }
176
177 }