GPSAI Chatbot
Intégration Mobile

dependencies {
    // Stream Chat UI Components
    implementation "io.getstream:stream-chat-android-ui-components:6.4.0"
    implementation "io.getstream:stream-chat-android-offline:6.4.0"
    implementation "io.getstream:stream-chat-android-state:6.4.0"

    // HTTP client for auth token call
    implementation "com.squareup.okhttp3:okhttp:4.12.0"
}

<uses-permission android:name="android.permission.INTERNET"/>
<uses-permission android:name="android.permission.RECORD_AUDIO"/> <!-- voice only -->

private void fetchToken() {
    new Thread(() -> {
        try {
            OkHttpClient client = new OkHttpClient();

            JSONObject body = new JSONObject();
            body.put("user_id",     "user_" + gpsUserId);
            body.put("gps_user_id", gpsUserId);

            Request request = new Request.Builder()
                .url(BACKEND_URL + "/chatbot_stream_backend.php?action=token")
                .post(RequestBody.create(
                    MediaType.parse("application/json"),
                    body.toString()))
                .build();

            Réponse response = client.newCall(request).execute();
            JSONObject json = new JSONObject(response.body().string());

            String token  = json.getString("token");
            String apiKey = json.getString("api_key");
            String botId  = json.getString("bot_id");

            runOnUiThread(() -> initChat(apiKey, token, botId));
        } catch (Exception e) {
            Log.e(TAG, "Token fetch failed", e);
        }
    }).start();
}

private void initChat(String apiKey, String token, String botId) {

    // Required plugins for SDK 6.x
    StreamOfflinePluginFactory offlinePlugin =
        new StreamOfflinePluginFactory(getApplicationContext());

    StreamStatePluginFactory statePlugin =
        new StreamStatePluginFactory(
            new StatePluginConfig(true, true),
            getApplicationContext());

    ChatClient client = new ChatClient.Builder(apiKey, getApplicationContext())
        .withPlugins(offlinePlugin, statePlugin)
        .build();

    User user = new User.Builder()
        .withId("user_" + gpsUserId)
        .withName("Utilisateur " + gpsUserId)
        .build();

    client.connectUser(user, token).enqueue(result -> {
        if (result.isSuccess()) {
            createOrOpenChannel(client, botId);
        } else {
            Log.e(TAG, "Connect failed: " + result.errorOrNull());
        }
    });
}

private void createOrOpenChannel(ChatClient client, String botId) {
    String channelId = "gps_chat_user_" + gpsUserId;

    Map<String, Object> extraData = new HashMap<>();
    extraData.put("gps_user_id", gpsUserId);
    extraData.put("name",        "Assistant GPS");

    client.channel("messaging", channelId)
        .create(Arrays.asList("user_" + gpsUserId, botId), extraData)
        .enqueue(result -> {
            if (result.isSuccess()) {
                String cid = "messaging:" + channelId;
                startActivity(CustomChatActivity.newIntent(this, cid));
                finish();
            }
        });
}

private void sendMessage(String text) {
    Message message = new Message.Builder()
        .withText(text)
        .build();

    ChatClient.instance()
        .channel("messaging", channelId)
        .sendMessage(message, false)
        .enqueue(result -> {
            if (result.isSuccess()) {
                Log.d(TAG, "Sent: " + text);
            }
        });
}

// MPEG_4 / AAC, 16 kHz mono, 64 kbps — small and Whisper-friendly
recorder.setAudioSource(MediaRecorder.AudioSource.MIC);
recorder.setOutputFormat(MediaRecorder.OutputFormat.MPEG_4);
recorder.setAudioEncoder(MediaRecorder.AudioEncoder.AAC);
recorder.setAudioSamplingRate(16000);
recorder.setAudioEncodingBitRate(64000);

// Store in filesDir (NOT cacheDir — file must survive for replay)
File dir = new File(context.getFilesDir(), "voice_messages");
String path = new File(dir, "voice_" + System.currentTimeMillis() + ".m4a")
    .getAbsolutePath();
recorder.setOutputFile(path);
recorder.prepare();
recorder.start();

// Sample amplitudes every 80ms for the waveform
handler.postDelayed(() -> amplitudes.add(recorder.getMaxAmplitude()), 80);

private void sendVoiceMessage(String path, long durationMs, ArrayList<Integer> amps) {

    // ── TRACK 1: Stream message with extraData (instant UI) ──
    HashMap<String, Object> extra = new HashMap<>();
    extra.put("is_voice",          true);
    extra.put("voice_local_path",  path);
    extra.put("voice_duration_ms", durationMs);
    extra.put("voice_amplitudes",  amps);

    Message msg = new Message.Builder()
        .withText("🎙️ Voice")
        .withExtraData(extra)
        .build();

    ChatClient.instance()
        .channel(channelType, channelId)
        .sendMessage(msg, false)
        .enqueue(r -> {});

    // ── TRACK 2: base64 to backend (for AI processing) ──
    new Thread(() -> {
        String base64 = VoiceRecorder.fileToBase64(path);

        JSONObject body = new JSONObject();
        body.put("user_id",      gpsUserId);
        body.put("channel_id",   channelId);
        body.put("audio_base64", base64);

        // POST { user_id, channel_id, audio_base64 } to ?action=voice
        // ⚠️ Do NOT delete the file here — local playback needs it!
    }).start();
}

public class VoicePlayerManager {
    private static VoicePlayerManager INSTANCE;
    private MediaPlayer player;
    private String currentPath;

    public boolean toggle(String path, Listener listener) {
        // Same file → pause/resume; different file → stop old, play new
        if (path.equals(currentPath) && player != null) {
            if (player.isPlaying()) {
                player.pause();
                return false;
            }
            player.start();
            return true;
        }
        releaseInternal();
        player = new MediaPlayer();
        player.setDataSource(path);
        player.prepare();
        player.start();
        currentPath = path;
        return true;
    }
}

// In your VoiceUserHolder:
btnPlayPause.setOnClickListener(v -> {
    boolean playing = VoicePlayerManager.get().toggle(localPath, listener);
    btnPlayPause.setImageResource(playing ? R.drawable.ic_pause : R.drawable.ic_play);
});