ChatMessageTypes.FileLink now supports openai provider

Author: lofcz

src/LlmTornado.Demo/ChatDemo2.cs

@@ -1812,6 +1812,28 @@ public static async Task PerplexitySecSearchTest()
         Console.WriteLine(response.Result?.Usage?.TotalTokens);
     }
 
+    [TornadoTest]
+    public static async Task OpenAiFileInput()
+    {
+        TornadoApi api = Program.Connect();
+        HttpCallResult<TornadoFile> uploadedFile = await api.Files.Upload("Static/Files/prezSample.pdf", mimeType: "application/pdf", expiration: new FileUploadExpiration(TimeSpan.FromHours(1)), provider: LLmProviders.OpenAi);
+
+        Conversation chat = Program.Connect().Chat.CreateConversation(new ChatRequest
+        {
+            Model = ChatModel.OpenAi.Gpt51.V51
+        });
+        
+        chat.AppendUserInput([
+            new ChatMessagePart("What is this file about?"),
+            new ChatMessagePart(new ChatMessagePartFileLinkData(uploadedFile.Data.Reference))
+        ]);
+        
+        ChatRichResponse response = await chat.GetResponseRich();
+        
+        Console.WriteLine(response);
+        Console.WriteLine(response.Result?.Usage?.TotalTokens);
+    }
+    
     [TornadoTest]
     public static async Task AnthropicFileInput()
     {

src/LlmTornado/Chat/ChatMessageTypes.cs

@@ -24,8 +24,7 @@ public enum ChatMessageTypes
     Audio,
 
     /// <summary>
-    /// Message part is URI-based file.<br/>
-    /// <b>Supported only by Google.</b>
+    /// Message part is URI-based file.
     /// </summary>
     FileLink,
 

src/LlmTornado/Chat/ChatRequest.cs

@@ -1099,6 +1099,7 @@ public override void WriteJson(JsonWriter writer, IList<ChatMessage>? value, Jso
 	                        ChatMessageTypes.Image => "image_url",
 	                        ChatMessageTypes.Audio => part.Audio?.Url is not null ? "audio_url" : "input_audio",
                             ChatMessageTypes.Video => "video_url",
+	                        ChatMessageTypes.FileLink => "file",
                             _ => "text"
                         };
 
@@ -1180,6 +1181,26 @@ public override void WriteJson(JsonWriter writer, IList<ChatMessage>? value, Jso
                                 writer.WriteEndObject();
                                 break;
                             }
+	                        case ChatMessageTypes.FileLink:
+	                        {
+		                        writer.WritePropertyName("file");
+		                        writer.WriteStartObject();
+
+		                        // writer.WritePropertyName("file_data");
+		                        // writer.WriteValue(part.Video?.Url);
+		                        
+		                        writer.WritePropertyName("file_id");
+		                        writer.WriteValue(part.FileLinkData?.File?.Uri ?? part.FileLinkData?.FileUri);
+
+		                        if (part.FileLinkData?.File?.Name is not null)
+		                        {
+			                        writer.WritePropertyName("filename");
+			                        writer.WriteValue(part.FileLinkData?.File?.Name);   
+		                        }
+		                        
+		                        writer.WriteEndObject();
+		                        break;
+	                        }
                         }
 
                         writer.WriteEndObject();

src/LlmTornado/Files/FilePurpose.cs

@@ -27,5 +27,29 @@ public enum FilePurpose
     ///     Agent purpose for ZAI file uploads.
     /// </summary>
     [EnumMember(Value = "agent")]
-    Agent
+    Agent,
+    
+    /// <summary>
+    ///     Used in the Batch API.
+    /// </summary>
+    [EnumMember(Value = "batch")]
+    Batch,
+    
+    /// <summary>
+    ///     Images used for vision fine-tuning.
+    /// </summary>
+    [EnumMember(Value = "vision")]
+    Vision,
+    
+    /// <summary>
+    ///     Flexible file type for any purpose.
+    /// </summary>
+    [EnumMember(Value = "user_data")]
+    UserData,
+    
+    /// <summary>
+    ///     Flexible file type for any purpose.
+    /// </summary>
+    [EnumMember(Value = "evals")]
+    Evals
 }

src/LlmTornado/Files/FileUploadRequest.cs

@@ -20,6 +20,53 @@ internal enum FileUploadRequestStates
     PayloadUrlObtained
 }
 
