Как вернуть ответ после завершения ввода-вывода базы данных в Коа-роутере?

Question

С помощью Koa а также Koa-routerЯ пишу функцию, чтобы принять POST на /videos и затем сохраните видео в HDFS(распределенная база данных). После завершения процесса сохранения ответ должен быть отправлен клиенту с сообщением о завершении загрузки. Однако ответ возвращается до ввода-вывода. Я новичок в JavaScript, пожалуйста, помогите.

app.js:

/**
 * Module dependencies.
 */

const logger = require('koa-logger');
const serve = require('koa-static');
const koaBody = require('koa-body');
const Koa = require('koa');
const app = new Koa();
const os = require('os');
const path = require('path');
var Router = require('koa-router');

var router = new Router();
// log requests

app.use(logger());

app.use(koaBody({ multipart: true }));

app.use(serve(path.join(__dirname, '/public')));



app
  .use(router.routes())
  .use(router.allowedMethods());

// listen

app.listen(3000);
console.log('listening on port 3000');



module.exports ={
  app:app,
router:router
} 

require('./services/service_upload.js')

service_upload.js

const router = require('../app.js').router

const upload = require('../business/business_uploadVideo.js')
 function service_upload() {
    router.post('/videos', function (ctx, next) {
        upload.upload(ctx, function () {
        })


        ctx.body='upload finish'
        console.log("redirect/")

    });
}


service_upload()

Answer 1

Если вы используете последние версии Koa и koa-router, вы можете использовать async / await с Promises следующим образом:

    router.post('/videos', async function (ctx, next) { // Declare function as async
      await new Promise((resolve, reject) => { // Create new Promise, await will wait until it resolves
        upload.upload(ctx, function (error) {
          if (error) { // Probably you should do error handling
            reject(error);
            return;
          }

          resolve();
        })
      });

      ctx.body='upload finish'
      console.log("redirect/")
    });

Подробнее об обещаниях: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise

Подробнее об async / await: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Operators/await