如何在node.js混淆中處理async/await和promises

我已經檢查了大量類似問題的所有資料，我很困惑。無論電話號碼是否在資料庫中，這都會回傳相同的結果。具有異步和承諾的其他版本已經使應用程式崩潰。請幫忙

如何使用管理 SDK 從 Firebase 實時資料庫獲取值并使用該值來確定輸出。此外，由于某種原因，它有時似乎例外緩慢

auth.controller.js

const validate = require('../utils/validate');
const { getItem, setItem } = require('../utils/firebase');
const { generatePin } = require('../utils/auth');
const argon2 = require('argon2');
const { error } = require('console');
const { networkInterfaces } = require('os');
const exp = require('constants');

exports.connect = async function (req, res) {
    const { phone } = req.body;
    if (!phone) {
        res.status(400).json({ message: 'Error, phone number is invalid or not registered'})
    } else {
        if(!validate.phoneNumber(phone))  {
            res.status(400).json({ message: 'Error, phone number is invalid or not registered' })              
        } else {
            const result = await generatePin();
            item = await setItem('clients', 'phone', phone, 'hash', result.hash)
            console.log(item)
            if(!item) {
                res.status(200).json({ message: 'Success', pin: result.pin})
            }  else {
                res.status(400).json({ message: 'Error, phone number is invalid or not registered' })
            }
            var currentTime = Date.now();   
            var expiryTime = currentTime   60;     
            setItem('clients', 'phone', phone, 'hashExpiry', expiryTime)
        }            
    }

firebase.js

const { on } = require("events");
var admin = require("firebase-admin");
// Import Admin SDK
const { getDatabase } = require('firebase-admin/database');
const { type } = require("os");

var serviceAccount = require("../fedex-3a42e-firebase-adminsdk-r96f1-7249eaf87b.json");
admin.initializeApp({
    credential: admin.credential.cert(serviceAccount),
    databaseURL: "https://fedex-3a42e-default-rtdb.firebaseio.com/"
});

const db = getDatabase()

function getItem(itemRef, child, val) {
    const dbRef = db.ref(itemRef);    
    dbRef.orderByChild(child).equalTo(val).on("value", (data) => {
        return data.val();       
    }); 
}

async function setItem(itemRef, child, val, key, pushedVal) {
    const value = await getItem(itemRef, child, val);
    console.log('val', value)
    if(value) {
        finallySetItem(value, itemRef, pushedVal);
        return true
    } else  {
        return false
    }         
}

function finallySetItem(data, itemRef, pushedVal) {
    console.log(data)
    if(data) {
        var itemKey = Object.keys(data)[0];
        console.log(itemKey)
        const dbRef = db.ref(itemRef   '/'   itemKey    '/'   key);
        dbRef.set(pushedVal);        
    }
}

module.exports = { getItem, setItem }

uj5u.com熱心網友回復：

這行不通：

function getItem(itemRef, child, val) {
    const dbRef = db.ref(itemRef);    
    dbRef.orderByChild(child).equalTo(val).on("value", (data) => {
        return data.val();       
    }); 
}

您將回呼傳遞給on()，并且on()不會對您在那里回傳的值執行任何操作。

您更有可能希望once()從那里異步使用和回傳值：

async function getItem(itemRef, child, val) {
    const dbRef = db.ref(itemRef);    
    const data = await dbRef.orderByChild(child).equalTo(val).once("value");
    return data.val();       
}

標籤：节点.js 火力基地 火力实时数据库

上一篇：顫振 火力 條紋

下一篇：如何將x天添加到unix時間戳