+/// <summary>
+/// Anchor timestamp after which the expiration policy applies.
+/// </summary>
+public enum FileUploadExpirationAnchor
+{
+    /// <summary>
+    /// Anchor to the file creation timestamp.
+    /// </summary>
+    CreatedAt
+}
+
+/// <summary>
+/// Expiration policy for a file. By default, files with purpose=batch expire after 30 days and all other files are persisted until they are manually deleted.
+/// </summary>
+public class FileUploadExpiration
+{
+    /// <summary>
+    /// Anchor timestamp after which the expiration policy applies. Supported anchors: created_at.
+    /// </summary>
+    [JsonProperty("anchor")]
+    public FileUploadExpirationAnchor Anchor { get; set; } = FileUploadExpirationAnchor.CreatedAt;
+    
+    /// <summary>
+    /// The number of seconds after the anchor time that the file will expire. Must be between 3600 (1 hour) and 2592000 (30 days).
+    /// </summary>
+    [JsonProperty("seconds")]
+    public int Seconds { get; set; }
+
+    /// <summary>
+    /// Creates an empty expiration
+    /// </summary>
+    public FileUploadExpiration()
+    {
+        
+    }
+
+    /// <summary>
+    /// Creates an expiration from a timespan.
+    /// </summary>
+    /// <param name="ttl"></param>
+    public FileUploadExpiration(TimeSpan ttl)
+    {
+        Seconds = (int)ttl.TotalSeconds;
+    }
+}
+
+
 /// <summary>
 /// Request to upload a file.
 /// </summary>
@@ -50,6 +97,11 @@ public class FileUploadRequest
     /// </summary>
     public string? DisplayName { get; set; }
 
+    /// <summary>
+    /// Optional expiration policy for the file. Supported only by OpenAI.
+    /// </summary>
+    public FileUploadExpiration? Expiration { get; set; }
+    
     internal FileUploadRequestStates? InternalState { get; set; } 
 
     private static string GetPurpose(FilePurpose purpose)
@@ -59,10 +111,23 @@ private static string GetPurpose(FilePurpose purpose)
             FilePurpose.Finetune => "fine-tune",
             FilePurpose.Assistants => "assistants",
             FilePurpose.Agent => "agent",
+            FilePurpose.Batch => "batch",
+            FilePurpose.Vision => "vision",
+            FilePurpose.UserData => "user_data",
+            FilePurpose.Evals => "evals",
             _ => string.Empty
         };
     }
 
