获取 firebase 管理文件上传进度

如何解决获取 firebase 管理文件上传进度

我正在尝试使用管理 sdk 获取将 1 分钟视频上传到 firebase 存储桶存储的进度。我已经看到很多关于使用 firebase.storage().ref.child ..... 但我无法使用 admin sdk 来做到这一点，因为它们没有相同的功能。这是我的文件上传：

exports.uploadMedia = (req,res) => {
    const BusBoy = require('busboy');
    const path = require('path');
    const os = require('os');
    const fs = require('fs');

    const busboy = new BusBoy({ headers: req.headers,limits: { files: 1,fileSize: 200000000 } });

    let mediaFileName;
    let mediaToBeUploaded = {};

    busboy.on('file',(fieldname,file,filename,encoding,mimetype) => {

        if(mimetype !== 'image/jpeg' && mimetype !== 'image/png' && mimetype !== 'video/quicktime' && mimetype !== 'video/mp4') {
            console.log(mimetype);
            return res.status(400).json({ error: 'Wrong file type submitted,only .png,.jpeg,.mov,and .mp4 files allowed'})
        }

        // my.image.png
        const imageExtension = filename.split('.')[filename.split('.').length - 1];
        
        //43523451452345231234.png
        mediaFileName = `${Math.round(Math.random()*100000000000)}.${imageExtension}`;
        const filepath = path.join(os.tmpdir(),mediaFileName);
        mediaToBeUploaded = { filepath,mimetype };
        file.pipe(fs.createWriteStream(filepath));

        file.on('limit',function(){
            fs.unlink(filepath,function(){
                return res.json({'Error': 'Max file size is 200 Mb,file size too large'});
            });
        });
    });
    busboy.on('finish',() => {
        admin
        .storage()
        .bucket()
        .upload(mediaToBeUploaded.filepath,{
            resumable: false,metadata: {
                metadata: {
                    contentType: mediaToBeUploaded.mimetype
                }
            }
        })
        .then(() => {
            const meadiaUrl = `https://firebasestorage.googleapis.com/v0/b/${config.storageBucket}/o/${mediaFileName}?alt=media`;
            return res.json({mediaUrl: meadiaUrl});
        })
        .catch((err) => {
            console.error(err);
            return res.json({'Error': 'Error uploading media'});
        });
    });
    req.pipe(busboy);
}

这现在可以正常工作，但唯一的问题是用户看不到他们上传的 1 或 2 分钟视频的位置。目前，它只是一个活动指示器，用户只是在没有任何通知的情况下等待。如果有任何帮助，我会在前端使用 react native。非常感谢您的帮助！

解决方法

我能够在客户端更轻松地实施...但它与图像和视频上传进度完美配合。在后端，我使用的是 admin sdk，但前端我最初使用的是 firebase sdk。

        this.uploadingMedia = true;
        const imageExtension = this.mediaFile.split('.')[this.mediaFile.split('.').length - 1];
        const mediaFileName = `${Math.round(Math.random()*100000000000)}.${imageExtension}`;
        const response = await fetch(this.mediaFile);
        const blob = await response.blob();
        const storageRef = storage.ref(`${mediaFileName}`).put(blob);
        storageRef.on(`state_changed`,snapshot=>{
          this.uploadProgress = (snapshot.bytesTransferred/snapshot.totalBytes);
        },error=>{
          this.error = error.message;
          this.submitting = false;
          this.uploadingMedia = false;
          return;
        },async () => {
          storageRef.snapshot.ref.getDownloadURL().then(async (url)=>{
            imageUrl = [];
            videoUrl = [url];
            this.uploadingMedia = false;
            this.submitPost(imageUrl,videoUrl);
          });
        });

,

export const uploadFile = (
  folderPath,fileName,file,generateDownloadURL = true,updateInformationUploadProgress
) => {
  return new Promise((resolve,reject) => {
    try {
      const storageRef = firebaseApp.storage().ref(`${folderPath}/${fileName}`)
      const uploadTask = storageRef.put(file)

      uploadTask.on(
        'state_changed',snapshot => {
          if (updateInformationUploadProgress) {
            const progress =
              (snapshot.bytesTransferred / snapshot.totalBytes) * 100
            updateInformationUploadProgress({
              name: fileName,progress: progress,})
          }
        },error => {
          console.log('upload error: ',error)
          reject(error)
        },() => {
          if (generateDownloadURL) {
            uploadTask.snapshot.ref
              .getDownloadURL()
              .then(url => {
                resolve(url)
              })
              .catch(error => {
                console.log('url error: ',error.message)
                reject(error)
              })
          } else {
            resolve(uploadTask.snapshot.metadata.fullPath)
          }
        }
      )
    } catch (error) {
      reject(error)
    }
  })
}