nodejs generator async callback - slack unity cloud build

Question

Я работал над интеграцией облачных вычислений на основе единой интеграции для слабого канала нашей команды. И застрял с надлежащим обратным вызовом. Похоже, вернуть значение null до завершения задачи asyc, поэтому нужна некоторая помощь в создании надлежащего асинхронного обратного вызова. Я включил скрипт и результат console.log.

var request = require('request'); 
 
var config = require('../../config.js'); 
 
var slackManager = require('../slack/slackmanager.js'); 
 

 
module.exports = { 
 
    AlertSlack: function (payload) { 
 
     var getLink = GetLink(payload); 
 
     console.log(getLink.next()); 
 
     slackManager.alertSlack(getLink.next().value); 
 
    } 
 
} 
 

 
function* GetLink(payload) { 
 
    try { 
 
     var shareEndPointURL = config.unity.apibaseurl + payload.links.api_self.href + "/share"; 
 
     var shareID = yield HttpRequestHandler(shareEndPointURL, 'GET'); 
 
     
 
     //space to yield more httpRequest 
 
     //space to yield more httpRequest 
 
     //space to yield more httpRequest 
 
     
 
     return " some final data "; 
 
    } catch (e) { 
 
     console.log("Exception : " + e); 
 
     return e; 
 
    } 
 
} 
 

 
function HttpRequestHandler(endpointURL, httpMethod) { 
 
    var options = { 
 
     url: endpointURL, 
 
     method: httpMethod, 
 
     headers: config.unity.unityAuthHeaders 
 
    } 
 
    request(options, function (err, resp, body) { 
 
     console.log(body); 
 
     return body; 
 
    }); 
 
}

И вот лог консоли

{ value: undefined, done: false } 
 
<-----recived call in slackmanager.js with ### some final data ###-----> 
 
{"shareid":"dfgdfgszdffzc"}

Answer 1

я, наконец, нашел решение, я пересмотрел логику и разработал простые обработчики событий.

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

Вот решение, с которым я столкнулся. Гораздо проще и чище, чем в старой версии.

var request = require('request'); 
 
var config = require('../../config.js'); 
 
var slackManager = require('../slack/slackmanager.js'); 
 

 
module.exports = { 
 
    AlertSlack: function (payload) { 
 
     var shareEndPointURL = config.unity.apibaseurl + payload.links.api_self.href + "/share";  
 
     HttpRequestHandler(shareEndPointURL, "GET", HandleShareID); 
 
    } 
 
} 
 

 
function HttpRequestHandler(endpointURL, httpMethod, handler) { 
 
    var options = { 
 
     url: endpointURL, 
 
     method: httpMethod, 
 
     headers: config.unity.unityAuthHeaders 
 
    } 
 
    request(options, function(error, response, body) { 
 
     handler(JSON.parse(body)); 
 
    }); 
 
} 
 

 
function HandleShareID(result){ 
 
    var downloadURL = config.unity.downloadEndPointBase + result.shareid; 
 
    HttpRequestHandler(downloadURL, 'GET', HandleDownLoadedData); 
 
} 
 

 
function HandleDownLoadedData(result) { 
 
    slackManager.alertSlack(result); 
 
}