W jaki sposób uzyskujesz dostęp do treści posta w usłudze Amazon SNS za pomocą Express/Node.js

Question

Jestem w trakcie przebudowywania aplikacji PHP w Node.js na platformie Express.

Jedną z części aplikacji jest URL wywołania zwrotnego, do którego wysłano numer Amazon SNS notification.

Ciało POST z SNS jest obecnie czytać w następujący sposób w PHP (które działa):

$notification = json_decode(file_get_contents('php://input')); 

Ekspresowe Próbowałem następujące:

app.post('/notification/url', function(req, res) { 
    console.log(req.body); 
}); 

Jednak obserwując konsolę , rejestruje się tylko następujące informacje po utworzeniu wpisu:

{} 

Aby powtórzyć zadanie ion: W jaki sposób uzyskujesz dostęp do treści pocztowej w usłudze Amazon SNS za pomocą Express/Node.js

Answer 1

Innym rozwiązaniem byłoby ustalenie Content-Type nagłówek.

Oto kod middleware, aby to zrobić:

exports.overrideContentType = function(){ 
    return function(req, res, next) { 
    if (req.headers['x-amz-sns-message-type']) { 
     req.headers['content-type'] = 'application/json;charset=UTF-8'; 
    } 
    next(); 
    }; 
} 

Zakłada znajduje się plik o nazwie util.js znajdujące się w katalogu projektu z korzenia:

util = require('./util'); 

w twojej aplikacja.js i powoływać w tym:

app.use(util.overrideContentType()); 

PRZED

app.use(express.bodyParser()); 

w app.js pliku. Pozwala bodyParser() do analizowania organizmowi prawidłowo ...

mniej inwazyjne, a następnie można uzyskać dostęp req.body normalnie.

Answer 2

Spójrz na AWS Node.js SDK - może uzyskać dostęp do wszystkich punktów końcowych usługi AWS.

var sns = new AWS.SNS(); 

    // subscribe 
    sns.subscribe({topic: "topic", Protocol: "https"}, function (err, data) { 
     if (err) { 
     console.log(err); // an error occurred 
     } else { 
     console.log(data); // successful response - the body should be in the data 
    } 
    }); 


    // publish example 
    sns.publish({topic: "topic", message: "my message"}, function (err, data) { 
     if (err) { 
     console.log(err); // an error occurred 
     } else { 
     console.log(data); // successful response - the body should be in the data 
    } 
    }); 

EDIT: Problem polega na tym, że standard parser organizm nie radzi sobie zwykły/tekstu, który jest co SNS wysyła jako typ zawartości. Oto kod do wyodrębnienia surowego ciała. Umieścić go przed parsera ciała:

app.use(function(req, res, next) { 
    var d= ''; 
    req.setEncoding('utf8'); 
    req.on('d', function(chunk) { 
     d+= chunk; 
    }); 
    req.on('end', function() { 
     req.rawBody = d; 
     next(); 
    }); 
}); 

Następnie można użyć:

JSON.stringify(req.rawBody)); 

ciągu trasy stworzyć JavaScript Object i działają na SNS zakładać odpowiednio.

Można również zmodyfikować analizator treści, aby obsługiwał tekst/zwykły, ale nie jest to świetny pomysł na modyfikowanie oprogramowania pośredniego. Po prostu użyj powyższego kodu.

Answer 3

ta opiera się na AlexGad za answer.Particularly ten komentarz:

Standardowa express parser zajmie tylko application/json, application/x-www-form-zakodowane multipart/form-data. Dodałem kod powyżej, aby umieścić go przed analizatorem treści.

app.post('/notification/url', function(req, res) { 
    var bodyarr = [] 
    req.on('data', function(chunk){ 
     bodyarr.push(chunk); 
    }) 
    req.on('end', function(){ 
     console.log(bodyarr.join('')) 
    }) 
})