Function json_recoverchannel

lightningd/opening_control.c:1446–1507

}

static struct command_result *json_recoverchannel(struct command *cmd,
						const char *buffer,
						const jsmntok_t *obj UNNEEDED,
						const jsmntok_t *params)
{
	const jsmntok_t *scb, *t;
	size_t i;
	struct json_stream *response;
	struct scb_chan *scb_chan = tal(cmd, struct scb_chan);

	if (!param(cmd, buffer, params,
		p_req("scb", param_array, &scb),
		NULL))
		return command_param_failed();

	response = json_stream_success(cmd);

	json_array_start(response, "stubs");
	json_for_each_arr(i,t,scb){

		char *token = json_strdup(tmpctx, buffer, t);
		const u8 *scb_arr = tal_hexdata(cmd, token, strlen(token));
		size_t scblen = tal_count(scb_arr);

		scb_chan = fromwire_scb_chan(cmd ,&scb_arr, &scblen);

		if (scb_chan == NULL) {
			log_broken(cmd->ld->log, "SCB is invalid!");
			continue;
		}

		struct lightningd *ld = cmd->ld;
		struct channel *channel= stub_chan(cmd,
						   scb_chan->id,
						   scb_chan->node_id,
						   scb_chan->cid,
						   scb_chan->funding,
						   scb_chan->addr,
						   scb_chan->funding_sats,
						   scb_chan->type);

		/* Returns NULL only when channel already exists, so we skip over it. */
		if (channel == NULL)
			continue;

		/* Now we put this in the database. */
		wallet_channel_insert(ld->wallet, channel);

		/* Watch the Funding */
		channel_watch_funding(ld, channel);

		json_add_channel_id(response, NULL, &scb_chan->cid);
	}

	/* This will try to reconnect to the peers and start
	* initiating the process */
	setup_peers(cmd->ld);