mirror of
https://github.com/valitydev/holmes.git
synced 2024-11-06 09:55:19 +00:00
143 lines
3.5 KiB
Bash
Executable File
143 lines
3.5 KiB
Bash
Executable File
#!/bin/bash
|
|
#
|
|
# This little guy repairs an invoice which have failed because of an unexpected
|
|
# error while trying to process payment though provider processed it successfully
|
|
# in the meantime.
|
|
#
|
|
# Attention! To attach some transaction info to the payment you must have a file
|
|
# name `trx.{invoice_id}.json' in the workdir which follows `domain.TransactionInfo'
|
|
# schema.
|
|
#
|
|
|
|
set -e
|
|
|
|
CWD="$(dirname $0)"
|
|
|
|
source "${CWD}/lib/logging"
|
|
|
|
# Actual work is going here
|
|
|
|
INVOICE="${1}"
|
|
PAYMENT="${2:-1}"
|
|
|
|
case ${INVOICE} in
|
|
""|"-h"|"--help" )
|
|
echo -ne "Given ID of an invoice and a payment make it look like the payment processed successfully. "
|
|
echo -ne "You can bind transaction info if you should, just place a file named "
|
|
echo -ne "'trx.{invoice_id}.{payment_id}.json' under the feet."
|
|
echo
|
|
echo
|
|
echo -e "Usage: ${SCRIPTNAME} invoice_id [payment_id] [--force]"
|
|
echo -e " invoice_id Invoice ID (string)."
|
|
echo -e " payment_id Payment ID (string), if not specified taken from last invoice event."
|
|
echo -e " --force Force execution even when transaction info is missing."
|
|
echo -e " -h, --help Show this help message."
|
|
echo
|
|
echo -e "More information:"
|
|
echo -e " https://github.com/rbkmoney/damsel/blob/master/proto/payment_processing.thrift"
|
|
exit 0
|
|
;;
|
|
* )
|
|
;;
|
|
esac
|
|
|
|
|
|
LAST_CHANGE=$(
|
|
${CWD}/hellgate/get-invoice-events.sh ${INVOICE} |
|
|
jq '.[-1].payload.invoice_changes[-1].invoice_payment_change'
|
|
)
|
|
|
|
if [ \
|
|
"${LAST_CHANGE}" = "null" -o \
|
|
"$(echo "${LAST_CHANGE}" | jq -r '.payload | has("invoice_payment_cash_flow_changed")')" != "true" \
|
|
]; then
|
|
err "Last seen change looks wrong for this repair scenario"
|
|
fi
|
|
|
|
LAST_PAYMENT="$(echo "${LAST_CHANGE}" | jq -r '.id')"
|
|
|
|
if [ "$(echo "${LAST_CHANGE}" | jq -r '.id')" != "${PAYMENT}" ]; then
|
|
err "Last seen change related to another payment with id $(em "${LAST_PAYMENT}")"
|
|
fi
|
|
|
|
TRXCHANGE=
|
|
TRXFILE="trx.${INVOICE}.${PAYMENT}.json"
|
|
|
|
if [ -f "${TRXFILE}" ]; then
|
|
|
|
TRXCHANGE=$(cat <<END
|
|
{
|
|
"invoice_payment_change": {
|
|
"id": "${PAYMENT}",
|
|
"payload": {
|
|
"invoice_payment_session_change": {
|
|
"target": {
|
|
"processed": []
|
|
},
|
|
"payload": {
|
|
"session_transaction_bound": {
|
|
"trx": $(cat "${TRXFILE}")
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
},
|
|
END
|
|
)
|
|
|
|
else
|
|
|
|
warn "No transaction info to bound, file $(em "${TRXFILE}") is missing"
|
|
if [ "${3}" != "--force" ]; then
|
|
err "Rerun with $(em --force) to proceed anyway"
|
|
fi
|
|
|
|
fi
|
|
|
|
# Essentially we have to simulate the failed session has been restarted and then
|
|
# finished successfully.
|
|
CHANGES=$(cat <<END
|
|
[
|
|
{
|
|
"invoice_payment_change": {
|
|
"id": "${PAYMENT}",
|
|
"payload": {
|
|
"invoice_payment_session_change": {
|
|
"target": {
|
|
"processed": []
|
|
},
|
|
"payload": {
|
|
"session_started": []
|
|
}
|
|
}
|
|
}
|
|
}
|
|
},
|
|
${TRXCHANGE}
|
|
{
|
|
"invoice_payment_change": {
|
|
"id": "${PAYMENT}",
|
|
"payload": {
|
|
"invoice_payment_session_change": {
|
|
"target": {
|
|
"processed": []
|
|
},
|
|
"payload": {
|
|
"session_finished": {
|
|
"result": {
|
|
"succeeded": []
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
]
|
|
END
|
|
)
|
|
|
|
# Then we should stuff it with previously reconstructed history
|
|
./repair-invoice.sh "${INVOICE}" "${CHANGES}"
|