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 ''
+ })
+}