javascriptでの非同期処理の順序立て方について

前提・実現したいこと

下記のプログラムのメッセージを作成する関数createMessageを動かした後に、結果を出力(this.emit)したいです。
（過去の質問、AlexaでDynamoDBを動かすを簡素化したものです。）
よろしくお願いします。

javascript
1function createMessage(data){
2  // db access
3  params = {...} // table name and key setting. dataの中身も使う
4  dynamoDoc.query(params,function(err,res){
5    let res_message = res.Items[0].message; // ここでメッセージを作成する
6    return res_message; 
7  }
8}
9
10function handlerA(userGaveUp){
11  // 最終的にこれを順序よく動かしたい
12  let message = createMessage(this);
13  console.log(message);  //このままだとundefined
14  this.emit(':tell',message); // (*1)これが正しくemitされてほしい
15}
16
17// これが最初に実行される
18handlerA.call(this,false);
19

試したことと、発生している問題・エラーメッセージ

emitterを用いる、createMessage内でthis.emitするなど幾つかトライしましたが、

上記のlet message = 関数でreturn値にした場合：undefined
emitterを定義してlet message=エミッタ.on()にした場合：[Object Object]
createMessage関数内でthis.emitする場合：thisにemitが未定義です

と返されます。

なお、

let message = "text"では正常にtextが出力されます。
this.emit(':tell',message);をコメントアウトすると、正常にmessageがconsole.logで出力されます。

補足情報（FW/ツールのバージョンなど）

Node.js 6.10

行動規範の内容に同意します

回答1件

ベストアンサー

dynamoDBを利用したことがないので間違っているかもしれませんが、
Promiseを使えばいいのではないでしょうか。

js
1	function createMessage(data){
2		// db access
3		params = {...} // table name and key setting. dataの中身も使う
4		//Promiseで返す
5		return new Promise( function(resolve, reject) {
6			dynamoDoc.query(params,function(err,res){
7				if( err ) reject(err);
8				let res_message = res.Items[0].message; // ここでメッセージを作成する
9				resolve(res_message)
10			}
11		} )
12	  }
13	  
14	  function handlerA(userGaveUp){
15		const self = this;
16		// Promiseでthenでつないでいく
17		createMessage(this).then(function(message){
18			console.log(message);
19			self.emit(':tell', message);
20		});
21	  }
22	  
23	  // これが最初に実行される
24	  handlerA.call(this,false);