add grafana source code

src/connector/grafana/tdengine/.gitignore

+node_modules
+npm-debug.log
+coverage/
+.aws-config.json
+awsconfig
+/emails/dist
+/public_gen
+/tmp
+vendor/phantomjs/phantomjs
+
+docs/AWS_S3_BUCKET
+docs/GIT_BRANCH
+docs/VERSION
+docs/GITCOMMIT
+docs/changed-files
+docs/changed-files
+
+# locally required config files
+public/css/*.min.css
+
+# Editor junk
+*.sublime-workspace
+*.swp
+.idea/
+*.iml
+
+/data/*
+/bin/*
+
+conf/custom.ini
+fig.yml
+profile.cov
+grafana
+.notouch
+
+# Test artifacts
+/dist/test/

src/connector/grafana/tdengine/.jscs.json

+{
+    "esnext": true,
+    "disallowImplicitTypeConversion": ["string"],
+    "disallowKeywords": ["with"],
+    "disallowMultipleLineBreaks": true,
+    "disallowMixedSpacesAndTabs": true,
+    "disallowTrailingWhitespace": true,
+    "requireSpacesInFunctionExpression": {
+        "beforeOpeningCurlyBrace": true
+    },
+    "disallowSpacesInsideArrayBrackets": true,
+    "disallowSpacesInsideParentheses": true,
+    "validateIndentation": 2
+}

src/connector/grafana/tdengine/Gruntfile.js

+module.exports = function(grunt) {
+
+  require('load-grunt-tasks')(grunt);
+
+  grunt.loadNpmTasks('grunt-execute');
+  grunt.loadNpmTasks('grunt-contrib-clean');
+
+  grunt.initConfig({
+
+    clean: ["dist"],
+
+    copy: {
+      src_to_dist: {
+        cwd: 'src',
+        expand: true,
+        src: ['**/*', '!**/*.js', '!**/*.scss'],
+        dest: 'dist'
+      },
+      pluginDef: {
+        expand: true,
+        src: ['README.md'],
+        dest: 'dist'
+      }
+    },
+
+    watch: {
+      rebuild_all: {
+        files: ['src/**/*'],
+        tasks: ['default'],
+        options: {spawn: false}
+      }
+    },
+
+    babel: {
+      options: {
+        sourceMap: true,
+        presets:  ['env'],
+        plugins: ['transform-object-rest-spread']
+      },
+      dist: {
+        files: [{
+          cwd: 'src',
+          expand: true,
+          src: ['**/*.js'],
+          dest: 'dist',
+          ext:'.js'
+        }]
+      },
+      distTestNoSystemJs: {
+        files: [{
+          cwd: 'src',
+          expand: true,
+          src: ['**/*.js'],
+          dest: 'dist/test',
+          ext:'.js'
+        }]
+      },
+      distTestsSpecsNoSystemJs: {
+        files: [{
+          expand: true,
+          cwd: 'spec',
+          src: ['**/*.js'],
+          dest: 'dist/test/spec',
+          ext:'.js'
+        }]
+      }
+    },
+
+    mochaTest: {
+      test: {
+        options: {
+          reporter: 'spec'
+        },
+        src: ['dist/test/spec/test-main.js', 'dist/test/spec/*_spec.js']
+      }
+    }
+  });
+
+  grunt.registerTask('default', ['clean', 'copy:src_to_dist', 'copy:pluginDef', 'babel', 'mochaTest']);
+};

src/connector/grafana/tdengine/datasource.js

-'use strict';
-
-System.register(['lodash'], function (_export, _context) {
-  "use strict";
-  var _, _createClass, GenericDatasource;
-  
-  function strTrim(str) {
-     return str.replace(/^\s+|\s+$/gm,'');
-  }
-
-  function _classCallCheck(instance, Constructor) {
-    if (!(instance instanceof Constructor)) {
-      throw new TypeError("Cannot call a class as a function");
-    }
-  }
-
-  return {
-    setters: [function (_lodash) {
-      _ = _lodash.default;
-    }],
-    execute: function () {
-      _createClass = function () {
-        function defineProperties(target, props) {
-          for (var i = 0; i < props.length; i++) {
-            var descriptor = props[i];
-            descriptor.enumerable = descriptor.enumerable || false;
-            descriptor.configurable = true;
-            if ("value" in descriptor) descriptor.writable = true;
-            Object.defineProperty(target, descriptor.key, descriptor);
-          }
-        }
-
-        return function (Constructor, protoProps, staticProps) {
-          if (protoProps) defineProperties(Constructor.prototype, protoProps);
-          if (staticProps) defineProperties(Constructor, staticProps);
-          return Constructor;
-        };
-      }();
-
-      _export('GenericDatasource', GenericDatasource = function () {
-        function GenericDatasource(instanceSettings, $q, backendSrv, templateSrv) {
-          _classCallCheck(this, GenericDatasource);
-          
-          this.type = instanceSettings.type;
-          this.url = instanceSettings.url;
-          this.name = instanceSettings.name;
-          this.q = $q;
-          this.backendSrv = backendSrv;
-          this.templateSrv = templateSrv;
-          //this.withCredentials = instanceSettings.withCredentials;
-          this.headers = { 'Content-Type': 'application/json' };
-          var taosuser = instanceSettings.jsonData.user;
-          var taospwd = instanceSettings.jsonData.password;
-          if (taosuser == null || taosuser == undefined || taosuser == "") {
-            taosuser = "root";
-          }
-          if (taospwd == null || taospwd == undefined || taospwd == "") {
-            taospwd = "taosdata";
-          }
-
-          this.headers.Authorization = "Basic " + this.encode(taosuser + ":" + taospwd);
-        }
-
-        _createClass(GenericDatasource, [{
-          key: 'encode',
-          value: function encode(input) {
-            var _keyStr = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";  
-            var output = "";  
-            var chr1, chr2, chr3, enc1, enc2, enc3, enc4;  
-            var i = 0;        
-            while (i < input.length) {  
-              chr1 = input.charCodeAt(i++);  
-              chr2 = input.charCodeAt(i++);  
-              chr3 = input.charCodeAt(i++);  
-              enc1 = chr1 >> 2;  
-              enc2 = ((chr1 & 3) << 4) | (chr2 >> 4);  
-              enc3 = ((chr2 & 15) << 2) | (chr3 >> 6);  
-              enc4 = chr3 & 63;  
-              if (isNaN(chr2)) {  
-                enc3 = enc4 = 64;  
-              } else if (isNaN(chr3)) {  
-                enc4 = 64;  
-              }  
-              output = output + _keyStr.charAt(enc1) + _keyStr.charAt(enc2) + _keyStr.charAt(enc3) + _keyStr.charAt(enc4);  
-            }  
-            
-            return output;
-          }
-        }, {
-          key: 'generateSql',
-          value: function generateSql(sql, queryStart, queryEnd, intervalMs) {
-            if (queryStart == undefined || queryStart == null) {
-                queryStart = "now-1h";
-            }
-            if (queryEnd == undefined || queryEnd == null) {
-                queryEnd = "now";
-            }
-            if (intervalMs == undefined || intervalMs == null) {
-                intervalMs = "20000";
-            }
-            
-            intervalMs += "a";
-            sql = sql.replace(/^\s+|\s+$/gm, '');
-            sql = sql.replace("$from", "'" + queryStart + "'");
-            sql = sql.replace("$begin", "'" + queryStart + "'");
-            sql = sql.replace("$to", "'" + queryEnd + "'");
-            sql = sql.replace("$end", "'" + queryEnd + "'");
-            sql = sql.replace("$interval", intervalMs);
-            
-            return sql;
-          }
-        }, {
-          key: 'query',
-          value: function query(options) {
-            var querys = new Array;
-            for (var i = 0; i < options.targets.length; ++i) {
-                var query = new Object;
-                
-                query.refId = options.targets[i].refId;
-                query.alias = options.targets[i].alias;
-                if (query.alias == null || query.alias == undefined) {
-                    query.alias = "";
-                }
-                
-                //query.sql = this.generateSql(options.targets[i].sql, options.range.raw.from, options.range.raw.to, options.intervalMs);
-                query.sql = this.generateSql(options.targets[i].sql, options.range.from.toISOString(), options.range.to.toISOString(), options.intervalMs);
-                console.log(query.sql);
-                
-                querys.push(query);
-            }
-            
-            if (querys.length <= 0) {
-              return this.q.when({ data: [] });
-            }
-
-            return this.doRequest({
-              url: this.url + '/grafana/query',
-              data: querys,
-              method: 'POST'
-            });
-          }
-        }, {
-          key: 'testDatasource',
-          value: function testDatasource() {
-            return this.doRequest({
-              url: this.url + '/grafana/heartbeat',
-              method: 'GET'
-            }).then(function (response) {
-              if (response.status === 200) {
-                return { status: "success", message: "TDengine Data source is working", title: "Success" };
-              }
-            });
-          }
-        }, {
-          key: 'doRequest',
-          value: function doRequest(options) {
-            options.headers = this.headers;
-            //console.log(options);
-            return this.backendSrv.datasourceRequest(options);
-          }
-        }]);
-
-        return GenericDatasource;
-      }());
-
-      _export('GenericDatasource', GenericDatasource);
-    }
-  };
-});
-//# sourceMappingURL=datasource.js.map

