Add swipe view to show active connections

This commit is contained in:
emanuele-f 2019-11-08 23:47:42 +01:00
parent e210306b42
commit 2b0b179e33
11 changed files with 527 additions and 250 deletions

View File

@ -1,5 +1,44 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="NullableNotNullManager">
<option name="myDefaultNullable" value="org.jetbrains.annotations.Nullable" />
<option name="myDefaultNotNull" value="androidx.annotation.NonNull" />
<option name="myNullables">
<value>
<list size="12">
<item index="0" class="java.lang.String" itemvalue="org.jetbrains.annotations.Nullable" />
<item index="1" class="java.lang.String" itemvalue="javax.annotation.Nullable" />
<item index="2" class="java.lang.String" itemvalue="javax.annotation.CheckForNull" />
<item index="3" class="java.lang.String" itemvalue="edu.umd.cs.findbugs.annotations.Nullable" />
<item index="4" class="java.lang.String" itemvalue="android.support.annotation.Nullable" />
<item index="5" class="java.lang.String" itemvalue="androidx.annotation.Nullable" />
<item index="6" class="java.lang.String" itemvalue="android.annotation.Nullable" />
<item index="7" class="java.lang.String" itemvalue="androidx.annotation.RecentlyNullable" />
<item index="8" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.qual.Nullable" />
<item index="9" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NullableDecl" />
<item index="10" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NullableType" />
<item index="11" class="java.lang.String" itemvalue="com.android.annotations.Nullable" />
</list>
</value>
</option>
<option name="myNotNulls">
<value>
<list size="11">
<item index="0" class="java.lang.String" itemvalue="org.jetbrains.annotations.NotNull" />
<item index="1" class="java.lang.String" itemvalue="javax.annotation.Nonnull" />
<item index="2" class="java.lang.String" itemvalue="edu.umd.cs.findbugs.annotations.NonNull" />
<item index="3" class="java.lang.String" itemvalue="android.support.annotation.NonNull" />
<item index="4" class="java.lang.String" itemvalue="androidx.annotation.NonNull" />
<item index="5" class="java.lang.String" itemvalue="android.annotation.NonNull" />
<item index="6" class="java.lang.String" itemvalue="androidx.annotation.RecentlyNonNull" />
<item index="7" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.qual.NonNull" />
<item index="8" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NonNullDecl" />
<item index="9" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NonNullType" />
<item index="10" class="java.lang.String" itemvalue="com.android.annotations.NonNull" />
</list>
</value>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_1_7" project-jdk-name="1.8" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/build/classes" />
</component>

View File

