AI 字幕

import AtomicXCore

// 按房间 ID 创建实例（同一房间多次调用返回同一实例）
let transcriberStore = AITranscriberStore.create(roomID: "your_room_id")

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

// 按房间 ID 创建实例（同一房间多次调用返回同一实例）
final transcriberStore = AITranscriberStore.create("your_room_id");

// 订阅字幕整体状态
transcriberStore.state.subscribe { state in
    for message in state.realtimeMessageList {
        print("Speaker: \\(message.speakerUserName)")
        print("Source text: \\(message.sourceText)")
        for (lang, text) in message.translationTexts {
            print("Translation[\\(lang)]: \\(text)")
        }
    }
    print("Transcription running: \\(state.isTranscriptionRunning)")
}

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

// 订阅实时字幕消息列表
transcriberStore.transcriberState.realtimeMessageList.addListener(() {
    final messages = transcriberStore.transcriberState.realtimeMessageList.value;
    for (final message in messages) {
        print("Speaker: ${message.speakerUserName}");
        print("Source text: ${message.sourceText}");
        message.translationTexts.forEach((lang, text) {
            print("Translation[$lang]: $text");
        });
    }
});

// 订阅转写运行状态
transcriberStore.transcriberState.isTranscriptionRunning.addListener(() {
    final running = transcriberStore.transcriberState.isTranscriptionRunning.value;
    print("Transcription running: $running");
});

import AtomicXCore

// 1. 配置转写参数：开启翻译
let config = TranscriptionConfig(enableTranslation: true)

// 2. 开启转写，指定源语言为中英混合
transcriberStore.startTranscription(myLanguage: .chineseEnglish, config: config) { error in
    if let error = error {
        print("Start transcription failed: \\(error)")
    } else {
        print("Start transcription success")
    }
}

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

// 1. 配置转写参数：开启翻译
final config = TranscriptionConfig(enableTranslation: true);

// 2. 开启转写，指定源语言为中英混合
final result = await transcriberStore.startTranscription(
    SourceLanguage.chineseEnglish,
    config: config,
);

if (!result.isSuccess) {
    print("Start transcription failed: ${result.errorMessage}");
} else {
    print("Start transcription success");
}

import AtomicXCore

// 运行中切换源语言为英语，并关闭翻译
var newConfig = TranscriptionConfig(enableTranslation: false)
transcriberStore.updateTranscription(myLanguage: .english, config: newConfig) { error in
    if let error = error {
        print("Update transcription failed: \\(error)")
    }
}

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

// 运行中切换源语言为英语，并关闭翻译
final newConfig = TranscriptionConfig(enableTranslation: false);
final result = await transcriberStore.updateTranscription(
    SourceLanguage.english,
    config: newConfig,
);

if (!result.isSuccess) {
    print("Update transcription failed: ${result.errorMessage}");
}

import AtomicXCore

transcriberStore.stopTranscription { error in
    if let error = error {
        print("Stop transcription failed: \\(error)")
    } else {
        print("Stop transcription success")
    }
}

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

final result = await transcriberStore.stopTranscription();

if (!result.isSuccess) {
    print("Stop transcription failed: ${result.errorMessage}");
} else {
    print("Stop transcription success");
}

import AtomicXCore

func setupAITranscriber(roomID: String) {
    // 1. 创建实例
    let store = AITranscriberStore.create(roomID: roomID)

    // 2. 订阅字幕状态
    store.state.subscribe { state in
        for msg in state.realtimeMessageList {
            print("[\\(msg.speakerUserName)] \\(msg.sourceText)")
        }
    }

    // 3. 开启字幕（含翻译）
    let transConfig = TranscriptionConfig(enableTranslation: true)
    store.startTranscription(myLanguage: .chineseEnglish, config: transConfig) { error in
        if let error = error {
            print("start failed: \\(error)")
        }
    }
}

import 'package:atomic_x_core/api/ai/ai_transcriber_store.dart';

Future<void> setupAITranscriber(String roomID) async {
    // 1. 创建实例
    final store = AITranscriberStore.create(roomID);

    // 2. 订阅字幕消息
    store.transcriberState.realtimeMessageList.addListener(() {
        final messages = store.transcriberState.realtimeMessageList.value;
        for (final msg in messages) {
            print("[${msg.speakerUserName}] ${msg.sourceText}");
        }
    });

    // 3. 开启字幕（含翻译）
    final transConfig = TranscriptionConfig(enableTranslation: true);
    final transResult = await store.startTranscription(
        SourceLanguage.chineseEnglish,
        config: transConfig,
    );
    if (!transResult.isSuccess) {
        print("start failed: ${transResult.errorMessage}");
    }
}