Обработка прерываний голосовой связи в журнале чата (предварительная версия)

from azure.ai.voicelive.models import (
    RequestSession,
    AzureSemanticVad,
)

# Configure session with auto truncation enabled
session_config = RequestSession(
    instructions="You are a helpful assistant.",
    turn_detection=AzureSemanticVad(
        interrupt_response=True,
        auto_truncate=True
    )
)

await conn.session.update(session=session_config)

using Azure.AI.VoiceLive;

// Configure session with auto truncation enabled
var sessionOptions = new VoiceLiveSessionOptions
{
    Instructions = "You are a helpful assistant.",
    TurnDetection = new AzureSemanticVadTurnDetection
    {
        InterruptResponse = true,
        AutoTruncate = true
    }
};

// Update session configuration
var sessionUpdatePayload = new
{
    type = "session.update",
    session = new
    {
        instructions = sessionOptions.Instructions,
        turn_detection = new
        {
            type = "azure_semantic_vad",
            interrupt_response = true,
            auto_truncate = true
        }
    }
};
BinaryData eventData = BinaryData.FromObjectAsJson(sessionUpdatePayload);
await session.SendCommandAsync(eventData, cancellationToken).ConfigureAwait(false);

import com.azure.ai.voicelive.models.*;

// Configure session with auto truncation enabled
AzureSemanticVadTurnDetection turnDetection = new AzureSemanticVadTurnDetection()
    .setInterruptResponse(true)
    .setAutoTruncate(true);

VoiceLiveSessionOptions sessionOptions = new VoiceLiveSessionOptions()
    .setInstructions("You are a helpful assistant.")
    .setTurnDetection(turnDetection);

// Send session update
session.sendEvent(new ClientEventSessionUpdate(sessionOptions)).subscribe();

// Configure session with auto truncation enabled
await session.sendEvent({
    type: "session.update",
    session: {
        instructions: "You are a helpful assistant.",
        turn_detection: {
            type: "azure_semantic_vad",
            interrupt_response: true,
            auto_truncate: true
        }
    }
});

# Send session update with appended_text_after_truncation via raw dict
# Note: conn.send() accepts a dict - the SDK handles JSON serialization internally
session_update = {
    "type": "session.update",
    "session": {
        "instructions": "You are a helpful assistant.",
        "turn_detection": {
            "type": "azure_semantic_vad",
            "interrupt_response": True,
            "auto_truncate": True,
            "appended_text_after_truncation": " [The user interrupted me.]"
        }
    }
}
await conn.send(session_update)

// Send session update with appended_text_after_truncation via JSON
var sessionUpdatePayload = new
{
    type = "session.update",
    session = new
    {
        instructions = "You are a helpful assistant.",
        turn_detection = new
        {
            type = "azure_semantic_vad",
            interrupt_response = true,
            auto_truncate = true,
            appended_text_after_truncation = " [The user interrupted me.]"
        }
    }
};
BinaryData eventData = BinaryData.FromObjectAsJson(sessionUpdatePayload);
await session.SendCommandAsync(eventData, cancellationToken).ConfigureAwait(false);

import com.azure.core.util.BinaryData;

// Send session update with appended_text_after_truncation via raw JSON
// Note: appended_text_after_truncation is not available in typed SDK classes
String sessionUpdate = """
    {
        "type": "session.update",
        "session": {
            "instructions": "You are a helpful assistant.",
            "turn_detection": {
                "type": "azure_semantic_vad",
                "interrupt_response": true,
                "auto_truncate": true,
                "appended_text_after_truncation": " [The user interrupted me.]"
            }
        }
    }
    """;
session.send(BinaryData.fromString(sessionUpdate)).subscribe();

// Send session update with appended_text_after_truncation via JSON
await session.sendEvent({
    type: "session.update",
    session: {
        instructions: "You are a helpful assistant.",
        turn_detection: {
            type: "azure_semantic_vad",
            interrupt_response: true,
            auto_truncate: true,
            appended_text_after_truncation: " [The user interrupted me.]"
        }
    }
});

async def _handle_event(self, event):
    if event.type == ServerEventType.CONVERSATION_ITEM_TRUNCATED:
        print(f"Response was truncated. Item ID: {event.item_id}")
        print(f"Truncated at index: {event.content_index}")
        # Log or handle the truncation as needed

private async Task HandleSessionUpdateAsync(SessionUpdate serverEvent, CancellationToken cancellationToken)
{
    if (serverEvent is SessionUpdateConversationItemTruncated truncatedEvent)
    {
        Console.WriteLine($"Response was truncated. Item ID: {truncatedEvent.ItemId}");
        Console.WriteLine($"Truncated at index: {truncatedEvent.ContentIndex}");
        // Log or handle the truncation as needed
    }
}

private void handleServerEvent(SessionUpdate event) {
    if (event.getType() == ServerEventType.CONVERSATION_ITEM_TRUNCATED) {
        SessionUpdateConversationItemTruncated truncatedEvent = 
            (SessionUpdateConversationItemTruncated) event;
        System.out.println("Response was truncated. Item ID: " + truncatedEvent.getItemId());
        System.out.println("Truncated at index: " + truncatedEvent.getContentIndex());
        // Log or handle the truncation as needed
    }
}

const subscription = session.subscribe({
    onConversationItemTruncated: async (event, context) => {
        console.log(`Response was truncated. Item ID: ${event.itemId}`);
        console.log(`Truncated at index: ${event.contentIndex}`);
        // Log or handle the truncation as needed
    }
});