Skip to content

added new message to notification topic for limit adjustment. #236

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
vgenev merged 6 commits into from
Jan 24, 2019
Merged

added new message to notification topic for limit adjustment. #236

Changes from 5 commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
40604e6
added new message to notification topic for limit adjustment. tests s…
vgenev Jan 22, 2019
b09135b
Merge branch 'master' into feat/566
vgenev Jan 24, 2019
d7b6715
enabling sidecar, disabled by mistake
vgenev Jan 24, 2019
955f8ef
delete package-lock
vgenev Jan 24, 2019
ac3b993
duplicate package-lock from master
vgenev Jan 24, 2019
7a809a6
jsdocs update and making code more readable
vgenev Jan 24, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
41 changes: 39 additions & 2 deletions src/domain/participant/index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -447,16 +447,53 @@ const getLimitsForAllParticipants = async ({ currency = null, type = null }) =>
* @returns {integer} - Returns number of database rows affected if successful, or throws an error if failed
*/

// {
Comment thread
vgenev marked this conversation as resolved.
Outdated
// "currency": "USD",
// "limit": {
// "type": "NET_DEBIT_CAP",
// "value": 1500,
// "thresholdAlarmPercentage": 10
// }
// }

const adjustLimits = async (name, payload) => {
try {
const participant = await ParticipantFacade.getByNameAndCurrency(name, payload.currency, Enum.LedgerAccountType.POSITION)
let { limit, currency } = payload
payload.name = name
Comment thread
vgenev marked this conversation as resolved.
Outdated
const participant = await ParticipantFacade.getByNameAndCurrency(name, currency, Enum.LedgerAccountType.POSITION)
participantExists(participant)
return ParticipantFacade.adjustLimits(participant.participantCurrencyId, payload.limit)
let result = await ParticipantFacade.adjustLimits(participant.participantCurrencyId, limit)
await Utility.produceGeneralMessage(TransferEventType.NOTIFICATION, TransferEventAction.EVENT, createLimitAdjustmentMessageProtocol(payload), Utility.ENUMS.STATE.SUCCESS)
return result
} catch (err) {
throw err
}
}

const createLimitAdjustmentMessageProtocol = (payload, action = 'limitAdjustment', state = '', pp = '') => {
return {
id: Uuid(),
from: payload.name,
to: 'SYSTEM',
type: 'application/json',
content: {
header: {},
payload
},
metadata: {
event: {
id: Uuid(),
responseTo: '',
type: 'notification',
action,
createdAt: new Date(),
state
}
},
pp
}
}

/**
* @function GetPositions
*
Expand Down