| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677 |
- crypto = require('crypto')
- ALGORITHM = 'aes-256-ctr'
- keyFn = (password, salt, callback)->
- return crypto.pbkdf2(password, salt, 10000, 64, 'sha1', callback)
- keyFn32 = (password, salt, keyLength, callback)->
- return crypto.pbkdf2(password, salt, 10000, 32, 'sha1', callback)
- class AccessTokenEncryptor
- constructor: (settings) ->
- @settings = settings
- @cipherLabel = @settings.cipherLabel
- throw Error("cipherLabel must not contain a colon (:)") if @cipherLabel?.match(/:/)
- @cipherPassword = @settings.cipherPasswords[@cipherLabel]
- throw Error("cipherPassword not set") if not @cipherPassword?
- throw Error("cipherPassword too short") if @cipherPassword.length < 16
- encryptJson: (json, callback) ->
- string = JSON.stringify(json)
- crypto.randomBytes 32, (err, bytes) =>
- return callback(err) if err
- salt = bytes.slice(0, 16)
- iv = bytes.slice(16, 32)
- keyFn32 @cipherPassword, salt, 32, (err, key) =>
- if err?
- logger.err err:err, "error getting Fn key"
- return callback(err)
- cipher = crypto.createCipheriv(ALGORITHM, key, iv)
- crypted = cipher.update(string, 'utf8', 'base64') + cipher.final('base64')
- callback(null, "#{@cipherLabel}:#{salt.toString('hex')}:#{crypted}:#{iv.toString('hex')}")
- decryptToJson: (encryptedJson, callback) ->
- [label, salt, cipherText, iv] = encryptedJson.split(':', 4)
- password = @settings.cipherPasswords[label]
- return callback(new Error("invalid password")) if not password? or password.length < 16
- if iv
- @decryptToJsonV2(password, salt, cipherText, iv, callback)
- else
- @decryptToJsonV1(password, salt, cipherText, callback)
- decryptToJsonV1: (password, salt, cipherText, callback) ->
- keyFn password, Buffer.from(salt, 'hex'), (err, key) =>
- if err?
- logger.err err:err, "error getting Fn key"
- return callback(err)
- decipher = crypto.createDecipher(ALGORITHM, key)
- dec = decipher.update(cipherText, 'base64', 'utf8') + decipher.final('utf8')
- try
- json = JSON.parse(dec)
- catch e
- return callback(new Error("error decrypting token"))
- callback(null, json, true)
- decryptToJsonV2: (password, salt, cipherText, iv, callback) ->
- keyFn32 password, Buffer.from(salt, 'hex'), 32, (err, key) =>
- if err?
- logger.err err:err, "error getting Fn key"
- return callback(err)
- decipher = crypto.createDecipheriv(ALGORITHM, key, Buffer.from(iv, 'hex'))
- dec = decipher.update(cipherText, 'base64', 'utf8') + decipher.final('utf8')
- try
- json = JSON.parse(dec)
- catch e
- return callback(new Error("error decrypting token"))
- callback(null, json)
- module.exports = AccessTokenEncryptor
|