+    private static string GetExpirationAnchor(FileUploadExpirationAnchor anchor)
+    {
+        return anchor switch
+        {
+            FileUploadExpirationAnchor.CreatedAt => "created_at",
+            _ => "created_at"
+        };
+    }
+    
     internal static TornadoFile? Deserialize(LLmProviders provider, string jsonData, string? postData)
     {
         return provider switch
@@ -79,11 +144,23 @@ private static string GetPurpose(FilePurpose purpose)
             LLmProviders.OpenAi, (x, y) =>
             {
                 ByteArrayContent bc = new ByteArrayContent(x.Bytes);
-                StringContent sc = new StringContent(x.Purpose is null ? "assistants" : GetPurpose(x.Purpose.Value));
+                StringContent sc = new StringContent(x.Purpose is null ? "user_data" : GetPurpose(x.Purpose.Value));
 
                 MultipartFormDataContent content = new MultipartFormDataContent();
                 content.Add(sc, "purpose");
                 content.Add(bc, "file", x.Name);
+                
+                if (x.Expiration is not null)
+                {
+                    string anchorValue = GetExpirationAnchor(x.Expiration.Anchor);
+                    string secondsValue = x.Expiration.Seconds.ToString();
+                    
+                    StringContent anchorContent = new StringContent(anchorValue);
+                    content.Add(anchorContent, "expires_after[anchor]");
+                    
+                    StringContent secondsContent = new StringContent(secondsValue);
+                    content.Add(secondsContent, "expires_after[seconds]");
+                }
 
                 return content;
             }

src/LlmTornado/Files/FilesEndpoint.cs

@@ -210,8 +210,9 @@ public async Task<HttpCallResult<DeletedTornadoFile>> Delete(string fileId, LLmP
 	/// </param>
 	/// <param name="fileName">Determined from path if not set</param>
 	/// <param name="mimeType">MIME type of the file</param>
+	/// <param name="expiration">Optional expiration policy for the file. Supported only by OpenAI.</param>
 	/// <param name="provider">Which provider will be used</param>
-	public async Task<HttpCallResult<TornadoFile>> Upload(string filePath, FilePurpose purpose = FilePurpose.Finetune, string? fileName = null, string? mimeType = null, LLmProviders? provider = null)
+	public async Task<HttpCallResult<TornadoFile>> Upload(string filePath, FilePurpose purpose = FilePurpose.UserData, string? fileName = null, string? mimeType = null, FileUploadExpiration? expiration = null, LLmProviders? provider = null)
     {
 	    if (!File.Exists(filePath))
 	    {
@@ -227,7 +228,7 @@ public async Task<HttpCallResult<TornadoFile>> Upload(string filePath, FilePurpo
 #endif
 	    string finalFileName = fileName ?? (resolvedProvider.Provider is LLmProviders.Google ? Guid.NewGuid().ToString() : Path.GetFileName(filePath)); // google requires alphanum + dashes, up to 40 chars
 
-        return await Upload(bytes, finalFileName, purpose, mimeType, resolvedProvider.Provider).ConfigureAwait(false);
+        return await Upload(bytes, finalFileName, purpose, mimeType, expiration, resolvedProvider.Provider).ConfigureAwait(false);
     }
 
 	/// <summary>
@@ -242,11 +243,12 @@ public async Task<HttpCallResult<TornadoFile>> Upload(string filePath, FilePurpo
 	/// </param>
 	/// <param name="fileName">Determined from path if not set</param>
 	/// <param name="mimeType">MIME type of the file</param>
+	/// <param name="expiration">Optional expiration policy for the file. Supported only by OpenAI.</param>
 	/// <param name="provider">Which provider will be used</param>
-	public async Task<HttpCallResult<TornadoFile>> Upload(Stream stream, string fileName, FilePurpose purpose = FilePurpose.Finetune, string? mimeType = null, LLmProviders? provider = null)
+	public async Task<HttpCallResult<TornadoFile>> Upload(Stream stream, string fileName, FilePurpose purpose = FilePurpose.UserData, string? mimeType = null, FileUploadExpiration? expiration = null, LLmProviders? provider = null)
 	{
 		byte[] bytes = await stream.ToArrayAsync().ConfigureAwait(false);
-		return await Upload(bytes, fileName, purpose, mimeType, provider).ConfigureAwait(false);
+		return await Upload(bytes, fileName, purpose, mimeType, expiration, provider).ConfigureAwait(false);
 	}
 
 	/// <summary>
@@ -261,15 +263,17 @@ public async Task<HttpCallResult<TornadoFile>> Upload(Stream stream, string file
 	/// </param>
 	/// <param name="fileName">Determined from path if not set</param>
 	/// <param name="mimeType">MIME type of the file</param>
+	/// <param name="expiration">Optional expiration policy for the file. Supported only by OpenAI.</param>
 	/// <param name="provider">Which provider will be used</param>
-	public async Task<HttpCallResult<TornadoFile>> Upload(byte[] fileBytes, string fileName, FilePurpose purpose = FilePurpose.Finetune, string? mimeType = null, LLmProviders? provider = null)
+	public async Task<HttpCallResult<TornadoFile>> Upload(byte[] fileBytes, string fileName, FilePurpose purpose = FilePurpose.UserData, string? mimeType = null, FileUploadExpiration? expiration = null, LLmProviders? provider = null)
 	{
 		return await Upload(new FileUploadRequest
 		{
 			Bytes = fileBytes,
 			Name = fileName,
 			Purpose = purpose,
-			MimeType = mimeType
+			MimeType = mimeType,
+			Expiration = expiration
 		}, provider).ConfigureAwait(false);
 	}
 

src/LlmTornado/Files/TornadoFile.cs

@@ -32,7 +32,7 @@ public class TornadoFile
 	///     The name of the file
 	/// </summary>
 	[JsonProperty("filename")]
-    public string Name { get; set; }
+    public string? Name { get; set; }
 
 	/// <summary>
 	///     The size of the file in bytes
@@ -93,4 +93,9 @@ public class TornadoFile
 	/// </summary>
 	[JsonIgnore]
 	public FileLinkStates? State { get; set; }
+
+	/// <summary>
+	/// Returns <see cref="Uri"/> or <see cref="Id"/> - this property should be used for cross-provider referencing of the file.
+	/// </summary>
+	public string Reference => Uri ?? Id;
 }