Skip to content

Commit

Permalink
edit ci and add seeds and add enpoints
Browse files Browse the repository at this point in the history
* Edited CI to build PISP docker image.

* Addressed comments.

Updated ci to python 3. (mojaloop#744)

Feature/335 thirdparty callbacks (mojaloop#748)

* Add new endpoint: `THIRDPARTY_CALLBACK_URL_TRX_REQ_POST`

* cleanup

* skip devDependencies in audit:check

Update pisp/master (mojaloop#755)

* fix for python error in CI (mojaloop#733)

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Ensure 'timeout-reserved' notification action passes through and not converted to 'abort' action (mojaloop#736)

* Update CS shared (mojaloop#737)

* Feature/1332 enable on-us transfers (mojaloop#738)

* Added ENABLE_ON_US_TRANSFERS

* Bumped up the version

* Feature/otc 525 implement get transaction object by transfer (mojaloop#735)

* OTC-525 Implement GET transaction Object by transferId
Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id
- Post ledger entry

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* OTC-525 Implement GET transaction Object by transferId
Bumput up versions

* OTC-525 Implement GET transaction Object by transferId
Resolved dependency updates

* OTC-525 Implement GET transaction Object by transferId

* OTC-525 Implement GET transaction Object by transferId

Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* changed docker dependency in circle CI image scan from python-dev to python3-dev (mojaloop#741)

* Updated python in some other places in circle CI (mojaloop#742)

* Fix the image scan step in circle CI

* Resolved audit checks

* Feature/#1335 aborted on put (mojaloop#740)

* added error log if action REJECT comes into fulfil handler

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* Bugfix/deadlock on adjust limits (mojaloop#745)

* added unique index on participantLimit and logging

* added unique index on participantLimit and logging

* resolve audit issues

* fixed coverage tests

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Updated dependencies and product version for issue: mojaloop/project#1378 (mojaloop#747)

* Update error message  (mojaloop#749)

* Update error message when Payer FSP and Payee FSP are the same and on-us is not enabled.. (Added text "FSP" to specify)

* Updated unit test

* #1423: Bulk transfers error processing in Central Ledger (mojaloop#743)

* Updates for bulk error processing

* Bump version

* Updates for bulk transfer error processing

* Updates for bulk transfer error processing

* More updates for bulk error processing

* changes to cater for bulk_abort

* updated central-services-shared

* Updates for bulk error processing

* Add unit test for BULK_ABORT branch in transfer fulfil handler

* Add unit test for BULK_ABORT branch in transfer facade

* Small fix for position handler test for BULK_ABORT branch

Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>

* Bump version for release (mojaloop#750)

* Feature/#1334 patch request notif (mojaloop#751)

* added handling of request for notification by payee functionality
* improved coverage and added missing action letter

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* chore(package): update contributors list & deps

* chore: audit & deps update

Co-authored-by: shashi165 <33355509+shashi165@users.noreply.github.com>
Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>
Co-authored-by: Steven Oderayi <oderayi@gmail.com>
Co-authored-by: vijayg10 <33152110+vijayg10@users.noreply.github.com>
Co-authored-by: lazolalucas <lazolalucas@users.noreply.github.com>
Co-authored-by: Valentin Genev <vgenev@gmail.com>
Co-authored-by: Valentin <valentin.genev@modusbox.com>
Co-authored-by: Adrian Enns <ennsak@gmail.com>
Co-authored-by: Sam <10507686+elnyry-sam-k@users.noreply.github.com>
Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>

chore: add thirdparty endpoints to database seeds (mojaloop#779)

* chore: add thirdparty endpoints to database seeds

* chore: update dependencies for vulnerabilities

* refactor: change name length to accomodate new endpoints

* chore: sync package-lock

* chore: remove migrations and shorten endpoint names

* chore: fix find and replace error

* chore: fix spelling

refactor: update pisp/master (mojaloop#781)

* fix for python error in CI (mojaloop#733)

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Ensure 'timeout-reserved' notification action passes through and not converted to 'abort' action (mojaloop#736)

* Update CS shared (mojaloop#737)

* Feature/1332 enable on-us transfers (mojaloop#738)

* Added ENABLE_ON_US_TRANSFERS

* Bumped up the version

* Feature/otc 525 implement get transaction object by transfer (mojaloop#735)

* OTC-525 Implement GET transaction Object by transferId
Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id
- Post ledger entry

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* OTC-525 Implement GET transaction Object by transferId
Bumput up versions

* OTC-525 Implement GET transaction Object by transferId
Resolved dependency updates

* OTC-525 Implement GET transaction Object by transferId

* OTC-525 Implement GET transaction Object by transferId

Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* changed docker dependency in circle CI image scan from python-dev to python3-dev (mojaloop#741)

* Updated python in some other places in circle CI (mojaloop#742)

* Fix the image scan step in circle CI

* Resolved audit checks

* Feature/#1335 aborted on put (mojaloop#740)

* added error log if action REJECT comes into fulfil handler

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* Bugfix/deadlock on adjust limits (mojaloop#745)

* added unique index on participantLimit and logging

* added unique index on participantLimit and logging

* resolve audit issues

* fixed coverage tests

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Updated dependencies and product version for issue: mojaloop/project#1378 (mojaloop#747)

* Update error message  (mojaloop#749)

* Update error message when Payer FSP and Payee FSP are the same and on-us is not enabled.. (Added text "FSP" to specify)

* Updated unit test

* #1423: Bulk transfers error processing in Central Ledger (mojaloop#743)

* Updates for bulk error processing

* Bump version

* Updates for bulk transfer error processing

* Updates for bulk transfer error processing

* More updates for bulk error processing

* changes to cater for bulk_abort

* updated central-services-shared

* Updates for bulk error processing

* Add unit test for BULK_ABORT branch in transfer fulfil handler

* Add unit test for BULK_ABORT branch in transfer facade

* Small fix for position handler test for BULK_ABORT branch

Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>

* Bump version for release (mojaloop#750)

* Feature/#1334 patch request notif (mojaloop#751)

* added handling of request for notification by payee functionality
* improved coverage and added missing action letter

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* Feature/1468 bulk quotes endpoints (mojaloop#761)

* version change

* Added  FSPIOP_CALLBACK_URL_BULK_QUOTES endpoint to seeds and updated population scripts and created one for local legacy simulator
updated dependencies

* updated dependencies to resolve audit issues

* Feature/#1375: GET bulk transfer implementation (mojaloop#760)

* Add bulk get topic and handler

* Implement GET bulk transfer logic

* Restore default config

* Add unit tests

* Bump version

* More bug fixes

* Fix unit test

* ensure error code is returned as string and not number for bulk get

* Add bulk get to handlers list for cli startup (mojaloop#765)

* Reset package-lock.json to fix bug with version update for AJV (mojaloop#766)

* SemVar fix (mojaloop#767)

* Fix error callback for bulk transfers REJECTED scenario (mojaloop#768)

* Correct FSPIOP API version for admin API (mojaloop#769)

* #1547: Ignore "RESERVED" transferState from v1.0 clients on fulfill callback (mojaloop#770)

* Ignore RESERVE transferState from v1.0 clients on fulfil callback

* Update package.json

Co-authored-by: Sam <10507686+elnyry-sam-k@users.noreply.github.com>

Co-authored-by: Sam <10507686+elnyry-sam-k@users.noreply.github.com>

* Bump version to v111.1.2 to fix broken release (mojaloop#771)

* #1547: Fail transfer fulfill with "RESERVED" state and v1.0 content-type (mojaloop#773)

* Update dependencies

* Bump version

* Fix integration tests

* #1547: Update dependencies (central-object-store etc.) (mojaloop#774)

* Update dependencies

* Bump version

* fix: package.json & package-lock.json to reduce vulnerabilities (mojaloop#775)

The following vulnerabilities are fixed with an upgrade:
- https://snyk.io/vuln/SNYK-JS-LODASH-590103

* Fix bug in volumes of temp_curl service (mojaloop#778)

* Edited CI to build PISP docker image. (mojaloop#734)

* Edited CI to build PISP docker image.

* Addressed comments.

* Updated ci to python 3. (mojaloop#744)

* Update pisp/master (mojaloop#755)

* fix for python error in CI (mojaloop#733)

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Ensure 'timeout-reserved' notification action passes through and not converted to 'abort' action (mojaloop#736)

* Update CS shared (mojaloop#737)

* Feature/1332 enable on-us transfers (mojaloop#738)

* Added ENABLE_ON_US_TRANSFERS

* Bumped up the version

* Feature/otc 525 implement get transaction object by transfer (mojaloop#735)

* OTC-525 Implement GET transaction Object by transferId
Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id
- Post ledger entry

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* OTC-525 Implement GET transaction Object by transferId
Bumput up versions

* OTC-525 Implement GET transaction Object by transferId
Resolved dependency updates

* OTC-525 Implement GET transaction Object by transferId

* OTC-525 Implement GET transaction Object by transferId

Changes:

Updated swagger def to include new endpoints for:
- Get transaction by transfer id

Added new method for:
- Get transaction by transfer id

Added unit tests for Get transaction by transfer id

* changed docker dependency in circle CI image scan from python-dev to python3-dev (mojaloop#741)

* Updated python in some other places in circle CI (mojaloop#742)

* Fix the image scan step in circle CI

* Resolved audit checks

* Feature/#1335 aborted on put (mojaloop#740)

* added error log if action REJECT comes into fulfil handler

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* Bugfix/deadlock on adjust limits (mojaloop#745)

* added unique index on participantLimit and logging

* added unique index on participantLimit and logging

* resolve audit issues

* fixed coverage tests

Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>

* Updated dependencies and product version for issue: mojaloop/project#1378 (mojaloop#747)

* Update error message  (mojaloop#749)

* Update error message when Payer FSP and Payee FSP are the same and on-us is not enabled.. (Added text "FSP" to specify)

* Updated unit test

* #1423: Bulk transfers error processing in Central Ledger (mojaloop#743)

* Updates for bulk error processing

* Bump version

* Updates for bulk transfer error processing

* Updates for bulk transfer error processing

* More updates for bulk error processing

* changes to cater for bulk_abort

* updated central-services-shared

* Updates for bulk error processing

* Add unit test for BULK_ABORT branch in transfer fulfil handler

* Add unit test for BULK_ABORT branch in transfer facade

* Small fix for position handler test for BULK_ABORT branch

Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>

* Bump version for release (mojaloop#750)

* Feature/#1334 patch request notif (mojaloop#751)

* added handling of request for notification by payee functionality
* improved coverage and added missing action letter

Co-authored-by: Valentin <valentin.genev@modusbox.com>

* chore(package): update contributors list & deps

* chore: audit & deps update

Co-authored-by: shashi165 <33355509+shashi165@users.noreply.github.com>
Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>
Co-authored-by: Steven Oderayi <oderayi@gmail.com>
Co-authored-by: vijayg10 <33152110+vijayg10@users.noreply.github.com>
Co-authored-by: lazolalucas <lazolalucas@users.noreply.github.com>
Co-authored-by: Valentin Genev <vgenev@gmail.com>
Co-authored-by: Valentin <valentin.genev@modusbox.com>
Co-authored-by: Adrian Enns <ennsak@gmail.com>
Co-authored-by: Sam <10507686+elnyry-sam-k@users.noreply.github.com>
Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>

* chore: add thirdparty endpoints to database seeds (mojaloop#779)

* chore: add thirdparty endpoints to database seeds

* chore: update dependencies for vulnerabilities

* refactor: change name length to accomodate new endpoints

* chore: sync package-lock

* chore: remove migrations and shorten endpoint names

* chore: fix find and replace error

* chore: fix spelling

* chore: update packages

* chore: sync package-lock

Co-authored-by: shashi165 <33355509+shashi165@users.noreply.github.com>
Co-authored-by: Shashi <shashikant.hirugade@modusbox.com>
Co-authored-by: Steven Oderayi <oderayi@gmail.com>
Co-authored-by: vijayg10 <33152110+vijayg10@users.noreply.github.com>
Co-authored-by: lazolalucas <lazolalucas@users.noreply.github.com>
Co-authored-by: Valentin Genev <vgenev@gmail.com>
Co-authored-by: Valentin <valentin.genev@modusbox.com>
Co-authored-by: Adrian Enns <ennsak@gmail.com>
Co-authored-by: Sam <10507686+elnyry-sam-k@users.noreply.github.com>
Co-authored-by: Rajiv Mothilal <rajivmothilal@gmail.com>
Co-authored-by: Snyk bot <github+bot@snyk.io>
Co-authored-by: Ali Behnamfard <abehnamfard@users.noreply.github.com>
Co-authored-by: eoln <2881004+eoln@users.noreply.github.com>

feat: add patch thirdparty request seed (mojaloop#783)

chore: add generate challenge endpoints (mojaloop#790)

* chore: add generate challenge endpoints

* chore: fix description

chore: add get transaction request seed (mojaloop#791)
  • Loading branch information
kleyow committed Dec 20, 2020
1 parent 7419b25 commit bf59a46
Show file tree
Hide file tree
Showing 5 changed files with 106 additions and 11 deletions.
29 changes: 20 additions & 9 deletions .circleci/config.yml
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@ defaults_awsCliDependencies: &defaults_awsCliDependencies |
less \
mailcap
pip3 install --upgrade pip awscli==1.14.5 s3cmd==2.0.1 python-magic
apk -v --purge del py-pip

defaults_license_scanner: &defaults_license_scanner
name: Install and set up license-scanner
Expand All @@ -55,6 +56,7 @@ executors:
default-machine:
machine:
image: ubuntu-1604:201903-01

##
# Jobs
#
Expand Down Expand Up @@ -240,7 +242,7 @@ jobs:
- run:
name: Install docker dependencies for anchore
command: |
apk add --update py-pip docker python3-dev libffi-dev openssl-dev gcc libc-dev make jq npm
apk add --update python3 py3-pip docker python3-dev libffi-dev openssl-dev gcc libc-dev make jq npm
- run:
name: Install general dependencies
command: |
Expand Down Expand Up @@ -316,12 +318,21 @@ jobs:
command: |
echo "Publishing $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$CIRCLE_TAG"
docker push $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$CIRCLE_TAG
echo "Publishing $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$RELEASE_TAG"
docker push $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$RELEASE_TAG
case "$CIRCLE_TAG" in
*-pisp*)
# Don't update `late5t` for an image that has a `-pisp`
echo 'skipping late5t tag'
exit 0
;;
*)
echo "Publishing $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$RELEASE_TAG"
docker push $DOCKER_ORG/$CIRCLE_PROJECT_REPONAME:$RELEASE_TAG
;;
esac
- slack/status:
webhook: "$SLACK_WEBHOOK_ANNOUNCEMENT"
success_message: '*"${CIRCLE_PROJECT_REPONAME}"* - Release \`"${CIRCLE_TAG}"\` \nhttps://github.com/mojaloop/"${CIRCLE_PROJECT_REPONAME}"/releases/tag/"${CIRCLE_TAG}"'

deploy:
executor: deploy-kube/helm-kube
steps:
Expand Down Expand Up @@ -411,7 +422,7 @@ workflows:
- setup
filters:
tags:
only: /.*/
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?(\-pisp)?/
branches:
ignore:
- /feature*/
Expand All @@ -438,7 +449,7 @@ workflows:
- audit-licenses
filters:
tags:
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?/
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?(\-pisp)?/
branches:
ignore:
- /.*/
Expand All @@ -448,7 +459,7 @@ workflows:
- build
filters:
tags:
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?/
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?(\-pisp)?/
branches:
ignore:
- /.*/
Expand All @@ -458,7 +469,7 @@ workflows:
- build
filters:
tags:
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?/
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?(\-pisp)?/
branches:
ignore:
- /.*/
Expand All @@ -469,7 +480,7 @@ workflows:
- image-scan
filters:
tags:
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?/
only: /v[0-9]+(\.[0-9]+)*(\-snapshot)?(\-hotfix(\.[0-9]+))?(\-pisp)?/
branches:
ignore:
- /.*/
Expand Down
5 changes: 4 additions & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,9 @@
"Sam Kummary <sam@modusbox.com>",
"Steven Oderayi <steven.oderayi@modusbox.com>",
"Valentin Genev <valentin.genev@modusbox.com>",
"Shashikant Hirugade <shashikant.hirugade@modusbox.com>"
"Shashikant Hirugade <shashikant.hirugade@modusbox.com>",
"Paweł Marzec <pawel.marzec@modusbox.com>",
"Kevin Leylow <kevin.leyow@modusbox.com>"
],
"repository": {
"type": "git",
Expand Down Expand Up @@ -79,6 +81,7 @@
"@hapi/good": "9.0.1",
"@hapi/hapi": "20.0.2",
"@hapi/inert": "6.0.3",
"@hapi/joi": "17.1.1",
"@hapi/vision": "6.0.1",
"@mojaloop/central-object-store": "11.0.1-snapshot",
"@mojaloop/central-services-database": "10.6.1",
Expand Down
72 changes: 72 additions & 0 deletions seeds/endpointType.js
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,78 @@ const endpointTypes = [
{
name: 'FSPIOP_CALLBACK_URL_BULK_QUOTES',
description: 'Bulk Quotes callback URL to which put bulkQuotes requests can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_GET',
description: 'Participant callback URL where GET /thirdpartyRequests/transactions/{ID} can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_POST',
description: 'Participant callback URL where POST /thirdpartyRequests/transactions can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_PUT',
description: 'Participant callback URL where PUT /thirdpartyRequests/transactions/{ID} can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_PUT_ERROR',
description: 'Participant callback URL to which PUT /thirdpartyRequests/transactions/{ID}/error error information can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_PATCH',
description: 'Participant callback URL where PATCH /thirdpartyRequests/transactions/{ID} can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_AUTH_POST',
description: 'Participant callback URL where POST /thirdpartyRequests/transactions/{ID}/authorizations can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_AUTH_PUT',
description: 'Participant callback URL where PUT /thirdpartyRequests/transactions/{ID}/authorizations can be sent'
},
{
name: 'TP_CB_URL_TRANSACTION_REQUEST_AUTH_PUT_ERROR',
description: 'Participant callback URL where PUT /thirdpartyRequests/transactions/{ID}/authorizations/error error information can be sent'
},
{
name: 'TP_CB_URL_CONSENT_REQUEST_POST',
description: 'Participant callback URL where POST /consentRequests can be sent'
},
{
name: 'TP_CB_URL_CONSENT_REQUEST_PUT',
description: 'Participant callback URL where PUT /consentRequests/{ID} can be sent'
},
{
name: 'TP_CB_URL_CONSENT_REQUEST_PUT_ERROR',
description: 'Participant callback URL where PUT /consentRequests/{ID}/error error information can be sent'
},
{
name: 'TP_CB_URL_CREATE_CREDENTIAL_POST',
description: 'Participant callback URL where POST /consentRequests/{ID}/createCredential can be sent'
},
{
name: 'TP_CB_URL_CONSENT_POST',
description: 'Participant callback URL where POST /consents/ can be sent'
},
{
name: 'TP_CB_URL_CONSENT_GET',
description: 'Participant callback URL where GET /consents/{ID} can be sent'
},
{
name: 'TP_CB_URL_CONSENT_PUT',
description: 'Participant callback URL where PUT /consents/{ID} can be sent'
},
{
name: 'TP_CB_URL_CONSENT_PUT_ERROR',
description: 'Participant callback URL where PUT /consents/{ID}/error error information can be sent'
},
{
name: 'TP_CB_URL_CONSENT_GENERATE_CHALLENGE_POST',
description: 'Participant callback URL where POST /consents/{ID}/generateChallenge can be sent'
},
{
name: 'TP_CB_URL_CONSENT_GENERATE_CHALLENGE_PUT_ERROR',
description: 'Participant callback URL where PUT /consents/{ID}/generateChallenge/error error information can be sent'
}
]

Expand Down
2 changes: 1 addition & 1 deletion src/api/transactions/routes.js
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
'use strict'

const Handler = require('./handler')
const Joi = require('joi')
const Joi = require('@hapi/joi')
const tags = ['api', 'transaction']

module.exports = [
Expand Down
9 changes: 9 additions & 0 deletions src/handlers/bulk/fulfil/handler.js
Original file line number Diff line number Diff line change
Expand Up @@ -149,6 +149,15 @@ const bulkFulfil = async (error, messages) => {
while ((doc = await streamReader.readAsync()) !== null) {
await sendIndividualTransfer(message, messageId, kafkaTopic, headers, payload, state, params, doc.payload, histTimerEnd)
}
const dataUri = encodePayload(JSON.stringify(individualTransferFulfil), headers[Enum.Http.Headers.GENERAL.CONTENT_TYPE.value])
const metadata = Util.StreamingProtocol.createMetadataWithCorrelatedEventState(message.value.metadata.event.id, Enum.Events.Event.Type.FULFIL, Enum.Events.Event.Action.COMMIT, Enum.Events.EventStatus.SUCCESS.status, Enum.Events.EventStatus.SUCCESS.code, Enum.Events.EventStatus.SUCCESS.description) // TODO: switch action to 'bulk-fulfil' flow
const msg = {
value: Util.StreamingProtocol.createMessage(messageId, headers[Enum.Http.Headers.FSPIOP.DESTINATION], headers[Enum.Http.Headers.FSPIOP.SOURCE], metadata, headers, dataUri, { id: transferId })
}
params = { message: msg, kafkaTopic, consumer: Consumer, producer: Producer }
const eventDetail = { functionality: Enum.Events.Event.Type.FULFIL, action: Enum.Events.Event.Action.BULK_COMMIT }
await Kafka.proceed(Config.KAFKA_CONFIG, params, { consumerCommit, histTimerEnd, eventDetail })
histTimerEnd({ success: true, fspId: Config.INSTRUMENTATION_METRICS_LABELS.fspId })
}
} catch (err) { // TODO: handle individual transfers streaming error
Logger.isInfoEnabled && Logger.info(Util.breadcrumb(location, `callbackErrorInternal2--${actionLetter}6`))
Expand Down

0 comments on commit bf59a46

Please sign in to comment.