Replace Vec with Iterator

1 files changed, 24 insertions, 17 deletions

diff --git a/src/zip/driver.rs b/src/zip/driver.rs
index 8dc902f..b4217c8 100644
--- a/src/zip/driver.rs
+++ b/src/zip/driver.rs
@@ -15,21 +15,30 @@ use std::collections::HashMap as Map;
 use std::fs::File;
 use std::io::{BufReader, Read, Seek, SeekFrom, Write};
 
-#[inline]
-fn split_fields(bytes: &[u8]) -> Option<Vec<(u16, &[u8])>> {
-    let mut fields = Vec::new();
-
-    let mut p = 0;
-    while p < bytes.len() {
-        let header: ExtraHeader = deserialize(bytes.get(p..p + 4)?).unwrap();
-        p += 4;
-        let data = bytes.get(p..p + header.size as usize)?;
-        p += header.size as usize;
+struct Fields<'b> {
+    pointer: usize,
+    bytes: &'b [u8],
+}
 
-        fields.push((header.id, data));
+impl<'b> Fields<'b> {
+    pub fn new(bytes: &'b [u8]) -> Self {
+        Self { pointer: 0, bytes }
     }
+}
 
-    Some(fields)
+impl<'b> Iterator for Fields<'b> {
+    type Item = (u16, &'b [u8]);
+
+    fn next(&mut self) -> Option<Self::Item> {
+        let header: ExtraHeader =
+            deserialize(self.bytes.get(self.pointer..self.pointer + 4)?).unwrap();
+        self.pointer += 4;
+        let data = self
+            .bytes
+            .get(self.pointer..self.pointer + header.size as usize)?;
+        self.pointer += header.size as usize;
+        Some((header.id, data))
+    }
 }
 
 #[inline]
@@ -159,7 +168,7 @@ impl<Io: Read + Seek> ArchiveRead for Zip<Io> {
             let mut ctime = None;
 
             // Parse extensible data fields
-            for (id, mut data) in split_fields(&extra_fields).ok_or(ZipError::InvalidExtraFields)? {
+            for (id, mut data) in Fields::new(&extra_fields) {
                 match id {
                     // Zip64
                     0x0001 => {
@@ -175,9 +184,7 @@ impl<Io: Read + Seek> ArchiveRead for Zip<Io> {
                     }
                     // NTFS
                     0x000a => {
-                        for (id, mut data) in
-                            split_fields(&data).ok_or(ZipError::InvalidExtraFields)?
-                        {
+                        for (id, mut data) in Fields::new(&data[4..]) {
                             match id {
                                 0x0001 => {
                                     mtime = ntfs_to_local(u64::from_le_bytes(data.read_arr()?))
@@ -198,7 +205,7 @@ impl<Io: Read + Seek> ArchiveRead for Zip<Io> {
                     // AES
                     0x9901 => {
                         let aes: AesField = deserialize(&data.read_arr::<7>()?).unwrap();
-                        if aes.id != 0x4541 {
+                        if aes.id != [0x41, 0x45] {
                             return Err(ZipError::InvalidExtraFields);
                         }
                         encryption_method = match aes.strength {