promisified

lib/add.d.ts

@@ -1,5 +1,6 @@
 import { TaskSpec } from 'ordu';
 declare function api_add(this: any): any;
+declare function api_message(this: any, pattern0: any, pattern1: any, action: any): any;
 declare const task: {
     translate(spec: TaskSpec): {
         op: string;
@@ -60,4 +61,4 @@ declare const task: {
         op: string;
     };
 };
-export { api_add, task, };
+export { api_add, api_message, task, };

lib/add.ts

@@ -62,6 +62,47 @@ function api_add(this: any) {
 }
 
 
+function api_message(this: any, pattern0: any, pattern1: any, action: any) {
+  let actfunc = action || pattern1
+  const action_wrapper: any =
+    null == actfunc
+      ? null
+      : function(this: any, msg: any, reply: any, meta: any) {
+        actfunc.call(this, msg, meta).then(reply).catch(reply)
+      }
+
+  if (null != actfunc && null != action_wrapper) {
+    if ('' != actfunc.name) {
+      Object.defineProperty(action_wrapper, 'name', { value: actfunc.name })
+    }
+
+    for (var p in actfunc) {
+      action_wrapper[p] = actfunc[p]
+    }
+
+    // NOTE: also set properties defined after call to seneca.message
+    setImmediate(function() {
+      for (var p in actfunc) {
+        action_wrapper[p] = actfunc[p]
+      }
+    })
+  }
+
+  if (action) {
+    this.add(pattern0, pattern1, action_wrapper)
+  }
+  else if (action_wrapper) {
+    this.add(pattern0, action_wrapper)
+  }
+  else {
+    this.add(pattern0)
+  }
+
+  return this
+}
+
+
+
 const task = {
   translate(spec: TaskSpec) {
     const args = spec.ctx.args
@@ -411,5 +452,6 @@ const intern = (module.exports.intern = {
 
 export {
   api_add,
+  api_message,
   task,
 }

lib/api.d.ts

@@ -45,6 +45,8 @@ declare function reply(this: any, spec: any): boolean;
 declare function listen(this: any, callpoint: any): (this: any, ...argsarr: any[]) => any;
 declare function client(this: any, callpoint: any): (this: any) => any;
 declare function decorate(this: any): void;
+declare function prepare(this: any, prepareAction: Function): any;
+declare function destroy(this: any, destroyAction: any): any;
 declare let API: {
     wrap: typeof wrap;
     fix: typeof fix;
@@ -78,5 +80,7 @@ declare let API: {
     listen: typeof listen;
     client: typeof client;
     decorate: typeof decorate;
+    prepare: typeof prepare;
+    destroy: typeof destroy;
 };
 export { API };

lib/api.ts

@@ -835,6 +835,67 @@ function decorate(this: any) {
 }
 
 
+function prepare(this: any, prepareAction: Function) {
+  if (null == prepareAction || 'function' != typeof prepareAction) {
+    throw new Error('seneca: first argument to prepare must be a function')
+  }
+
+  async function prepare_wrapper(this: any, msg: any) {
+    await prepareAction.call(this, msg)
+    return this.prior(msg)
+  }
+
+  if ('' != prepareAction.name) {
+    Object.defineProperty(prepare_wrapper, 'name', {
+      value: 'prepare_' + prepareAction.name,
+    })
+  }
+
+  const plugin = this.plugin
+
+  let pat = {
+    role: 'seneca',
+    plugin: 'init',
+    init: plugin.name,
+    tag: undefined,
+  }
+
+  if (null != plugin.tag && '-' != plugin.tag) {
+    pat.tag = plugin.tag
+  }
+
+  this.message(pat, prepare_wrapper)
+
+  this.plugin.prepare = this.plugin.prepare || []
+  this.plugin.prepare.push(prepareAction)
+
+  return this
+}
+
+
+function destroy(this: any, destroyAction: any) {
+  async function destroy_wrapper(this: any, msg: any) {
+    await destroyAction.call(this, msg)
+    return this.prior(msg)
+  }
+
+  if ('' != destroyAction.name) {
+    Object.defineProperty(destroy_wrapper, 'name', {
+      value: 'destroy_' + destroyAction.name,
+    })
+  }
+
+  this.message('role:seneca,cmd:close', destroy_wrapper)
+
+  this.plugin.destroy = this.plugin.destroy || []
+  this.plugin.destroy.push(destroyAction)
+
+  return this
+}
+
+
+
+
 
 intern.parse_config = function(args: any) {
   let out: any = {}
@@ -1031,6 +1092,8 @@ let API = {
   listen,
   client,
   decorate,
+  prepare,
+  destroy,
 }