current/DataAccess/Access_OniArchive.pas

unit Access_OniArchive;
interface

uses DataAccess, Classes, TypeDefs;

type
  TAccess_OniArchive = class(TDataAccess)
  private
    Fdat_file:           TFileStream;
    Fraw_file:           TFileStream;
    Fsep_file:           TFileStream;
    Fdat_files:          TFiles;
    Fdat_extensionsmap:  TExtensionsMap;
  protected
  public
    constructor Create(DatFilename: String; ConnectionID: Integer; var Msg: TStatusMessages); override;
    procedure Close; override;

    function GetFileInfo(FileID: Integer): TFileInfo; override;
    function GetFilesList(Ext: String; Pattern: String;
      NoEmptyFiles: Boolean; SortType: TSortType): TStrings; override;
    function GetFileCount: Integer; override;
    function GetExtensionsList(ExtListFormat: TExtensionFormat): TStrings; override;

    procedure LoadDatFile(FileID: Integer; var Target: TStream); overload; override;
    procedure UpdateDatFile(FileID: Integer; Src: TStream); overload; override;
    procedure LoadDatFilePart(FileID, Offset, Size: Integer; var Target: TStream); overload; override;
    procedure UpdateDatFilePart(FileID, Offset, Size: Integer; Src: TStream); overload; override;

    function GetDatLinks(FileID: Integer): TDatLinkList; override;
    function GetDatLink(FileID, DatOffset: Integer): TDatLink; override;
    function GetRawList(FileID: Integer): TRawDataList; override;
    function GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo; override;
    function GetRawsForType(RawType: String): TRawDataList; override;

    procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream); overload;
    procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer); overload;
    procedure LoadRawFile(FileID, DatOffset: Integer; var Target: TStream); overload; override;
    procedure UpdateRawFile(FileID, DatOffset: Integer; Src: TStream); overload; override;
    procedure LoadRawFilePart(FileID, DatOffset, Offset, Size: Integer; var Target: TStream); overload; override;
    procedure UpdateRawFilePart(FileID, DatOffset, Offset, Size: Integer; Src: TStream); overload; override;

    function AppendRawFile(LocSep: Boolean; Src: TStream): Integer; overload; override;
  published
  end;

implementation

uses
  SysUtils, StrUtils, Data, Functions, RawList, DatLinks, Math;


(*
================================================================================
                      Implementation of  TOniDataDat
*)


constructor TAccess_OniArchive.Create(DatFilename: String; ConnectionID: Integer; var Msg: TStatusMessages);
var
  i: Integer;
  header_pc, header_mac, header_macbeta: Boolean;
  Fdat_header:   THeader;
  Fdat_filesmap: TFilesMap;
  Fdat_namedfilesmap: TNamedFilesMap;
begin
  Msg := SM_UnknownError;
  if not FileExists(DatFilename) then
  begin
    Msg := SM_FileNotFound;
    Exit;
  end;
  FFileName := DatFilename;
  Fdat_file := TFileStream.Create(FFileName, fmOpenRead);
  Fdat_file.Read(Fdat_header, SizeOf(Fdat_header));
  header_pc  := True;
  header_mac := True;
  header_macbeta := True;
  for i := 0 to High(Fdat_header.GlobalIdent) do
    if Fdat_header.GlobalIdent[i] <> HeaderGlobalIdent[i] then
    begin
      Msg := SM_IncompatibleFile;
      Exit;
    end;

  for i := 0 to High(Fdat_header.OSIdent) do
  begin
    if Fdat_header.OSIdent[i] <> HeaderOSIdentWin[i] then
      header_pc := False;
    if Fdat_header.OSIdent[i] <> HeaderOSIdentMac[i] then
      header_mac := False;
    if Fdat_header.OSIdent[i] <> HeaderOSIdentMacBeta[i] then
      header_macbeta := False;
  end;
  if not (header_pc xor header_mac xor header_macbeta) then
  begin
    Msg := SM_IncompatibleFile;
    Exit;
  end
  else
  begin
    if (header_pc and not header_mac and not header_macbeta) then
      FDataOS := DOS_WIN
    else if (not header_pc and header_mac and not header_macbeta) then
      FDataOS := DOS_MAC
    else if (not header_pc and not header_mac and header_macbeta) then
      FDataOS := DOS_MACBETA;
  end;
  SetLength(Fdat_filesmap, Fdat_header.Files);
  SetLength(Fdat_files, Fdat_header.Files);
  for i := 0 to Fdat_header.Files - 1 do
    Fdat_file.Read(Fdat_filesmap[i], SizeOf(Fdat_filesmap[i]));
  for i := 0 to Fdat_header.Files - 1 do
  begin
    Fdat_files[i].ID := i;
    Fdat_files[i].Extension := Fdat_filesmap[i].Extension;
    Fdat_files[i].Extension := ReverseString(Fdat_files[i].Extension);
    Fdat_files[i].Size      := Fdat_filesmap[i].FileSize;
    Fdat_files[i].FileType  := Fdat_filesmap[i].FileType;
    Fdat_files[i].DatAddr   := Fdat_filesmap[i].DataAddr - 8 + Fdat_header.DataAddr;
    if (Fdat_filesmap[i].FileType and $01) = 0 then
    begin
      Fdat_file.Seek(Fdat_filesmap[i].NameAddr + Fdat_header.NamesAddr, soFromBeginning);
      SetLength(Fdat_files[i].Name, 100);
      Fdat_file.Read(Fdat_files[i].Name[1], 100);
      Fdat_files[i].Name := MidStr(Fdat_files[i].Name, 1 + 4, Pos(
        #0, Fdat_files[i].Name) - 1 - 4);
    end
    else
    begin
      Fdat_files[i].Name := '';
    end;
  end;
  Fdat_file.Seek($40 + Fdat_header.Files * $14, soFromBeginning);
  SetLength(Fdat_namedfilesmap, Fdat_header.NamedFiles);
  for i := 0 to Fdat_header.NamedFiles - 1 do
    Fdat_file.Read(Fdat_namedfilesmap[i], SizeOf(Fdat_namedfilesmap[i]));

  Fdat_file.Seek($40 + Fdat_header.Files * $14 + Fdat_header.NamedFiles * $8, soFromBeginning);
  SetLength(Fdat_extensionsmap, Fdat_header.Extensions);
  for i := 0 to Fdat_header.Extensions - 1 do
    Fdat_file.Read(Fdat_extensionsmap[i], SizeOf(Fdat_extensionsmap[i]));

  Fdat_file.Seek(Fdat_files[0].DatAddr + 7, soFromBeginning);
  Fdat_file.Read(FLevelNumber, 1);
  FLevelNumber := FLevelNumber div 2;

  Fraw_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.raw'),
    fmOpenReadWrite);
  if not (FDataOS = DOS_WIN) then
    Fsep_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.sep'),
      fmOpenReadWrite);

  Msg := SM_OK;
  FBackend := DB_ONI;
  FConnectionID := ConnectionID;
  FChangeRights := [CR_EditDat, CR_EditRaw, CR_AppendRaw];

  inherited;