@ -29,6 +29,8 @@ dependencies {
implementation 'androidx.appcompat:appcompat:1.1.0'
implementation 'androidx.constraintlayout:constraintlayout:1.1.3'
implementation 'androidx.preference:preference:1.1.0-alpha05'
implementation 'androidx.viewpager:viewpager:1.0.0'
implementation 'com.google.android.material:material:1.0.0'
testImplementation 'junit:junit:4.12'
androidTestImplementation 'androidx.test:runner:1.2.0'
androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'

View File

@ -0,0 +1,8 @@
package com.emanuelef.remote_capture;
interface AppStateListener {
void appStateReady();
void appStateStarting();
void appStateRunning();
void appStateStopping();
}

View File

@ -0,0 +1,44 @@
package com.emanuelef.remote_capture;
import android.content.Context;
import android.os.Bundle;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.ListView;
import android.widget.TextView;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.fragment.app.Fragment;
public class ConnectionsFragment extends Fragment {
private MainActivity activity;
@Override
public void onAttach(@NonNull Context context) {
super.onAttach(context);
activity = (MainActivity) context;
activity.setConnectionsFragment(this);
}
@Override
public void onDetach() {
activity.setConnectionsFragment(null);
super.onDetach();
}
@Override
public View onCreateView(LayoutInflater inflater,
ViewGroup container, Bundle savedInstanceState) {
return inflater.inflate(R.layout.connections, container, false);
}
@Override
public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {
ListView connList = view.findViewById(R.id.connections_view);
TextView emptyText = view.findViewById(R.id.no_connections);
connList.setEmptyView(emptyText);
}
}

View File

@ -24,10 +24,6 @@ import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.SharedPreferences;
import android.content.pm.ApplicationInfo;
import android.content.pm.PackageInfo;
import android.content.pm.PackageManager;
import android.graphics.drawable.Drawable;
import android.net.Uri;
import android.net.VpnService;
@ -35,36 +31,34 @@ import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.appcompat.app.AlertDialog;
import androidx.appcompat.app.AppCompatActivity;
import androidx.fragment.app.Fragment;
import androidx.fragment.app.FragmentManager;
import androidx.fragment.app.FragmentPagerAdapter;
import androidx.loader.app.LoaderManager;
import androidx.loader.content.AsyncTaskLoader;
import androidx.loader.content.Loader;
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import androidx.preference.PreferenceManager;
import androidx.viewpager.widget.ViewPager;
import android.os.Bundle;
import android.util.Log;
import android.view.Menu;
import android.view.MenuInflater;
import android.view.MenuItem;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import java.util.ArrayList;
import java.util.List;
import cat.ereza.customactivityoncrash.config.CaocConfig;
public class MainActivity extends AppCompatActivity implements LoaderManager.LoaderCallbacks<List<AppDescriptor>> {
Button mStartButton;
public class MainActivity extends AppCompatActivity implements LoaderManager.LoaderCallbacks<List<AppDescriptor>>, AppStateListener {
SharedPreferences mPrefs;
TextView mCollectorInfo;
TextView mCaptureStatus;
Menu mMenu;
int mFilterUid;
boolean mOpenAppsWhenDone;
List<AppDescriptor> mInstalledApps;
AppState mState;
StatusFragment statusFragment;
ConnectionsFragment connectionsFragment;
private static final int REQUEST_CODE_VPN = 2;
private static final int MENU_ITEM_APP_SELECTOR_IDX = 0;
@ -78,51 +72,35 @@ public class MainActivity extends AppCompatActivity implements LoaderManager.Loa
stopping
}
private void appStateReady() {
mState = AppState.ready;
public class MainPagerAdapter extends FragmentPagerAdapter {
public MainPagerAdapter(FragmentManager fm) {
super(fm);
}
mStartButton.setText(R.string.start_button);
mStartButton.setEnabled(true);
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(true);
@NonNull
@Override
public Fragment getItem(int position) {
if(position == 0) {
return new StatusFragment();
} else {
return new ConnectionsFragment();
}
}
mCaptureStatus.setText(R.string.ready);
setCollectorInfo(getCollectorIPPref(), getCollectorPortPref());
}
@Override
public CharSequence getPageTitle(int position) {
if(position == 0) {
return getResources().getString(R.string.status_view);
} else {
return getResources().getString(R.string.connections_view);
}
}
private void appStateStarting() {
mState = AppState.starting;
mStartButton.setEnabled(false);
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
}
private void appStateRunning() {
mState = AppState.running;
mStartButton.setText(R.string.stop_button);
mStartButton.setEnabled(true);
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
mCaptureStatus.setText(formatBytes(CaptureService.getBytes()));
setCollectorInfo(CaptureService.getCollectorAddress(),
Integer.toString(CaptureService.getCollectorPort()));
}
private void appStateStopping() {
mState = AppState.stopping;
mStartButton.setEnabled(false);
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
}
/* Try to determine the current app state */
private void setAppState() {
boolean is_active = CaptureService.isServiceActive();
if(!is_active)
appStateReady();
else
appStateRunning();
@Override
public int getCount() {
return 2;
}
}
@Override
@ -132,58 +110,25 @@ public class MainActivity extends AppCompatActivity implements LoaderManager.Loa
mFilterUid = CaptureService.getUidFilter();
mOpenAppsWhenDone = false;
mInstalledApps = null;
statusFragment = null;
connectionsFragment = null;
CaocConfig.Builder.create()
.errorDrawable(R.drawable.ic_app_crash)
.apply();
setContentView(R.layout.activity_main);
setContentView(R.layout.main_activity);
ViewPager viewPager = (ViewPager) findViewById(R.id.main_viewpager);
MainPagerAdapter pagerAdapter = new MainPagerAdapter(getSupportFragmentManager());
viewPager.setAdapter(pagerAdapter);
mPrefs = PreferenceManager.getDefaultSharedPreferences(this);
mStartButton = findViewById(R.id.button_start);
mCollectorInfo = findViewById(R.id.collector_info);
mCaptureStatus = findViewById(R.id.status_view);
mPrefs.registerOnSharedPreferenceChangeListener(new SharedPreferences.OnSharedPreferenceChangeListener() {
@Override
public void onSharedPreferenceChanged(SharedPreferences sharedPreferences, String s) {
if(mState == AppState.ready)
setCollectorInfo(getCollectorIPPref(), getCollectorPortPref());
}
});
mStartButton.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
Log.d("Main", "Clicked");
if(CaptureService.isServiceActive()) {
CaptureService.stopService();
appStateStopping();
} else {
Intent vpnPrepareIntent = VpnService.prepare(MainActivity.this);
if (vpnPrepareIntent != null)
startActivityForResult(vpnPrepareIntent, REQUEST_CODE_VPN);
else
onActivityResult(REQUEST_CODE_VPN, RESULT_OK, null);
appStateStarting();
}
}
});
startLoadingApps();
LocalBroadcastManager bcast_man = LocalBroadcastManager.getInstance(this);
/* Register for stats update */
bcast_man.registerReceiver(new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
processStatsUpdateIntent(intent);
}
}, new IntentFilter(CaptureService.ACTION_TRAFFIC_STATS_UPDATE));
/* Register for connections update */
bcast_man.registerReceiver(new BroadcastReceiver() {
@Override
@ -209,9 +154,180 @@ public class MainActivity extends AppCompatActivity implements LoaderManager.Loa
}, new IntentFilter(CaptureService.ACTION_SERVICE_STATUS));
}
private void setCollectorInfo(String collector_ip, String collector_port) {
mCollectorInfo.setText(String.format(getResources().getString(R.string.collector_info),
collector_ip, collector_port));
@Override
public void appStateReady() {
mState = AppState.ready;
if(statusFragment != null)
statusFragment.appStateReady();
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(true);
}
@Override
public void appStateStarting() {
mState = AppState.starting;
if(statusFragment != null)
statusFragment.appStateStarting();
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
}
@Override
public void appStateRunning() {
mState = AppState.running;
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
if(statusFragment != null)
statusFragment.appStateRunning();
}
@Override
public void appStateStopping() {
mState = AppState.stopping;
if(statusFragment != null)
statusFragment.appStateStopping();
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setEnabled(false);
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
MenuInflater menuInflater = getMenuInflater();
menuInflater.inflate(R.menu.settings_menu, menu);
mMenu = menu;
// Possibly set an initial app state
setAppState();
return true;
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
int id = item.getItemId();
if (id == R.id.action_settings) {
Intent intent = new Intent(MainActivity.this, SettingsActivity.class);
startActivity(intent);
return true;
} else if(id == R.id.action_show_app_filter) {
openAppSelector();
return true;
} else if(id == R.id.action_about) {
Intent browserIntent = new Intent(Intent.ACTION_VIEW, Uri.parse("https://github.com/emanuele-f/RemoteCapture"));
startActivity(browserIntent);
return true;
}
return super.onOptionsItemSelected(item);
}
@Override
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
super.onActivityResult(requestCode, resultCode, data);
if(requestCode == REQUEST_CODE_VPN && resultCode == RESULT_OK) {
Intent intent = new Intent(MainActivity.this, CaptureService.class);
Bundle bundle = new Bundle();
// the configuration for the VPN
bundle.putString("dns_server", "8.8.8.8"); // TODO: read system DNS
bundle.putString(Prefs.PREF_COLLECTOR_IP_KEY, getCollectorIPPref());
bundle.putInt(Prefs.PREF_COLLECTOR_PORT_KEY, Integer.parseInt(getCollectorPortPref()));
bundle.putInt(Prefs.PREF_UID_FILTER, mFilterUid);
bundle.putBoolean(Prefs.PREF_CAPTURE_UNKNOWN_APP_TRAFFIC, getCaptureUnknownTrafficPref());
intent.putExtra("settings", bundle);
Log.d("Main", "onActivityResult -> start CaptureService");
startService(intent);
}
}
@NonNull
@Override
public Loader<List<AppDescriptor>> onCreateLoader(int id, @Nullable Bundle args) {
return new AsyncTaskLoader<List<AppDescriptor>>(this) {
@Nullable
@Override
public List<AppDescriptor> loadInBackground() {
Log.d("AppsLoader", "Loading APPs...");
return Utils.getInstalledApps(getContext());
}
};
}
@Override
public void onLoadFinished(@NonNull Loader<List<AppDescriptor>> loader, List<AppDescriptor> data) {
Log.d("AppsLoader", data.size() + " APPs loaded");
mInstalledApps = data;
if(mFilterUid != -1) {
/* An filter is active, try to set the corresponding app image */
for(int i=0; i<mInstalledApps.size(); i++) {
AppDescriptor app = mInstalledApps.get(i);
if(app.getUid() == mFilterUid) {
setSelectedAppIcon(app);
break;
}
}
}
if(mOpenAppsWhenDone)
openAppSelector();
}
@Override
public void onLoaderReset(@NonNull Loader<List<AppDescriptor>> loader) {}
public void processConnectionsDump(Intent intent) {
Bundle bundle = intent.getExtras();
if(bundle != null) {
ConnDescriptor connections[] = (ConnDescriptor[]) bundle.getSerializable("value");
Log.i("ConnectionsDump", "TODO: handle " + connections.length + " connections");
}
}
/* Try to determine the current app state */
private void setAppState() {
boolean is_active = CaptureService.isServiceActive();
if(!is_active)
appStateReady();
else
appStateRunning();
}
public void toggleService() {
if(CaptureService.isServiceActive()) {
CaptureService.stopService();
appStateStopping();
} else {
Intent vpnPrepareIntent = VpnService.prepare(MainActivity.this);
if (vpnPrepareIntent != null)
startActivityForResult(vpnPrepareIntent, REQUEST_CODE_VPN);
else
onActivityResult(REQUEST_CODE_VPN, RESULT_OK, null);
appStateStarting();
}
}
void setStatusFragment(StatusFragment screen) {
statusFragment = screen;
}
void setConnectionsFragment(ConnectionsFragment view) {
connectionsFragment = view;
}
AppState getState() {
return(mState);
}
private void startLoadingApps() {
@ -228,44 +344,6 @@ public class MainActivity extends AppCompatActivity implements LoaderManager.Loa
loader.forceLoad();
}
private List<AppDescriptor> getInstalledApps() {
PackageManager pm = getPackageManager();
List<AppDescriptor> apps = new ArrayList<>();
List<PackageInfo> packs = pm.getInstalledPackages(0);
// Add the "No Filter" app
apps.add(new AppDescriptor("", getResources().getDrawable(android.R.drawable.ic_menu_view), getResources().getString(R.string.no_filter), -1));
for (int i = 0; i < packs.size(); i++) {
PackageInfo p = packs.get(i);
if((p.applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) == 0) {
String packages = p.applicationInfo.packageName;
if(!packages.equals("com.emanuelef.remote_capture")) {
String appName = p.applicationInfo.loadLabel(pm).toString();
Drawable icon = p.applicationInfo.loadIcon(pm);
int uid = p.applicationInfo.uid;
apps.add(new AppDescriptor(appName, icon, packages, uid));
Log.d("APPS", appName + " - " + packages + " [" + uid + "]");
}
}
}
return apps;
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
MenuInflater menuInflater = getMenuInflater();
menuInflater.inflate(R.menu.settings_menu, menu);
mMenu = menu;
// Possibly set an initial app state
setAppState();
return true;
}
private void setSelectedAppIcon(AppDescriptor app) {
// clone the drawable to avoid a "zoom-in" effect when clicked
mMenu.getItem(MENU_ITEM_APP_SELECTOR_IDX).setIcon(app.getIcon().getConstantState().newDrawable());
@ -300,127 +378,15 @@ public class MainActivity extends AppCompatActivity implements LoaderManager.Loa
alert.show();
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
int id = item.getItemId();
if (id == R.id.action_settings) {
Intent intent = new Intent(MainActivity.this, SettingsActivity.class);
startActivity(intent);
return true;
} else if(id == R.id.action_show_app_filter) {
openAppSelector();
return true;
} else if(id == R.id.action_about) {
Intent browserIntent = new Intent(Intent.ACTION_VIEW, Uri.parse("https://github.com/emanuele-f/RemoteCapture"));
startActivity(browserIntent);
return true;
}
return super.onOptionsItemSelected(item);
}
private String getCollectorIPPref() {
String getCollectorIPPref() {
return(mPrefs.getString(Prefs.PREF_COLLECTOR_IP_KEY, getString(R.string.default_collector_ip)));
}
private String getCollectorPortPref() {
String getCollectorPortPref() {
return(mPrefs.getString(Prefs.PREF_COLLECTOR_PORT_KEY, getString(R.string.default_collector_port)));
}
private boolean getCaptureUnknownTrafficPref() {
return(mPrefs.getBoolean(Prefs.PREF_CAPTURE_UNKNOWN_APP_TRAFFIC, true));
}
@Override
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
super.onActivityResult(requestCode, resultCode, data);
if(requestCode == REQUEST_CODE_VPN && resultCode == RESULT_OK) {
Intent intent = new Intent(MainActivity.this, CaptureService.class);
Bundle bundle = new Bundle();
// the configuration for the VPN
bundle.putString("dns_server", "8.8.8.8"); // TODO: read system DNS
bundle.putString(Prefs.PREF_COLLECTOR_IP_KEY, getCollectorIPPref());
bundle.putInt(Prefs.PREF_COLLECTOR_PORT_KEY, Integer.parseInt(getCollectorPortPref()));
bundle.putInt(Prefs.PREF_UID_FILTER, mFilterUid);
bundle.putBoolean(Prefs.PREF_CAPTURE_UNKNOWN_APP_TRAFFIC, getCaptureUnknownTrafficPref());
intent.putExtra("settings", bundle);
Log.d("Main", "onActivityResult -> start CaptureService");
startService(intent);
}
}
@NonNull
@Override
public Loader<List<AppDescriptor>> onCreateLoader(int id, @Nullable Bundle args) {
return new AsyncTaskLoader<List<AppDescriptor>>(this) {
@Nullable
@Override
public List<AppDescriptor> loadInBackground() {
Log.d("AppsLoader", "Loading APPs...");
return getInstalledApps();
}
};
}
@Override
public void onLoadFinished(@NonNull Loader<List<AppDescriptor>> loader, List<AppDescriptor> data) {
Log.d("AppsLoader", data.size() + " APPs loaded");
mInstalledApps = data;
if(mFilterUid != -1) {
/* An filter is active, try to set the corresponding app image */
for(int i=0; i<mInstalledApps.size(); i++) {
AppDescriptor app = mInstalledApps.get(i);
if(app.getUid() == mFilterUid) {
setSelectedAppIcon(app);
break;
}
}
}
if(mOpenAppsWhenDone)
openAppSelector();
}
@Override
public void onLoaderReset(@NonNull Loader<List<AppDescriptor>> loader) {}
public static String formatBytes(long bytes) {
long divisor;
String suffix;
if(bytes < 1024) return bytes + " B";
if(bytes < 1024*1024) { divisor = 1024; suffix = "KB"; }
else if(bytes < 1024*1024*1024) { divisor = 1024*1024; suffix = "MB"; }
else { divisor = 1024*1024*1024; suffix = "GB"; }
return String.format("%.1f %s", ((float)bytes) / divisor, suffix);
}
public void processStatsUpdateIntent(Intent intent) {
long bytes_sent = intent.getLongExtra(CaptureService.TRAFFIC_STATS_UPDATE_SENT_BYTES, 0);
long bytes_rcvd = intent.getLongExtra(CaptureService.TRAFFIC_STATS_UPDATE_RCVD_BYTES, 0);
int pkts_sent = intent.getIntExtra(CaptureService.TRAFFIC_STATS_UPDATE_SENT_PKTS, 0);
int pkts_rcvd = intent.getIntExtra(CaptureService.TRAFFIC_STATS_UPDATE_RCVD_PKTS, 0);
Log.d("MainReceiver", "Got StatsUpdate: bytes_sent=" + bytes_sent + ", bytes_rcvd=" +
bytes_rcvd + ", pkts_sent=" + pkts_sent + ", pkts_rcvd=" + pkts_rcvd);
mCaptureStatus.setText(formatBytes(bytes_sent + bytes_rcvd));
}
public void processConnectionsDump(Intent intent) {
Bundle bundle = intent.getExtras();
if(bundle != null) {
ConnDescriptor connections[] = (ConnDescriptor[]) bundle.getSerializable("value");
Log.i("ConnectionsDump", "TODO: handle " + connections.length + " connections");
}
}
}

