fix: error log

package.json

@@ -134,7 +134,7 @@
     "pre-commit": "1.2.2",
     "proxyquire": "2.1.3",
     "replace": "^1.2.2",
-    "sinon": "17.0.1",
+    "sinon": "17.0.2",
     "standard": "17.1.0",
     "standard-version": "9.5.0",
     "swagmock": "1.0.0"

src/handlers/QuotingHandler.js

@@ -68,7 +68,7 @@ class QuotingHandler {
       await model.handleQuoteRequest(headers, payload, span, this.cache)
       this.logger.debug('handlePostQuotes is done')
     } catch (err) {
-      this.logger.error(`error in handlePostQuotes: ${err?.stack}`)
+      this.logger.error(`error in handlePostQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopError = reformatFSPIOPError(err)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, payload.quoteId, fspiopError, headers, span)
@@ -90,7 +90,7 @@ class QuotingHandler {
         : await model.handleQuoteUpdate(headers, quoteId, payload, span)
       this.logger.isDebugEnabled && this.logger.debug(`handlePutQuotes is done: ${JSON.stringify(result)}`)
     } catch (err) {
-      this.logger.error(`error in handlePutQuotes: ${err?.stack}`)
+      this.logger.error(`error in handlePutQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, quoteId, err, headers, span)
     }
@@ -108,7 +108,7 @@ class QuotingHandler {
       await model.handleQuoteGet(headers, quoteId, span)
       this.logger.debug('handleGetQuotes is done')
     } catch (err) {
-      this.logger.error(`error in handleGetQuotes: ${err?.stack}`)
+      this.logger.error(`error in handleGetQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, quoteId, err, headers, span)
     }
@@ -126,7 +126,7 @@ class QuotingHandler {
       await model.handleBulkQuoteRequest(headers, payload, span)
       this.logger.debug('handlePostBulkQuotes is done')
     } catch (err) {
-      this.logger.error(`error in handlePostBulkQuotes: ${err?.stack}`)
+      this.logger.error(`error in handlePostBulkQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopError = reformatFSPIOPError(err)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, payload.bulkQuoteId, fspiopError, headers, span)
@@ -148,7 +148,7 @@ class QuotingHandler {
         : await model.handleBulkQuoteUpdate(headers, bulkQuoteId, payload, span)
       this.logger.isDebugEnabled && this.logger.debug(`handlePutBulkQuotes is done: ${JSON.stringify(result)}`)
     } catch (err) {
-      this.logger.error(`error in handlePutBulkQuotes: ${err?.stack}`)
+      this.logger.error(`error in handlePutBulkQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, bulkQuoteId, err, headers, span)
     }
@@ -166,7 +166,7 @@ class QuotingHandler {
       await model.handleBulkQuoteGet(headers, bulkQuoteId, span)
       this.logger.debug('handleGetBulkQuotes is done')
     } catch (err) {
-      this.logger.error(`error in handleGetBulkQuotes: ${err?.stack}`)
+      this.logger.error(`error in handleGetBulkQuotes partition:${requestData.partition}, offset:${requestData.offset}: ${err?.stack}`)
       const fspiopSource = headers[FSPIOP.SOURCE]
       await model.handleException(fspiopSource, bulkQuoteId, err, headers, span)
     }

src/lib/dto.js

@@ -43,12 +43,14 @@ const messageFromRequestDto = (request, type, action) => {
 }
 
 const requestDataFromMessageDto = (message) => {
-  const { topic, value } = message
+  const { topic, value, offset, partition } = message
 
   return Object.freeze({
     topic,
     requestData: {
       ...value.content,
+      offset,
+      partition,
       payload: decodePayload(value.content?.payload)
       // see messageFromRequestDto for details of "content" field
     }