laantungir/didactyl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity
Files
v0.2.43
didactyl/src/main.c
T

1708 lines
59 KiB
C
Raw Permalink Blame History

#define _POSIX_C_SOURCE 200809L
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <errno.h>
#include <sys/socket.h>
#include <sys/un.h>
#include "../nostr_core_lib/nostr_core/nostr_core.h"
#include "main.h"
#include "agent.h"
#include "config.h"
#include "llm.h"
#include "nostr_handler.h"
#include "debug.h"
#include "trigger_manager.h"
#include "tools/tools.h"
#include "cjson/cJSON.h"
#include "http_api.h"
#include "setup_wizard.h"
#include "cashu_wallet.h"
#include "nostr_block_list.h"
#include "mongoose.h"
static volatile sig_atomic_t g_running = 1;
typedef struct {
trigger_manager_t* trigger_manager;
int loaded_once;
} deferred_trigger_load_ctx_t;
static void on_self_skill_eose_load_triggers(int event_count, void* user_data) {
deferred_trigger_load_ctx_t* ctx = (deferred_trigger_load_ctx_t*)user_data;
if (!ctx || !ctx->trigger_manager) {
return;
}
if (ctx->loaded_once) {
DEBUG_TRACE("[didactyl] deferred trigger load skipped (already loaded once) event_count=%d", event_count);
return;
}
DEBUG_INFO("[didactyl] deferred trigger load begin after self-skill EOSE (event_count=%d)", event_count);
if (trigger_manager_load_from_skills(ctx->trigger_manager) != 0) {
DEBUG_WARN("[didactyl] deferred trigger load failed after self-skill EOSE");
return;
}
ctx->loaded_once = 1;
char* status = trigger_manager_status_json(ctx->trigger_manager);
if (status) {
DEBUG_INFO("[didactyl] deferred trigger load status: %s", status);
free(status);
}
}
static volatile sig_atomic_t g_sigint_count = 0;
static void signal_handler(int signum) {
if (signum == SIGINT) {
g_sigint_count++;
if (g_sigint_count >= 2) {
_exit(130);
}
}
g_running = 0;
}
static int systemd_notify_send(const char* state) {
if (!state || state[0] == '\0') {
return 0;
}
const char* notify_socket = getenv("NOTIFY_SOCKET");
if (!notify_socket || notify_socket[0] == '\0') {
return 0;
}
if (notify_socket[0] != '/' && notify_socket[0] != '@') {
return -1;
}
int fd = socket(AF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC, 0);
if (fd < 0) {
return -1;
}
struct sockaddr_un addr;
memset(&addr, 0, sizeof(addr));
addr.sun_family = AF_UNIX;
size_t path_len = strlen(notify_socket);
if (path_len >= sizeof(addr.sun_path)) {
close(fd);
return -1;
}
memcpy(addr.sun_path, notify_socket, path_len + 1);
socklen_t addr_len = (socklen_t)(sizeof(sa_family_t) + path_len + 1U);
if (notify_socket[0] == '@') {
addr.sun_path[0] = '\0';
addr_len = (socklen_t)(sizeof(sa_family_t) + path_len);
}
ssize_t sent = sendto(fd,
state,
strlen(state),
MSG_NOSIGNAL,
(const struct sockaddr*)&addr,
addr_len);
int saved_errno = errno;
close(fd);
errno = saved_errno;
if (sent < 0) {
return -1;
}
return 1;
}
static void configure_mongoose_log_level_from_debug(void) {
if (g_debug_level >= DEBUG_LEVEL_TRACE) {
mg_log_set(MG_LL_INFO);
} else if (g_debug_level >= DEBUG_LEVEL_DEBUG) {
mg_log_set(MG_LL_INFO);
} else if (g_debug_level >= DEBUG_LEVEL_INFO) {
mg_log_set(MG_LL_INFO);
} else if (g_debug_level >= DEBUG_LEVEL_WARN) {
mg_log_set(MG_LL_ERROR);
} else {
mg_log_set(MG_LL_NONE);
}
}
static void print_usage(const char* prog) {
const char* p = prog ? prog : "didactyl";
fprintf(stderr,
"Didactyl - sovereign Nostr agent\n\n"
"Usage:\n"
" %s [options]\n\n"
"Options:\n"
" -h, --help\n"
" Show this help text and exit.\n"
" -v, --version\n"
" Show version and exit.\n"
" --config <path>\n"
" Path to config/genesis JSONC file (default: ./genesis.jsonc).\n"
" If file is missing, startup falls back to minimal nsec-only mode.\n"
" --nsec <nsec_or_hex>\n"
" Private key as nsec1... or 64-char hex; overrides DIDACTYL_NSEC.\n"
" --admin <npub_or_hex>\n"
" Administrator pubkey override; accepts npub1... or 64-char hex.\n"
" --api-port <port>\n"
" Enable HTTP API and bind to this port (1-65535).\n"
" --api-bind <addr>\n"
" Enable HTTP API and bind address (example: 127.0.0.1).\n"
" --debug <0-5>\n"
" Log level (0=fatal, 1=error, 2=warn, 3=info, 4=debug, 5=trace).\n"
" --dump-schemas\n"
" Print tool schemas JSON and exit.\n"
" --test-tool <name> <args_json>\n"
" Execute one tool call locally and print JSON result, then exit.\n"
"\n"
"Environment:\n"
" DIDACTYL_NSEC\n"
" Fallback private key when --nsec is not provided.\n"
"\n"
"Examples:\n"
" 1) Genesis-based startup\n"
" %s --config genesis.jsonc\n"
"\n"
" 2) nsec-only startup (no config file)\n"
" %s --nsec nsec1...\n"
"\n"
" 3) nsec via environment variable\n"
" DIDACTYL_NSEC=nsec1... %s\n"
"\n"
" 4) Override API bind/port\n"
" %s --config genesis.jsonc --api-bind 127.0.0.1 --api-port 8484\n"
"\n"
" 5) Dump tool schemas\n"
" %s --dump-schemas\n"
"\n"
" 6) Test a tool invocation\n"
" %s --test-tool config_recall '{\"config_name\":\"llm_config\"}'\n",
p,
p,
p,
p,
p,
p,
p);
}
static int derive_keys_from_nsec(const char* nsec_or_hex, didactyl_config_t* cfg) {
if (!nsec_or_hex || !cfg) return -1;
size_t n = strlen(nsec_or_hex);
if (n == 0 || n >= sizeof(cfg->keys.nsec)) {
return -1;
}
snprintf(cfg->keys.nsec, sizeof(cfg->keys.nsec), "%s", nsec_or_hex);
int dec_rc = -1;
if (strncmp(nsec_or_hex, "nsec1", 5) == 0) {
dec_rc = (nostr_decode_nsec(nsec_or_hex, cfg->keys.private_key) == 0) ? 0 : -1;
} else if (strlen(nsec_or_hex) == 64U) {
dec_rc = (nostr_hex_to_bytes(nsec_or_hex, cfg->keys.private_key, 32) == 0) ? 0 : -1;
}
if (dec_rc != 0) {
return -1;
}
if (nostr_ec_public_key_from_private_key(cfg->keys.private_key, cfg->keys.public_key) != 0) {
return -1;
}
nostr_bytes_to_hex(cfg->keys.public_key, 32, cfg->keys.public_key_hex);
return 0;
}
static int is_first_run_from_kind10002(const didactyl_config_t* cfg) {
if (!cfg || cfg->keys.public_key_hex[0] == '\0') {
return 1;
}
cJSON* filter = cJSON_CreateObject();
cJSON* kinds = cJSON_CreateArray();
cJSON* authors = cJSON_CreateArray();
if (!filter || !kinds || !authors) {
cJSON_Delete(filter);
cJSON_Delete(kinds);
cJSON_Delete(authors);
return 1;
}
cJSON_AddItemToArray(kinds, cJSON_CreateNumber(10002));
cJSON_AddItemToObject(filter, "kinds", kinds);
cJSON_AddItemToArray(authors, cJSON_CreateString(cfg->keys.public_key_hex));
cJSON_AddItemToObject(filter, "authors", authors);
cJSON_AddNumberToObject(filter, "limit", 1);
char* events_json = nostr_handler_query_json(filter, 3000);
cJSON_Delete(filter);
if (!events_json) {
return 1;
}
int first_run = 1;
cJSON* arr = cJSON_Parse(events_json);
free(events_json);
if (arr && cJSON_IsArray(arr) && cJSON_GetArraySize(arr) > 0) {
first_run = 0;
}
cJSON_Delete(arr);
return first_run;
}
static int tool_result_success(const char* json) {
if (!json) {
return 0;
}
cJSON* root = cJSON_Parse(json);
if (!root || !cJSON_IsObject(root)) {
cJSON_Delete(root);
return 0;
}
cJSON* success = cJSON_GetObjectItemCaseSensitive(root, "success");
int ok = (success && cJSON_IsBool(success) && cJSON_IsTrue(success)) ? 1 : 0;
cJSON_Delete(root);
return ok;
}
static int wait_for_connected_relays(int timeout_ms) {
if (timeout_ms <= 0) {
return nostr_handler_connected_relay_count() > 0 ? 1 : 0;
}
const int step_ms = 100;
int elapsed_ms = 0;
while (elapsed_ms < timeout_ms) {
if (nostr_handler_connected_relay_count() > 0) {
return 1;
}
(void)nostr_handler_poll(step_ms);
elapsed_ms += step_ms;
}
return nostr_handler_connected_relay_count() > 0 ? 1 : 0;
}
static void startup_step_begin(int step, const char* label) {
DEBUG_INFO("[didactyl] startup checklist [%02d] %s: begin", step, label);
fprintf(stdout, "[startup %02d] %s ...\n", step, label);
fflush(stdout);
}
static void startup_step_ok(int step, const char* label, const char* detail) {
if (detail && detail[0] != '\0') {
DEBUG_INFO("[didactyl] startup checklist [%02d] %s: ok (%s)", step, label, detail);
fprintf(stdout, "[startup %02d] %s: OK (%s)\n", step, label, detail);
} else {
DEBUG_INFO("[didactyl] startup checklist [%02d] %s: ok", step, label);
fprintf(stdout, "[startup %02d] %s: OK\n", step, label);
}
fflush(stdout);
}
static void startup_step_fail(int step, const char* label, const char* detail) {
if (detail && detail[0] != '\0') {
DEBUG_ERROR("[didactyl] startup checklist [%02d] %s: failed (%s)", step, label, detail);
fprintf(stderr, "[startup %02d] %s: FAILED (%s)\n", step, label, detail);
} else {
DEBUG_ERROR("[didactyl] startup checklist [%02d] %s: failed", step, label);
fprintf(stderr, "[startup %02d] %s: FAILED\n", step, label);
}
fflush(stderr);
}
static int relay_list_contains(char** relays, int relay_count, const char* relay_url) {
if (!relays || relay_count <= 0 || !relay_url || relay_url[0] == '\0') {
return 0;
}
for (int i = 0; i < relay_count; i++) {
if (relays[i] && strcmp(relays[i], relay_url) == 0) {
return 1;
}
}
return 0;
}
static void free_relay_list(char** relays, int relay_count) {
if (!relays) {
return;
}
for (int i = 0; i < relay_count; i++) {
free(relays[i]);
}
free(relays);
}
static int query_self_kind10002_relays(const didactyl_config_t* cfg,
int timeout_ms,
char*** out_relays,
int* out_relay_count) {
if (!cfg || !out_relays || !out_relay_count || cfg->keys.public_key_hex[0] == '\0') {
return -1;
}
*out_relays = NULL;
*out_relay_count = 0;
cJSON* filter = cJSON_CreateObject();
cJSON* kinds = cJSON_CreateArray();
cJSON* authors = cJSON_CreateArray();
if (!filter || !kinds || !authors) {
cJSON_Delete(filter);
cJSON_Delete(kinds);
cJSON_Delete(authors);
return -1;
}
cJSON_AddItemToArray(kinds, cJSON_CreateNumber(10002));
cJSON_AddItemToObject(filter, "kinds", kinds);
cJSON_AddItemToArray(authors, cJSON_CreateString(cfg->keys.public_key_hex));
cJSON_AddItemToObject(filter, "authors", authors);
cJSON_AddNumberToObject(filter, "limit", 16);
DEBUG_INFO("[didactyl] kind10002 query begin: timeout_ms=%d author=%.16s... relay_count=%d",
timeout_ms,
cfg->keys.public_key_hex,
cfg->relay_count);
char* relay_status_snapshot = nostr_handler_relay_status_json();
if (relay_status_snapshot) {
DEBUG_INFO("[didactyl] kind10002 query relay snapshot: %s", relay_status_snapshot);
free(relay_status_snapshot);
}
char* events_json = nostr_handler_query_json(filter, timeout_ms);
cJSON_Delete(filter);
if (!events_json) {
DEBUG_WARN("[didactyl] kind10002 query returned NULL JSON payload");
return 0;
}
size_t events_json_len = strlen(events_json);
cJSON* events = cJSON_Parse(events_json);
free(events_json);
if (!events || !cJSON_IsArray(events)) {
DEBUG_WARN("[didactyl] kind10002 query parse failed or non-array payload (len=%zu)", events_json_len);
cJSON_Delete(events);
return 0;
}
DEBUG_INFO("[didactyl] kind10002 query received event_count=%d", cJSON_GetArraySize(events));
cJSON* best_tags = NULL;
double best_created_at = -1.0;
int event_count = cJSON_GetArraySize(events);
for (int i = 0; i < event_count; i++) {
cJSON* ev = cJSON_GetArrayItem(events, i);
if (!ev || !cJSON_IsObject(ev)) {
continue;
}
cJSON* created_at = cJSON_GetObjectItemCaseSensitive(ev, "created_at");
cJSON* tags = cJSON_GetObjectItemCaseSensitive(ev, "tags");
if (!tags || !cJSON_IsArray(tags)) {
continue;
}
double ts = (created_at && cJSON_IsNumber(created_at)) ? created_at->valuedouble : 0.0;
if (!best_tags || ts >= best_created_at) {
best_tags = tags;
best_created_at = ts;
}
}
if (!best_tags) {
if (event_count == 0) {
DEBUG_WARN("[didactyl] kind10002 query returned zero events");
} else {
DEBUG_WARN("[didactyl] kind10002 query found events but none had valid tags array");
}
cJSON_Delete(events);
return 0;
}
char** relays = NULL;
int relay_count = 0;
int tag_count = cJSON_GetArraySize(best_tags);
for (int i = 0; i < tag_count; i++) {
cJSON* tag = cJSON_GetArrayItem(best_tags, i);
if (!tag || !cJSON_IsArray(tag) || cJSON_GetArraySize(tag) < 2) {
continue;
}
cJSON* key = cJSON_GetArrayItem(tag, 0);
cJSON* val = cJSON_GetArrayItem(tag, 1);
if (!key || !val || !cJSON_IsString(key) || !cJSON_IsString(val) ||
!key->valuestring || !val->valuestring) {
continue;
}
if (strcmp(key->valuestring, "r") != 0 || val->valuestring[0] == '\0') {
continue;
}
if (relay_list_contains(relays, relay_count, val->valuestring)) {
continue;
}
char** grown = (char**)realloc(relays, (size_t)(relay_count + 1) * sizeof(char*));
if (!grown) {
free_relay_list(relays, relay_count);
cJSON_Delete(events);
return -1;
}
relays = grown;
relays[relay_count] = strdup(val->valuestring);
if (!relays[relay_count]) {
free_relay_list(relays, relay_count);
cJSON_Delete(events);
return -1;
}
relay_count++;
}
cJSON_Delete(events);
if (relay_count <= 0) {
free(relays);
return 0;
}
*out_relays = relays;
*out_relay_count = relay_count;
cJSON* relays_debug = cJSON_CreateArray();
if (relays_debug) {
for (int i = 0; i < relay_count; i++) {
if (relays[i]) {
cJSON_AddItemToArray(relays_debug, cJSON_CreateString(relays[i]));
}
}
char* relays_debug_json = cJSON_PrintUnformatted(relays_debug);
if (relays_debug_json) {
DEBUG_INFO("[didactyl] kind10002 query extracted relays=%s", relays_debug_json);
free(relays_debug_json);
}
cJSON_Delete(relays_debug);
}
return relay_count;
}
static int merge_discovered_relays_into_config(didactyl_config_t* cfg,
char** discovered_relays,
int discovered_count) {
if (!cfg || !discovered_relays || discovered_count <= 0) {
return 0;
}
int old_count = cfg->relay_count;
int max_count = old_count + discovered_count;
char** merged = (char**)calloc((size_t)max_count, sizeof(char*));
if (!merged) {
return -1;
}
int merged_count = 0;
for (int i = 0; i < old_count; i++) {
if (!cfg->relays || !cfg->relays[i] || cfg->relays[i][0] == '\0') {
continue;
}
if (relay_list_contains(merged, merged_count, cfg->relays[i])) {
continue;
}
merged[merged_count] = strdup(cfg->relays[i]);
if (!merged[merged_count]) {
free_relay_list(merged, merged_count);
return -1;
}
merged_count++;
}
int added = 0;
for (int i = 0; i < discovered_count; i++) {
if (!discovered_relays[i] || discovered_relays[i][0] == '\0') {
continue;
}
if (relay_list_contains(merged, merged_count, discovered_relays[i])) {
continue;
}
merged[merged_count] = strdup(discovered_relays[i]);
if (!merged[merged_count]) {
free_relay_list(merged, merged_count);
return -1;
}
merged_count++;
added++;
}
if (cfg->relays) {
for (int i = 0; i < cfg->relay_count; i++) {
free(cfg->relays[i]);
}
free(cfg->relays);
}
cfg->relays = merged;
cfg->relay_count = merged_count;
return added;
}
static int wait_for_self_kind10002_relays(const didactyl_config_t* cfg,
int timeout_ms,
int poll_ms,
char*** out_relays,
int* out_relay_count) {
if (!cfg || !out_relays || !out_relay_count) {
return -1;
}
*out_relays = NULL;
*out_relay_count = 0;
if (poll_ms <= 0) {
poll_ms = 100;
}
const int query_timeout_ms = 5000;
if (timeout_ms <= 0) {
return query_self_kind10002_relays(cfg, query_timeout_ms, out_relays, out_relay_count);
}
struct timespec start;
if (clock_gettime(CLOCK_MONOTONIC, &start) != 0) {
return query_self_kind10002_relays(cfg, query_timeout_ms, out_relays, out_relay_count);
}
for (;;) {
char** relays = NULL;
int relay_count = 0;
int rc = query_self_kind10002_relays(cfg, query_timeout_ms, &relays, &relay_count);
if (rc > 0 && relay_count > 0 && relays) {
DEBUG_INFO("[didactyl] kind10002 wait success: relay_count=%d", relay_count);
for (int i = 0; i < relay_count; i++) {
DEBUG_INFO("[didactyl] kind10002 relay[%d]=%s", i, relays[i] ? relays[i] : "");
}
char* status_after = nostr_handler_relay_status_json();
if (status_after) {
DEBUG_INFO("[didactyl] kind10002 wait success relay snapshot: %s", status_after);
free(status_after);
}
*out_relays = relays;
*out_relay_count = relay_count;
return relay_count;
}
free_relay_list(relays, relay_count);
char* status_before_poll = nostr_handler_relay_status_json();
if (status_before_poll) {
DEBUG_INFO("[didactyl] kind10002 wait retry: rc=%d relay_count=%d snapshot=%s",
rc,
relay_count,
status_before_poll);
free(status_before_poll);
} else {
DEBUG_INFO("[didactyl] kind10002 wait retry: rc=%d relay_count=%d snapshot=<unavailable>", rc, relay_count);
}
(void)nostr_handler_poll(poll_ms);
struct timespec now;
if (clock_gettime(CLOCK_MONOTONIC, &now) != 0) {
break;
}
long elapsed_ms = (long)((now.tv_sec - start.tv_sec) * 1000L)
+ (long)((now.tv_nsec - start.tv_nsec) / 1000000L);
if (elapsed_ms >= timeout_ms) {
break;
}
}
DEBUG_WARN("[didactyl] kind10002 wait timed out after %dms", timeout_ms);
return 0;
}
static int llm_config_is_complete(const llm_config_t* llm) {
if (!llm) return 0;
return llm->api_key[0] != '\0' &&
llm->model[0] != '\0' &&
llm->base_url[0] != '\0';
}
static int admin_config_is_complete(const didactyl_config_t* cfg) {
return cfg && cfg->admin.pubkey[0] != '\0';
}
static const char* dm_protocol_to_string(dm_protocol_t protocol) {
switch (protocol) {
case DM_PROTOCOL_NIP17: return "nip17";
case DM_PROTOCOL_BOTH: return "both";
case DM_PROTOCOL_NIP04:
default:
return "nip04";
}
}
static void dm_protocol_from_string(const char* s, didactyl_config_t* cfg) {
if (!cfg || !s) return;
if (strcmp(s, "nip17") == 0) {
cfg->dm_protocol = DM_PROTOCOL_NIP17;
} else if (strcmp(s, "both") == 0) {
cfg->dm_protocol = DM_PROTOCOL_BOTH;
} else {
cfg->dm_protocol = DM_PROTOCOL_NIP04;
}
}
static int decode_pubkey_hex_or_npub_local(const char* input, char out_hex[65]) {
if (!input || !out_hex) return -1;
if (strncmp(input, "npub1", 5) == 0) {
unsigned char pubkey[32];
if (nostr_decode_npub(input, pubkey) != 0) {
return -1;
}
nostr_bytes_to_hex(pubkey, 32, out_hex);
return 0;
}
if (strlen(input) == 64U) {
unsigned char buf[32];
if (nostr_hex_to_bytes(input, buf, 32) != 0) {
return -1;
}
snprintf(out_hex, 65, "%s", input);
return 0;
}
return -1;
}
static int fetch_self_config_plaintext(const didactyl_config_t* cfg, const char* d_tag, char** out_plaintext) {
if (!cfg || !d_tag || !out_plaintext || cfg->keys.public_key_hex[0] == '\0') {
return -1;
}
*out_plaintext = NULL;
cJSON* filter = cJSON_CreateObject();
cJSON* kinds = cJSON_CreateArray();
cJSON* authors = cJSON_CreateArray();
cJSON* d_vals = cJSON_CreateArray();
if (!filter || !kinds || !authors || !d_vals) {
cJSON_Delete(filter);
cJSON_Delete(kinds);
cJSON_Delete(authors);
cJSON_Delete(d_vals);
return -1;
}
cJSON_AddItemToArray(kinds, cJSON_CreateNumber(30078));
cJSON_AddItemToObject(filter, "kinds", kinds);
cJSON_AddItemToArray(authors, cJSON_CreateString(cfg->keys.public_key_hex));
cJSON_AddItemToObject(filter, "authors", authors);
cJSON_AddItemToArray(d_vals, cJSON_CreateString(d_tag));
cJSON_AddItemToObject(filter, "#d", d_vals);
cJSON_AddNumberToObject(filter, "limit", 20);
char* events_json = nostr_handler_query_json(filter, 4000);
cJSON_Delete(filter);
if (!events_json) {
return -1;
}
cJSON* arr = cJSON_Parse(events_json);
free(events_json);
if (!arr || !cJSON_IsArray(arr) || cJSON_GetArraySize(arr) <= 0) {
cJSON_Delete(arr);
return -1;
}
cJSON* newest_ev = NULL;
long newest_created_at = -1;
int n = cJSON_GetArraySize(arr);
for (int i = 0; i < n; i++) {
cJSON* ev = cJSON_GetArrayItem(arr, i);
if (!ev || !cJSON_IsObject(ev)) {
continue;
}
cJSON* content = cJSON_GetObjectItemCaseSensitive(ev, "content");
if (!content || !cJSON_IsString(content) || !content->valuestring || content->valuestring[0] == '\0') {
continue;
}
cJSON* created_at = cJSON_GetObjectItemCaseSensitive(ev, "created_at");
long ts = (created_at && cJSON_IsNumber(created_at)) ? (long)created_at->valuedouble : 0;
if (!newest_ev || ts > newest_created_at) {
newest_ev = ev;
newest_created_at = ts;
}
}
cJSON* content = newest_ev ? cJSON_GetObjectItemCaseSensitive(newest_ev, "content") : NULL;
if (!content || !cJSON_IsString(content) || !content->valuestring || content->valuestring[0] == '\0') {
cJSON_Delete(arr);
return -1;
}
size_t out_cap = strlen(content->valuestring) + 1024U;
char* plaintext = (char*)malloc(out_cap);
if (!plaintext) {
cJSON_Delete(arr);
return -1;
}
int dec_rc = nostr_nip44_decrypt(cfg->keys.private_key,
cfg->keys.public_key,
content->valuestring,
plaintext,
out_cap);
cJSON_Delete(arr);
if (dec_rc != NOSTR_SUCCESS) {
free(plaintext);
return -1;
}
*out_plaintext = plaintext;
return 0;
}
static int apply_recalled_user_settings(didactyl_config_t* cfg,
const char* plaintext,
int* out_backfill_needed) {
if (!cfg || !plaintext) return -1;
if (out_backfill_needed) {
*out_backfill_needed = 0;
}
cJSON* root = cJSON_Parse(plaintext);
if (!root || !cJSON_IsObject(root)) {
cJSON_Delete(root);
return -1;
}
cJSON* global_llm = cJSON_GetObjectItemCaseSensitive(root, "global_llm");
cJSON* didactyl = cJSON_GetObjectItemCaseSensitive(root, "didactyl");
if (!global_llm || !cJSON_IsObject(global_llm)) {
cJSON_Delete(root);
return -1;
}
cJSON* provider = cJSON_GetObjectItemCaseSensitive(global_llm, "provider");
cJSON* api_key = cJSON_GetObjectItemCaseSensitive(global_llm, "api_key");
cJSON* model = cJSON_GetObjectItemCaseSensitive(global_llm, "model");
cJSON* base_url = cJSON_GetObjectItemCaseSensitive(global_llm, "base_url");
cJSON* max_tokens = cJSON_GetObjectItemCaseSensitive(global_llm, "max_tokens");
cJSON* temperature = cJSON_GetObjectItemCaseSensitive(global_llm, "temperature");
cJSON* admin_pubkey = NULL;
cJSON* dm_protocol = NULL;
cJSON* max_turns = NULL;
if (didactyl && cJSON_IsObject(didactyl)) {
admin_pubkey = cJSON_GetObjectItemCaseSensitive(didactyl, "admin_pubkey");
dm_protocol = cJSON_GetObjectItemCaseSensitive(didactyl, "dm_protocol");
max_turns = cJSON_GetObjectItemCaseSensitive(didactyl, "max_turns");
} else if (out_backfill_needed) {
*out_backfill_needed = 1;
}
if (!api_key || !cJSON_IsString(api_key) || !api_key->valuestring || api_key->valuestring[0] == '\0' ||
!model || !cJSON_IsString(model) || !model->valuestring || model->valuestring[0] == '\0' ||
!base_url || !cJSON_IsString(base_url) || !base_url->valuestring || base_url->valuestring[0] == '\0') {
cJSON_Delete(root);
return -1;
}
if (provider && cJSON_IsString(provider) && provider->valuestring && provider->valuestring[0] != '\0') {
snprintf(cfg->llm.provider, sizeof(cfg->llm.provider), "%s", provider->valuestring);
} else if (cfg->llm.provider[0] == '\0') {
snprintf(cfg->llm.provider, sizeof(cfg->llm.provider), "%s", "openai");
}
snprintf(cfg->llm.api_key, sizeof(cfg->llm.api_key), "%s", api_key->valuestring);
snprintf(cfg->llm.model, sizeof(cfg->llm.model), "%s", model->valuestring);
snprintf(cfg->llm.base_url, sizeof(cfg->llm.base_url), "%s", base_url->valuestring);
if (max_tokens && cJSON_IsNumber(max_tokens)) {
cfg->llm.max_tokens = (int)max_tokens->valuedouble;
}
if (temperature && cJSON_IsNumber(temperature)) {
cfg->llm.temperature = temperature->valuedouble;
}
if (admin_pubkey && cJSON_IsString(admin_pubkey) && admin_pubkey->valuestring && admin_pubkey->valuestring[0] != '\0') {
char decoded[65] = {0};
if (decode_pubkey_hex_or_npub_local(admin_pubkey->valuestring, decoded) != 0) {
cJSON_Delete(root);
return -1;
}
snprintf(cfg->admin.pubkey, sizeof(cfg->admin.pubkey), "%s", decoded);
} else if (out_backfill_needed) {
*out_backfill_needed = 1;
}
if (dm_protocol && cJSON_IsString(dm_protocol) && dm_protocol->valuestring && dm_protocol->valuestring[0] != '\0') {
dm_protocol_from_string(dm_protocol->valuestring, cfg);
} else if (out_backfill_needed) {
*out_backfill_needed = 1;
}
if (max_turns && cJSON_IsNumber(max_turns)) {
int parsed = (int)max_turns->valuedouble;
cfg->tools.max_turns = (parsed > 0) ? parsed : 40;
}
cJSON_Delete(root);
return 0;
}
static int publish_encrypted_self_config(const didactyl_config_t* cfg, const char* d_tag, const char* content_json) {
if (!cfg || !d_tag || !content_json || d_tag[0] == '\0') return -1;
size_t cipher_cap = (strlen(content_json) * 4U) + 1024U;
char* ciphertext = (char*)malloc(cipher_cap);
if (!ciphertext) return -1;
int enc_rc = nostr_nip44_encrypt(cfg->keys.private_key,
cfg->keys.public_key,
content_json,
ciphertext,
cipher_cap);
if (enc_rc != NOSTR_SUCCESS) {
free(ciphertext);
return -1;
}
cJSON* tags = cJSON_CreateArray();
cJSON* d = cJSON_CreateArray();
cJSON* app = cJSON_CreateArray();
if (!tags || !d || !app) {
cJSON_Delete(tags);
cJSON_Delete(d);
cJSON_Delete(app);
free(ciphertext);
return -1;
}
cJSON_AddItemToArray(d, cJSON_CreateString("d"));
cJSON_AddItemToArray(d, cJSON_CreateString(d_tag));
cJSON_AddItemToArray(tags, d);
cJSON_AddItemToArray(app, cJSON_CreateString("app"));
cJSON_AddItemToArray(app, cJSON_CreateString("didactyl"));
cJSON_AddItemToArray(tags, app);
nostr_publish_result_t result;
memset(&result, 0, sizeof(result));
int rc = nostr_handler_publish_kind_event(30078, ciphertext, tags, &result);
nostr_handler_publish_result_free(&result);
cJSON_Delete(tags);
free(ciphertext);
return rc;
}
static int persist_runtime_config_to_nostr(const didactyl_config_t* cfg, int persist_llm_config) {
if (!cfg) return -1;
if (!persist_llm_config) {
DEBUG_INFO("[didactyl] startup phase: skipping user-settings publish because runtime config was recalled from Nostr");
return 0;
}
cJSON* user_settings = cJSON_CreateObject();
cJSON* global_llm = cJSON_CreateObject();
cJSON* didactyl = cJSON_CreateObject();
if (!user_settings || !global_llm || !didactyl) {
cJSON_Delete(user_settings);
cJSON_Delete(global_llm);
cJSON_Delete(didactyl);
return -1;
}
cJSON_AddNumberToObject(user_settings, "v", 2);
cJSON_AddNumberToObject(user_settings, "updatedAt", (double)time(NULL));
cJSON_AddStringToObject(global_llm, "provider", cfg->llm.provider);
cJSON_AddStringToObject(global_llm, "api_key", cfg->llm.api_key);
cJSON_AddStringToObject(global_llm, "model", cfg->llm.model);
cJSON_AddStringToObject(global_llm, "base_url", cfg->llm.base_url);
cJSON_AddNumberToObject(global_llm, "max_tokens", cfg->llm.max_tokens);
cJSON_AddNumberToObject(global_llm, "temperature", cfg->llm.temperature);
cJSON_AddItemToObject(user_settings, "global_llm", global_llm);
cJSON_AddStringToObject(didactyl, "admin_pubkey", cfg->admin.pubkey);
cJSON_AddStringToObject(didactyl, "dm_protocol", dm_protocol_to_string(cfg->dm_protocol));
cJSON_AddNumberToObject(didactyl, "max_turns", cfg->tools.max_turns > 0 ? cfg->tools.max_turns : 40);
cJSON_AddItemToObject(user_settings, "didactyl", didactyl);
char* user_settings_json = cJSON_PrintUnformatted(user_settings);
cJSON_Delete(user_settings);
if (!user_settings_json) {
return -1;
}
int rc = publish_encrypted_self_config(cfg, "user-settings", user_settings_json);
free(user_settings_json);
return rc;
}
static int recover_missing_runtime_config_from_nostr(didactyl_config_t* cfg, int* out_backfill_needed) {
if (!cfg) {
return 0;
}
if (out_backfill_needed) {
*out_backfill_needed = 0;
}
char* settings_plaintext = NULL;
if (fetch_self_config_plaintext(cfg, "user-settings", &settings_plaintext) != 0 || !settings_plaintext) {
DEBUG_WARN("[didactyl] startup phase: user-settings recall unavailable");
free(settings_plaintext);
return 0;
}
int backfill_needed = 0;
if (apply_recalled_user_settings(cfg, settings_plaintext, &backfill_needed) != 0) {
DEBUG_WARN("[didactyl] startup phase: failed to parse/decrypt recalled user-settings");
free(settings_plaintext);
return 0;
}
free(settings_plaintext);
if (out_backfill_needed) {
*out_backfill_needed = backfill_needed;
}
if (backfill_needed) {
DEBUG_INFO("[didactyl] startup phase: recovered user-settings from Nostr (missing didactyl fields will be backfilled)");
} else {
DEBUG_INFO("[didactyl] startup phase: recovered user-settings from Nostr");
}
return 1;
}
int main(int argc, char** argv) {
const char* config_path = "./genesis.jsonc";
const char* cli_nsec = NULL;
const char* cli_admin_pubkey = NULL;
const char* api_bind_override = NULL;
int api_port_override = 0;
int debug_level = DEBUG_LEVEL_NONE;
int dump_schemas = 0;
const char* test_tool_name = NULL;
const char* test_tool_args = "{}";
didactyl_config_t cfg;
memset(&cfg, 0, sizeof(cfg));
int config_preloaded = 0;
int bootstrap_mode = 0;
if (argc == 1) {
if (!isatty(STDIN_FILENO)) {
print_usage(argv[0]);
return 1;
}
debug_level = DEBUG_LEVEL_INFO;
debug_init(debug_level);
configure_mongoose_log_level_from_debug();
DEBUG_INFO("%s %s starting (interactive setup)", DIDACTYL_NAME, DIDACTYL_VERSION);
if (nostr_init() != NOSTR_SUCCESS) {
fprintf(stderr, "Failed to initialize nostr core\n");
return 1;
}
char genesis_path[256] = {0};
int wizard_rc = setup_wizard_run(&cfg, genesis_path, sizeof(genesis_path));
if (wizard_rc == SETUP_WIZARD_RC_ABORT) {
config_free(&cfg);
nostr_cleanup();
return 1;
}
if (wizard_rc == SETUP_WIZARD_RC_EXIT) {
config_free(&cfg);
nostr_cleanup();
return 0;
}
if (wizard_rc == SETUP_WIZARD_RC_BOOTSTRAP) {
bootstrap_mode = 1;
}
config_preloaded = 1;
}
if (!config_preloaded) {
int config_path_explicit = 0;
for (int i = 1; i < argc; i++) {
if (strcmp(argv[i], "-h") == 0 || strcmp(argv[i], "--help") == 0) {
print_usage(argv[0]);
return 0;
} else if (strcmp(argv[i], "-v") == 0 || strcmp(argv[i], "--version") == 0) {
printf("%s %s\n", DIDACTYL_NAME, DIDACTYL_VERSION);
return 0;
} else if (strcmp(argv[i], "--config") == 0 && i + 1 < argc) {
config_path = argv[++i];
config_path_explicit = 1;
} else if (strcmp(argv[i], "--debug") == 0 && i + 1 < argc) {
debug_level = atoi(argv[++i]);
} else if (strcmp(argv[i], "--nsec") == 0 && i + 1 < argc) {
cli_nsec = argv[++i];
} else if (strcmp(argv[i], "--admin") == 0 && i + 1 < argc) {
cli_admin_pubkey = argv[++i];
} else if (strcmp(argv[i], "--api-port") == 0 && i + 1 < argc) {
api_port_override = atoi(argv[++i]);
} else if (strcmp(argv[i], "--api-bind") == 0 && i + 1 < argc) {
api_bind_override = argv[++i];
} else if (strcmp(argv[i], "--dump-schemas") == 0) {
dump_schemas = 1;
} else if (strcmp(argv[i], "--test-tool") == 0 && i + 2 < argc) {
test_tool_name = argv[++i];
test_tool_args = argv[++i];
} else {
print_usage(argv[0]);
return 1;
}
}
if (config_path_explicit) {
bootstrap_mode = 1;
}
debug_init(debug_level);
configure_mongoose_log_level_from_debug();
DEBUG_INFO("%s %s starting", DIDACTYL_NAME, DIDACTYL_VERSION);
if (nostr_init() != NOSTR_SUCCESS) {
fprintf(stderr, "Failed to initialize nostr core\n");
return 1;
}
if (config_load(config_path, &cfg) != 0) {
fprintf(stderr, "Failed to load config: %s\n", config_path);
fprintf(stderr, "Config error: %s\n", config_last_error());
nostr_cleanup();
return 1;
}
}
if (cfg.keys.nsec[0] == '\0') {
const char* env_nsec = getenv("DIDACTYL_NSEC");
const char* input_nsec = (cli_nsec && cli_nsec[0] != '\0') ? cli_nsec : env_nsec;
if (!input_nsec || input_nsec[0] == '\0') {
fprintf(stderr, "No nsec available: provide key.nsec in config, --nsec, or DIDACTYL_NSEC\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
if (derive_keys_from_nsec(input_nsec, &cfg) != 0) {
fprintf(stderr, "Invalid nsec provided via --nsec or DIDACTYL_NSEC\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
}
if (cli_admin_pubkey && cli_admin_pubkey[0] != '\0') {
char decoded_admin[65] = {0};
if (decode_pubkey_hex_or_npub_local(cli_admin_pubkey, decoded_admin) != 0) {
fprintf(stderr, "Invalid admin pubkey provided via --admin (expected npub1... or 64-char hex)\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
snprintf(cfg.admin.pubkey, sizeof(cfg.admin.pubkey), "%s", decoded_admin);
DEBUG_INFO("[didactyl] startup phase: admin override applied from --admin (%.16s...)", cfg.admin.pubkey);
}
if (config_ensure_startup_skill_adoption(&cfg) != 0) {
fprintf(stderr, "Failed to synthesize startup skill adoption events\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
if (api_port_override > 0 && api_port_override <= 65535) {
cfg.api.enabled = 1;
cfg.api.port = api_port_override;
}
if (api_bind_override && api_bind_override[0] != '\0') {
cfg.api.enabled = 1;
snprintf(cfg.api.bind_address, sizeof(cfg.api.bind_address), "%s", api_bind_override);
}
{
const char* ca_bundle = nostr_http_detect_ca_bundle();
if (ca_bundle && ca_bundle[0] != '\0') {
nostr_http_set_ca_bundle(ca_bundle);
}
}
if (dump_schemas || test_tool_name) {
if (llm_init(&cfg.llm) != 0) {
fprintf(stderr, "Failed to initialize llm client\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
if (nostr_handler_init(&cfg) != 0) {
fprintf(stderr, "Failed to initialize nostr handler\n");
config_free(&cfg);
llm_cleanup();
nostr_cleanup();
return 1;
}
(void)nostr_block_list_init(&cfg);
(void)nostr_block_list_load_from_relays();
tools_context_t tools_ctx;
if (tools_init(&tools_ctx, &cfg) != 0) {
fprintf(stderr, "Failed to initialize tools context\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
llm_cleanup();
nostr_cleanup();
return 1;
}
int wallet_initialized = 0;
int exit_code = 0;
if (cashu_wallet_init(&cfg) == 0) {
wallet_initialized = 1;
if (cfg.cashu_wallet.enabled) {
(void)nostr_handler_subscribe_wallet_events();
int wallet_rc = 0;
if (cfg.cashu_wallet.auto_load) {
wallet_rc = cashu_wallet_load_from_relays();
}
if (wallet_rc != 0 && cfg.cashu_wallet.mint_count > 0) {
(void)cashu_wallet_create_new_from_config();
}
}
}
if (test_tool_name) {
const int timeout_ms = 15000;
if (!wait_for_connected_relays(timeout_ms)) {
fprintf(stderr,
"No relay connection established within %d ms; refusing to run --test-tool '%s'\n",
timeout_ms,
test_tool_name);
tools_cleanup(&tools_ctx);
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
llm_cleanup();
nostr_cleanup();
return 1;
}
}
if (dump_schemas) {
char* schemas = tools_build_openai_schema_json(&tools_ctx);
if (!schemas) {
fprintf(stderr, "Failed to build tool schemas\n");
exit_code = 1;
} else {
printf("%s\n", schemas);
free(schemas);
}
} else {
char* result = tools_execute(&tools_ctx, test_tool_name, test_tool_args);
if (!result) {
fprintf(stderr, "Failed to execute tool\n");
exit_code = 1;
} else {
printf("%s\n", result);
exit_code = tool_result_success(result) ? 0 : 1;
free(result);
}
}
tools_cleanup(&tools_ctx);
if (wallet_initialized) {
cashu_wallet_cleanup();
}
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
llm_cleanup();
nostr_cleanup();
return exit_code;
}
if (nostr_handler_init(&cfg) != 0) {
fprintf(stderr, "Failed to initialize nostr handler\n");
config_free(&cfg);
nostr_cleanup();
return 1;
}
(void)nostr_block_list_init(&cfg);
(void)nostr_block_list_load_from_relays();
const int startup_connect_timeout_ms = 15000;
startup_step_begin(1, "Relay connectivity");
if (!wait_for_connected_relays(startup_connect_timeout_ms)) {
startup_step_fail(1, "Relay connectivity", "no relay connected within timeout; continuing best-effort");
DEBUG_WARN("[didactyl] startup phase: no relay connected within %d ms; continuing with best effort", startup_connect_timeout_ms);
} else {
char detail[64];
snprintf(detail, sizeof(detail), "connected relays: %d/%d", nostr_handler_connected_relay_count(), cfg.relay_count);
startup_step_ok(1, "Relay connectivity", detail);
}
startup_step_begin(2, "Recover runtime config from Nostr");
int user_settings_backfill_needed = 0;
int llm_recalled_from_nostr = recover_missing_runtime_config_from_nostr(&cfg, &user_settings_backfill_needed);
startup_step_ok(2,
"Recover runtime config from Nostr",
llm_recalled_from_nostr
? (user_settings_backfill_needed ? "user-settings recalled (backfill required)" : "user-settings recalled")
: NULL);
startup_step_begin(3, "Validate LLM config");
if (!llm_config_is_complete(&cfg.llm)) {
startup_step_fail(3, "Validate LLM config", "missing user-settings.global_llm (model/base_url/api_key)");
fprintf(stderr,
"Missing LLM config: provide genesis file values or store d=user-settings with global_llm\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
startup_step_ok(3, "Validate LLM config", NULL);
startup_step_begin(4, "Validate admin config");
if (!admin_config_is_complete(&cfg)) {
startup_step_fail(4, "Validate admin config", "missing admin pubkey");
fprintf(stderr,
"Missing admin config: provide admin.pubkey in genesis, pass --admin, or store d=user-settings with didactyl.admin_pubkey\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
startup_step_ok(4, "Validate admin config", NULL);
startup_step_begin(5, "Initialize LLM client");
if (llm_init(&cfg.llm) != 0) {
startup_step_fail(5, "Initialize LLM client", "llm_init failed");
fprintf(stderr, "Failed to initialize llm client\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
startup_step_ok(5, "Initialize LLM client", NULL);
startup_step_begin(6, "Detect first run via kind 10002");
int first_run = is_first_run_from_kind10002(&cfg);
DEBUG_INFO("[didactyl] startup phase: first-run detection via kind 10002 => %s", first_run ? "first-run" : "subsequent-run");
startup_step_ok(6, "Detect first run via kind 10002", first_run ? "first-run" : "subsequent-run");
startup_step_begin(7, "Reconcile/persist startup state");
if (bootstrap_mode || first_run) {
if (nostr_handler_reconcile_startup_events() != 0) {
startup_step_fail(7, "Reconcile/persist startup state", "startup event reconciliation failed");
fprintf(stderr, "Failed to publish startup events; aborting startup\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
} else {
DEBUG_INFO("[didactyl] startup phase: existing-agent mode; skipping startup-event reconcile on subsequent run");
}
if (bootstrap_mode || first_run || user_settings_backfill_needed) {
if (persist_runtime_config_to_nostr(&cfg,
(llm_recalled_from_nostr && !user_settings_backfill_needed) ? 0 : 1) != 0) {
DEBUG_WARN("[didactyl] startup phase: failed to persist encrypted runtime config to Nostr");
} else {
DEBUG_INFO("[didactyl] startup phase: persisted encrypted runtime config to Nostr");
}
} else {
DEBUG_INFO("[didactyl] startup phase: skipping encrypted runtime config publish on subsequent run");
}
startup_step_ok(7, "Reconcile/persist startup state", NULL);
startup_step_begin(8, "Initialize agent");
if (agent_init(&cfg) != 0) {
startup_step_fail(8, "Initialize agent", "agent_init failed");
fprintf(stderr, "Failed to initialize agent\n");
nostr_block_list_cleanup();
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
startup_step_ok(8, "Initialize agent", NULL);
startup_step_begin(9, "Initialize trigger manager");
trigger_manager_t trigger_manager;
if (trigger_manager_init(&trigger_manager, &cfg) != 0) {
startup_step_fail(9, "Initialize trigger manager", "trigger_manager_init failed");
fprintf(stderr, "Failed to initialize trigger manager\n");
agent_cleanup();
nostr_block_list_cleanup();
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
startup_step_ok(9, "Initialize trigger manager", NULL);
agent_set_trigger_manager(&trigger_manager);
nostr_handler_set_trigger_manager(&trigger_manager);
deferred_trigger_load_ctx_t deferred_trigger_ctx = {
.trigger_manager = &trigger_manager,
.loaded_once = 0
};
nostr_handler_set_self_skill_eose_callback(on_self_skill_eose_load_triggers, &deferred_trigger_ctx);
DEBUG_INFO("[didactyl] startup phase: deferred trigger load will run after self-skill EOSE");
startup_step_begin(10, "Load startup triggers");
DEBUG_INFO("[didactyl] startup phase: startup-config trigger load begin");
if (trigger_manager_load_from_startup_events(&trigger_manager) != 0) {
DEBUG_WARN("[didactyl] startup phase: startup-config trigger load failed (continuing)");
}
DEBUG_INFO("[didactyl] startup phase: startup-config trigger load end");
startup_step_ok(10, "Load startup triggers", NULL);
startup_step_begin(11, "Discover self relay list via kind 10002");
const int kind10002_timeout_ms = 25000;
char** discovered_relays = NULL;
int discovered_count = 0;
if (wait_for_self_kind10002_relays(&cfg, kind10002_timeout_ms, 200, &discovered_relays, &discovered_count) <= 0) {
startup_step_fail(11, "Discover self relay list via kind 10002", "required relay list not retrievable; aborting startup");
fprintf(stderr, "Startup aborted: could not retrieve valid self kind 10002 within %d ms\n", kind10002_timeout_ms);
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
int added_relays = merge_discovered_relays_into_config(&cfg, discovered_relays, discovered_count);
free_relay_list(discovered_relays, discovered_count);
discovered_relays = NULL;
if (added_relays < 0 || nostr_handler_sync_relays_from_config() != 0) {
startup_step_fail(11, "Discover self relay list via kind 10002", "failed to apply discovered relay list to pool");
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
if (!wait_for_connected_relays(startup_connect_timeout_ms)) {
DEBUG_WARN("[didactyl] startup phase: no relay connected after relay-list expansion; continuing best effort");
}
char relay_detail[128];
snprintf(relay_detail,
sizeof(relay_detail),
"kind10002=%d added=%d connected=%d/%d",
discovered_count,
added_relays,
nostr_handler_connected_relay_count(),
cfg.relay_count);
startup_step_ok(11, "Discover self relay list via kind 10002", relay_detail);
startup_step_begin(12, "Subscribe admin context");
DEBUG_INFO("[didactyl] startup phase: subscribe admin context begin");
if (nostr_handler_subscribe_admin_context() != 0) {
DEBUG_WARN("[didactyl] startup phase: subscribe admin context failed (continuing)");
}
DEBUG_INFO("[didactyl] startup phase: subscribe admin context end");
startup_step_ok(12, "Subscribe admin context", NULL);
startup_step_begin(13, "Subscribe agent self context");
DEBUG_INFO("[didactyl] startup phase: subscribe agent self context begin");
if (nostr_handler_subscribe_agent_context() != 0) {
DEBUG_WARN("[didactyl] startup phase: subscribe agent self context failed (continuing)");
}
DEBUG_INFO("[didactyl] startup phase: subscribe agent self context end");
startup_step_ok(13, "Subscribe agent self context", NULL);
startup_step_begin(14, "Subscribe self-skill cache");
DEBUG_INFO("[didactyl] startup phase: subscribe self skill cache begin");
if (nostr_handler_subscribe_self_skills() != 0) {
startup_step_fail(14, "Subscribe self-skill cache", "nostr_handler_subscribe_self_skills failed");
DEBUG_ERROR("[didactyl] startup phase: subscribe self skill cache failed");
fprintf(stderr, "Startup aborted: failed to subscribe self-skill cache\n");
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
const int self_skill_eose_timeout_ms = 15000;
if (nostr_handler_wait_for_self_skill_eose(self_skill_eose_timeout_ms) != 0) {
startup_step_fail(14,
"Subscribe self-skill cache",
"self-skill EOSE not received within timeout");
fprintf(stderr,
"Startup aborted: self-skill EOSE not received within %d ms\n",
self_skill_eose_timeout_ms);
fprintf(stderr,
"Check relay connectivity (connected=%d/%d) and ensure skill events exist on relays\n",
nostr_handler_connected_relay_count(),
cfg.relay_count);
fprintf(stderr,
"If this is a first run, use genesis to publish startup events\n");
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
int startup_skill_count = 0;
int startup_adoption_count = 0;
if (nostr_handler_validate_self_skill_cache(&startup_skill_count, &startup_adoption_count) != 0) {
startup_step_fail(14,
"Subscribe self-skill cache",
"no skill events found after EOSE");
fprintf(stderr,
"Startup aborted: no skill events (kind 31123/31124) found in self-skill cache\n");
fprintf(stderr,
"The agent requires at least one skill event to operate\n");
fprintf(stderr,
"Run genesis to publish the default skill, or publish a skill manually\n");
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
char self_skill_detail[128];
snprintf(self_skill_detail,
sizeof(self_skill_detail),
"skills=%d adoptions=%d",
startup_skill_count,
startup_adoption_count);
DEBUG_INFO("[didactyl] startup phase: subscribe self skill cache end");
startup_step_ok(14, "Subscribe self-skill cache", self_skill_detail);
startup_step_begin(15, "Subscribe DMs");
DEBUG_INFO("[didactyl] startup phase: subscribe DMs begin");
if (nostr_handler_subscribe_dms(agent_on_message, NULL) != 0) {
startup_step_fail(15, "Subscribe DMs", "nostr_handler_subscribe_dms failed");
DEBUG_ERROR("[didactyl] startup phase: subscribe DMs failed");
fprintf(stderr, "Failed to subscribe to DMs\n");
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 1;
}
DEBUG_INFO("[didactyl] startup phase: subscribe DMs end");
startup_step_ok(15, "Subscribe DMs", NULL);
startup_step_begin(16, "Subscribe wallet events");
DEBUG_INFO("[didactyl] startup phase: subscribe wallet events begin");
if (nostr_handler_subscribe_wallet_events() != 0) {
DEBUG_WARN("[didactyl] startup phase: subscribe wallet events failed (continuing)");
}
DEBUG_INFO("[didactyl] startup phase: subscribe wallet events end");
startup_step_ok(16, "Subscribe wallet events", NULL);
startup_step_begin(17, "Initialize cashu wallet");
if (cashu_wallet_init(&cfg) != 0) {
DEBUG_WARN("[didactyl] startup phase: cashu_wallet_init failed (continuing without wallet)");
startup_step_fail(17, "Initialize cashu wallet", "cashu_wallet_init failed; wallet tools may return errors");
} else {
int wallet_rc = 0;
if (cfg.cashu_wallet.auto_load) {
wallet_rc = cashu_wallet_load_from_relays();
}
if (wallet_rc != 0 && cfg.cashu_wallet.mint_count > 0) {
wallet_rc = cashu_wallet_create_new_from_config();
}
if (wallet_rc != 0) {
DEBUG_WARN("[didactyl] startup phase: cashu wallet load/create deferred to first tool call");
startup_step_ok(17, "Initialize cashu wallet", "initialized; load/create deferred");
} else {
startup_step_ok(17, "Initialize cashu wallet", cfg.cashu_wallet.auto_load ? "loaded or created" : "initialized");
}
}
struct sigaction sa;
memset(&sa, 0, sizeof(sa));
sa.sa_handler = signal_handler;
sigemptyset(&sa.sa_mask);
sa.sa_flags = 0;
(void)sigaction(SIGINT, &sa, NULL);
(void)sigaction(SIGTERM, &sa, NULL);
struct sigaction sa_pipe;
memset(&sa_pipe, 0, sizeof(sa_pipe));
sa_pipe.sa_handler = SIG_IGN;
sigemptyset(&sa_pipe.sa_mask);
sa_pipe.sa_flags = 0;
(void)sigaction(SIGPIPE, &sa_pipe, NULL);
int http_api_started = 0;
if (cfg.api.enabled) {
http_api_context_t http_ctx;
memset(&http_ctx, 0, sizeof(http_ctx));
http_ctx.cfg = &cfg;
http_ctx.tools_ctx = agent_tools_context();
http_ctx.trigger_manager = &trigger_manager;
if (http_api_init(&http_ctx) != 0) {
fprintf(stderr,
"Failed to initialize HTTP API on %s:%d (continuing without HTTP API)\n",
cfg.api.bind_address,
cfg.api.port);
DEBUG_WARN("[didactyl] HTTP API disabled due to bind/init failure; agent will continue without local API");
http_api_started = 0;
} else {
http_api_started = 1;
DEBUG_INFO("[didactyl] HTTP API listening at http://%s:%d",
cfg.api.bind_address[0] ? cfg.api.bind_address : "127.0.0.1",
cfg.api.port > 0 ? cfg.api.port : 8484);
DEBUG_INFO("[didactyl] HTTP API endpoints: http://%s:%d/api/context/current http://%s:%d/api/context/parts",
cfg.api.bind_address[0] ? cfg.api.bind_address : "127.0.0.1",
cfg.api.port > 0 ? cfg.api.port : 8484,
cfg.api.bind_address[0] ? cfg.api.bind_address : "127.0.0.1",
cfg.api.port > 0 ? cfg.api.port : 8484);
}
} else {
DEBUG_INFO("[didactyl] HTTP API disabled (set api.enabled=true in config to enable)");
}
nostr_handler_refresh_relay_statuses();
char startup_dm[768];
const char* startup_name = nostr_handler_get_startup_display_name();
int connected_relays = nostr_handler_connected_relay_count();
time_t startup_now = time(NULL);
struct tm startup_tm;
char startup_time_str[32] = {0};
if (localtime_r(&startup_now, &startup_tm)) {
(void)strftime(startup_time_str, sizeof(startup_time_str), "%Y-%m-%d %H:%M:%S", &startup_tm);
} else {
snprintf(startup_time_str, sizeof(startup_time_str), "%ld", (long)startup_now);
}
snprintf(startup_dm,
sizeof(startup_dm),
"%s has started up and is online at %s (version %s, connected relays: %d/%d).",
(startup_name && startup_name[0] != '\0') ? startup_name : "Didactyl",
startup_time_str,
DIDACTYL_VERSION,
connected_relays,
cfg.relay_count);
if (nostr_handler_send_dm_auto(cfg.admin.pubkey, startup_dm) != 0) {
DEBUG_WARN("[didactyl] startup phase: failed to send startup status DM to admin");
}
startup_step_ok(18, "READY", "agent online; entering main poll loop");
DEBUG_INFO("[didactyl] entering main poll loop");
DEBUG_INFO("[didactyl] running with pubkey %s", cfg.keys.public_key_hex);
(void)systemd_notify_send("READY=1");
time_t last_watchdog_ping = 0;
while (g_running) {
(void)nostr_handler_poll(100);
(void)trigger_manager_poll(&trigger_manager);
if (http_api_started) {
(void)http_api_poll(0);
}
time_t now = time(NULL);
if (now != (time_t)-1 && (last_watchdog_ping == 0 || (now - last_watchdog_ping) >= 10)) {
(void)systemd_notify_send("WATCHDOG=1");
last_watchdog_ping = now;
}
struct timespec ts = {0, 10 * 1000 * 1000};
nanosleep(&ts, NULL);
}
DEBUG_INFO("[didactyl] shutting down");
if (http_api_started) {
http_api_cleanup();
}
cashu_wallet_cleanup();
agent_cleanup();
nostr_block_list_cleanup();
trigger_manager_cleanup(&trigger_manager);
nostr_handler_cleanup();
llm_cleanup();
config_free(&cfg);
nostr_cleanup();
return 0;
}
Reference in New Issue View Git Blame Copy Permalink