Looks like the conversion is complete?

Author: RickCarlino

app/config.ts

@@ -1,19 +1,16 @@
-import log from "./logger";
+import { log } from "./logger";
 
 // TODO: Clean up ENV management into something less crappy.
 // or use a 3rd party node ENV manager module.
-let DEFAULT_URL = "http://localhost:3000";
+export let DEFAULT_URL = "http://localhost:3000";
+export let webAppUrl;
+export let httpPort = 3002;
+export let mqttPort = 1883;
 
-let webAppUrl;
 if (process.env.WEB_API_URL) {
     webAppUrl = process.env.WEB_API_URL;
 } else {
     webAppUrl = DEFAULT_URL;
     log("You did not set WEB_API_URL. Defaulting to " + DEFAULT_URL);
 }
 
-module.exports = {
-    webAppUrl: webAppUrl,
-    httpPort: 3002,
-    mqttPort: 1883
-}

app/index.ts

@@ -1,5 +1,5 @@
 import { Server } from "mosca";
-import { conf } from "./config";
+import * as conf from "./config";
 import { onReady } from "./on_ready";
 import { maybeEnableSSL } from "./security/maybe_enable_ssl";
 import { authorizePublish } from "./security/authorize_publish";

app/logger.ts

@@ -1,4 +1,4 @@
-export default function (args: any) {
+export function log(args: any) {
     if (!process.env.DISABLE_LOGS) {
         console.log.apply(this, arguments);
     }

app/mosca.d.ts

@@ -0,0 +1,12 @@
+declare module "mosca" {
+    export class Server extends EventEmitter {
+        constructor(opts: any);
+        public toString: () => string;
+        public subscribe: (topic, callback, done) => any;
+        public publish: (packet, client, callback) => any;
+        public authenticate: (client, username, password, callback) => any;
+        public on: any;
+        public authorizePublish: any;
+        public authorizeSubscribe: any;
+    }
+}

app/on_ready.ts

@@ -3,7 +3,7 @@ import { authorizePublish } from "./security/authorize_publish";
 import { authorizeSubscribe } from "./security/authorize_subscribe";
 import { log } from "./logger";
 
-module.exports = (server) => () => {
+export let onReady = (server) => () => {
     log("Server online");
     startLogging(server);
     startSecurity(server);
@@ -24,8 +24,8 @@ function startLogging(server) {
         "subscribed",
         "unsubscribed",
         "error"
-    ].forEach(function (event) {
-        server.on(event, function () {
+    ].forEach(function(event) {
+        server.on(event, function() {
             log("" + event + " event.");
         });
     });

app/security/authenticate.ts

@@ -2,8 +2,10 @@
 import { fetchToken } from "./fetch_token";
 import { verifyToken } from "./verify_token";
 import { log } from "../logger";
+import Axios, { Promise as AxiosPromise } from "axios";
 
-function determineAuthStrategy(username, password) {
+type tokenHandler = (u: string, pass: string) => AxiosPromise<any>;
+function determineAuthStrategy(username: string, password: string): tokenHandler {
     // Really long password? Probably a JWT.
     if (password.length > 100) {
         return verifyToken;
@@ -12,7 +14,7 @@ function determineAuthStrategy(username, password) {
     }
 };
 
-export default function (client, username, password, callback) {
+export function authenticate(client, username: string, password: string, callback) {
     password = (password || "").toString();
     username = username || "";
     let auth = determineAuthStrategy(username, password);

app/security/authorize_publish.ts

@@ -1,5 +1,5 @@
 import { canUseTopic } from "./can_use_topic";
 
-export default function authorizePublish(client, topic, payload, callback) {
+export function authorizePublish(client, topic, payload, callback) {
   callback(null, canUseTopic(client, topic));
 }

app/security/authorize_subscribe.ts

@@ -1,5 +1,5 @@
 import { canUseTopic } from "./can_use_topic";
 
-export default function authorizeSubscribe(client, topic, callback) {
-  callback(null, canUseTopic(client, topic));
+export function authorizeSubscribe(client, topic, callback) {
+    callback(null, canUseTopic(client, topic));
 }

app/security/can_use_topic.ts

@@ -3,7 +3,7 @@ import { log } from "../logger";
 // If a user has a bot of id XYZ, then they may access any topic
 // following pattern bot/XYZ/#
 
-export default function (client, topic) {
+export function canUseTopic(client, topic) {
     let hasBot = topic && client && client.permissions && client.permissions.bot;
     if (!hasBot) {
         log("Tried to access topic " + (topic || "???") + " but no bot/topic provided.");

app/security/fetch_token.ts

@@ -1,18 +1,19 @@
-import { post } from "axios";
+import Axios from "axios";
 import { webAppUrl } from "../config";
 import { log } from "../logger";
+import * as config from "../config";
 
 const TOKEN_URL = "" + config.webAppUrl + '/api/tokens';
 
-export default function (password, username) {
-  let params = {
-    user: {
-      email: username,
-      password: password
-    }
-  };
-  let email = params.user.email;
-  let e = new Error(
-    "Login credentials are too short. Use a JSON web token as password");
-  return Promise.reject(e);
+export function fetchToken(password, username) {
+    let params = {
+        user: {
+            email: username,
+            password: password
+        }
+    };
+    let email = params.user.email;
+    let e = new Error(
+        "Login credentials are too short. Use a JSON web token as password");
+    return Promise.reject(e);
 }

app/security/maybe_enable_ssl.ts

@@ -8,7 +8,7 @@ let SSL_CERT = SSL_DIR + "cert.pem";
 let SSL_KEY = SSL_DIR + "privkey.pem";
 import { log } from "../logger";
 
-export default function maybeEnableSSL(config) {
+export function maybeEnableSSL(config) {
     if (SSL) {
         config.secure = config.secure || {};
         config.secure.port = SSL_MQTT_PORT;

app/security/verify_token.ts

@@ -1,32 +1,32 @@
 import { webAppUrl } from "../config";
-import { get } from "axios";
+import Axios from "axios";
 import * as jwt from "jsonwebtoken";
 import { log } from "../logger";
 
 let url = webAppUrl + "/api/public_key";
 
 function keyOk(resp) {
-  log("Downloaded certificate from " + url);
-  return new Buffer(resp.data, 'utf8');
+    log("Downloaded certificate from " + url);
+    return new Buffer(resp.data, 'utf8');
 }
 
 function no(error) {
-  log("Unable to download certificate from " + url);
-  log("Is the FarmBot API running?");
-  process.exit();
+    log("Unable to download certificate from " + url);
+    log("Is the FarmBot API running?");
+    process.exit();
 }
 
-let getCertificate = get(url).then(keyOk, no);
+let getCertificate = Axios.get(url).then(keyOk, no);
 
-export default function verifyToken(token) {
-  function no(error) {
-    log("Unable to verify token " + url);
-  }
+export function verifyToken(token) {
+    function no(error) {
+        log("Unable to verify token " + url);
+    }
 
-  function ok(cert) {
-    log("Did fetch certifiacte. Will verify token with certificate.");
-    return jwt.verify(token, cert, { algorithms: ['RS256'] });
-  }
-  log("Will fetch certificate...")
-  return getCertificate.then(ok, no)
+    function ok(cert) {
+        log("Did fetch certifiacte. Will verify token with certificate.");
+        return jwt.verify(token, cert, { algorithms: ['RS256'] });
+    }
+    log("Will fetch certificate...")
+    return getCertificate.then(ok, no)
 };

package.json

@@ -23,17 +23,17 @@
     "@types/axios": "^0.9.34",
     "@types/jsonwebtoken": "^7.1.33",
     "@types/mqtt": "0.0.32",
+    "@types/node": "0.0.2",
     "axios": "^0.15.2",
     "jsonwebtoken": "^7.1.9",
     "mosca": "^2.2.0",
     "mqtt": "^1.7.4"
   },
   "devDependencies": {
-    "@types/node": "0.0.2",
     "istanbul": "^0.4.4",
     "jasmine": "^2.4.1",
     "nodemon": "^1.11.0",
     "ts-node": "^1.7.0",
     "typescript": "^2.0.10"
   }
-}
+}

tsconfig.json

@@ -7,7 +7,10 @@
         "module": "commonjs",
         "target": "es5",
         "noImplicitAny": false,
-        "sourceMap": false
+        "sourceMap": false,
+        "types": [
+            "node"
+        ]
     },
     "exclude": [
         "node_modules"