@@ -18,14 +18,15 @@ package e2e
18
18
19
19
import (
20
20
"fmt"
21
+ "time"
21
22
22
23
. "github.com/onsi/ginkgo/v2" //nolint
23
24
. "github.com/onsi/gomega" //nolint
24
25
25
26
"d7y.io/dragonfly/v2/test/e2e/v2/util"
26
27
)
27
28
28
- var _ = Describe ("Download with proxy " , func () {
29
+ var _ = Describe ("Download Using Proxy " , func () {
29
30
Context ("/etc/containerd/config.toml file" , func () {
30
31
It ("download should be ok" , Label ("proxy" , "download" ), func () {
31
32
clientPod , err := util .ClientExec ()
@@ -334,7 +335,7 @@ var _ = Describe("Download with proxy", func() {
334
335
fmt .Println (string (out ))
335
336
336
337
fileMetadata := util.FileMetadata {
337
- ID : "28ded7113a871c1eb08728204810514f08e200952131075ea5f7a3756973ceb2 " ,
338
+ ID : "871b9e11903e7f3cadcb25706be7fd2c153b76cdf138f713bd7b506f695fc863 " ,
338
339
Sha256 : "ba9a10ceceb80562fc124dc9bc94ea2a38e3a71e3e746e2140e6381ac791cdeb" ,
339
340
}
340
341
@@ -470,3 +471,325 @@ var _ = Describe("Download with proxy", func() {
470
471
})
471
472
})
472
473
})
474
+
475
+ var _ = Describe ("Download Using Prefetch Proxy" , func () {
476
+ Context ("/etc/containerd/config.toml file" , func () {
477
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" ), func () {
478
+ seedClientPod , err := util .SeedClientExec (0 )
479
+ fmt .Println (err )
480
+ Expect (err ).NotTo (HaveOccurred ())
481
+
482
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -H 'X-Dragonfly-Tag: prefetch-proxy' %s --output %s" , util .GetFileURL ("/etc/containerd/config.toml" ), util .GetOutputPath ("config-prefetch-proxy.coml" ))).CombinedOutput ()
483
+ fmt .Println (err )
484
+ Expect (err ).NotTo (HaveOccurred ())
485
+ fmt .Println (string (out ))
486
+
487
+ fileMetadata := util.FileMetadata {
488
+ ID : "0fa5f40dfccfcd4c20b2d2dba0bab7205bfced189cc7a013919a6d155d841dab" ,
489
+ Sha256 : "66404431f9a0d5c78205e5a3eb041f76767094fc278c0a091d4ffa10f06cf641" ,
490
+ }
491
+
492
+ sha256sum , err := util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
493
+ Expect (err ).NotTo (HaveOccurred ())
494
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
495
+
496
+ sha256sum , err = util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("config-prefetch-proxy.coml" ))
497
+ Expect (err ).NotTo (HaveOccurred ())
498
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
499
+ })
500
+ })
501
+
502
+ Context ("/bin/kubectl file" , func () {
503
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" ), func () {
504
+ seedClientPod , err := util .SeedClientExec (0 )
505
+ fmt .Println (err )
506
+ Expect (err ).NotTo (HaveOccurred ())
507
+
508
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -H 'X-Dragonfly-Tag: prefetch-proxy' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy" ))).CombinedOutput ()
509
+ fmt .Println (err )
510
+ Expect (err ).NotTo (HaveOccurred ())
511
+ fmt .Println (string (out ))
512
+
513
+ fileMetadata := util.FileMetadata {
514
+ ID : "8cdfeba7c8858b1bf7dc6097aeb6bae12e3a4cb8ed32cc3b60bdb45765bda590" ,
515
+ Sha256 : "327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ,
516
+ }
517
+
518
+ sha256sum , err := util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
519
+ Expect (err ).NotTo (HaveOccurred ())
520
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
521
+
522
+ sha256sum , err = util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy" ))
523
+ Expect (err ).NotTo (HaveOccurred ())
524
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
525
+ })
526
+ })
527
+
528
+ Context ("/bin/x86_64 file" , func () {
529
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" ), func () {
530
+ seedClientPod , err := util .SeedClientExec (0 )
531
+ fmt .Println (err )
532
+ Expect (err ).NotTo (HaveOccurred ())
533
+
534
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -H 'X-Dragonfly-Tag: prefetch-proxy' %s --output %s" , util .GetFileURL ("/bin/x86_64" ), util .GetOutputPath ("x86_64-prefetch-proxy" ))).CombinedOutput ()
535
+ fmt .Println (err )
536
+ Expect (err ).NotTo (HaveOccurred ())
537
+ fmt .Println (string (out ))
538
+
539
+ fileMetadata := util.FileMetadata {
540
+ ID : "86b0c4424368f35e500045d5375b8b53940cadf69b71d0ae4b349ac972ad6bdb" ,
541
+ Sha256 : "a1cbf1bf2d66757121677fd7fefafacd4f843a2cb44a451131002803bae56a65" ,
542
+ }
543
+
544
+ sha256sum , err := util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
545
+ Expect (err ).NotTo (HaveOccurred ())
546
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
547
+
548
+ sha256sum , err = util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("x86_64-prefetch-proxy" ))
549
+ Expect (err ).NotTo (HaveOccurred ())
550
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
551
+ })
552
+ })
553
+
554
+ Context ("/bin/zless file" , func () {
555
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" ), func () {
556
+ seedClientPod , err := util .SeedClientExec (0 )
557
+ fmt .Println (err )
558
+ Expect (err ).NotTo (HaveOccurred ())
559
+
560
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -H 'X-Dragonfly-Tag: prefetch-proxy' %s --output %s" , util .GetFileURL ("/bin/zless" ), util .GetOutputPath ("zless-prefetch-proxy" ))).CombinedOutput ()
561
+ fmt .Println (err )
562
+ Expect (err ).NotTo (HaveOccurred ())
563
+ fmt .Println (string (out ))
564
+
565
+ fileMetadata := util.FileMetadata {
566
+ ID : "d759035bb589e9334717660701c58ef91ebab49bb5790367ede36bf78daa52a1" ,
567
+ Sha256 : "b0cfe211f851049a78f5812cf5b1d7cb4f3fbb101c02c1865c940d5797f4b73b" ,
568
+ }
569
+
570
+ sha256sum , err := util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
571
+ Expect (err ).NotTo (HaveOccurred ())
572
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
573
+
574
+ sha256sum , err = util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("zless-prefetch-proxy" ))
575
+ Expect (err ).NotTo (HaveOccurred ())
576
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
577
+ })
578
+ })
579
+
580
+ Context ("/bin/bash file" , func () {
581
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" ), func () {
582
+ seedClientPod , err := util .SeedClientExec (0 )
583
+ fmt .Println (err )
584
+ Expect (err ).NotTo (HaveOccurred ())
585
+
586
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -H 'X-Dragonfly-Tag: prefetch-proxy' %s --output %s" , util .GetFileURL ("/bin/bash" ), util .GetOutputPath ("bash-prefetch-proxy" ))).CombinedOutput ()
587
+ fmt .Println (err )
588
+ Expect (err ).NotTo (HaveOccurred ())
589
+ fmt .Println (string (out ))
590
+
591
+ fileMetadata := util.FileMetadata {
592
+ ID : "ecd74f0e4f9ff453e3c165934d473ef6946b088fecabb8a2eb7d11d2948f743c" ,
593
+ Sha256 : "c37f93c73cf2f303f874c094f6f76e47b2421a3da9f0e7e0b98bea8a3d685322" ,
594
+ }
595
+
596
+ sha256sum , err := util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
597
+ Expect (err ).NotTo (HaveOccurred ())
598
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
599
+
600
+ sha256sum , err = util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("bash-prefetch-proxy" ))
601
+ Expect (err ).NotTo (HaveOccurred ())
602
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
603
+ })
604
+ })
605
+
606
+ Context ("/bin/kubectl file and set range header" , func () {
607
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=-100" ), func () {
608
+ seedClientPod , err := util .SeedClientExec (0 )
609
+ fmt .Println (err )
610
+ Expect (err ).NotTo (HaveOccurred ())
611
+
612
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r -100 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-100' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100" ))).CombinedOutput ()
613
+ fmt .Println (err )
614
+ Expect (err ).NotTo (HaveOccurred ())
615
+ fmt .Println (string (out ))
616
+
617
+ fileMetadata := util.FileMetadata {
618
+ ID : "2d9e6ebe90a230ff5ffad7938163456c308e072e910eac3dd063f64f62112f05" ,
619
+ Sha256 : "cd00e292c5970d3c5e2f0ffa5171e555bc46bfc4faddfb4a418b6840b86e79a3" ,
620
+ }
621
+
622
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100" ))
623
+ Expect (err ).NotTo (HaveOccurred ())
624
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
625
+
626
+ time .Sleep (5 * time .Second )
627
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
628
+ Expect (err ).NotTo (HaveOccurred ())
629
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
630
+
631
+ })
632
+ })
633
+
634
+ Context ("/bin/kubectl file and set range header" , func () {
635
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=0-100" ), func () {
636
+ seedClientPod , err := util .SeedClientExec (0 )
637
+ fmt .Println (err )
638
+ Expect (err ).NotTo (HaveOccurred ())
639
+
640
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 0-100 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-0-100' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-0-100" ))).CombinedOutput ()
641
+ fmt .Println (err )
642
+ Expect (err ).NotTo (HaveOccurred ())
643
+ fmt .Println (string (out ))
644
+
645
+ fileMetadata := util.FileMetadata {
646
+ ID : "bd969c992e6faff240ac1601afe07bdeaa64c2b75bd5abb36a1fd6601895c542" ,
647
+ Sha256 : "7bbfcb694f6acc69483751d3b48d5bdbdcb284f9e04c7b7caa04b5977cffddc8" ,
648
+ }
649
+
650
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-0-100" ))
651
+ Expect (err ).NotTo (HaveOccurred ())
652
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
653
+
654
+ time .Sleep (5 * time .Second )
655
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
656
+ Expect (err ).NotTo (HaveOccurred ())
657
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
658
+ })
659
+ })
660
+
661
+ Context ("/bin/kubectl file and set range header" , func () {
662
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=100-" ), func () {
663
+ seedClientPod , err := util .SeedClientExec (0 )
664
+ fmt .Println (err )
665
+ Expect (err ).NotTo (HaveOccurred ())
666
+
667
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 100- -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-100-' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-" ))).CombinedOutput ()
668
+ fmt .Println (err )
669
+ Expect (err ).NotTo (HaveOccurred ())
670
+ fmt .Println (string (out ))
671
+
672
+ fileMetadata := util.FileMetadata {
673
+ ID : "a58f439c45c5737613f1c1d4f10b57c06239b675fccdc32a3d078af89d2bd870" ,
674
+ Sha256 : "ba9a10ceceb80562fc124dc9bc94ea2a38e3a71e3e746e2140e6381ac791cdeb" ,
675
+ }
676
+
677
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-" ))
678
+ Expect (err ).NotTo (HaveOccurred ())
679
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
680
+
681
+ time .Sleep (5 * time .Second )
682
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
683
+ Expect (err ).NotTo (HaveOccurred ())
684
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
685
+ })
686
+ })
687
+
688
+ Context ("/bin/kubectl file and set range header" , func () {
689
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=100-46026751" ), func () {
690
+ seedClientPod , err := util .SeedClientExec (0 )
691
+ fmt .Println (err )
692
+ Expect (err ).NotTo (HaveOccurred ())
693
+
694
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 100-46026751 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-100-46026751' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-46026751" ))).CombinedOutput ()
695
+ fmt .Println (err )
696
+ Expect (err ).NotTo (HaveOccurred ())
697
+ fmt .Println (string (out ))
698
+
699
+ fileMetadata := util.FileMetadata {
700
+ ID : "ba4b4a0a1be91ab6b2a76f99bbd8eac5977c388cfc7de73707d30e5d5cf0a6d4" ,
701
+ Sha256 : "ba9a10ceceb80562fc124dc9bc94ea2a38e3a71e3e746e2140e6381ac791cdeb" ,
702
+ }
703
+
704
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-46026751" ))
705
+ Expect (err ).NotTo (HaveOccurred ())
706
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
707
+
708
+ time .Sleep (5 * time .Second )
709
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
710
+ Expect (err ).NotTo (HaveOccurred ())
711
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
712
+ })
713
+ })
714
+
715
+ Context ("/bin/kubectl file and set range header" , func () {
716
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=0-46026751" ), func () {
717
+ seedClientPod , err := util .SeedClientExec (0 )
718
+ fmt .Println (err )
719
+ Expect (err ).NotTo (HaveOccurred ())
720
+
721
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 0-46026751 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-0-46026751' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-0-46026751" ))).CombinedOutput ()
722
+ fmt .Println (err )
723
+ Expect (err ).NotTo (HaveOccurred ())
724
+ fmt .Println (string (out ))
725
+
726
+ fileMetadata := util.FileMetadata {
727
+ ID : "66b8f945a2906550194aefee5a6da6c3a4c60b533e30340707c8bea67ce35eae" ,
728
+ Sha256 : "327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ,
729
+ }
730
+
731
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-0-46026751" ))
732
+ Expect (err ).NotTo (HaveOccurred ())
733
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
734
+
735
+ time .Sleep (5 * time .Second )
736
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
737
+ Expect (err ).NotTo (HaveOccurred ())
738
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
739
+ })
740
+ })
741
+
742
+ Context ("/bin/kubectl file and set range header" , func () {
743
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=100-10240" ), func () {
744
+ seedClientPod , err := util .SeedClientExec (0 )
745
+ fmt .Println (err )
746
+ Expect (err ).NotTo (HaveOccurred ())
747
+
748
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 100-10240 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-100-10240' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-10240" ))).CombinedOutput ()
749
+ fmt .Println (err )
750
+ Expect (err ).NotTo (HaveOccurred ())
751
+ fmt .Println (string (out ))
752
+
753
+ fileMetadata := util.FileMetadata {
754
+ ID : "5cfbab580dd42ef5c3a4d28488fde7e82220115dffc8aff01c0c568665405bcb" ,
755
+ Sha256 : "8732360b941ad09a5e0e5d5f9891118bc068f6d0d5a56e3c6d483e4600fbc43f" ,
756
+ }
757
+
758
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-10240" ))
759
+ Expect (err ).NotTo (HaveOccurred ())
760
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
761
+
762
+ time .Sleep (5 * time .Second )
763
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
764
+ Expect (err ).NotTo (HaveOccurred ())
765
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
766
+ })
767
+ })
768
+
769
+ Context ("/bin/kubectl file and set range header" , func () {
770
+ It ("download should be ok" , Label ("prefetch-proxy" , "download" , "range: bytes=100-1024" ), func () {
771
+ seedClientPod , err := util .SeedClientExec (0 )
772
+ fmt .Println (err )
773
+ Expect (err ).NotTo (HaveOccurred ())
774
+
775
+ out , err := seedClientPod .Command ("sh" , "-c" , fmt .Sprintf ("curl -x 127.0.0.1:4001 -r 100-1024 -H 'X-Dragonfly-Tag: prefetch-proxy-bytes-100-1024' %s --output %s" , util .GetFileURL ("/bin/kubectl" ), util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-1024" ))).CombinedOutput ()
776
+ fmt .Println (err )
777
+ Expect (err ).NotTo (HaveOccurred ())
778
+ fmt .Println (string (out ))
779
+
780
+ fileMetadata := util.FileMetadata {
781
+ ID : "e376250edb769e967fe48bdd05d50f4124f89f3db367b0eee9850128c93043d7" ,
782
+ Sha256 : "d6d17dca18b8de59e38da525dc24c47b74fec1a790a9f64afdd6538f4f8fa90e" ,
783
+ }
784
+
785
+ sha256sum , err := util .CalculateSha256ByOutput ([]* util.PodExec {seedClientPod }, util .GetOutputPath ("kubectl-prefetch-proxy-bytes-100-1024" ))
786
+ Expect (err ).NotTo (HaveOccurred ())
787
+ Expect (fileMetadata .Sha256 ).To (Equal (sha256sum ))
788
+
789
+ time .Sleep (5 * time .Second )
790
+ sha256sum , err = util .CalculateSha256ByTaskID ([]* util.PodExec {seedClientPod }, fileMetadata .ID )
791
+ Expect (err ).NotTo (HaveOccurred ())
792
+ Expect ("327b4022d0bfd1d5e9c0701d4a3f989a536f7e6e865e102dcd77c7e7adb31f9a" ).To (Equal (sha256sum ))
793
+ })
794
+ })
795
+ })
0 commit comments