openai/openai-dotnet

Public

mirrored from https://github.com/openai/openai-dotnetAvailable

CodeCommitsIssuesPull requestsActionsInsightsSecurity
OpenAI_2.1.0-beta.1

Branches

Tags

  • No tags available.
0Branches0Tags
Go to file
Add file
Code

Clone

HTTPS

Download ZIP

src/Generated/InternalAssistantMessageClient.cs

152lines · modeblame

9f9f2936Jose Arriaga Maldonado2 years ago1// <auto-generated/>
2
3#nullable disable
4
5using System;
6using System.ClientModel;
7using System.ClientModel.Primitives;
8using System.Threading.Tasks;
9
10namespace OpenAI.Assistants
11{
12// Data plane generated sub-client.
13internal partial class InternalAssistantMessageClient
14{
15private const string AuthorizationHeader = "Authorization";
16private readonly ApiKeyCredential _keyCredential;
17private const string AuthorizationApiKeyPrefix = "Bearer";
18private readonly ClientPipeline _pipeline;
19private readonly Uri _endpoint;
20
21protected InternalAssistantMessageClient()
22{
23}
24
19fc7d54Jose Arriaga Maldonado2 years ago25public virtual async Task<ClientResult> GetMessagesAsync(string threadId, int? limit, string order, string after, string before, RequestOptions options)
26{
27Argument.AssertNotNullOrEmpty(threadId, nameof(threadId));
28
29using PipelineMessage message = CreateGetMessagesRequest(threadId, limit, order, after, before, options);
30return ClientResult.FromResponse(await _pipeline.ProcessMessageAsync(message, options).ConfigureAwait(false));
31}
32
33public virtual ClientResult GetMessages(string threadId, int? limit, string order, string after, string before, RequestOptions options)
34{
35Argument.AssertNotNullOrEmpty(threadId, nameof(threadId));
36
37using PipelineMessage message = CreateGetMessagesRequest(threadId, limit, order, after, before, options);
38return ClientResult.FromResponse(_pipeline.ProcessMessage(message, options));
39}
40
9f9f2936Jose Arriaga Maldonado2 years ago41internal PipelineMessage CreateCreateMessageRequest(string threadId, BinaryContent content, RequestOptions options)
42{
43var message = _pipeline.CreateMessage();
44message.ResponseClassifier = PipelineMessageClassifier200;
45var request = message.Request;
46request.Method = "POST";
47var uri = new ClientUriBuilder();
48uri.Reset(_endpoint);
583e9f6fJose Arriaga Maldonado1 years ago49uri.AppendPath("/threads/", false);
9f9f2936Jose Arriaga Maldonado2 years ago50uri.AppendPath(threadId, true);
51uri.AppendPath("/messages", false);
52request.Uri = uri.ToUri();
53request.Headers.Set("Accept", "application/json");
54request.Headers.Set("Content-Type", "application/json");
55request.Content = content;
56message.Apply(options);
57return message;
58}
59
60internal PipelineMessage CreateGetMessagesRequest(string threadId, int? limit, string order, string after, string before, RequestOptions options)
61{
62var message = _pipeline.CreateMessage();
63message.ResponseClassifier = PipelineMessageClassifier200;
64var request = message.Request;
65request.Method = "GET";
66var uri = new ClientUriBuilder();
67uri.Reset(_endpoint);
583e9f6fJose Arriaga Maldonado1 years ago68uri.AppendPath("/threads/", false);
9f9f2936Jose Arriaga Maldonado2 years ago69uri.AppendPath(threadId, true);
70uri.AppendPath("/messages", false);
71if (limit != null)
72{
73uri.AppendQuery("limit", limit.Value, true);
74}
75if (order != null)
76{
77uri.AppendQuery("order", order, true);
78}
79if (after != null)
80{
81uri.AppendQuery("after", after, true);
82}
83if (before != null)
84{
85uri.AppendQuery("before", before, true);
86}
87request.Uri = uri.ToUri();
88request.Headers.Set("Accept", "application/json");
89message.Apply(options);
90return message;
91}
92
93internal PipelineMessage CreateGetMessageRequest(string threadId, string messageId, RequestOptions options)
94{
95var message = _pipeline.CreateMessage();
96message.ResponseClassifier = PipelineMessageClassifier200;
97var request = message.Request;
98request.Method = "GET";
99var uri = new ClientUriBuilder();
100uri.Reset(_endpoint);
583e9f6fJose Arriaga Maldonado1 years ago101uri.AppendPath("/threads/", false);
9f9f2936Jose Arriaga Maldonado2 years ago102uri.AppendPath(threadId, true);
103uri.AppendPath("/messages/", false);
104uri.AppendPath(messageId, true);
105request.Uri = uri.ToUri();
106request.Headers.Set("Accept", "application/json");
107message.Apply(options);
108return message;
109}
110
111internal PipelineMessage CreateModifyMessageRequest(string threadId, string messageId, BinaryContent content, RequestOptions options)
112{
113var message = _pipeline.CreateMessage();
114message.ResponseClassifier = PipelineMessageClassifier200;
115var request = message.Request;
116request.Method = "POST";
117var uri = new ClientUriBuilder();
118uri.Reset(_endpoint);
583e9f6fJose Arriaga Maldonado1 years ago119uri.AppendPath("/threads/", false);
9f9f2936Jose Arriaga Maldonado2 years ago120uri.AppendPath(threadId, true);
121uri.AppendPath("/messages/", false);
122uri.AppendPath(messageId, true);
123request.Uri = uri.ToUri();
124request.Headers.Set("Accept", "application/json");
125request.Headers.Set("Content-Type", "application/json");
126request.Content = content;
127message.Apply(options);
128return message;
129}
130
131internal PipelineMessage CreateDeleteMessageRequest(string threadId, string messageId, RequestOptions options)
132{
133var message = _pipeline.CreateMessage();
134message.ResponseClassifier = PipelineMessageClassifier200;
135var request = message.Request;
136request.Method = "DELETE";
137var uri = new ClientUriBuilder();
138uri.Reset(_endpoint);
583e9f6fJose Arriaga Maldonado1 years ago139uri.AppendPath("/threads/", false);
9f9f2936Jose Arriaga Maldonado2 years ago140uri.AppendPath(threadId, true);
141uri.AppendPath("/messages/", false);
142uri.AppendPath(messageId, true);
143request.Uri = uri.ToUri();
144request.Headers.Set("Accept", "application/json");
145message.Apply(options);
146return message;
147}
148
149private static PipelineMessageClassifier _pipelineMessageClassifier200;
150private static PipelineMessageClassifier PipelineMessageClassifier200 => _pipelineMessageClassifier200 ??= PipelineMessageClassifier.Create(stackalloc ushort[] { 200 });
151}
152}