2016-09-06 09:17:49 +02:00
# include "invoice.h"
2018-03-16 04:45:08 +01:00
# include "json.h"
2016-09-06 09:17:49 +02:00
# include "jsonrpc.h"
2018-05-24 23:40:18 +02:00
# include "jsonrpc_errors.h"
2016-09-06 09:17:49 +02:00
# include "lightningd.h"
2017-11-22 01:25:39 +01:00
# include <bitcoin/address.h>
# include <bitcoin/base58.h>
# include <bitcoin/script.h>
2016-09-06 09:17:49 +02:00
# include <ccan/str/hex/hex.h>
# include <ccan/tal/str/str.h>
2017-11-22 01:25:39 +01:00
# include <common/bech32.h>
# include <common/bolt11.h>
2018-03-26 02:08:15 +02:00
# include <common/json_escaped.h>
2017-08-28 18:02:01 +02:00
# include <common/utils.h>
2017-11-22 01:25:39 +01:00
# include <errno.h>
2017-11-30 17:07:38 +01:00
# include <hsmd/gen_hsm_client_wire.h>
2017-10-05 23:29:56 +02:00
# include <inttypes.h>
2017-11-22 01:25:39 +01:00
# include <lightningd/hsm_control.h>
2018-04-26 09:42:04 +02:00
# include <lightningd/jsonrpc_errors.h>
2017-10-05 23:29:56 +02:00
# include <lightningd/log.h>
2018-01-17 04:04:29 +01:00
# include <lightningd/options.h>
2018-07-16 22:48:38 +02:00
# include <lightningd/param.h>
2016-09-06 09:17:49 +02:00
# include <sodium/randombytes.h>
2017-11-22 01:25:39 +01:00
# include <wire/wire_sync.h>
2016-09-06 09:17:49 +02:00
2018-02-20 02:07:30 +01:00
static const char * invoice_status_str ( const struct invoice_details * inv )
2018-01-17 04:04:29 +01:00
{
if ( inv - > state = = PAID )
return " paid " ;
2018-01-23 02:02:10 +01:00
if ( inv - > state = = EXPIRED )
2018-01-17 04:04:29 +01:00
return " expired " ;
return " unpaid " ;
}
2018-01-13 12:14:13 +01:00
static void json_add_invoice ( struct json_result * response ,
2018-02-20 02:07:30 +01:00
const struct invoice_details * inv ,
2018-01-17 04:04:29 +01:00
bool modern )
2018-01-13 12:14:13 +01:00
{
json_object_start ( response , NULL ) ;
2018-03-26 02:08:16 +02:00
json_add_escaped_string ( response , " label " , inv - > label ) ;
2018-02-28 17:26:58 +01:00
json_add_string ( response , " bolt11 " , inv - > bolt11 ) ;
2018-01-13 12:17:34 +01:00
json_add_hex ( response , " payment_hash " , & inv - > rhash , sizeof ( inv - > rhash ) ) ;
2018-01-13 12:14:13 +01:00
if ( inv - > msatoshi )
json_add_u64 ( response , " msatoshi " , * inv - > msatoshi ) ;
2018-01-17 04:04:29 +01:00
if ( modern )
json_add_string ( response , " status " , invoice_status_str ( inv ) ) ;
else if ( deprecated_apis & & ! modern )
json_add_bool ( response , " complete " , inv - > state = = PAID ) ;
2018-01-13 12:19:33 +01:00
if ( inv - > state = = PAID ) {
2018-01-13 12:14:13 +01:00
json_add_u64 ( response , " pay_index " , inv - > pay_index ) ;
2018-01-13 12:19:33 +01:00
json_add_u64 ( response , " msatoshi_received " ,
inv - > msatoshi_received ) ;
2018-01-19 10:53:24 +01:00
if ( deprecated_apis )
json_add_u64 ( response , " paid_timestamp " ,
inv - > paid_timestamp ) ;
json_add_u64 ( response , " paid_at " , inv - > paid_timestamp ) ;
2018-01-13 12:19:33 +01:00
}
2018-01-19 10:53:24 +01:00
if ( deprecated_apis )
json_add_u64 ( response , " expiry_time " , inv - > expiry_time ) ;
json_add_u64 ( response , " expires_at " , inv - > expiry_time ) ;
2018-01-13 12:14:13 +01:00
json_object_end ( response ) ;
}
2018-02-01 12:51:19 +01:00
static void tell_waiter ( struct command * cmd , const struct invoice * inv )
2016-09-06 09:17:49 +02:00
{
struct json_result * response = new_json_result ( cmd ) ;
2018-02-20 02:07:30 +01:00
struct invoice_details details ;
2016-09-06 09:17:49 +02:00
2018-02-23 02:04:47 +01:00
wallet_invoice_details ( cmd , cmd - > ld - > wallet , * inv , & details ) ;
2018-02-20 02:07:30 +01:00
json_add_invoice ( response , & details , true ) ;
if ( details . state = = PAID )
2018-02-01 12:51:19 +01:00
command_success ( cmd , response ) ;
2018-05-24 23:40:18 +02:00
else {
/* FIXME: -2 should be a constant in jsonrpc_errors.h. */
2018-02-01 12:51:19 +01:00
command_fail_detailed ( cmd , - 2 , response ,
" invoice expired during wait " ) ;
2018-05-24 23:40:18 +02:00
}
2016-09-06 09:17:49 +02:00
}
2018-01-14 15:15:30 +01:00
static void tell_waiter_deleted ( struct command * cmd )
2017-12-27 13:55:22 +01:00
{
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Invoice deleted during wait " ) ;
2017-12-27 13:55:22 +01:00
}
2018-01-14 15:15:30 +01:00
static void wait_on_invoice ( const struct invoice * invoice , void * cmd )
2016-09-06 09:17:49 +02:00
{
2018-01-14 15:15:30 +01:00
if ( invoice )
tell_waiter ( ( struct command * ) cmd , invoice ) ;
else
tell_waiter_deleted ( ( struct command * ) cmd ) ;
2016-09-06 09:17:49 +02:00
}
2016-11-11 00:02:04 +01:00
2017-11-22 01:25:39 +01:00
static bool hsm_sign_b11 ( const u5 * u5bytes ,
const u8 * hrpu8 ,
secp256k1_ecdsa_recoverable_signature * rsig ,
struct lightningd * ld )
{
2018-07-09 13:17:59 +02:00
u8 * msg = towire_hsm_sign_invoice ( NULL , u5bytes , hrpu8 ) ;
2017-11-22 01:25:39 +01:00
if ( ! wire_sync_write ( ld - > hsm_fd , take ( msg ) ) )
fatal ( " Could not write to HSM: %s " , strerror ( errno ) ) ;
2018-07-09 13:17:59 +02:00
msg = wire_sync_read ( tmpctx , ld - > hsm_fd ) ;
2018-02-20 21:59:09 +01:00
if ( ! fromwire_hsm_sign_invoice_reply ( msg , rsig ) )
2017-11-22 01:25:39 +01:00
fatal ( " HSM gave bad sign_invoice_reply %s " ,
tal_hex ( msg , msg ) ) ;
return true ;
}
2018-03-28 04:00:37 +02:00
/* We allow a string, or a literal number, for labels */
static struct json_escaped * json_tok_label ( const tal_t * ctx ,
const char * buffer ,
const jsmntok_t * tok )
{
struct json_escaped * label ;
label = json_tok_escaped_string ( ctx , buffer , tok ) ;
if ( label )
return label ;
/* Allow literal numbers */
if ( tok - > type ! = JSMN_PRIMITIVE )
return NULL ;
for ( int i = tok - > start ; i < tok - > end ; i + + )
if ( ! cisdigit ( buffer [ i ] ) )
return NULL ;
return json_escaped_string_ ( ctx , buffer + tok - > start ,
tok - > end - tok - > start ) ;
}
2018-04-05 07:13:51 +02:00
static bool parse_fallback ( struct command * cmd ,
const char * buffer , const jsmntok_t * fallback ,
const u8 * * fallback_script )
{
enum address_parse_result fallback_parse ;
fallback_parse
= json_tok_address_scriptpubkey ( cmd ,
get_chainparams ( cmd - > ld ) ,
buffer , fallback ,
fallback_script ) ;
if ( fallback_parse = = ADDRESS_PARSE_UNRECOGNIZED ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Fallback address not valid " ) ;
2018-04-05 07:13:51 +02:00
return false ;
} else if ( fallback_parse = = ADDRESS_PARSE_WRONG_NETWORK ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD ,
" Fallback address does not match our network %s " ,
2018-04-05 07:13:51 +02:00
get_chainparams ( cmd - > ld ) - > network_name ) ;
return false ;
}
return true ;
}
2016-09-06 09:17:49 +02:00
static void json_invoice ( struct command * cmd ,
const char * buffer , const jsmntok_t * params )
{
2018-02-23 02:04:47 +01:00
struct invoice invoice ;
2018-02-20 02:07:30 +01:00
struct invoice_details details ;
2018-07-16 22:48:38 +02:00
const jsmntok_t * msatoshi , * label , * desctok , * fallback , * fallbacks ;
const jsmntok_t * preimagetok ;
2018-01-14 15:15:30 +01:00
u64 * msatoshi_val ;
2018-03-26 02:08:47 +02:00
const struct json_escaped * label_val , * desc ;
2018-02-17 12:48:22 +01:00
const char * desc_val ;
2016-11-11 00:02:04 +01:00
struct json_result * response = new_json_result ( cmd ) ;
2018-01-14 15:15:30 +01:00
struct wallet * wallet = cmd - > ld - > wallet ;
2017-10-26 05:06:19 +02:00
struct bolt11 * b11 ;
char * b11enc ;
2018-04-05 07:13:51 +02:00
const u8 * * fallback_scripts = NULL ;
2018-07-16 22:48:38 +02:00
u64 expiry ;
2018-02-23 02:04:47 +01:00
bool result ;
2016-09-06 09:17:49 +02:00
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_req ( " msatoshi " , json_tok_tok , & msatoshi ) ,
p_req ( " label " , json_tok_tok , & label ) ,
p_req ( " description " , json_tok_tok , & desctok ) ,
p_opt_def ( " expiry " , json_tok_u64 , & expiry , 3600 ) ,
p_opt_tok ( " fallback " , & fallback ) ,
p_opt_tok ( " fallbacks " , & fallbacks ) ,
p_opt_tok ( " preimage " , & preimagetok ) ,
NULL ) )
2016-09-06 09:17:49 +02:00
return ;
2018-01-14 15:15:30 +01:00
/* Get arguments. */
/* msatoshi */
2018-01-10 02:28:44 +01:00
if ( json_tok_streq ( buffer , msatoshi , " any " ) )
2018-01-14 15:15:30 +01:00
msatoshi_val = NULL ;
2018-01-10 02:28:44 +01:00
else {
2018-01-14 15:15:30 +01:00
msatoshi_val = tal ( cmd , u64 ) ;
if ( ! json_tok_u64 ( buffer , msatoshi , msatoshi_val )
| | * msatoshi_val = = 0 ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
2018-01-10 02:28:44 +01:00
" '%.*s' is not a valid positive number " ,
msatoshi - > end - msatoshi - > start ,
buffer + msatoshi - > start ) ;
return ;
}
2016-09-06 09:17:49 +02:00
}
2018-01-14 15:15:30 +01:00
/* label */
2018-03-28 04:00:37 +02:00
label_val = json_tok_label ( cmd , buffer , label ) ;
2018-03-26 02:08:15 +02:00
if ( ! label_val ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" label '%.*s' not a string or number " ,
2018-03-26 02:08:15 +02:00
label - > end - label - > start , buffer + label - > start ) ;
2016-09-06 09:17:49 +02:00
return ;
}
2018-03-26 02:08:16 +02:00
if ( wallet_invoice_find_by_label ( wallet , & invoice , label_val ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , INVOICE_LABEL_ALREADY_EXISTS ,
" Duplicate label '%s' " , label_val - > s ) ;
2018-03-26 02:08:15 +02:00
return ;
}
if ( strlen ( label_val - > s ) > INVOICE_MAX_LABEL_LEN ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" Label '%s' over %u bytes " , label_val - > s ,
2016-09-06 09:17:49 +02:00
INVOICE_MAX_LABEL_LEN ) ;
return ;
}
2018-03-26 02:08:47 +02:00
desc = json_tok_escaped_string ( cmd , buffer , desctok ) ;
if ( ! desc ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" description '%.*s' not a string " ,
2018-03-26 02:08:47 +02:00
desctok - > end - desctok - > start ,
buffer + desctok - > start ) ;
return ;
}
desc_val = json_escaped_unescape ( cmd , desc ) ;
if ( ! desc_val ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" description '%s' is invalid "
2018-03-26 02:08:47 +02:00
" (note: we don't allow \\ u) " ,
desc - > s ) ;
return ;
}
2018-02-17 12:48:22 +01:00
/* description */
2018-03-26 02:08:47 +02:00
if ( strlen ( desc_val ) > = BOLT11_FIELD_BYTE_LIMIT ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
2018-02-17 12:48:22 +01:00
" Descriptions greater than %d bytes "
" not yet supported "
2018-03-26 02:08:47 +02:00
" (description length %zu) " ,
2018-02-17 12:48:22 +01:00
BOLT11_FIELD_BYTE_LIMIT ,
2018-03-26 02:08:47 +02:00
strlen ( desc_val ) ) ;
2018-02-17 12:48:22 +01:00
return ;
}
2017-11-21 07:26:15 +01:00
2018-04-05 07:13:51 +02:00
/* fallback addresses */
2018-02-15 00:45:04 +01:00
if ( fallback ) {
2018-04-05 07:13:51 +02:00
if ( deprecated_apis ) {
fallback_scripts = tal_arr ( cmd , const u8 * , 1 ) ;
if ( ! parse_fallback ( cmd , buffer , fallback ,
& fallback_scripts [ 0 ] ) )
return ;
} else {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" fallback is deprecated: use fallbacks " ) ;
2018-04-05 07:13:51 +02:00
return ;
}
}
if ( fallbacks ) {
const jsmntok_t * i , * end = json_next ( fallbacks ) ;
size_t n = 0 ;
if ( fallback ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" Cannot use fallback and fallbacks " ) ;
2018-02-24 15:59:39 +01:00
return ;
2018-04-05 07:13:51 +02:00
}
if ( fallbacks - > type ! = JSMN_ARRAY ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" fallback must be an array " ) ;
2018-02-15 00:45:04 +01:00
return ;
}
2018-04-05 07:13:51 +02:00
fallback_scripts = tal_arr ( cmd , const u8 * , n ) ;
for ( i = fallbacks + 1 ; i < end ; i = json_next ( i ) ) {
tal_resize ( & fallback_scripts , n + 1 ) ;
if ( ! parse_fallback ( cmd , buffer , i ,
& fallback_scripts [ n ] ) )
return ;
n + + ;
}
2018-02-15 00:45:04 +01:00
}
2018-02-28 17:26:58 +01:00
struct preimage r ;
struct sha256 rhash ;
2018-02-15 00:45:04 +01:00
2018-04-22 15:42:23 +02:00
if ( preimagetok ) {
/* Get secret preimage from user. */
if ( ! hex_decode ( buffer + preimagetok - > start ,
preimagetok - > end - preimagetok - > start ,
r . r , sizeof ( r . r ) ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" preimage must be 64 hex digits " ) ;
2018-04-22 15:42:23 +02:00
return ;
}
} else
/* Generate random secret preimage. */
randombytes_buf ( r . r , sizeof ( r . r ) ) ;
/* Generate preimage hash. */
2018-02-28 17:26:58 +01:00
sha256 ( & rhash , r . r , sizeof ( r . r ) ) ;
2018-02-20 02:07:30 +01:00
2018-04-25 01:04:33 +02:00
/* Check duplicate preimage if explicitly specified.
* We do not check when it is randomly generated , since
* the probability of that matching is very low .
*/
if ( preimagetok & &
wallet_invoice_find_by_rhash ( cmd - > ld - > wallet , & invoice , & rhash ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , INVOICE_PREIMAGE_ALREADY_EXISTS ,
" preimage already used " ) ;
2018-04-25 01:04:33 +02:00
return ;
}
2017-10-26 05:06:19 +02:00
/* Construct bolt11 string. */
2018-02-28 17:26:58 +01:00
b11 = new_bolt11 ( cmd , msatoshi_val ) ;
2017-10-26 05:06:19 +02:00
b11 - > chain = get_chainparams ( cmd - > ld ) ;
b11 - > timestamp = time_now ( ) . ts . tv_sec ;
2018-02-28 17:26:58 +01:00
b11 - > payment_hash = rhash ;
2017-10-26 05:06:19 +02:00
b11 - > receiver_id = cmd - > ld - > id ;
2017-10-26 05:08:19 +02:00
b11 - > min_final_cltv_expiry = cmd - > ld - > config . cltv_final ;
2017-11-21 07:26:15 +01:00
b11 - > expiry = expiry ;
2018-02-17 12:48:22 +01:00
b11 - > description = tal_steal ( b11 , desc_val ) ;
b11 - > description_hash = NULL ;
2018-04-05 07:13:51 +02:00
if ( fallback_scripts )
b11 - > fallbacks = tal_steal ( b11 , fallback_scripts ) ;
2017-10-26 05:06:19 +02:00
/* FIXME: add private routes if necessary! */
2017-11-22 01:25:39 +01:00
b11enc = bolt11_encode ( cmd , b11 , false , hsm_sign_b11 , cmd - > ld ) ;
2017-10-26 05:06:19 +02:00
2018-02-28 17:26:58 +01:00
result = wallet_invoice_create ( cmd - > ld - > wallet ,
& invoice ,
take ( msatoshi_val ) ,
2018-03-26 02:08:16 +02:00
take ( label_val ) ,
2018-02-28 17:26:58 +01:00
expiry ,
b11enc ,
& r ,
& rhash ) ;
if ( ! result ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD ,
" Failed to create invoice on database " ) ;
2018-02-28 17:26:58 +01:00
return ;
}
/* Get details */
wallet_invoice_details ( cmd , cmd - > ld - > wallet , invoice , & details ) ;
2016-09-06 09:17:49 +02:00
json_object_start ( response , NULL ) ;
2018-01-13 12:17:34 +01:00
json_add_hex ( response , " payment_hash " ,
2018-02-20 02:07:30 +01:00
& details . rhash , sizeof ( details . rhash ) ) ;
2018-01-19 10:53:24 +01:00
if ( deprecated_apis )
2018-02-20 02:07:30 +01:00
json_add_u64 ( response , " expiry_time " , details . expiry_time ) ;
json_add_u64 ( response , " expires_at " , details . expiry_time ) ;
2018-02-28 17:26:58 +01:00
json_add_string ( response , " bolt11 " , details . bolt11 ) ;
2016-09-06 09:17:49 +02:00
json_object_end ( response ) ;
command_success ( cmd , response ) ;
}
2017-01-04 04:38:15 +01:00
static const struct json_command invoice_command = {
2016-09-06 09:17:49 +02:00
" invoice " ,
json_invoice ,
2018-05-08 15:08:43 +02:00
" Create an invoice for {msatoshi} with {label} and {description} with optional {expiry} seconds (default 1 hour) and optional {preimage} (default autogenerated) "
2016-09-06 09:17:49 +02:00
} ;
2017-01-04 04:38:15 +01:00
AUTODATA ( json_command , & invoice_command ) ;
2016-09-06 09:17:49 +02:00
2016-09-06 09:17:49 +02:00
static void json_add_invoices ( struct json_result * response ,
2018-01-14 15:15:30 +01:00
struct wallet * wallet ,
2018-03-26 02:08:16 +02:00
const struct json_escaped * label ,
2018-01-17 04:04:29 +01:00
bool modern )
2016-09-06 09:17:49 +02:00
{
2018-02-24 13:11:14 +01:00
struct invoice_iterator it ;
2018-02-20 02:07:30 +01:00
struct invoice_details details ;
2016-09-06 09:17:49 +02:00
2018-06-14 06:50:47 +02:00
/* Don't iterate entire db if we're just after one. */
if ( label ) {
struct invoice invoice ;
if ( wallet_invoice_find_by_label ( wallet , & invoice , label ) ) {
wallet_invoice_details ( response , wallet , invoice ,
& details ) ;
json_add_invoice ( response , & details , modern ) ;
}
return ;
}
2018-02-24 13:11:14 +01:00
memset ( & it , 0 , sizeof ( it ) ) ;
while ( wallet_invoice_iterate ( wallet , & it ) ) {
wallet_invoice_iterator_deref ( response , wallet , & it , & details ) ;
2018-02-20 02:07:30 +01:00
json_add_invoice ( response , & details , modern ) ;
2016-09-06 09:17:49 +02:00
}
}
2018-01-16 21:29:32 +01:00
static void json_listinvoice_internal ( struct command * cmd ,
const char * buffer ,
const jsmntok_t * params ,
bool modern )
2016-09-06 09:17:49 +02:00
{
2018-07-16 22:48:38 +02:00
jsmntok_t * labeltok ;
2018-03-26 02:08:16 +02:00
struct json_escaped * label ;
2016-11-11 00:02:04 +01:00
struct json_result * response = new_json_result ( cmd ) ;
2018-01-14 15:15:30 +01:00
struct wallet * wallet = cmd - > ld - > wallet ;
2016-09-06 09:17:49 +02:00
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_opt_tok ( " label " , & labeltok ) ,
NULL ) )
2016-09-06 09:17:49 +02:00
return ;
2018-03-26 02:08:16 +02:00
if ( labeltok ) {
2018-03-28 04:00:37 +02:00
label = json_tok_label ( cmd , buffer , labeltok ) ;
2018-03-26 02:08:16 +02:00
if ( ! label ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" label '%.*s' is not a string or number " ,
2018-03-26 02:08:16 +02:00
labeltok - > end - labeltok - > start ,
buffer + labeltok - > start ) ;
return ;
}
} else
label = NULL ;
2018-01-16 21:29:32 +01:00
if ( modern ) {
json_object_start ( response , NULL ) ;
json_array_start ( response , " invoices " ) ;
} else
json_array_start ( response , NULL ) ;
2018-03-26 02:08:16 +02:00
json_add_invoices ( response , wallet , label , modern ) ;
2016-09-06 09:17:49 +02:00
json_array_end ( response ) ;
2018-01-16 21:29:32 +01:00
if ( modern )
json_object_end ( response ) ;
2016-09-06 09:17:49 +02:00
command_success ( cmd , response ) ;
}
2018-01-16 21:29:32 +01:00
/* FIXME: Deprecated! */
static void json_listinvoice ( struct command * cmd ,
const char * buffer , const jsmntok_t * params )
{
return json_listinvoice_internal ( cmd , buffer , params , false ) ;
}
2017-01-04 04:38:15 +01:00
static const struct json_command listinvoice_command = {
2016-09-06 09:17:49 +02:00
" listinvoice " ,
json_listinvoice ,
2018-01-16 21:28:46 +01:00
" (DEPRECATED) Show invoice {label} (or all, if no {label})) " ,
. deprecated = true
2016-09-06 09:17:49 +02:00
} ;
2017-01-04 04:38:15 +01:00
AUTODATA ( json_command , & listinvoice_command ) ;
2016-09-06 09:17:49 +02:00
2018-01-16 21:29:32 +01:00
static void json_listinvoices ( struct command * cmd ,
const char * buffer , const jsmntok_t * params )
{
return json_listinvoice_internal ( cmd , buffer , params , true ) ;
}
static const struct json_command listinvoices_command = {
2018-01-16 21:28:46 +01:00
" listinvoices " ,
json_listinvoices ,
2018-01-22 09:55:07 +01:00
" Show invoice {label} (or all, if no {label}) "
2018-01-16 21:28:46 +01:00
} ;
AUTODATA ( json_command , & listinvoices_command ) ;
2016-09-06 09:17:49 +02:00
static void json_delinvoice ( struct command * cmd ,
const char * buffer , const jsmntok_t * params )
{
2018-02-23 02:04:47 +01:00
struct invoice i ;
2018-02-20 02:07:30 +01:00
struct invoice_details details ;
2018-07-16 22:48:38 +02:00
const jsmntok_t * labeltok , * statustok ;
2016-09-06 09:17:49 +02:00
struct json_result * response = new_json_result ( cmd ) ;
2018-03-26 02:08:16 +02:00
const char * status , * actual_status ;
struct json_escaped * label ;
2018-01-14 15:15:30 +01:00
struct wallet * wallet = cmd - > ld - > wallet ;
2016-09-06 09:17:49 +02:00
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_req ( " label " , json_tok_tok , & labeltok ) ,
p_req ( " status " , json_tok_tok , & statustok ) ,
NULL ) )
2016-09-06 09:17:49 +02:00
return ;
2018-03-28 04:00:37 +02:00
label = json_tok_label ( cmd , buffer , labeltok ) ;
2018-03-26 02:08:16 +02:00
if ( ! label ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" label '%.*s' is not a string or number " ,
2018-03-26 02:08:16 +02:00
labeltok - > end - labeltok - > start ,
buffer + labeltok - > start ) ;
return ;
}
2018-02-23 02:04:47 +01:00
if ( ! wallet_invoice_find_by_label ( wallet , & i , label ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Unknown invoice " ) ;
2016-09-06 09:17:49 +02:00
return ;
}
2018-02-20 02:07:30 +01:00
wallet_invoice_details ( cmd , cmd - > ld - > wallet , i , & details ) ;
2017-10-05 23:29:56 +02:00
2018-01-18 04:57:16 +01:00
status = tal_strndup ( cmd , buffer + statustok - > start ,
statustok - > end - statustok - > start ) ;
/* This is time-sensitive, so only call once; otherwise error msg
* might not make sense if it changed ! */
2018-02-20 02:07:30 +01:00
actual_status = invoice_status_str ( & details ) ;
2018-01-18 04:57:16 +01:00
if ( ! streq ( actual_status , status ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Invoice status is %s not %s " ,
2018-01-18 04:57:16 +01:00
actual_status , status ) ;
return ;
}
2017-12-27 12:51:58 +01:00
/* Get invoice details before attempting to delete, as
* otherwise the invoice will be freed . */
2018-02-20 02:07:30 +01:00
json_add_invoice ( response , & details , true ) ;
2017-12-27 12:51:58 +01:00
2018-01-18 04:55:43 +01:00
if ( ! wallet_invoice_delete ( wallet , i ) ) {
log_broken ( cmd - > ld - > log ,
" Error attempting to remove invoice % " PRIu64 ,
2018-02-23 02:04:47 +01:00
i . id ) ;
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Database error " ) ;
2017-12-27 12:51:58 +01:00
return ;
}
2016-09-06 09:17:49 +02:00
command_success ( cmd , response ) ;
}
2017-01-04 04:38:15 +01:00
static const struct json_command delinvoice_command = {
2016-09-06 09:17:49 +02:00
" delinvoice " ,
json_delinvoice ,
2018-01-18 04:57:16 +01:00
" Delete unpaid invoice {label} with {status} " ,
2016-09-06 09:17:49 +02:00
} ;
2017-01-04 04:38:15 +01:00
AUTODATA ( json_command , & delinvoice_command ) ;
2016-09-06 09:17:49 +02:00
2018-02-26 13:37:53 +01:00
static void json_delexpiredinvoice ( struct command * cmd , const char * buffer ,
const jsmntok_t * params )
{
2018-07-16 22:48:38 +02:00
u64 maxexpirytime ;
2018-02-26 13:37:53 +01:00
struct json_result * result ;
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_opt_def ( " maxexpirytime " , json_tok_u64 , & maxexpirytime ,
time_now ( ) . ts . tv_sec ) ,
NULL ) )
2018-02-26 13:37:53 +01:00
return ;
wallet_invoice_delete_expired ( cmd - > ld - > wallet , maxexpirytime ) ;
result = new_json_result ( cmd ) ;
json_object_start ( result , NULL ) ;
json_object_end ( result ) ;
command_success ( cmd , result ) ;
}
static const struct json_command delexpiredinvoice_command = {
" delexpiredinvoice " ,
json_delexpiredinvoice ,
" Delete all expired invoices that expired as of given {maxexpirytime} (a UNIX epoch time), or all expired invoices if not specified "
} ;
AUTODATA ( json_command , & delexpiredinvoice_command ) ;
2018-03-17 16:12:37 +01:00
static void json_autocleaninvoice ( struct command * cmd ,
const char * buffer ,
const jsmntok_t * params )
{
2018-07-16 22:48:38 +02:00
u64 cycle ;
u64 exby ;
2018-03-17 16:12:37 +01:00
struct json_result * result ;
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_opt_def ( " cycle_seconds " , json_tok_u64 , & cycle , 3600 ) ,
p_opt_def ( " expired_by " , json_tok_u64 , & exby , 86400 ) ,
NULL ) )
2018-03-17 16:12:37 +01:00
return ;
wallet_invoice_autoclean ( cmd - > ld - > wallet , cycle , exby ) ;
result = new_json_result ( cmd ) ;
json_object_start ( result , NULL ) ;
json_object_end ( result ) ;
command_success ( cmd , result ) ;
}
static const struct json_command autocleaninvoice_command = {
" autocleaninvoice " ,
json_autocleaninvoice ,
" Set up autoclean of expired invoices. "
" Perform cleanup every {cycle_seconds} (default 3600), or disable autoclean if 0. "
" Clean up expired invoices that have expired for {expired_by} seconds (default 86400). "
} ;
AUTODATA ( json_command , & autocleaninvoice_command ) ;
2017-01-17 22:09:09 +01:00
static void json_waitanyinvoice ( struct command * cmd ,
2016-09-06 09:17:49 +02:00
const char * buffer , const jsmntok_t * params )
{
2017-12-26 23:58:42 +01:00
u64 pay_index ;
2017-12-26 14:47:27 +01:00
struct wallet * wallet = cmd - > ld - > wallet ;
2016-09-06 09:17:49 +02:00
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_opt_def ( " lastpay_index " , json_tok_u64 , & pay_index , 0 ) ,
NULL ) )
2016-09-06 09:17:49 +02:00
return ;
2017-12-26 14:47:27 +01:00
2018-01-14 15:15:30 +01:00
/* Set command as pending. We do not know if
* wallet_invoice_waitany will return immediately
* or not , so indicating pending is safest . */
2017-12-15 11:15:54 +01:00
command_still_pending ( cmd ) ;
2018-01-14 15:15:30 +01:00
/* Find next paid invoice. */
wallet_invoice_waitany ( cmd , wallet , pay_index ,
& wait_on_invoice , ( void * ) cmd ) ;
2016-09-06 09:17:49 +02:00
}
2017-01-17 22:09:09 +01:00
static const struct json_command waitanyinvoice_command = {
" waitanyinvoice " ,
json_waitanyinvoice ,
2018-01-22 09:55:07 +01:00
" Wait for the next invoice to be paid, after {lastpay_index} (if supplied) "
2016-09-06 09:17:49 +02:00
} ;
2017-01-17 22:09:09 +01:00
AUTODATA ( json_command , & waitanyinvoice_command ) ;
2017-01-10 12:18:40 +01:00
/* Wait for an incoming payment matching the `label` in the JSON
* command . This will either return immediately if the payment has
* already been received or it may add the ` cmd ` to the list of
* waiters , if the payment is still pending .
*/
2017-01-17 22:09:09 +01:00
static void json_waitinvoice ( struct command * cmd ,
2017-01-10 12:18:40 +01:00
const char * buffer , const jsmntok_t * params )
{
2018-02-23 02:04:47 +01:00
struct invoice i ;
2018-02-20 02:07:30 +01:00
struct invoice_details details ;
2018-01-14 15:15:30 +01:00
struct wallet * wallet = cmd - > ld - > wallet ;
2018-07-16 22:48:38 +02:00
const jsmntok_t * labeltok ;
2018-03-26 02:08:16 +02:00
struct json_escaped * label ;
2017-01-10 12:18:40 +01:00
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_req ( " label " , json_tok_tok , & labeltok ) ,
NULL ) )
2017-01-10 12:18:40 +01:00
return ;
2018-02-23 02:04:47 +01:00
/* Search for invoice */
2018-03-28 04:00:37 +02:00
label = json_tok_label ( cmd , buffer , labeltok ) ;
2018-03-26 02:08:16 +02:00
if ( ! label ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , JSONRPC2_INVALID_PARAMS ,
" label '%.*s' is not a string or number " ,
2018-03-26 02:08:16 +02:00
labeltok - > end - labeltok - > start ,
buffer + labeltok - > start ) ;
return ;
}
2018-02-23 02:04:47 +01:00
if ( ! wallet_invoice_find_by_label ( wallet , & i , label ) ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Label not found " ) ;
2017-01-10 12:18:40 +01:00
return ;
2018-02-20 02:07:30 +01:00
}
wallet_invoice_details ( cmd , cmd - > ld - > wallet , i , & details ) ;
2018-02-23 02:04:47 +01:00
/* If paid or expired return immediately */
2018-02-20 02:07:30 +01:00
if ( details . state = = PAID | | details . state = = EXPIRED ) {
2018-02-23 02:04:47 +01:00
tell_waiter ( cmd , & i ) ;
2017-10-03 18:31:07 +02:00
return ;
} else {
/* There is an unpaid one matching, let's wait... */
2017-12-15 11:15:54 +01:00
command_still_pending ( cmd ) ;
2018-01-14 15:15:30 +01:00
wallet_invoice_waitone ( cmd , wallet , i ,
& wait_on_invoice , ( void * ) cmd ) ;
2017-01-10 12:18:40 +01:00
}
}
2017-01-17 22:09:09 +01:00
static const struct json_command waitinvoice_command = {
" waitinvoice " ,
json_waitinvoice ,
2018-01-23 02:02:10 +01:00
" Wait for an incoming payment matching the invoice with {label}, or if the invoice expires "
2017-01-10 12:18:40 +01:00
} ;
2017-01-17 22:09:09 +01:00
AUTODATA ( json_command , & waitinvoice_command ) ;
2017-11-22 01:25:39 +01:00
2018-04-05 07:13:51 +02:00
static void json_add_fallback ( struct json_result * response ,
const char * fieldname ,
const u8 * fallback ,
const struct chainparams * chain )
{
struct bitcoin_address pkh ;
struct ripemd160 sh ;
struct sha256 wsh ;
json_object_start ( response , fieldname ) ;
if ( is_p2pkh ( fallback , & pkh ) ) {
json_add_string ( response , " type " , " P2PKH " ) ;
json_add_string ( response , " addr " ,
bitcoin_to_base58 ( tmpctx , chain - > testnet , & pkh ) ) ;
} else if ( is_p2sh ( fallback , & sh ) ) {
json_add_string ( response , " type " , " P2SH " ) ;
json_add_string ( response , " addr " ,
p2sh_to_base58 ( tmpctx , chain - > testnet , & sh ) ) ;
} else if ( is_p2wpkh ( fallback , & pkh ) ) {
char out [ 73 + strlen ( chain - > bip173_name ) ] ;
json_add_string ( response , " type " , " P2WPKH " ) ;
if ( segwit_addr_encode ( out , chain - > bip173_name , 0 ,
( const u8 * ) & pkh , sizeof ( pkh ) ) )
json_add_string ( response , " addr " , out ) ;
} else if ( is_p2wsh ( fallback , & wsh ) ) {
char out [ 73 + strlen ( chain - > bip173_name ) ] ;
json_add_string ( response , " type " , " P2WSH " ) ;
if ( segwit_addr_encode ( out , chain - > bip173_name , 0 ,
( const u8 * ) & wsh , sizeof ( wsh ) ) )
json_add_string ( response , " addr " , out ) ;
}
json_add_hex ( response , " hex " , fallback , tal_len ( fallback ) ) ;
json_object_end ( response ) ;
}
2017-11-22 01:25:39 +01:00
static void json_decodepay ( struct command * cmd ,
const char * buffer , const jsmntok_t * params )
{
2018-07-16 22:48:38 +02:00
const jsmntok_t * bolt11tok , * desctok ;
2017-11-22 01:25:39 +01:00
struct bolt11 * b11 ;
struct json_result * response ;
char * str , * desc , * fail ;
2018-07-16 22:48:38 +02:00
if ( ! param ( cmd , buffer , params ,
p_req ( " bolt11 " , json_tok_tok , & bolt11tok ) ,
p_opt_tok ( " description " , & desctok ) ,
NULL ) )
2017-11-22 01:25:39 +01:00
return ;
str = tal_strndup ( cmd , buffer + bolt11tok - > start ,
bolt11tok - > end - bolt11tok - > start ) ;
if ( desctok )
desc = tal_strndup ( cmd , buffer + desctok - > start ,
desctok - > end - desctok - > start ) ;
else
desc = NULL ;
b11 = bolt11_decode ( cmd , str , desc , & fail ) ;
if ( ! b11 ) {
2018-05-24 23:40:18 +02:00
command_fail ( cmd , LIGHTNINGD , " Invalid bolt11: %s " , fail ) ;
2017-11-22 01:25:39 +01:00
return ;
}
response = new_json_result ( cmd ) ;
json_object_start ( response , NULL ) ;
json_add_string ( response , " currency " , b11 - > chain - > bip173_name ) ;
2018-01-19 10:53:24 +01:00
if ( deprecated_apis )
json_add_u64 ( response , " timestamp " , b11 - > timestamp ) ;
json_add_u64 ( response , " created_at " , b11 - > timestamp ) ;
2017-11-22 01:25:39 +01:00
json_add_u64 ( response , " expiry " , b11 - > expiry ) ;
json_add_pubkey ( response , " payee " , & b11 - > receiver_id ) ;
if ( b11 - > msatoshi )
json_add_u64 ( response , " msatoshi " , * b11 - > msatoshi ) ;
2018-03-26 02:08:47 +02:00
if ( b11 - > description ) {
struct json_escaped * esc = json_escape ( NULL , b11 - > description ) ;
json_add_escaped_string ( response , " description " , take ( esc ) ) ;
}
2017-11-22 01:25:39 +01:00
if ( b11 - > description_hash )
json_add_hex ( response , " description_hash " ,
b11 - > description_hash ,
sizeof ( * b11 - > description_hash ) ) ;
2018-01-16 20:44:32 +01:00
json_add_num ( response , " min_final_cltv_expiry " ,
b11 - > min_final_cltv_expiry ) ;
2018-04-05 07:13:51 +02:00
if ( tal_count ( b11 - > fallbacks ) ) {
if ( deprecated_apis )
json_add_fallback ( response , " fallback " ,
b11 - > fallbacks [ 0 ] , b11 - > chain ) ;
json_array_start ( response , " fallbacks " ) ;
for ( size_t i = 0 ; i < tal_count ( b11 - > fallbacks ) ; i + + )
json_add_fallback ( response , NULL ,
b11 - > fallbacks [ i ] , b11 - > chain ) ;
json_array_end ( response ) ;
2017-11-22 01:25:39 +01:00
}
if ( tal_count ( b11 - > routes ) ) {
size_t i , n ;
json_array_start ( response , " routes " ) ;
for ( i = 0 ; i < tal_count ( b11 - > routes ) ; i + + ) {
json_array_start ( response , NULL ) ;
for ( n = 0 ; n < tal_count ( b11 - > routes [ i ] ) ; n + + ) {
json_object_start ( response , NULL ) ;
json_add_pubkey ( response , " pubkey " ,
& b11 - > routes [ i ] [ n ] . pubkey ) ;
json_add_short_channel_id ( response ,
" short_channel_id " ,
& b11 - > routes [ i ] [ n ]
. short_channel_id ) ;
2017-12-12 01:34:07 +01:00
json_add_u64 ( response , " fee_base_msat " ,
b11 - > routes [ i ] [ n ] . fee_base_msat ) ;
json_add_u64 ( response , " fee_proportional_millionths " ,
b11 - > routes [ i ] [ n ] . fee_proportional_millionths ) ;
2017-11-22 01:25:39 +01:00
json_add_num ( response , " cltv_expiry_delta " ,
b11 - > routes [ i ] [ n ]
. cltv_expiry_delta ) ;
json_object_end ( response ) ;
}
json_array_end ( response ) ;
}
json_array_end ( response ) ;
}
if ( ! list_empty ( & b11 - > extra_fields ) ) {
struct bolt11_field * extra ;
json_array_start ( response , " extra " ) ;
list_for_each ( & b11 - > extra_fields , extra , list ) {
char * data = tal_arr ( cmd , char , tal_len ( extra - > data ) + 1 ) ;
size_t i ;
for ( i = 0 ; i < tal_len ( extra - > data ) ; i + + )
data [ i ] = bech32_charset [ extra - > data [ i ] ] ;
data [ i ] = ' \0 ' ;
json_object_start ( response , NULL ) ;
json_add_string ( response , " tag " ,
tal_fmt ( data , " %c " , extra - > tag ) ) ;
json_add_string ( response , " data " , data ) ;
tal_free ( data ) ;
json_object_end ( response ) ;
}
json_array_end ( response ) ;
}
json_add_hex ( response , " payment_hash " ,
& b11 - > payment_hash , sizeof ( b11 - > payment_hash ) ) ;
json_add_string ( response , " signature " ,
type_to_string ( cmd , secp256k1_ecdsa_signature ,
& b11 - > sig ) ) ;
json_object_end ( response ) ;
command_success ( cmd , response ) ;
}
static const struct json_command decodepay_command = {
" decodepay " ,
json_decodepay ,
2018-01-22 09:55:07 +01:00
" Decode {bolt11}, using {description} if necessary "
2017-11-22 01:25:39 +01:00
} ;
AUTODATA ( json_command , & decodepay_command ) ;