|
@@ -5,6 +5,9 @@ ALGORITHM = 'aes-256-ctr'
|
|
|
keyFn = (password, salt, callback)->
|
|
keyFn = (password, salt, callback)->
|
|
|
return crypto.pbkdf2(password, salt, 10000, 64, 'sha1', 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
|
|
class AccessTokenEncryptor
|
|
|
|
|
|
|
|
constructor: (settings) ->
|
|
constructor: (settings) ->
|
|
@@ -19,25 +22,52 @@ class AccessTokenEncryptor
|
|
|
|
|
|
|
|
encryptJson: (json, callback) ->
|
|
encryptJson: (json, callback) ->
|
|
|
string = JSON.stringify(json)
|
|
string = JSON.stringify(json)
|
|
|
- salt = crypto.randomBytes(16)
|
|
|
|
|
- keyFn @cipherPassword, salt, (err, key) =>
|
|
|
|
|
- if err?
|
|
|
|
|
- logger.err err:err, "error getting Fn key"
|
|
|
|
|
- return callback(err)
|
|
|
|
|
- cipher = crypto.createCipher(ALGORITHM, key)
|
|
|
|
|
- crypted = cipher.update(string, 'utf8', 'base64') + cipher.final('base64')
|
|
|
|
|
- callback(null, @cipherLabel + ":" + salt.toString('hex') + ":" + crypted)
|
|
|
|
|
|
|
+ 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) ->
|
|
decryptToJson: (encryptedJson, callback) ->
|
|
|
- [label, salt, cipherText] = encryptedJson.split(':', 3)
|
|
|
|
|
|
|
+ [label, salt, cipherText, iv] = encryptedJson.split(':', 4)
|
|
|
password = @settings.cipherPasswords[label]
|
|
password = @settings.cipherPasswords[label]
|
|
|
return callback(new Error("invalid password")) if not password? or password.length < 16
|
|
return callback(new Error("invalid password")) if not password? or password.length < 16
|
|
|
- keyFn password, new Buffer(salt, 'hex'), (err, key) =>
|
|
|
|
|
|
|
+
|
|
|
|
|
+ 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?
|
|
if err?
|
|
|
logger.err err:err, "error getting Fn key"
|
|
logger.err err:err, "error getting Fn key"
|
|
|
return callback(err)
|
|
return callback(err)
|
|
|
decipher = crypto.createDecipher(ALGORITHM, key)
|
|
decipher = crypto.createDecipher(ALGORITHM, key)
|
|
|
dec = decipher.update(cipherText, 'base64', 'utf8') + decipher.final('utf8')
|
|
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
|
|
try
|
|
|
json = JSON.parse(dec)
|
|
json = JSON.parse(dec)
|
|
|
catch e
|
|
catch e
|