Асинхронное промежуточное ПО в экспресс-функции с AWS Lambda (TypeError) - PullRequest
Новая
       20

Асинхронное промежуточное ПО в экспресс-функции с AWS Lambda (TypeError)

0 голосов
/ 07 июля 2019

Я хочу использовать функцию async в своем промежуточном программном обеспечении, которая извлекает пользователя из моей функции AWS Lambda.

Вот код: 

const bodyParser = require('body-parser');
const awsServerlessExpressMiddleware = require('aws-serverless-express/middleware');
const AWS = require('aws-sdk');

const asyncHandler = fn => (req, res, next) =>
  Promise.resolve(fn(req, res, next)).catch(next);

const pipe = (...fns) => x => fns.reduce((y, f) => f(y), x);
const tapRoute = f => route => {
  route.use(f);
  return route;
};

const configureCors = route => {
  route.use(function(req, res, next) {
    res.header('Access-Control-Allow-Origin', '*');
    res.header(
      'Access-Control-Allow-Headers',
      'Origin, X-Requested-With, Content-Type, Accept'
    );
    next();
  });
};
const injectUser = route => {
  route.use(async function(req, res, next) {
    try {
      const IDP_REGEX = /.*\/.*,(.*)\/(.*):CognitoSignIn:(.*)/;
      const authProvider =
        req.apiGateway.event.requestContext.identity
          .cognitoAuthenticationProvider;
      const [, , , userId] = authProvider.match(IDP_REGEX);
      console.log(userId);
      console.log('Got user id');

      const cognito = new AWS.CognitoIdentityServiceProvider();
      const listUsersResponse = await cognito
        .listUsers({
          UserPoolId: process.env.AUTH_LAMBDAUSERB2E6BC69_USERPOOLID,
          Filter: `sub = "${userId}"`,
          Limit: 1,
        })
        .promise();
      console.log('ListedUsers');
      const user = listUsersResponse.Users[0];
      req.user = user;
      next();
    } catch (error) {
      console.log(error);
      next(error);
    } finally {
      return route;
    }
  });
};

const applyMiddleware = (route, ...middleware) =>
  pipe(
    tapRoute(bodyParser.json()),
    tapRoute(awsServerlessExpressMiddleware.eventContext()),
    configureCors,
    injectUser,
    ...middleware
  )(route);

module.exports = {
  applyMiddleware,
};

Код выдает ошибку в этой строке: 

route.use(async function(req, res, next) {

А вот и ошибка: 

module initialization error: TypeError
at injectUser (/var/task/middleware.js:25:9)
at fns.reduce (/var/task/middleware.js:8:52)
at Array.reduce (<anonymous>)
at x (/var/task/middleware.js:8:35)
at applyMiddleware (/var/task/middleware.js:63:4)
at Object.<anonymous> (/var/task/app.js:13:1)
at Module._compile (module.js:652:30)
at Object.Module._extensions..js (module.js:663:10)
at Module.load (module.js:565:32)
at tryModuleLoad (module.js:505:12)

Как правило, позже я использую это промежуточное программное обеспечение следующим образом: 

const express = require('express');
const applyMiddleware = require('./middleware').applyMiddleware;

const app = express();
applyMiddleware(app);

app.get( // ... rest of the code

Но иногда я также внедряю промежуточное ПО для каждого маршрута.

Что происходит? Почему эта ошибка TypeError выбрасывается? Есть ли способ, которым я могу использовать асинхронное промежуточное программное обеспечение, которое внедряет пользователя в мою трубу, чтобы я мог уменьшить свой шаблон? Если я закомментирую injectUser, промежуточное программное обеспечение работает ...

Edit:

Использование app.use(async function // ... работает, но я хотел бы иметь функцию асинхронности в моем pipe aka. в applyMiddleware.

1 Ответ

1 голос
/ 10 июля 2019

Проблема в вашей configureCors функции. Там вы ничего не возвращаете, поэтому цепочка обрывается и injectUser получает переменную undefined route. Это должно быть обновлено как ниже 

const configureCors = route => {
  route.use(function(req, res, next) {
    res.header('Access-Control-Allow-Origin', '*');
    res.header(
      'Access-Control-Allow-Headers',
      'Origin, X-Requested-With, Content-Type, Accept'
    );
    next();

  });
  return route;
};
...