diff --git a/app/build.gradle.kts b/app/build.gradle.kts
index c44c803..035475c 100644
--- a/app/build.gradle.kts
+++ b/app/build.gradle.kts
@@ -6,9 +6,7 @@ plugins {
android {
namespace = "sh.sar.callpipe"
compileSdk {
- version = release(36) {
- minorApiLevel = 1
- }
+ version = release(37)
}
defaultConfig {
@@ -48,6 +46,8 @@ dependencies {
implementation(libs.androidx.compose.ui.tooling.preview)
implementation(libs.androidx.core.ktx)
implementation(libs.androidx.lifecycle.runtime.ktx)
+ implementation(libs.androidx.lifecycle.runtime.compose)
+ implementation(libs.nanohttpd.websocket)
testImplementation(libs.junit)
androidTestImplementation(platform(libs.androidx.compose.bom))
androidTestImplementation(libs.androidx.compose.ui.test.junit4)
diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml
index 7a53664..811f9c3 100644
--- a/app/src/main/AndroidManifest.xml
+++ b/app/src/main/AndroidManifest.xml
@@ -2,6 +2,25 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ android:theme="@style/Theme.Callpipe"
+ tools:targetApi="34">
+
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
\ No newline at end of file
+
diff --git a/app/src/main/assets/web/app.js b/app/src/main/assets/web/app.js
new file mode 100644
index 0000000..cb01474
--- /dev/null
+++ b/app/src/main/assets/web/app.js
@@ -0,0 +1,110 @@
+// CallPipe agent softphone.
+// Audio: 16 kHz mono PCM S16LE both ways over a binary WebSocket, matching the
+// relay/phone pipeline. One ScriptProcessor both captures the mic (-> uplink)
+// and plays received audio (<- downlink). Signaling is text JSON on the same WS.
+
+const RATE = 16000;
+const MAX_PLAY = RATE; // cap playback backlog at ~1s to bound latency
+
+let ws = null;
+let ac = null;
+let node = null;
+let micStream = null;
+let playBuf = []; // queued Float32 samples to play
+let callActive = false;
+
+const $ = (id) => document.getElementById(id);
+function log(m) {
+ const el = $("log");
+ el.textContent = (new Date().toLocaleTimeString() + " " + m + "\n" + el.textContent).slice(0, 2000);
+}
+
+function setDot(id, on) { $(id).classList.toggle("on", !!on); }
+function show(id, on) { $(id).classList.toggle("hide", !on); }
+
+// ---- WebSocket ----
+function connect() {
+ ws = new WebSocket(`wss://${location.host}/agent`);
+ ws.binaryType = "arraybuffer";
+ ws.onopen = () => { setDot("dotWs", true); $("wsText").textContent = "Connected"; log("ws open"); };
+ ws.onclose = () => {
+ setDot("dotWs", false); $("wsText").textContent = "Reconnecting…";
+ log("ws closed"); setTimeout(connect, 2000);
+ };
+ ws.onerror = () => log("ws error");
+ ws.onmessage = (e) => {
+ if (typeof e.data === "string") { onSignal(JSON.parse(e.data)); return; }
+ const i16 = new Int16Array(e.data);
+ for (let i = 0; i < i16.length; i++) playBuf.push(i16[i] / 32768);
+ if (playBuf.length > MAX_PLAY) playBuf.splice(0, playBuf.length - MAX_PLAY);
+ };
+}
+
+function send(obj) { if (ws && ws.readyState === 1) ws.send(JSON.stringify(obj)); }
+
+// ---- Signaling ----
+function onSignal(msg) {
+ if (msg.event === "state") {
+ const s = msg.state || "IDLE";
+ callActive = (s !== "IDLE" && s !== "DISCONNECTED");
+ $("stateText").textContent = prettyState(s);
+ $("numText").textContent = msg.number ? ((msg.direction || "") + " " + msg.number).trim() : "";
+ show("btnAnswer", s === "RINGING");
+ show("btnHangup", callActive);
+ show("btnDial", !callActive && ws && ws.readyState === 1);
+ } else if (msg.event === "relay") {
+ setDot("dotRelay", msg.connected);
+ $("relayText").textContent = msg.connected ? "Relay connected" : "Relay not connected";
+ } else if (msg.event === "error") {
+ log("error: " + msg.msg);
+ } else if (msg.event === "hello") {
+ log("hello from " + msg.app);
+ }
+}
+
+function prettyState(s) {
+ return { IDLE:"Idle", CONNECTING:"Connecting…", DIALING:"Ringing…",
+ RINGING:"Incoming call", ACTIVE:"Connected", HOLDING:"On hold",
+ DISCONNECTING:"Ending…", DISCONNECTED:"Call ended" }[s] || s;
+}
+
+// ---- Audio ----
+async function initAudio() {
+ ac = new AudioContext({ sampleRate: RATE });
+ micStream = await navigator.mediaDevices.getUserMedia({
+ audio: { channelCount: 1, echoCancellation: true, noiseSuppression: true, autoGainControl: true }
+ });
+ const src = ac.createMediaStreamSource(micStream);
+ node = ac.createScriptProcessor(2048, 1, 1);
+ node.onaudioprocess = (e) => {
+ // capture mic -> uplink
+ const inp = e.inputBuffer.getChannelData(0);
+ if (callActive && ws && ws.readyState === 1) {
+ const out = new Int16Array(inp.length);
+ for (let i = 0; i < inp.length; i++) {
+ let s = Math.max(-1, Math.min(1, inp[i]));
+ out[i] = s < 0 ? s * 32768 : s * 32767;
+ }
+ ws.send(out.buffer);
+ }
+ // playback downlink -> speakers
+ const o = e.outputBuffer.getChannelData(0);
+ for (let i = 0; i < o.length; i++) o[i] = playBuf.length ? playBuf.shift() : 0;
+ };
+ src.connect(node);
+ node.connect(ac.destination);
+ log("audio ready @ " + ac.sampleRate + "Hz");
+}
+
+// ---- Buttons ----
+$("btnStart").onclick = async () => {
+ $("btnStart").disabled = true;
+ try { await initAudio(); connect(); show("btnStart", false); }
+ catch (err) { log("mic failed: " + err); $("btnStart").disabled = false; }
+};
+$("btnAnswer").onclick = () => send({ cmd: "answer" });
+$("btnHangup").onclick = () => send({ cmd: "hangup" });
+$("btnDial").onclick = () => {
+ const n = prompt("Number to dial:");
+ if (n) send({ cmd: "dial", number: n });
+};
diff --git a/app/src/main/assets/web/index.html b/app/src/main/assets/web/index.html
new file mode 100644
index 0000000..7a3d4ec
--- /dev/null
+++ b/app/src/main/assets/web/index.html
@@ -0,0 +1,51 @@
+
+
+
+
+
+CallPipe Agent
+
+
+
+
+
CallPipe Agent
+
browser softphone
+
+
Not connected
+
Relay unknown
+
+
Idle
+
+
+
+
+
+
+
+
+