現在Clound Functionsを利用し、firestoreに格納されている内容からYouTube APIを叩き、取得してきた情報をfirestoreに格納する機能を作成しています。
localでの動作確認は完了しており、あとはdeployするだけなのですが、deploy中にエラーPromises must be handled appropriately
が発生しdeployができません。forEachはコールバックが無視されてしまうため、Promiseをちゃんと処理出来ないというのは調べて分かったのですが、そこからどうPromiseを処理してあげれば良いのかが分かりません。
typescriptのバージョンは3.8.3を使用しています。
以下ソースコードになります。
typescript
1import * as functions from 'firebase-functions'; 2import * as admin from 'firebase-admin'; 3import axios from 'axios'; 4 5 6export const getCharactor = functions.https.onRequest(async(request, response) => { 7 try{ 8 const snapshot = admin.firestore().collection('/Charactor').get() 9 const channelIdList = await fetchFirestoreCollectionBySnapshotList(snapshot) 10 11 channelIdList.forEach((channelId: string) => { 12 //YouTube APIのURLを作成して変数に格納する。 13 const upcomingVideoUrl = createGetUpcomingVideoUrl(channelId) 14 //URLを利用して情報を取得する 15 axios 16 .get(upcomingVideoUrl) 17 .then(responseUpcomingVideoList => { 18 responseUpcomingVideoList.data.items.forEach( (video: any) => { 19 const videoId = video.id.videoId 20 //YouTube APIのURLを作成して変数に格納する。 21 const getUpcomingVideoInfoUrl = createGetUpcomingVideoInfoUrl(videoId) 22 //URLを利用して情報を取得する 23 axios 24 .get(getUpcomingVideoInfoUrl) 25 .then(responseUpcomingVideoInfoList => { 26 responseUpcomingVideoInfoList.data.items.forEach((videoInfo: any) => { 27 const datetimeNum = videoInfo.liveStreamingDetails.scheduledStartTime; 28 const millisecondNum = Date.parse(datetimeNum); 29 const scheduledStartDate = new Date(millisecondNum) 30 31 const data: any = { 32 //firestoreに格納するデータを作成する 33 } 34 admin.firestore().doc(`/Schedule/${videoInfo.id}`).set(data) 35 }) 36 }) 37 .catch(() => { 38 console.log('ビデオ情報の取得に失敗しました。'); 39 }); 40 }) 41 }) 42 .catch(() => { 43 console.log('公開予定のビデオ一覧の取得に失敗しました。'); 44 }); 45 }) 46 response.send("データのinsertが完了しました。") 47 }catch(error){ 48 response.send(error) 49 } 50}); 51 52const fetchFirestoreCollectionBySnapshotList = async (firestoreSnapshot: any) => { 53 return firestoreSnapshot 54 .then((snapshot: any) => { 55 const channelIdList: string[] = []; 56 snapshot.forEach((doc: any) => { 57 channelIdList.push(doc.id) 58 }) 59 return channelIdList 60 }) 61 .catch( (e: any) => { 62 return Promise.reject(e) 63 }) 64}
あなたの回答
tips
プレビュー