Kumaresan Rajeswaran
9 years ago
597 changed files with 8625 additions and 9122 deletions
@ -0,0 +1,59 @@ |
|||||||
|
/* |
||||||
|
* Copyright 2010-2013 Eric Kok et al. |
||||||
|
* |
||||||
|
* Transdroid is free software: you can redistribute it and/or modify |
||||||
|
* it under the terms of the GNU General Public License as published by |
||||||
|
* the Free Software Foundation, either version 3 of the License, or |
||||||
|
* (at your option) any later version. |
||||||
|
* |
||||||
|
* Transdroid is distributed in the hope that it will be useful, |
||||||
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
||||||
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
||||||
|
* GNU General Public License for more details. |
||||||
|
* |
||||||
|
* You should have received a copy of the GNU General Public License |
||||||
|
* along with Transdroid. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
*/ |
||||||
|
package org.transdroid.core.gui; |
||||||
|
|
||||||
|
import android.content.Context; |
||||||
|
import android.widget.RelativeLayout; |
||||||
|
import android.widget.TextView; |
||||||
|
|
||||||
|
import org.androidannotations.annotations.EViewGroup; |
||||||
|
import org.androidannotations.annotations.ViewById; |
||||||
|
import org.transdroid.R; |
||||||
|
import org.transdroid.core.gui.navigation.NavigationFilter; |
||||||
|
import org.transdroid.daemon.IDaemonAdapter; |
||||||
|
|
||||||
|
@EViewGroup(R.layout.actionbar_serverselection) |
||||||
|
public class ServerSelectionView extends RelativeLayout { |
||||||
|
|
||||||
|
@ViewById |
||||||
|
protected TextView filterText, serverText; |
||||||
|
|
||||||
|
public ServerSelectionView(Context context) { |
||||||
|
super(context); |
||||||
|
} |
||||||
|
|
||||||
|
public ServerSelectionView(TorrentsActivity activity) { |
||||||
|
super(activity.torrentsToolbar.getContext()); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Updates the name of the current connected server. |
||||||
|
* @param currentServer The server currently connected to |
||||||
|
*/ |
||||||
|
public void updateCurrentServer(IDaemonAdapter currentServer) { |
||||||
|
serverText.setText(currentServer.getSettings().getName()); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Updates the name of the selected filter. |
||||||
|
* @param currentFilter The filter that is currently selected |
||||||
|
*/ |
||||||
|
public void updateCurrentFilter(NavigationFilter currentFilter) { |
||||||
|
filterText.setText(currentFilter.getName()); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
File diff suppressed because it is too large
Load Diff
@ -1,17 +0,0 @@ |
|||||||
package org.transdroid.core.gui.lists; |
|
||||||
|
|
||||||
import org.transdroid.R; |
|
||||||
|
|
||||||
import uk.co.senab.actionbarpulltorefresh.library.DefaultHeaderTransformer; |
|
||||||
import android.app.Activity; |
|
||||||
import android.view.View; |
|
||||||
|
|
||||||
public class NoProgressHeaderTransformer extends DefaultHeaderTransformer { |
|
||||||
|
|
||||||
@Override |
|
||||||
public void onViewCreated(Activity activity, View headerView) { |
|
||||||
super.onViewCreated(activity, headerView); |
|
||||||
setProgressBarColor(activity.getResources().getColor(R.color.green)); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,70 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2010-2013 Eric Kok et al. |
|
||||||
* |
|
||||||
* Transdroid is free software: you can redistribute it and/or modify |
|
||||||
* it under the terms of the GNU General Public License as published by |
|
||||||
* the Free Software Foundation, either version 3 of the License, or |
|
||||||
* (at your option) any later version. |
|
||||||
* |
|
||||||
* Transdroid is distributed in the hope that it will be useful, |
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
||||||
* GNU General Public License for more details. |
|
||||||
* |
|
||||||
* You should have received a copy of the GNU General Public License |
|
||||||
* along with Transdroid. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/ |
|
||||||
package org.transdroid.core.gui.navigation; |
|
||||||
|
|
||||||
import org.androidannotations.annotations.EBean; |
|
||||||
import org.transdroid.daemon.IDaemonAdapter; |
|
||||||
|
|
||||||
import android.view.View; |
|
||||||
import android.view.ViewGroup; |
|
||||||
|
|
||||||
/** |
|
||||||
* List adapter that holds filter items, that is, servers, view types and labels and is displayed as content to a |
|
||||||
* Spinner instead of a ListView. |
|
||||||
* @author Eric Kok |
|
||||||
*/ |
|
||||||
@EBean |
|
||||||
public class FilterListDropDownAdapter extends FilterListAdapter { |
|
||||||
|
|
||||||
protected NavigationSelectionView navigationSelectionView = null; |
|
||||||
private String currentServer = null; |
|
||||||
private String currentFilter = null; |
|
||||||
|
|
||||||
@Override |
|
||||||
public View getView(int position, View convertView, ViewGroup parent) { |
|
||||||
// This returns the singleton navigation spinner view
|
|
||||||
if (navigationSelectionView == null) { |
|
||||||
navigationSelectionView = NavigationSelectionView_.build(context); |
|
||||||
} |
|
||||||
navigationSelectionView.bind(currentServer, currentFilter); |
|
||||||
return navigationSelectionView; |
|
||||||
} |
|
||||||
|
|
||||||
@Override |
|
||||||
public View getDropDownView(int position, View convertView, ViewGroup parent) { |
|
||||||
// This returns the item to show in the drop down list
|
|
||||||
return super.getView(position, convertView, parent); |
|
||||||
} |
|
||||||
|
|
||||||
public void updateCurrentFilter(NavigationFilter currentFilter) { |
|
||||||
this.currentFilter = currentFilter.getName(); |
|
||||||
if (navigationSelectionView != null) |
|
||||||
navigationSelectionView.bind(this.currentServer, this.currentFilter); |
|
||||||
} |
|
||||||
|
|
||||||
public void updateCurrentServer(IDaemonAdapter currentConnection) { |
|
||||||
this.currentServer = currentConnection.getSettings().getName(); |
|
||||||
if (navigationSelectionView != null) |
|
||||||
navigationSelectionView.bind(this.currentServer, this.currentFilter); |
|
||||||
} |
|
||||||
|
|
||||||
public void hideServersLabel() { |
|
||||||
serverSeparator.setViewVisibility(View.GONE); |
|
||||||
notifyDataSetInvalidated(); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,52 +0,0 @@ |
|||||||
/* |
|
||||||
* Copyright 2010-2013 Eric Kok et al. |
|
||||||
* |
|
||||||
* Transdroid is free software: you can redistribute it and/or modify |
|
||||||
* it under the terms of the GNU General Public License as published by |
|
||||||
* the Free Software Foundation, either version 3 of the License, or |
|
||||||
* (at your option) any later version. |
|
||||||
* |
|
||||||
* Transdroid is distributed in the hope that it will be useful, |
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
||||||
* GNU General Public License for more details. |
|
||||||
* |
|
||||||
* You should have received a copy of the GNU General Public License |
|
||||||
* along with Transdroid. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
*/ |
|
||||||
package org.transdroid.core.gui.navigation; |
|
||||||
|
|
||||||
import org.androidannotations.annotations.EViewGroup; |
|
||||||
import org.androidannotations.annotations.ViewById; |
|
||||||
|
|
||||||
import android.content.Context; |
|
||||||
import android.widget.LinearLayout; |
|
||||||
import android.widget.TextView; |
|
||||||
|
|
||||||
/** |
|
||||||
* View that displays the user-selected server and display filter inside the action bar list navigation spinner |
|
||||||
* @author Eric Kok |
|
||||||
*/ |
|
||||||
@EViewGroup(resName="actionbar_navigation") |
|
||||||
public class NavigationSelectionView extends LinearLayout { |
|
||||||
|
|
||||||
@ViewById |
|
||||||
protected TextView filterText; |
|
||||||
@ViewById |
|
||||||
protected TextView serverText; |
|
||||||
|
|
||||||
public NavigationSelectionView(Context context) { |
|
||||||
super(context); |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* Binds the names of the current connected server and selected filter to this navigation view. |
|
||||||
* @param currentServer The name of the server currently connected to |
|
||||||
* @param currentFilter The name of the filter that is currently selected |
|
||||||
*/ |
|
||||||
public void bind(String currentServer, String currentFilter) { |
|
||||||
serverText.setText(currentServer); |
|
||||||
filterText.setText(currentFilter); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -1,117 +0,0 @@ |
|||||||
package org.transdroid.core.gui.settings; |
|
||||||
|
|
||||||
import org.transdroid.R; |
|
||||||
|
|
||||||
import android.content.Context; |
|
||||||
import android.preference.Preference; |
|
||||||
import android.util.AttributeSet; |
|
||||||
import android.view.View; |
|
||||||
import android.view.View.OnClickListener; |
|
||||||
import android.view.ViewGroup; |
|
||||||
import android.widget.ImageButton; |
|
||||||
|
|
||||||
/** |
|
||||||
* A {@link Preference} item that shows an extra overflow button at the right side of the screen. The action attached to |
|
||||||
* this button is set using {@link #setOnOverflowClickedListener(OnOverflowClicked)}. Normal clicks on this preference |
|
||||||
* are handled in the standard way. |
|
||||||
* @author Eric Kok |
|
||||||
*/ |
|
||||||
public class OverflowPreference extends Preference { |
|
||||||
|
|
||||||
private OnPreferenceClickListener onPreferenceClickListener = null; |
|
||||||
private OnOverflowClicked onOverflowClickedListener = null; |
|
||||||
private ImageButton overflowButton = null; |
|
||||||
|
|
||||||
public OverflowPreference(Context context) { |
|
||||||
super(context); |
|
||||||
init(); |
|
||||||
} |
|
||||||
|
|
||||||
public OverflowPreference(Context context, AttributeSet attrs) { |
|
||||||
super(context, attrs); |
|
||||||
init(); |
|
||||||
} |
|
||||||
|
|
||||||
public OverflowPreference(Context context, AttributeSet attrs, int defStyle) { |
|
||||||
super(context, attrs, defStyle); |
|
||||||
init(); |
|
||||||
} |
|
||||||
|
|
||||||
@Override |
|
||||||
protected View onCreateView(ViewGroup parent) { |
|
||||||
View layout = super.onCreateView(parent); |
|
||||||
// Since the Preference layout is now created, we can attach the proper click listeners
|
|
||||||
layout.setClickable(true); |
|
||||||
layout.setFocusable(true); |
|
||||||
// When setting the background drawable the padding on this Preference layout disappears, so add it again
|
|
||||||
int bottom = layout.getPaddingBottom(); |
|
||||||
int top = layout.getPaddingTop(); |
|
||||||
int right = layout.getPaddingRight(); |
|
||||||
int left = layout.getPaddingLeft(); |
|
||||||
layout.setBackgroundResource(R.drawable.selectable_background_holo_light); |
|
||||||
layout.setPadding(left, top, right, bottom); |
|
||||||
layout.setOnClickListener(new OnClickListener() { |
|
||||||
@Override |
|
||||||
public void onClick(View v) { |
|
||||||
if (onPreferenceClickListener != null) |
|
||||||
onPreferenceClickListener.onPreferenceClick(OverflowPreference.this); |
|
||||||
} |
|
||||||
}); |
|
||||||
overflowButton = (ImageButton) layout.findViewById(R.id.overflow_button); |
|
||||||
overflowButton.setOnClickListener(new OnClickListener() { |
|
||||||
@Override |
|
||||||
public void onClick(View v) { |
|
||||||
if (onOverflowClickedListener != null) |
|
||||||
onOverflowClickedListener.onOverflowClicked(v); |
|
||||||
} |
|
||||||
}); |
|
||||||
return layout; |
|
||||||
} |
|
||||||
|
|
||||||
public void init() { |
|
||||||
// Load an overflow-style image button as custom widget in the right of this Preference layout
|
|
||||||
setWidgetLayoutResource(R.layout.pref_withoverflow); |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* Hides the overflow button (on the right side of the Preference) from the UI. |
|
||||||
*/ |
|
||||||
public void hideOverflowButton() { |
|
||||||
if (overflowButton != null) { |
|
||||||
overflowButton.setVisibility(View.GONE); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* Shows (after hiding it) the overflow button (on the right side of the Preference) in the UI. |
|
||||||
*/ |
|
||||||
public void showOverflowButton() { |
|
||||||
if (overflowButton != null) { |
|
||||||
overflowButton.setVisibility(View.VISIBLE); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
@Override |
|
||||||
public void setOnPreferenceClickListener(OnPreferenceClickListener onPreferenceClickListener) { |
|
||||||
// Instead of the build-in list item click behaviour, we have to manually assign the click listener to this
|
|
||||||
// Preference item, as we stole the focus behaviour when we added a Button to the Preference layout
|
|
||||||
this.onPreferenceClickListener = onPreferenceClickListener; |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* Registers the listener for clicks on the overflow button contained in this preference. |
|
||||||
* @param onOverflowClickedListener The overflow button click listener |
|
||||||
*/ |
|
||||||
public void setOnOverflowClickedListener(OnOverflowClicked onOverflowClickedListener) { |
|
||||||
this.onOverflowClickedListener = onOverflowClickedListener; |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* An interface to be implemented by any activity (or otherwise) that wants to handle events when the contained |
|
||||||
* overflow button is clicked. |
|
||||||
*/ |
|
||||||
public interface OnOverflowClicked { |
|
||||||
public void onOverflowClicked(View overflowButton); |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
@ -0,0 +1,72 @@ |
|||||||
|
package org.transdroid.core.gui.settings; |
||||||
|
|
||||||
|
import android.content.res.Configuration; |
||||||
|
import android.os.Bundle; |
||||||
|
import android.preference.PreferenceActivity; |
||||||
|
import android.support.annotation.Nullable; |
||||||
|
import android.support.v7.app.ActionBar; |
||||||
|
import android.support.v7.app.AppCompatCallback; |
||||||
|
import android.support.v7.app.AppCompatDelegate; |
||||||
|
import android.support.v7.view.ActionMode; |
||||||
|
|
||||||
|
public class PreferenceCompatActivity extends PreferenceActivity implements AppCompatCallback { |
||||||
|
|
||||||
|
private AppCompatDelegate acd; |
||||||
|
|
||||||
|
@Override |
||||||
|
protected void onCreate(Bundle savedInstanceState) { |
||||||
|
super.onCreate(savedInstanceState); |
||||||
|
acd = AppCompatDelegate.create(this, this); |
||||||
|
acd.onCreate(savedInstanceState); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
protected void onPostCreate(Bundle savedInstanceState) { |
||||||
|
super.onPostCreate(savedInstanceState); |
||||||
|
acd.onPostCreate(savedInstanceState); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void onConfigurationChanged(Configuration newConfig) { |
||||||
|
super.onConfigurationChanged(newConfig); |
||||||
|
acd.onConfigurationChanged(newConfig); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void setTitle(CharSequence title) { |
||||||
|
super.setTitle(title); |
||||||
|
acd.setTitle(title); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
protected void onStop() { |
||||||
|
super.onStop(); |
||||||
|
acd.onStop(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
protected void onDestroy() { |
||||||
|
super.onDestroy(); |
||||||
|
acd.onDestroy(); |
||||||
|
} |
||||||
|
|
||||||
|
public ActionBar getSupportActionBar() { |
||||||
|
return acd.getSupportActionBar(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void onSupportActionModeStarted(ActionMode actionMode) { |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void onSupportActionModeFinished(ActionMode actionMode) { |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
@Nullable |
||||||
|
@Override |
||||||
|
public ActionMode onWindowStartingSupportActionMode(ActionMode.Callback callback) { |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,450 @@ |
|||||||
|
/* |
||||||
|
* This file is part of Transdroid <http://www.transdroid.org>
|
||||||
|
* |
||||||
|
* Transdroid is free software: you can redistribute it and/or modify |
||||||
|
* it under the terms of the GNU General Public License as published by |
||||||
|
* the Free Software Foundation, either version 3 of the License, or |
||||||
|
* (at your option) any later version. |
||||||
|
* |
||||||
|
* Transdroid is distributed in the hope that it will be useful, |
||||||
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
||||||
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
||||||
|
* GNU General Public License for more details. |
||||||
|
* |
||||||
|
* You should have received a copy of the GNU General Public License |
||||||
|
* along with Transdroid. If not, see <http://www.gnu.org/licenses/>.
|
||||||
|
* |
||||||
|
*/ |
||||||
|
package org.transdroid.daemon.Ttorrent; |
||||||
|
|
||||||
|
import com.android.internalcopy.http.multipart.FilePart; |
||||||
|
import com.android.internalcopy.http.multipart.MultipartEntity; |
||||||
|
import com.android.internalcopy.http.multipart.Part; |
||||||
|
|
||||||
|
import org.apache.http.HttpEntity; |
||||||
|
import org.apache.http.HttpResponse; |
||||||
|
import org.apache.http.NameValuePair; |
||||||
|
import org.apache.http.client.entity.UrlEncodedFormEntity; |
||||||
|
import org.apache.http.client.methods.HttpPost; |
||||||
|
import org.apache.http.cookie.Cookie; |
||||||
|
import org.apache.http.impl.client.DefaultHttpClient; |
||||||
|
import org.apache.http.message.BasicNameValuePair; |
||||||
|
import org.apache.http.protocol.HTTP; |
||||||
|
import org.json.JSONArray; |
||||||
|
import org.json.JSONException; |
||||||
|
import org.json.JSONObject; |
||||||
|
import org.transdroid.core.gui.log.Log; |
||||||
|
import org.transdroid.daemon.Daemon; |
||||||
|
import org.transdroid.daemon.DaemonException; |
||||||
|
import org.transdroid.daemon.DaemonException.ExceptionType; |
||||||
|
import org.transdroid.daemon.DaemonSettings; |
||||||
|
import org.transdroid.daemon.IDaemonAdapter; |
||||||
|
import org.transdroid.daemon.Priority; |
||||||
|
import org.transdroid.daemon.Torrent; |
||||||
|
import org.transdroid.daemon.TorrentDetails; |
||||||
|
import org.transdroid.daemon.TorrentFile; |
||||||
|
import org.transdroid.daemon.TorrentStatus; |
||||||
|
import org.transdroid.daemon.task.AddByFileTask; |
||||||
|
import org.transdroid.daemon.task.AddByMagnetUrlTask; |
||||||
|
import org.transdroid.daemon.task.AddByUrlTask; |
||||||
|
import org.transdroid.daemon.task.DaemonTask; |
||||||
|
import org.transdroid.daemon.task.DaemonTaskFailureResult; |
||||||
|
import org.transdroid.daemon.task.DaemonTaskResult; |
||||||
|
import org.transdroid.daemon.task.DaemonTaskSuccessResult; |
||||||
|
import org.transdroid.daemon.task.GetFileListTask; |
||||||
|
import org.transdroid.daemon.task.GetFileListTaskSuccessResult; |
||||||
|
import org.transdroid.daemon.task.GetTorrentDetailsTask; |
||||||
|
import org.transdroid.daemon.task.GetTorrentDetailsTaskSuccessResult; |
||||||
|
import org.transdroid.daemon.task.RemoveTask; |
||||||
|
import org.transdroid.daemon.task.RetrieveTask; |
||||||
|
import org.transdroid.daemon.task.RetrieveTaskSuccessResult; |
||||||
|
import org.transdroid.daemon.task.SetFilePriorityTask; |
||||||
|
import org.transdroid.daemon.task.SetTransferRatesTask; |
||||||
|
import org.transdroid.daemon.util.HttpHelper; |
||||||
|
|
||||||
|
import java.io.File; |
||||||
|
import java.io.FileNotFoundException; |
||||||
|
import java.io.UnsupportedEncodingException; |
||||||
|
import java.net.URI; |
||||||
|
import java.net.URLEncoder; |
||||||
|
import java.util.ArrayList; |
||||||
|
import java.util.Collections; |
||||||
|
import java.util.List; |
||||||
|
|
||||||
|
/** |
||||||
|
* The daemon adapter for the tTorrent Android torrent client. |
||||||
|
* @author erickok |
||||||
|
*/ |
||||||
|
public class TtorrentAdapter implements IDaemonAdapter { |
||||||
|
|
||||||
|
private static final String LOG_NAME = "tTorrent daemon"; |
||||||
|
|
||||||
|
private DaemonSettings settings; |
||||||
|
private DefaultHttpClient httpclient; |
||||||
|
|
||||||
|
public TtorrentAdapter(DaemonSettings settings) { |
||||||
|
this.settings = settings; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public DaemonTaskResult executeTask(Log log, DaemonTask task) { |
||||||
|
|
||||||
|
try { |
||||||
|
switch (task.getMethod()) { |
||||||
|
case Retrieve: |
||||||
|
|
||||||
|
// Request all torrents from server
|
||||||
|
JSONArray result = new JSONArray(makeRequest(log, "/json/events")); |
||||||
|
return new RetrieveTaskSuccessResult((RetrieveTask) task, parseJsonTorrents(result), null); |
||||||
|
|
||||||
|
case GetTorrentDetails: |
||||||
|
|
||||||
|
// Request tracker and error details for a specific teacher
|
||||||
|
String mhash = task.getTargetTorrent().getUniqueID(); |
||||||
|
JSONArray messages = |
||||||
|
new JSONArray(makeRequest(log, "/json/propertiesTrackers/" + mhash)); |
||||||
|
return new GetTorrentDetailsTaskSuccessResult((GetTorrentDetailsTask) task, parseJsonTorrentDetails(messages)); |
||||||
|
|
||||||
|
case GetFileList: |
||||||
|
|
||||||
|
// Request files listing for a specific torrent
|
||||||
|
String fhash = task.getTargetTorrent().getUniqueID(); |
||||||
|
JSONArray files = |
||||||
|
new JSONArray(makeRequest(log, "/json/propertiesFiles/" + fhash)); |
||||||
|
return new GetFileListTaskSuccessResult((GetFileListTask) task, parseJsonFiles(files)); |
||||||
|
|
||||||
|
case AddByFile: |
||||||
|
|
||||||
|
// Upload a local .torrent file
|
||||||
|
String ufile = ((AddByFileTask) task).getFile(); |
||||||
|
makeUploadRequest("/command/upload", ufile, log); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case AddByUrl: |
||||||
|
|
||||||
|
// Request to add a torrent by URL
|
||||||
|
String url = ((AddByUrlTask) task).getUrl(); |
||||||
|
makeRequest(log, "/command/download", new BasicNameValuePair("urls", url)); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case AddByMagnetUrl: |
||||||
|
|
||||||
|
// Request to add a magnet link by URL
|
||||||
|
String magnet = ((AddByMagnetUrlTask) task).getUrl(); |
||||||
|
makeRequest(log, "/command/download", new BasicNameValuePair("urls", magnet)); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case Remove: |
||||||
|
|
||||||
|
// Remove a torrent
|
||||||
|
RemoveTask removeTask = (RemoveTask) task; |
||||||
|
makeRequest(log, (removeTask.includingData() ? "/command/deletePerm" : "/command/delete"), |
||||||
|
new BasicNameValuePair("hashes", removeTask.getTargetTorrent().getUniqueID())); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case Pause: |
||||||
|
|
||||||
|
// Pause a torrent
|
||||||
|
makeRequest(log, "/command/pause", new BasicNameValuePair("hash", task.getTargetTorrent().getUniqueID())); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case PauseAll: |
||||||
|
|
||||||
|
// Resume all torrents
|
||||||
|
makeRequest(log, "/command/pauseall"); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case Resume: |
||||||
|
|
||||||
|
// Resume a torrent
|
||||||
|
makeRequest(log, "/command/resume", new BasicNameValuePair("hash", task.getTargetTorrent().getUniqueID())); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case ResumeAll: |
||||||
|
|
||||||
|
// Resume all torrents
|
||||||
|
makeRequest(log, "/command/resumeall"); |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
case SetFilePriorities: |
||||||
|
|
||||||
|
// Update the priorities to a set of files
|
||||||
|
SetFilePriorityTask setPrio = (SetFilePriorityTask) task; |
||||||
|
String newPrio = "0"; |
||||||
|
if (setPrio.getNewPriority() == Priority.Low) { |
||||||
|
newPrio = "1"; |
||||||
|
} else if (setPrio.getNewPriority() == Priority.Normal) { |
||||||
|
newPrio = "2"; |
||||||
|
} else if (setPrio.getNewPriority() == Priority.High) { |
||||||
|
newPrio = "7"; |
||||||
|
} |
||||||
|
// We have to make a separate request per file, it seems
|
||||||
|
for (TorrentFile file : setPrio.getForFiles()) { |
||||||
|
makeRequest(log, "/command/setFilePrio", new BasicNameValuePair("hash", task.getTargetTorrent().getUniqueID()), |
||||||
|
new BasicNameValuePair("id", file.getKey()), new BasicNameValuePair("priority", newPrio)); |
||||||
|
} |
||||||
|
return new DaemonTaskSuccessResult(task); |
||||||
|
|
||||||
|
default: |
||||||
|
return new DaemonTaskFailureResult(task, |
||||||
|
new DaemonException(ExceptionType.MethodUnsupported, task.getMethod() + " is not supported by " + getType())); |
||||||
|
} |
||||||
|
} catch (JSONException e) { |
||||||
|
return new DaemonTaskFailureResult(task, new DaemonException(ExceptionType.ParsingFailed, e.toString())); |
||||||
|
} catch (DaemonException e) { |
||||||
|
return new DaemonTaskFailureResult(task, e); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private String makeRequest(Log log, String path, NameValuePair... params) throws DaemonException { |
||||||
|
|
||||||
|
try { |
||||||
|
|
||||||
|
// Setup request using POST
|
||||||
|
HttpPost httppost = new HttpPost(buildWebUIUrl(path)); |
||||||
|
List<NameValuePair> nvps = new ArrayList<>(); |
||||||
|
Collections.addAll(nvps, params); |
||||||
|
httppost.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8)); |
||||||
|
return makeWebRequest(httppost, log); |
||||||
|
|
||||||
|
} catch (UnsupportedEncodingException e) { |
||||||
|
throw new DaemonException(ExceptionType.ConnectionError, e.toString()); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private String makeUploadRequest(String path, String file, Log log) throws DaemonException { |
||||||
|
|
||||||
|
try { |
||||||
|
|
||||||
|
// Setup request using POST
|
||||||
|
HttpPost httppost = new HttpPost(buildWebUIUrl(path)); |
||||||
|
File upload = new File(URI.create(file)); |
||||||
|
Part[] parts = {new FilePart("torrentfile", upload)}; |
||||||
|
httppost.setEntity(new MultipartEntity(parts, httppost.getParams())); |
||||||
|
return makeWebRequest(httppost, log); |
||||||
|
|
||||||
|
} catch (FileNotFoundException e) { |
||||||
|
throw new DaemonException(ExceptionType.FileAccessError, e.toString()); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private String makeWebRequest(HttpPost httppost, Log log) throws DaemonException { |
||||||
|
|
||||||
|
try { |
||||||
|
|
||||||
|
// Initialise the HTTP client
|
||||||
|
if (httpclient == null) { |
||||||
|
initialise(); |
||||||
|
} |
||||||
|
|
||||||
|
// Execute
|
||||||
|
HttpResponse response = httpclient.execute(httppost); |
||||||
|
|
||||||
|
HttpEntity entity = response.getEntity(); |
||||||
|
if (entity != null) { |
||||||
|
|
||||||
|
// Read JSON response
|
||||||
|
java.io.InputStream instream = entity.getContent(); |
||||||
|
String result = HttpHelper.convertStreamToString(instream); |
||||||
|
instream.close(); |
||||||
|
|
||||||
|
// Return raw result
|
||||||
|
return result; |
||||||
|
} |
||||||
|
|
||||||
|
log.d(LOG_NAME, "Error: No entity in HTTP response"); |
||||||
|
throw new DaemonException(ExceptionType.UnexpectedResponse, "No HTTP entity object in response."); |
||||||
|
|
||||||
|
} catch (Exception e) { |
||||||
|
log.d(LOG_NAME, "Error: " + e.toString()); |
||||||
|
throw new DaemonException(ExceptionType.ConnectionError, e.toString()); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Instantiates an HTTP client with proper credentials that can be used for all tTorrent requests. |
||||||
|
* @throws DaemonException On conflicting or missing settings |
||||||
|
*/ |
||||||
|
private void initialise() throws DaemonException { |
||||||
|
httpclient = HttpHelper.createStandardHttpClient(settings, true); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Build the URL of the web UI request from the user settings |
||||||
|
* @return The URL to request |
||||||
|
*/ |
||||||
|
private String buildWebUIUrl(String path) { |
||||||
|
return (settings.getSsl() ? "https://" : "http://") + settings.getAddress() + ":" + settings.getPort() + path; |
||||||
|
} |
||||||
|
|
||||||
|
private TorrentDetails parseJsonTorrentDetails(JSONArray messages) throws JSONException { |
||||||
|
|
||||||
|
ArrayList<String> trackers = new ArrayList<>(); |
||||||
|
ArrayList<String> errors = new ArrayList<>(); |
||||||
|
|
||||||
|
// Parse response
|
||||||
|
if (messages.length() > 0) { |
||||||
|
for (int i = 0; i < messages.length(); i++) { |
||||||
|
JSONObject tor = messages.getJSONObject(i); |
||||||
|
trackers.add(tor.getString("url")); |
||||||
|
String msg = tor.getString("msg"); |
||||||
|
if (msg != null && !msg.equals("")) |
||||||
|
errors.add(msg); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
// Return the list
|
||||||
|
return new TorrentDetails(trackers, errors); |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private ArrayList<Torrent> parseJsonTorrents(JSONArray response) throws JSONException { |
||||||
|
|
||||||
|
// Parse response
|
||||||
|
ArrayList<Torrent> torrents = new ArrayList<>(); |
||||||
|
for (int i = 0; i < response.length(); i++) { |
||||||
|
JSONObject tor = response.getJSONObject(i); |
||||||
|
double progress = tor.getDouble("progress"); |
||||||
|
int leechers[] = parsePeers(tor.getString("num_leechs")); |
||||||
|
int seeders[] = parsePeers(tor.getString("num_seeds")); |
||||||
|
long size = parseSize(tor.getString("size")); |
||||||
|
double ratio = parseRatio(tor.getString("ratio")); |
||||||
|
int dlspeed = (int) parseSize(tor.getString("dlspeed")); |
||||||
|
int upspeed = (int) parseSize(tor.getString("upspeed")); |
||||||
|
|
||||||
|
long eta = -1L; |
||||||
|
if (dlspeed > 0) |
||||||
|
eta = (long) (size - (size * progress)) / dlspeed; |
||||||
|
// @formatter:off
|
||||||
|
torrents.add(new Torrent( |
||||||
|
(long) i, |
||||||
|
tor.getString("hash"), |
||||||
|
tor.getString("name"), |
||||||
|
parseStatus(tor.getString("state")), |
||||||
|
null, |
||||||
|
dlspeed, |
||||||
|
upspeed, |
||||||
|
seeders[0], |
||||||
|
seeders[1], |
||||||
|
leechers[0], |
||||||
|
leechers[1], |
||||||
|
(int) eta, |
||||||
|
(long) (size * progress), |
||||||
|
(long) (size * ratio), |
||||||
|
size, |
||||||
|
(float) progress, |
||||||
|
0f, |
||||||
|
null, |
||||||
|
null, |
||||||
|
null, |
||||||
|
null, |
||||||
|
settings.getType())); |
||||||
|
// @formatter:on
|
||||||
|
} |
||||||
|
|
||||||
|
// Return the list
|
||||||
|
return torrents; |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private double parseRatio(String string) { |
||||||
|
// Ratio is given in "1.5" string format
|
||||||
|
try { |
||||||
|
return Double.parseDouble(string); |
||||||
|
} catch (Exception e) { |
||||||
|
return 0D; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private long parseSize(String string) { |
||||||
|
if (string.equals("Unknown")) |
||||||
|
return -1; |
||||||
|
// Sizes are given in "1562690683 B"-like string format
|
||||||
|
String[] parts = string.split(" "); |
||||||
|
try { |
||||||
|
return Long.parseLong(parts[0]); |
||||||
|
} catch (Exception e) { |
||||||
|
return -1L; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private int[] parsePeers(String seeds) { |
||||||
|
// Peers (seeders or leechers) are defined in a string like "num_seeds":"66 (27)" but we are also compatible with the old
|
||||||
|
// "num_seeds":"66 (27)" format
|
||||||
|
String[] parts = seeds.split(" "); |
||||||
|
if (parts.length > 1) { |
||||||
|
return new int[]{Integer.parseInt(parts[0]), Integer.parseInt(parts[1].substring(1, parts[1].length() - 1))}; |
||||||
|
} |
||||||
|
return new int[]{Integer.parseInt(parts[0]), Integer.parseInt(parts[0])}; |
||||||
|
} |
||||||
|
|
||||||
|
private TorrentStatus parseStatus(String state) { |
||||||
|
// Status is given as a descriptive string
|
||||||
|
if (state.equals("downloading")) { |
||||||
|
return TorrentStatus.Downloading; |
||||||
|
} else if (state.equals("uploading")) { |
||||||
|
return TorrentStatus.Seeding; |
||||||
|
} else if (state.equals("pausedDL")) { |
||||||
|
return TorrentStatus.Paused; |
||||||
|
} else if (state.equals("pausedUL")) { |
||||||
|
return TorrentStatus.Paused; |
||||||
|
} else if (state.equals("stalledUP")) { |
||||||
|
return TorrentStatus.Seeding; |
||||||
|
} else if (state.equals("stalledDL")) { |
||||||
|
return TorrentStatus.Downloading; |
||||||
|
} else if (state.equals("checkingUP")) { |
||||||
|
return TorrentStatus.Checking; |
||||||
|
} else if (state.equals("checkingDL")) { |
||||||
|
return TorrentStatus.Checking; |
||||||
|
} else if (state.equals("queuedDL")) { |
||||||
|
return TorrentStatus.Queued; |
||||||
|
} else if (state.equals("queuedUL")) { |
||||||
|
return TorrentStatus.Queued; |
||||||
|
} |
||||||
|
return TorrentStatus.Unknown; |
||||||
|
} |
||||||
|
|
||||||
|
private ArrayList<TorrentFile> parseJsonFiles(JSONArray response) throws JSONException { |
||||||
|
|
||||||
|
// Parse response
|
||||||
|
ArrayList<TorrentFile> torrentfiles = new ArrayList<>(); |
||||||
|
for (int i = 0; i < response.length(); i++) { |
||||||
|
JSONObject file = response.getJSONObject(i); |
||||||
|
|
||||||
|
long size = parseSize(file.getString("size")); |
||||||
|
torrentfiles.add(new TorrentFile("" + i, file.getString("name"), null, null, size, (long) (size * file.getDouble("progress")), |
||||||
|
parsePriority(file.getInt("priority")))); |
||||||
|
} |
||||||
|
|
||||||
|
// Return the list
|
||||||
|
return torrentfiles; |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private Priority parsePriority(int priority) { |
||||||
|
// Priority is an integer
|
||||||
|
// Actually 1 = Normal, 2 = High, 7 = Maximum, but adjust this to Transdroid values
|
||||||
|
if (priority == 0) { |
||||||
|
return Priority.Off; |
||||||
|
} else if (priority == 1) { |
||||||
|
return Priority.Low; |
||||||
|
} else if (priority == 2) { |
||||||
|
return Priority.Normal; |
||||||
|
} |
||||||
|
return Priority.High; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public Daemon getType() { |
||||||
|
return settings.getType(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public DaemonSettings getSettings() { |
||||||
|
return this.settings; |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
Before Width: | Height: | Size: 205 B |
|
Before Width: | Height: | Size: 189 B |
|
Before Width: | Height: | Size: 213 B |
|
Before Width: | Height: | Size: 192 B |
|
Before Width: | Height: | Size: 199 B |
|
Before Width: | Height: | Size: 199 B |
|
Before Width: | Height: | Size: 75 B |
|
Before Width: | Height: | Size: 205 B |
|
Before Width: | Height: | Size: 204 B |
|
Before Width: | Height: | Size: 191 B |
|
Before Width: | Height: | Size: 154 B |
|
Before Width: | Height: | Size: 159 B |
|
Before Width: | Height: | Size: 159 B |
|
Before Width: | Height: | Size: 189 B |
|
Before Width: | Height: | Size: 189 B |
|
Before Width: | Height: | Size: 107 B |
|
Before Width: | Height: | Size: 118 B |
|
Before Width: | Height: | Size: 118 B |
|
Before Width: | Height: | Size: 202 B |
|
Before Width: | Height: | Size: 199 B |
|
After Width: | Height: | Size: 223 B |
|
After Width: | Height: | Size: 1.2 KiB |
|
After Width: | Height: | Size: 287 B |
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in new issue