modules/m_event: Add event refs rebuild util w/ console cmd.

modules/console.cc

@@ -5852,6 +5852,20 @@ console_cmd__event__refs(opt &out, const string_view &line)
 	return true;
 }
 
+bool
+console_cmd__event__refs__rebuild(opt &out, const string_view &line)
+{
+	using prototype = void ();
+	static mods::import<prototype> rebuild
+	{
+		"m_event", "event_refs__rebuild"
+	};
+
+	rebuild();
+	out << "done" << std::endl;
+	return true;
+}
+
 //
 // state
 //

modules/m_event.cc

@@ -556,3 +556,64 @@ pretty_oneline__prev(std::ostream &s,
 		s << unquote(prev_event[0]) << " ";
 	s << "] ";
 }
+
+extern "C" void
+event_refs__rebuild()
+{
+	static const size_t pool_size{64};
+	static const size_t log_interval{8192};
+
+	db::txn txn
+	{
+		*m::dbs::events
+	};
+
+	auto &column
+	{
+		dbs::event_json
+	};
+
+	auto it
+	{
+		column.begin()
+	};
+
+	ctx::dock dock;
+	ctx::pool pool;
+	pool.min(pool_size);
+	size_t i(0), j(0);
+	for(; it; ++it)
+	{
+		std::string event{it->second};
+		const m::event::idx event_idx
+		{
+			byte_view<m::event::idx>(it->first)
+		};
+
+		pool([&txn, &dock, &i, &j, event(std::move(event)), event_idx]
+		{
+			m::dbs::write_opts wopts;
+			wopts.event_idx = event_idx;
+			m::dbs::_index_event_refs(txn, json::object{event}, wopts);
+			if(++j % log_interval == 0) log::info
+			{
+				m::log, "Refs builder @%zu:%zu of %lu (@idx: %lu)",
+				i,
+				j,
+				m::vm::current_sequence,
+				event_idx
+			};
+
+			dock.notify_one();
+		});
+
+		++i;
+	}
+
+	dock.wait([&i, &j]
+	{
+		return i == j;
+	});
+
+	txn();
+}