mirror of
https://github.com/ElementsProject/lightning.git
synced 2024-11-19 18:11:28 +01:00
183 lines
6.5 KiB
C
183 lines
6.5 KiB
C
#include "config.h"
|
|
#include "../seeker.c"
|
|
#include <ccan/err/err.h>
|
|
#include <common/blinding.h>
|
|
#include <common/channel_type.h>
|
|
#include <common/ecdh.h>
|
|
#include <common/json_stream.h>
|
|
#include <common/onionreply.h>
|
|
#include <common/setup.h>
|
|
#include <common/wireaddr.h>
|
|
#include <stdio.h>
|
|
|
|
/* AUTOGENERATED MOCKS START */
|
|
/* Generated stub for blinding_hash_e_and_ss */
|
|
void blinding_hash_e_and_ss(const struct pubkey *e UNNEEDED,
|
|
const struct secret *ss UNNEEDED,
|
|
struct sha256 *sha UNNEEDED)
|
|
{ fprintf(stderr, "blinding_hash_e_and_ss called!\n"); abort(); }
|
|
/* Generated stub for blinding_next_privkey */
|
|
bool blinding_next_privkey(const struct privkey *e UNNEEDED,
|
|
const struct sha256 *h UNNEEDED,
|
|
struct privkey *next UNNEEDED)
|
|
{ fprintf(stderr, "blinding_next_privkey called!\n"); abort(); }
|
|
/* Generated stub for blinding_next_pubkey */
|
|
bool blinding_next_pubkey(const struct pubkey *pk UNNEEDED,
|
|
const struct sha256 *h UNNEEDED,
|
|
struct pubkey *next UNNEEDED)
|
|
{ fprintf(stderr, "blinding_next_pubkey called!\n"); abort(); }
|
|
/* Generated stub for ecdh */
|
|
void ecdh(const struct pubkey *point UNNEEDED, struct secret *ss UNNEEDED)
|
|
{ fprintf(stderr, "ecdh called!\n"); abort(); }
|
|
/* Generated stub for fmt_wireaddr_without_port */
|
|
char *fmt_wireaddr_without_port(const tal_t *ctx UNNEEDED, const struct wireaddr *a UNNEEDED)
|
|
{ fprintf(stderr, "fmt_wireaddr_without_port called!\n"); abort(); }
|
|
/* Generated stub for fromwire_wireaddr */
|
|
bool fromwire_wireaddr(const u8 **cursor UNNEEDED, size_t *max UNNEEDED, struct wireaddr *addr UNNEEDED)
|
|
{ fprintf(stderr, "fromwire_wireaddr called!\n"); abort(); }
|
|
/* Generated stub for json_add_member */
|
|
void json_add_member(struct json_stream *js UNNEEDED,
|
|
const char *fieldname UNNEEDED,
|
|
bool quote UNNEEDED,
|
|
const char *fmt UNNEEDED, ...)
|
|
{ fprintf(stderr, "json_add_member called!\n"); abort(); }
|
|
/* Generated stub for json_member_direct */
|
|
char *json_member_direct(struct json_stream *js UNNEEDED,
|
|
const char *fieldname UNNEEDED, size_t extra UNNEEDED)
|
|
{ fprintf(stderr, "json_member_direct called!\n"); abort(); }
|
|
/* Generated stub for json_object_end */
|
|
void json_object_end(struct json_stream *js UNNEEDED)
|
|
{ fprintf(stderr, "json_object_end called!\n"); abort(); }
|
|
/* Generated stub for json_object_start */
|
|
void json_object_start(struct json_stream *ks UNNEEDED, const char *fieldname UNNEEDED)
|
|
{ fprintf(stderr, "json_object_start called!\n"); abort(); }
|
|
/* Generated stub for new_onionreply */
|
|
struct onionreply *new_onionreply(const tal_t *ctx UNNEEDED, const u8 *contents TAKES UNNEEDED)
|
|
{ fprintf(stderr, "new_onionreply called!\n"); abort(); }
|
|
/* Generated stub for new_reltimer_ */
|
|
struct oneshot *new_reltimer_(struct timers *timers UNNEEDED,
|
|
const tal_t *ctx UNNEEDED,
|
|
struct timerel expire UNNEEDED,
|
|
void (*cb)(void *) UNNEEDED, void *arg UNNEEDED)
|
|
{ fprintf(stderr, "new_reltimer_ called!\n"); abort(); }
|
|
/* Generated stub for query_channel_range */
|
|
bool query_channel_range(struct daemon *daemon UNNEEDED,
|
|
struct peer *peer UNNEEDED,
|
|
u32 first_blocknum UNNEEDED, u32 number_of_blocks UNNEEDED,
|
|
enum query_option_flags qflags UNNEEDED,
|
|
void (*cb)(struct peer *peer UNNEEDED,
|
|
u32 first_blocknum UNNEEDED, u32 number_of_blocks UNNEEDED,
|
|
const struct range_query_reply *replies))
|
|
{ fprintf(stderr, "query_channel_range called!\n"); abort(); }
|
|
/* Generated stub for query_short_channel_ids */
|
|
bool query_short_channel_ids(struct daemon *daemon UNNEEDED,
|
|
struct peer *peer UNNEEDED,
|
|
const struct short_channel_id *scids UNNEEDED,
|
|
const u8 *query_flags UNNEEDED,
|
|
void (*cb)(struct peer *peer UNNEEDED, bool complete))
|
|
{ fprintf(stderr, "query_short_channel_ids called!\n"); abort(); }
|
|
/* Generated stub for queue_peer_msg */
|
|
void queue_peer_msg(struct peer *peer UNNEEDED, const u8 *msg TAKES UNNEEDED)
|
|
{ fprintf(stderr, "queue_peer_msg called!\n"); abort(); }
|
|
/* Generated stub for random_peer */
|
|
struct peer *random_peer(struct daemon *daemon UNNEEDED,
|
|
bool (*check_peer)(const struct peer *peer))
|
|
{ fprintf(stderr, "random_peer called!\n"); abort(); }
|
|
/* Generated stub for random_select */
|
|
bool random_select(double weight UNNEEDED, double *tot_weight UNNEEDED)
|
|
{ fprintf(stderr, "random_select called!\n"); abort(); }
|
|
/* Generated stub for status_failed */
|
|
void status_failed(enum status_failreason code UNNEEDED,
|
|
const char *fmt UNNEEDED, ...)
|
|
{ fprintf(stderr, "status_failed called!\n"); abort(); }
|
|
/* Generated stub for status_fmt */
|
|
void status_fmt(enum log_level level UNNEEDED,
|
|
const struct node_id *peer UNNEEDED,
|
|
const char *fmt UNNEEDED, ...)
|
|
|
|
{ fprintf(stderr, "status_fmt called!\n"); abort(); }
|
|
/* Generated stub for towire_wireaddr */
|
|
void towire_wireaddr(u8 **pptr UNNEEDED, const struct wireaddr *addr UNNEEDED)
|
|
{ fprintf(stderr, "towire_wireaddr called!\n"); abort(); }
|
|
/* Generated stub for would_ratelimit_cupdate */
|
|
bool would_ratelimit_cupdate(struct routing_state *rstate UNNEEDED,
|
|
const struct half_chan *hc UNNEEDED,
|
|
u32 timestamp UNNEEDED)
|
|
{ fprintf(stderr, "would_ratelimit_cupdate called!\n"); abort(); }
|
|
/* AUTOGENERATED MOCKS END */
|
|
|
|
static void test_block_range(struct seeker *seeker,
|
|
u32 blockheight,
|
|
u32 first, u32 last,
|
|
...)
|
|
{
|
|
int start, end, num;
|
|
u32 first_blocknum, number_of_blocks;
|
|
va_list ap;
|
|
|
|
seeker->daemon->current_blockheight = blockheight;
|
|
seeker->scid_probe_start = first;
|
|
seeker->scid_probe_end = last;
|
|
|
|
num = last - first + 1;
|
|
va_start(ap, last);
|
|
while ((start = va_arg(ap, int)) != -1) {
|
|
end = va_arg(ap, int);
|
|
if (!next_block_range(seeker, num,
|
|
&first_blocknum, &number_of_blocks))
|
|
abort();
|
|
if (first_blocknum != start
|
|
|| number_of_blocks != end - start + 1) {
|
|
errx(1, "Expected %u-%u but got %u-%u",
|
|
start, end,
|
|
first_blocknum, first_blocknum+number_of_blocks-1);
|
|
}
|
|
num = end - start + 1;
|
|
}
|
|
if (next_block_range(seeker, num, &first_blocknum, &number_of_blocks))
|
|
abort();
|
|
va_end(ap);
|
|
}
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
struct seeker *seeker = tal(NULL, struct seeker);
|
|
|
|
common_setup(argv[0]);
|
|
|
|
seeker->daemon = tal(seeker, struct daemon);
|
|
|
|
/* Case where we start at beginning */
|
|
test_block_range(seeker, 100,
|
|
0, 0,
|
|
1, 2,
|
|
3, 6,
|
|
7, 14,
|
|
15, 30,
|
|
31, 62,
|
|
63, 100,
|
|
-1);
|
|
|
|
/* Case where we start at end */
|
|
test_block_range(seeker, 100,
|
|
100, 100,
|
|
98, 99,
|
|
94, 97,
|
|
86, 93,
|
|
70, 85,
|
|
38, 69,
|
|
0, 37,
|
|
-1);
|
|
|
|
/* Start in the middle. */
|
|
test_block_range(seeker, 100,
|
|
50, 59,
|
|
30, 49,
|
|
0, 29,
|
|
60, 100,
|
|
-1);
|
|
|
|
tal_free(seeker);
|
|
common_shutdown();
|
|
}
|