updated dockerfile & api

API_DOCS.md

@@ -179,6 +179,80 @@ or
 }
 ```
 
+### 5. Get Angle Metadata for Session
+**Endpoint:** `GET /api/audio/angles/{session_id}`
+
+**Description:** Retrieve angle data collected during an audio streaming session.
+
+**Authentication:** Required (JWT token)
+
+**Parameters:**
+- `session_id` (path parameter): The UUID of the audio session
+
+**Response:**
+```json
+{
+  "ok": true,
+  "session_id": "uuid-here",
+  "angles": [
+    {"timestamp": 0.000, "angle": 45.50},
+    {"timestamp": 0.064, "angle": 46.20},
+    {"timestamp": 0.128, "angle": 47.00}
+  ],
+  "count": 3
+}
+```
+
+### 6. Download Audio File
+**Endpoint:** `GET /api/audio/download/{session_id}`
+
+**Description:** Download the recorded audio file (.wav) for a specific session.
+
+**Authentication:** Required (JWT token)
+
+**Parameters:**
+- `session_id` (path parameter): The UUID of the audio session
+
+**Response:**
+- Binary WAV file with `Content-Type: audio/wav`
+- File download with appropriate filename header
+
+### 7. Set Desired Angle
+**Endpoint:** `POST /api/audio/set-angle/{session_id}`
+
+**Description:** Send a desired/target angle to the audio processing backend for a session.
+
+**Authentication:** Required (JWT token)
+
+**Parameters:**
+- `session_id` (path parameter): The UUID of the audio session
+- `angle` (form parameter, required): Desired angle in degrees (0-360)
+
+**Request:**
+```
+POST /api/audio/set-angle/session-uuid-here
+Content-Type: multipart/form-data
+
+angle=45.5
+```
+
+**Response:**
+```json
+{
+  "ok": true,
+  "message": "Desired angle set to 45.5°",
+  "session_id": "uuid-here",
+  "angle": 45.5
+}
+```
+
+**Error Response (Invalid Angle):**
+```json
+{
+  "detail": "Angle must be between 0 and 360 degrees"
+}
+```
+
 ## File Storage
 
 All uploaded files and processed data are stored in the `/Model/` directory:
@@ -240,4 +314,28 @@ async def stream_audio():
         await websocket.send(json.dumps({"command": "stop"}))
 
 asyncio.run(stream_audio())
+
+# 4. Get angle data for a session
+response = requests.get(
+    f"http://localhost:8000/api/audio/angles/{session_id}",
+    headers={"Authorization": f"Bearer {token}"}
+)
+angles = response.json()["angles"]
+print(f"Recorded {len(angles)} angle measurements")
+
+# 5. Download recorded audio
+response = requests.get(
+    f"http://localhost:8000/api/audio/download/{session_id}",
+    headers={"Authorization": f"Bearer {token}"}
+)
+with open("downloaded_audio.wav", "wb") as f:
+    f.write(response.content)
+
+# 6. Send desired angle to backend
+response = requests.post(
+    f"http://localhost:8000/api/audio/set-angle/{session_id}",
+    data={"angle": 90.0},
+    headers={"Authorization": f"Bearer {token}"}
+)
+print(response.json())
 ```

Dockerfile

@@ -3,6 +3,9 @@ FROM python:3.11-slim
 WORKDIR /app
 
 RUN apt-get update && apt-get install -y \
+    gcc \
+    gfortran \
+    libopenblas-dev \
     libgl1-mesa-glx \
     libglib2.0-0 \
     libsm6 \

server.py

@@ -710,5 +710,128 @@ async def list_audio_recordings(current_user: UserPublic = Depends(get_current_u
         logger.error(f"Error listing recordings: {e}")
         raise HTTPException(status_code=500, detail=str(e))
 
+@app.get("/api/audio/angles/{session_id}")
+async def get_audio_angles(
+    session_id: str
+):
+    """Get angle metadata for a specific audio session."""
+    try:
+        metadata_file = MODEL_DIR / "audio_recordings" / f"audio_{session_id}_metadata.txt"
+        
+        if not metadata_file.exists():
+            raise HTTPException(
+                status_code=404,
+                detail=f"No metadata found for session {session_id}"
+            )
+        
+        angles_data = []
+        with open(metadata_file, 'r') as f:
+            lines = f.readlines()
+            # Skip header if present
+            start_idx = 1 if lines and 'timestamp' in lines[0] else 0
+            for line in lines[start_idx:]:
+                if line.strip():
+                    parts = line.strip().split(',')
+                    if len(parts) >= 2:
+                        try:
+                            timestamp = float(parts[0])
+                            angle = float(parts[1])
+                            angles_data.append({"timestamp": timestamp, "angle": angle})
+                        except ValueError:
+                            continue
+        
+        return {
+            "ok": True,
+            "session_id": session_id,
+            "angles": angles_data,
+            "count": len(angles_data)
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Error retrieving angles for session {session_id}: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/audio/download/{session_id}")
+async def download_audio_file(
+    session_id: str
+):
+    """Download recorded audio file for a specific session."""
+    try:
+        # Find the audio file matching this session_id
+        audio_dir = MODEL_DIR / "audio_recordings"
+        
+        if not audio_dir.exists():
+            raise HTTPException(status_code=404, detail="No audio recordings found")
+        
+        # Search for the file with this session_id
+        audio_file = None
+        for file in audio_dir.glob(f"audio_{session_id}_*.wav"):
+            # Skip metadata files
+            if not str(file).endswith("_metadata.txt"):
+                audio_file = file
+                break
+        
+        if not audio_file or not audio_file.exists():
+            raise HTTPException(
+                status_code=404,
+                detail=f"Audio file not found for session {session_id}"
+            )
+        
+        return StreamingResponse(
+            iter([await asyncio.get_event_loop().run_in_executor(None, audio_file.read_bytes)]),
+            media_type="audio/wav",
+            headers={
+                "Content-Disposition": f"attachment; filename={audio_file.name}"
+            }
+        )
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Error downloading audio for session {session_id}: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.post("/api/audio/set-angle/{session_id}")
+async def set_desired_angle(
+    session_id: str,
+    angle: float = Form(...)
+):
+    """Send a desired angle to the audio processing system."""
+    try:
+        if not (0 <= angle <= 360):
+            raise HTTPException(
+                status_code=400,
+                detail="Angle must be between 0 and 360 degrees"
+            )
+        
+        # Check if session exists
+        audio_dir = MODEL_DIR / "audio_recordings"
+        session_exists = any(audio_dir.glob(f"audio_{session_id}_*.wav"))
+        
+        if not session_exists:
+            raise HTTPException(
+                status_code=404,
+                detail=f"Session {session_id} not found"
+            )
+        
+        # Store desired angle (append to metadata or create angle request file)
+        desired_angle_file = audio_dir / f"audio_{session_id}_desired_angle.txt"
+        with open(desired_angle_file, 'w') as f:
+            f.write(f"{angle}\n")
+        
+        logger.info(f"Set desired angle {angle}° for session {session_id}")
+        
+        return {
+            "ok": True,
+            "message": f"Desired angle set to {angle}°",
+            "session_id": session_id,
+            "angle": angle
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Error setting angle for session {session_id}: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
 if __name__ == "__main__":
     uvicorn.run("server:app", host="0.0.0.0", port=8000, reload=True)