Как можно обернуть запрос graphql в транзакцию pg-обещания

PG-Promise предоставляет красивую безопасную оболочку транзакций

db.tx(t => {
    // Here you can use t to run any queries
    // in a single transaction, on a single connection.
})

Apollo GraphQL Express предоставляет промежуточное программное обеспечение Express, которое обрабатывает запросы GraphQL. Это зависит от набора предопределенных «преобразователей», которые разрешают различные части запроса. Эти преобразователи вызываются из библиотеки, и их результаты объединяются для формирования ответа.

Я хотел бы иметь возможность обернуть запрос GraphQL, который извлекает несколько фрагментов данных или выполняет несколько операций (мутаций) с базой данных, в транзакцию pg-prom, чтобы обеспечить базовую целостность транзакции. Для меня нет очевидного способа сделать это.

Лучшая идея, которую я придумал, - это создать собственное промежуточное ПО для запуска до GraphQL, которое добавляет новую задачу транзакции к объекту запроса:

const bindTx = (req, res, next) => {
    db.tx(async (t) => {
        req = Object.assign(req, {getTransaction: () => t})
        await next()
    })
}

Я считаю, что это промежуточное программное обеспечение будет обеспечивать выполнение следующего промежуточного программного обеспечения внутри транзакции. Я помещаю это в цепочку Express перед GraphQL:

app.use('/graphql', bodyParser.json(), bindTx, graphql)

Затем моя установка graphql берет транзакцию, добавленную к запросу bindTx, и передает ее резолверам через context:

const graphql = graphqlExpress((req) => {
  const t = req.getTransaction()

  return {
    schema: makeExecutableSchema({
      typeDefs,
      resolvers
    }),
    context: {t}
  }
}

Наконец, решатель может выглядеть так:

getSomethingById(_, {somethingId}, context) {
  context.t.one(
    'select * from something where id = ${somethingId}',
    {somethingId}
  )
}

Поскольку я понимаю, что GraphQL запускает преобразователи последовательно, и они могут возвращать обещание, которое должно быть выполнено до запуска следующего преобразователя, я подумал, что это сработает.

Похоже, это приводит к состоянию гонки, при котором в большинстве случаев возникает ошибка Unhandled rejection Error: Querying against a released or lost connection.. Я считаю, что это означает, что транзакция уже была закрыта, когда преобразователи работали и пытались выполнить запрос.

Я совершенно не привязан к этому подходу, на самом деле он кажется чрезмерно сложным, но я ищу способ заставить мое разрешение GraphQL работать внутри транзакции. Хотя в настоящее время я использую Express, Apollo и PG-Promise, это не требования, если другие библиотеки могут решить проблему.

Любые идеи?