Meteor:在服务器上正确使用 Meteor.wrapAsync

IT技术 javascript meteor stripe-payments
2021-02-04 15:00:36

背景

我正在尝试将条带支付集成到我的网站中。我需要使用我的私有条带密钥创建一个条带用户。我将此密钥存储在我的服务器上,并调用服务器方法来创建用户。也许有另一种方法可以实现这一目标?这是条带 api(为方便起见复制如下):https : //stripe.com/docs/api/node#create_customer

//stripe api call
var Stripe = StripeAPI('my_secret_key');

Stripe.customers.create({
  description: 'Customer for test@example.com',
  card: "foobar" // obtained with Stripe.js
}, function(err, customer) {
  // asynchronously called
});

我的尝试和结果

我一直在使用具有不同服务器代码的相同客户端代码。所有尝试立即在客户端的 console.log(...) 上给出 undefined 但在服务器 console.log(...) 上给出正确的响应:

//client
Meteor.call('stripeCreateUser', options, function(err, result) {
  console.log(err, result);
});

//server attempt 1
var Stripe = StripeAPI('my_secret_key');

Meteor.methods({
    stripeCreateUser: function(options) {  
        return Meteor.wrapAsync(Stripe.customers.create({
            description: 'Woot! A new customer!',
            card: options.ccToken,
            plan: options.pricingPlan
        }, function (err, res) {
            console.log(res, err);
            return (res || err);
        }));
    }
});

//server attempt 2
var Stripe = StripeAPI('my_secret_key');

Meteor.methods({
    stripeCreateUser: function(options) {  
        return Meteor.wrapAsync(Stripe.customers.create({
            description: 'Woot! A new customer!',
            card: options.ccToken,
            plan: options.pricingPlan
        }));
    }
});

我也试过没有 Meteor.wrapAsync。

编辑 - 我也在使用这个包:https : //atmospherejs.com/mrgalaxy/stripe

4个回答

Meteor.wrapAsync http://docs.meteor.com/#meteor_wrapasync您可以看到您需要向它传递一个函数和一个可选的上下文,而在您的两次尝试中,您正在传递调用Stripe.customers.create.

Meteor.methods({
  stripeCreateUser: function(options) {
    // get a sync version of our API async func
    var stripeCustomersCreateSync=Meteor.wrapAsync(Stripe.customers.create,Stripe.customers);
    // call the sync version of our API func with the parameters from the method call
    var result=stripeCustomersCreateSync({
      description: 'Woot! A new customer!',
      card: options.ccToken,
      plan: options.pricingPlan
    });
    // do whatever you want with the result
    console.log(result);
  }
});

Meteor.wrapAsync将异步函数转换为方便的同步查找函数,允许编写顺序查找代码。(底层的一切仍然在异步 Node.js 事件循环中执行)。

我们需要传递给Meteor.wrapAsync我们的 API 函数 ( Stripe.customers.create) 以及函数上下文,即this在 API func 的主体内部,在这种情况下是Stripe.customers

编辑 :

如何检索错误?

传统的节点样式 API 函数通常将回调作为最后一个参数,当所需任务完成时,该回调将最终被调用。这个回调有 2 个参数:error 和 data,根据调用的结果,其中一个将为 null。

我们如何使用返回的同步包装函数访问错误对象Meteor.wrapAsync

我们必须依赖于使用 try/catch 块,因为如果出现错误,它将被同步函数抛出,而不是作为异步函数回调的第一个参数传递。

try{
  var result=syncFunction(params);
  console.log("result :",result);
}
catch(error){
  console.log("error",error);
}
// is the equivalent of :
asyncFunc(params,function(error,result){
  if(error){
    console.log("error",error);
    return;
  }
  console.log("result :",result);
});

为什么不需要通过 Stripe?

JavaScript 没有“命名空间”的概念,因此 API 开发人员使用定义一个全局对象作为 API 命名空间的常用技巧,在该对象上定义的属性是 API 的“子module”。这意味着它Stripe.customers是 Stripe API 的一个子module,用于公开与客户相关的 funcs,因此这些 funcsthis上下文是Stripe.customers,而不是Stripe