src/connector/grafana/tdengine/dist/README.md

+TDengine Datasource - build by Taosdata Inc. www.taosdata.com
+
+TDengine backend server implement 2 urls:
+
+ * `/heartbeat` return 200 ok. Used for "Test connection" on the datasource config page.
+ * `/query` return data based on input sqls.
+
+## Installation
+
+To install this plugin:
+Copy the data source you want to /var/lib/grafana/plugins/. Then restart grafana-server. The new data source should now be available in the data source type dropdown in the Add Data Source View.
+
+```
+cp -r <tdengine-extrach-dir>/connector/grafana/tdengine /var/lib/grafana/plugins/
+sudo service grafana-server restart
+```
+
+### Query API
+
+Example request
+``` javascript
+[{
+	"refId": "A",
+	"alias": "taosd-memory",
+	"sql": "select avg(mem_taosd) from sys.dn where ts > now-5m and ts < now interval(500a)"
+},
+{
+	"refId": "B",
+	"alias": "system-memory",
+	"sql": "select avg(mem_system) from sys.dn where ts > now-5m and ts < now interval(500a)"
+}]
+```
+
+Example response
+``` javascript
+[{
+	"datapoints": [
+		[206.488281, 1538137825000],
+		[206.488281, 1538137855000],
+		[206.488281, 1538137885500],
+		[210.609375, 1538137915500],
+		[210.867188, 1538137945500]
+	],
+	"refId": "A",
+	"target": "taosd-memory"
+},
+{
+	"datapoints": [
+		[2910.218750, 1538137825000],
+		[2912.265625, 1538137855000],
+		[2912.437500, 1538137885500],
+		[2916.644531, 1538137915500],
+		[2917.066406, 1538137945500]
+	],
+	"refId": "B",
+	"target": "system-memory"
+}]
+```
+
+### Heartbeat API
+
+Example request
+``` javascript
+<null> get request
+```
+
+Example response
+``` javascript   
+{
+	"message": "Grafana server receive a quest from you!"
+}
+```

src/connector/grafana/tdengine/dist/datasource.js

+'use strict';
+
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.GenericDatasource = undefined;
+
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+var _lodash = require('lodash');
+
+var _lodash2 = _interopRequireDefault(_lodash);
+
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var GenericDatasource = exports.GenericDatasource = function () {
+  function GenericDatasource(instanceSettings, $q, backendSrv, templateSrv) {
+    _classCallCheck(this, GenericDatasource);
+
+    this.type = instanceSettings.type;
+    this.url = instanceSettings.url;
+    this.name = instanceSettings.name;
+    this.q = $q;
+    this.backendSrv = backendSrv;
+    this.templateSrv = templateSrv;
+    this.headers = { 'Content-Type': 'application/json' };
+    this.headers.Authorization = this.getAuthorization(instanceSettings.jsonData);
+  }
+
+  _createClass(GenericDatasource, [{
+    key: 'query',
+    value: function query(options) {
+      var targets = this.buildQueryParameters(options);
+
+      if (targets.length <= 0) {
+        return this.q.when({ data: [] });
+      }
+
+      return this.doRequest({
+        url: this.url + '/grafana/query',
+        data: targets,
+        method: 'POST'
+      });
+    }
+  }, {
+    key: 'testDatasource',
+    value: function testDatasource() {
+      return this.doRequest({
+        url: this.url + '/grafana/heartbeat',
+        method: 'GET'
+      }).then(function (response) {
+        if (response.status === 200) {
+          return { status: "success", message: "TDengine Data source is working", title: "Success" };
+        }
+      });
+    }
+  }, {
+    key: 'doRequest',
+    value: function doRequest(options) {
+      options.headers = this.headers;
+
+      return this.backendSrv.datasourceRequest(options);
+    }
+  }, {
+    key: 'buildQueryParameters',
+    value: function buildQueryParameters(options) {
+      var _this = this;
+
+      var targets = _lodash2.default.map(options.targets, function (target) {
+        return {
+          refId: target.refId,
+          alias: target.alias || "",
+          sql: _this.generateSql(options, target)
+        };
+      });
+
+      return targets;
+    }
+  }, {
+    key: 'encode',
+    value: function encode(input) {
+      var _keyStr = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";
+      var output = "";
+      var chr1, chr2, chr3, enc1, enc2, enc3, enc4;
+      var i = 0;
+      while (i < input.length) {
+        chr1 = input.charCodeAt(i++);
+        chr2 = input.charCodeAt(i++);
+        chr3 = input.charCodeAt(i++);
+        enc1 = chr1 >> 2;
+        enc2 = (chr1 & 3) << 4 | chr2 >> 4;
+        enc3 = (chr2 & 15) << 2 | chr3 >> 6;
+        enc4 = chr3 & 63;
+        if (isNaN(chr2)) {
+          enc3 = enc4 = 64;
+        } else if (isNaN(chr3)) {
+          enc4 = 64;
+        }
+        output = output + _keyStr.charAt(enc1) + _keyStr.charAt(enc2) + _keyStr.charAt(enc3) + _keyStr.charAt(enc4);
+      }
+
+      return output;
+    }
+  }, {
+    key: 'getAuthorization',
+    value: function getAuthorization(jsonData) {
+      jsonData = jsonData || {};
+      var defaultUser = jsonData.user || "root";
+      var defaultPassword = jsonData.password || "taosdata";
+
+      return "Basic " + this.encode(defaultUser + ":" + defaultPassword);
+    }
+  }, {
+    key: 'generateSql',
+    value: function generateSql(options, target) {
+      var sql = target.sql;
+      if (sql == null || sql == "") {
+        return sql;
+      }
+
+      var queryStart = "now-1h";
+      if (options != null && options.range != null && options.range.from != null) {
+        queryStart = options.range.from.toISOString();
+      }
+
+      var queryEnd = "now";
+      if (options != null && options.range != null && options.range.to != null) {
+        queryEnd = options.range.to.toISOString();
+      }
+      var intervalMs = options.intervalMs || "20000";
+
+      intervalMs += "a";
+      sql = sql.replace(/^\s+|\s+$/gm, '');
+      sql = sql.replace("$from", "'" + queryStart + "'");
+      sql = sql.replace("$begin", "'" + queryStart + "'");
+      sql = sql.replace("$to", "'" + queryEnd + "'");
+      sql = sql.replace("$end", "'" + queryEnd + "'");
+      sql = sql.replace("$interval", intervalMs);
+
+      return sql;
+    }
+  }]);
+
+  return GenericDatasource;
+}();
+//# sourceMappingURL=datasource.js.map

