summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'src/com/isode/stroke/serializer/payloadserializers/PubSubEventSubscriptionSerializer.java')
-rw-r--r--src/com/isode/stroke/serializer/payloadserializers/PubSubEventSubscriptionSerializer.java75
1 files changed, 75 insertions, 0 deletions
diff --git a/src/com/isode/stroke/serializer/payloadserializers/PubSubEventSubscriptionSerializer.java b/src/com/isode/stroke/serializer/payloadserializers/PubSubEventSubscriptionSerializer.java
new file mode 100644
index 0000000..d34bfb1
--- /dev/null
+++ b/src/com/isode/stroke/serializer/payloadserializers/PubSubEventSubscriptionSerializer.java
@@ -0,0 +1,75 @@
+/*
+* Copyright (c) 2014, Isode Limited, London, England.
+* All rights reserved.
+*/
+/*
+* Copyright (c) 2014, Remko Tronçon.
+* All rights reserved.
+*/
+
+package com.isode.stroke.serializer.payloadserializers;
+
+import com.isode.stroke.serializer.GenericPayloadSerializer;
+import com.isode.stroke.serializer.PayloadSerializerCollection;
+import com.isode.stroke.serializer.xml.XMLElement;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.TimeZone;
+import com.isode.stroke.elements.PubSubEventSubscription;
+
+public class PubSubEventSubscriptionSerializer extends GenericPayloadSerializer<PubSubEventSubscription> {
+public PubSubEventSubscriptionSerializer(PayloadSerializerCollection serializers) {
+ super(PubSubEventSubscription.class);
+
+ serializers_ = serializers;
+}
+
+protected String serializePayload(PubSubEventSubscription payload) {
+ if (payload == null) {
+ return "";
+ }
+
+ XMLElement element = new XMLElement("subscription", "http://jabber.org/protocol/pubsub#event");
+
+ element.setAttribute("subscription", serializeSubscriptionType(payload.getSubscription()));
+
+ if(payload.getSubscriptionID() != null) {
+ element.setAttribute("subid", payload.getSubscriptionID());
+ }
+
+ if(payload.getNode() != null) {
+ element.setAttribute("node", payload.getNode());
+ }
+
+ if(payload.getJID() != null) {
+ element.setAttribute("jid", payload.getJID().toString());
+ }
+
+ if(payload.getExpiry() != null) {
+ element.setAttribute("expiry", dateToString(payload.getExpiry()));
+ }
+
+ return element.serialize();
+}
+
+private static String serializeSubscriptionType(PubSubEventSubscription.SubscriptionType value) {
+ switch (value) {
+ case None: return "none";
+ case Pending: return "pending";
+ case Subscribed: return "subscribed";
+ case Unconfigured: return "unconfigured";
+ }
+ return "undefined-subscriptiontype";
+}
+
+private static String dateToString(Date date) {
+ SimpleDateFormat dfm = new SimpleDateFormat("YYYY-MM-dd");
+ SimpleDateFormat tfm = new SimpleDateFormat("hh:mm:ss");
+ dfm.setTimeZone(TimeZone.getTimeZone("UTC"));
+ tfm.setTimeZone(TimeZone.getTimeZone("UTC"));
+ String sinceDateString = dfm.format(date) + "T" + tfm.format(date) + "Z";
+ return sinceDateString;
+}
+
+PayloadSerializerCollection serializers_;
+}