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.StreamCompletionAsync(Message, Func<string, Task>)

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

OpenAICompatibleService.ParseOpenAICompatibleUsage(JsonElement)

AIService.RunAgentAsync(string, int)

AIService.ApiKey

AIService.HttpClient

AIService._chatRequests

AIService.DefaultPolicy

AIService.CurrentPolicy

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.MaxMessageCount

AIService.GetEffectiveMaxTokens()

AIService.Functions

AIService.EnableFunctions

AIService.FunctionCallMode

AIService.ForceFunctionName

AIService.ShouldUseFunctions

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(string, Dictionary<string, object>)

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.StreamOnceAsync(string, CancellationToken)

AIService.StreamOnceAsync(Message, CancellationToken)

AIService.StreamCompletionAsync(string, Action<string>)

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

AIService.BeginStream(string)

AIService._structuredOutputSchemaJson

AIService.StructuredOutputMaxRetries

AIService.GetCompletionAsync<T>(string)

AIService.GetStructuredOutputInstruction()

AIService.ConversationPolicy

AIService.ApplySummaryPolicyIfNeededAsync()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

AIServiceExtensions.AskOnceAsync(AIService, Message)

AIServiceExtensions.AskOnceAsync(AIService, string)

AIServiceExtensions.AskOnceWithImageAsync(AIService, string, string)

AIServiceExtensions.BeginMessage(AIService)

AIServiceExtensions.GetCompletionWithContextAsync(AIService, string, int)

AIServiceExtensions.GetConversationSummary(AIService)

AIServiceExtensions.GetLastAssistantResponse(AIService)

AIServiceExtensions.RetryLastMessageAsync(AIService)

AIServiceExtensions.StartNewConversation(AIService)

AIServiceExtensions.StartNewConversation(AIService, string)

AIServiceExtensions.SwitchModel(AIService, string)

AIServiceExtensions.WithComplexPolicy(AIService)

AIServiceExtensions.WithFastPolicy(AIService)

AIServiceExtensions.WithMaxRounds(AIService, int)

AIServiceExtensions.WithMaxTokens(AIService, uint)

AIServiceExtensions.WithNoRetryStructuredOutput(AIService)

AIServiceExtensions.WithPolicy(AIService, FunctionCallingPolicy)

AIServiceExtensions.WithStatelessMode(AIService, bool)

AIServiceExtensions.WithStrictStructuredOutput(AIService)

AIServiceExtensions.WithStructuredOutputPolicy(AIService, StructuredOutputPolicy)

AIServiceExtensions.WithSystemMessage(AIService, string)

AIServiceExtensions.WithTemperature(AIService, float)

AIServiceExtensions.WithTimeout(AIService, int)

FunctionExtensions.AskWithoutFunctionsAsync(AIService, string)

FunctionExtensions.WithFunction(AIService, FunctionDefinition)

FunctionExtensions.WithFunction(AIService, string, string, Func<string>)

FunctionExtensions.WithFunctionAsync(AIService, string, string, Func<Task<string>>)

FunctionExtensions.WithFunctionAsync<T>(AIService, string, string, (string name, string description, bool required), Func<T, Task<string>>)

FunctionExtensions.WithFunctionAsync<T1, T2>(AIService, string, string, (string name, string description, bool required), (string name, string description, bool required), Func<T1, T2, Task<string>>)

FunctionExtensions.WithFunctionAsync<T1, T2, T3>(AIService, string, string, (string name, string description, bool required), (string name, string description, bool required), (string name, string description, bool required), Func<T1, T2, T3, Task<string>>)

FunctionExtensions.WithFunction<T>(AIService, string, string, (string name, string description, bool required), Func<T, string>)

FunctionExtensions.WithFunction<T1, T2>(AIService, string, string, (string name, string description, bool required), (string name, string description, bool required), Func<T1, T2, string>)

FunctionExtensions.WithFunction<T1, T2, T3>(AIService, string, string, (string name, string description, bool required), (string name, string description, bool required), (string name, string description, bool required), Func<T1, T2, T3, string>)

FunctionExtensions.WithFunctionsEnabled(AIService, bool)

FunctionExtensions.WithFunctions<T>(AIService, T)

FunctionExtensions.WithStaticFunctions<T>(AIService)

FunctionExtensions.WithoutFunctions(AIService, bool)

McpServiceExtensions.WithMcpServerAsync(AIService, IMcpTransport, Func<string, bool>?, string?, CancellationToken)

McpServiceExtensions.WithMcpServerAsync(AIService, string, string?, Func<string, bool>?, string?, string?, Dictionary<string, string>?, CancellationToken)

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

ExtractFunctionCall(string)

Extracts function call from API response

protected override (string content, FunctionCall functionCall) ExtractFunctionCall(string response)

Parameters

response string

Returns

(string content, FunctionCall functionCall)

ExtractResponseContent(string)

Extracts the response content from the API response

protected override string ExtractResponseContent(string responseContent)

Parameters

responseContent string

Returns

string

GenerateImageAsync(string, string)

Generates an image from a text prompt

public override Task<byte[]> GenerateImageAsync(string prompt, string size = "1024x1024")

Parameters

prompt string

size string

Returns

Task<byte[]>

GenerateImageUrlAsync(string, string)

Generates an image URL from a text prompt

public override Task<string> GenerateImageUrlAsync(string prompt, string size = "1024x1024")

Parameters

prompt string

size string

Returns

Task<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

WithQwenParameters(QwenThinking)

public QwenService WithQwenParameters(QwenThinking thinking = QwenThinking.On)

Parameters

thinking QwenThinking

Returns

QwenService