src/connector/grafana/tdengine/dist/datasource.js.map

+{"version":3,"sources":["../src/datasource.js"],"names":["GenericDatasource","instanceSettings","$q","backendSrv","templateSrv","type","url","name","q","headers","Authorization","getAuthorization","jsonData","options","targets","buildQueryParameters","length","when","data","doRequest","method","then","response","status","message","title","datasourceRequest","_","map","refId","target","alias","sql","generateSql","input","_keyStr","output","chr1","chr2","chr3","enc1","enc2","enc3","enc4","i","charCodeAt","isNaN","charAt","defaultUser","user","defaultPassword","password","encode","queryStart","range","from","toISOString","queryEnd","to","intervalMs","replace"],"mappings":";;;;;;;;;AAAA;;;;;;;;IAEaA,iB,WAAAA,iB;AAEX,6BAAYC,gBAAZ,EAA8BC,EAA9B,EAAkCC,UAAlC,EAA8CC,WAA9C,EAA2D;AAAA;;AACzD,SAAKC,IAAL,GAAYJ,iBAAiBI,IAA7B;AACA,SAAKC,GAAL,GAAWL,iBAAiBK,GAA5B;AACA,SAAKC,IAAL,GAAYN,iBAAiBM,IAA7B;AACA,SAAKC,CAAL,GAASN,EAAT;AACA,SAAKC,UAAL,GAAkBA,UAAlB;AACA,SAAKC,WAAL,GAAmBA,WAAnB;AACA,SAAKK,OAAL,GAAe,EAAC,gBAAgB,kBAAjB,EAAf;AACA,SAAKA,OAAL,CAAaC,aAAb,GAA6B,KAAKC,gBAAL,CAAsBV,iBAAiBW,QAAvC,CAA7B;AACD;;;;0BAEKC,O,EAAS;AACb,UAAIC,UAAU,KAAKC,oBAAL,CAA0BF,OAA1B,CAAd;;AAEA,UAAIC,QAAQE,MAAR,IAAkB,CAAtB,EAAyB;AACvB,eAAO,KAAKR,CAAL,CAAOS,IAAP,CAAY,EAACC,MAAM,EAAP,EAAZ,CAAP;AACD;;AAED,aAAO,KAAKC,SAAL,CAAe;AACpBb,aAAK,KAAKA,GAAL,GAAW,gBADI;AAEpBY,cAAMJ,OAFc;AAGpBM,gBAAQ;AAHY,OAAf,CAAP;AAKD;;;qCAEgB;AACf,aAAO,KAAKD,SAAL,CAAe;AACpBb,aAAK,KAAKA,GAAL,GAAW,oBADI;AAEpBc,gBAAQ;AAFY,OAAf,EAGJC,IAHI,CAGC,oBAAY;AAClB,YAAIC,SAASC,MAAT,KAAoB,GAAxB,EAA6B;AAC3B,iBAAO,EAAEA,QAAQ,SAAV,EAAqBC,SAAS,iCAA9B,EAAiEC,OAAO,SAAxE,EAAP;AACD;AACF,OAPM,CAAP;AAQD;;;8BAESZ,O,EAAS;AACjBA,cAAQJ,OAAR,GAAkB,KAAKA,OAAvB;;AAEA,aAAO,KAAKN,UAAL,CAAgBuB,iBAAhB,CAAkCb,OAAlC,CAAP;AACD;;;yCAEoBA,O,EAAS;AAAA;;AAE5B,UAAIC,UAAUa,iBAAEC,GAAF,CAAMf,QAAQC,OAAd,EAAuB,kBAAU;AAC7C,eAAO;AACLe,iBAAOC,OAAOD,KADT;AAELE,iBAAOD,OAAOC,KAAP,IAAgB,EAFlB;AAGLC,eAAK,MAAKC,WAAL,CAAiBpB,OAAjB,EAA0BiB,MAA1B;AAHA,SAAP;AAKD,OANa,CAAd;;AAQA,aAAOhB,OAAP;AACD;;;2BAEMoB,K,EAAO;AACZ,UAAIC,UAAU,mEAAd;AACA,UAAIC,SAAS,EAAb;AACA,UAAIC,IAAJ,EAAUC,IAAV,EAAgBC,IAAhB,EAAsBC,IAAtB,EAA4BC,IAA5B,EAAkCC,IAAlC,EAAwCC,IAAxC;AACA,UAAIC,IAAI,CAAR;AACA,aAAOA,IAAIV,MAAMlB,MAAjB,EAAyB;AACvBqB,eAAOH,MAAMW,UAAN,CAAiBD,GAAjB,CAAP;AACAN,eAAOJ,MAAMW,UAAN,CAAiBD,GAAjB,CAAP;AACAL,eAAOL,MAAMW,UAAN,CAAiBD,GAAjB,CAAP;AACAJ,eAAOH,QAAQ,CAAf;AACAI,eAAQ,CAACJ,OAAO,CAAR,KAAc,CAAf,GAAqBC,QAAQ,CAApC;AACAI,eAAQ,CAACJ,OAAO,EAAR,KAAe,CAAhB,GAAsBC,QAAQ,CAArC;AACAI,eAAOJ,OAAO,EAAd;AACA,YAAIO,MAAMR,IAAN,CAAJ,EAAiB;AACfI,iBAAOC,OAAO,EAAd;AACD,SAFD,MAEO,IAAIG,MAAMP,IAAN,CAAJ,EAAiB;AACtBI,iBAAO,EAAP;AACD;AACDP,iBAASA,SAASD,QAAQY,MAAR,CAAeP,IAAf,CAAT,GAAgCL,QAAQY,MAAR,CAAeN,IAAf,CAAhC,GAAuDN,QAAQY,MAAR,CAAeL,IAAf,CAAvD,GAA8EP,QAAQY,MAAR,CAAeJ,IAAf,CAAvF;AACD;;AAED,aAAOP,MAAP;AACD;;;qCAEgBxB,Q,EAAS;AACxBA,iBAAWA,YAAY,EAAvB;AACA,UAAIoC,cAAcpC,SAASqC,IAAT,IAAiB,MAAnC;AACA,UAAIC,kBAAkBtC,SAASuC,QAAT,IAAqB,UAA3C;;AAEA,aAAO,WAAW,KAAKC,MAAL,CAAYJ,cAAc,GAAd,GAAoBE,eAAhC,CAAlB;AACD;;;gCAEWrC,O,EAASiB,M,EAAQ;AAC3B,UAAIE,MAAMF,OAAOE,GAAjB;AACA,UAAIA,OAAO,IAAP,IAAeA,OAAO,EAA1B,EAA6B;AAC3B,eAAOA,GAAP;AACD;;AAED,UAAIqB,aAAa,QAAjB;AACA,UAAIxC,WAAW,IAAX,IAAmBA,QAAQyC,KAAR,IAAiB,IAApC,IAA4CzC,QAAQyC,KAAR,CAAcC,IAAd,IAAsB,IAAtE,EAA2E;AACzEF,qBAAaxC,QAAQyC,KAAR,CAAcC,IAAd,CAAmBC,WAAnB,EAAb;AACD;;AAED,UAAIC,WAAW,KAAf;AACA,UAAI5C,WAAW,IAAX,IAAmBA,QAAQyC,KAAR,IAAiB,IAApC,IAA4CzC,QAAQyC,KAAR,CAAcI,EAAd,IAAoB,IAApE,EAAyE;AACvED,mBAAW5C,QAAQyC,KAAR,CAAcI,EAAd,CAAiBF,WAAjB,EAAX;AACD;AACD,UAAIG,aAAa9C,QAAQ8C,UAAR,IAAsB,OAAvC;;AAEAA,oBAAc,GAAd;AACA3B,YAAMA,IAAI4B,OAAJ,CAAY,aAAZ,EAA2B,EAA3B,CAAN;AACA5B,YAAMA,IAAI4B,OAAJ,CAAY,OAAZ,EAAqB,MAAMP,UAAN,GAAmB,GAAxC,CAAN;AACArB,YAAMA,IAAI4B,OAAJ,CAAY,QAAZ,EAAsB,MAAMP,UAAN,GAAmB,GAAzC,CAAN;AACArB,YAAMA,IAAI4B,OAAJ,CAAY,KAAZ,EAAmB,MAAMH,QAAN,GAAiB,GAApC,CAAN;AACAzB,YAAMA,IAAI4B,OAAJ,CAAY,MAAZ,EAAoB,MAAMH,QAAN,GAAiB,GAArC,CAAN;AACAzB,YAAMA,IAAI4B,OAAJ,CAAY,WAAZ,EAAyBD,UAAzB,CAAN;;AAEA,aAAO3B,GAAP;AACD","file":"datasource.js","sourcesContent":["import _ from \"lodash\";\n\nexport class GenericDatasource {\n\n  constructor(instanceSettings, $q, backendSrv, templateSrv) {\n    this.type = instanceSettings.type;\n    this.url = instanceSettings.url;\n    this.name = instanceSettings.name;\n    this.q = $q;\n    this.backendSrv = backendSrv;\n    this.templateSrv = templateSrv;\n    this.headers = {'Content-Type': 'application/json'};\n    this.headers.Authorization = this.getAuthorization(instanceSettings.jsonData);\n  }\n\n  query(options) {\n    var targets = this.buildQueryParameters(options);\n\n    if (targets.length <= 0) {\n      return this.q.when({data: []});\n    }\n\n    return this.doRequest({\n      url: this.url + '/grafana/query',\n      data: targets,\n      method: 'POST'\n    });\n  }\n\n  testDatasource() {\n    return this.doRequest({\n      url: this.url + '/grafana/heartbeat',\n      method: 'GET',\n    }).then(response => {\n      if (response.status === 200) {\n        return { status: \"success\", message: \"TDengine Data source is working\", title: \"Success\" };\n      }\n    });\n  }\n\n  doRequest(options) {\n    options.headers = this.headers;\n\n    return this.backendSrv.datasourceRequest(options);\n  }\n\n  buildQueryParameters(options) {\n\n    var targets = _.map(options.targets, target => {\n      return {\n        refId: target.refId,\n        alias: target.alias || \"\",\n        sql: this.generateSql(options, target)\n      };\n    });\n\n    return targets;\n  }\n\n  encode(input) {\n    var _keyStr = \"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=\";\n    var output = \"\";\n    var chr1, chr2, chr3, enc1, enc2, enc3, enc4;\n    var i = 0;\n    while (i < input.length) {\n      chr1 = input.charCodeAt(i++);\n      chr2 = input.charCodeAt(i++);\n      chr3 = input.charCodeAt(i++);\n      enc1 = chr1 >> 2;\n      enc2 = ((chr1 & 3) << 4) | (chr2 >> 4);\n      enc3 = ((chr2 & 15) << 2) | (chr3 >> 6);\n      enc4 = chr3 & 63;\n      if (isNaN(chr2)) {\n        enc3 = enc4 = 64;\n      } else if (isNaN(chr3)) {\n        enc4 = 64;\n      }\n      output = output + _keyStr.charAt(enc1) + _keyStr.charAt(enc2) + _keyStr.charAt(enc3) + _keyStr.charAt(enc4);\n    }\n\n    return output;\n  }\n\n  getAuthorization(jsonData){\n    jsonData = jsonData || {};\n    var defaultUser = jsonData.user || \"root\";\n    var defaultPassword = jsonData.password || \"taosdata\";\n\n    return \"Basic \" + this.encode(defaultUser + \":\" + defaultPassword);\n  }\n\n  generateSql(options, target) {\n    var sql = target.sql;\n    if (sql == null || sql == \"\"){\n      return sql;\n    }\n\n    var queryStart = \"now-1h\";\n    if (options != null && options.range != null && options.range.from != null){\n      queryStart = options.range.from.toISOString();\n    }\n\n    var queryEnd = \"now\";\n    if (options != null && options.range != null && options.range.to != null){\n      queryEnd = options.range.to.toISOString();\n    }\n    var intervalMs = options.intervalMs || \"20000\";\n\n    intervalMs += \"a\";\n    sql = sql.replace(/^\\s+|\\s+$/gm, '');\n    sql = sql.replace(\"$from\", \"'\" + queryStart + \"'\");\n    sql = sql.replace(\"$begin\", \"'\" + queryStart + \"'\");\n    sql = sql.replace(\"$to\", \"'\" + queryEnd + \"'\");\n    sql = sql.replace(\"$end\", \"'\" + queryEnd + \"'\");\n    sql = sql.replace(\"$interval\", intervalMs);\n\n    return sql;\n  }\n\n}"]}
\ No newline at end of file

