using CRC32; using SharpCompress.Archive; using SharpCompress.Archive.SevenZip; using SharpCompress.Common; using SharpCompress.Reader; using System; using System.Collections.Generic; using System.IO; using System.IO.Compression; using System.Linq; using System.Security.Cryptography; using System.Text.RegularExpressions; namespace SabreTools.Helper { public class FileTools { #region Archive Writing /// /// Copy a file to an output archive /// /// Input filename to be moved /// Output directory to build to /// RomData representing the new information /// True if the archive was written properly, false otherwise public static bool WriteToArchive(string inputFile, string outputDirectory, Rom rom) { bool success = false; // If the input file doesn't exist, return if (!File.Exists(inputFile)) { return success; } string archiveFileName = Path.Combine(outputDirectory, rom.Machine.Name + ".zip"); ZipArchive outarchive = null; try { // If the archive doesn't exist, create it if (!File.Exists(archiveFileName)) { outarchive = ZipFile.Open(archiveFileName, ZipArchiveMode.Create); outarchive.Dispose(); } // Open the archive for writing using (outarchive = ZipFile.Open(archiveFileName, ZipArchiveMode.Update)) { // If the archive doesn't already contain the entry, add it if (outarchive.GetEntry(rom.Name) == null) { outarchive.CreateEntryFromFile(inputFile, rom.Name, CompressionLevel.Optimal); } // If there's a Date attached to the rom, change the entry to that Date if (!String.IsNullOrEmpty(rom.Date)) { DateTimeOffset dto = DateTimeOffset.Now; if (DateTimeOffset.TryParse(rom.Date, out dto)) { outarchive.GetEntry(rom.Name).LastWriteTime = dto; } } } success = true; } catch (Exception ex) { Console.WriteLine(ex); success = false; } finally { outarchive?.Dispose(); } return success; } /// /// Write an input file to a torrent GZ file /// /// File to write from /// Directory to write archive to /// True if files should be output in Romba depot folders, false otherwise /// Logger object for file and console output /// True if the write was a success, false otherwise /// This works for now, but it can be sped up by using Ionic.Zip or another zlib wrapper that allows for header values built-in. See edc's code. public static bool WriteTorrentGZ(string input, string outdir, bool romba, Logger logger) { // Check that the input file exists if (!File.Exists(input)) { logger.Warning("File " + input + " does not exist!"); return false; } input = Path.GetFullPath(input); // Make sure the output directory exists if (!Directory.Exists(outdir)) { Directory.CreateDirectory(outdir); } outdir = Path.GetFullPath(outdir); // Now get the Rom info for the file so we have hashes and size Rom rom = FileTools.GetSingleFileInfo(input); // If it doesn't exist, create the output file and then write string outfile = Path.Combine(outdir, rom.HashData.SHA1 + ".gz"); using (FileStream inputstream = new FileStream(input, FileMode.Open)) using (GZipStream output = new GZipStream(File.Open(outfile, FileMode.Create, FileAccess.Write), CompressionMode.Compress)) { inputstream.CopyTo(output); } // Now that it's ready, inject the header info using (BinaryWriter sw = new BinaryWriter(new MemoryStream())) { using (BinaryReader br = new BinaryReader(File.OpenRead(outfile))) { // Write standard header and TGZ info byte[] data = Constants.TorrentGZHeader .Concat(Style.StringToByteArray(rom.HashData.MD5)) // MD5 .Concat(Style.StringToByteArray(rom.HashData.CRC)) // CRC .Concat(BitConverter.GetBytes(rom.HashData.Size).Reverse().ToArray()) // Long size (Mirrored) .ToArray(); sw.Write(data); // Finally, copy the rest of the data from the original file br.BaseStream.Seek(10, SeekOrigin.Begin); int i = 10; while (br.BaseStream.Position < br.BaseStream.Length) { sw.Write(br.ReadByte()); i++; } } using (BinaryWriter bw = new BinaryWriter(File.Open(outfile, FileMode.Create))) { // Now write the new file over the original sw.BaseStream.Seek(0, SeekOrigin.Begin); bw.BaseStream.Seek(0, SeekOrigin.Begin); sw.BaseStream.CopyTo(bw.BaseStream); } } // If we're in romba mode, create the subfolder and move the file if (romba) { string subfolder = Path.Combine(rom.HashData.SHA1.Substring(0, 2), rom.HashData.SHA1.Substring(2, 2), rom.HashData.SHA1.Substring(4, 2), rom.HashData.SHA1.Substring(6, 2)); outdir = Path.Combine(outdir, subfolder); if (!Directory.Exists(outdir)) { Directory.CreateDirectory(outdir); } try { File.Move(outfile, Path.Combine(outdir, Path.GetFileName(outfile))); } catch (Exception ex) { logger.Warning(ex.ToString()); File.Delete(outfile); } } return true; } /// /// Write an existing zip archive construct to a torrent zip file /// /// ZipArchiveStruct representing the zipfile /// Name of the file to write out to /// Logger object for file and console output public static void WriteTorrentZip(ZipArchiveStruct zae, string output, Logger logger) { // First, rearrange entries by name List entries = zae.Entries; entries.Sort((i, j) => { return Style.CompareNumeric(i.FileName.ToLowerInvariant(), j.FileName.ToLowerInvariant()); }); using (BinaryWriter bw = new BinaryWriter(File.Open(output, FileMode.Create))) { List offsets = new List(); // First, write out entries foreach (ZipArchiveEntryStruct zaes in zae.Entries) { offsets.Add(bw.BaseStream.Position); bw.Write(new byte[] { 0x50, 0x4b, 0x03, 0x04 }); // local file header signature bw.Write((ushort)zaes.VersionNeeded); bw.Write((ushort)zaes.GeneralPurposeBitFlag); bw.Write((ushort)zaes.CompressionMethod); bw.Write(zaes.LastModFileTime); bw.Write(zaes.LastModFileDate); bw.Write(zaes.CRC); bw.Write(zaes.CompressedSize); bw.Write(zaes.UncompressedSize); bw.Write((ushort)zaes.FileName.Length); bw.Write((ushort)zaes.ExtraField.Length); bw.Write(zaes.FileName); bw.Write(zaes.ExtraField); bw.Write(zaes.Data); if ((zaes.GeneralPurposeBitFlag & GeneralPurposeBitFlag.ZeroedCRCAndSize) != 0) { bw.Write(zaes.CRC); bw.Write(zaes.CompressedSize); bw.Write(zaes.UncompressedSize); } } // Then write out the central directory int index = 0; zae.SOCDOffset = (int)bw.BaseStream.Position; foreach (ZipArchiveEntryStruct zaes in zae.Entries) { bw.Write(new byte[] { 0x50, 0x4b, 0x01, 0x02 }); // central file header signature bw.Write((ushort)zaes.VersionMadeBy); bw.Write((ushort)zaes.VersionNeeded); bw.Write((ushort)zaes.GeneralPurposeBitFlag); bw.Write((ushort)zaes.CompressionMethod); bw.Write(zaes.LastModFileTime); bw.Write(zaes.LastModFileDate); bw.Write((short)zaes.FileName.Length); bw.Write((short)zaes.ExtraField.Length); bw.Write((short)zaes.Comment.Length); bw.Write((short)0); bw.Write((short)zaes.InternalFileAttributes); bw.Write(zaes.ExternalFileAttributes); bw.Write((int)offsets[index]); bw.Write(zaes.FileName); bw.Write(zaes.ExtraField); bw.Write(zaes.Comment); index++; } zae.EOCDOffset = (int)bw.BaseStream.Position; // Finally, write out the end record bw.Write(new byte[] { 0x50, 0x4b, 0x05, 0x06 }); // end of central dir signature bw.Write((short)0); bw.Write((short)0); bw.Write((short)zae.Entries.Count); bw.Write((int)(zae.EOCDOffset - zae.SOCDOffset)); bw.Write((int)(zae.EOCDOffset - zae.SOCDOffset)); bw.Write((short)22); bw.Write("TORRENTZIPPED-"); } using (BinaryReader br = new BinaryReader(File.OpenRead(output))) { br.BaseStream.Seek(zae.SOCDOffset, SeekOrigin.Begin); byte[] cd = br.ReadBytes(zae.EOCDOffset - zae.SOCDOffset); OptimizedCRC ocrc = new OptimizedCRC(); ocrc.Update(cd, 0, cd.Length); zae.CentralDirectoryCRC = ocrc.Value; } using (BinaryWriter bw = new BinaryWriter(File.Open(output, FileMode.Append))) { bw.Write(zae.CentralDirectoryCRC); } } #endregion #region Archive Extraction /// /// Attempt to extract a file as an archive /// /// Name of the file to be extracted /// Temporary directory for archive extraction /// Logger object for file and console output /// True if the extraction was a success, false otherwise public static bool ExtractArchive(string input, string tempdir, Logger logger) { return ExtractArchive(input, tempdir, ArchiveScanLevel.Both, ArchiveScanLevel.External, ArchiveScanLevel.External, ArchiveScanLevel.Both, logger); } /// /// Attempt to extract a file as an archive /// /// Name of the file to be extracted /// Temporary directory for archive extraction /// Integer representing the archive handling level for 7z /// Integer representing the archive handling level for GZip /// Integer representing the archive handling level for RAR /// Integer representing the archive handling level for Zip /// Logger object for file and console output /// True if the extraction was a success, false otherwise public static bool ExtractArchive(string input, string tempdir, int sevenzip, int gz, int rar, int zip, Logger logger) { return ExtractArchive(input, tempdir, (ArchiveScanLevel)sevenzip, (ArchiveScanLevel)gz, (ArchiveScanLevel)rar, (ArchiveScanLevel)zip, logger); } /// /// Attempt to extract a file as an archive /// /// Name of the file to be extracted /// Temporary directory for archive extraction /// Archive handling level for 7z /// Archive handling level for GZip /// Archive handling level for RAR /// Archive handling level for Zip /// Logger object for file and console output /// True if the extraction was a success, false otherwise public static bool ExtractArchive(string input, string tempdir, ArchiveScanLevel sevenzip, ArchiveScanLevel gz, ArchiveScanLevel rar, ArchiveScanLevel zip, Logger logger) { bool encounteredErrors = true; // First get the archive type ArchiveType? at = GetCurrentArchiveType(input, logger); // If we got back null, then it's not an archive, so we we return if (at == null) { return encounteredErrors; } IReader reader = null; SevenZipArchive sza = null; try { if (at == ArchiveType.SevenZip && sevenzip != ArchiveScanLevel.External) { sza = SevenZipArchive.Open(File.OpenRead(input)); logger.Log("Found archive of type: " + at); // Create the temp directory Directory.CreateDirectory(tempdir); // Extract all files to the temp directory sza.WriteToDirectory(tempdir, ExtractOptions.ExtractFullPath | ExtractOptions.Overwrite); encounteredErrors = false; } else if (at == ArchiveType.GZip && gz != ArchiveScanLevel.External) { logger.Log("Found archive of type: " + at); // Create the temp directory Directory.CreateDirectory(tempdir); using (FileStream itemstream = File.OpenRead(input)) { using (FileStream outstream = File.Create(Path.Combine(tempdir, Path.GetFileNameWithoutExtension(input)))) { using (GZipStream gzstream = new GZipStream(itemstream, CompressionMode.Decompress)) { gzstream.CopyTo(outstream); } } } encounteredErrors = false; } else { reader = ReaderFactory.Open(File.OpenRead(input)); logger.Log("Found archive of type: " + at); if ((at == ArchiveType.Zip && zip != ArchiveScanLevel.External) || (at == ArchiveType.Rar && rar != ArchiveScanLevel.External)) { // Create the temp directory Directory.CreateDirectory(tempdir); // Extract all files to the temp directory reader.WriteAllToDirectory(tempdir, ExtractOptions.ExtractFullPath | ExtractOptions.Overwrite); encounteredErrors = false; } } } catch (EndOfStreamException) { // Catch this but don't count it as an error because SharpCompress is unsafe } catch (InvalidOperationException) { encounteredErrors = true; } catch (Exception) { // Don't log file open errors encounteredErrors = true; } finally { reader?.Dispose(); sza?.Dispose(); } return encounteredErrors; } /// /// Attempt to extract a file from an archive /// /// Name of the archive to be extracted /// Name of the entry to be extracted /// Temporary directory for archive extraction /// Logger object for file and console output /// Name of the extracted file, null on error public static string ExtractSingleItemFromArchive(string input, string entryname, string tempdir, Logger logger) { string outfile = null; // First get the archive type ArchiveType? at = GetCurrentArchiveType(input, logger); // If we got back null, then it's not an archive, so we we return if (at == null) { return outfile; } IReader reader = null; try { reader = ReaderFactory.Open(File.OpenRead(input)); if (at == ArchiveType.Zip || at == ArchiveType.SevenZip || at == ArchiveType.Rar) { // Create the temp directory Directory.CreateDirectory(tempdir); while (reader.MoveToNextEntry()) { logger.Log("Current entry name: '" + reader.Entry.Key + "'"); if (reader.Entry != null && reader.Entry.Key.Contains(entryname)) { outfile = Path.GetFullPath(Path.Combine(tempdir, reader.Entry.Key)); if (!Directory.Exists(Path.GetDirectoryName(outfile))) { Directory.CreateDirectory(Path.GetDirectoryName(outfile)); } reader.WriteEntryToFile(outfile, ExtractOptions.Overwrite); } } } else if (at == ArchiveType.GZip) { // Dispose the original reader reader.Dispose(); using(FileStream itemstream = File.OpenRead(input)) { using (FileStream outstream = File.Create(Path.Combine(tempdir, Path.GetFileNameWithoutExtension(input)))) { using (GZipStream gzstream = new GZipStream(itemstream, CompressionMode.Decompress)) { gzstream.CopyTo(outstream); outfile = Path.GetFullPath(Path.Combine(tempdir, Path.GetFileNameWithoutExtension(input))); } } } } } catch (Exception ex) { logger.Error(ex.ToString()); outfile = null; } finally { reader?.Dispose(); } return outfile; } #endregion #region Archive-to-Archive Handling /// /// Attempt to copy a file between archives /// /// Source archive name /// Destination archive name /// Input entry name /// Output entry name /// Logger object for file and console output /// True if the copy was a success, false otherwise public static bool CopyFileBetweenArchives(string inputArchive, string outputDirectory, string sourceEntryName, Rom destEntry, Logger logger) { string tempfile = ExtractSingleItemFromArchive(inputArchive, sourceEntryName, Path.GetTempPath(), logger); return WriteToArchive(tempfile, outputDirectory, destEntry); } /// /// Reorder all of the files in the archive based on lowercase filename /// /// Source archive name /// Logger object for file and console output /// True if the operation succeeded, false otherwise public static bool TorrentZipArchive(string inputArchive, Logger logger) { bool success = false; // If the input file doesn't exist, return if (!File.Exists(inputArchive)) { return success; } // Make sure the file is a zip file to begin with if (GetCurrentArchiveType(inputArchive, logger) != ArchiveType.Zip) { return success; } ZipArchiveStruct zas = GetZipFileInfo(inputArchive, logger); Console.WriteLine("Archive Filename: " + zas.FileName); Console.WriteLine("Archive Comment: " + zas.Comment.Length + " " + zas.Comment); Console.WriteLine("Archive Central Directory CRC: " + zas.CentralDirectoryCRC.ToString("X8")); Console.WriteLine(); Console.WriteLine("Entries:"); foreach (ZipArchiveEntryStruct zaes in zas.Entries) { Console.WriteLine("Entry Filename: " + zaes.FileName.Length + " " + zaes.FileName); Console.WriteLine("Entry Comment: " + zaes.Comment.Length + " " + zaes.Comment); Console.WriteLine("Entry Compressed Size: " + zaes.CompressedSize); Console.WriteLine("Entry Compression Method: " + zaes.CompressionMethod); Console.WriteLine("Entry CRC: " + zaes.CRC.ToString("X8")); Console.WriteLine("Entry External File Attributes: " + zaes.ExternalFileAttributes); Console.WriteLine("Entry Extra Field: " + zaes.ExtraField.Length + " " + zaes.ExtraField); Console.WriteLine("Entry General Purpose Flag: " + zaes.GeneralPurposeBitFlag); Console.WriteLine("Entry Internal File Attributes: " + zaes.InternalFileAttributes); Console.WriteLine("Entry Last Modification File Date: " + zaes.LastModFileDate); Console.WriteLine("Entry Last Modification File Time: " + zaes.LastModFileTime); Console.WriteLine("Entry Relative Offset: " + zaes.RelativeOffset); Console.WriteLine("Entry Uncompressed Size: " + zaes.UncompressedSize); Console.WriteLine("Entry Version Made By: " + zaes.VersionMadeBy); Console.WriteLine("Entry Version Needed: " + zaes.VersionNeeded); Console.WriteLine(); } Console.ReadLine(); /* ZipArchive outarchive = null; try { // If the archive doesn't exist, create it if (!File.Exists(inputArchive)) { outarchive = ZipFile.Open(inputArchive, ZipArchiveMode.Create); outarchive.Dispose(); } // Open the archive for sorting Dictionary entries = new Dictionary(); using (outarchive = ZipFile.Open(inputArchive, ZipArchiveMode.Update)) { // Get and sort the entries foreach (ZipArchiveEntry entry in outarchive.Entries) { entries.Add(entry.Name.ToLowerInvariant(), entry.Name); } } // Now write out the entries by name List keys = entries.Keys.ToList(); keys.Sort(Style.CompareNumeric); foreach (string key in keys) { Rom temp = new Rom { Machine = new Machine { Name = Path.GetFileNameWithoutExtension(inputArchive) + ".new", }, Name = entries[key], Date = "12/24/1996 11:32 PM", }; CopyFileBetweenArchives(inputArchive, Path.GetDirectoryName(inputArchive), entries[key], temp, logger); } string newfile = Path.Combine(Path.GetDirectoryName(inputArchive), Path.GetFileNameWithoutExtension(inputArchive) + ".new.zip"); File.Delete(inputArchive); File.Move(newfile, inputArchive); success = true; } catch (Exception ex) { Console.WriteLine(ex); success = false; } finally { outarchive?.Dispose(); } */ return success; } #endregion #region File Information /// /// Retrieve file information for a single file /// /// Filename to get information from /// True if MD5 hashes should not be calculated, false otherwise /// True if SHA-1 hashes should not be calcluated, false otherwise /// Populated RomData object if success, empty one on error /// Add read-offset for hash info public static Rom GetSingleFileInfo(string input, bool noMD5 = false, bool noSHA1 = false, long offset = 0) { // Add safeguard if file doesn't exist if (!File.Exists(input)) { return new Rom(); } FileInfo temp = new FileInfo(input); Rom rom = new Rom { Name = Path.GetFileName(input), Type = ItemType.Rom, HashData = new Hash { Size = temp.Length, CRC = string.Empty, MD5 = string.Empty, SHA1 = string.Empty, }, Date = temp.LastWriteTime.ToString(), }; try { using (OptimizedCRC crc = new OptimizedCRC()) using (MD5 md5 = MD5.Create()) using (SHA1 sha1 = SHA1.Create()) using (FileStream fs = File.OpenRead(input)) { // Seek to the starting position, if one is set if (offset > 0) { fs.Seek(offset, SeekOrigin.Begin); } byte[] buffer = new byte[1024]; int read; while ((read = fs.Read(buffer, 0, buffer.Length)) > 0) { crc.Update(buffer, 0, read); if (!noMD5) { md5.TransformBlock(buffer, 0, read, buffer, 0); } if (!noSHA1) { sha1.TransformBlock(buffer, 0, read, buffer, 0); } } crc.Update(buffer, 0, 0); rom.HashData.CRC = crc.Value.ToString("X8").ToLowerInvariant(); if (!noMD5) { md5.TransformFinalBlock(buffer, 0, 0); rom.HashData.MD5 = BitConverter.ToString(md5.Hash).Replace("-", "").ToLowerInvariant(); } if (!noSHA1) { sha1.TransformFinalBlock(buffer, 0, 0); rom.HashData.SHA1 = BitConverter.ToString(sha1.Hash).Replace("-", "").ToLowerInvariant(); } } } catch (IOException) { return new Rom(); } return rom; } /// /// Generate a list of RomData objects from the header values in an archive /// /// Input file to get data from /// Logger object for file and console output /// List of RomData objects representing the found data public static List GetArchiveFileInfo(string input, Logger logger) { List roms = new List(); string gamename = Path.GetFileNameWithoutExtension(input); // First get the archive type ArchiveType? at = GetCurrentArchiveType(input, logger); // If we got back null, then it's not an archive, so we we return if (at == null) { return roms; } // If we got back GZip, try to get TGZ info first else if (at == ArchiveType.GZip) { Rom possibleTgz = GetTorrentGZFileInfo(input, logger); // If it was, then add it to the outputs and continue if (possibleTgz.Name != null) { roms.Add(possibleTgz); return roms; } } IReader reader = null; try { logger.Log("Found archive of type: " + at); long size = 0; string crc = ""; // If we have a gzip file, get the crc directly if (at == ArchiveType.GZip) { // Get the CRC and size from the file using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { br.BaseStream.Seek(-8, SeekOrigin.End); byte[] headercrc = br.ReadBytes(4); crc = BitConverter.ToString(headercrc.Reverse().ToArray()).Replace("-", string.Empty).ToLowerInvariant(); byte[] headersize = br.ReadBytes(4); size = BitConverter.ToInt32(headersize.Reverse().ToArray(), 0); } } reader = ReaderFactory.Open(File.OpenRead(input)); if (at != ArchiveType.Tar) { while (reader.MoveToNextEntry()) { if (reader.Entry != null && !reader.Entry.IsDirectory) { logger.Log("Entry found: '" + reader.Entry.Key + "': " + (size == 0 ? reader.Entry.Size : size) + ", " + (crc == "" ? reader.Entry.Crc.ToString("X").ToLowerInvariant() : crc)); roms.Add(new Rom { Type = ItemType.Rom, Name = reader.Entry.Key, Machine = new Machine { Name = gamename, }, HashData = new Hash { Size = (size == 0 ? reader.Entry.Size : size), CRC = (crc == "" ? reader.Entry.Crc.ToString("X").ToLowerInvariant() : crc), }, }); } } } } catch (Exception ex) { logger.Error(ex.ToString()); } finally { reader?.Dispose(); } return roms; } /// /// Retrieve file information for a single torrent GZ file /// /// Filename to get information from /// Logger object for file and console output /// Populated RomData object if success, empty one on error public static Rom GetTorrentGZFileInfo(string input, Logger logger) { string datum = Path.GetFileName(input).ToLowerInvariant(); long filesize = new FileInfo(input).Length; // Check if the name is the right length if (!Regex.IsMatch(datum, @"^[0-9a-f]{40}\.gz")) { logger.Warning("Non SHA-1 filename found, skipping: '" + datum + "'"); return new Rom(); } // Check if the file is at least the minimum length if (filesize < 40 /* bytes */) { logger.Warning("Possibly corrupt file '" + input + "' with size " + Style.GetBytesReadable(filesize)); return new Rom(); } // Get the Romba-specific header data byte[] header; // Get preamble header for checking byte[] headermd5; // MD5 byte[] headercrc; // CRC byte[] headersz; // Int64 size using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { header = br.ReadBytes(12); headermd5 = br.ReadBytes(16); headercrc = br.ReadBytes(4); headersz = br.ReadBytes(8); } // If the header is not correct, return a blank rom bool correct = true; for (int i = 0; i < header.Length; i++) { // This is a temp fix to ignore the modification time and OS until romba can be fixed if (i == 4 || i == 5 || i == 6 || i == 7 || i == 9) { continue; } correct &= (header[i] == Constants.TorrentGZHeader[i]); } if (!correct) { return new Rom(); } // Now convert the data and get the right position string gzmd5 = BitConverter.ToString(headermd5).Replace("-", string.Empty); string gzcrc = BitConverter.ToString(headercrc).Replace("-", string.Empty); long extractedsize = BitConverter.ToInt64(headersz, 0); Rom rom = new Rom { Type = ItemType.Rom, Machine = new Machine { Name = Path.GetFileNameWithoutExtension(input).ToLowerInvariant(), }, Name = Path.GetFileNameWithoutExtension(input).ToLowerInvariant(), HashData = new Hash { Size = extractedsize, CRC = gzcrc.ToLowerInvariant(), MD5 = gzmd5.ToLowerInvariant(), SHA1 = Path.GetFileNameWithoutExtension(input).ToLowerInvariant(), }, }; return rom; } /// /// Returns the archive type of an input file /// /// Input file to check /// Logger object for file and console output /// ArchiveType of inputted file (null on error) public static ArchiveType? GetCurrentArchiveType(string input, Logger logger) { ArchiveType? outtype = null; // First line of defense is going to be the extension, for better or worse string ext = Path.GetExtension(input).ToLowerInvariant(); if (ext.StartsWith(".")) { ext = ext.Substring(1); } if (ext != "7z" && ext != "gz" && ext != "lzma" && ext != "rar" && ext != "rev" && ext != "r00" && ext != "r01" && ext != "tar" && ext != "tgz" && ext != "tlz" && ext != "zip" && ext != "zipx") { return outtype; } // Read the first bytes of the file and get the magic number try { byte[] magic = new byte[8]; using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { magic = br.ReadBytes(8); } // Convert it to an uppercase string string mstr = string.Empty; for (int i = 0; i < magic.Length; i++) { mstr += BitConverter.ToString(new byte[] { magic[i] }); } mstr = mstr.ToUpperInvariant(); // Now try to match it to a known signature if (mstr.StartsWith(Constants.SevenZipSig)) { outtype = ArchiveType.SevenZip; } else if (mstr.StartsWith(Constants.GzSig)) { outtype = ArchiveType.GZip; } else if (mstr.StartsWith(Constants.RarSig) || mstr.StartsWith(Constants.RarFiveSig)) { outtype = ArchiveType.Rar; } else if (mstr.StartsWith(Constants.TarSig) || mstr.StartsWith(Constants.TarZeroSig)) { outtype = ArchiveType.Tar; } else if (mstr.StartsWith(Constants.ZipSig) || mstr.StartsWith(Constants.ZipSigEmpty) || mstr.StartsWith(Constants.ZipSigSpanned)) { outtype = ArchiveType.Zip; } } catch (Exception) { // Don't log file open errors } return outtype; } /// /// Get if the current file should be scanned internally and externally /// /// Name of the input file to check /// User-defined scan level for 7z archives /// User-defined scan level for GZ archives /// User-defined scan level for RAR archives /// User-defined scan level for Zip archives /// Logger object for file and console output /// Output parameter determining if file should be processed externally /// Output parameter determining if file should be processed internally public static void GetInternalExternalProcess(string input, ArchiveScanLevel sevenzip, ArchiveScanLevel gzip, ArchiveScanLevel rar, ArchiveScanLevel zip, Logger logger, out bool shouldExternalProcess, out bool shouldInternalProcess) { shouldExternalProcess = true; shouldInternalProcess = true; ArchiveType? archiveType = FileTools.GetCurrentArchiveType(input, logger); switch (archiveType) { case null: shouldExternalProcess = true; shouldInternalProcess = false; break; case ArchiveType.GZip: shouldExternalProcess = (gzip != ArchiveScanLevel.Internal); shouldInternalProcess = (gzip != ArchiveScanLevel.External); break; case ArchiveType.Rar: shouldExternalProcess = (rar != ArchiveScanLevel.Internal); shouldInternalProcess = (rar != ArchiveScanLevel.External); break; case ArchiveType.SevenZip: shouldExternalProcess = (sevenzip != ArchiveScanLevel.Internal); shouldInternalProcess = (sevenzip != ArchiveScanLevel.External); break; case ArchiveType.Zip: shouldExternalProcess = (zip != ArchiveScanLevel.Internal); shouldInternalProcess = (zip != ArchiveScanLevel.External); break; } } /// /// Read the information from an input zip file /// /// Name of the input file to check /// Logger object for file and console output /// /// This does not do any handling for Zip64 currently /// https://pkware.cachefly.net/webdocs/casestudies/APPNOTE.TXT /// public static ZipArchiveStruct GetZipFileInfo(string input, Logger logger) { // Create the zip archive struct to hold all of the information ZipArchiveStruct zas = new ZipArchiveStruct { FileName = Path.GetFileNameWithoutExtension(input), Entries = new List(), }; int position = -1; // Seek backwards to find the EOCD pattern using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { int sig = 101010256; int read = 0; int index = -5; while (sig != read && (-index) < new FileInfo(input).Length) { br.BaseStream.Seek(index, SeekOrigin.End); read = br.ReadInt32(); index--; } // If we found the signature, then set the correct position if (sig == read) { position = (int)br.BaseStream.Position - 4; } } // If we found the EOCD, get all of the information out of that area if (position != -1) { zas.EOCDOffset = (int)position; using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { br.BaseStream.Seek(position, SeekOrigin.Begin); br.ReadInt32(); // end of central dir signature br.ReadInt16(); // number of this disk br.ReadInt16(); // number of the disk with the start of the central directory br.ReadInt16(); // total number of entries in the central directory on this disk br.ReadInt16(); // total number of entries in the central directory br.ReadInt32(); // size of the central directory position = br.ReadInt32(); // offset of start of central directory with respect to the starting disk number int commentlength = br.ReadInt16(); zas.Comment = Style.ConvertHex(BitConverter.ToString(br.ReadBytes(commentlength))); } } // If we found the SOCD, get all of the information out of that area if (position != -1 && position != zas.EOCDOffset) { zas.SOCDOffset = position; using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { int temp = 0; while (temp != 84233040 /* digital signature */ && temp != 101010256 /* eocd */) { ZipArchiveEntryStruct zaes = new ZipArchiveEntryStruct(); br.BaseStream.Seek(position, SeekOrigin.Begin); br.ReadInt32(); // central file header signature zaes.VersionMadeBy = (ArchiveVersion)br.ReadInt16(); zaes.VersionNeeded = (ArchiveVersion)br.ReadInt16(); zaes.GeneralPurposeBitFlag = (GeneralPurposeBitFlag)br.ReadInt16(); zaes.CompressionMethod = (CompressionMethod)br.ReadInt16(); zaes.LastModFileTime = br.ReadUInt16(); zaes.LastModFileDate = br.ReadUInt16(); zaes.CRC = br.ReadUInt32(); zaes.CompressedSize = br.ReadUInt32(); zaes.UncompressedSize = br.ReadUInt32(); int fileNameLength = br.ReadInt16(); int extraFieldLength = br.ReadInt16(); int fileCommentLength = br.ReadInt16(); br.ReadInt16(); // disk number start zaes.InternalFileAttributes = (InternalFileAttributes)br.ReadInt16(); zaes.ExternalFileAttributes = br.ReadInt32(); zaes.RelativeOffset = br.ReadInt32(); zaes.FileName = Style.ConvertHex(BitConverter.ToString(br.ReadBytes(fileNameLength))); zaes.ExtraField = Style.ConvertHex(BitConverter.ToString(br.ReadBytes(extraFieldLength))); zaes.Comment = Style.ConvertHex(BitConverter.ToString(br.ReadBytes(fileCommentLength))); position += 46 + fileNameLength + extraFieldLength + fileCommentLength; temp = br.ReadInt32(); zas.Entries.Add(zaes); } } } // Finally, get a hash of the entire central directory (between SOCD and EOCD) if (zas.SOCDOffset > 0 && zas.EOCDOffset > 0) { using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { br.BaseStream.Seek(zas.SOCDOffset, SeekOrigin.Begin); byte[] cd = br.ReadBytes(zas.EOCDOffset - zas.SOCDOffset); OptimizedCRC ocrc = new OptimizedCRC(); ocrc.Update(cd, 0, cd.Length); zas.CentralDirectoryCRC = ocrc.Value; } } return zas; } /// /// Read the information from an input 7z file /// /// Name of the input file to check /// Logger object for file and console output /// http://cpansearch.perl.org/src/BJOERN/Compress-Deflate7-1.0/7zip/DOC/7zFormat.txt public static void GetSevenZipFIleInfo(string input, Logger logger) { using (BinaryReader br = new BinaryReader(File.OpenRead(input))) { br.ReadBytes(6); // BYTE kSignature[6] = {'7', 'z', 0xBC, 0xAF, 0x27, 0x1C}; logger.User("ArchiveVersion (Major.Minor): " + br.ReadByte() + "." + br.ReadByte()); logger.User("StartHeaderCRC: " + br.ReadUInt32()); logger.User("StartHeader (NextHeaderOffset, NextHeaderSize, NextHeaderCRC)" + br.ReadUInt64() + ", " + br.ReadUInt64() + ", " + br.ReadUInt32()); } } #endregion #region File Manipulation /// /// Remove an arbitrary number of bytes from the inputted file /// /// File to be cropped /// Outputted file /// Bytes to be removed from head of file /// Bytes to be removed from tail of file public static void RemoveBytesFromFile(string input, string output, long bytesToRemoveFromHead, long bytesToRemoveFromTail) { // If any of the inputs are invalid, skip if (!File.Exists(input) || new FileInfo(input).Length <= (bytesToRemoveFromHead + bytesToRemoveFromTail)) { return; } // Read the input file and write to the fail using (BinaryReader br = new BinaryReader(File.OpenRead(input))) using (BinaryWriter bw = new BinaryWriter(File.OpenWrite(output))) { int bufferSize = 1024; long adjustedLength = br.BaseStream.Length - bytesToRemoveFromTail; // Seek to the correct position br.BaseStream.Seek((bytesToRemoveFromHead < 0 ? 0 : bytesToRemoveFromHead), SeekOrigin.Begin); // Now read the file in chunks and write out byte[] buffer = new byte[bufferSize]; while (br.BaseStream.Position <= (adjustedLength - bufferSize)) { buffer = br.ReadBytes(bufferSize); bw.Write(buffer); } // For the final chunk, if any, write out only that number of bytes int length = (int)(adjustedLength - br.BaseStream.Position); buffer = new byte[length]; buffer = br.ReadBytes(length); bw.Write(buffer); } } /// /// Add an aribtrary number of bytes to the inputted file /// /// File to be appended to /// Outputted file /// String representing bytes to be added to head of file /// String representing bytes to be added to tail of file public static void AppendBytesToFile(string input, string output, string bytesToAddToHead, string bytesToAddToTail) { // Source: http://stackoverflow.com/questions/311165/how-do-you-convert-byte-array-to-hexadecimal-string-and-vice-versa byte[] bytesToAddToHeadArray = new byte[bytesToAddToHead.Length / 2]; for (int i = 0; i < bytesToAddToHead.Length; i += 2) { bytesToAddToHeadArray[i / 2] = Convert.ToByte(bytesToAddToHead.Substring(i, 2), 16); } byte[] bytesToAddToTailArray = new byte[bytesToAddToTail.Length / 2]; for (int i = 0; i < bytesToAddToTail.Length; i += 2) { bytesToAddToTailArray[i / 2] = Convert.ToByte(bytesToAddToTail.Substring(i, 2), 16); } AppendBytesToFile(input, output, bytesToAddToHeadArray, bytesToAddToTailArray); } /// /// Add an aribtrary number of bytes to the inputted file /// /// File to be appended to /// Outputted file /// Bytes to be added to head of file /// Bytes to be added to tail of file public static void AppendBytesToFile(string input, string output, byte[] bytesToAddToHead, byte[] bytesToAddToTail) { // If any of the inputs are invalid, skip if (!File.Exists(input)) { return; } using (BinaryReader br = new BinaryReader(File.OpenRead(input))) using (BinaryWriter bw = new BinaryWriter(File.OpenWrite(output))) { if (bytesToAddToHead.Count() > 0) { bw.Write(bytesToAddToHead); } int bufferSize = 1024; // Now read the file in chunks and write out byte[] buffer = new byte[bufferSize]; while (br.BaseStream.Position <= (br.BaseStream.Length - bufferSize)) { buffer = br.ReadBytes(bufferSize); bw.Write(buffer); } // For the final chunk, if any, write out only that number of bytes int length = (int)(br.BaseStream.Length - br.BaseStream.Position); buffer = new byte[length]; buffer = br.ReadBytes(length); bw.Write(buffer); if (bytesToAddToTail.Count() > 0) { bw.Write(bytesToAddToTail); } } } /// /// Copy a file to a new location, creating directories as needed /// /// Input filename /// Output filename public static void CopyFileToNewLocation(string input, string output) { if (File.Exists(input) && !File.Exists(output)) { if (!Directory.Exists(Path.GetDirectoryName(output))) { Directory.CreateDirectory(Path.GetDirectoryName(output)); } File.Copy(input, output); } } /// /// Cleans out the temporary directory /// /// Name of the directory to clean out public static void CleanDirectory(string dirname) { foreach (string file in Directory.EnumerateFiles(dirname, "*", SearchOption.TopDirectoryOnly)) { try { File.Delete(file); } catch { } } foreach (string dir in Directory.EnumerateDirectories(dirname, "*", SearchOption.TopDirectoryOnly)) { try { Directory.Delete(dir, true); } catch { } } } #endregion } }