*/
public class UidlWriter implements Serializable {
+ private LegacyUidlWriter legacyUidlWriter = new LegacyUidlWriter();
+ private SharedStateWriter sharedStateWriter = new SharedStateWriter();
+ private ConnectorTypeWriter connectorTypeWriter = new ConnectorTypeWriter();
+ private ConnectorHierarchyWriter connectorHierarchyWriter = new ConnectorHierarchyWriter();
+ private ClientRpcWriter clientRpcWriter = new ClientRpcWriter();
+ private MetadataWriter metadataWriter = new MetadataWriter();
+ private ResourceWriter resourceWriter = new ResourceWriter();
+
/**
* Writes a JSON object containing all pending changes to the given UI.
*
// to write out
session.getService().runPendingAccessTasks(session);
- ArrayList<ClientConnector> dirtyVisibleConnectors = ui
- .getConnectorTracker().getDirtyVisibleConnectors();
- LegacyCommunicationManager manager = session.getCommunicationManager();
// Paints components
- ConnectorTracker uiConnectorTracker = ui.getConnectorTracker();
getLogger().log(Level.FINE, "* Creating response to client");
+ ConnectorTracker uiConnectorTracker = ui.getConnectorTracker();
+ ArrayList<ClientConnector> dirtyVisibleConnectors = uiConnectorTracker
+ .getDirtyVisibleConnectors();
getLogger().log(
Level.FINE,
"Found " + dirtyVisibleConnectors.size()
try {
writer.write("\"changes\" : ");
+ LegacyCommunicationManager manager = session
+ .getCommunicationManager();
+
JsonPaintTarget paintTarget = new JsonPaintTarget(manager, writer,
!repaintAll);
- new LegacyUidlWriter().write(ui, writer, paintTarget);
+ legacyUidlWriter.write(ui, writer, paintTarget);
paintTarget.close();
writer.write(", "); // close changes
// processing.
writer.write("\"state\":");
- new SharedStateWriter().write(ui, writer);
+ sharedStateWriter.write(ui, writer);
writer.write(", "); // close states
// TODO This should be optimized. The type only needs to be
// widget mapping
writer.write("\"types\":");
- new ConnectorTypeWriter().write(ui, writer, paintTarget);
+ connectorTypeWriter.write(ui, writer, paintTarget);
writer.write(", "); // close states
// Send update hierarchy information to the client.
// child to 0 children)
writer.write("\"hierarchy\":");
- new ConnectorHierarchyWriter().write(ui, writer);
+ connectorHierarchyWriter.write(ui, writer);
writer.write(", "); // close hierarchy
// send server to client RPC calls for components in the UI, in call
// which they were performed, remove the calls from components
writer.write("\"rpc\" : ");
- new ClientRpcWriter().write(ui, writer);
+ clientRpcWriter.write(ui, writer);
writer.write(", "); // close rpc
uiConnectorTracker.markAllConnectorsClean();
SystemMessages messages = ui.getSession().getService()
.getSystemMessages(ui.getLocale(), null);
// TODO hilightedConnector
- new MetadataWriter().write(ui, writer, repaintAll, async, messages);
+ metadataWriter.write(ui, writer, repaintAll, async, messages);
writer.write(", ");
writer.write("\"resources\" : ");
- new ResourceWriter().write(ui, writer, paintTarget);
+ resourceWriter.write(ui, writer, paintTarget);
Collection<Class<? extends ClientConnector>> usedClientConnectors = paintTarget
.getUsedClientConnectors();
--- /dev/null
+/*
+ * Copyright 2000-2013 Vaadin Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package com.vaadin.server.communication;
+
+import java.io.IOException;
+import java.io.StringWriter;
+import java.util.ArrayList;
+import java.util.Locale;
+
+import org.easymock.EasyMock;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+
+import com.vaadin.server.ClientConnector;
+import com.vaadin.server.LegacyCommunicationManager;
+import com.vaadin.server.SystemMessages;
+import com.vaadin.server.VaadinRequest;
+import com.vaadin.server.VaadinService;
+import com.vaadin.server.VaadinSession;
+import com.vaadin.server.WrappedSession;
+import com.vaadin.ui.ConnectorTracker;
+import com.vaadin.ui.UI;
+
+/**
+ *
+ * @since
+ * @author Vaadin Ltd
+ */
+public class UidlWriterTest {
+
+ private UI ui;
+ private UidlWriter uidlWriter;
+
+ @Before
+ public void setUp() {
+ SystemMessages messages = EasyMock.createNiceMock(SystemMessages.class);
+ EasyMock.expect(messages.isSessionExpiredNotificationEnabled())
+ .andReturn(true).anyTimes();
+ EasyMock.replay(messages);
+
+ VaadinService service = EasyMock.createNiceMock(VaadinService.class);
+ EasyMock.expect(
+ service.getSystemMessages(EasyMock.anyObject(Locale.class),
+ EasyMock.anyObject(VaadinRequest.class)))
+ .andReturn(messages).anyTimes();
+ EasyMock.replay(service);
+
+ LegacyCommunicationManager manager = EasyMock
+ .createNiceMock(LegacyCommunicationManager.class);
+ EasyMock.replay(manager);
+
+ WrappedSession wrappedSession = EasyMock
+ .createNiceMock(WrappedSession.class);
+ EasyMock.expect(wrappedSession.getMaxInactiveInterval()).andReturn(100)
+ .times(3).andReturn(200);
+
+ EasyMock.replay(wrappedSession);
+
+ VaadinSession session = EasyMock.createNiceMock(VaadinSession.class);
+ EasyMock.expect(session.getService()).andReturn(service).anyTimes();
+ EasyMock.expect(session.getCommunicationManager()).andReturn(manager)
+ .anyTimes();
+ EasyMock.expect(session.getSession()).andReturn(wrappedSession)
+ .anyTimes();
+ EasyMock.replay(session);
+
+ ConnectorTracker tracker = EasyMock
+ .createNiceMock(ConnectorTracker.class);
+ EasyMock.expect(tracker.getDirtyVisibleConnectors())
+ .andReturn(new ArrayList<ClientConnector>()).anyTimes();
+ EasyMock.replay(tracker);
+
+ ui = EasyMock.createNiceMock(UI.class);
+ EasyMock.expect(ui.getSession()).andReturn(session).anyTimes();
+ EasyMock.expect(ui.getConnectorTracker()).andReturn(tracker).anyTimes();
+ EasyMock.replay(ui);
+
+ uidlWriter = new UidlWriter();
+ }
+
+ @Test
+ public void testMetadataWriterState() throws IOException, JSONException {
+
+ Assert.assertEquals(
+ "Metadata should contain redirect interval on first write",
+ 115, getRedirect(uidl(false, false)).optInt("interval"));
+ Assert.assertNull(
+ "Metadata should not contain redirect interval on second write",
+ getRedirect(uidl(false, false)));
+ Assert.assertEquals(
+ "Metadata should contain redirect interval on repaintAll", 115,
+ getRedirect(uidl(true, false)).optInt("interval"));
+ Assert.assertEquals(
+ "Metadata should contain redirect interval when changed in session",
+ 215, getRedirect(uidl(false, false)).optInt("interval"));
+ }
+
+ private JSONObject uidl(boolean repaintAll, boolean async)
+ throws IOException, JSONException {
+ StringWriter writer = new StringWriter();
+ uidlWriter.write(ui, writer, repaintAll, async);
+ return new JSONObject("{" + writer.toString() + "}");
+ }
+
+ private JSONObject getRedirect(JSONObject json) throws JSONException {
+ return json.getJSONObject("meta").optJSONObject("timedRedirect");
+
+ }
+}