Вход с помощью Amazon для Alexa Skills (LWA) - PullRequest
0 голосов
/ 06 мая 2018

Кто-нибудь получил комплексное решение для LWA и AWS Lambda? Когда я думаю, что понимаю протокол запроса / ответа, я больше запутываюсь, когда пытаюсь заставить его работать.

Ответы [ 2 ]

0 голосов
/ 18 июля 2018

В поисках решения этого вопроса я наткнулся на этот вопрос. Ответ NHLIVES не для меня, так как я использую node.js. Следующий код неполон и изменен из примера Amazon, но не должен содержать ошибок. Это, безусловно, может быть улучшено. Но это сработало для меня, и я надеюсь, что это будет полезно для следующего человека в будущем.

Еще одна вещь, модуль 'request' недоступен в Lambda, поэтому вы должны предоставить его. Просто создайте zip-файл с вашим index.js на верхнем уровне, каталогом node_modules, содержащим каталоги 'request' и 'safe-buffer' (скопированы из установки вашего локального узла) и загрузите zip-файл в Amazon Lambda (в AWS Lambda: «Тип ввода кода»: «Загрузить ZIP-файл»).

var AWS = require('aws-sdk');
var requestlib = require('request');

exports.handler = function (request, context) {

    var whoami = async function (request) {
        var amznProfileURL = 'https://api.amazon.com/user/profile?access_token=';

        if (request.directive.header.namespace === 'Alexa.Discovery' && request.directive.header.name === 'Discover') {
            amznProfileURL += request.directive.payload.scope.token;
        } else {
            amznProfileURL += request.directive.endpoint.scope.token;
        }

        await new Promise(function(resolve, reject) {
            log("LWArequest: ", "amznProfileURL ", amznProfileURL);
            requestlib(amznProfileURL, function(error, response, body) {
                if (response.statusCode == 200) {
                    var profile = JSON.parse(body);
                    log("LWArequest: ", "user_id ", body);
                    resolve();
                } else {
                    log("LWArequest: ", "error ", "can't connect to Amazon Profile Service");
                    reject();
                }
            });
        }
        );
    }

    whoami(request);
    if (request.directive.header.namespace === 'Alexa.Discovery' && request.directive.header.name === 'Discover') {
        log("DEBUG:", "Discover request",  JSON.stringify(request));
        handleDiscovery(request, context, "");
    }

    function log(message, message1, message2) {
        console.log(message + message1 + message2);
    }

}

Вы должны увидеть что-то подобное в вашем файле журнала CloudWatch:

2018-07-17T23:06:28.108Z    08d795d3-8a16-11e8-b912-0f46b6510aa8    
  LWArequest: amznProfileURL https://api.amazon.com/user/profile?access_token=Atza|IwEBIP5ozi...

2018-07-17T23:06:28.409Z    08d795d3-8a16-11e8-b912-0f46b6510aa8    
  LWArequest: user_id
  {
    "user_id": "amzn1.account.A..........................A"
  }

Надеюсь, это поможет.

0 голосов
/ 11 июня 2018

URL-адрес: https://api.amazon.com/user/profile.. Токен OAuth 2.0 необходимо передавать одним из трех способов: в качестве параметра в URL-адресе, в качестве токена-носителя в заголовке или в виде XML. Вот ссылка: https://login.amazon.com/website. Токен очень длинный и для каждого Amazon должен быть закодирован. Это может сделать его слишком длинным для URL. Я использовал подход заголовка.

    public static WebClient client = new WebClient();
    public static JObject GetAmznProfile(string token)
    {
        string amznProfileHost = "https://api.amazon.com/user/profile";
        try
        {
            client.Headers.Remove("user-agent");
            client.Headers.Remove("Authorization");
            client.Headers.Add("Authorization: bearer " + token);
        }
        catch { Logger(Constants.SEVERE, "Exception caught trying to modify http headers in \"GetAmznProfile\""); }
        finally { }

        string body = GetUrl(amznProfileHost);
        if (body != null)
        {
            JObject json = JObject.Parse(body);
            return json;
        }
        else
        {
            string error = @"{'user_id':'error','name':'error','email':'error'}";
            JObject json = JObject.Parse(error);
            return json;
        }
    }

    public static string GetUrl(string url)
    {
        Logger(Constants.DEBUG, "In 'GetUrl' the URL is " + url);
        try
        {
            Stream data = client.OpenRead(url);
            StreamReader reader = new StreamReader(data);
            string body = reader.ReadToEnd();
            data.Close();
            reader.Close();

            return body;
        }
        catch (WebException e) { Logger(Constants.INFO, e.ToString() + " exception caught"); return null; }
    }
...