Class QwenService

Namespace

Mythosia.AI.Providers.Alibaba

Assembly

Mythosia.AI.Providers.Alibaba.dll

public class QwenService : OpenAICompatibleService, IAIService, IFunctionRegisterable

Inheritance

object

AIService

OpenAICompatibleService

QwenService

Implements

IAIService

IFunctionRegisterable

Inherited Members

OpenAICompatibleService.StreamItemIdMetadataKey

OpenAICompatibleService.StreamIndexExplicitMetadataKey

OpenAICompatibleService.RequiresProviderCallIdMetadataKey

OpenAICompatibleService.StreamCompletionAsync(Message, Func<string, Task>)

OpenAICompatibleService.StreamRoundAsync(StreamOptions, bool, FunctionCallingPolicy, CancellationToken)

OpenAICompatibleService.OnStreamRoundFailed()

OpenAICompatibleService.OnStreamRoundStarting()

OpenAICompatibleService.EnrichStreamAssistantMessage(Message)

OpenAICompatibleService.ParseOpenAICompatibleUsage(JsonElement)

AIService.ApiKey

AIService.HttpClient

AIService._chatRequests

AIService._structuredOutputSchemaJson

AIService.RunAgentAsync(string, int, AIRequestContext)

AIService.RunAgentStreamAsync(string, int, StreamOptions, AIRequestContext, CancellationToken)

AIService.GetEffectiveMaxTokens()

AIService.ResolveRequestTimeoutSeconds(FunctionCallingPolicy)

AIService.CreateRequestTimeoutCts(FunctionCallingPolicy, CancellationToken)

AIService.AddNewChat(ChatBlock)

AIService.AddNewChat()

AIService.SetActivateChat(string)

AIService.ChangeModel(string)

AIService.GetLatestMessages()

AIService.EnsureUserFirstMessage(List<Message>)

AIService.GetLatestMessagesWithFunctionFallback()

AIService.GetCompletionAsync(string, AIRequestProfile, AIRequestContext)

AIService.GetCompletionAsync(Message, AIRequestProfile, AIRequestContext)

AIService.GetCompletionWithImageAsync(string, string)

AIService.GetCompletionWithImageUrlAsync(string, string)

AIService.CopyFrom(AIService)

AIService.ApplyRequestProfile(AIRequestProfile)

AIService.ApplyRequestContext(AIRequestContext)

AIService.GetEffectiveSystemMessageWithRequestContext()

AIService.ProcessFunctionCallAsync(FunctionCall)

AIService.ProcessFunctionCallsAsync(FunctionCallBatch, FunctionCallingPolicy, CancellationToken)

AIService.ProcessFunctionCallsSequentiallyAsync(FunctionCallBatch, FunctionCallingPolicy, CancellationToken)

AIService.ProcessFunctionCallsInParallelAsync(FunctionCallBatch, FunctionCallingPolicy, CancellationToken)

AIService.AddFunctionCallBatchToHistory(string, FunctionCallBatch, Dictionary<string, object>)

AIService.AddFunctionResultBatchToHistory(FunctionCallResultBatch, Dictionary<string, object>)

AIService.ReadSseLinesAsync(HttpResponseMessage, StreamDiagnostics, CancellationToken)

AIService.QuickAskAsync(string, string, string)

AIService.QuickAskWithImageAsync(string, string, string, string)

AIService.StreamAsync(string, CancellationToken)

AIService.StreamAsync(Message, AIRequestContext, CancellationToken)

AIService.StreamAsync(string, StreamOptions, CancellationToken)

AIService.StreamAsync(Message, StreamOptions, AIRequestContext, CancellationToken)

AIService.StreamCoreAsync(Message, StreamOptions, CancellationToken)

AIService.CreateRoundUsageContent(int, bool, TokenUsage)

AIService.CopyTokenUsage(TokenUsage)

AIService.StreamOnceAsync(string, CancellationToken)

AIService.StreamOnceAsync(Message, CancellationToken)

AIService.StreamCompletionAsync(string, Action<string>)

AIService.StreamCompletionAsync(string, Func<string, Task>)

AIService.BeginStream(string)

AIService.GetCompletionAsync<T>(string)

AIService.GetStructuredOutputInstruction()

AIService.ApplySummaryPolicyIfNeededAsync()

AIService.DefaultPolicy

AIService.CurrentPolicy

AIService.SystemMessageProvider

AIService.ChatRequests

AIService.ActivateChat

AIService.StatelessMode

AIService.FunctionsDisabled

AIService.Model

AIService.SystemMessage

AIService.TopP

AIService.Temperature

AIService.FrequencyPenalty

AIService.PresencePenalty

AIService.MaxTokens

AIService.Stream

AIService.ContextRecoveryMaxRetries

AIService.Functions

AIService.EnableFunctions

AIService.FunctionCallMode

AIService.ForceFunctionName

AIService.ShouldUseFunctions

