Firebase Firestore - 在 Stripe.CreateCustomer 之后通过 Cloud Function 更新 Firestore 数据库

Question

在调用 OnCreate 以创建条带用户后，我正在尝试更新我的数据库，但是我遇到了问题。这应该是一件容易的事，但我似乎遗漏了一些东西。

在我的 SignUpActivity.java 文件中，我将字段 userStripeCusId 和 userStripeAcctId 创建为 null，然后稍后尝试使用我的云函数 https 调用更新字段值。

我知道它会触发，因为它在 Stripe 数据库中创建了一个新用户，并且我让它记录了新创建的 Stripe 客户 ID，这是我试图保存在我的 Firestore 数据库中的内容。

有没有人知道如何解决这个问题？

我一直在看这个 youtube 视频以供参考，但没有任何运气。 Youtube 视频适用于实时数据库，而不是我使用的 Cloud Firestore。

SignUpActivity.java

private void registerUser() {

userDocRef.set(userInfo).addOnSuccessListener(new OnSuccessListener<Void>() {
                        @Override
                        public void onSuccess(Void aVoid) {

                            //time stamp block
                            Date date = Calendar.getInstance().getTime();
                            DateFormat formatter = new SimpleDateFormat("yyyy/MM/dd hh:mm a", Locale.US);
                            String userCreatedTimestamp = formatter.format(date);
                            System.out.println("Today : " + userCreatedTimestamp);

                            userDocRef.update(
                                    "firstName", firstName,
                                    "lastName", lastName,
                                    "userEmail", userEmail,
                                    "userName", userName,
                                    "userPhoneNumber", completePhoneNumber,
                                    "userStripeCusId", null, // <--FIELD CREATED HERE!
                                    "userStripeAcctId", null,  // <--FIELD CREATED HERE!
                                    "userCreatedTimestamp", userCreatedTimestamp).addOnSuccessListener(new OnSuccessListener<Void>() {
                                @Override
                                public void onSuccess(Void aVoid) {
                                    Log.d(TAG, "onSuccess: userinfo was created");
                                }
                            });
                            Log.d(TAG, "onSuccess: user was created");
                            startActivity(new Intent(SignUpActivity.this, DashboardActivity.class));
                            finish();

                        }
                    })

        createStripeCustomer();

    private void createStripeCustomer() {

        mFunctions.getHttpsCallable("createStripeCustomerHTTPSCall").call(data);

    }

index.js

exports.createStripeCustomerHTTPSCall = functions.firestore.document('Users/{userName}').onCreate((snapshot, context) =>{

    console.log("Stripe Customer profile for " + context.params.userName + " created."); 
    // ^ returns username correctly

    return stripeToken.customers.create(
        {
            description: 'My First Test Customer (created for API docs)',
            email: context.params.userName,
        },
        (err, StripeCustomer) => {

            console.log("customer id: " + StripeCustomer.id + " customer email: " + StripeCustomer.email);
            //^ returns correct stripe customer ID and associated email it was created with.

            console.log("Creating Stripe customer failed because: " + err.toString())
            admin.database().ref('Users/{userName}').update({ "userStripeCusId": StripeCustomer.id})
// no action is triggered. Stripe customerID is not saved in my firebase DB       

// ^ @DougStevenson pointed out that using admin.database() is meant for a REALTIME DATABASE  which is not my case.

        }
).catch(error => {
        console.log(error)
    })
});

--------------更新-------- ---

index.js 已更新至此。

exports.createStripeCustomerHTTPSCall = functions.firestore.document('Users/{userName}').onCreate((snapshot, context) =>{

    console.log("Stripe Customer profile for " + context.params.userName + " created.");
    console.log("Stripe Customer Email for " + context.params.userEmail + " created.");

    return stripeToken.customers.create(
        {
            description: 'My First Test Customer (created for API docs)',
            email: context.params.userName,
        },
        (err, StripeCustomer) => {
        // asynchronously called
            console.log("customer id: " + StripeCustomer.id + " customer email: " + StripeCustomer.email);
            // admin.database().ref('Users/{userName}').update({ "userStripeCusId": StripeCustomer.id}) // <-- admin.database() is for REALTIME DATABASE 

            console.log("snapshot.get-userStripeCusId-: " +  snapshot.get("userStripeCusId"));

            // console.log("snapshot.get(Users/{userName}/userStripeCusId): " +  snapshot.get("Users/{userName}/userStripeCusId")); <-- doesnt work
            console.log("snapshot.data(): " + snapshot.data().toString()); // <-- returns object
            console.log("snapshot.data().userName: " + snapshot.data().userName); // <-- returns correct userName 
            console.log("snapshot.data().userEmail: " + snapshot.data().userEmail); // <-- returns correct userEmail

我尝试了以下方法，但都没有成功。

1) return admin.firestore.ref.update({"userStripeCusId": StripeCustomer.id})

虽然Firebase video 8:07 建议这样做，但这不起作用

2) return admin.firestore().collection('Users').doc(snapshot.data().userEmail).update({"userStripeCusId": StripeCustomer.id}); 也试过这个StackOverflow Post

我也尝试过关注this Firestore / Stripe source，但没有成功

Answer 1

原来罪魁祸首是createStripeCustomerHttpsCall。我联系了stripe help center，他们把我送到了their docs，我认为我有类似的代码。原来我没有。

我将他们的createStripeCustomer 调整为下面的块，它对我有用。

// When a user is created, register them with Stripe
exports.createStripeCustomerOG = functions.auth.user().onCreate(async (user) => {

  const customer = await stripeToken.customers.create({email: user.email});
  return admin.firestore().collection('Users').doc(user.email).update({userStripeCusId: customer.id});
});

Answer 2

您正在写入实时数据库而不是 Firestore：

admin.database().ref('Users/{userName}').update({ "userStripeCusId": StripeCustomer.id})

admin.database() 不允许您访问 Firestore。请改用admin.firestore()（注意它有一个完全不同的API）。

此外，您没有处理从该（不正确的）更新返回的承诺，因此 Cloud Functions 不知道等待它完成。