mirror of
https://github.com/ElementsProject/lightning.git
synced 2024-11-19 18:11:28 +01:00
3510c29e5d
Now that we have json_stream in common/, we can move all the related helpers from lightningd/json to common/json. This way everyone can benefit of them (including libplugin, the plugins themselves, potentially lightning-cli), not lightningd alone! Note that the Makefile of the common/test/ had to be modified, because the new helpers make use of common/wireaddr... Which turns out to \#include <lightingd/lightningd.h> ! So we couldnt just include the .c and add mocks if we redefined some structs (hello run-param).
116 lines
4.6 KiB
C
116 lines
4.6 KiB
C
#include "../log.c"
|
|
#include <common/wireaddr.h>
|
|
|
|
/* AUTOGENERATED MOCKS START */
|
|
/* Generated stub for bigsize_get */
|
|
size_t bigsize_get(const u8 *p UNNEEDED, size_t max UNNEEDED, bigsize_t *val UNNEEDED)
|
|
{ fprintf(stderr, "bigsize_get called!\n"); abort(); }
|
|
/* Generated stub for bigsize_put */
|
|
size_t bigsize_put(u8 buf[BIGSIZE_MAX_LEN] UNNEEDED, bigsize_t v UNNEEDED)
|
|
{ fprintf(stderr, "bigsize_put called!\n"); abort(); }
|
|
/* Generated stub for command_fail */
|
|
struct command_result *command_fail(struct command *cmd UNNEEDED, errcode_t code UNNEEDED,
|
|
const char *fmt UNNEEDED, ...)
|
|
|
|
{ fprintf(stderr, "command_fail called!\n"); abort(); }
|
|
/* Generated stub for command_param_failed */
|
|
struct command_result *command_param_failed(void)
|
|
|
|
{ fprintf(stderr, "command_param_failed called!\n"); abort(); }
|
|
/* Generated stub for command_success */
|
|
struct command_result *command_success(struct command *cmd UNNEEDED,
|
|
struct json_stream *response)
|
|
|
|
{ fprintf(stderr, "command_success 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 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_array_end */
|
|
void json_array_end(struct json_stream *js UNNEEDED)
|
|
{ fprintf(stderr, "json_array_end called!\n"); abort(); }
|
|
/* Generated stub for json_array_start */
|
|
void json_array_start(struct json_stream *js UNNEEDED, const char *fieldname UNNEEDED)
|
|
{ fprintf(stderr, "json_array_start 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 json_stream_log_suppress_for_cmd */
|
|
void json_stream_log_suppress_for_cmd(struct json_stream *js UNNEEDED,
|
|
const struct command *cmd UNNEEDED)
|
|
{ fprintf(stderr, "json_stream_log_suppress_for_cmd called!\n"); abort(); }
|
|
/* Generated stub for json_stream_success */
|
|
struct json_stream *json_stream_success(struct command *cmd UNNEEDED)
|
|
{ fprintf(stderr, "json_stream_success called!\n"); abort(); }
|
|
/* Generated stub for node_id_to_hexstr */
|
|
char *node_id_to_hexstr(const tal_t *ctx UNNEEDED, const struct node_id *id UNNEEDED)
|
|
{ fprintf(stderr, "node_id_to_hexstr called!\n"); abort(); }
|
|
/* Generated stub for notify_warning */
|
|
void notify_warning(struct lightningd *ld UNNEEDED, struct log_entry *l UNNEEDED)
|
|
{ fprintf(stderr, "notify_warning called!\n"); abort(); }
|
|
/* Generated stub for param */
|
|
bool param(struct command *cmd UNNEEDED, const char *buffer UNNEEDED,
|
|
const jsmntok_t params[] UNNEEDED, ...)
|
|
{ fprintf(stderr, "param called!\n"); abort(); }
|
|
/* AUTOGENERATED MOCKS END */
|
|
|
|
int main(void)
|
|
{
|
|
struct log_book *lb;
|
|
struct log *l;
|
|
|
|
setup_locale();
|
|
lb = new_log_book(NULL,
|
|
(sizeof(struct log_entry) + sizeof("test XXXXXX"))
|
|
*100);
|
|
l = new_log(lb, lb, NULL, "test %s", "prefix");
|
|
|
|
assert(streq(log_prefix(l), "test prefix"));
|
|
|
|
for (size_t i = 0; i < 100; i++)
|
|
log_debug(l, "test %06zi", i);
|
|
|
|
assert(lb->num_entries == 100);
|
|
for (size_t i = 0; i < 100; i++) {
|
|
assert(lb->log[i].level == LOG_DBG);
|
|
assert(lb->log[i].skipped == 0);
|
|
assert(lb->log[i].nc == NULL);
|
|
assert(streq(lb->log[i].prefix, "test prefix"));
|
|
assert(streq(lb->log[i].log, tal_fmt(lb, "test %06zi", i)));
|
|
assert(lb->log[i].io == NULL);
|
|
}
|
|
|
|
log_debug(l, "final test message");
|
|
assert(lb->num_entries < 100);
|
|
assert(lb->num_entries > 11);
|
|
|
|
/* last 10% must be preserved exactly (with final and pruning
|
|
* msg appended) */
|
|
for (size_t i = 91; i < 100; i++) {
|
|
size_t pos = lb->num_entries - 2 - (100 - i);
|
|
assert(streq(lb->log[pos].log, tal_fmt(lb, "test %06zi", i)));
|
|
}
|
|
assert(streq(lb->log[lb->num_entries - 2].log, "final test message"));
|
|
|
|
/* Sum should still reflect 102 total messages */
|
|
size_t total = 0;
|
|
for (size_t i = 0; i < lb->num_entries; i++)
|
|
total += 1 + lb->log[i].skipped;
|
|
assert(total == 102);
|
|
|
|
/* Freeing (last) log frees logbook */
|
|
tal_free(l);
|
|
}
|