mohammed-ali-1

stateDiagram-v2
    [*] --> Triggered: PRODUCT_DATA_MERGE_TRIGGERED
    Triggered --> Saved: New task
    Triggered --> Discarded: Unprocessed task exists
    Triggered --> SavedButNotQueued: Processing task exists
    Discarded --> End
    Saved --> Queued
    Queued --> Started: PRODUCT_DATA_MERGING
    Started --> Succeeded: PRODUCT_DATA_MERGED
    Started --> Failed: PRODUCT_DATA_MERGE_FAILED

mohammed-ali-1

apiVersion: apps/v1beta1
kind: Deployment
metadata:
  name: mqtt-provider
spec:
  replicas: 1
  template:
    metadata:
      labels:
        app: mqtt-service-provider

mohammed-ali-1

{
  "_id": "_design/subscriptions",
  "views": {
    "host_topic_counts": {
      "reduce": "_sum",
      "map": "function (doc) {\n  emit(doc.url + '#' + doc.topic, 1);\n}"
    },
    "host_topic_triggers": {
      "map": "function (doc) {\n  emit(doc.url + '#' + doc.topic, {trigger: doc._id, username: doc.username, password: doc.password});\n}"
    },

mohammed-ali-1

function action(args) {
  var request = require('sync-request');
  var res = request('POST', 'http://COUCHDB_HOST:COUCHDB_PORT_NUMBER/readings/', {
    json: {reading: args},
    headers: {
      'Content-Type': 'application/json',
    },
  });
}

mohammed-ali-1

function action(args) {
  var request = require('sync-request');
  var res = request(
    'GET',
    'http://COUCHDB_HOST:COUCHDB_PORT/readings/_all_docs?limit=10&include_docs=true&ascending=true'
  );
  var readings = JSON.parse(res.getBody().toString()).rows.map(elem => elem.doc.reading);
  return {
    body: readings
  };

mohammed-ali-1

function main({reading}) {
    var script = `
<script>
    function latest_readings() {
      const Http = new XMLHttpRequest();

      //URL to getLatestTenReadings web action
      const url='https://OPENWHISK_HOST:OPENWHISK_PORT/api/v1/web/guest/default/getLatestTenReadings';

      Http.open("GET", url);