/************************************************************************* * ModernUO * * Copyright 2019-2023 - ModernUO Development Team * * Email: hi@modernuo.com * * File: BinaryFileReader.cs * * * * This program is free software: you can redistribute it and/or modify * * it under the terms of the GNU General Public License as published by * * the Free Software Foundation, either version 3 of the License, or * * (at your option) any later version. * * * * You should have received a copy of the GNU General Public License * * along with this program. If not, see . * *************************************************************************/ using System; using System.Collections.Generic; using System.IO; using System.Runtime.CompilerServices; using System.Text; using Server.Buffers; using Server.Collections; using Server.Logging; using Server.Text; namespace Server; public class BinaryFileReader : IGenericReader, IDisposable { private static readonly ILogger logger = LogFactory.GetLogger(typeof(BinaryFileReader)); private Dictionary _typesDb; private BinaryReader _reader; private Encoding _encoding; public BinaryFileReader(BinaryReader br, Dictionary typesDb = null, Encoding encoding = null) { _reader = br; _encoding = encoding ?? TextEncoding.UTF8; _typesDb = typesDb; } public BinaryFileReader(Stream stream, Dictionary typesDb = null, Encoding encoding = null) : this(new BinaryReader(stream), typesDb, encoding) { } public long Position => _reader.BaseStream.Position; [MethodImpl(MethodImplOptions.AggressiveInlining)] public void Close() => _reader.Close(); public DateTime LastSerialized { get; init; } [MethodImpl(MethodImplOptions.AggressiveInlining)] public string ReadString(bool intern = false) => ReadBool() ? ReadStringRaw(intern) : null; public string ReadStringRaw(bool intern = false) { var length = ((IGenericReader)this).ReadEncodedInt(); if (length <= 0) { return "".Intern(); } byte[] buffer = STArrayPool.Shared.Rent(length); var strBuffer = buffer.AsSpan(0, length); _reader.Read(strBuffer); var str = TextEncoding.GetString(strBuffer, _encoding); STArrayPool.Shared.Return(buffer); return intern ? str.Intern() : str; } [MethodImpl(MethodImplOptions.AggressiveInlining)] public long ReadLong() => _reader.ReadInt64(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public ulong ReadULong() => _reader.ReadUInt64(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public int ReadInt() => _reader.ReadInt32(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public uint ReadUInt() => _reader.ReadUInt32(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public short ReadShort() => _reader.ReadInt16(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public ushort ReadUShort() => _reader.ReadUInt16(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public double ReadDouble() => _reader.ReadDouble(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public float ReadFloat() => _reader.ReadSingle(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public byte ReadByte() => _reader.ReadByte(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public sbyte ReadSByte() => _reader.ReadSByte(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public bool ReadBool() => _reader.ReadBoolean(); [MethodImpl(MethodImplOptions.AggressiveInlining)] public Serial ReadSerial() => (Serial)_reader.ReadUInt32(); public Type ReadType() => ReadByte() switch { 0 => null, 1 => AssemblyHandler.FindTypeByFullName(ReadStringRaw()), // Backward compatibility 2 => ReadTypeByHash() }; public Type ReadTypeByHash() { var hash = ReadULong(); var t = AssemblyHandler.FindTypeByHash(hash); if (t != null) { return t; } if (_typesDb == null) { logger.Error( new Exception($"The file SerializedTypes.db was not loaded. Type hash '{hash}' could not be found."), "Invalid {Hash} at position {Position}", hash, Position ); return null; } if (!_typesDb.TryGetValue(hash, out var typeName)) { logger.Error( new Exception($"Type hash '{hash}' is not present in the serialized types database."), "Invalid type hash {Hash} at position {Position}", hash, Position ); return null; } t = AssemblyHandler.FindTypeByFullName(typeName, false); if (t == null) { logger.Error( new Exception($"Type '{typeName}' was not found."), "Type {Type} was not found.", typeName ); } return t; } [MethodImpl(MethodImplOptions.AggressiveInlining)] public int Read(Span buffer) => _reader.Read(buffer); [MethodImpl(MethodImplOptions.AggressiveInlining)] public BitArray ReadBitArray() { var length = ((IGenericReader)this).ReadEncodedInt(); // BinaryReader doesn't expose a Span slice of the buffer, so we use a custom ctor return new BitArray(_reader, length); } [MethodImpl(MethodImplOptions.AggressiveInlining)] public long Seek(long offset, SeekOrigin origin) => _reader.BaseStream.Seek(offset, origin); [MethodImpl(MethodImplOptions.AggressiveInlining)] public void Dispose() => Close(); }