src/connector/grafana/tdengine/dist/module.js

+'use strict';
+
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.AnnotationsQueryCtrl = exports.QueryOptionsCtrl = exports.ConfigCtrl = exports.QueryCtrl = exports.Datasource = undefined;
+
+var _datasource = require('./datasource');
+
+var _query_ctrl = require('./query_ctrl');
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+var GenericConfigCtrl = function GenericConfigCtrl() {
+  _classCallCheck(this, GenericConfigCtrl);
+};
+
+GenericConfigCtrl.templateUrl = 'partials/config.html';
+
+var GenericQueryOptionsCtrl = function GenericQueryOptionsCtrl() {
+  _classCallCheck(this, GenericQueryOptionsCtrl);
+};
+
+GenericQueryOptionsCtrl.templateUrl = 'partials/query.options.html';
+
+var GenericAnnotationsQueryCtrl = function GenericAnnotationsQueryCtrl() {
+  _classCallCheck(this, GenericAnnotationsQueryCtrl);
+};
+
+GenericAnnotationsQueryCtrl.templateUrl = 'partials/annotations.editor.html';
+
+exports.Datasource = _datasource.GenericDatasource;
+exports.QueryCtrl = _query_ctrl.GenericDatasourceQueryCtrl;
+exports.ConfigCtrl = GenericConfigCtrl;
+exports.QueryOptionsCtrl = GenericQueryOptionsCtrl;
+exports.AnnotationsQueryCtrl = GenericAnnotationsQueryCtrl;
+//# sourceMappingURL=module.js.map