View File

@ -0,0 +1,128 @@
package com.emanuelef.remote_capture;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.SharedPreferences;
import android.os.Bundle;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.Button;
import android.widget.TextView;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.fragment.app.Fragment;
import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import androidx.preference.PreferenceManager;
public class StatusFragment extends Fragment implements AppStateListener {
private Button mStartButton;
private TextView mCollectorInfo;
private TextView mCaptureStatus;
private MainActivity activity;
@Override
public void onAttach(@NonNull Context context) {
super.onAttach(context);
activity = (MainActivity) context;
activity.setStatusFragment(this);
}
@Override
public void onDetach() {
activity.setStatusFragment(null);
super.onDetach();
}
@Override
public View onCreateView(LayoutInflater inflater,
ViewGroup container, Bundle savedInstanceState) {
return inflater.inflate(R.layout.status, container, false);
}
@Override
public void onViewCreated(@NonNull View view, @Nullable Bundle savedInstanceState) {
mStartButton = view.findViewById(R.id.button_start);
mCollectorInfo = view.findViewById(R.id.collector_info);
mCaptureStatus = view.findViewById(R.id.status_view);
SharedPreferences mPrefs = PreferenceManager.getDefaultSharedPreferences(activity);
mPrefs.registerOnSharedPreferenceChangeListener(new SharedPreferences.OnSharedPreferenceChangeListener() {
@Override
public void onSharedPreferenceChanged(SharedPreferences sharedPreferences, String s) {
if(activity.getState() == MainActivity.AppState.ready)
setCollectorInfo(activity.getCollectorIPPref(), activity.getCollectorPortPref());
}
});
mStartButton.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
Log.d("Main", "Clicked");
activity.toggleService();
}
});
LocalBroadcastManager bcast_man = LocalBroadcastManager.getInstance(activity);
/* Register for stats update */
bcast_man.registerReceiver(new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
processStatsUpdateIntent(intent);
}
}, new IntentFilter(CaptureService.ACTION_TRAFFIC_STATS_UPDATE));
}
@Override
public void appStateReady() {
mStartButton.setText(R.string.start_button);
mStartButton.setEnabled(true);
mCaptureStatus.setText(R.string.ready);
setCollectorInfo(activity.getCollectorIPPref(), activity.getCollectorPortPref());
}
@Override
public void appStateStarting() {
mStartButton.setEnabled(false);
}
@Override
public void appStateRunning() {
mStartButton.setText(R.string.stop_button);
mStartButton.setEnabled(true);
mCaptureStatus.setText(Utils.formatBytes(CaptureService.getBytes()));
setCollectorInfo(CaptureService.getCollectorAddress(),
Integer.toString(CaptureService.getCollectorPort()));
}
@Override
public void appStateStopping() {
mStartButton.setEnabled(false);
}
private void processStatsUpdateIntent(Intent intent) {
long bytes_sent = intent.getLongExtra(CaptureService.TRAFFIC_STATS_UPDATE_SENT_BYTES, 0);
long bytes_rcvd = intent.getLongExtra(CaptureService.TRAFFIC_STATS_UPDATE_RCVD_BYTES, 0);
int pkts_sent = intent.getIntExtra(CaptureService.TRAFFIC_STATS_UPDATE_SENT_PKTS, 0);
int pkts_rcvd = intent.getIntExtra(CaptureService.TRAFFIC_STATS_UPDATE_RCVD_PKTS, 0);
Log.d("MainReceiver", "Got StatsUpdate: bytes_sent=" + bytes_sent + ", bytes_rcvd=" +
bytes_rcvd + ", pkts_sent=" + pkts_sent + ", pkts_rcvd=" + pkts_rcvd);
mCaptureStatus.setText(Utils.formatBytes(bytes_sent + bytes_rcvd));
}
private void setCollectorInfo(String collector_ip, String collector_port) {
mCollectorInfo.setText(String.format(getResources().getString(R.string.collector_info),
collector_ip, collector_port));
}
}

