UnhandledPromiseRejectionWarning: TypeError：_base64Stream2.default.encode不是一个函数

Question

我试图在本文的帮助下制作这个简单的api，.The阅读本文的主要目的是学习react本机，但它从nodejs中的服务器开始，.I无法使它正确运行。以下是链接文章的链接

以下是server.js文件的代码

import express from 'express';
import http from 'http';
import giphyapi from 'giphy-api';
import base64 from 'base64-stream';
// Initialize http server
const app = express();

// Register /gif endpoint that returns base64 encoded gif
app.get('/gif', async (req, res) => {
  res.json({
    gif: await fetchGif(),
  });
});

// Launch the server on port 3000
const server = app.listen(3000, () => {
  const { address, port } = server.address();
  console.log(`Listening at http://${address}:${port}`);
});
// Fetch random GIF url with Giphy API, download and Base64 encode it
export const fetchGif = async () => {
    const item = await giphyapi().random('cat');
    return await encode(await download(item.data.image_url));
  };

  // File download helper
const download = async (url) => {
    return new Promise((resolve, reject) => {
      let req = http.get(url.replace('https', 'http'));
      req.on('response', res => {
        resolve(res);
      });
      req.on('error', err => {
        reject(err);
      });
    });
  };
  // Base64 encode helper
const encode = async (content) => {
    let output = 'data:image/gif;base64,';
    const stream = content.pipe(base64.encode());
    return new Promise((resolve, reject) => {
      stream.on('readable', () => {
        let read = stream.read();
        if (read) {
          output += read.toString();
        }
        else {
          resolve(output);
        }
      });
      stream.on('error', (err) => {
        reject(err);
      });
    });
  };

Answer 1

错误的发生是因为第三方库“have 64流”没有“编码”函数，它可能存在于以前的版本中。

要解决这个问题，您需要更改代码的一些行，以便您的服务器看起来像下面的代码。

const express = require('express'); // instead of "import express from 'express';"
const http = require('http'); // instead of "import http from 'http';"
const giphyapi = require('giphy-api'); // instead of "import http from 'http';"
const { Base64Encode } = require('base64-stream'); // instead of "import base64 from 'base64-stream';"
// Initialize http server
const app = express();

// Register /gif endpoint that returns base64 encoded gif
app.get('/gif', async (req, res) => {
  try {
    const gif = await fetchGif();
    res.json({ gif });
  } catch (error) {
    res.status(500).send({ error });
  }
});

// Base64 encode helper
const encode = (content) => {
  let output = 'data:image/gif;base64,';
  const stream = content.pipe(new Base64Encode()); // instead of "const stream = content.pipe(base64.encode());"
  return new Promise((resolve, reject) => {
    stream.on('readable', () => {
      let read = stream.read();
      if (read) {
        output += read.toString();
      }
      else {
        resolve(output);
      }
    });
    stream.on('error', (err) => {
      reject(err);
    });
  });
};

// Launch the server on port 3000
const server = app.listen(3000, () => {
  const { address, port } = server.address();
  console.log(`Listening at http://${address}:${port}`);
});

// Fetch random GIF url with Giphy API, download and Base64 encode it
const fetchGif = async () => {
  try {
    const item = await giphyapi().random('cat');
    const image = await download(item.data.image_url);
    return await encode(image);
  } catch (error) {
    console.log('fetchGif', error);
  }
};

// File download helper
const download = (url) => {
  return new Promise((resolve, reject) => {
    let req = http.get(url.replace('https', 'http'));
    req.on('response', res => {
      resolve(res);
    });
    req.on('error', err => {
      reject(err);
    });
  });
};

Answer 2

base64-stream没有任何叫做encode(..)的函数。

有两个类Base64Encode，Base64Decode，用于流。