получение неопределенного от asyn c в узле машинописи - PullRequest
Новая
       21

получение неопределенного от asyn c в узле машинописи

0 голосов
/ 06 февраля 2020

Вариант использования: Я пытаюсь вставить запись в amazon QLDB, используя Node и машинопись. Я могу успешно вставить запись / документ, и он возвращает мне documentID в ответ.

есть 2 контроллера: EntityController и CommonController -EntityController расширяет CommonController -EntityController имеет код для получения объекта req, преобразующего его в объект модели, и вызывающую функцию insert (), которая была расширена из CommonController.

проблема Я пытаюсь распространить этот documentID на все путь к моему вызову API, но почему-то я получаю неопределенный в EntityController. тогда как я могу напечатать documentID в CommonController.

Я не уверен, почему я получаю неопределенное значение, когда я четко возвращаю значение. 

const CommonController = require("../template/controller");
import { Request, Response } from 'express';
const tableName:string = "entities";
const EntityModel = require("./model")

class EntityController extends CommonController {
    async insertEntitiy(req:Request,res:Response) {
    async insertEntitiy(req:any,res:any) {
        console.log(req);
        console.log("===========");
        console.log(req.body);
        let entity = new EntityModel();
        entity.balance = req.body.balance;
        entity.firstName = req.body.firstName;
        entity.lastName = req.body.lastName;
        entity.email = req.body.email;
        try {
            let documentIds = await this.insert(tableName,entity);
            console.log("--------- inside insertEntity fiunction()---------");
            console.log(documentIds);
            console.log("------------------");
            res.status(200).send(documentIds[0]);
        } catch (error) {
            console.error(`error in creating Entity: ${error}`);
            res.status(500).send({ errMsg: `error in creating Entity: ${error}` });
        }
    } 
}

module.exports = new EntityController();




import { createQldbWriter, QldbSession, QldbWriter, Result, TransactionExecutor } from "amazon-qldb-driver-nodejs";
import { Reader } from "ion-js";
import { error, log } from "../qldb/LogUtil";
import { getFieldValue, writeValueAsIon } from "../qldb/Util";
import { closeQldbSession, createQldbSession } from "../qldb/ConnectToLedger";

module.exports = class Conroller {
  async insert(tablename:string, object:any): Promise<Array<string>> {
    let session: QldbSession;
    let result:Array<string>;
    try {
        session = await createQldbSession();
        await session.executeLambda(async (txn) => {
            result =  await this.insertDocument(txn,tablename,object);
            console.log("---------result inside insert fiunction()---------");
            console.log(result);
            console.log("------------------");
            return (Promise.resolve(result));
          })
    } catch (e) {
        error(`Unable to insert documents: ${e}`);
        return(["Error"]);
    } finally {
        closeQldbSession(session);
    }
  }

  /**
  * Insert the given list of documents into a table in a single transaction.
  * @param txn The {@linkcode TransactionExecutor} for lambda execute.
  * @param tableName Name of the table to insert documents into.
  * @param documents List of documents to insert.
  * @returns Promise which fulfills with a {@linkcode Result} object.
  */
  async  insertDocument(
    txn: TransactionExecutor,
    tableName: string,
    documents: object
  ): Promise<Array<string>> {
    const statement: string = `INSERT INTO ${tableName} ?`;
    const documentsWriter: QldbWriter = createQldbWriter();
    let documentIds: Array<string> = [];
    writeValueAsIon(documents, documentsWriter);
    let result: Result = await txn.executeInline(statement, [documentsWriter]);
    const listOfDocumentIds: Reader[] = result.getResultList();
    listOfDocumentIds.forEach((reader: Reader, i: number) => {
      documentIds.push(getFieldValue(reader, ["documentId"]));   
    });
    console.log("---------documentIds---------");
    console.log(documentIds);
    console.log("------------------");
    return (documentIds);
  }
}

выход: - ------- documentIds ---------

['4o5UZjMqEdgENqbP9l7Uhz']

--------- результат внутри функции вставки () - --------

['4o5UZjMqEdgENqbP9l7Uhz']

--------- inside insertEntity fiunction () ---------

undefined

1 Ответ

1 голос
/ 06 февраля 2020

Как указал @ daniel-w-strimpel в комментариях, ваш метод вставки возвращается только в части catch.

Попробуйте: 

insert(tablename:string, object:any): Promise<Array<string>> {
  let session: QldbSession;
  let result: Array<string>;
  try {
    session = await createQldbSession();
    return session.executeLambda(async (txn) => {
      result = await this.insertDocument(txn,tablename,object);
      console.log("---------result inside insert fiunction()---------");
      console.log(result);
      console.log("------------------");
      return result;
    })
  } catch (e) {
    error(`Unable to insert documents: ${e}`);
    return(["Error"]);
  } finally {
    closeQldbSession(session);
  }
}
...

В return session.executeLambda вы вернетесь Обещание.

В return result; вы возвращаете фактическое значение.

Подробнее об обещаниях здесь: https://pouchdb.com/2015/05/18/we-have-a-problem-with-promises.html

...