View File

@ -0,0 +1,52 @@
package com.emanuelef.remote_capture;
import android.content.Context;
import android.content.pm.ApplicationInfo;
import android.content.pm.PackageInfo;
import android.content.pm.PackageManager;
import android.graphics.drawable.Drawable;
import android.util.Log;
import java.util.ArrayList;
import java.util.List;
public class Utils {
public static String formatBytes(long bytes) {
long divisor;
String suffix;
if(bytes < 1024) return bytes + " B";
if(bytes < 1024*1024) { divisor = 1024; suffix = "KB"; }
else if(bytes < 1024*1024*1024) { divisor = 1024*1024; suffix = "MB"; }
else { divisor = 1024*1024*1024; suffix = "GB"; }
return String.format("%.1f %s", ((float)bytes) / divisor, suffix);
}
public static List<AppDescriptor> getInstalledApps(Context context) {
PackageManager pm = context.getPackageManager();
List<AppDescriptor> apps = new ArrayList<>();
List<PackageInfo> packs = pm.getInstalledPackages(0);
// Add the "No Filter" app
apps.add(new AppDescriptor("", context.getResources().getDrawable(android.R.drawable.ic_menu_view), context.getResources().getString(R.string.no_filter), -1));
for (int i = 0; i < packs.size(); i++) {
PackageInfo p = packs.get(i);
if((p.applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) == 0) {
String packages = p.applicationInfo.packageName;
if(!packages.equals("com.emanuelef.remote_capture")) {
String appName = p.applicationInfo.loadLabel(pm).toString();
Drawable icon = p.applicationInfo.loadIcon(pm);
int uid = p.applicationInfo.uid;
apps.add(new AppDescriptor(appName, icon, packages, uid));
Log.d("APPS", appName + " - " + packages + " [" + uid + "]");
}
}
}
return apps;
}
}

