examples/androidvoip/java/org/webrtc/examples/androidvoip/MainActivity.java - src - Git at Google

 /*
  *  Copyright (c) 2020 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */

 package org.webrtc.examples.androidvoip;

 import android.Manifest.permission;
 import android.app.Activity;
 import android.app.AlertDialog;
 import android.content.Context;
 import android.content.pm.PackageManager;
 import android.os.Bundle;
 import android.view.Gravity;
 import android.view.View;
 import android.widget.AdapterView;
 import android.widget.ArrayAdapter;
 import android.widget.Button;
 import android.widget.EditText;
 import android.widget.RelativeLayout;
 import android.widget.ScrollView;
 import android.widget.Spinner;
 import android.widget.Switch;
 import android.widget.TextView;
 import android.widget.Toast;
 import android.widget.ToggleButton;
 import androidx.core.app.ActivityCompat;
 import androidx.core.content.ContextCompat;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
 import org.webrtc.ContextUtils;

 public class MainActivity extends Activity implements OnVoipClientTaskCompleted {
   private static final int NUM_SUPPORTED_CODECS = 6;

   private VoipClient voipClient;
   private List<String> supportedCodecs;
   private boolean[] isDecoderSelected;
   private Set<Integer> selectedDecoders;

   private Toast toast;
   private ScrollView scrollView;
   private TextView localIPAddressTextView;
   private EditText localPortNumberEditText;
   private EditText remoteIPAddressEditText;
   private EditText remotePortNumberEditText;
   private Spinner encoderSpinner;
   private Button decoderSelectionButton;
   private TextView decodersTextView;
   private ToggleButton sessionButton;
   private RelativeLayout switchLayout;
   private Switch sendSwitch;
   private Switch playoutSwitch;

   @Override
   protected void onCreate(Bundle savedInstance) {
     ContextUtils.initialize(getApplicationContext());

     super.onCreate(savedInstance);
     setContentView(R.layout.activity_main);

     System.loadLibrary("examples_androidvoip_jni");

     voipClient = new VoipClient(getApplicationContext(), this);
     voipClient.getAndSetUpLocalIPAddress();
     voipClient.getAndSetUpSupportedCodecs();

     isDecoderSelected = new boolean[NUM_SUPPORTED_CODECS];
     selectedDecoders = new HashSet<>();

     toast = Toast.makeText(this, "", Toast.LENGTH_SHORT);

     scrollView = (ScrollView) findViewById(R.id.scroll_view);
     localIPAddressTextView = (TextView) findViewById(R.id.local_ip_address_text_view);
     localPortNumberEditText = (EditText) findViewById(R.id.local_port_number_edit_text);
     remoteIPAddressEditText = (EditText) findViewById(R.id.remote_ip_address_edit_text);
     remotePortNumberEditText = (EditText) findViewById(R.id.remote_port_number_edit_text);
     encoderSpinner = (Spinner) findViewById(R.id.encoder_spinner);
     decoderSelectionButton = (Button) findViewById(R.id.decoder_selection_button);
     decodersTextView = (TextView) findViewById(R.id.decoders_text_view);
     sessionButton = (ToggleButton) findViewById(R.id.session_button);
     switchLayout = (RelativeLayout) findViewById(R.id.switch_layout);
     sendSwitch = (Switch) findViewById(R.id.start_send_switch);
     playoutSwitch = (Switch) findViewById(R.id.start_playout_switch);

     setUpSessionButton();
     setUpSendAndPlayoutSwitch();
   }

   private void setUpEncoderSpinner(List<String> supportedCodecs) {
     ArrayAdapter<String> encoderAdapter =
         new ArrayAdapter<String>(this, android.R.layout.simple_spinner_item, supportedCodecs);
     encoderAdapter.setDropDownViewResource(android.R.layout.simple_spinner_dropdown_item);
     encoderSpinner.setAdapter(encoderAdapter);
     encoderSpinner.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() {
       @Override
       public void onItemSelected(AdapterView<?> parent, View view, int position, long id) {
         voipClient.setEncoder((String) parent.getSelectedItem());
       }
       @Override
       public void onNothingSelected(AdapterView<?> parent) {}
     });
   }

   private List<String> getSelectedDecoders() {
     List<String> decoders = new ArrayList<>();
     for (int i = 0; i < supportedCodecs.size(); i++) {
       if (selectedDecoders.contains(i)) {
         decoders.add(supportedCodecs.get(i));
       }
     }
     return decoders;
   }

   private void setUpDecoderSelectionButton(List<String> supportedCodecs) {
     decoderSelectionButton.setOnClickListener((view) -> {
       AlertDialog.Builder dialogBuilder = new AlertDialog.Builder(this);
       dialogBuilder.setTitle(R.string.dialog_title);

       // Populate multi choice items with supported decoders.
       String[] supportedCodecsArray = supportedCodecs.toArray(new String[0]);
       dialogBuilder.setMultiChoiceItems(
           supportedCodecsArray, isDecoderSelected, (dialog, position, isChecked) -> {
             if (isChecked) {
               selectedDecoders.add(position);
             } else if (!isChecked) {
               selectedDecoders.remove(position);
             }
           });

       // "Ok" button.
       dialogBuilder.setPositiveButton(R.string.ok_label, (dialog, position) -> {
         List<String> decoders = getSelectedDecoders();
         String result = decoders.stream().collect(Collectors.joining(", "));
         if (result.isEmpty()) {
           decodersTextView.setText(R.string.decoders_text_view_default);
         } else {
           decodersTextView.setText(result);
         }
         voipClient.setDecoders(decoders);
       });

       // "Dismiss" button.
       dialogBuilder.setNegativeButton(
           R.string.dismiss_label, (dialog, position) -> { dialog.dismiss(); });

       // "Clear All" button.
       dialogBuilder.setNeutralButton(R.string.clear_all_label, (dialog, position) -> {
         Arrays.fill(isDecoderSelected, false);
         selectedDecoders.clear();
         decodersTextView.setText(R.string.decoders_text_view_default);
       });

       AlertDialog dialog = dialogBuilder.create();
       dialog.show();
     });
   }

   private void setUpSessionButton() {
     sessionButton.setOnCheckedChangeListener((button, isChecked) -> {
       // Ask for permission on RECORD_AUDIO if not granted.
       if (ContextCompat.checkSelfPermission(this, permission.RECORD_AUDIO)
           != PackageManager.PERMISSION_GRANTED) {
         String[] sList = {permission.RECORD_AUDIO};
         ActivityCompat.requestPermissions(this, sList, 1);
       }

       if (isChecked) {
         // Order matters here, addresses have to be set before starting session
         // before setting codec.
         voipClient.setLocalAddress(localIPAddressTextView.getText().toString(),
             Integer.parseInt(localPortNumberEditText.getText().toString()));
         voipClient.setRemoteAddress(remoteIPAddressEditText.getText().toString(),
             Integer.parseInt(remotePortNumberEditText.getText().toString()));
         voipClient.startSession();
         voipClient.setEncoder((String) encoderSpinner.getSelectedItem());
         voipClient.setDecoders(getSelectedDecoders());
       } else {
         voipClient.stopSession();
       }
     });
   }

   private void setUpSendAndPlayoutSwitch() {
     sendSwitch.setOnCheckedChangeListener((button, isChecked) -> {
       if (isChecked) {
         voipClient.startSend();
       } else {
         voipClient.stopSend();
       }
     });

     playoutSwitch.setOnCheckedChangeListener((button, isChecked) -> {
       if (isChecked) {
         voipClient.startPlayout();
       } else {
         voipClient.stopPlayout();
       }
     });
   }

   private void setUpIPAddressEditTexts(String localIPAddress) {
     if (localIPAddress.isEmpty()) {
       showToast("Please check your network configuration");
     } else {
       localIPAddressTextView.setText(localIPAddress);
       // By default remote IP address is the same as local IP address.
       remoteIPAddressEditText.setText(localIPAddress);
     }
   }

   private void showToast(String message) {
     if (toast != null) {
       toast.cancel();
       toast = Toast.makeText(this, message, Toast.LENGTH_SHORT);
       toast.setGravity(Gravity.TOP, 0, 200);
       toast.show();
     }
   }

   @Override
   protected void onDestroy() {
     voipClient.close();
     voipClient = null;

     super.onDestroy();
   }

   @Override
   public void onGetLocalIPAddressCompleted(String localIPAddress) {
     runOnUiThread(() -> { setUpIPAddressEditTexts(localIPAddress); });
   }

   @Override
   public void onGetSupportedCodecsCompleted(List<String> supportedCodecs) {
     runOnUiThread(() -> {
       this.supportedCodecs = supportedCodecs;
       setUpEncoderSpinner(supportedCodecs);
       setUpDecoderSelectionButton(supportedCodecs);
     });
   }

   @Override
   public void onVoipClientInitializationCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (!isSuccessful) {
         showToast("Error initializing audio device");
       }
     });
   }

   @Override
   public void onStartSessionCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Session started");
         switchLayout.setVisibility(View.VISIBLE);
         scrollView.post(() -> { scrollView.fullScroll(ScrollView.FOCUS_DOWN); });
       } else {
         showToast("Failed to start session");
       }
     });
   }

   @Override
   public void onStopSessionCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Session stopped");
         // Set listeners to null so the checked state can be changed programmatically.
         sendSwitch.setOnCheckedChangeListener(null);
         playoutSwitch.setOnCheckedChangeListener(null);
         sendSwitch.setChecked(false);
         playoutSwitch.setChecked(false);
         // Redo the switch listener setup.
         setUpSendAndPlayoutSwitch();
         switchLayout.setVisibility(View.GONE);
       } else {
         showToast("Failed to stop session");
       }
     });
   }

   @Override
   public void onStartSendCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Started sending");
       } else {
         showToast("Error initializing microphone");
       }
     });
   }

   @Override
   public void onStopSendCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Stopped sending");
       } else {
         showToast("Microphone termination failed");
       }
     });
   }

   @Override
   public void onStartPlayoutCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Started playout");
       } else {
         showToast("Error initializing speaker");
       }
     });
   }

   @Override
   public void onStopPlayoutCompleted(boolean isSuccessful) {
     runOnUiThread(() -> {
       if (isSuccessful) {
         showToast("Stopped playout");
       } else {
         showToast("Speaker termination failed");
       }
     });
   }

   @Override
   public void onUninitializedVoipClient() {
     runOnUiThread(() -> { showToast("Voip client is uninitialized"); });
   }
 }
	/*
	* Copyright (c) 2020 The WebRTC project authors. All Rights Reserved.
	*
	* Use of this source code is governed by a BSD-style license
	* that can be found in the LICENSE file in the root of the source
	* tree. An additional intellectual property rights grant can be found
	* in the file PATENTS. All contributing project authors may
	* be found in the AUTHORS file in the root of the source tree.
	*/

	package org.webrtc.examples.androidvoip;

	import android.Manifest.permission;
	import android.app.Activity;
	import android.app.AlertDialog;
	import android.content.Context;
	import android.content.pm.PackageManager;
	import android.os.Bundle;
	import android.view.Gravity;
	import android.view.View;
	import android.widget.AdapterView;
	import android.widget.ArrayAdapter;
	import android.widget.Button;
	import android.widget.EditText;
	import android.widget.RelativeLayout;
	import android.widget.ScrollView;
	import android.widget.Spinner;
	import android.widget.Switch;
	import android.widget.TextView;
	import android.widget.Toast;
	import android.widget.ToggleButton;
	import androidx.core.app.ActivityCompat;
	import androidx.core.content.ContextCompat;
	import java.util.ArrayList;
	import java.util.Arrays;
	import java.util.HashSet;
	import java.util.List;
	import java.util.Set;
	import java.util.stream.Collectors;
	import org.webrtc.ContextUtils;

	public class MainActivity extends Activity implements OnVoipClientTaskCompleted {
	private static final int NUM_SUPPORTED_CODECS = 6;

	private VoipClient voipClient;
	private List<String> supportedCodecs;
	private boolean[] isDecoderSelected;
	private Set<Integer> selectedDecoders;

	private Toast toast;
	private ScrollView scrollView;
	private TextView localIPAddressTextView;
	private EditText localPortNumberEditText;
	private EditText remoteIPAddressEditText;
	private EditText remotePortNumberEditText;
	private Spinner encoderSpinner;
	private Button decoderSelectionButton;
	private TextView decodersTextView;
	private ToggleButton sessionButton;
	private RelativeLayout switchLayout;
	private Switch sendSwitch;
	private Switch playoutSwitch;

	@Override
	protected void onCreate(Bundle savedInstance) {
	ContextUtils.initialize(getApplicationContext());

	super.onCreate(savedInstance);
	setContentView(R.layout.activity_main);

	System.loadLibrary("examples_androidvoip_jni");

	voipClient = new VoipClient(getApplicationContext(), this);
	voipClient.getAndSetUpLocalIPAddress();
	voipClient.getAndSetUpSupportedCodecs();

	isDecoderSelected = new boolean[NUM_SUPPORTED_CODECS];
	selectedDecoders = new HashSet<>();

	toast = Toast.makeText(this, "", Toast.LENGTH_SHORT);

	scrollView = (ScrollView) findViewById(R.id.scroll_view);
	localIPAddressTextView = (TextView) findViewById(R.id.local_ip_address_text_view);
	localPortNumberEditText = (EditText) findViewById(R.id.local_port_number_edit_text);
	remoteIPAddressEditText = (EditText) findViewById(R.id.remote_ip_address_edit_text);
	remotePortNumberEditText = (EditText) findViewById(R.id.remote_port_number_edit_text);
	encoderSpinner = (Spinner) findViewById(R.id.encoder_spinner);
	decoderSelectionButton = (Button) findViewById(R.id.decoder_selection_button);
	decodersTextView = (TextView) findViewById(R.id.decoders_text_view);
	sessionButton = (ToggleButton) findViewById(R.id.session_button);
	switchLayout = (RelativeLayout) findViewById(R.id.switch_layout);
	sendSwitch = (Switch) findViewById(R.id.start_send_switch);
	playoutSwitch = (Switch) findViewById(R.id.start_playout_switch);

	setUpSessionButton();
	setUpSendAndPlayoutSwitch();
	}

	private void setUpEncoderSpinner(List<String> supportedCodecs) {
	ArrayAdapter<String> encoderAdapter =
	new ArrayAdapter<String>(this, android.R.layout.simple_spinner_item, supportedCodecs);
	encoderAdapter.setDropDownViewResource(android.R.layout.simple_spinner_dropdown_item);
	encoderSpinner.setAdapter(encoderAdapter);
	encoderSpinner.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() {
	@Override
	public void onItemSelected(AdapterView<?> parent, View view, int position, long id) {
	voipClient.setEncoder((String) parent.getSelectedItem());
	}
	@Override
	public void onNothingSelected(AdapterView<?> parent) {}
	});
	}

	private List<String> getSelectedDecoders() {
	List<String> decoders = new ArrayList<>();
	for (int i = 0; i < supportedCodecs.size(); i++) {
	if (selectedDecoders.contains(i)) {
	decoders.add(supportedCodecs.get(i));
	}
	}
	return decoders;
	}

	private void setUpDecoderSelectionButton(List<String> supportedCodecs) {
	decoderSelectionButton.setOnClickListener((view) -> {
	AlertDialog.Builder dialogBuilder = new AlertDialog.Builder(this);
	dialogBuilder.setTitle(R.string.dialog_title);

	// Populate multi choice items with supported decoders.
	String[] supportedCodecsArray = supportedCodecs.toArray(new String[0]);
	dialogBuilder.setMultiChoiceItems(
	supportedCodecsArray, isDecoderSelected, (dialog, position, isChecked) -> {
	if (isChecked) {
	selectedDecoders.add(position);
	} else if (!isChecked) {
	selectedDecoders.remove(position);
	}
	});

	// "Ok" button.
	dialogBuilder.setPositiveButton(R.string.ok_label, (dialog, position) -> {
	List<String> decoders = getSelectedDecoders();
	String result = decoders.stream().collect(Collectors.joining(", "));
	if (result.isEmpty()) {
	decodersTextView.setText(R.string.decoders_text_view_default);
	} else {
	decodersTextView.setText(result);
	}
	voipClient.setDecoders(decoders);
	});

	// "Dismiss" button.
	dialogBuilder.setNegativeButton(
	R.string.dismiss_label, (dialog, position) -> { dialog.dismiss(); });

	// "Clear All" button.
	dialogBuilder.setNeutralButton(R.string.clear_all_label, (dialog, position) -> {
	Arrays.fill(isDecoderSelected, false);
	selectedDecoders.clear();
	decodersTextView.setText(R.string.decoders_text_view_default);
	});

	AlertDialog dialog = dialogBuilder.create();
	dialog.show();
	});
	}

	private void setUpSessionButton() {
	sessionButton.setOnCheckedChangeListener((button, isChecked) -> {
	// Ask for permission on RECORD_AUDIO if not granted.
	if (ContextCompat.checkSelfPermission(this, permission.RECORD_AUDIO)
	!= PackageManager.PERMISSION_GRANTED) {
	String[] sList = {permission.RECORD_AUDIO};
	ActivityCompat.requestPermissions(this, sList, 1);
	}

	if (isChecked) {
	// Order matters here, addresses have to be set before starting session
	// before setting codec.
	voipClient.setLocalAddress(localIPAddressTextView.getText().toString(),
	Integer.parseInt(localPortNumberEditText.getText().toString()));
	voipClient.setRemoteAddress(remoteIPAddressEditText.getText().toString(),
	Integer.parseInt(remotePortNumberEditText.getText().toString()));
	voipClient.startSession();
	voipClient.setEncoder((String) encoderSpinner.getSelectedItem());
	voipClient.setDecoders(getSelectedDecoders());
	} else {
	voipClient.stopSession();
	}
	});
	}

	private void setUpSendAndPlayoutSwitch() {
	sendSwitch.setOnCheckedChangeListener((button, isChecked) -> {
	if (isChecked) {
	voipClient.startSend();
	} else {
	voipClient.stopSend();
	}
	});

	playoutSwitch.setOnCheckedChangeListener((button, isChecked) -> {
	if (isChecked) {
	voipClient.startPlayout();
	} else {
	voipClient.stopPlayout();
	}
	});
	}

	private void setUpIPAddressEditTexts(String localIPAddress) {
	if (localIPAddress.isEmpty()) {
	showToast("Please check your network configuration");
	} else {
	localIPAddressTextView.setText(localIPAddress);
	// By default remote IP address is the same as local IP address.
	remoteIPAddressEditText.setText(localIPAddress);
	}
	}

	private void showToast(String message) {
	if (toast != null) {
	toast.cancel();
	toast = Toast.makeText(this, message, Toast.LENGTH_SHORT);
	toast.setGravity(Gravity.TOP, 0, 200);
	toast.show();
	}
	}

	@Override
	protected void onDestroy() {
	voipClient.close();
	voipClient = null;

	super.onDestroy();
	}

	@Override
	public void onGetLocalIPAddressCompleted(String localIPAddress) {
	runOnUiThread(() -> { setUpIPAddressEditTexts(localIPAddress); });
	}

	@Override
	public void onGetSupportedCodecsCompleted(List<String> supportedCodecs) {
	runOnUiThread(() -> {
	this.supportedCodecs = supportedCodecs;
	setUpEncoderSpinner(supportedCodecs);
	setUpDecoderSelectionButton(supportedCodecs);
	});
	}

	@Override
	public void onVoipClientInitializationCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (!isSuccessful) {
	showToast("Error initializing audio device");
	}
	});
	}

	@Override
	public void onStartSessionCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Session started");
	switchLayout.setVisibility(View.VISIBLE);
	scrollView.post(() -> { scrollView.fullScroll(ScrollView.FOCUS_DOWN); });
	} else {
	showToast("Failed to start session");
	}
	});
	}

	@Override
	public void onStopSessionCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Session stopped");
	// Set listeners to null so the checked state can be changed programmatically.
	sendSwitch.setOnCheckedChangeListener(null);
	playoutSwitch.setOnCheckedChangeListener(null);
	sendSwitch.setChecked(false);
	playoutSwitch.setChecked(false);
	// Redo the switch listener setup.
	setUpSendAndPlayoutSwitch();
	switchLayout.setVisibility(View.GONE);
	} else {
	showToast("Failed to stop session");
	}
	});
	}

	@Override
	public void onStartSendCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Started sending");
	} else {
	showToast("Error initializing microphone");
	}
	});
	}

	@Override
	public void onStopSendCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Stopped sending");
	} else {
	showToast("Microphone termination failed");
	}
	});
	}

	@Override
	public void onStartPlayoutCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Started playout");
	} else {
	showToast("Error initializing speaker");
	}
	});
	}

	@Override
	public void onStopPlayoutCompleted(boolean isSuccessful) {
	runOnUiThread(() -> {
	if (isSuccessful) {
	showToast("Stopped playout");
	} else {
	showToast("Speaker termination failed");
	}
	});
	}

	@Override
	public void onUninitializedVoipClient() {
	runOnUiThread(() -> { showToast("Voip client is uninitialized"); });
	}
	}