MirandaNGHistoryToDB moved to deprecated

git-svn-id: http://svn.miranda-ng.org/main/trunk@7118 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c

1 files changed, 222 insertions, 0 deletions

diff --git a/plugins/!Deprecated/MirandaNGHistoryToDB/FSMonitor.pas b/plugins/!Deprecated/MirandaNGHistoryToDB/FSMonitor.pas
new file mode 100644
index 0000000000..b19cde322f
--- /dev/null
+++ b/plugins/!Deprecated/MirandaNGHistoryToDB/FSMonitor.pas
@@ -0,0 +1,222 @@
+{ ############################################################################ }

+{ #                                                                          # }

+{ #  MirandaNG HistoryToDB Plugin v2.5                                       # }

+{ #                                                                          # }

+{ #  License: GPLv3                                                          # }

+{ #                                                                          # }

+{ #  Author: Grigorev Michael (icq: 161867489, email: sleuthhound@gmail.com) # }

+{ #                                                                          # }

+{ ############################################################################ }

+

+unit FSMonitor;

+

+{$I jedi.inc}

+

+interface

+

+type

+  // Структура с информацией об изменении в файловой системе (передается в callback процедуру)

+  PInfoCallBack = ^TInfoCallBack;

+  TInfoCallBack = record

+    FAction      : Integer; // Тип изменения (константы FILE_ACTION_XXX)

+    FDrive       : String;  // Диск, на котором было изменение

+    FOldFileName : String;  // Имя файла до переименования

+    FNewFileName : String;  // Имя файла после переименования

+  end;

+

+  // callback процедура, вызываемая при изменении в файловой системе

+  TWatchFileSystemCallBack = procedure (pInfo: TInfoCallBack);

+

+  { Запуск мониторинга файловой системы

+  Праметры:

+  pName    - имя папки для мониторинга

+  pFilter  - комбинация констант FILE_NOTIFY_XXX

+  pSubTree - мониторить ли все подпапки заданной папки

+  pInfoCallBack - адрес callback процедуры, вызываемой при изменении в файловой системе }

+  procedure StartWatch(pName: String; pFilter: Cardinal; pSubTree: Boolean; pInfoCallBack: TWatchFileSystemCallBack);

+  // Остановка мониторинга

+  procedure StopWatch;

+

+implementation

+

+uses

+  Classes, Windows, SysUtils, IniFiles;

+

+const

+  FILE_LIST_DIRECTORY   = $0001;

+

+type

+  PFileNotifyInformation = ^TFileNotifyInformation;

+  TFileNotifyInformation = record

+    NextEntryOffset : DWORD;

+    Action          : DWORD;

+    FileNameLength  : DWORD;

+    FileName        : Array[0..0] of WideChar;

+  end;

+

+  WFSError = class(Exception);

+

+  TWFS = class(TThread)

+  private

+    FName           : String;

+    FFilter         : Cardinal;

+    FSubTree        : Boolean;

+    FInfoCallBack   : TWatchFileSystemCallBack;

+    FWatchHandle    : THandle;

+    FWatchBuf       : Array[0..4096] of Byte;

+    FOverLapp       : TOverlapped;

+    FPOverLapp      : POverlapped;

+    FBytesWritte    : DWORD;

+    FCompletionPort : THandle;

+    FNumBytes       : Cardinal;

+    FOldFileName    : String;

+    function CreateDirHandle(aDir: string): THandle;

+    procedure WatchEvent;

+    //procedure HandleEvent;

+  protected

+    procedure Execute; override;

+  public

+    constructor Create(pName: String; pFilter: Cardinal; pSubTree: Boolean; pInfoCallBack: TWatchFileSystemCallBack);

+    destructor Destroy; override;

+  end;

+

+

+var

+  WFS : TWFS;

+

+procedure StartWatch(pName: String; pFilter: Cardinal; pSubTree: Boolean; pInfoCallBack: TWatchFileSystemCallBack);

+begin

+  WFS := TWFS.Create(pName, pFilter, pSubTree, pInfoCallBack);

+end;

+

+procedure StopWatch;

+begin

+  if Assigned(WFS) then

+  begin

+    PostQueuedCompletionStatus(WFS.FCompletionPort, 0, 0, nil);

+    WFS.Terminate;

+    WFS.WaitFor;

+    WFS.Free;

+    WFS := nil;

+  end;

+end;

+

+constructor TWFS.Create(pName: String; pFilter: Cardinal; pSubTree: Boolean; pInfoCallBack: TWatchFileSystemCallBack);

+begin

+  inherited Create(True);

+  FreeOnTerminate := False;

+  FName := IncludeTrailingBackslash(pName);

+  FFilter := pFilter;

+  FSubTree := pSubTree;

+  FOldFileName := EmptyStr;

+  ZeroMemory(@FOverLapp, SizeOf(TOverLapped));

+  FPOverLapp := @FOverLapp;

+  ZeroMemory(@FWatchBuf, SizeOf(FWatchBuf));

+  FInfoCallBack := pInfoCallBack;

+  Resume;

+end;

+

+

+destructor TWFS.Destroy;

+begin

+  PostQueuedCompletionStatus(FCompletionPort, 0, 0, nil);

+  CloseHandle(FWatchHandle);

+  FWatchHandle := 0;

+  CloseHandle(FCompletionPort);

+  FCompletionPort := 0;

+  inherited Destroy;

+end;

+

+function TWFS.CreateDirHandle(aDir: String): THandle;

+begin

+  Result := CreateFile(PChar(aDir), FILE_LIST_DIRECTORY, FILE_SHARE_READ+FILE_SHARE_DELETE+FILE_SHARE_WRITE,

+                   nil,OPEN_EXISTING, FILE_FLAG_BACKUP_SEMANTICS or FILE_FLAG_OVERLAPPED, 0);

+end;

+

+procedure TWFS.Execute;

+begin

+  FWatchHandle := CreateDirHandle(FName);

+  WatchEvent;

+end;

+

+{procedure TWFS.HandleEvent;

+var

+  FileNotifyInfo : PFileNotifyInformation;

+  InfoCallBack   : TInfoCallBack;

+  Offset         : Longint;

+begin

+  Pointer(FileNotifyInfo) := @FWatchBuf[0];

+  repeat

+    Offset := FileNotifyInfo^.NextEntryOffset;

+    InfoCallBack.FAction := FileNotifyInfo^.Action;

+    InfoCallBack.FDrive := FName;

+    SetString(InfoCallBack.FNewFileName,FileNotifyInfo^.FileName,FileNotifyInfo^.FileNameLength );

+    InfoCallBack.FNewFileName := Trim(InfoCallBack.FNewFileName);

+    case FileNotifyInfo^.Action of

+      FILE_ACTION_RENAMED_OLD_NAME: FOldFileName := Trim(WideCharToString(@(FileNotifyInfo^.FileName[0])));

+      FILE_ACTION_RENAMED_NEW_NAME: InfoCallBack.FOldFileName := FOldFileName;

+    end;

+    FInfoCallBack(InfoCallBack);

+    PChar(FileNotifyInfo) := PChar(FileNotifyInfo)+Offset;

+  until (Offset=0) or Terminated;

+end;}

+

+procedure TWFS.WatchEvent;

+var

+  {$ifdef DELPHIXE_UP}

+  CompletionKey: DWORD_PTR;

+  {$ELSE}

+    CompletionKey: Cardinal;

+  {$endif}

+  // Перенесено из HandleEvent

+  FileNotifyInfo : PFileNotifyInformation;

+  InfoCallBack   : TInfoCallBack;

+  Offset         : Longint;

+  // End

+begin

+  FCompletionPort := CreateIoCompletionPort(FWatchHandle, 0, Longint(pointer(self)), 0);

+  ZeroMemory(@FWatchBuf, SizeOf(FWatchBuf));

+  if not ReadDirectoryChanges(FWatchHandle, @FWatchBuf, SizeOf(FWatchBuf), FSubTree,

+    FFilter, @FBytesWritte,  @FOverLapp, 0) then

+  begin

+    raise WFSError.Create(SysErrorMessage(GetLastError));

+    Terminate;

+  end

+  else

+  begin

+    while not Terminated do

+    begin

+      GetQueuedCompletionStatus(FCompletionPort, FNumBytes, CompletionKey, FPOverLapp, INFINITE);

+      if CompletionKey <> 0 then

+      begin

+        //Synchronize(HandleEvent);

+        { Т.к. Synchronize(HandleEvent) не отрабатывает в

+         плагине по непонятной причине, то его код перенесен сюда

+         Подробнее тут -> http://forum.qip.ru/showthread.php?t=25200 }

+        Pointer(FileNotifyInfo) := @FWatchBuf[0];

+        repeat

+          Offset := FileNotifyInfo^.NextEntryOffset;

+          InfoCallBack.FAction := FileNotifyInfo^.Action;

+          InfoCallBack.FDrive := FName;

+          SetString(InfoCallBack.FNewFileName,FileNotifyInfo^.FileName,FileNotifyInfo^.FileNameLength );

+          InfoCallBack.FNewFileName := Trim(InfoCallBack.FNewFileName);

+          case FileNotifyInfo^.Action of

+            FILE_ACTION_RENAMED_OLD_NAME: FOldFileName := Trim(WideCharToString(@(FileNotifyInfo^.FileName[0])));

+            FILE_ACTION_RENAMED_NEW_NAME: InfoCallBack.FOldFileName := FOldFileName;

+          end;

+          FInfoCallBack(InfoCallBack);

+          PChar(FileNotifyInfo) := PChar(FileNotifyInfo)+Offset;

+        until (Offset=0) or Terminated;

+        // End synchronize

+        ZeroMemory(@FWatchBuf, SizeOf(FWatchBuf));

+        FBytesWritte := 0;

+        ReadDirectoryChanges(FWatchHandle, @FWatchBuf, SizeOf(FWatchBuf), FSubTree, FFilter,

+                             @FBytesWritte, @FOverLapp, 0);

+      end

+      else

+        Terminate;

+    end

+  end

+end;

+

+end.