FirebaseのCloud FunctionsでonCallすると内部でhttp.getを行いそれに応じた郵便番号を返したい

Question

const functions = require("firebase-functions");
const admin = require('firebase-admin');
let http = require('https');
admin.initializeApp();


exports.postalCode = functions.https.onCall(async (data, context) => {
        //const URL = "https://zipcloud.ibsnet.co.jp/api/search?zipcode="+data.text;
    const URL = 'https://zipcloud.ibsnet.co.jp/api/search?zipcode=100-0002';
    var data = [];
    http.get(URL, (res) => {
        let body = '';
        res.setEncoding('utf8');

        res.on('data', (chunk) => {
            body += chunk;
            data.push(body);
        });

        res.on('end', (res) => {
            return data[0];
        });
    }).on('error', (e) => {
        console.log(e.message); //エラー時
    });   
});

このようなコード内容でアプリ側(Flutter)から叩いた時にdata[0]が返ってこないです

エラー文(Flutter側)

Error: [firebase_functions/internal] internal

at Object.throw_ [as throw] (http://localhost:8080/dart_sdk.js:5061:11)
at https_callable_web.HttpsCallableWeb.new.call
(http://localhost:8080/packages/cloud_functions_web/https_callable_web.dart.lib.js:39:23)
at call.throw (<anonymous>)
at http://localhost:8080/dart_sdk.js:38645:38
at _RootZone.runBinary (http://localhost:8080/dart_sdk.js:38515:59)
at _FutureListener.thenAwait.handleError (http://localhost:8080/dart_sdk.js:33724:33)
at handleError (http://localhost:8080/dart_sdk.js:34281:51)
at Function._propagateToListeners (http://localhost:8080/dart_sdk.js:34307:17)
at _Future.new.[_completeError] (http://localhost:8080/dart_sdk.js:34157:23)
at async._AsyncCallbackEntry.new.callback (http://localhost:8080/dart_sdk.js:34193:31)
at Object._microtaskLoop (http://localhost:8080/dart_sdk.js:38778:13)
at _startMicrotaskLoop (http://localhost:8080/dart_sdk.js:38784:13)
at http://localhost:8080/dart_sdk.js:34519:9

どうかご教授の程よろしくお願いします。

Answer 1

レスポンスが帰ってこない原因としては

• onCallのcallbackの中でPromiseを返せていない
• http.getの処理をawaitして待たないため、関数が即座に終了してしまい、正しい処理が行われない
• これらの例外が処理されていない

ため、エラーコード500, Internal Errorが発生しているのだと思います。

httpsよりは、axiosを使ったほうがGETリクエストを処理しやすく、async/awaitでの記述を活かすことができると思います。
以下は書き換えた場合の参考のコードになります。動作確認までは完全にできていませんが、http.getをawait axios.get()に書き換え、エラーが発生した場合はキャッチし、functions.HttpsErrorを呼び出し元に返却するようにすると、関数として正しく動作するようになると思います

HttpsErrorについては以下のURLで詳細を確認できます。

• https://firebase.google.com/docs/functions/callable?hl=ja#handle_errors
• https://firebase.google.com/docs/reference/functions/providers_https_?hl=ja#functionserrorcode

const axios = require('axios');
const url = "https://qiita.com/api/v2/items";
const functions = require("firebase-functions");

exports.postalCode = functions.https.onCall(async (data, context) => {
  try {
    const URL = 'https://zipcloud.ibsnet.co.jp/api/search?zipcode=100-0002';
    const res = await axios.get(url);
    return res.data // ★要調整
  } catch (error) {
    throw new functions.HttpsError(...); // ★ 適切なErrorを返す
  }
});