end;


procedure TAccess_OniArchive.Close;
begin
  if Assigned(Fdat_file) then
    Fdat_file.Free;
  if Assigned(Fraw_file) then
    Fraw_file.Free;
  if Assigned(Fsep_file) then
    Fsep_file.Free;
  Self.Free;
end;


function TAccess_OniArchive.GetFileInfo(fileid: Integer): TFileInfo;
begin
  if fileid = -1 then
  begin
    Result := inherited GetFileInfo(fileid);
    Exit;
  end;
  if fileid < Self.GetFileCount then
    Result    := Fdat_files[fileid]
  else
    Result.ID := -1;
end;


function TAccess_OniArchive.GetFilesList(ext: String; pattern: String;
  NoEmptyFiles: Boolean; SortType: TSortType): TStrings;
var
  i:      Integer;
  list:   TStringList;
  id, name, extension: String;
  fields: TStrings;

  procedure getfields;
  begin
    fields.CommaText := StringReplace(AnsiQuotedStr(list.Strings[i], '"'), ';', '","', [rfReplaceAll]);
    if SortType in [ST_IDAsc, ST_IDDesc] then
    begin
      id := fields.Strings[0];
      name := fields.Strings[1];
      extension := fields.Strings[2];
    end;
    if SortType in [ST_NameAsc, ST_NameDesc] then
    begin
      id := fields.Strings[1];
      name := fields.Strings[0];
      extension := fields.Strings[2];
    end;
    if SortType in [ST_ExtAsc, ST_ExtDesc] then
    begin
      id := fields.Strings[1];
      name := fields.Strings[2];
      extension := fields.Strings[0];
    end;
    if SortType in [ST_ExtNameAsc, ST_ExtNameDesc] then
    begin
      id := fields.Strings[2];
      name := fields.Strings[1];
      extension := fields.Strings[0];
    end;
  end;

begin
  list := TStringList.Create;
  list.Sorted := True;
  if ext = '*' then
    ext := '';
  for i := 0 to GetFileCount - 1 do
  begin
    if ((Length(ext) = 0) or (Pos(Fdat_files[i].Extension, ext) > 0)) and
      ((Length(pattern) = 0) or
      (Pos(UpperCase(pattern), UpperCase(Fdat_files[i].Name)) > 0)) then
    begin
      if (NoEmptyFiles = False) or ((Fdat_files[i].FileType and $02) = 0) then
      begin
        id := FormatNumber(Fdat_files[i].ID, 5, '0');
        name := Fdat_files[i].Name;
        extension := Fdat_files[i].Extension;

        case SortType of
          ST_IDAsc, ST_IDDesc:     list.Add(id + ';' + name + ';' + extension);
          ST_NameAsc, ST_NameDesc: list.Add(name + ';' + id + ';' + extension);
          ST_ExtAsc, ST_ExtDesc:   list.Add(extension + ';' + id + ';' + name);
          ST_ExtNameAsc, ST_ExtNameDesc: list.Add(name + ';' + extension + ';' + id);
        end;
      end;
    end;
  end;
  if not Assigned(Result) then
    Result := TStringList.Create;
  if list.Count > 0 then
  begin
    fields := TStringList.Create;
    if SortType in [ST_IDAsc, ST_NameAsc, ST_ExtAsc, ST_ExtNameAsc] then
      for i := 0 to list.Count - 1 do
      begin
        getfields;
        Result.Add(id + '-' + name + '.' + extension);
      end
    else
      for i := list.Count - 1 downto 0 do
      begin
        getfields;
        Result.Add(id + '-' + name + '.' + extension);
      end;
    fields.Free;
  end;
  list.Free;
