Class LinksInfo

ZezeJava/ZezeJava/src/main/java/Zeze/Arch/LinksInfo.java:16–104

import org.jetbrains.annotations.NotNull;

public class LinksInfo extends AbstractLinksInfo {
	private final Netty netty = new Netty();
	private final @NotNull HttpServer httpServer;
	private final AbstractAgent agent;
	private String defaultLinkServiceName;

	public LinksInfo() throws Exception {
		var conf = Config.load();
		agent = Application.createServiceManager(conf, "LinksInfo");
		if (agent == null)
			throw new IllegalStateException("agent is null. check your config for ServiceManager.");
		httpServer = new HttpServer();
		RegisterHttpServlet(httpServer);
	}

	public void start() throws Exception {
		agent.start();
		agent.waitReady();
		httpServer.start(netty, 80);
	}

	public void stop() throws Exception {
		agent.close();
		httpServer.close();
		netty.close();
	}

	public void subscribeLinkService(@NotNull String linkServiceName) {
		if (defaultLinkServiceName == null)
			defaultLinkServiceName = linkServiceName;
		agent.subscribeService(new BSubscribeInfo(linkServiceName));
	}

	public static void main(String @NotNull [] args) throws Exception {
		var linksInfo = new LinksInfo();
		linksInfo.start();
		for (var i = 0; i < args.length; ++i) {
			switch (args[i]) {
			case "-link":
				linksInfo.subscribeLinkService(args[++i]);
				break;
			case "-default":
				linksInfo.defaultLinkServiceName = args[++i];
				break;
			}
		}
		try {
			if (linksInfo.defaultLinkServiceName == null)
				throw new IllegalArgumentException("no link service present.");
			synchronized (Thread.currentThread()) {
				Thread.currentThread().wait();
			}
		} finally {
			linksInfo.stop();
		}
	}

	private void send(HttpExchange x, String sep) {