using GenerativeAI;
using GenerativeAI.Live;
using GenerativeAI.Types;

var config = new GenerationConfig
{
    ResponseModalities = new List<Modality> { Modality.AUDIO }
};

using var client = new MultiModalLiveClient(
    new GoogleAIPlatformAdapter(apiKey),
    GoogleAIModels.Gemini38Live,
    config,
    systemInstruction: "You are a helpful assistant.")
{
    OutputAudioTranscriptionEnabled = true,   // text transcript of the model's audio
    InputAudioTranscriptionEnabled = true     // text transcript of your audio
};

client.Connected += (_, _) => Console.WriteLine("Connected");
client.Disconnected += (_, e) =>
{
    // When the server closes the session with a reason, e is GenerativeAI.Live.Events.ErrorMessageEventArgs.
    if (e is GenerativeAI.Live.Events.ErrorMessageEventArgs closed)
        Console.WriteLine($"Closed by server: {closed.ErrorMessage}");
};
client.ErrorOccurred += (_, e) => Console.WriteLine($"Error: {e.GetException().Message}");

client.AudioChunkReceived += (_, e) => Play(e.Buffer, e.HeaderInfo.SampleRate);   // raw PCM chunk
client.AudioReceiveCompleted += (_, e) => Console.WriteLine($"Turn audio: {e.Buffer.Length} bytes");
client.TextChunkReceived += (_, e) => Console.Write(e.Text);                       // e.IsTurnFinish at the end
client.OutputTranscriptionReceived += (_, t) => Console.Write(t.Text);
client.InputTranscriptionReceived += (_, t) => Console.WriteLine($"You said: {t.Text}");
client.TurnCompleted += (_, _) => Console.WriteLine("\n[turn complete]");
client.GenerationInterrupted += (_, _) => StopPlayback();                           // the user barged in
client.MessageReceived += (_, e) => { /* raw LiveServerMessage in e.Payload */ };
client.GoAwayReceived += (_, goAway) => Console.WriteLine($"Server closing soon, time left: {goAway.TimeLeft}");
client.SessionResumableUpdateReceived += (_, update) => { /* update.NewHandle, update.Resumable */ };

await client.ConnectAsync();

// A complete user turn (client content).
await client.SentTextAsync("Hi! What's the weather like on Mars?");

// Realtime text: processed like streamed audio, and can interrupt the model.
await client.SendRealtimeTextAsync("Actually, tell me about Venus instead.");

// Realtime audio: 16-bit PCM, 16 kHz mono by default ("audio/pcm;rate=16000").
await client.SendAudioAsync(pcmChunk);
await client.SendAudioStreamEndAsync();   // microphone turned off (Gemini API only)

// Video frames (camera or screen capture), JPEG by default.
await client.SendVideoFrameAsync(jpegBytes);

await client.DisconnectAsync();

client.RealtimeInputConfig = new RealtimeInputConfig
{
    AutomaticActivityDetection = new AutomaticActivityDetection { Disabled = true }
};
await client.ConnectAsync();

await client.SendActivityStartAsync();
await client.SendAudioAsync(pcmChunk);      // one or more audio chunks
await client.SendActivityEndAsync();

client.SessionResumption = new SessionResumptionConfig();
await client.ConnectAsync();
// ... later, before the session ends:
string? handle = client.LastSessionResumptionHandle;

// New client, same conversation:
using var resumed = new MultiModalLiveClient(new GoogleAIPlatformAdapter(apiKey), GoogleAIModels.Gemini38Live, config)
{
    SessionResumption = new SessionResumptionConfig { Handle = handle }
};
await resumed.ConnectAsync();

client.ContextWindowCompression = new ContextWindowCompressionConfig
{
    TriggerTokens = 100_000,
    SlidingWindow = new SlidingWindow { TargetTokens = 50_000 }
};

await client.SendContextUpdateAsync("You are a pirate. Answer in one word.");
// Pass tools as the second argument; an empty collection removes all tools, null keeps the current ones.

using GenerativeAI.Clients;

// Server side
var tokens = new AuthTokensClient(new GoogleAIPlatformAdapter(apiKey));
AuthToken token = await tokens.CreateAsync(new CreateAuthTokenConfig
{
    Uses = 1,
    ExpireTime = DateTime.UtcNow.AddMinutes(10),
    NewSessionExpireTime = DateTime.UtcNow.AddMinutes(2),
    LiveConnectConstraints = new LiveClientSetup
    {
        Model = GoogleAIModels.Gemini38Live,
        GenerationConfig = config
    }
});

// Client side: token.Name ("auth_tokens/...") replaces the API key.
using var live = new MultiModalLiveClient(new GoogleAIPlatformAdapter(token.Name), GoogleAIModels.Gemini38Live, config);
await live.ConnectAsync();

using var music = new LiveMusicClient(new GoogleAIPlatformAdapter(apiKey), GoogleAIModels.Music.LyriaRealtimeExp);

music.AudioChunkReceived += (_, e) => Play(e.Data, e.SampleRate, e.Channels);
music.FilteredPromptReceived += (_, e) => Console.WriteLine($"Prompt filtered: {e.Text} ({e.FilteredReason})");
music.ErrorOccurred += (_, e) => Console.WriteLine(e.GetException().Message);

await music.ConnectAsync();   // waits for setupComplete (TimeoutException after SetupTimeout, default 30 s)
await music.SetWeightedPromptsAsync(new[] { new WeightedPrompt { Text = "calm piano", Weight = 1.0 } });
await music.SetMusicGenerationConfigAsync(new LiveMusicGenerationConfig { Bpm = 90 });
await music.PlayAsync();

// Steer while playing, then stop.
await music.SetWeightedPromptsAsync("upbeat jazz");
await music.PauseAsync();
await music.StopAsync();
await music.DisconnectAsync();