Firebase Firestore - обновляет базу данных Firestore через облачную функцию после Stripe.CreateCustomer - PullRequest
0 голосов
/ 22 марта 2020

Я пытаюсь обновить базу данных после вызова OnCreate, чтобы создать пользователя с полосами, однако у меня возникли проблемы. Это должно быть легкой задачей, но я, кажется, что-то упустил.

В моем файле SignUpActivity. java я создаю свои поля userStripeCusId и userStripeAcctId как null, а затем пытаюсь обновить значения полей позже с помощью моего облачного вызова функции https.

Я знаю, что он срабатывает, потому что он создает нового пользователя в базе данных Stripe, и я записываю в журнал недавно созданный идентификатор клиента Stripe, который я пытаюсь сохранить в моей базе данных 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

I'm попробовал следующее, но не повезло с ними.

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

Это не работает, хотя это предлагается в этом Firebase видео в 8:07

2) return admin.firestore().collection('Users').doc(snapshot.data().userEmail).update({"userStripeCusId": StripeCustomer.id}); Пробовал также, как показано в этом StackOverflow Post

Я также пытался следовать этот источник Firestore / Stripe , но не повезло

Ответы [ 2 ]

1 голос
/ 22 марта 2020

Вы пишете в базу данных реального времени вместо Firestore:

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

admin.database() не дает вам доступ к Firestore. Вместо этого используйте admin.firestore() (и обратите внимание, что у него совершенно другой API).

Кроме того, вы не имеете дело с обещанием, возвращенным из этого (неправильного) обновления, поэтому Cloud Functions не знает, ждать это до фини sh.

0 голосов
/ 25 марта 2020

Оказывается, виновником был createStripeCustomerHttpsCall. Я обратился в справочный центр по полосам , и они отправили меня в их документы , к которым, как мне казалось, у меня был похожий код. Оказывается, я этого не сделал.

Я настроил их 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});
});
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...