/**
 * 返回獲取一份提交的函數(shù)
 * @param {ParamData}  paramData
 * @param {Context}   ctx
 * @param {string}   id
 */
export async function retrieveOne(paramData, ctx, id) {
 const { subModel } = paramData.ce;
 const sub_asgn_id = Number(id);

 // 通過(guò) paramData.user 獲取 user 相關(guān)信息，如 user_id ，
 // 但無(wú)法細(xì)化日志輸出粒度，除非修改 retrieveOneSub 的簽名，
 // 添加 paramData 為其參數(shù)。
 const { user_id } = paramData.user;
 console.log(`${user_id} is trying to retreive one submission.`);
 // 調(diào)用了 retrieveOneSub 函數(shù)。
 const sub = await retrieveOneSub(sub_asgn_id, subModel);
 const submission = sub;
 assign(sub, { sub_asgn_id });
 assign(paramData, { submission, sub });
 return sub;
}

/**
 * 從數(shù)據(jù)庫(kù)獲取一份提交
 * @param {number}   sub_asgn_id
 * @param {SubModel}   model
 */
async function retrieveOneSub(sub_asgn_id, model) {
 const [sub] = await model.findById(sub_asgn_id);
 if (!sub) {
  throw new ME.SoftError(ME.NOT_FOUND, '找不到該提交');
 }
 return sub;
}

const asyncHooks = require("async_hooks");
const { executionAsyncId, triggerAsyncId } = asyncHooks;

console.log(`top level: ${executionAsyncId()} ${triggerAsyncId()}`);

const f = () => {
 console.log(`f: ${executionAsyncId()} ${triggerAsyncId()}`);
};

f();

const g = () => {
 console.log(`setTimeout: ${executionAsyncId()} ${triggerAsyncId()}`);
 setTimeout(() => {
  console.log(`inner setTimeout: ${executionAsyncId()} ${triggerAsyncId()}`);
 }, 0);
};

setTimeout(g, 0);
setTimeout(g, 0);

top level: 1 0
f: 1 0
setTimeout: 7 1    
setTimeout: 9 1    
inner setTimeout: 11 7
inner setTimeout: 13 9

const asyncHooks = require("async_hooks");

// 創(chuàng)建一個(gè) AsyncHooks 實(shí)例。
const hooks = asyncHooks.createHook({
 // 對(duì)象構(gòu)造時(shí)會(huì)觸發(fā) init 事件。
 init: function(asyncId, type, triggerId, resource) {},
 // 在執(zhí)行回調(diào)前會(huì)觸發(fā) before 事件。
 before: function(asyncId) {},
 // 在執(zhí)行回調(diào)后會(huì)觸發(fā) after 事件。
 after: function(asyncId) {},
 // 在銷(xiāo)毀對(duì)象后會(huì)觸發(fā) destroy 事件。
 destroy: function(asyncId) {}
});

// 允許該實(shí)例中對(duì)異步函數(shù)啟用 hooks 。
hooks.enable();

// 關(guān)閉對(duì)異步資源的追蹤。
hooks.disable();

const asyncHooks = require("async_hooks");
const { executionAsyncId } = asyncHooks;

// 保存異步調(diào)用的上下文。
const contexts = {};

const hooks = asyncHooks.createHook({
 // 對(duì)象構(gòu)造時(shí)會(huì)觸發(fā) init 事件。
 init: function(asyncId, type, triggerId, resource) {
  // triggerId 即為當(dāng)前函數(shù)的調(diào)用者的 asyncId 。
  if (contexts[triggerId]) {
   // 設(shè)置當(dāng)前函數(shù)的異步上下文與調(diào)用者的異步上下文一致。
   contexts[asyncId] = contexts[triggerId];
  }
 },
 // 在銷(xiāo)毀對(duì)象后會(huì)觸發(fā) destroy 事件。
 destroy: function(asyncId) {
  if (!contexts[asyncId]) return;
  // 銷(xiāo)毀當(dāng)前異步上下文。
  delete contexts[asyncId];
 }
});

// 關(guān)鍵！允許該實(shí)例中對(duì)異步函數(shù)啟用 hooks 。
hooks.enable();

// 模擬業(yè)務(wù)處理函數(shù)。
function handler(params) {
 // 設(shè)置 context ，可在中間件中完成此操作（如 Logger Middleware）。
 contexts[executionAsyncId()] = params;
 
 // 以下是業(yè)務(wù)邏輯。
 console.log(`handler ${JSON.stringify(params)}`);
 f();
}

function f() {
 setTimeout(() => {
  // 輸出所屬異步過(guò)程的 params 。
  console.log(`setTimeout ${JSON.stringify(contexts[executionAsyncId()])}`);
 });
}

// 模擬兩個(gè)異步過(guò)程（兩個(gè)請(qǐng)求）。
setTimeout(handler, 0, { id: 0 });
setTimeout(handler, 0, { id: 1 });

handler {"id":0}
handler {"id":1}
setTimeout {"id":0}
setTimeout {"id":1}