Function trigger_expiration

wallet/invoices.c:179–209

}

static void trigger_expiration(struct invoices *invoices)
{
	u64 *inv_dbids;
	u64 now = clock_time().ts.tv_sec;
	struct db_stmt *stmt;

	/* Free current expiration timer */
	invoices->expiration_timer = tal_free(invoices->expiration_timer);

	inv_dbids = expired_ids(tmpctx, invoices->wallet->db, now, UNPAID);

	/* Trigger expirations */
	for (size_t i = 0; i < tal_count(inv_dbids); i++) {
		stmt = db_prepare_v2(invoices->wallet->db, SQL("UPDATE invoices"
							       "   SET state = ?"
							       "      , updated_index = ?"
							       " WHERE id = ?"));
		db_bind_int(stmt, EXPIRED);
		db_bind_u64(stmt,
			    /* FIXME: details! */
			    invoice_index_update_status(invoices->wallet->ld,
							NULL, EXPIRED));
		db_bind_u64(stmt, inv_dbids[i]);
		db_exec_prepared_v2(take(stmt));

		/* Trigger expiration */
		trigger_invoice_waiter_expire_or_delete(invoices, inv_dbids[i], false);
	}

	install_expiration_timer(invoices);
}

static void install_expiration_timer(struct invoices *invoices)
{