您可以通过在浏览器控制台中复制粘贴此模拟代码来自行测试:

Stripe={
  customers:{
    create:function(){
      console.log(this==Stripe.customers);
    }
  }
};

然后像这样在浏览器控制台中调用存根函数:

> Stripe.customers.create();
true
这在我最近的编辑中得到了解决,感谢您指出这一点。
2021-03-19 15:00:36
@saimeunt 如果您从客户端使用 Meteor.call,如何将错误返回给客户端?如果您在客户端设置回调(如果您不使用存根,则必须这样做)似乎无法返回传统样式(错误,结果),只能返回结果。对此的任何了解将不胜感激。
2021-03-20 15:00:36
你怎么得到错误?我在别处看到你仍然可以提供一个回调来接收(错误,数据),但是在同步响应中,如果失败,会出现一个错误对象而不是数据吗?
2021-03-25 15:00:36
谢谢。文档对我来说不像你的回答那么清楚。我也不完全理解你的最后一段。我将不得不多研究一点。比如,为什么不需要通过Stripe?再次感谢!
2021-04-01 15:00:36
@saimeunt 我似乎已经解决了我发回错误的特殊问题。如果有人感兴趣,我会将其作为答案
2021-04-12 15:00:36

另一种选择是这个,它实现了类似的目标。

meteor add meteorhacks:async

从包自述文件:

异步包装(函数)

包装一个异步函数并允许它在没有回调的情况下在 Meteor 中运行。

//declare a simple async function
function delayedMessge(delay, message, callback) {
  setTimeout(function() {
    callback(null, message);
  }, delay);
}

//wrapping
var wrappedDelayedMessage = Async.wrap(delayedMessge);

//usage
Meteor.methods({
  'delayedEcho': function(message) {
    var response = wrappedDelayedMessage(500, message);
    return response;
  }
});
是的,你可以这样做。请注意,Meteor 回调是异步的。docs.meteor.com/#/full/meteor_call
2021-03-17 15:00:36
好的,所以对于同步方法调用不要给它一个回调
2021-03-20 15:00:36
嗯,我想知道包装 Meteor.call 方法本身。Meteor.call 从客户端调用时应该有一个回调。所以也许我们可以包装那个方法。
2021-03-22 15:00:36

首先感谢@saimeunt 的回答,让一些难懂的概念变得清晰。但是,我想要一个经典的异步回调(错误,结果)在客户端上显示错误和结果,以便我可以在浏览器中提供信息性消息。

我是这样解决的:

服务器代码:

var Stripe = StripeAPI(STRIPE_SECRET_KEY);

Meteor.methods({
    createCust: Meteor.wrapAsync(Stripe.charges.create, Stripe.charges)
});

客户端代码:

var stripeCallOptions = {
    description: 'Woot! A new customer!',
    card: ccToken,
    plan: pricingPlan
};


Meteor.call('createCust', stripeCallOptions, function(error, result){
    console.log('client error', error);
    console.log('client result', result);
});

看起来很整洁。然而不幸的是 wrapAsync 有一个开放的错误,(见https://github.com/meteor/meteor/issues/2774)因为它没有将正确的错误恢复给调用者。一位名叫 Faceyspacey 的天才编写了一个名为 Meteor.makeAsync() 的替代品,您可以在我提到的错误页面上找到它,但是它会将结果或错误返回给 'result' 变量,而未定义 'error' 变量。我现在很好,至少我对正确的错误对象有一个钩子。

如果你使用 makeAsync() 你需要像这样导入 Futures:

Meteor.startup(function () {
    //this is so that our makeAsync function works
    Future = Npm.require('fibers/future');
});

由于您几乎需要将每个函数都包装在 Async 中,因此您应该使用这个包,https://atmospherejs.com/copleykj/stripe-sync使用WrapAsync 预先包装所有条带函数,使您的生活更轻松,代码更简洁。

生活更轻松,代码更干净……你不应该认为他的生活很肮脏:p
2021-03-28 15:00:36