pgpcrypt

conf/config.js

@@ -5,6 +5,7 @@ var cfg = {
   'mqtt' : cfg_load('mqtt.json'),
   'memstore' : cfg_load('memstore.json'),
   'storage' : cfg_load('storage.json'),
+  'keystore': cfg_load('keystore.json'),
   'auth' : {
     'secret': cfg_load('secret.json'),
 	  'acl' : cfg_load('acl.json')

conf/template/keystore.json

+{
+    "dir":"./keys"
+}
\ No newline at end of file

env/default.json

@@ -6,5 +6,6 @@
     {"env":"BSCONFIG_MEMSTORE_URL","conf":"memstore.url"},
     {"env":"BSCONFIG_STORAGE_REPOSITORY","conf":"storage.repository"},
     {"env":"BSCONFIG_STORAGE_APIHOSTNAME","conf":"storage.api_hostname"},
-    {"env":"BSCONFIG_SECRET_TEXT","conf":"auth.secret.value"}
+    {"env":"BSCONFIG_SECRET_TEXT","conf":"auth.secret.value"},
+    {"env":"BSCONFIG_KEYSTORE_DIR","conf":"keystore.dir"}
 ]
\ No newline at end of file

plugins/dt/dt-pgpcrypt/perform.js

 var ctx = require('../../../context');
 var Utils = ctx.getLib('lib/util/plugin-utils');
-var pgplib = require('./pgp')
+var pgplib = require('./pgp');
+var path = require('path');
+var fs = require('fs');
 
 function perform_function(context,request,response){
   var job_id = context.jobconfig.job_id;
@@ -18,10 +20,26 @@ function perform_function(context,request,response){
   var req_passphrase = param.passphrase || ""
   var req_output = param.output|| "binary"
 
+  var key_dir = ctx.getConfig('keystore.dir','./keys');
+  var fn_load_key = function (name) {
+    var k = "";
+    var fp = path.join(key_dir ,path.basename(name));
+    try{
+      k = fs.readFileSync(fp).toString('utf8');
+    }catch(e){
+
+    }
+
+    return k;
+  }
+
   var env = {
     'type' : output_type,
     'data' : data,
-    'meta' : meta
+    'meta' : meta,
+    '_fn' : {
+      'load_key' : fn_load_key
+    }
   }
 
   req_publickey = Utils.vm_execute_text(env,req_publickey);