Update Android native API example to use real camera.

For simplicity, camera with index 0 is used. User also has to manually
give the permission to use the camera for the app.

Bug: webrtc:8769
Change-Id: I371f26f94d629411fd299671b4f3202e84556b80
Reviewed-on: https://webrtc-review.googlesource.com/76982
Commit-Queue: Sami Kalliomäki <sakal@webrtc.org>
Reviewed-by: Paulina Hensman <phensman@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#23284}

examples/androidnativeapi/AndroidManifest.xml

@@ -5,6 +5,7 @@
   <uses-sdk android:minSdkVersion="19" android:targetSdkVersion="27" />
 
   <uses-permission android:name="android.permission.INTERNET" />
+  <uses-permission android:name="android.permission.CAMERA" />
 
   <application
     android:allowBackup="true"

examples/androidnativeapi/BUILD.gn

@@ -12,8 +12,11 @@ rtc_android_apk("androidnativeapi") {
 
   deps = [
     ":resources",
+    "//modules/audio_device:audio_device_java",
+    "//sdk/android:camera_java",
     "//sdk/android:surfaceviewrenderer_java",
     "//sdk/android:video_api_java",
+    "//sdk/android:video_java",
   ]
 
   shared_libraries = [ ":examples_androidnativeapi_jni" ]
@@ -58,7 +61,6 @@ rtc_shared_library("examples_androidnativeapi_jni") {
     "//modules/audio_processing",
     "//modules/utility:utility",
     "//pc:libjingle_peerconnection",
-    "//pc:pc_test_utils",
     "//rtc_base:rtc_base",
     "//rtc_base:rtc_base_approved",
     "//sdk/android:native_api_base",

examples/androidnativeapi/java/org/webrtc/examples/androidnativeapi/CallClient.java

@@ -10,28 +10,46 @@
 
 package org.webrtc.examples.androidnativeapi;
 
+import android.content.Context;
 import android.os.Handler;
 import android.os.HandlerThread;
+import org.webrtc.JNINamespace;
 import org.webrtc.NativeClassQualifiedName;
+import org.webrtc.SurfaceTextureHelper;
+import org.webrtc.VideoCapturer;
 import org.webrtc.VideoSink;
 
+@JNINamespace("webrtc_examples")
 public class CallClient {
   private static final String TAG = "CallClient";
+  private static final int CAPTURE_WIDTH = 640;
+  private static final int CAPTURE_HEIGHT = 480;
+  private static final int CAPTURE_FPS = 30;
 
+  private final Context applicationContext;
   private final HandlerThread thread;
   private final Handler handler;
 
   private long nativeClient;
+  private SurfaceTextureHelper surfaceTextureHelper;
+  private VideoCapturer videoCapturer;
 
-  public CallClient() {
+  public CallClient(Context applicationContext) {
+    this.applicationContext = applicationContext;
     thread = new HandlerThread(TAG + "Thread");
     thread.start();
     handler = new Handler(thread.getLooper());
     handler.post(() -> { nativeClient = nativeCreateClient(); });
   }
 
-  public void call(VideoSink localSink, VideoSink remoteSink) {
-    handler.post(() -> { nativeCall(nativeClient, localSink, remoteSink); });
+  public void call(VideoSink localSink, VideoSink remoteSink, VideoCapturer videoCapturer,
+      SurfaceTextureHelper videoCapturerSurfaceTextureHelper) {
+    handler.post(() -> {
+      nativeCall(nativeClient, localSink, remoteSink);
+      videoCapturer.initialize(videoCapturerSurfaceTextureHelper, applicationContext,
+          nativeGetJavaVideoCapturerObserver(nativeClient));
+      videoCapturer.startCapture(CAPTURE_WIDTH, CAPTURE_HEIGHT, CAPTURE_FPS);
+    });
   }
 
   public void hangup() {
@@ -53,4 +71,7 @@ public class CallClient {
   private static native void nativeHangup(long nativePtr);
   @NativeClassQualifiedName("webrtc_examples::AndroidCallClient")
   private static native void nativeDelete(long nativePtr);
+  @NativeClassQualifiedName("webrtc_examples::AndroidCallClient")
+  private static native VideoCapturer.CapturerObserver nativeGetJavaVideoCapturerObserver(
+      long nativePtr);
 }

examples/androidnativeapi/java/org/webrtc/examples/androidnativeapi/MainActivity.java

@@ -11,19 +11,27 @@
 package org.webrtc.examples.androidnativeapi;
 
 import android.app.Activity;
+import android.content.Context;
 import android.os.Bundle;
 import android.widget.Button;
 import javax.annotation.Nullable;
+import org.webrtc.Camera1Enumerator;
+import org.webrtc.Camera2Enumerator;
+import org.webrtc.CameraEnumerator;
 import org.webrtc.ContextUtils;
 import org.webrtc.EglBase;
 import org.webrtc.GlRectDrawer;
+import org.webrtc.SurfaceTextureHelper;
 import org.webrtc.SurfaceViewRenderer;
+import org.webrtc.VideoCapturer;
 
 public class MainActivity extends Activity {
   private @Nullable CallClient callClient;
   private @Nullable EglBase eglBase;
   private @Nullable SurfaceViewRenderer localRenderer;
   private @Nullable SurfaceViewRenderer remoteRenderer;
+  private @Nullable SurfaceTextureHelper videoCapturerSurfaceTextureHelper;
+  private @Nullable VideoCapturer videoCapturer;
 
   @Override
   protected void onCreate(Bundle savedInstance) {
@@ -33,13 +41,19 @@ public class MainActivity extends Activity {
     setContentView(R.layout.activity_main);
 
     System.loadLibrary("examples_androidnativeapi_jni");
-    callClient = new CallClient();
+    callClient = new CallClient(getApplicationContext());
 
     Button callButton = (Button) findViewById(R.id.call_button);
-    callButton.setOnClickListener((view) -> { callClient.call(localRenderer, remoteRenderer); });
+    callButton.setOnClickListener((view) -> {
+      if (videoCapturer == null) {
+        videoCapturer = createVideoCapturer(getApplicationContext());
+      }
+      callClient.call(
+          localRenderer, remoteRenderer, videoCapturer, videoCapturerSurfaceTextureHelper);
+    });
 
     Button hangupButton = (Button) findViewById(R.id.hangup_button);
-    hangupButton.setOnClickListener((view) -> { callClient.hangup(); });
+    hangupButton.setOnClickListener((view) -> { hangup(); });
   }
 
   @Override
@@ -54,18 +68,23 @@ public class MainActivity extends Activity {
         new GlRectDrawer());
     remoteRenderer.init(eglBase.getEglBaseContext(), null /* rendererEvents */,
         EglBase.CONFIG_PLAIN, new GlRectDrawer());
+
+    videoCapturerSurfaceTextureHelper =
+        SurfaceTextureHelper.create("VideoCapturerThread", eglBase.getEglBaseContext());
   }
 
   @Override
   protected void onStop() {
-    callClient.hangup();
+    hangup();
 
     localRenderer.release();
     remoteRenderer.release();
+    videoCapturerSurfaceTextureHelper.dispose();
     eglBase.release();
 
     localRenderer = null;
     remoteRenderer = null;
+    videoCapturerSurfaceTextureHelper = null;
     eglBase = null;
 
     super.onStop();
@@ -78,4 +97,24 @@ public class MainActivity extends Activity {
 
     super.onDestroy();
   }
+
+  private void hangup() {
+    if (videoCapturer != null) {
+      try {
+        videoCapturer.stopCapture();
+      } catch (InterruptedException e) {
+        throw new RuntimeException(e);
+      }
+      videoCapturer.dispose();
+      videoCapturer = null;
+    }
+    callClient.hangup();
+  }
+
+  private static VideoCapturer createVideoCapturer(Context context) {
+    CameraEnumerator enumerator = Camera2Enumerator.isSupported(context)
+        ? new Camera2Enumerator(context)
+        : new Camera1Enumerator();
+    return enumerator.createCapturer(enumerator.getDeviceNames()[0], null /* eventsHandler */);
+  }
 }

examples/androidnativeapi/jni/androidcallclient.cc

@@ -20,7 +20,6 @@
 #include "media/engine/internalencoderfactory.h"
 #include "media/engine/webrtcmediaengine.h"
 #include "modules/audio_processing/include/audio_processing.h"
-#include "pc/test/fakeperiodicvideocapturer.h"
 #include "rtc_base/ptr_util.h"
 #include "sdk/android/native_api/jni/java_types.h"
 #include "sdk/android/native_api/video/wrapper.h"
@@ -97,16 +96,8 @@ void AndroidCallClient::Call(JNIEnv* env,
   local_sink_ = webrtc::JavaToNativeVideoSink(env, local_sink.obj());
   remote_sink_ = webrtc::JavaToNativeVideoSink(env, remote_sink.obj());
 
-  // The fake video source wants to be created on the same thread as it is
-  // destroyed. It is destroyed on the signaling thread so we have to invoke
-  // here.
-  // TODO(sakal): Get picture from camera?
-  video_source_ = pcf_->CreateVideoSource(
-      signaling_thread_
-          ->Invoke<std::unique_ptr<webrtc::FakePeriodicVideoCapturer>>(
-              RTC_FROM_HERE, [&] {
-                return rtc::MakeUnique<webrtc::FakePeriodicVideoCapturer>();
-              }));
+  video_source_ = webrtc::CreateJavaVideoSource(env, signaling_thread_.get(),
+                                                false /* is_screencast */);
 
   CreatePeerConnection();
   Connect();
@@ -138,6 +129,15 @@ void AndroidCallClient::Delete(JNIEnv* env,
   delete this;
 }
 
+webrtc::ScopedJavaLocalRef<jobject>
+AndroidCallClient::GetJavaVideoCapturerObserver(
+    JNIEnv* env,
+    const webrtc::JavaRef<jobject>& cls) {
+  RTC_DCHECK_RUN_ON(&thread_checker_);
+
+  return video_source_->GetJavaVideoCapturerObserver(env);
+}
+
 void AndroidCallClient::CreatePeerConnectionFactory() {
   network_thread_ = rtc::Thread::CreateWithSocketServer();
   network_thread_->SetName("network_thread", nullptr);
@@ -277,10 +277,10 @@ void SetLocalSessionDescriptionObserver::OnFailure(const std::string& error) {
   RTC_LOG(LS_INFO) << "Set local description failure: " << error;
 }
 
-}  // namespace webrtc_examples
-
 static jlong JNI_CallClient_CreateClient(
     JNIEnv* env,
     const webrtc::JavaParamRef<jclass>& cls) {
   return webrtc::NativeToJavaPointer(new webrtc_examples::AndroidCallClient());
 }
+
+}  // namespace webrtc_examples

examples/androidnativeapi/jni/androidcallclient.h

@@ -21,6 +21,7 @@
 #include "rtc_base/scoped_ref_ptr.h"
 #include "rtc_base/thread_checker.h"
 #include "sdk/android/native_api/jni/scoped_java_ref.h"
+#include "sdk/android/native_api/video/videosource.h"
 
 namespace webrtc_examples {
 
@@ -36,6 +37,10 @@ class AndroidCallClient {
   // A helper method for Java code to delete this object. Calls delete this.
   void Delete(JNIEnv* env, const webrtc::JavaRef<jobject>& cls);
 
+  webrtc::ScopedJavaLocalRef<jobject> GetJavaVideoCapturerObserver(
+      JNIEnv* env,
+      const webrtc::JavaRef<jobject>& cls);
+
  private:
   class PCObserver;
 
@@ -60,7 +65,7 @@ class AndroidCallClient {
       RTC_GUARDED_BY(thread_checker_);
   std::unique_ptr<rtc::VideoSinkInterface<webrtc::VideoFrame>> remote_sink_
       RTC_GUARDED_BY(thread_checker_);
-  rtc::scoped_refptr<webrtc::VideoTrackSourceInterface> video_source_
+  rtc::scoped_refptr<webrtc::JavaVideoTrackSourceInterface> video_source_
       RTC_GUARDED_BY(thread_checker_);
 
   rtc::CriticalSection pc_mutex_;