end;


function TAccess_OniArchive.GetFileCount: Integer;
begin
  Result := Length(Fdat_files);
end;


function TAccess_OniArchive.GetExtensionsList(ExtListFormat: TExtensionFormat): TStrings;
var
  i: Integer;
begin
  if not Assigned(Result) then
    Result := TStringList.Create;
  if Result is TStringList then
    TStringList(Result).Sorted := True;
  for i := 0 to Length(Fdat_extensionsmap) - 1 do
  begin
    with Fdat_extensionsmap[i] do
    begin
      case ExtListFormat of
        EF_ExtOnly:
          Result.Add(Extension[3] + Extension[2] + Extension[1] + Extension[0]);
        EF_ExtCount:
          Result.Add(Extension[3] + Extension[2] + Extension[1] + Extension[0] +
                ' (' + IntToStr(ExtCount) + ')');
      end;
    end;
  end;
end;


procedure TAccess_OniArchive.LoadDatFile(FileID: Integer; var Target: TStream);
var
  streampos: Integer;
begin
  if fileid < GetFileCount then
  begin
    if not Assigned(Target) then
      Target := TMemoryStream.Create;
    if GetFileInfo(FileID).Size > 0 then
    begin
      Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
      streampos := Target.Position;
      Target.CopyFrom(Fdat_file, Fdat_files[fileid].Size);
      Target.Seek(streampos, soFromBeginning);
    end;
  end;
end;

procedure TAccess_OniArchive.UpdateDatFile(FileID: Integer; Src: TStream);
begin
  if fileid < GetFileCount then
  begin
    Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
    Fdat_file.CopyFrom(Src, Fdat_files[fileid].Size);
  end;
end;

procedure TAccess_OniArchive.LoadDatFilePart(FileID, Offset, Size: Integer; var Target: TStream);
var
  streampos: Integer;
begin
  if fileid < GetFileCount then
  begin
    if not Assigned(Target) then
      Target := TMemoryStream.Create;
    Fdat_file.Seek(Fdat_files[fileid].DatAddr + offset, soFromBeginning);
    streampos := Target.Position;
    Target.CopyFrom(Fdat_file, size);
    Target.Seek(streampos, soFromBeginning);
  end;
end;

procedure TAccess_OniArchive.UpdateDatFilePart(FileID, Offset, Size: Integer; Src: TStream);
begin
  if fileid < GetFileCount then
  begin
    Fdat_file.Seek(Fdat_files[fileid].DatAddr + offset, soFromBeginning);
    Fdat_file.CopyFrom(Src, Size);
  end;
end;


function TAccess_OniArchive.GetDatLink(FileID, DatOffset: Integer): TDatLink;
var
  link: Integer;
begin
  Result := DatLinksManager.GetDatLink(FConnectionID, FileID, DatOffset);
  LoadDatFilePart(fileid, Result.SrcOffset, 4, @link);
  if link > 0 then
    Result.DestID := link div 256
  else
    Result.DestID := -1;
end;


function TAccess_OniArchive.GetDatLinks(FileID: Integer): TDatLinkList;
var
  i: Integer;
  link: Integer;
begin
  Result := DatLinksManager.GetDatLinks(FConnectionID, FileID);
  if Length(Result) > 0 then
  begin
    for i := 0 to High(Result) do
    begin
      LoadDatFilePart(fileid, Result[i].SrcOffset, 4, @link);
      if link > 0 then
        Result[i].DestID := link div 256
      else
        Result[i].DestID := -1;
    end;
  end;
end;


function TAccess_OniArchive.GetRawList(FileID: Integer): TRawDataList;
begin
  Result := RawLists.GetRawList(FConnectionID, FileID);
end;


function TAccess_OniArchive.GetRawsForType(RawType: String): TRawDataList;
var
  i, j: Integer;
  dats: TStrings;
  list: TRawDataList;
begin
  dats := nil;
  dats := GetFilesList(MidStr(RawType, 1, 4), '', True, ST_IDAsc);
  for i := 0 to dats.Count - 1 do
  begin
    list := GetRawList(StrToInt(MidStr(dats.Strings[i], 1, 5)));
    for j := 0 to Length(list) - 1 do
    begin
      if (list[j].RawType = RawType) and (list[j].RawSize > 0) then
      begin
        SetLength(Result, Length(Result)+1);
        Result[High(Result)] := list[j];
      end;
    end;
  end;
end;


function TAccess_OniArchive.GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo;
begin
  Result := RawLists.GetRawInfo(FConnectionID, FileID, DatOffset);
end;


procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream);
begin
  if not Assigned(Target) then
    Target := TMemoryStream.Create;
  if not LocSep then
  begin
    if RawAddr <= Fraw_file.Size then
    begin
      Fraw_file.Seek(RawAddr, soFromBeginning);
      Target.CopyFrom(Fraw_file, size);
      Target.Seek(0, soFromBeginning);
    end;
  end
  else
  begin
    if RawAddr <= Fsep_file.Size then
    begin
      Fsep_file.Seek(RawAddr, soFromBeginning);
      Target.CopyFrom(Fsep_file, size);
      Target.Seek(0, soFromBeginning);
    end;
  end;