src/connector/grafana/tdengine/dist/module.js.map

+{"version":3,"sources":["../src/module.js"],"names":["GenericConfigCtrl","templateUrl","GenericQueryOptionsCtrl","GenericAnnotationsQueryCtrl","Datasource","GenericDatasource","QueryCtrl","GenericDatasourceQueryCtrl","ConfigCtrl","QueryOptionsCtrl","AnnotationsQueryCtrl"],"mappings":";;;;;;;AAAA;;AACA;;;;IAEMA,iB;;;;AACNA,kBAAkBC,WAAlB,GAAgC,sBAAhC;;IAEMC,uB;;;;AACNA,wBAAwBD,WAAxB,GAAsC,6BAAtC;;IAEME,2B;;;;AACNA,4BAA4BF,WAA5B,GAA0C,kCAA1C;;QAGuBG,U,GAArBC,6B;QAC8BC,S,GAA9BC,sC;QACqBC,U,GAArBR,iB;QAC2BS,gB,GAA3BP,uB;QAC+BQ,oB,GAA/BP,2B","file":"module.js","sourcesContent":["import {GenericDatasource} from './datasource';\nimport {GenericDatasourceQueryCtrl} from './query_ctrl';\n\nclass GenericConfigCtrl {}\nGenericConfigCtrl.templateUrl = 'partials/config.html';\n\nclass GenericQueryOptionsCtrl {}\nGenericQueryOptionsCtrl.templateUrl = 'partials/query.options.html';\n\nclass GenericAnnotationsQueryCtrl {}\nGenericAnnotationsQueryCtrl.templateUrl = 'partials/annotations.editor.html'\n\nexport {\n  GenericDatasource as Datasource,\n  GenericDatasourceQueryCtrl as QueryCtrl,\n  GenericConfigCtrl as ConfigCtrl,\n  GenericQueryOptionsCtrl as QueryOptionsCtrl,\n  GenericAnnotationsQueryCtrl as AnnotationsQueryCtrl\n};\n"]}
\ No newline at end of file

src/connector/grafana/tdengine/partials/query.editor.html → src/connector/grafana/tdengine/dist/partials/query.editor.html

@@ -3,7 +3,7 @@
   <div class="gf-form-inline">  
     <div class="gf-form gf-form--grow">
       <label class="gf-form-label query-keyword width-7">INPUT SQL</label>
-      <input type="text" class="gf-form-input" ng-model="ctrl.target.sql" spellcheck='false' placeholder="select count(*) from sys.cpu where ts >= $from and ts < $to interval($interval)" ng-blur="ctrl.panelCtrl.refresh()" data-mode="sql"></input>        
+      <input type="text" class="gf-form-input" ng-model="ctrl.target.sql" spellcheck='false' placeholder="select avg(mem_system)  from log.dn where ts >= $from and ts < $to interval($interval)" ng-blur="ctrl.panelCtrl.refresh()" data-mode="sql"></input>
     </div>   
   </div>
   

src/connector/grafana/tdengine/plugin.json → src/connector/grafana/tdengine/dist/plugin.json

@@ -9,10 +9,9 @@
 
   "metrics": true,
   "annotations": false,