AIService.StructuredOutputMaxRetries

AIService.ConversationPolicy

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

QwenService(string, EndpointPlatform, HttpClient)

public QwenService(string baseUrl, EndpointPlatform platform, HttpClient httpClient)

Parameters

baseUrl string

platform EndpointPlatform

httpClient HttpClient

QwenService(string, EndpointPlatform, string, HttpClient)

public QwenService(string baseUrl, EndpointPlatform platform, string model, HttpClient httpClient)

Parameters

baseUrl string

platform EndpointPlatform

model string

httpClient HttpClient

QwenService(string, HttpClient)

public QwenService(string apiKey, HttpClient httpClient)

Parameters

apiKey string

httpClient HttpClient

QwenService(string, string, HttpClient)

public QwenService(string apiKey, string model, HttpClient httpClient)

Parameters

apiKey string

model string

httpClient HttpClient

Properties

ModelIdOverride

public string? ModelIdOverride { get; set; }

Property Value

string

Provider

The AI provider for this service

public override string Provider { get; }

Property Value

string

ThinkingMode

public QwenThinking ThinkingMode { get; set; }

Property Value

QwenThinking

Methods

ApplyProviderSpecificRequestProfile(AIRequestProfile)

protected override Action ApplyProviderSpecificRequestProfile(AIRequestProfile profile)

Parameters

profile AIRequestProfile

Returns

Action

CreateFunctionMessageRequest()

Creates HTTP request with function definitions

protected override HttpRequestMessage CreateFunctionMessageRequest()

Returns

HttpRequestMessage

CreateMessageRequest()

Creates the HTTP request message for the AI service

protected override HttpRequestMessage CreateMessageRequest()

Returns

HttpRequestMessage

CreateStreamParseFailure(string, Exception, StreamDiagnostics)

Lets providers turn a malformed SSE data event into an explicit terminal error. Returning null preserves the tolerant behavior used by legacy compatible providers.

protected override StreamingContent? CreateStreamParseFailure(string jsonData, Exception exception, StreamDiagnostics diagnostics)

Parameters

jsonData string

exception Exception

diagnostics StreamDiagnostics

Returns

StreamingContent

ExtractFunctionCalls(string)

Extracts every function call from one API response.

protected override (string content, FunctionCallBatch functionCalls) ExtractFunctionCalls(string response)

Parameters

response string

Returns

(string content, FunctionCallBatch functionCalls)

ExtractResponseContent(string)

Extracts the response content from the API response

protected override string ExtractResponseContent(string responseContent)

Parameters

responseContent string

Returns

string

GetCompletionAsync(Message)

public override Task<string> GetCompletionAsync(Message message)

Parameters

message Message

Returns

Task<string>

GetInputTokenCountAsync()

Gets the token count for the current conversation

public override Task<uint> GetInputTokenCountAsync()

Returns

Task<uint>

GetInputTokenCountAsync(string)

Gets the token count for a specific prompt

public override Task<uint> GetInputTokenCountAsync(string prompt)

Parameters

prompt string

Returns

Task<uint>

GetModelMaxOutputTokens()

Returns the maximum output tokens allowed for the current model. Override in each service to provide model-specific limits.

protected override uint GetModelMaxOutputTokens()

Returns

uint

ParseStreamChunk(string, StreamOptions)

Parses a single SSE JSON chunk into a provider-neutral stream chunk. Each provider overrides this to handle its specific JSON format.

protected override OpenAICompatibleService.OpenAIStreamChunk ParseStreamChunk(string jsonData, StreamOptions options)

Parameters

jsonData string

options StreamOptions

Returns

OpenAICompatibleService.OpenAIStreamChunk

StreamParseJson(string)

Parses streaming JSON data

protected override string StreamParseJson(string jsonData)

Parameters

jsonData string

Returns

string

UseMaxModel()

public QwenService UseMaxModel()

Returns

QwenService

UsePlusModel()

public QwenService UsePlusModel()

Returns

QwenService

UseQwen3_235BModel()

public QwenService UseQwen3_235BModel()

Returns

QwenService

UseQwen3_32BModel()

public QwenService UseQwen3_32BModel()

Returns

QwenService

UseTurboModel()

public QwenService UseTurboModel()

Returns

QwenService

ValidateStreamTermination(bool, bool, StreamDiagnostics)

Lets providers require an explicit successful terminal event before committing a streamed assistant message or executing a collected function call.

protected override StreamingContent? ValidateStreamTermination(bool doneMarkerReceived, bool completionEventReceived, StreamDiagnostics diagnostics)

Parameters

doneMarkerReceived bool

completionEventReceived bool

diagnostics StreamDiagnostics

Returns

StreamingContent

WithQwenParameters(QwenThinking)

public QwenService WithQwenParameters(QwenThinking thinking = QwenThinking.On)

Parameters

thinking QwenThinking

Returns

QwenService