Skip to content

Commit

Permalink
Code refactoring and require status parameter
Browse files Browse the repository at this point in the history
Also, make doc-all ran!

Signed-off-by: Vincenzo Palazzo <[email protected]>
  • Loading branch information
vincenzopalazzo authored and cdecker committed Sep 9, 2020
1 parent 50f3872 commit d792432
Show file tree
Hide file tree
Showing 6 changed files with 39 additions and 49 deletions.
14 changes: 7 additions & 7 deletions doc/lightning-delpay.7

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

13 changes: 6 additions & 7 deletions doc/lightning-delpay.7.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,17 +4,16 @@ lightning-delpay -- Command for removing a completed or failed payment
SYNOPSIS
--------

**delpay** *payment\_hash* \[status\]
**delpay** *payment\_hash* *status*

DESCRIPTION
-----------

The **delpay** RPC command removes a payment as given in **listsendpays** or **listpays** with a complete or failed
status. Deleting a `pending` payment is an error.
The **delpay** RPC command deletes a payment with the given `payment_hash` if its status is either `complete` or `failed`. Deleting a `pending` payment is an error.

- *payment\_hash*: The unique identifier of a payment. Find it, you can run **listpays** or **listsendpays**;
- *status*: Expected status of the payment. Valid values are *complete* or *failed*.
Only deletes if the payment status matches. If not specified, defaults to *complete*.
- *payment\_hash*: The unique identifier of a payment.
- *status*: Expected status of the payment.
Only deletes if the payment status matches.

EXAMPLE JSON REQUEST
------------
Expand All @@ -32,7 +31,7 @@ EXAMPLE JSON REQUEST
RETURN VALUE
------------

On success, the command will return a payment object, such as the **listsendpays**. If the payment is aa MPP (multi part payment) the command return a list of
If successful the command returns a payment object, in the same format as **listsendpays**. If the payment is a multi-part payment (MPP) the command return a list of
payments will be return -- one payment object for each partid.

On failure, an error is returned. If the lightning process fails before responding, the
Expand Down
16 changes: 9 additions & 7 deletions lightningd/pay.c
Original file line number Diff line number Diff line change
Expand Up @@ -1530,19 +1530,21 @@ static struct command_result *json_delpay(struct command *cmd,

if (!param(cmd, buffer, params,
p_req("payment_hash", param_sha256, &payment_hash),
p_opt("status", param_string, &status_str),
p_req("status", param_string, &status_str),
NULL))
return command_param_failed();

if (!status_str)
status_str = "complete";

if (!string_to_payment_status(status_str, &status))
return command_fail(cmd, JSONRPC2_INVALID_PARAMS, "Unrecognized status: %s", status_str);

if (status == PAYMENT_PENDING)
return command_fail(cmd, JSONRPC2_INVALID_PARAMS, "Invalid status: %s",
payment_status_to_string(status));
switch(status){
case PAYMENT_COMPLETE:
case PAYMENT_FAILED:
break;
case PAYMENT_PENDING:
return command_fail(cmd, JSONRPC2_INVALID_PARAMS, "Invalid status: %s",
payment_status_to_string(status));
}

payments = wallet_payment_list(cmd, cmd->ld->wallet, payment_hash);

Expand Down
40 changes: 15 additions & 25 deletions tests/test_pay.py
Original file line number Diff line number Diff line change
Expand Up @@ -3265,46 +3265,38 @@ def test_mpp_presplit_routehint_conflict(node_factory, bitcoind):

def test_delpay_argument_invalid(node_factory, bitcoind):
"""
This test includes all possible combination of input error inside the
This test includes all possible combinations of input error inside the
delpay command.
"""

l1, l2 = node_factory.get_nodes(2)
# Create the line graph l2 -> l1 with a channel of 10 ** 5 sat!
l2, l1 = node_factory.line_graph(2, fundamount=10**5, wait_for_announce=True)

with pytest.raises(RpcError):
l2.rpc.delpay()

# invoice unpaid
# sanity check
inv = l1.rpc.invoice(10 ** 5, 'inv', 'inv')
payment_hash = inv["payment_hash"]
payment_hash = "AA" * 32
with pytest.raises(RpcError):
l2.rpc.delpay(payment_hash)
l2.rpc.delpay(payment_hash, 'complete')

l2.rpc.pay(inv['bolt11'])

# payment unpaid with wrong status (pending status is a illegal input)
wait_for(lambda: l2.rpc.listpays(inv['bolt11'])['pays'][0]['status'] == 'complete')

payment_hash = inv['payment_hash']

# payment paid with wrong status (pending status is a illegal input)
with pytest.raises(RpcError):
l2.rpc.delpay(payment_hash, 'pending')

with pytest.raises(RpcError):
l2.rpc.delpay(payment_hash, 'invalid_status')

l2.rpc.connect(l1.info['id'], 'localhost', l1.port)
l2.fund_channel(l1, 10 ** 6)

bitcoind.generate_block(6)
sync_blockheight(bitcoind, [l1, l2])

wait_for(lambda: len(l2.rpc.listchannels()['channels']) == 2)

l2.rpc.pay(inv['bolt11'])

with pytest.raises(RpcError):
l2.rpc.delpay(payment_hash, 'failed')

with pytest.raises(RpcError):
l2.rpc.delpay(payment_hash, 'pending')

assert len(l2.rpc.listpays()['pays']) == 1

# test if the node is still ready
payments = l2.rpc.delpay(payment_hash, 'complete')

Expand All @@ -3320,10 +3312,8 @@ def test_delpay_payment_split(node_factory, bitcoind):
MPP_TARGET_SIZE = 10**7 # Taken from libpluin-pay.c
amt = 5 * MPP_TARGET_SIZE

l1, l2, l3 = node_factory.line_graph(
3, fundamount=10**8, wait_for_announce=True,
opts={'wumbo': None}
)
l1, l2, l3 = node_factory.line_graph(3, fundamount=10**5,
wait_for_announce=True)

inv = l3.rpc.invoice(amt, 'lbl', 'desc')
l1.rpc.pay(inv['bolt11'])
Expand Down
2 changes: 1 addition & 1 deletion wallet/wallet.c
Original file line number Diff line number Diff line change
Expand Up @@ -2443,7 +2443,7 @@ void wallet_payment_store(struct wallet *wallet,
if (payment->bolt11 != NULL)
db_bind_text(stmt, 10, payment->bolt11);
else
db_bind_null(stmt, 10);
db_bind_null(stmt, 10);

db_bind_amount_msat(stmt, 11, &payment->total_msat);
db_bind_u64(stmt, 12, payment->partid);
Expand Down
3 changes: 1 addition & 2 deletions wallet/wallet.h
Original file line number Diff line number Diff line change
Expand Up @@ -973,8 +973,7 @@ void wallet_payment_delete(struct wallet *wallet,
* Removes the payment from the database by hash; if it is a MPP payment
* it remove all parts with a single query.
*/
void wallet_payment_delete_by_hash(struct wallet *wallet,
const struct sha256 *payment_hash);
void wallet_payment_delete_by_hash(struct wallet *wallet, const struct sha256 *payment_hash);

/**
* wallet_local_htlc_out_delete - Remove a local outgoing failed HTLC
Expand Down

0 comments on commit d792432

Please sign in to comment.