end;

procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer);
var
  data: TStream;
begin
  data := nil;
  LoadRawOffset(LocSep, RawAddr, Size, data);
  data.Read(Target^, Size);
  data.Free;
end;

procedure TAccess_OniArchive.LoadRawFile(FileID, DatOffset: Integer; var Target: TStream);
var
  raw_info: TRawDataInfo;
  streampos: Integer;
begin
  if not Assigned(Target) then
    Target := TMemoryStream.Create;
  if fileid < GetFileCount then
  begin
    raw_info := Self.GetRawInfo(FileID, DatOffset);
    if not raw_info.LocSep then
    begin
      Fraw_file.Seek(raw_info.RawAddr, soFromBeginning);
      streampos := Target.Position;
      Target.CopyFrom(Fraw_file, raw_info.RawSize);
      Target.Seek(streampos, soFromBeginning);
    end
    else
    begin
      Fsep_file.Seek(raw_info.RawAddr, soFromBeginning);
      streampos := Target.Position;
      Target.CopyFrom(Fsep_file, raw_info.RawSize);
      Target.Seek(streampos, soFromBeginning);
    end;
  end;
end;

procedure TAccess_OniArchive.UpdateRawFile(FileID, DatOffset: Integer; Src: TStream);
var
  raw_info: TRawDataInfo;
begin
  if fileid < GetFileCount then
  begin
    raw_info := GetRawInfo(FileID, DatOffset);
    if not raw_info.LocSep then
    begin
      Fraw_file.Seek(raw_info.RawAddr, soFromBeginning);
      Fraw_file.CopyFrom(Src, Min(raw_info.RawSize, Src.Size));
    end
    else
    begin
      Fsep_file.Seek(raw_info.RawAddr, soFromBeginning);
      Fsep_file.CopyFrom(Src, raw_info.RawSize);
    end;
  end;
end;

procedure TAccess_OniArchive.LoadRawFilePart(FileID, DatOffset, Offset, Size: Integer; var Target: TStream);
var
  Data: TStream;
  streampos: Integer;
begin
  if not Assigned(Target) then
    Target := TMemoryStream.Create;
  if fileid < Self.GetFileCount then
  begin
    data := nil;
    LoadRawFile(FileID, DatOffset, Data);
    Data.Seek(Offset, soFromBeginning);
    streampos := Target.Position;
    Target.CopyFrom(Data, Size);
    Target.Seek(streampos, soFromBeginning);
  end;
end;


procedure TAccess_OniArchive.UpdateRawFilePart(FileID, DatOffset, Offset, Size: Integer; Src: TStream);
var
  raw_info: TRawDataInfo;
begin
  if fileid < GetFileCount then
  begin
    raw_info := GetRawInfo(FileID, DatOffset);
    if not raw_info.LocSep then
    begin
      Fraw_file.Seek(raw_info.RawAddr + Offset, soFromBeginning);
      Fraw_file.CopyFrom(Src, Size);
    end
    else
    begin
      Fsep_file.Seek(raw_info.RawAddr + Offset, soFromBeginning);
      Fsep_file.CopyFrom(Src, Size);
    end;
  end;
end;

function TAccess_OniArchive.AppendRawFile(LocSep: Boolean; Src: TStream): Integer;
const
  EmptyBytes: Array[0..31] of Byte = (
      0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 );
begin
  if not LocSep then
  begin
    if (Fraw_file.Size mod 32) > 0 then
      Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
    Result := Fraw_file.Size;
    Fraw_file.Seek(0, soFromEnd);
    Fraw_file.CopyFrom(Src, Src.Size);
    if (Fraw_file.Size mod 32) > 0 then
      Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
  end
  else
  begin
    if (Fsep_file.Size mod 32) > 0 then
      Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
    Result := Fsep_file.Size;
    Fsep_file.Seek(0, soFromEnd);
    Fsep_file.CopyFrom(Src, Src.Size);
    if (Fsep_file.Size mod 32) > 0 then
      Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
  end;
end;

