Class PerplexityService

Namespace

Mythosia.AI.Services.Perplexity

Assembly

Mythosia.AI.dll

public class PerplexityService : AIService, IAIService, IFunctionRegisterable

Inheritance

object

AIService

PerplexityService

Implements

IAIService

IFunctionRegisterable

Inherited Members

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

AIService.CopyFrom(AIService)

AIService.ApplyRequestProfile(AIRequestProfile)

AIService.ApplyProviderSpecificRequestProfile(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.CreateRoundUsageContent(int, bool, TokenUsage)

AIService.CopyTokenUsage(TokenUsage)

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

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()

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.WithSystemMessageProvider(AIService, Func<AIRequestContext?>)

AIServiceExtensions.WithSystemMessageProvider(AIService, Func<CancellationToken, ValueTask<AIRequestContext?>>)

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)

AIServiceExtensions.WithStreamDiagnostics<T>(T, Action<StreamDiagnosticsBuilder>)

Constructors

PerplexityService(string, HttpClient)

public PerplexityService(string apiKey, HttpClient httpClient)

Parameters

apiKey string

httpClient HttpClient

PerplexityService(string, string, HttpClient)

Creates a PerplexityService with a specific model.

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

Parameters

apiKey string

model string

httpClient HttpClient

Properties

Provider

The AI provider for this service

public override string Provider { get; }

Property Value

string

Methods

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

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>

GetCompletionWithImageAsync(string, string)

Perplexity doesn't support multimodal inputs

public override Task<string> GetCompletionWithImageAsync(string prompt, string imagePath)

Parameters

prompt string

imagePath string

Returns

Task<string>

GetCompletionWithSearchAsync(string, string[]?, string)

Gets a completion with web search and citations

public Task<PerplexityService.SonarSearchResponse> GetCompletionWithSearchAsync(string prompt, string[]? domainFilter = null, string recencyFilter = "month")

Parameters

prompt string

domainFilter string[]

recencyFilter string

Returns

Task<PerplexityService.SonarSearchResponse>

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

StreamCompletionAsync(Message, Func<string, Task>)

public override Task StreamCompletionAsync(Message message, Func<string, Task> messageReceivedAsync)

Parameters

message Message

messageReceivedAsync Func<string, Task>

Returns

Task

StreamCoreAsync(Message, StreamOptions, CancellationToken)

Replaces the base pipeline outright for the Sonar-specific implementation; Perplexity has no function calling and so needs no round loop.

Consequence: context-overflow recovery, which lives in that loop, does not run here. An overflow surfaces as an error chunk — flagged context_length_exceeded so the caller can still identify it — but the conversation is not compacted and nothing is re-sent.

protected override IAsyncEnumerable<StreamingContent> StreamCoreAsync(Message message, StreamOptions options, CancellationToken cancellationToken = default)

Parameters

message Message

options StreamOptions

cancellationToken CancellationToken

Returns

IAsyncEnumerable<StreamingContent>

StreamParseJson(string)

Parses streaming JSON data

protected override string StreamParseJson(string jsonData)

Parameters

jsonData string

Returns

string

UseSonarPro()

Switches to Sonar Pro model for enhanced capabilities

public PerplexityService UseSonarPro()

Returns

PerplexityService

UseSonarReasoning()

Switches to Sonar Reasoning Pro model for complex reasoning tasks. The legacy sonar-reasoning model was removed from the Perplexity API on 2025-12-15; sonar-reasoning-pro is its official replacement.

public PerplexityService UseSonarReasoning()

Returns

PerplexityService

WithSearchParameters(bool, string, params string[])

Configures search parameters for the service

public PerplexityService WithSearchParameters(bool returnCitations = true, string recencyFilter = "month", params string[] domainFilter)

Parameters

returnCitations bool

recencyFilter string

domainFilter string[]

Returns

PerplexityService