add no_hardware to pubber options

bin/pubber

@@ -31,29 +31,26 @@ else
         if [[ $option == *"="* ]]; then
             k=$(echo $option | cut -d'=' -f1)
             v=$(echo $option | cut -d'=' -f2)
-            options[$k]=$v
+            if ! [[ $v =~ ^[0-9]+([.][0-9]+)?$ ]]; then
+                v="\"$v\""
+            fi
         else
-            options[$option]=$option
+            k=$option
+            v=true
         fi
+        printf -v options_json '%s"%s":%s,' "$options_json" "$k" "$v"
     done
-
-    extra_point="${options[extra_point]}"    
-
-    if [ -n "${options[extra_field]}" ]; then
-        printf -v extra_field '"extraField": "%s",' "${options[extra_field]}"
-    fi
-
+    options_json="{${options_json%?}}"
     cloud_region=`jq -r .cloud_region $site_path/cloud_iot_config.json`
 
     cat <<EOF > /tmp/pubber_config.json
 {
-    $extra_field
-    "extraPoint": "$extra_point",
     "projectId": "$project_id",
     "sitePath": "$site_path",
     "cloudRegion": "$cloud_region",
     "deviceId": "$device_id",
-    "serialNo": "$serial"
+    "serialNo": "$serial_no",
+    "options": $options_json
 }
 EOF
     $ROOT_DIR/pubber/bin/run /tmp/pubber_config.json

docs/tools/pubber.md

@@ -29,6 +29,8 @@ The following parameters are currently supported from the CLI:
   (will trigger validation schema error)
 * `extra_point` - adds an extra point to the device which does not exist in
   device's metadata (will trigger validation additional point error)
+* `no_hardware` - omits the `system.hardware` field from state messages (will
+  trigger validation error, missing required field)
 
 Values can be assigned to the parameters e.g. 
 `bin/pubber SITE_PATH PROJECT_ID DEVICE_ID SERIAL_NO extra_point=name_of_point`

proxy/pubber.json

@@ -2,11 +2,13 @@
   "projectId": "bos-udmi-hub",
   "cloudRegion": "us-central1",
   "registryId": "ZZ-TRI-FECTA",
-  "extraField": 1234,
   "serialNo": "test_aux-16132",
   "macAddr": "3c5ab41e8f0a",
   "keyFile": "./udmi_site_model/devices/GAT-123/ec_private.pkcs8",
   "algorithm": "ES256",
   "gatewayId": "GAT-123",
-  "deviceId": "SNS-4"
+  "deviceId": "SNS-4",
+  "options": {
+    "extraField": true
+  }
 }

pubber/src/main/java/daq/pubber/Configuration.java

@@ -1,5 +1,6 @@
 package daq.pubber;
 
+
 /**
  * General bucket of pubber configuration information.
  */
@@ -15,8 +16,7 @@ public class Configuration {
   public String keyFile = "local/rsa_private.pkcs8";
   public byte[] keyBytes;
   public String algorithm = "RS256";
-  public Object extraField;
   public String serialNo;
   public String macAddr;
-  public String extraPoint;
+  public ConfigurationOptions options = new ConfigurationOptions();
 }

pubber/src/main/java/daq/pubber/ConfigurationOptions.java

@@ -0,0 +1,11 @@
+package daq.pubber;
+
+/**
+ * Pubber configuration options which change default behavior.
+ */
+public class ConfigurationOptions {
+  public Boolean noHardware = false;
+  public Boolean extraPoint = false;
+  public Boolean extraField = false;
+
+}

pubber/src/main/java/daq/pubber/Pubber.java

@@ -3,8 +3,10 @@
 import static java.util.stream.Collectors.toMap;
 
 import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.databind.MapperFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException;
 import com.fasterxml.jackson.databind.util.ISO8601DateFormat;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableMap;
@@ -75,6 +77,7 @@ public class Pubber {
   private static final String UDMI_VERSION = "1.3.14";
   private static final Logger LOG = LoggerFactory.getLogger(Pubber.class);
   private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper()
+      .disable(MapperFeature.ALLOW_COERCION_OF_SCALARS)
       .enable(SerializationFeature.INDENT_OUTPUT)
       .setDateFormat(new ISO8601DateFormat())
       .setSerializationInclusion(JsonInclude.Include.NON_NULL);
@@ -146,6 +149,8 @@ public Pubber(String configPath) {
     File configFile = new File(configPath);
     try {
       configuration = OBJECT_MAPPER.readValue(configFile, Configuration.class);
+    } catch (UnrecognizedPropertyException e) {
+      throw new RuntimeException("Invalid arguments or options: " + e.getMessage());
     } catch (Exception e) {
       throw new RuntimeException("While reading config " + configFile.getAbsolutePath(), e);
     }
@@ -357,24 +362,32 @@ private void initializeDevice() {
       pullDeviceMessage();
     }
 
-    info(String.format("Starting pubber %s, serial %s, mac %s, extra %s, gateway %s",
+    info(String.format("Starting pubber %s, serial %s, mac %, gateway %s",
         configuration.deviceId, configuration.serialNo, configuration.macAddr,
-        configuration.extraField,
         configuration.gatewayId));
 
     deviceState.system.operational = true;
     deviceState.system.serial_no = configuration.serialNo;
     deviceState.system.hardware.make = "BOS";
     deviceState.system.hardware.model = "pubber";
     deviceState.system.software = new HashMap<>();
-    deviceState.system.software.put("firmware", "v1");
+    deviceState.system.software.put("firmware", "v1");    
     deviceState.system.last_config = new Date(0);
-    devicePoints.extraField = configuration.extraField;
 
-    if (configuration.extraPoint != null && !configuration.extraPoint.isEmpty()) {
-      addPoint(makePoint(configuration.extraPoint,
+    // Pubber runtime options
+    if (configuration.options.extraField) {
+      devicePoints.extraField = "extra_field";
+    }
+
+    if (configuration.options.extraPoint) {
+      addPoint(makePoint("extra_point",
           makePointPointsetModel(true, 50, 50, "Celsius")));
     }
+
+    if (configuration.options.noHardware) {
+      deviceState.system.hardware = null;
+    }
+
     markStateDirty(0);
   }