openai/openai-dotnet

Public

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

CodeCommitsIssuesPull requestsActionsInsightsSecurity
OpenAI_2.0.0-beta.12

Branches

Tags

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

Clone

HTTPS

Download ZIP

src/Custom/Chat/Internal/InternalChatCompletionStreamResponseDelta.Serialization.cs

143lines · modecode

1using System;
2using System.ClientModel.Primitives;
3using System.Collections.Generic;
4using System.Runtime.CompilerServices;
5using System.Text.Json;
6
7namespace OpenAI.Chat;
8
9[CodeGenSuppress("global::System.ClientModel.Primitives.IJsonModel<OpenAI.Chat.InternalChatCompletionStreamResponseDelta>.Write", typeof(Utf8JsonWriter), typeof(ModelReaderWriterOptions))]
10internal partial class InternalChatCompletionStreamResponseDelta : IJsonModel<InternalChatCompletionStreamResponseDelta>
11{
12 [MethodImpl(MethodImplOptions.AggressiveInlining)]
13 private void SerializeContentValue(Utf8JsonWriter writer, ModelReaderWriterOptions options)
14 {
15 throw new NotImplementedException();
16 }
17
18 [MethodImpl(MethodImplOptions.AggressiveInlining)]
19 private static void DeserializeContentValue(JsonProperty property, ref IReadOnlyList<ChatMessageContentPart> content, ModelReaderWriterOptions options = null)
20 {
21 throw new NotImplementedException();
22 }
23
24 void IJsonModel<InternalChatCompletionStreamResponseDelta>.Write(Utf8JsonWriter writer, ModelReaderWriterOptions options)
25 => CustomSerializationHelpers.SerializeInstance(this, SerializeInternalChatCompletionStreamResponseDelta, writer, options);
26
27 internal static void SerializeInternalChatCompletionStreamResponseDelta(InternalChatCompletionStreamResponseDelta instance, Utf8JsonWriter writer, ModelReaderWriterOptions options)
28 {
29 writer.WriteStartObject();
30 if (Optional.IsCollectionDefined(instance.Content))
31 {
32 if (instance.Content[0] != null)
33 {
34 writer.WritePropertyName("content"u8);
35 writer.WriteStringValue(instance.Content[0].Text);
36 }
37 else
38 {
39 writer.WriteNull("content");
40 }
41 }
42 if (Optional.IsDefined(instance.FunctionCall))
43 {
44 writer.WritePropertyName("function_call"u8);
45 writer.WriteObjectValue(instance.FunctionCall, options);
46 }
47 if (Optional.IsCollectionDefined(instance.ToolCalls))
48 {
49 writer.WritePropertyName("tool_calls"u8);
50 writer.WriteStartArray();
51 foreach (var item in instance.ToolCalls)
52 {
53 writer.WriteObjectValue(item, options);
54 }
55 writer.WriteEndArray();
56 }
57 if (Optional.IsDefined(instance.Role))
58 {
59 writer.WritePropertyName("role"u8);
60 writer.WriteStringValue(instance.Role.Value.ToSerialString());
61 }
62 writer.WriteSerializedAdditionalRawData(instance.SerializedAdditionalRawData, options);
63 writer.WriteEndObject();
64 }
65
66 internal static InternalChatCompletionStreamResponseDelta DeserializeInternalChatCompletionStreamResponseDelta(JsonElement element, ModelReaderWriterOptions options = null)
67 {
68 options ??= ModelSerializationExtensions.WireOptions;
69
70 if (element.ValueKind == JsonValueKind.Null)
71 {
72 return null;
73 }
74 IReadOnlyList<ChatMessageContentPart> content = default;
75 StreamingChatFunctionCallUpdate functionCall = default;
76 IReadOnlyList<StreamingChatToolCallUpdate> toolCalls = default;
77 ChatMessageRole? role = default;
78 string refusal = default;
79 IDictionary<string, BinaryData> serializedAdditionalRawData = default;
80 Dictionary<string, BinaryData> rawDataDictionary = new Dictionary<string, BinaryData>();
81 foreach (var property in element.EnumerateObject())
82 {
83 if (property.NameEquals("content"u8))
84 {
85 if (property.Value.ValueKind == JsonValueKind.Null)
86 {
87 continue;
88 }
89 List<ChatMessageContentPart> array = new List<ChatMessageContentPart>();
90 array.Add(ChatMessageContentPart.CreateTextPart(property.Value.GetString()));
91 content = array;
92 continue;
93 }
94 if (property.NameEquals("function_call"u8))
95 {
96 if (property.Value.ValueKind == JsonValueKind.Null)
97 {
98 continue;
99 }
100 functionCall = StreamingChatFunctionCallUpdate.DeserializeStreamingChatFunctionCallUpdate(property.Value, options);
101 continue;
102 }
103 if (property.NameEquals("tool_calls"u8))
104 {
105 if (property.Value.ValueKind == JsonValueKind.Null)
106 {
107 continue;
108 }
109 List<StreamingChatToolCallUpdate> array = new List<StreamingChatToolCallUpdate>();
110 foreach (var item in property.Value.EnumerateArray())
111 {
112 array.Add(StreamingChatToolCallUpdate.DeserializeStreamingChatToolCallUpdate(item, options));
113 }
114 toolCalls = array;
115 continue;
116 }
117 if (property.NameEquals("role"u8))
118 {
119 if (property.Value.ValueKind == JsonValueKind.Null)
120 {
121 continue;
122 }
123 role = property.Value.GetString().ToChatMessageRole();
124 continue;
125 }
126 if (property.NameEquals("refusal"u8))
127 {
128 if (property.Value.ValueKind == JsonValueKind.Null)
129 {
130 continue;
131 }
132 refusal = property.Value.GetString();
133 continue;
134 }
135 if (true)
136 {
137 rawDataDictionary.Add(property.Name, BinaryData.FromString(property.Value.GetRawText()));
138 }
139 }
140 serializedAdditionalRawData = rawDataDictionary;
141 return new InternalChatCompletionStreamResponseDelta(content ?? new ChangeTrackingList<ChatMessageContentPart>(), functionCall, toolCalls ?? new ChangeTrackingList<StreamingChatToolCallUpdate>(), role, refusal, serializedAdditionalRawData);
142 }
143}
144