commit 291d5570005561ebaee86900bd09a0a705a93b26
Author: hjwang <2392948297@qq.com>
Date: Mon Jun 1 18:03:26 2026 +0800
first commit
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..173d16f
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,18 @@
+*.iml
+.gradle
+/local.properties
+/.idea/caches
+/.idea/libraries
+/.idea/modules.xml
+/.idea/workspace.xml
+/.idea/navEditor.xml
+/.idea/assetWizardSettings.xml
+.DS_Store
+/build
+/captures
+.externalNativeBuild
+.cxx
+local.properties
+
+
+.idea/
diff --git a/app/.gitignore b/app/.gitignore
new file mode 100644
index 0000000..42afabf
--- /dev/null
+++ b/app/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/app/build.gradle b/app/build.gradle
new file mode 100644
index 0000000..3d4b0e6
--- /dev/null
+++ b/app/build.gradle
@@ -0,0 +1,39 @@
+plugins {
+ alias(libs.plugins.android.application)
+}
+
+android {
+ namespace 'com.kimgo.posefit'
+ compileSdk 34
+
+ defaultConfig {
+ applicationId "com.kimgo.posefit"
+ minSdk 29
+ targetSdk 34
+ versionCode 1
+ versionName "1.0"
+
+ testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+ }
+
+ buildTypes {
+ release {
+ minifyEnabled false
+ proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+ }
+ }
+ compileOptions {
+ sourceCompatibility JavaVersion.VERSION_11
+ targetCompatibility JavaVersion.VERSION_11
+ }
+}
+
+dependencies {
+ implementation libs.appcompat
+ implementation libs.material
+ testImplementation libs.junit
+ androidTestImplementation libs.espresso.core
+ androidTestImplementation libs.ext.junit
+ implementation "io.getstream:stream-webrtc-android:1.3.10"
+ implementation "com.squareup.okhttp3:okhttp:4.12.0"
+}
\ No newline at end of file
diff --git a/app/proguard-rules.pro b/app/proguard-rules.pro
new file mode 100644
index 0000000..481bb43
--- /dev/null
+++ b/app/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+# http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+# public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
\ No newline at end of file
diff --git a/app/src/androidTest/java/com/kimgo/posefit/ExampleInstrumentedTest.java b/app/src/androidTest/java/com/kimgo/posefit/ExampleInstrumentedTest.java
new file mode 100644
index 0000000..57e91f3
--- /dev/null
+++ b/app/src/androidTest/java/com/kimgo/posefit/ExampleInstrumentedTest.java
@@ -0,0 +1,26 @@
+package com.kimgo.posefit;
+
+import android.content.Context;
+
+import androidx.test.platform.app.InstrumentationRegistry;
+import androidx.test.ext.junit.runners.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * @see Testing documentation
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+ @Test
+ public void useAppContext() {
+ // Context of the app under test.
+ Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
+ assertEquals("com.kimgo.posefit", appContext.getPackageName());
+ }
+}
\ No newline at end of file
diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
new file mode 100644
index 0000000..3ce5776
--- /dev/null
+++ b/app/src/main/AndroidManifest.xml
@@ -0,0 +1,44 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/app/src/main/java/com/kimgo/posefit/MainActivity.kt b/app/src/main/java/com/kimgo/posefit/MainActivity.kt
new file mode 100644
index 0000000..cdd24e0
--- /dev/null
+++ b/app/src/main/java/com/kimgo/posefit/MainActivity.kt
@@ -0,0 +1,41 @@
+package com.kimgo.posefit
+
+import android.Manifest
+import android.os.Bundle
+import androidx.activity.ComponentActivity
+import androidx.activity.result.contract.ActivityResultContracts
+import com.kimgo.posefit.sender.WebRtcSenderClient
+
+class MainActivity : ComponentActivity() {
+
+ private lateinit var webRtcClient: WebRtcSenderClient
+
+ private val requestPermission =
+ registerForActivityResult(ActivityResultContracts.RequestPermission()) { granted ->
+ if (granted) {
+ startWebRtc()
+ }
+ }
+
+ override fun onCreate(savedInstanceState: Bundle?) {
+ super.onCreate(savedInstanceState)
+
+ requestPermission.launch(Manifest.permission.CAMERA)
+ }
+
+ private fun startWebRtc() {
+ webRtcClient = WebRtcSenderClient(
+ context = this,
+ signalingUrl = "ws://192.168.110.240:8080"
+ )
+
+ webRtcClient.start()
+ }
+
+ override fun onDestroy() {
+ super.onDestroy()
+ if (::webRtcClient.isInitialized) {
+ webRtcClient.release()
+ }
+ }
+}
\ No newline at end of file
diff --git a/app/src/main/java/com/kimgo/posefit/sender/SimpleSdpObserver.kt b/app/src/main/java/com/kimgo/posefit/sender/SimpleSdpObserver.kt
new file mode 100644
index 0000000..27178af
--- /dev/null
+++ b/app/src/main/java/com/kimgo/posefit/sender/SimpleSdpObserver.kt
@@ -0,0 +1,12 @@
+package com.kimgo.posefit.sender
+
+import org.webrtc.SdpObserver
+import org.webrtc.SessionDescription
+
+
+open class SimpleSdpObserver : SdpObserver {
+ override fun onCreateSuccess(desc: SessionDescription) {}
+ override fun onSetSuccess() {}
+ override fun onCreateFailure(error: String) {}
+ override fun onSetFailure(error: String) {}
+}
\ No newline at end of file
diff --git a/app/src/main/java/com/kimgo/posefit/sender/WebRtcSenderClient.kt b/app/src/main/java/com/kimgo/posefit/sender/WebRtcSenderClient.kt
new file mode 100644
index 0000000..01fa51c
--- /dev/null
+++ b/app/src/main/java/com/kimgo/posefit/sender/WebRtcSenderClient.kt
@@ -0,0 +1,223 @@
+package com.kimgo.posefit.sender
+
+import android.content.Context
+import okhttp3.*
+import org.json.JSONObject
+import org.webrtc.*
+
+class WebRtcSenderClient(
+ private val context: Context,
+ private val signalingUrl: String
+) {
+
+ private val eglBase = EglBase.create()
+ private val okHttpClient = OkHttpClient()
+
+ private lateinit var webSocket: WebSocket
+ private lateinit var factory: PeerConnectionFactory
+ private var peerConnection: PeerConnection? = null
+
+ private var videoCapturer: CameraVideoCapturer? = null
+ private var videoSource: VideoSource? = null
+ private var videoTrack: VideoTrack? = null
+ private var surfaceTextureHelper: SurfaceTextureHelper? = null
+
+ fun start() {
+ initPeerConnectionFactory()
+ connectSignaling()
+ }
+
+ private fun initPeerConnectionFactory() {
+ PeerConnectionFactory.initialize(
+ PeerConnectionFactory.InitializationOptions.builder(context)
+ .createInitializationOptions()
+ )
+
+ val encoderFactory = DefaultVideoEncoderFactory(
+ eglBase.eglBaseContext,
+ true,
+ true
+ )
+
+ val decoderFactory = DefaultVideoDecoderFactory(
+ eglBase.eglBaseContext
+ )
+
+ factory = PeerConnectionFactory.builder()
+ .setVideoEncoderFactory(encoderFactory)
+ .setVideoDecoderFactory(decoderFactory)
+ .createPeerConnectionFactory()
+ }
+
+ private fun connectSignaling() {
+ val request = Request.Builder()
+ .url(signalingUrl)
+ .build()
+
+ webSocket = okHttpClient.newWebSocket(request, object : WebSocketListener() {
+
+ override fun onOpen(webSocket: WebSocket, response: Response) {
+ createPeerConnection()
+ startCamera()
+ createOffer()
+ }
+
+ override fun onMessage(webSocket: WebSocket, text: String) {
+ handleSignalingMessage(text)
+ }
+ })
+ }
+
+ private fun createPeerConnection() {
+ val iceServers = listOf(
+ PeerConnection.IceServer.builder("stun:stun.l.google.com:19302")
+ .createIceServer()
+ )
+
+ val rtcConfig = PeerConnection.RTCConfiguration(iceServers).apply {
+ sdpSemantics = PeerConnection.SdpSemantics.UNIFIED_PLAN
+ }
+
+ peerConnection = factory.createPeerConnection(
+ rtcConfig,
+ object : PeerConnection.Observer {
+
+ override fun onIceCandidate(candidate: IceCandidate) {
+ val json = JSONObject().apply {
+ put("type", "candidate")
+ put("sdpMid", candidate.sdpMid)
+ put("sdpMLineIndex", candidate.sdpMLineIndex)
+ put("candidate", candidate.sdp)
+ }
+
+ webSocket.send(json.toString())
+ }
+
+ override fun onSignalingChange(state: PeerConnection.SignalingState) {}
+ override fun onIceConnectionChange(state: PeerConnection.IceConnectionState) {}
+ override fun onIceConnectionReceivingChange(receiving: Boolean) {}
+ override fun onIceGatheringChange(state: PeerConnection.IceGatheringState) {}
+ override fun onIceCandidatesRemoved(candidates: Array) {}
+ override fun onAddStream(stream: MediaStream) {}
+ override fun onRemoveStream(stream: MediaStream) {}
+ override fun onDataChannel(channel: DataChannel) {}
+ override fun onRenegotiationNeeded() {}
+ override fun onAddTrack(receiver: RtpReceiver, streams: Array) {}
+ }
+ )
+ }
+
+ private fun startCamera() {
+ val enumerator = Camera2Enumerator(context)
+
+ val cameraName = enumerator.deviceNames.firstOrNull {
+ enumerator.isFrontFacing(it)
+ } ?: enumerator.deviceNames.first()
+
+ videoCapturer = enumerator.createCapturer(cameraName, null)
+
+ surfaceTextureHelper = SurfaceTextureHelper.create(
+ "CameraThread",
+ eglBase.eglBaseContext
+ )
+
+ videoSource = factory.createVideoSource(false)
+
+ videoCapturer?.initialize(
+ surfaceTextureHelper,
+ context,
+ videoSource?.capturerObserver
+ )
+
+ videoCapturer?.startCapture(1280, 720, 30)
+
+ videoTrack = factory.createVideoTrack("video_track", videoSource)
+
+ peerConnection?.addTrack(
+ videoTrack,
+ listOf("posefit_stream")
+ )
+ }
+
+ private fun createOffer() {
+ val constraints = MediaConstraints().apply {
+ mandatory.add(
+ MediaConstraints.KeyValuePair("OfferToReceiveVideo", "false")
+ )
+ mandatory.add(
+ MediaConstraints.KeyValuePair("OfferToReceiveAudio", "false")
+ )
+ }
+
+ peerConnection?.createOffer(object : SdpObserver {
+
+ override fun onCreateSuccess(desc: SessionDescription) {
+ peerConnection?.setLocalDescription(object : SdpObserver {
+ override fun onSetSuccess() {
+ val json = JSONObject().apply {
+ put("type", desc.type.canonicalForm())
+ put("sdp", desc.description)
+ }
+
+ webSocket.send(json.toString())
+ }
+
+ override fun onSetFailure(error: String) {}
+ override fun onCreateSuccess(desc: SessionDescription) {}
+ override fun onCreateFailure(error: String) {}
+ }, desc)
+ }
+
+ override fun onSetSuccess() {}
+ override fun onCreateFailure(error: String) {}
+ override fun onSetFailure(error: String) {}
+
+ }, constraints)
+ }
+
+ private fun handleSignalingMessage(text: String) {
+ val json = JSONObject(text)
+
+ when (json.getString("type")) {
+ "answer" -> {
+ val sdp = SessionDescription(
+ SessionDescription.Type.ANSWER,
+ json.getString("sdp")
+ )
+
+ peerConnection?.setRemoteDescription(
+ SimpleSdpObserver(),
+ sdp
+ )
+ }
+
+ "candidate" -> {
+ val candidate = IceCandidate(
+ json.getString("sdpMid"),
+ json.getInt("sdpMLineIndex"),
+ json.getString("candidate")
+ )
+
+ peerConnection?.addIceCandidate(candidate)
+ }
+ }
+ }
+
+ fun release() {
+ try {
+ videoCapturer?.stopCapture()
+ } catch (_: Exception) {
+ }
+
+ videoCapturer?.dispose()
+ videoSource?.dispose()
+ videoTrack?.dispose()
+ surfaceTextureHelper?.dispose()
+ peerConnection?.close()
+ peerConnection?.dispose()
+ factory.dispose()
+ eglBase.release()
+ webSocket.close(1000, "close")
+ okHttpClient.dispatcher.executorService.shutdown()
+ }
+}
\ No newline at end of file
diff --git a/app/src/main/res/drawable/ic_launcher_background.xml b/app/src/main/res/drawable/ic_launcher_background.xml
new file mode 100644
index 0000000..07d5da9
--- /dev/null
+++ b/app/src/main/res/drawable/ic_launcher_background.xml
@@ -0,0 +1,170 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/app/src/main/res/drawable/ic_launcher_foreground.xml b/app/src/main/res/drawable/ic_launcher_foreground.xml
new file mode 100644
index 0000000..2b068d1
--- /dev/null
+++ b/app/src/main/res/drawable/ic_launcher_foreground.xml
@@ -0,0 +1,30 @@
+
+
+
+
+