end.
Revision:	248
Committed:	Mon Nov 26 11:02:28 2007 UTC (17 years, 10 months ago) by alloc
Content type:	text/x-pascal
File size:	17653 byte(s)
Log Message:
#	Content
1	unit Access_OniArchive;
2	interface
3
4	uses DataAccess, Classes, TypeDefs;
5
6	type
7	TAccess_OniArchive = class(TDataAccess)
8	private
9	Fdat_file: TFileStream;
10	Fraw_file: TFileStream;
11	Fsep_file: TFileStream;
12	Fdat_files: TFiles;
13	Fdat_extensionsmap: TExtensionsMap;
14	protected
15	public
16	constructor Create(DatFilename: String; ConnectionID: Integer; var Msg: TStatusMessages); override;
17	procedure Close; override;
18
19	function GetFileInfo(FileID: Integer): TFileInfo; override;
20	function GetFilesList(Ext: String; Pattern: String;
21	NoEmptyFiles: Boolean; SortType: TSortType): TStrings; override;
22	function GetFileCount: Integer; override;
23	function GetExtensionsList(ExtListFormat: TExtensionFormat): TStrings; override;
24
25	procedure LoadDatFile(FileID: Integer; var Target: TStream); overload; override;
26	procedure UpdateDatFile(FileID: Integer; Src: TStream); overload; override;
27	procedure LoadDatFilePart(FileID, Offset, Size: Integer; var Target: TStream); overload; override;
28	procedure UpdateDatFilePart(FileID, Offset, Size: Integer; Src: TStream); overload; override;
29
30	function GetDatLinks(FileID: Integer): TDatLinkList; override;
31	function GetDatLink(FileID, DatOffset: Integer): TDatLink; override;
32	function GetRawList(FileID: Integer): TRawDataList; override;
33	function GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo; override;
34	function GetRawsForType(RawType: String): TRawDataList; override;
35
36	procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream); overload;
37	procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer); overload;
38	procedure LoadRawFile(FileID, DatOffset: Integer; var Target: TStream); overload; override;
39	procedure UpdateRawFile(FileID, DatOffset: Integer; Src: TStream); overload; override;
40	procedure LoadRawFilePart(FileID, DatOffset, Offset, Size: Integer; var Target: TStream); overload; override;
41	procedure UpdateRawFilePart(FileID, DatOffset, Offset, Size: Integer; Src: TStream); overload; override;
42
43	function AppendRawFile(LocSep: Boolean; Src: TStream): Integer; overload; override;
44	published
45	end;
46
47	implementation
48
49	uses
50	SysUtils, StrUtils, Data, Functions, RawList, DatLinks, Math;
51
52
53	(*
54	================================================================================
55	Implementation of TOniDataDat
56	*)
57
58
59	constructor TAccess_OniArchive.Create(DatFilename: String; ConnectionID: Integer; var Msg: TStatusMessages);
60	var
61	i: Integer;
62	header_pc, header_mac, header_macbeta: Boolean;
63	Fdat_header: THeader;
64	Fdat_filesmap: TFilesMap;
65	Fdat_namedfilesmap: TNamedFilesMap;
66	begin
67	Msg := SM_UnknownError;
68	if not FileExists(DatFilename) then
69	begin
70	Msg := SM_FileNotFound;
71	Exit;
72	end;
73	FFileName := DatFilename;
74	Fdat_file := TFileStream.Create(FFileName, fmOpenRead);
75	Fdat_file.Read(Fdat_header, SizeOf(Fdat_header));
76	header_pc := True;
77	header_mac := True;
78	header_macbeta := True;
79	for i := 0 to High(Fdat_header.GlobalIdent) do
80	if Fdat_header.GlobalIdent[i] <> HeaderGlobalIdent[i] then
81	begin
82	Msg := SM_IncompatibleFile;
83	Exit;
84	end;
85
86	for i := 0 to High(Fdat_header.OSIdent) do
87	begin
88	if Fdat_header.OSIdent[i] <> HeaderOSIdentWin[i] then
89	header_pc := False;
90	if Fdat_header.OSIdent[i] <> HeaderOSIdentMac[i] then
91	header_mac := False;
92	if Fdat_header.OSIdent[i] <> HeaderOSIdentMacBeta[i] then
93	header_macbeta := False;
94	end;
95	if not (header_pc xor header_mac xor header_macbeta) then
96	begin
97	Msg := SM_IncompatibleFile;
98	Exit;
99	end
100	else
101	begin
102	if (header_pc and not header_mac and not header_macbeta) then
103	FDataOS := DOS_WIN
104	else if (not header_pc and header_mac and not header_macbeta) then
105	FDataOS := DOS_MAC
106	else if (not header_pc and not header_mac and header_macbeta) then
107	FDataOS := DOS_MACBETA;
108	end;
109	SetLength(Fdat_filesmap, Fdat_header.Files);
110	SetLength(Fdat_files, Fdat_header.Files);
111	for i := 0 to Fdat_header.Files - 1 do
112	Fdat_file.Read(Fdat_filesmap[i], SizeOf(Fdat_filesmap[i]));
113	for i := 0 to Fdat_header.Files - 1 do
114	begin
115	Fdat_files[i].ID := i;
116	Fdat_files[i].Extension := Fdat_filesmap[i].Extension;
117	Fdat_files[i].Extension := ReverseString(Fdat_files[i].Extension);
118	Fdat_files[i].Size := Fdat_filesmap[i].FileSize;
119	Fdat_files[i].FileType := Fdat_filesmap[i].FileType;
120	Fdat_files[i].DatAddr := Fdat_filesmap[i].DataAddr - 8 + Fdat_header.DataAddr;
121	if (Fdat_filesmap[i].FileType and $01) = 0 then
122	begin
123	Fdat_file.Seek(Fdat_filesmap[i].NameAddr + Fdat_header.NamesAddr, soFromBeginning);
124	SetLength(Fdat_files[i].Name, 100);
125	Fdat_file.Read(Fdat_files[i].Name[1], 100);
126	Fdat_files[i].Name := MidStr(Fdat_files[i].Name, 1 + 4, Pos(
127	#0, Fdat_files[i].Name) - 1 - 4);
128	end
129	else
130	begin
131	Fdat_files[i].Name := '';
132	end;
133	end;
134	Fdat_file.Seek($40 + Fdat_header.Files * $14, soFromBeginning);
135	SetLength(Fdat_namedfilesmap, Fdat_header.NamedFiles);
136	for i := 0 to Fdat_header.NamedFiles - 1 do
137	Fdat_file.Read(Fdat_namedfilesmap[i], SizeOf(Fdat_namedfilesmap[i]));
138
139	Fdat_file.Seek($40 + Fdat_header.Files * $14 + Fdat_header.NamedFiles * $8, soFromBeginning);
140	SetLength(Fdat_extensionsmap, Fdat_header.Extensions);
141	for i := 0 to Fdat_header.Extensions - 1 do
142	Fdat_file.Read(Fdat_extensionsmap[i], SizeOf(Fdat_extensionsmap[i]));
143
144	Fdat_file.Seek(Fdat_files[0].DatAddr + 7, soFromBeginning);
145	Fdat_file.Read(FLevelNumber, 1);
146	FLevelNumber := FLevelNumber div 2;
147
148	Fraw_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.raw'),
149	fmOpenReadWrite);
150	if not (FDataOS = DOS_WIN) then
151	Fsep_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.sep'),
152	fmOpenReadWrite);
153
154	Msg := SM_OK;
155	FBackend := DB_ONI;
156	FConnectionID := ConnectionID;
157	FChangeRights := [CR_EditDat, CR_EditRaw, CR_AppendRaw];
158
159	inherited;
160	end;
161
162
163
164
165	procedure TAccess_OniArchive.Close;
166	begin
167	if Assigned(Fdat_file) then
168	Fdat_file.Free;
169	if Assigned(Fraw_file) then
170	Fraw_file.Free;
171	if Assigned(Fsep_file) then
172	Fsep_file.Free;
173	Self.Free;
174	end;
175
176
177
178
179	function TAccess_OniArchive.GetFileInfo(fileid: Integer): TFileInfo;
180	begin
181	if fileid = -1 then
182	begin
183	Result := inherited GetFileInfo(fileid);
184	Exit;
185	end;
186	if fileid < Self.GetFileCount then
187	Result := Fdat_files[fileid]
188	else
189	Result.ID := -1;
190	end;
191
192
193
194
195	function TAccess_OniArchive.GetFilesList(ext: String; pattern: String;
196	NoEmptyFiles: Boolean; SortType: TSortType): TStrings;
197	var
198	i: Integer;
199	list: TStringList;
200	id, name, extension: String;
201	fields: TStrings;
202
203	procedure getfields;
204	begin
205	fields.CommaText := StringReplace(AnsiQuotedStr(list.Strings[i], '"'), ';', '","', [rfReplaceAll]);
206	if SortType in [ST_IDAsc, ST_IDDesc] then
207	begin
208	id := fields.Strings[0];
209	name := fields.Strings[1];
210	extension := fields.Strings[2];
211	end;
212	if SortType in [ST_NameAsc, ST_NameDesc] then
213	begin
214	id := fields.Strings[1];
215	name := fields.Strings[0];
216	extension := fields.Strings[2];
217	end;
218	if SortType in [ST_ExtAsc, ST_ExtDesc] then
219	begin
220	id := fields.Strings[1];
221	name := fields.Strings[2];
222	extension := fields.Strings[0];
223	end;
224	if SortType in [ST_ExtNameAsc, ST_ExtNameDesc] then
225	begin
226	id := fields.Strings[2];
227	name := fields.Strings[1];
228	extension := fields.Strings[0];
229	end;
230	end;
231
232	begin
233	list := TStringList.Create;
234	list.Sorted := True;
235	if ext = '*' then
236	ext := '';
237	for i := 0 to GetFileCount - 1 do
238	begin
239	if ((Length(ext) = 0) or (Pos(Fdat_files[i].Extension, ext) > 0)) and
240	((Length(pattern) = 0) or
241	(Pos(UpperCase(pattern), UpperCase(Fdat_files[i].Name)) > 0)) then
242	begin
243	if (NoEmptyFiles = False) or ((Fdat_files[i].FileType and $02) = 0) then
244	begin
245	id := FormatNumber(Fdat_files[i].ID, 5, '0');
246	name := Fdat_files[i].Name;
247	extension := Fdat_files[i].Extension;
248
249	case SortType of
250	ST_IDAsc, ST_IDDesc: list.Add(id + ';' + name + ';' + extension);
251	ST_NameAsc, ST_NameDesc: list.Add(name + ';' + id + ';' + extension);
252	ST_ExtAsc, ST_ExtDesc: list.Add(extension + ';' + id + ';' + name);
253	ST_ExtNameAsc, ST_ExtNameDesc: list.Add(name + ';' + extension + ';' + id);
254	end;
255	end;
256	end;
257	end;
258	if not Assigned(Result) then
259	Result := TStringList.Create;
260	if list.Count > 0 then
261	begin
262	fields := TStringList.Create;
263	if SortType in [ST_IDAsc, ST_NameAsc, ST_ExtAsc, ST_ExtNameAsc] then
264	for i := 0 to list.Count - 1 do
265	begin
266	getfields;
267	Result.Add(id + '-' + name + '.' + extension);
268	end
269	else
270	for i := list.Count - 1 downto 0 do
271	begin
272	getfields;
273	Result.Add(id + '-' + name + '.' + extension);
274	end;
275	fields.Free;
276	end;
277	list.Free;
278	end;
279
280
281
282
283	function TAccess_OniArchive.GetFileCount: Integer;
284	begin
285	Result := Length(Fdat_files);
286	end;
287
288
289
290
291	function TAccess_OniArchive.GetExtensionsList(ExtListFormat: TExtensionFormat): TStrings;
292	var
293	i: Integer;
294	begin
295	if not Assigned(Result) then
296	Result := TStringList.Create;
297	if Result is TStringList then
298	TStringList(Result).Sorted := True;
299	for i := 0 to Length(Fdat_extensionsmap) - 1 do
300	begin
301	with Fdat_extensionsmap[i] do
302	begin
303	case ExtListFormat of
304	EF_ExtOnly:
305	Result.Add(Extension[3] + Extension[2] + Extension[1] + Extension[0]);
306	EF_ExtCount:
307	Result.Add(Extension[3] + Extension[2] + Extension[1] + Extension[0] +
308	' (' + IntToStr(ExtCount) + ')');
309	end;
310	end;
311	end;
312	end;
313
314
315
316	procedure TAccess_OniArchive.LoadDatFile(FileID: Integer; var Target: TStream);
317	var
318	streampos: Integer;
319	begin
320	if fileid < GetFileCount then
321	begin
322	if not Assigned(Target) then
323	Target := TMemoryStream.Create;
324	if GetFileInfo(FileID).Size > 0 then
325	begin
326	Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
327	streampos := Target.Position;
328	Target.CopyFrom(Fdat_file, Fdat_files[fileid].Size);
329	Target.Seek(streampos, soFromBeginning);
330	end;
331	end;
332	end;
333
334	procedure TAccess_OniArchive.UpdateDatFile(FileID: Integer; Src: TStream);
335	begin
336	if fileid < GetFileCount then
337	begin
338	Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
339	Fdat_file.CopyFrom(Src, Fdat_files[fileid].Size);
340	end;
341	end;
342
343	procedure TAccess_OniArchive.LoadDatFilePart(FileID, Offset, Size: Integer; var Target: TStream);
344	var
345	streampos: Integer;
346	begin
347	if fileid < GetFileCount then
348	begin
349	if not Assigned(Target) then
350	Target := TMemoryStream.Create;
351	Fdat_file.Seek(Fdat_files[fileid].DatAddr + offset, soFromBeginning);
352	streampos := Target.Position;
353	Target.CopyFrom(Fdat_file, size);
354	Target.Seek(streampos, soFromBeginning);
355	end;
356	end;
357
358	procedure TAccess_OniArchive.UpdateDatFilePart(FileID, Offset, Size: Integer; Src: TStream);
359	begin
360	if fileid < GetFileCount then
361	begin
362	Fdat_file.Seek(Fdat_files[fileid].DatAddr + offset, soFromBeginning);
363	Fdat_file.CopyFrom(Src, Size);
364	end;
365	end;
366
367
368
369	function TAccess_OniArchive.GetDatLink(FileID, DatOffset: Integer): TDatLink;
370	var
371	link: Integer;
372	begin
373	Result := DatLinksManager.GetDatLink(FConnectionID, FileID, DatOffset);
374	LoadDatFilePart(fileid, Result.SrcOffset, 4, @link);
375	if link > 0 then
376	Result.DestID := link div 256
377	else
378	Result.DestID := -1;
379	end;
380
381
382	function TAccess_OniArchive.GetDatLinks(FileID: Integer): TDatLinkList;
383	var
384	i: Integer;
385	link: Integer;
386	begin
387	Result := DatLinksManager.GetDatLinks(FConnectionID, FileID);
388	if Length(Result) > 0 then
389	begin
390	for i := 0 to High(Result) do
391	begin
392	LoadDatFilePart(fileid, Result[i].SrcOffset, 4, @link);
393	if link > 0 then
394	Result[i].DestID := link div 256
395	else
396	Result[i].DestID := -1;
397	end;
398	end;
399	end;
400
401
402	function TAccess_OniArchive.GetRawList(FileID: Integer): TRawDataList;
403	begin
404	Result := RawLists.GetRawList(FConnectionID, FileID);
405	end;
406
407
408	function TAccess_OniArchive.GetRawsForType(RawType: String): TRawDataList;
409	var
410	i, j: Integer;
411	dats: TStrings;
412	list: TRawDataList;
413	begin
414	dats := nil;
415	dats := GetFilesList(MidStr(RawType, 1, 4), '', True, ST_IDAsc);
416	for i := 0 to dats.Count - 1 do
417	begin
418	list := GetRawList(StrToInt(MidStr(dats.Strings[i], 1, 5)));
419	for j := 0 to Length(list) - 1 do
420	begin
421	if (list[j].RawType = RawType) and (list[j].RawSize > 0) then
422	begin
423	SetLength(Result, Length(Result)+1);
424	Result[High(Result)] := list[j];
425	end;
426	end;
427	end;
428	end;
429
430
431	function TAccess_OniArchive.GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo;
432	begin
433	Result := RawLists.GetRawInfo(FConnectionID, FileID, DatOffset);
434	end;
435
436
437
438	procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream);
439	begin
440	if not Assigned(Target) then
441	Target := TMemoryStream.Create;
442	if not LocSep then
443	begin
444	if RawAddr <= Fraw_file.Size then
445	begin
446	Fraw_file.Seek(RawAddr, soFromBeginning);
447	Target.CopyFrom(Fraw_file, size);
448	Target.Seek(0, soFromBeginning);
449	end;
450	end
451	else
452	begin
453	if RawAddr <= Fsep_file.Size then
454	begin
455	Fsep_file.Seek(RawAddr, soFromBeginning);
456	Target.CopyFrom(Fsep_file, size);
457	Target.Seek(0, soFromBeginning);
458	end;
459	end;
460	end;
461
462	procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer);
463	var
464	data: TStream;
465	begin
466	data := nil;
467	LoadRawOffset(LocSep, RawAddr, Size, data);
468	data.Read(Target^, Size);
469	data.Free;
470	end;
471
472	procedure TAccess_OniArchive.LoadRawFile(FileID, DatOffset: Integer; var Target: TStream);
473	var
474	raw_info: TRawDataInfo;
475	streampos: Integer;
476	begin
477	if not Assigned(Target) then
478	Target := TMemoryStream.Create;
479	if fileid < GetFileCount then
480	begin
481	raw_info := Self.GetRawInfo(FileID, DatOffset);
482	if not raw_info.LocSep then
483	begin
484	Fraw_file.Seek(raw_info.RawAddr, soFromBeginning);
485	streampos := Target.Position;
486	Target.CopyFrom(Fraw_file, raw_info.RawSize);
487	Target.Seek(streampos, soFromBeginning);
488	end
489	else
490	begin
491	Fsep_file.Seek(raw_info.RawAddr, soFromBeginning);
492	streampos := Target.Position;
493	Target.CopyFrom(Fsep_file, raw_info.RawSize);
494	Target.Seek(streampos, soFromBeginning);
495	end;
496	end;
497	end;
498
499	procedure TAccess_OniArchive.UpdateRawFile(FileID, DatOffset: Integer; Src: TStream);
500	var
501	raw_info: TRawDataInfo;
502	begin
503	if fileid < GetFileCount then
504	begin
505	raw_info := GetRawInfo(FileID, DatOffset);
506	if not raw_info.LocSep then
507	begin
508	Fraw_file.Seek(raw_info.RawAddr, soFromBeginning);
509	Fraw_file.CopyFrom(Src, Min(raw_info.RawSize, Src.Size));
510	end
511	else
512	begin
513	Fsep_file.Seek(raw_info.RawAddr, soFromBeginning);
514	Fsep_file.CopyFrom(Src, raw_info.RawSize);
515	end;
516	end;
517	end;
518
519	procedure TAccess_OniArchive.LoadRawFilePart(FileID, DatOffset, Offset, Size: Integer; var Target: TStream);
520	var
521	Data: TStream;
522	streampos: Integer;
523	begin
524	if not Assigned(Target) then
525	Target := TMemoryStream.Create;
526	if fileid < Self.GetFileCount then
527	begin
528	data := nil;
529	LoadRawFile(FileID, DatOffset, Data);
530	Data.Seek(Offset, soFromBeginning);
531	streampos := Target.Position;
532	Target.CopyFrom(Data, Size);
533	Target.Seek(streampos, soFromBeginning);
534	end;
535	end;
536
537
538	procedure TAccess_OniArchive.UpdateRawFilePart(FileID, DatOffset, Offset, Size: Integer; Src: TStream);
539	var
540	raw_info: TRawDataInfo;
541	begin
542	if fileid < GetFileCount then
543	begin
544	raw_info := GetRawInfo(FileID, DatOffset);
545	if not raw_info.LocSep then
546	begin
547	Fraw_file.Seek(raw_info.RawAddr + Offset, soFromBeginning);
548	Fraw_file.CopyFrom(Src, Size);
549	end
550	else
551	begin
552	Fsep_file.Seek(raw_info.RawAddr + Offset, soFromBeginning);
553	Fsep_file.CopyFrom(Src, Size);
554	end;
555	end;
556	end;
557
558	function TAccess_OniArchive.AppendRawFile(LocSep: Boolean; Src: TStream): Integer;
559	const
560	EmptyBytes: Array[0..31] of Byte = (
561	0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 );
562	begin
563	if not LocSep then
564	begin
565	if (Fraw_file.Size mod 32) > 0 then
566	Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
567	Result := Fraw_file.Size;
568	Fraw_file.Seek(0, soFromEnd);
569	Fraw_file.CopyFrom(Src, Src.Size);
570	if (Fraw_file.Size mod 32) > 0 then
571	Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
572	end
573	else
574	begin
575	if (Fsep_file.Size mod 32) > 0 then
576	Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
577	Result := Fsep_file.Size;
578	Fsep_file.Seek(0, soFromEnd);
579	Fsep_file.CopyFrom(Src, Src.Size);
580	if (Fsep_file.Size mod 32) > 0 then
581	Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
582	end;
583	end;
584
585	end.