@@ -469,21 +469,23 @@ defmodule Reencodarr.AbAv1.ProgressParserTest do
469469 assert vmaf . percent == 75.0
470470 end
471471
472- test "comprehensive fixture processing coverage" , % { video: video , crf_search_lines: crf_lines , encoding_lines: enc_lines } do
472+ test "comprehensive fixture processing coverage" , % {
473+ video: video ,
474+ crf_search_lines: crf_lines ,
475+ encoding_lines: enc_lines
476+ } do
473477 # Test that ProgressParser can handle ALL fixture lines without errors
474478 all_lines = crf_lines ++ enc_lines
475479
476480 # Test CRF search context with all lines
477- { processed_crf , error_crf } =
481+ { processed_crf , error_crf } =
478482 Enum . reduce ( crf_lines , { 0 , 0 } , fn line , { processed , errors } ->
479483 try do
480484 ProgressParser . process_line ( line , { video , [ ] , 95 } )
481485 { processed + 1 , errors }
482486 rescue
483- error ->
484- IO . puts "Error processing CRF line: #{ line } "
485- IO . puts "Error: #{ inspect ( error ) } "
486- { processed , errors + 1 }
487+ _error ->
488+ { processed , errors + 1 }
487489 end
488490 end )
489491
@@ -496,38 +498,29 @@ defmodule Reencodarr.AbAv1.ProgressParserTest do
496498 partial_line_buffer: ""
497499 }
498500
499- { processed_enc , error_enc } =
501+ { processed_enc , error_enc } =
500502 Enum . reduce ( enc_lines , { 0 , 0 } , fn line , { processed , errors } ->
501503 try do
502504 ProgressParser . process_line ( line , encoding_state )
503505 { processed + 1 , errors }
504506 rescue
505- error ->
506- IO . puts "Error processing encoding line: #{ line } "
507- IO . puts "Error: #{ inspect ( error ) } "
508- { processed , errors + 1 }
507+ _error ->
508+ { processed , errors + 1 }
509509 end
510510 end )
511511
512512 total_lines = length ( all_lines )
513513 total_processed = processed_crf + processed_enc
514514 total_errors = error_crf + error_enc
515515
516- # Log comprehensive analysis
517- IO . puts "\n === ProgressParser Fixture Coverage Analysis ==="
518- IO . puts "Total fixture lines processed: #{ total_lines } "
519- IO . puts "Successfully processed: #{ total_processed } "
520- IO . puts "Errors encountered: #{ total_errors } "
521- if total_lines > 0 do
522- IO . puts "Success rate: #{ Float . round ( total_processed / total_lines * 100 , 1 ) } %"
523- end
524- IO . puts "CRF search lines: #{ processed_crf } "
525- IO . puts "Encoding lines: #{ processed_enc } "
526-
527516 # Verify we processed lines without major errors
528517 assert total_lines > 0 , "No fixture lines found"
529- assert total_errors == 0 , "ProgressParser encountered #{ total_errors } errors processing fixture lines"
530- assert total_processed == total_lines , "Expected to process all #{ total_lines } lines, but only processed #{ total_processed } "
518+
519+ assert total_errors == 0 ,
520+ "ProgressParser encountered #{ total_errors } errors processing fixture lines"
521+
522+ assert total_processed == total_lines ,
523+ "Expected to process all #{ total_lines } lines, but only processed #{ total_processed } "
531524 end
532525 end
533526
@@ -639,21 +632,35 @@ defmodule Reencodarr.AbAv1.ProgressParserTest do
639632 describe "NimbleParsec size parser" do
640633 test "parses various size formats correctly" do
641634 # Test decimal sizes
642- assert { :ok , [ % { size: 2.5 , unit: "gb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "2.5 GB" )
643- assert { :ok , [ % { size: 800.0 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "800.0 MB" )
644- assert { :ok , [ % { size: 1.2 , unit: "tb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "1.2TB" )
635+ assert { :ok , [ % { size: 2.5 , unit: "gb" } ] , "" , % { } , { 1 , 0 } , _ } =
636+ ProgressParser . parse_size ( "2.5 GB" )
637+
638+ assert { :ok , [ % { size: 800.0 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } =
639+ ProgressParser . parse_size ( "800.0 MB" )
640+
641+ assert { :ok , [ % { size: 1.2 , unit: "tb" } ] , "" , % { } , { 1 , 0 } , _ } =
642+ ProgressParser . parse_size ( "1.2TB" )
645643
646644 # Test integer sizes
647- assert { :ok , [ % { size: 500 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "500 MB" )
648- assert { :ok , [ % { size: 1024 , unit: "kb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "1024KB" )
645+ assert { :ok , [ % { size: 500 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } =
646+ ProgressParser . parse_size ( "500 MB" )
647+
648+ assert { :ok , [ % { size: 1024 , unit: "kb" } ] , "" , % { } , { 1 , 0 } , _ } =
649+ ProgressParser . parse_size ( "1024KB" )
649650
650651 # Test binary units
651- assert { :ok , [ % { size: 2 , unit: "gib" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "2 GiB" )
652- assert { :ok , [ % { size: 512 , unit: "mib" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "512MiB" )
652+ assert { :ok , [ % { size: 2 , unit: "gib" } ] , "" , % { } , { 1 , 0 } , _ } =
653+ ProgressParser . parse_size ( "2 GiB" )
654+
655+ assert { :ok , [ % { size: 512 , unit: "mib" } ] , "" , % { } , { 1 , 0 } , _ } =
656+ ProgressParser . parse_size ( "512MiB" )
653657
654658 # Test case insensitive
655- assert { :ok , [ % { size: 100 , unit: "gb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "100gb" )
656- assert { :ok , [ % { size: 50 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } = ProgressParser . parse_size ( "50mb" )
659+ assert { :ok , [ % { size: 100 , unit: "gb" } ] , "" , % { } , { 1 , 0 } , _ } =
660+ ProgressParser . parse_size ( "100gb" )
661+
662+ assert { :ok , [ % { size: 50 , unit: "mb" } ] , "" , % { } , { 1 , 0 } , _ } =
663+ ProgressParser . parse_size ( "50mb" )
657664 end
658665
659666 test "handles invalid size formats" do
@@ -667,19 +674,22 @@ defmodule Reencodarr.AbAv1.ProgressParserTest do
667674 test "size string parsing integration" do
668675 # Test the public interface that uses NimbleParsec internally
669676 # This tests the private parse_size_string function indirectly through vmaf size checking
670- video = Fixtures . video_fixture ( % {
671- path: "/test/size_test_#{ System . unique_integer ( [ :positive ] ) } /video.mkv" ,
672- service_id: "test_size" ,
673- service_type: :sonarr ,
674- size: 1_000_000_000
675- } )
677+ video =
678+ Fixtures . video_fixture ( % {
679+ path: "/test/size_test_#{ System . unique_integer ( [ :positive ] ) } /video.mkv" ,
680+ service_id: "test_size" ,
681+ service_type: :sonarr ,
682+ size: 1_000_000_000
683+ } )
676684
677685 # Create vmaf record with size data
678686 vmaf_params = % {
679687 crf: 24 ,
680688 score: 95.5 ,
681- size: "2.5 GB" , # This will be parsed by our NimbleParsec parser
682- params: [ "--crf" , "24" ] , # Required field
689+ # This will be parsed by our NimbleParsec parser
690+ size: "2.5 GB" ,
691+ # Required field
692+ params: [ "--crf" , "24" ] ,
683693 video_id: video . id
684694 }
685695
0 commit comments