torrentutil.java

java 文件下载器。可自定义

					Logger.log(new LogAlert(dms[i], false, "Torrent export failed", e));
				}

			
			{
				composite = composite1;
				super(x0);
			}
			});
			MenuItem itemWebSeed = new MenuItem(menuExport, 8);
			Messages.setLanguageText(itemWebSeed, "MyTorrentsView.menu.exporthttpseeds");
			itemWebSeed.addListener(13, new DMTask(dms) {

				public void run(DownloadManager dms[])
				{
					String NL = "\r\n";
					String data = "";
					boolean http_enable = COConfigurationManager.getBooleanParameter("HTTP.Data.Listen.Port.Enable");
					String port;
					if (http_enable)
					{
						int p = COConfigurationManager.getIntParameter("HTTP.Data.Listen.Port");
						int o = COConfigurationManager.getIntParameter("HTTP.Data.Listen.Port.Override");
						if (o == 0)
							port = String.valueOf(p);
						else
							port = String.valueOf(o);
					} else
					{
						data = "You need to enable the HTTP port or modify the URL(s) appropriately\r\n\r\n";
						port = "<port>";
					}
					String ip = COConfigurationManager.getStringParameter("Tracker IP", "");
					if (ip.length() == 0)
					{
						data = (new StringBuilder()).append(data).append("You might need to modify the host address in the URL(s)\r\n\r\n").toString();
						try
						{
							InetAddress ia = AzureusCoreFactory.getSingleton().getInstanceManager().getMyInstance().getExternalAddress();
							if (ia != null)
								ip = IPToHostNameResolver.syncResolve(ia.getHostAddress(), 10000);
						}
						catch (Throwable e) { }
						if (ip.length() == 0)
							ip = "<host>";
					}
					String base = (new StringBuilder()).append("http://").append(UrlUtils.convertIPV6Host(ip)).append(":").append(port).append("/").toString();
					for (int i = 0; i < dms.length; i++)
					{
						DownloadManager dm = dms[i];
						if (dm == null)
							continue;
						TOTorrent torrent = dm.getTorrent();
						if (torrent == null)
							continue;
						data = (new StringBuilder()).append(data).append(base).append("webseed").append("\r\n").toString();
						try
						{
							data = (new StringBuilder()).append(data).append(base).append("files/").append(URLEncoder.encode(new String(torrent.getHash(), "ISO-8859-1"), "ISO-8859-1")).append("/").append("\r\n").append("\r\n").toString();
						}
						catch (Throwable e) { }
					}

					if (data.length() > 0)
						ClipboardCopy.copyToClipBoard(data);
				}

			});
		}
		if (userMode > 0)
		{
			MenuItem itemExportXML = new MenuItem(menuAdvanced, 8);
			Messages.setLanguageText(itemExportXML, "MainWindow.menu.view.configuration");
			itemExportXML.addListener(13, new DMTask(dms) {

				public void run(DownloadManager dms[])
				{
					UIFunctions uiFunctions = UIFunctionsManager.getUIFunctions();
					uiFunctions.openView(6, dms);
				}

			});
		}
		if (userMode > 0)
		{
			MenuItem itemPeerSource = new MenuItem(menuAdvanced, 64);
			Messages.setLanguageText(itemPeerSource, "MyTorrentsView.menu.peersource");
			Menu menuPeerSource = new Menu(composite.getShell(), 4);
			itemPeerSource.setMenu(menuPeerSource);
			for (int i = 0; i < PEPeerSource.PS_SOURCES.length; i++)
			{
				String p = PEPeerSource.PS_SOURCES[i];
				String msg_text = (new StringBuilder()).append("ConfigView.section.connection.peersource.").append(p).toString();
				MenuItem itemPS = new MenuItem(menuPeerSource, 32);
				itemPS.setData("peerSource", p);
				Messages.setLanguageText(itemPS, msg_text);
				itemPS.addListener(13, new DMTask(dms, p, itemPS) {

					final String val$p;
					final MenuItem val$itemPS;

					public void run(DownloadManager dm)
					{
						dm.getDownloadState().setPeerSourceEnabled(p, itemPS.getSelection());
					}

			
			{
				p = s;
				itemPS = menuitem;
				super(x0);
			}
				});
				itemPS.setSelection(true);
				boolean bChecked = hasSelection;
				boolean bEnabled = !hasSelection;
				if (bChecked)
				{
					bEnabled = true;
					for (int j = 0; j < dms.length; j++)
					{
						DownloadManager dm = dms[j];
						if (!dm.getDownloadState().isPeerSourceEnabled(p))
							bChecked = false;
						if (!dm.getDownloadState().isPeerSourcePermitted(p))
							bEnabled = false;
					}

				}
				itemPS.setSelection(bChecked);
				itemPS.setEnabled(bEnabled);
			}

		}
		if (userMode > 1)
		{
			MenuItem itemNetworks = new MenuItem(menuAdvanced, 64);
			Messages.setLanguageText(itemNetworks, "MyTorrentsView.menu.networks");
			Menu menuNetworks = new Menu(composite.getShell(), 4);
			itemNetworks.setMenu(menuNetworks);
			for (int i = 0; i < AENetworkClassifier.AT_NETWORKS.length; i++)
			{
				String nn = AENetworkClassifier.AT_NETWORKS[i];
				String msg_text = (new StringBuilder()).append("ConfigView.section.connection.networks.").append(nn).toString();
				MenuItem itemNetwork = new MenuItem(menuNetworks, 32);
				itemNetwork.setData("network", nn);
				Messages.setLanguageText(itemNetwork, msg_text);
				itemNetwork.addListener(13, new DMTask(dms, nn, itemNetwork) {

					final String val$nn;
					final MenuItem val$itemNetwork;

					public void run(DownloadManager dm)
					{
						dm.getDownloadState().setNetworkEnabled(nn, itemNetwork.getSelection());
					}

			
			{
				nn = s;
				itemNetwork = menuitem;
				super(x0);
			}
				});
				boolean bChecked = hasSelection;
				if (bChecked)
				{
					int j = 0;
					do
					{
						if (j >= dms.length)
							break;
						DownloadManager dm = dms[j];
						if (!dm.getDownloadState().isNetworkEnabled(nn))
						{
							bChecked = false;
							break;
						}
						j++;
					} while (true);
				}
				itemNetwork.setSelection(bChecked);
			}

		}
		if (userMode > 1 && isSeedingView)
		{
			MenuItem itemSuperSeed = new MenuItem(menuAdvanced, 32);
			Messages.setLanguageText(itemSuperSeed, "ManagerItem.superseeding");
			boolean enabled = canSetSuperSeed && (superSeedAllNo || superSeedAllYes);
			itemSuperSeed.setEnabled(enabled);
			boolean selected = superSeedAllNo;
			if (enabled)
			{
				itemSuperSeed.setSelection(selected);
				itemSuperSeed.addListener(13, new DMTask(dms, selected) {

					final boolean val$selected;

					public void run(DownloadManager dm)
					{
						PEPeerManager pm = dm.getPeerManager();
						if (pm != null && pm.isSuperSeedMode() == selected && pm.canToggleSuperSeedMode())
							pm.setSuperSeedMode(!selected);
					}

			
			{
				selected = flag;
				super(x0);
			}
				});
			}
		}
		MenuItem itemPositionManual = new MenuItem(menuAdvanced, 8);
		Messages.setLanguageText(itemPositionManual, "MyTorrentsView.menu.reposition.manual");
		itemPositionManual.addSelectionListener(new SelectionAdapter(azureus_core, isSeedingView, composite, tv, dms) {

			final AzureusCore val$azureus_core;
			final boolean val$isSeedingView;
			final Composite val$composite;
			final TableView val$tv;
			final DownloadManager val$dms[];

			public void widgetSelected(SelectionEvent e)
			{
				InputShell is = new InputShell("MyTorrentsView.dialog.setPosition.title", "MyTorrentsView.dialog.setPosition.text");
				String sReturn = is.open();
				if (sReturn == null)
					return;
				int newPosition = -1;
				try
				{
					newPosition = Integer.valueOf(sReturn).intValue();
				}
				catch (NumberFormatException er) { }
				int size = azureus_core.getGlobalManager().downloadManagerCount(isSeedingView);
				if (newPosition > size)
					newPosition = size;
				if (newPosition <= 0)
				{
					MessageBox mb = new MessageBox(composite.getShell(), 33);
					mb.setText(MessageText.getString("MyTorrentsView.dialog.NumberError.title"));
					mb.setMessage(MessageText.getString("MyTorrentsView.dialog.NumberError.text"));
					mb.open();
					return;
				} else
				{
					TorrentUtil.moveSelectedTorrentsTo(tv, dms, newPosition);
					return;
				}
			}

			
			{
				azureus_core = azureuscore;
				isSeedingView = flag;
				composite = composite1;
				tv = tableview;
				dms = adownloadmanager;
				super();
			}
		});
		if (userMode > 0 && isTrackerOn)
		{
			MenuItem itemHost = new MenuItem(menu, 8);
			Messages.setLanguageText(itemHost, "MyTorrentsView.menu.host");
			Utils.setMenuItemImage(itemHost, "host");
			itemHost.addListener(13, new Listener(dms, azureus_core, composite) {

				final DownloadManager val$dms[];
				final AzureusCore val$azureus_core;
				final Composite val$composite;

				public void handleEvent(Event event)
				{
					TorrentUtil.hostTorrents(dms, azureus_core, composite);
				}

			
			{
				dms = adownloadmanager;
				azureus_core = azureuscore;
				composite = composite1;
				super();
			}
			});
			MenuItem itemPublish = new MenuItem(menu, 8);
			Messages.setLanguageText(itemPublish, "MyTorrentsView.menu.publish");
			Utils.setMenuItemImage(itemPublish, "publish");
			itemPublish.addListener(13, new Listener(dms, azureus_core, composite) {

				final DownloadManager val$dms[];
				final AzureusCore val$azureus_core;
				final Composite val$composite;

				public void handleEvent(Event event)
				{
					TorrentUtil.publishTorrents(dms, azureus_core, composite);
				}

			
			{
				dms = adownloadmanager;
				azureus_core = azureuscore;
				composite = composite1;
				super();
			}
			});
			itemHost.setEnabled(hasSelection);
			itemPublish.setEnabled(hasSelection);
		}
		Menu menuCategory = new Menu(composite.getShell(), 4);
		MenuItem itemCategory = new MenuItem(menu, 64);
		Messages.setLanguageText(itemCategory, "MyTorrentsView.menu.setCategory");
		itemCategory.setMenu(menuCategory);
		itemCategory.setEnabled(hasSelection);
		addCategorySubMenu(dms, menuCategory, composite);
		MenuItem itemRenameAll = new MenuItem(menu, 64);
		Messages.setLanguageText(itemRenameAll, "MyTorrentsView.menu.rename");
		itemRenameAll.setEnabled(hasSelection);
		if (itemRenameAll.isEnabled())
		{
			itemRenameAll.setData("suggested_text", first_selected.getDisplayName());
			itemRenameAll.setData("display_name", Boolean.FALSE);
			itemRenameAll.setData("save_name", Boolean.FALSE);
			itemRenameAll.setData("rename_all", Boolean.TRUE);
			itemRenameAll.setData("msg_key", "displayed");
		}
		itemRenameAll.addListener(13, rename_listener);
		MenuItem itemEditComment = new MenuItem(menu, 64);
		Messages.setLanguageText(itemEditComment, "MyTorrentsView.menu.edit_comment");
		itemEditComment.setEnabled(dms.length > 0);
		itemEditComment.addListener(13, new DMTask(dms) {

			public void run(DownloadManager dms[])
			{
				TorrentUtil.promptUserForComment(dms);
			}

		});
		new MenuItem(menu, 2);
		MenuItem itemQueue = new MenuItem(menu, 8);
		Messages.setLanguageText(itemQueue, "MyTorrentsView.menu.queue");
		Utils.setMenuItemImage(itemQueue, "start");
		itemQueue.addListener(13, new DMTask(dms, menu) {

			final Menu val$menu;

			public void run(DownloadManager dms[])
			{
				TorrentUtil.queueTorrents(dms, menu.getShell());
			}

			
			{
				menu = menu1;
				super(x0);
			}
		});
		itemQueue.setEnabled(start);
		if (userMode > 0)
		{
			MenuItem itemForceStart = new MenuItem(menu, 32);
			Messages.setLanguageText(itemForceStart, "MyTorrentsView.menu.forceStart");
			Utils.setMenuItemImage(itemForceStart, "forcestart");
			itemForceStart.addListener(13, new DMTask(dms, itemForceStart) {

				final MenuItem val$itemForceStart;

				public void run(DownloadManager dm)
				{
					if (ManagerUtils.isForceStartable(dm))
						dm.setForceStart(itemForceStart.getSelection());
				}

			
			{
				itemForceStart = menuitem;
				super(x0);
			}
			});
			itemForceStart.setSelection(forceStart);
			itemForceStart.setEnabled(forceStartEnabled);
		}
		MenuItem itemStop = new MenuItem(menu, 8);
		Messages.setLanguageText(itemStop, "MyTorrentsView.menu.stop");
		Utils.setMenuItemImage(itemStop, "stop");
		itemStop.addListener(13, new DMTask(dms, menu) {

			final Menu val$menu;

			public void run(DownloadManager dms[])
			{
				TorrentUtil.stopTorrents(dms, menu.getShell());
			}

			
			{
				menu = menu1;
				super(x0);
			}
		});
		itemStop.setEnabled(stop);
		MenuItem itemRecheck = new MenuItem(menu, 8);
		Messages.setLanguageText(itemRecheck, "MyTorrentsView.menu.recheck");
		Utils.setMenuItemImage(itemRecheck, "recheck");
		itemRecheck.addListener(13, new DMTask(dms) {

			public void run(DownloadManager dm)
			{
				if (dm.canForceRecheck())
					dm.forceRecheck();
			}

		});
		itemRecheck.setEnabled(recheck);
		MenuItem itemRemove = new MenuItem(menu, 8);
		Messages.setLanguageText(itemRemove, "MyTorrentsView.menu.remove");
		Utils.setMenuItemImage(itemRemove, "delete");
		itemRemove.addListener(13, new DMTask(dms, menu) {

			final Menu val$menu;

			public void run(DownloadManager dm)
			{
				TorrentUtil.removeTorrent(dm, false, false, menu.getShell());
			}

			
			{
				menu = menu1;
				super(x0);
			}
		});
		itemRemove.setEnabled(hasSelection);
		MenuItem itemRemoveAnd = new MenuItem(menu, 64);
		Messages.setLanguageText(itemRemoveAnd, "MyTorrentsView.menu.removeand");
		Utils.setMenuItemImage(itemRemoveAnd, "delete");
		itemRemoveAnd.setEnabled(hasSelection);
		Menu menuRemove = new Menu(composite.getShell(), 4);
		itemRemoveAnd.setMenu(menuRemove);
		MenuItem itemDeleteTorrent = new MenuItem(menuRemove, 8);
		Messages.setLanguageText(itemDeleteTorrent, "MyTorrentsView.menu.removeand.deletetorrent");
		itemDeleteTorrent.addListener(13, new DMTask(dms, menu) {

			final Menu val$menu;

			public void run(DownloadManager dm)
			{
				TorrentUtil.removeTorrent(dm, true, false, menu.getShell());
			}