View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical">
<ListView
android:layout_width="match_parent"
android:layout_height="match_parent"
android:id="@+id/connections_view"
></ListView>
<TextView
android:id="@+id/no_connections"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:gravity="center_horizontal"
android:layout_marginTop="80dp"
android:textStyle="italic"
android:textSize="15dp"
android:text="@string/no_connections">
</TextView>
</LinearLayout>

View File

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="utf-8"?>
<androidx.viewpager.widget.ViewPager xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:id="@+id/main_viewpager">
<com.google.android.material.tabs.TabLayout
android:id="@+id/tab_layout"
android:layout_width="match_parent"
android:layout_height="wrap_content" />
</androidx.viewpager.widget.ViewPager>

View File

@ -2,7 +2,7 @@
<androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:app="http://schemas.android.com/apk/res-auto"
xmlns:tools="http://schemas.android.com/tools"
android:id="@+id/linearLayout"
android:id="@+id/main_screen"
android:layout_width="match_parent"
android:layout_height="match_parent"
tools:context="com.emanuelef.remote_capture.MainActivity">

View File

@ -22,4 +22,7 @@
<string name="capture_unknown_app">Capture Unknown Traffic</string>
<string name="capture_unknown_app_summary">When an app filter is set, also capture general purpose traffic which cannot be associated to a specific app. This is usually needed to properly capture DNS traffic.</string>
<string name="capture_prefs">Capture</string>
<string name="status_view">Status</string>
<string name="connections_view">Connections</string>
<string name="no_connections">No connections</string>
</resources>