-  "alerting": true,
 
   "info": {
-    "description": "TDengine datasource",
+    "description": "grafana datasource plugin for tdengine",
     "author": {
       "name": "Taosdata Inc.",
       "url": "https://www.taosdata.com"
@@ -21,8 +20,12 @@
       "small": "img/taosdata_logo.png",
       "large": "img/taosdata_logo.png"
     },
+    "links": [
+      {"name": "GitHub", "url": "https://github.com/taosdata/TDengine/tree/develop/src/connector/grafana/tdengine"},
+      {"name": "AGPL 3.0", "url": "https://github.com/taosdata/TDengine/tree/develop/src/connector/grafana/tdengine/LICENSE"}
+    ],
     "version": "1.6.0",
-    "updated": "2019-07-01"
+    "updated": "2019-11-12"
   },
 
   "dependencies": {

src/connector/grafana/tdengine/dist/query_ctrl.js

+'use strict';
+
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.GenericDatasourceQueryCtrl = undefined;
+
+var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
+
+var _sdk = require('app/plugins/sdk');
+
+require('./css/query-editor.css!');
+
+function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
+
+function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
+
+function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
+
+var GenericDatasourceQueryCtrl = exports.GenericDatasourceQueryCtrl = function (_QueryCtrl) {
+  _inherits(GenericDatasourceQueryCtrl, _QueryCtrl);
+
+  function GenericDatasourceQueryCtrl($scope, $injector) {
+    _classCallCheck(this, GenericDatasourceQueryCtrl);
+
+    var _this = _possibleConstructorReturn(this, (GenericDatasourceQueryCtrl.__proto__ || Object.getPrototypeOf(GenericDatasourceQueryCtrl)).call(this, $scope, $injector));
+
+    _this.scope = $scope;
+    _this.target.target = _this.target.target || 'select metric';
+    _this.target.type = _this.target.type || 'timeserie';
+    return _this;
+  }
+
+  _createClass(GenericDatasourceQueryCtrl, [{
+    key: 'onChangeInternal',
+    value: function onChangeInternal() {
+      this.panelCtrl.refresh(); // Asks the panel to refresh data.
+    }
+  }, {
+    key: 'generateSQL',
+    value: function generateSQL(query) {
+      this.lastGenerateSQL = this.datasource.generateSql(this.panelCtrl, this.target);
+      this.showGenerateSQL = !this.showGenerateSQL;
+    }
+  }]);
+
+  return GenericDatasourceQueryCtrl;
+}(_sdk.QueryCtrl);
+
+GenericDatasourceQueryCtrl.templateUrl = 'partials/query.editor.html';
+//# sourceMappingURL=query_ctrl.js.map

src/connector/grafana/tdengine/dist/query_ctrl.js.map

+{"version":3,"sources":["../src/query_ctrl.js"],"names":["GenericDatasourceQueryCtrl","$scope","$injector","scope","target","type","panelCtrl","refresh","query","lastGenerateSQL","datasource","generateSql","showGenerateSQL","QueryCtrl","templateUrl"],"mappings":";;;;;;;;;AAAA;;AACA;;;;;;;;IAEaA,0B,WAAAA,0B;;;AAEX,sCAAYC,MAAZ,EAAoBC,SAApB,EAAgC;AAAA;;AAAA,wJACxBD,MADwB,EAChBC,SADgB;;AAG9B,UAAKC,KAAL,GAAaF,MAAb;AACA,UAAKG,MAAL,CAAYA,MAAZ,GAAqB,MAAKA,MAAL,CAAYA,MAAZ,IAAsB,eAA3C;AACA,UAAKA,MAAL,CAAYC,IAAZ,GAAmB,MAAKD,MAAL,CAAYC,IAAZ,IAAoB,WAAvC;AAL8B;AAM/B;;;;uCAEkB;AACjB,WAAKC,SAAL,CAAeC,OAAf,GADiB,CACS;AAC3B;;;gCAEWC,K,EAAO;AACjB,WAAKC,eAAL,GAAuB,KAAKC,UAAL,CAAgBC,WAAhB,CAA6B,KAAKL,SAAlC,EAA6C,KAAKF,MAAlD,CAAvB;AACA,WAAKQ,eAAL,GAAuB,CAAC,KAAKA,eAA7B;AACD;;;;EAjB6CC,c;;AAqBhDb,2BAA2Bc,WAA3B,GAAyC,4BAAzC","file":"query_ctrl.js","sourcesContent":["import {QueryCtrl} from 'app/plugins/sdk';\nimport './css/query-editor.css!'\n\nexport class GenericDatasourceQueryCtrl extends QueryCtrl {\n\n  constructor($scope, $injector)  {\n    super($scope, $injector);\n\n    this.scope = $scope;\n    this.target.target = this.target.target || 'select metric';\n    this.target.type = this.target.type || 'timeserie';\n  }\n\n  onChangeInternal() {\n    this.panelCtrl.refresh(); // Asks the panel to refresh data.\n  }\n\n  generateSQL(query) {\n    this.lastGenerateSQL = this.datasource.generateSql( this.panelCtrl, this.target);\n    this.showGenerateSQL = !this.showGenerateSQL;\n  }\n\n}\n\nGenericDatasourceQueryCtrl.templateUrl = 'partials/query.editor.html';"]}
\ No newline at end of file

src/connector/grafana/tdengine/module.js

-'use strict';
-
-System.register(['./datasource', './query_ctrl'], function (_export, _context) {
-  "use strict";
-
-  var GenericDatasource, GenericDatasourceQueryCtrl, GenericConfigCtrl, GenericQueryOptionsCtrl, GenericAnnotationsQueryCtrl;
-
-  function _classCallCheck(instance, Constructor) {
-    if (!(instance instanceof Constructor)) {
-      throw new TypeError("Cannot call a class as a function");
-    }
-  }
-
-  return {
-    setters: [function (_datasource) {
-      GenericDatasource = _datasource.GenericDatasource;
-    }, function (_query_ctrl) {
-      GenericDatasourceQueryCtrl = _query_ctrl.GenericDatasourceQueryCtrl;
-    }],
-    execute: function () {
-      _export('ConfigCtrl', GenericConfigCtrl = function GenericConfigCtrl() {
-        _classCallCheck(this, GenericConfigCtrl);
-      });
-
-      GenericConfigCtrl.templateUrl = 'partials/config.html';
-
-      _export('QueryOptionsCtrl', GenericQueryOptionsCtrl = function GenericQueryOptionsCtrl() {
-        _classCallCheck(this, GenericQueryOptionsCtrl);
-      });
-
-      GenericQueryOptionsCtrl.templateUrl = 'partials/query.options.html';
-
-      _export('AnnotationsQueryCtrl', GenericAnnotationsQueryCtrl = function GenericAnnotationsQueryCtrl() {
-        _classCallCheck(this, GenericAnnotationsQueryCtrl);
-      });
-
-      GenericAnnotationsQueryCtrl.templateUrl = 'partials/annotations.editor.html';
-
-      _export('Datasource', GenericDatasource);
-
-      _export('QueryCtrl', GenericDatasourceQueryCtrl);
-
-      _export('ConfigCtrl', GenericConfigCtrl);
-
-      _export('QueryOptionsCtrl', GenericQueryOptionsCtrl);
-
-      _export('AnnotationsQueryCtrl', GenericAnnotationsQueryCtrl);
-    }
-  };
-});
-//# sourceMappingURL=module.js.map

src/connector/grafana/tdengine/package.json

+{
+  "name": "TDengine",
+  "private": true,
+  "version": "1.0.0",
+  "description": "grafana datasource plugin for tdengine",
+  "main": "index.js",
+  "scripts": {
+    "build": "./node_modules/grunt-cli/bin/grunt",
+    "test": "./node_modules/grunt-cli/bin/grunt mochaTest"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/taosdata/TDengine.git"
+  },
+  "author": "",
+  "license": "AGPL 3.0",
+  "bugs": {
+    "url": "https://github.com/taosdata/TDengine/issues"
+  },
+  "engineStrict": true,
+  "devDependencies": {
+    "babel": "^6.23.0",
+    "babel-preset-env": "^1.7.0",
+    "babel-plugin-transform-object-rest-spread": "^6.26.0",
+    "chai": "~3.5.0",
+    "grunt": "^1.0.1",
+    "grunt-babel": "~6.0.0",
+    "grunt-cli": "^1.2.0",
+    "grunt-contrib-clean": "^1.1.0",
+    "grunt-contrib-copy": "^1.0.0",
+    "grunt-contrib-uglify": "^2.3.0",
+    "grunt-contrib-watch": "^1.0.0",
+    "grunt-execute": "~0.2.2",
+    "grunt-mocha-test": "^0.13.2",
+    "grunt-systemjs-builder": "^1.0.0",
+    "jsdom": "~9.12.0",
+    "load-grunt-tasks": "^3.5.2",
+    "mocha": "^3.2.0",
+    "prunk": "^1.3.0",
+    "q": "^1.5.0"
+  },
+  "dependencies": {
+    "lodash": "^4.17.4"
+  },
+  "homepage": "https://github.com/taosdata/TDengine/tree/develop/src/connector/grafana/tdengine"
+}

src/connector/grafana/tdengine/query_ctrl.js

-'use strict';
-
-System.register(['app/plugins/sdk'], function (_export, _context) {
-  "use strict";
-
-  var QueryCtrl, _createClass, GenericDatasourceQueryCtrl;
-
-  function _classCallCheck(instance, Constructor) {
-    if (!(instance instanceof Constructor)) {
-      throw new TypeError("Cannot call a class as a function");
-    }
-  }
-
-  function _possibleConstructorReturn(self, call) {
-    if (!self) {
-      throw new ReferenceError("this hasn't been initialised - super() hasn't been called");
-    }
-
-    return call && (typeof call === "object" || typeof call === "function") ? call : self;
-  }
-
-  function _inherits(subClass, superClass) {
-    if (typeof superClass !== "function" && superClass !== null) {
-      throw new TypeError("Super expression must either be null or a function, not " + typeof superClass);
-    }
-
-    subClass.prototype = Object.create(superClass && superClass.prototype, {
-      constructor: {
-        value: subClass,
-        enumerable: false,
-        writable: true,
-        configurable: true
-      }
-    });
-    if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass;
-  }
-
-  return {
-    setters: [function (_appPluginsSdk) {
-      QueryCtrl = _appPluginsSdk.QueryCtrl;
-    }, function (_cssQueryEditorCss) {}],
-    execute: function () {
-      _createClass = function () {
-        function defineProperties(target, props) {
-          for (var i = 0; i < props.length; i++) {
-            var descriptor = props[i];
-            descriptor.enumerable = descriptor.enumerable || false;
-            descriptor.configurable = true;
-            if ("value" in descriptor) descriptor.writable = true;
-            Object.defineProperty(target, descriptor.key, descriptor);
-          }
-        }
-
-        return function (Constructor, protoProps, staticProps) {
-          if (protoProps) defineProperties(Constructor.prototype, protoProps);
-          if (staticProps) defineProperties(Constructor, staticProps);
-          return Constructor;
-        };
-      }();
-
-      _export('GenericDatasourceQueryCtrl', GenericDatasourceQueryCtrl = function (_QueryCtrl) {
-        _inherits(GenericDatasourceQueryCtrl, _QueryCtrl);
-
-        function GenericDatasourceQueryCtrl($scope, $injector) {
-          _classCallCheck(this, GenericDatasourceQueryCtrl);
-
-          var _this = _possibleConstructorReturn(this, (GenericDatasourceQueryCtrl.__proto__ || Object.getPrototypeOf(GenericDatasourceQueryCtrl)).call(this, $scope, $injector));
-
-          _this.scope = $scope;
-          return _this;
-        }
-
-        _createClass(GenericDatasourceQueryCtrl, [{
-          key: 'generateSQL',
-          value: function generateSQL(query) {
-            //this.lastGenerateSQL = this.datasource.generateSql(this.target.sql, this.panelCtrl.range.raw.from, this.panelCtrl.range.raw.to, this.panelCtrl.intervalMs);
-            this.lastGenerateSQL = this.datasource.generateSql(this.target.sql, this.panelCtrl.range.from.toISOString(), this.panelCtrl.range.to.toISOString(), this.panelCtrl.intervalMs);
-            this.showGenerateSQL = !this.showGenerateSQL;
-          }
-        }]);
-
-        return GenericDatasourceQueryCtrl;
-      }(QueryCtrl));
-
-      _export('GenericDatasourceQueryCtrl', GenericDatasourceQueryCtrl);
-
-      GenericDatasourceQueryCtrl.templateUrl = 'partials/query.editor.html';
-    }
-  };
-});
-//# sourceMappingURL=query_ctrl.js.map

src/connector/grafana/tdengine/spec/datasource_spec.js

+import {Datasource} from "../module";
+import Q from "q";
+
+describe('GenericDatasource', function() {
+    var ctx = {};
+
+    beforeEach(function() {
+        ctx.$q = Q;
+        ctx.backendSrv = {};
+        ctx.templateSrv = {};
+        ctx.ds = new Datasource({}, ctx.$q, ctx.backendSrv, ctx.templateSrv);
+    });
+
+    it('should return an empty array when no targets are set', function(done) {
+        ctx.ds.query({targets: []}).then(function(result) {
+            expect(result.data).to.have.length(0);
+            done();
+        });
+    });
+
+
+});

src/connector/grafana/tdengine/spec/test-main.js

+import prunk from 'prunk';
+import {jsdom} from 'jsdom';
+import chai from 'chai';
+
+// Mock Grafana modules that are not available outside of the core project
+// Required for loading module.js
+prunk.mock('./css/query-editor.css!', 'no css, dude.');
+prunk.mock('app/plugins/sdk', {
+    QueryCtrl: null
+});
+
+// Setup jsdom
+// Required for loading angularjs
+global.document = jsdom('<html><head><script></script></head><body></body></html>');
+global.window = global.document.parentWindow;
+
+// Setup Chai
+chai.should();
+global.assert = chai.assert;
+global.expect = chai.expect;

src/connector/grafana/tdengine/src/css/query-editor.css

+.generic-datasource-query-row .query-keyword {
+  width: 75px;
+}
\ No newline at end of file

src/connector/grafana/tdengine/src/datasource.js

+import _ from "lodash";
+
+export class GenericDatasource {
+
+  constructor(instanceSettings, $q, backendSrv, templateSrv) {
+    this.type = instanceSettings.type;
+    this.url = instanceSettings.url;
+    this.name = instanceSettings.name;
+    this.q = $q;
+    this.backendSrv = backendSrv;
+    this.templateSrv = templateSrv;
+    this.headers = {'Content-Type': 'application/json'};
+    this.headers.Authorization = this.getAuthorization(instanceSettings.jsonData);
+  }
+
+  query(options) {
+    var targets = this.buildQueryParameters(options);
+
+    if (targets.length <= 0) {
+      return this.q.when({data: []});
+    }
+
+    return this.doRequest({
+      url: this.url + '/grafana/query',
+      data: targets,
+      method: 'POST'
+    });
+  }
+
+  testDatasource() {
+    return this.doRequest({
+      url: this.url + '/grafana/heartbeat',
+      method: 'GET',
+    }).then(response => {
+      if (response.status === 200) {
+        return { status: "success", message: "TDengine Data source is working", title: "Success" };
+      }
+    });
+  }
+
+  doRequest(options) {
+    options.headers = this.headers;
+
+    return this.backendSrv.datasourceRequest(options);
+  }
+
+  buildQueryParameters(options) {
+
+    var targets = _.map(options.targets, target => {
+      return {
+        refId: target.refId,
+        alias: target.alias || "",
+        sql: this.generateSql(options, target)
+      };
+    });
+
+    return targets;
+  }
+
+  encode(input) {
+    var _keyStr = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";
+    var output = "";
+    var chr1, chr2, chr3, enc1, enc2, enc3, enc4;
+    var i = 0;
+    while (i < input.length) {
+      chr1 = input.charCodeAt(i++);
+      chr2 = input.charCodeAt(i++);
+      chr3 = input.charCodeAt(i++);
+      enc1 = chr1 >> 2;
+      enc2 = ((chr1 & 3) << 4) | (chr2 >> 4);
+      enc3 = ((chr2 & 15) << 2) | (chr3 >> 6);
+      enc4 = chr3 & 63;
+      if (isNaN(chr2)) {
+        enc3 = enc4 = 64;
+      } else if (isNaN(chr3)) {
+        enc4 = 64;
+      }
+      output = output + _keyStr.charAt(enc1) + _keyStr.charAt(enc2) + _keyStr.charAt(enc3) + _keyStr.charAt(enc4);
+    }
+
+    return output;
+  }
+
+  getAuthorization(jsonData){
+    jsonData = jsonData || {};
+    var defaultUser = jsonData.user || "root";
+    var defaultPassword = jsonData.password || "taosdata";
+
+    return "Basic " + this.encode(defaultUser + ":" + defaultPassword);
+  }
+
+  generateSql(options, target) {
+    var sql = target.sql;
+    if (sql == null || sql == ""){
+      return sql;
+    }
+
+    var queryStart = "now-1h";
+    if (options != null && options.range != null && options.range.from != null){
+      queryStart = options.range.from.toISOString();
+    }
+
+    var queryEnd = "now";
+    if (options != null && options.range != null && options.range.to != null){
+      queryEnd = options.range.to.toISOString();
+    }
+    var intervalMs = options.intervalMs || "20000";
+
+    intervalMs += "a";
+    sql = sql.replace(/^\s+|\s+$/gm, '');
+    sql = sql.replace("$from", "'" + queryStart + "'");
+    sql = sql.replace("$begin", "'" + queryStart + "'");
+    sql = sql.replace("$to", "'" + queryEnd + "'");
+    sql = sql.replace("$end", "'" + queryEnd + "'");
+    sql = sql.replace("$interval", intervalMs);
+
+    return sql;
+  }
+
+}
\ No newline at end of file

src/connector/grafana/tdengine/src/module.js

+import {GenericDatasource} from './datasource';
+import {GenericDatasourceQueryCtrl} from './query_ctrl';
+
+class GenericConfigCtrl {}
+GenericConfigCtrl.templateUrl = 'partials/config.html';
+
+class GenericQueryOptionsCtrl {}
+GenericQueryOptionsCtrl.templateUrl = 'partials/query.options.html';
+
+class GenericAnnotationsQueryCtrl {}
+GenericAnnotationsQueryCtrl.templateUrl = 'partials/annotations.editor.html'
+
+export {
+  GenericDatasource as Datasource,
+  GenericDatasourceQueryCtrl as QueryCtrl,
+  GenericConfigCtrl as ConfigCtrl,
+  GenericQueryOptionsCtrl as QueryOptionsCtrl,
+  GenericAnnotationsQueryCtrl as AnnotationsQueryCtrl
+};

src/connector/grafana/tdengine/src/partials/config.html

+<h3 class="page-heading">TDengine Connection</h3>
+
+<div class="gf-form-group">
+	<div class="gf-form max-width-30">
+		<span class="gf-form-label width-7">Host</span>
+		<input type="text" class="gf-form-input" ng-model='ctrl.current.url' placeholder="http://localhost:6020" bs-typeahead="{{['http://localhost:6020']}}" required></input>
+	</div>
+
+	<div class="gf-form-inline">
+		<div class="gf-form max-width-15">
+			<span class="gf-form-label width-7">User</span>
+			<input type="text" class="gf-form-input" ng-model='ctrl.current.jsonData.user' placeholder="root"></input>
+		</div>
+		<div class="gf-form max-width-15">
+			<span class="gf-form-label width-7">Password</span>
+			<input type="password" class="gf-form-input" ng-model='ctrl.current.jsonData.password' placeholder="taosdata"></input>
+		</div>
+	</div>
+</div>
\ No newline at end of file

src/connector/grafana/tdengine/src/partials/query.editor.html

+<query-editor-row query-ctrl="ctrl" can-collapse="true" >
+
+  <div class="gf-form-inline">  
+    <div class="gf-form gf-form--grow">
+      <label class="gf-form-label query-keyword width-7">INPUT SQL</label>
+      <input type="text" class="gf-form-input" ng-model="ctrl.target.sql" spellcheck='false' placeholder="select avg(mem_system)  from log.dn where ts >= $from and ts < $to interval($interval)" ng-blur="ctrl.panelCtrl.refresh()" data-mode="sql"></input>
+    </div>   
+  </div>
+  
+  <div class="gf-form-inline">
+    <div class="gf-form-inline"  ng-hide="ctrl.target.resultFormat === 'table'">
+      <div class="gf-form max-width-30">
+        <label class="gf-form-label query-keyword width-7">ALIAS BY</label>
+        <input type="text" class="gf-form-input" ng-model="ctrl.target.alias" spellcheck='false' placeholder="Naming pattern" ng-blur="ctrl.panelCtrl.refresh()">
+      </div>
+    </div>    
+    <div class="gf-form">
+      <label class="gf-form-label query-keyword" ng-click="ctrl.generateSQL()">
+        GENERATE SQL
+        <i class="fa fa-caret-down" ng-show="ctrl.showGenerateSQL"></i>
+        <i class="fa fa-caret-right" ng-hide="ctrl.showGenerateSQL"></i>
+      </label>
+    </div>
+    <div class="gf-form">
+      <label class="gf-form-label query-keyword" ng-click="ctrl.showHelp = !ctrl.showHelp">
+        SHOW HELP
+        <i class="fa fa-caret-down" ng-show="ctrl.showHelp"></i>
+        <i class="fa fa-caret-right" ng-hide="ctrl.showHelp"></i>
+      </label>
+    </div>        
+  </div>
+  
+  <div class="gf-form" ng-show="ctrl.showGenerateSQL">
+    <pre class="gf-form-pre">{{ctrl.lastGenerateSQL}}</pre>
+  </div>
+
+  <div class="gf-form"  ng-show="ctrl.showHelp">
+    <pre class="gf-form-pre alert alert-info">Use any SQL that can return Resultset such as:
+- [[timestamp1, value1], [timestamp2, value2], ... ]
+
+Macros:
+- $from -&gt; start timestamp of panel
+- $to -&gt; stop timestamp of panel
+- $interval -&gt; interval of panel
+
+Example of SQL:
+&nbsp;&nbsp;SELECT count(*)
+&nbsp;&nbsp;FROM db.table
+&nbsp;&nbsp;WHERE ts > $from and ts < $to
+&nbsp;&nbsp;INTERVAL ($interval)
+    </pre>
+  </div>
+
+  <div class="gf-form" ng-show="ctrl.lastQueryError">
+    <pre class="gf-form-pre alert alert-error">{{ctrl.lastQueryError}}</pre>
+  </div>
+  
+</query-editor-row>

src/connector/grafana/tdengine/src/plugin.json

+{
+  "name": "TDengine",
+  "id": "tdengine",
+  "type": "datasource",
+
+  "partials": {
+    "config": "partials/config.html"
+  },
+
+  "metrics": true,
+  "annotations": false,
+
+  "info": {
+    "description": "grafana datasource plugin for tdengine",
+    "author": {
+      "name": "Taosdata Inc.",
+      "url": "https://www.taosdata.com"
+    },
+    "logos": {
+      "small": "img/taosdata_logo.png",
+      "large": "img/taosdata_logo.png"
+    },
+    "links": [
+      {"name": "GitHub", "url": "https://github.com/taosdata/TDengine/tree/develop/src/connector/grafana/tdengine"},
+      {"name": "AGPL 3.0", "url": "https://github.com/taosdata/TDengine/tree/develop/src/connector/grafana/tdengine/LICENSE"}
+    ],
+    "version": "1.6.0",
+    "updated": "2019-11-12"
+  },
+
+  "dependencies": {
+    "grafanaVersion": "5.2.4",
+    "plugins": [ ]
+  }
+}

src/connector/grafana/tdengine/src/query_ctrl.js

+import {QueryCtrl} from 'app/plugins/sdk';
+import './css/query-editor.css!'
+
+export class GenericDatasourceQueryCtrl extends QueryCtrl {
+
+  constructor($scope, $injector)  {
+    super($scope, $injector);
+
+    this.scope = $scope;
+    this.target.target = this.target.target || 'select metric';
+    this.target.type = this.target.type || 'timeserie';
+  }
+
+  onChangeInternal() {
+    this.panelCtrl.refresh(); // Asks the panel to refresh data.
+  }
+
+  generateSQL(query) {
+    this.lastGenerateSQL = this.datasource.generateSql( this.panelCtrl, this.target);
+    this.showGenerateSQL = !this.showGenerateSQL;
+  }
+
+}
+
+GenericDatasourceQueryCtrl.templateUrl = 'partials/query.editor.html';
\ No newline at end of file