Conver to ts

.babelrc

@@ -0,0 +1,3 @@
+{
+    "extends": "./node_modules/@connectedcars/setup/.babelrc"
+}

.eslintrc

@@ -1,26 +1,5 @@
 {
-    "parser": "babel-eslint",
-    "extends": [
-      "prettier"
-    ],
-    "plugins": [
-      "prettier",
-      "node"
-    ],
-    "parserOptions": {
-      "ecmaVersion": 2016,
-      "sourceType": "module"
-    },
-    "rules": {
-      "node/no-unsupported-features": "error",
-      "no-unused-vars": "warn",
-      "prettier/prettier": ["error", {
-        "singleQuote": true,
-        "semi": false
-      }]
-    },
-    "env": {
-      "es6": true,
-      "node": true
-    }
-}
+  "extends": "./node_modules/@connectedcars/setup/.eslintrc",
+  // Force eslint to use local installed parser not the one from ./node_modules/@connectedcars/setup
+  "parser": "@typescript-eslint/parser"
+}

.gitignore

@@ -58,3 +58,5 @@ typings/
 .env
 
 .vscode/
+.DS_Store
+build/

Dockerfile

@@ -0,0 +1,15 @@
+ARG NODE_VERSION=stable
+
+FROM gcr.io/connectedcars-staging/node-builder.master:$NODE_VERSION as builder
+
+ARG COMMIT_SHA=master
+
+WORKDIR /app
+
+USER builder
+
+# Copy application code.
+COPY --chown=builder:builder . /app
+
+RUN npm i
+RUN npm run ci-auto

bin/jwtdecode.test.js → bin/jwtdecode.test.ts

@@ -1,20 +1,18 @@
-'use strict'
-const { spawn } = require('child_process')
-const { readFileSync } = require('fs')
+import { spawn } from 'child_process'
+import { readFileSync } from 'fs'
+import sinon from 'sinon'
 
-const expect = require('unexpected')
+import { JwtUtils } from '../src/index'
 
-const { JwtUtils } = require('../src/index')
+const rsaPrivateKey = readFileSync(`${__dirname}/jwtencode.test.key`).toString()
 
-const rsaPrivateKey = readFileSync(`${__dirname}/jwtencode.test.key`)
-
-let jwtHeader = {
+const jwtHeader = {
   alg: 'RS256',
   typ: 'JWT',
   kid: '1'
 }
 
-let jwtBody = {
+const jwtBody = {
   iss: 'https://jwt.io',
   aud: 'localhost',
   sub: '[email protected]',
@@ -24,26 +22,38 @@ let jwtBody = {
 }
 
 describe('jwtencode', () => {
-  it('should return ok', function(done) {
-    this.timeout(10000)
-    this.slow(3000)
-    let jwtEncode = spawn(`${__dirname}/jwtdecode.js`, [
+  let clock: sinon.SinonFakeTimers
+
+  beforeAll(async () => {
+    clock = sinon.useFakeTimers()
+  })
+
+  afterEach(async () => {
+    clock.restore()
+  })
+
+  afterAll(async () => {
+    sinon.restore()
+  })
+  it('should return ok', function (done) {
+    clock.tick(3000)
+    const jwtEncode = spawn(`${__dirname}/jwtdecode.js`, [
       `${__dirname}/jwtencode.test.pub`,
       '1',
       'RS256',
       'https://jwt.io',
       'localhost'
     ])
 
-    let jwt = JwtUtils.encode(rsaPrivateKey, jwtHeader, jwtBody)
+    const jwt = JwtUtils.encode(rsaPrivateKey, jwtHeader, jwtBody)
 
     // Write JSON
     jwtEncode.stdin.write(jwt)
     jwtEncode.stdin.end()
 
     // Read stderr
     let stderrStr = ''
-    let errorData = []
+    const errorData: any[] = []
     jwtEncode.stderr.on('data', data => {
       errorData.push(data)
     })
@@ -53,25 +63,25 @@ describe('jwtencode', () => {
 
     // Read token
     let stdoutStr = ''
-    let decodedData = []
-    let error
+    const decodedData: Buffer[] = []
+    let error: Error
     jwtEncode.stdout.on('data', data => {
       decodedData.push(data)
     })
     jwtEncode.stdout.on('end', () => {
       try {
-        stdoutStr = Buffer.concat(decodedData)
-          .toString('utf8')
-          .trim()
-        let decodedBody = JSON.parse(stdoutStr)
-        expect(decodedBody, 'to equal', jwtBody)
+        stdoutStr = Buffer.concat(decodedData).toString('utf8').trim()
+        const decodedBody = JSON.parse(stdoutStr)
+        expect(decodedBody).toEqual(jwtBody)
       } catch (e) {
         error = e
       }
     })
 
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     jwtEncode.on('exit', (code, signal) => {
       if (error) {
+        // eslint-disable-next-line no-console
         console.log(`stdout:${stdoutStr}\nstderr:${stderrStr}\nexit:${code}`)
         done(error)
       } else {

bin/jwtdecode.ts

@@ -0,0 +1,50 @@
+#!/usr/bin/env node
+
+import fs from 'fs'
+
+import { JwtUtils } from '../src'
+
+if (process.argv.length < 6) {
+  // eslint-disable-next-line no-console
+  console.log('jwtdecode publickeyfile keyid algo issuer audiences')
+  process.exit(255)
+}
+const publicKeyPath = process.argv[2]
+const keyId = process.argv[3]
+const algo = process.argv[4]
+const issuer = process.argv[5]
+const audiences = process.argv[6].split(',')
+
+const publicKey = fs.readFileSync(publicKeyPath)
+
+const pubKeys = {
+  [issuer]: {
+    [`${keyId}@${algo}`]: publicKey.toString('utf8')
+  }
+}
+
+process.stdin.resume()
+process.stdin.setEncoding('utf8')
+
+let buffer = ''
+process.stdin.on('data', function (chunk) {
+  buffer += chunk
+  buffer = processJwts(buffer)
+})
+
+process.stdin.on('end', function () {
+  buffer = processJwts(buffer)
+})
+
+function processJwts(buffer: string): string {
+  return buffer.replace(/(?:^|\n)\s*?([a-zA-Z0-9_-]+\.[a-zA-Z0-9_-]+\.[a-zA-Z0-9_-]+)\s*?(?:$|\n)/g, (match, jwt) => {
+    try {
+      // eslint-disable-next-line no-console
+      console.log(JSON.stringify(JwtUtils.decode(jwt, pubKeys, audiences), null, 2))
+    } catch (e) {
+      // eslint-disable-next-line no-console
+      console.error(e.message)
+    }
+    return ''
+  })
+}