consoleinput.java

java 文件下载器。可自定义

	}

	public void downloadRemoteTorrent(String url)
	{
		downloadRemoteTorrent(url, getDefaultSaveDirectory());
	}

	private void registerPluginCommands()
	{
		for (Iterator iter = pluginCommands.iterator(); iter.hasNext();)
		{
			Class clazz = (Class)iter.next();
			try
			{
				IConsoleCommand command = (IConsoleCommand)clazz.newInstance();
				registerCommand(command);
			}
			catch (InstantiationException e)
			{
				out.println((new StringBuilder()).append("Error while registering plugin command: ").append(clazz.getName()).append(":").append(e.getMessage()).toString());
			}
			catch (IllegalAccessException e)
			{
				out.println((new StringBuilder()).append("Error while registering plugin command: ").append(clazz.getName()).append(":").append(e.getMessage()).toString());
			}
		}

	}

	protected void registerAlertHandler()
	{
		org.gudy.azureus2.core3.logging.Logger.addListener(new ILogAlertListener() {

			private Set history;
			final ConsoleInput this$0;

			public void alertRaised(LogAlert alert)
			{
				if (!alert.repeatable)
				{
					if (history.contains(alert.text))
						return;
					history.add(alert.text);
				}
				out.println(alert.text);
				if (alert.err != null)
					alert.err.printStackTrace(out);
			}

			
			{
				this$0 = ConsoleInput.this;
				super();
				history = Collections.synchronizedSet(new HashSet());
			}
		});
	}

	protected void registerCommands()
	{
		registerCommand(new XML());
		registerCommand(new Hack());
		registerCommand(new AddFind());
		registerCommand(new TorrentCheck());
		registerCommand(new TorrentQueue());
		registerCommand(new TorrentRemove());
		registerCommand(new TorrentStart());
		registerCommand(new TorrentStop());
		registerCommand(new TorrentHost());
		registerCommand(new TorrentPublish());
		registerCommand(new TorrentForceStart());
		registerCommand(new TorrentLog());
		registerCommand(new Log());
		registerCommand(new Move());
		registerCommand(new Share());
		registerCommand(new org.gudy.azureus2.ui.console.commands.Set());
		registerCommand(new Show());
		registerCommand(new CommandUI());
		registerCommand(new CommandLogout());
		registerCommand(new CommandQuit());
		registerCommand(new CommandHelp());
		registerCommand(new Alias());
		registerCommand(new Priority());
		registerCommand(new Plugin());
	}

	protected void registerCommand(IConsoleCommand command)
	{
		String cmdName;
		for (Iterator iter = command.getCommandNames().iterator(); iter.hasNext(); commands.put(cmdName, command))
			cmdName = (String)iter.next();

		helpItems.add(command);
	}

	protected void unregisterCommand(IConsoleCommand command)
	{
		Iterator iter = command.getCommandNames().iterator();
		do
		{
			if (!iter.hasNext())
				break;
			String cmdName = (String)iter.next();
			if (command.equals(commands.get(cmdName)))
				commands.remove(cmdName);
		} while (true);
		helpItems.remove(command);
	}

	protected void unregisterCommand(String commandName)
	{
		IConsoleCommand cmd = (IConsoleCommand)commands.get(commandName);
		if (cmd == null)
			return;
		int numCommands = 0;
		Iterator iter = commands.entrySet().iterator();
		do
		{
			if (!iter.hasNext())
				break;
			java.util.Map.Entry entry = (java.util.Map.Entry)iter.next();
			if (cmd.equals(entry.getValue()))
				numCommands++;
		} while (true);
		if (numCommands == 1)
			unregisterCommand(cmd);
		else
			commands.remove(commandName);
	}

	public ConsoleInput(String con, AzureusCore _azureus_core, InputStream _in, PrintStream _out, Boolean _controlling)
	{
		this(con, _azureus_core, ((Reader) (new InputStreamReader(_in))), _out, _controlling);
	}

	private static void quit(boolean finish)
	{
		if (finish)
			UIConst.shutdown();
	}

	public void printwelcome()
	{
		out.println((new StringBuilder()).append("Running ").append(Constants.APP_NAME).append(" ").append("4.2.0.0").append("...").toString());
		out.println("Using configuration settings from:");
		out.println((new StringBuilder()).append("  ").append(SystemProperties.getUserPath()).toString());
	}

	public void printconsolehelp()
	{
		printconsolehelp(out);
	}

	private void printconsolehelp(PrintStream os)
	{
		os.println("> -----");
		os.println("Available console commands (use help <command> for more details):");
		os.println();
		ArrayList cmd_lines = new ArrayList();
		StringBuffer line_so_far;
		for (Iterator itr = helpItems.iterator(); itr.hasNext(); cmd_lines.add(line_so_far.toString()))
		{
			line_so_far = new StringBuffer("[");
			IConsoleCommand cmd = (IConsoleCommand)itr.next();
			String short_name = cmd.getShortCommandName();
			if (short_name != null)
				line_so_far.append(short_name);
			line_so_far.append("] ");
			line_so_far.append(cmd.getCommandName());
		}

		TextWrap.printList(cmd_lines.iterator(), os, "   ");
		os.println("> -----");
	}

	public boolean invokeCommand(String command, List cargs)
	{
		IConsoleCommand cmd;
		if (command.startsWith("\\"))
			command = command.substring(1);
		else
		if (aliases.containsKey(command))
		{
			List list = br.parseCommandLine(aliases.getProperty(command));
			String newCommand = list.remove(0).toString().toLowerCase();
			list.addAll(cargs);
			return invokeCommand(newCommand, list);
		}
		if (!commands.containsKey(command))
			break MISSING_BLOCK_LABEL_167;
		cmd = (IConsoleCommand)commands.get(command);
		if (cargs == null)
			cargs = new ArrayList();
		cmd.execute(command, this, cargs);
		return true;
		Exception e;
		e;
		out.println((new StringBuilder()).append("> Invoking Command '").append(command).append("' failed. Exception: ").append(Debug.getNestedExceptionMessage(e)).toString());
		return false;
		return false;
	}

	public void run()
	{
		running = true;
		do
		{
			if (!running)
				break;
			List comargs;
			try
			{
				String line = br.readLine();
				comargs = br.parseCommandLine(line);
			}
			catch (Exception e)
			{
				out.println((new StringBuilder()).append("Stopping console input reader because of exception: ").append(e.getMessage()).toString());
				running = false;
				break;
			}
			if (!comargs.isEmpty())
			{
				String command = ((String)comargs.get(0)).toLowerCase();
				if (".".equals(command))
					if (oldcommand != null)
					{
						comargs.clear();
						comargs.addAll(oldcommand);
						command = ((String)comargs.get(0)).toLowerCase();
					} else
					{
						out.println("No old command. Remove commands are not repeated to prevent errors");
					}
				oldcommand.clear();
				oldcommand.addAll(comargs);
				comargs.remove(0);
				try
				{
					if (!invokeCommand(command, comargs))
						out.println((new StringBuilder()).append("> Command '").append(command).append("' unknown (or . used without prior command)").toString());
				}
				catch (Throwable e)
				{
					out.println((new StringBuilder()).append("Exception occurred when executing command: '").append(command).append("'").toString());
					e.printStackTrace(out);
				}
			}
		} while (true);
	}

	private File getAliasesFile()
	{
		PluginInterface pi = azureus_core.getPluginManager().getDefaultPluginInterface();
		String azureusUserDir = pi.getUtilities().getAzureusUserDir();
		return new File(azureusUserDir, "console.aliases.properties");
	}

	private void loadAliases()
		throws IOException
	{
		FileInputStream fr;
		File aliasesFile = getAliasesFile();
		out.println((new StringBuilder()).append("Attempting to load aliases from: ").append(aliasesFile.getCanonicalPath()).toString());
		if (!aliasesFile.exists())
			break MISSING_BLOCK_LABEL_79;
		fr = new FileInputStream(aliasesFile);
		aliases.clear();
		aliases.load(fr);
		fr.close();
		break MISSING_BLOCK_LABEL_79;
		Exception exception;
		exception;
		fr.close();
		throw exception;
	}

	public void saveAliases()
	{
		File aliasesFile = getAliasesFile();
		try
		{
			out.println((new StringBuilder()).append("Saving aliases to: ").append(aliasesFile.getCanonicalPath()).toString());
			FileOutputStream fo = new FileOutputStream(aliasesFile);
			aliases.store(fo, "This aliases file was automatically written by Azureus");
		}
		catch (IOException e)
		{
			out.println((new StringBuilder()).append("> Error saving aliases to ").append(aliasesFile.getPath()).append(":").append(e.getMessage()).toString());
		}
	}

	public UserProfile getUserProfile()
	{
		return userProfile;
	}

	public String getDefaultSaveDirectory()
	{
		String saveDir;
		saveDir = getUserProfile().getDefaultSaveDirectory();
		if (saveDir == null)
		{
			saveDir = COConfigurationManager.getDirectoryParameter("Default save path");
			if (saveDir == null || saveDir.length() == 0)
				saveDir = ".";
		}
		return saveDir;
		Exception e;
		e;
		e.printStackTrace();
		return ".";
	}

	protected void registerUpdateChecker()
	{
		boolean check_at_start = COConfigurationManager.getBooleanParameter("update.start", true);
		if (!check_at_start)
			return;
		PluginManager pm = azureus_core.getPluginManager();
		pm.getPluginInstaller().addListener(new PluginInstallerListener() {

			final ConsoleInput this$0;

			public boolean installRequest(String reason, InstallablePlugin plugin)
				throws PluginException
			{
				out.println((new StringBuilder()).append("Plugin installation request for '").append(plugin.getName()).append("' - ").append(reason).toString());
				String desc = plugin.getDescription();
				String bits[] = desc.split("\n");
				for (int i = 0; i < bits.length; i++)
					out.println((new StringBuilder()).append("\t").append(bits[i]).toString());

				return true;
			}

			
			{
				this$0 = ConsoleInput.this;
				super();
			}
		});
		PluginInterface pi = pm.getPluginInterfaceByClass(org/gudy/azureus2/update/CorePatchChecker);
		if (pi != null)
			pi.getPluginState().setDisabled(true);
		pi = pm.getPluginInterfaceByClass(org/gudy/azureus2/update/UpdaterUpdateChecker);
		if (pi != null)
			pi.getPluginState().setDisabled(true);
		UpdateManager update_manager = azureus_core.getPluginManager().getDefaultPluginInterface().getUpdateManager();
		UpdateCheckInstance checker = update_manager.createUpdateCheckInstance();
		checker.addListener(new UpdateCheckInstanceListener() {

			final ConsoleInput this$0;

			public void cancelled(UpdateCheckInstance updatecheckinstance)
			{
			}

			public void complete(UpdateCheckInstance instance)
			{
				Update updates[] = instance.getUpdates();
				for (int i = 0; i < updates.length; i++)
				{
					Update update = updates[i];
					out.println((new StringBuilder()).append("Update available for '").append(update.getName()).append("', new version = ").append(update.getNewVersion()).toString());
					String descs[] = update.getDescription();
					for (int j = 0; j < descs.length; j++)
						out.println((new StringBuilder()).append("\t").append(descs[j]).toString());

				}

			}

			
			{
				this$0 = ConsoleInput.this;
				super();
			}
		});
		checker.start();
	}

	public AzureusCore getCore()
	{
		return azureus_core;
	}

	public GlobalManager getGlobalManager()
	{
		return azureus_core.getGlobalManager();
	}







}