feat: Add write_to/2 method for file writing and fix streaming issues

- Added HTTP.Response.write_to/2 to write response bodies to files
- Supports both streaming and non-streaming responses
- Automatically creates directories if they don't exist
- Fixed streaming threshold from 100KB to 5MB
- Fixed streaming implementation message format issues
- Added comprehensive tests for write_to/2 functionality
- Updated version to 0.4.2
- Updated README.md with write_to/2 examples

Author: GSMLG-BOT

CHANGELOG.md

@@ -5,7 +5,24 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [Unreleased]
+## [0.4.2] - 2025-08-01
+
+### Added
+- Added `HTTP.Response.write_to/2` method to write response bodies to files
+  - Supports both streaming and non-streaming responses
+  - Automatically creates directories if they don't exist
+  - Returns `:ok` or `{:error, reason}` for proper error handling
+
+### Fixed
+- Fixed streaming implementation message format for complete responses
+- Increased streaming threshold from 100KB to 5MB to prevent issues with large files
+- Fixed test assertion for content-length comparison using `byte_size/1` instead of `length/1`
+
+### Changed
+- Updated streaming threshold to prevent streaming for files under 5MB
+- Improved streaming process error handling
+
+## [0.4.1] - 2025-07-31
 
 ### Added
 - **URI struct support** - HTTP.fetch/2 now accepts both string URLs and %URI{} structs

README.md

@@ -121,6 +121,16 @@ response =
 
 # response.body contains the raw binary response data
 binary_data = response.body
+
+# Write response to file (supports both streaming and non-streaming)
+:ok = HTTP.Response.write_to(response, "/tmp/downloaded-file.txt")
+
+# Write large file downloads directly to disk
+{:ok, response} = 
+  HTTP.fetch("https://example.com/large-file.zip")
+  |> HTTP.Promise.await()
+
+:ok = HTTP.Response.write_to(response, "/tmp/large-file.zip")
 ```
 
 ### HTTP.Request

lib/http/response.ex

@@ -183,8 +183,9 @@ defmodule HTTP.Response do
       case response do
         %{body: body, stream: nil} when is_binary(body) or is_list(body) ->
           # Non-streaming response
-          binary_body = 
+          binary_body =
             if is_list(body), do: IO.iodata_to_binary(body), else: body
+
           File.write!(file_path, binary_body)
           :ok
 
@@ -209,6 +210,7 @@ defmodule HTTP.Response do
           # For streaming responses, use collect_stream to get all data
           body = read_all(response)
           IO.binwrite(file, body)
+
         _ ->
           :ok
       end

mix.exs

@@ -1,7 +1,7 @@
 defmodule HttpFetch.MixProject do
   use Mix.Project
 
-  @version "0.4.0"
+  @version "0.4.2"
   @source_url "https://github.com/gsmlg-dev/http_fetch"
 
   def project do

test/http/response_test.exs

@@ -87,7 +87,7 @@ defmodule HTTP.ResponseTest do
   describe "write_to/2" do
     test "write non-streaming response to file" do
       temp_path = Path.join(System.tmp_dir!(), "http_response_test.txt")
-      
+
       response = %HTTP.Response{
         status: 200,
         headers: %HTTP.Headers{},
@@ -98,14 +98,14 @@ defmodule HTTP.ResponseTest do
 
       assert :ok = HTTP.Response.write_to(response, temp_path)
       assert File.read!(temp_path) == "test content"
-      
+
       # Cleanup
       File.rm!(temp_path)
     end
 
     test "write empty response to file" do
       temp_path = Path.join(System.tmp_dir!(), "empty_response_test.txt")
-      
+
       response = %HTTP.Response{
         status: 200,
         headers: %HTTP.Headers{},
@@ -116,14 +116,14 @@ defmodule HTTP.ResponseTest do
 
       assert :ok = HTTP.Response.write_to(response, temp_path)
       assert File.read!(temp_path) == ""
-      
+
       # Cleanup
       File.rm!(temp_path)
     end
 
     test "write iodata response to file" do
       temp_path = Path.join(System.tmp_dir!(), "iodata_response_test.txt")
-      
+
       response = %HTTP.Response{
         status: 200,
         headers: %HTTP.Headers{},
@@ -134,15 +134,15 @@ defmodule HTTP.ResponseTest do
 
       assert :ok = HTTP.Response.write_to(response, temp_path)
       assert File.read!(temp_path) == "hello world"
-      
+
       # Cleanup
       File.rm!(temp_path)
     end
 
     test "write creates directory if needed" do
       temp_dir = Path.join(System.tmp_dir!(), "nested_test_dir")
       temp_path = Path.join(temp_dir, "test_file.txt")
-      
+
       response = %HTTP.Response{
         status: 200,
         headers: %HTTP.Headers{},
@@ -153,14 +153,14 @@ defmodule HTTP.ResponseTest do
 
       assert :ok = HTTP.Response.write_to(response, temp_path)
       assert File.read!(temp_path) == "nested directory content"
-      
+
       # Cleanup
       File.rm_rf!(temp_dir)
     end
 
     test "write_to with actual HTTP response" do
       temp_path = Path.join(System.tmp_dir!(), "actual_response_test.txt")
-      
+
       resp =
         HTTP.fetch("https://httpbin.org/json",
           headers: [{"user-agent", "Elixir http_fetch 0.4.1"}],
@@ -170,13 +170,13 @@ defmodule HTTP.ResponseTest do
 
       assert resp.status == 200
       assert :ok = HTTP.Response.write_to(resp, temp_path)
-      
+
       # Verify file was written
       assert File.exists?(temp_path)
       content = File.read!(temp_path)
       assert byte_size(content) > 0
       assert content =~ "slideshow"
-      
+
       # Cleanup
       File.rm!(temp_path)
     end