IoTFieldsExtensionProvider.java

  1. /**
  2.  *
  3.  * Copyright © 2016-2021 Florian Schmaus
  4.  *
  5.  * Licensed under the Apache License, Version 2.0 (the "License");
  6.  * you may not use this file except in compliance with the License.
  7.  * You may obtain a copy of the License at
  8.  *
  9.  *     http://www.apache.org/licenses/LICENSE-2.0
  10.  *
  11.  * Unless required by applicable law or agreed to in writing, software
  12.  * distributed under the License is distributed on an "AS IS" BASIS,
  13.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.  * See the License for the specific language governing permissions and
  15.  * limitations under the License.
  16.  */
  17. package org.jivesoftware.smackx.iot.data.provider;

  18. import java.io.IOException;
  19. import java.text.ParseException;
  20. import java.util.ArrayList;
  21. import java.util.Date;
  22. import java.util.List;
  23. import java.util.logging.Logger;

  24. import org.jivesoftware.smack.packet.XmlEnvironment;
  25. import org.jivesoftware.smack.provider.ExtensionElementProvider;
  26. import org.jivesoftware.smack.util.ParserUtils;
  27. import org.jivesoftware.smack.xml.XmlPullParser;
  28. import org.jivesoftware.smack.xml.XmlPullParserException;

  29. import org.jivesoftware.smackx.iot.data.element.IoTDataField;
  30. import org.jivesoftware.smackx.iot.data.element.IoTFieldsExtension;
  31. import org.jivesoftware.smackx.iot.data.element.NodeElement;
  32. import org.jivesoftware.smackx.iot.data.element.TimestampElement;
  33. import org.jivesoftware.smackx.iot.element.NodeInfo;
  34. import org.jivesoftware.smackx.iot.parser.NodeInfoParser;

  35. import org.jxmpp.util.XmppDateTime;

  36. public class IoTFieldsExtensionProvider extends ExtensionElementProvider<IoTFieldsExtension> {

  37.     private static final Logger LOGGER = Logger.getLogger(IoTFieldsExtensionProvider.class.getName());

  38.     @Override
  39.     public IoTFieldsExtension parse(XmlPullParser parser, int initialDepth, XmlEnvironment xmlEnvironment)
  40.                     throws IOException, XmlPullParserException, ParseException {
  41.         int seqNr = ParserUtils.getIntegerAttributeOrThrow(parser, "seqnr", "IoT data request <accepted/> without sequence number");
  42.         boolean done = ParserUtils.getBooleanAttribute(parser, "done", false);
  43.         List<NodeElement> nodes = new ArrayList<>();
  44.         outerloop: while (true) {
  45.             final XmlPullParser.Event eventType = parser.next();
  46.             final String name = parser.getName();
  47.             switch (eventType) {
  48.             case START_ELEMENT:
  49.                 switch (name) {
  50.                 case NodeElement.ELEMENT:
  51.                     NodeElement node = parseNode(parser);
  52.                     nodes.add(node);
  53.                     break;
  54.                 }
  55.                 break;
  56.             case END_ELEMENT:
  57.                 if (parser.getDepth() == initialDepth) {
  58.                     break outerloop;
  59.                 }
  60.                 break;
  61.             default:
  62.                 // Catch all for incomplete switch (MissingCasesInEnumSwitch) statement.
  63.                 break;
  64.             }
  65.         }
  66.         return new IoTFieldsExtension(seqNr, done, nodes);
  67.     }

  68.     public NodeElement parseNode(XmlPullParser parser) throws XmlPullParserException, IOException, ParseException {
  69.         final int initialDepth = parser.getDepth();
  70.         final NodeInfo nodeInfo = NodeInfoParser.parse(parser);
  71.         List<TimestampElement> timestampElements = new ArrayList<>();
  72.         outerloop: while (true) {
  73.             final XmlPullParser.Event eventType = parser.next();
  74.             final String name = parser.getName();
  75.             switch (eventType) {
  76.             case START_ELEMENT:
  77.                 switch (name){
  78.                 case TimestampElement.ELEMENT:
  79.                     TimestampElement timestampElement = parseTimestampElement(parser);
  80.                     timestampElements.add(timestampElement);
  81.                     break;
  82.                 }
  83.                 break;
  84.             case END_ELEMENT:
  85.                 if (parser.getDepth() == initialDepth) {
  86.                     break outerloop;
  87.                 }
  88.                 break;
  89.             default:
  90.                 // Catch all for incomplete switch (MissingCasesInEnumSwitch) statement.
  91.                 break;
  92.             }
  93.         }
  94.         return new NodeElement(nodeInfo, timestampElements);
  95.     }

  96.     public TimestampElement parseTimestampElement(XmlPullParser parser)
  97.                     throws XmlPullParserException, IOException, ParseException {
  98.         final int initialDepth = parser.getDepth();
  99.         final String dateString = parser.getAttributeValue(null, "value");
  100.         Date date = XmppDateTime.parseDate(dateString);
  101.         List<IoTDataField> fields = new ArrayList<>();
  102.         outerloop: while (true) {
  103.             final XmlPullParser.Event eventType = parser.next();
  104.             switch (eventType) {
  105.             case START_ELEMENT:
  106.                 final String name = parser.getName();
  107.                 IoTDataField field = null;
  108.                 final String fieldName = parser.getAttributeValue(null, "name");
  109.                 final String fieldValue = parser.getAttributeValue(null, "value");
  110.                 switch (name) {
  111.                 case "int": {
  112.                     int value = Integer.parseInt(fieldValue);
  113.                     field = new IoTDataField.IntField(fieldName, value);
  114.                     }
  115.                     break;
  116.                 case "boolean": {
  117.                     boolean value = Boolean.parseBoolean(fieldValue);
  118.                     field = new IoTDataField.BooleanField(fieldName, value);
  119.                     }
  120.                     break;
  121.                 default:
  122.                     LOGGER.warning("IoT Data field type '" + name + "' not implement yet. Ignoring.");
  123.                     break;
  124.                 }
  125.                 if (field != null) {
  126.                     fields.add(field);
  127.                 }
  128.                 break;
  129.             case END_ELEMENT:
  130.                 if (parser.getDepth() == initialDepth) {
  131.                     break outerloop;
  132.                 }
  133.                 break;
  134.             default:
  135.                 // Catch all for incomplete switch (MissingCasesInEnumSwitch) statement.
  136.                 break;
  137.             }
  138.         }
  139.         return new TimestampElement(date, fields);
  140.     }
  141. }