TpLink8970Reader.java

package it.albertus.routerlogger.reader;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.StringReader;
import java.util.LinkedHashMap;
import java.util.logging.Level;
import java.util.logging.Logger;

import it.albertus.routerlogger.resources.Messages;
import it.albertus.util.IOUtils;
import it.albertus.util.logging.LoggerFactory;

/**
 * <b>TP-Link TD-W8970 V1</b>. Comandi Telnet disponibili (case sensitive):
 * <ul>
 * <li><tt><b>adsl show info</b></tt></li>
 * <li><tt><b>wan show connection info</b></tt> (sconsigliato, verboso)</li>
 * <li><tt><b>wan show connection info <i>name</i></b></tt></li>
 * </ul>
 */
public class TpLink8970Reader extends Reader {

	private static final Logger logger = LoggerFactory.getLogger(TpLink8970Reader.class);

	public static class Defaults {
		public static final String COMMAND_INFO_ADSL = "adsl show info";

		private Defaults() {
			throw new IllegalAccessError("Constants class");
		}
	}

	public static final String DEVICE_MODEL_KEY = "lbl.device.model.tplink.8970";

	protected static final String COMMAND_PROMPT = "#";
	protected static final String LOGIN_PROMPT = ":";

	@Override
	public boolean login(final String username, final char[] password) throws IOException {
		final StringBuilder received = new StringBuilder();

		// Username...
		received.append(readFromTelnet(LOGIN_PROMPT, true).trim());
		writeToTelnet(username);

		// Password...
		received.append(readFromTelnet(LOGIN_PROMPT, true).trim());
		writeToTelnet(password);

		logger.log(Level.INFO, LOG_MASK_TELNET, received);
		received.setLength(0);

		// Welcome! (salto caratteri speciali (clear screen, ecc.)...
		final String welcome = readFromTelnet("-", true);
		received.append(readFromTelnet(COMMAND_PROMPT, true).trim());
		if (logger.isLoggable(Level.INFO)) {
			logger.log(Level.INFO, LOG_MASK_TELNET, welcome.charAt(welcome.length() - 1) + received.toString());
		}

		return true;
	}

	@Override
	public LinkedHashMap<String, String> readInfo() throws IOException {
		// Informazioni sulla portante ADSL...
		writeToTelnet(configuration.getString("tplink.8970.command.info.adsl", Defaults.COMMAND_INFO_ADSL));
		readFromTelnet("{", true); // Avanzamento del reader fino all'inizio dei dati di interesse.
		final LinkedHashMap<String, String> info = new LinkedHashMap<String, String>();

		BufferedReader reader = null;
		try {
			reader = new BufferedReader(new StringReader(readFromTelnet("}", false).trim()));
			String line;
			while ((line = reader.readLine()) != null) {
				info.put(line.substring(0, line.indexOf('=')).trim(), line.substring(line.indexOf('=') + 1).trim());
			}
		}
		finally {
			IOUtils.closeQuietly(reader);
		}
		readFromTelnet(COMMAND_PROMPT, true); // Avanzamento del reader fino al prompt dei comandi.

		// Informazioni sulla connessione ad Internet...
		final String commandInfoWan = configuration.getString("tplink.8970.command.info.wan");
		if (commandInfoWan != null && commandInfoWan.trim().length() != 0) {
			writeToTelnet(commandInfoWan);
			readFromTelnet("{", true);
			try {
				reader = new BufferedReader(new StringReader(readFromTelnet("}", false).trim()));
				String line;
				while ((line = reader.readLine()) != null) {
					info.put(line.substring(0, line.indexOf('=')).trim(), line.substring(line.indexOf('=') + 1).trim());
				}
			}
			finally {
				IOUtils.closeQuietly(reader);
			}
			readFromTelnet(COMMAND_PROMPT, true);
		}

		return info;
	}

	@Override
	public void logout() throws IOException {
		logger.info(Messages.get("msg.logging.out"));
		writeToTelnet("logout");
	}

	@Override
	public String getDeviceModel() {
		return Messages.get(DEVICE_MODEL_KEY);
	}

	@Override
	public String getImageFileName() {
		return "tplink_td_w8970v1.png";
	}

}