diff --git a/bin/pubber b/bin/pubber index 2893e37af..39eaf7443 100755 --- a/bin/pubber +++ b/bin/pubber @@ -30,17 +30,15 @@ else for option in $*; do if [[ $option == *"="* ]]; then k=$(echo $option | cut -d'=' -f1) - v=$(echo $option | cut -d'=' -f2) - if ! [[ $v =~ ^[0-9]+([.][0-9]+)?$ ]]; then - v="\"$v\"" - fi + v="\"$(echo $option | cut -d'=' -f2)\"" else k=$option v=true fi printf -v options_json '%s"%s":%s,' "$options_json" "$k" "$v" done - options_json="{${options_json%?}}" + options_json="{${options_json%,}}" + cloud_region=`jq -r .cloud_region $site_path/cloud_iot_config.json` cat < /tmp/pubber_config.json diff --git a/pubber/src/main/java/daq/pubber/ConfigurationOptions.java b/pubber/src/main/java/daq/pubber/ConfigurationOptions.java index 7532d9bd6..c3db6317a 100644 --- a/pubber/src/main/java/daq/pubber/ConfigurationOptions.java +++ b/pubber/src/main/java/daq/pubber/ConfigurationOptions.java @@ -5,7 +5,7 @@ */ public class ConfigurationOptions { public Boolean noHardware = false; - public Boolean extraPoint = false; - public Boolean extraField = false; + public String extraPoint = ""; + public String extraField = ""; } diff --git a/pubber/src/main/java/daq/pubber/Pubber.java b/pubber/src/main/java/daq/pubber/Pubber.java index 197853940..20e9cc03f 100644 --- a/pubber/src/main/java/daq/pubber/Pubber.java +++ b/pubber/src/main/java/daq/pubber/Pubber.java @@ -3,7 +3,6 @@ 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; @@ -77,7 +76,6 @@ 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); @@ -375,12 +373,12 @@ private void initializeDevice() { deviceState.system.last_config = new Date(0); // Pubber runtime options - if (configuration.options.extraField) { - devicePoints.extraField = "extra_field"; + if (!configuration.options.extraField.isEmpty()) { + devicePoints.extraField = configuration.options.extraField; } - if (configuration.options.extraPoint) { - addPoint(makePoint("extra_point", + if (!configuration.options.extraPoint.isEmpty()) { + addPoint(makePoint(configuration.options.extraPoint, makePointPointsetModel(true, 50, 50, "Celsius"))); }