Terminal.h 43 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912
  1. //---------------------------------------------------------------------------
  2. #ifndef TerminalH
  3. #define TerminalH
  4. #include <Classes.hpp>
  5. #include "SessionInfo.h"
  6. #include "Interface.h"
  7. #include "FileOperationProgress.h"
  8. #include "FileMasks.h"
  9. #include "Exceptions.h"
  10. //---------------------------------------------------------------------------
  11. class TCopyParamType;
  12. class TFileOperationProgressType;
  13. class TRemoteDirectory;
  14. class TRemoteFile;
  15. class TCustomFileSystem;
  16. class TTunnelThread;
  17. class TSecureShell;
  18. struct TCalculateSizeParams;
  19. struct TOverwriteFileParams;
  20. struct TSynchronizeData;
  21. struct TSynchronizeOptions;
  22. class TSynchronizeChecklist;
  23. struct TCalculateSizeStats;
  24. struct TFileSystemInfo;
  25. struct TSpaceAvailable;
  26. struct TFilesFindParams;
  27. class TTunnelUI;
  28. class TCallbackGuard;
  29. class TParallelOperation;
  30. class TCollectedFileList;
  31. struct TLocalFileHandle;
  32. //---------------------------------------------------------------------------
  33. typedef void __fastcall (__closure *TQueryUserEvent)
  34. (TObject * Sender, const UnicodeString Query, TStrings * MoreMessages, unsigned int Answers,
  35. const TQueryParams * Params, unsigned int & Answer, TQueryType QueryType, void * Arg);
  36. typedef void __fastcall (__closure *TPromptUserEvent)
  37. (TTerminal * Terminal, TPromptKind Kind, UnicodeString Name, UnicodeString Instructions,
  38. TStrings * Prompts, TStrings * Results, bool & Result, void * Arg);
  39. typedef void __fastcall (__closure *TDisplayBannerEvent)
  40. (TTerminal * Terminal, UnicodeString SessionName, const UnicodeString & Banner,
  41. bool & NeverShowAgain, int Options, unsigned int & Params);
  42. typedef void __fastcall (__closure *TExtendedExceptionEvent)
  43. (TTerminal * Terminal, Exception * E, void * Arg);
  44. typedef void __fastcall (__closure *TReadDirectoryEvent)(System::TObject * Sender, Boolean ReloadOnly);
  45. typedef void __fastcall (__closure *TReadDirectoryProgressEvent)(
  46. System::TObject* Sender, int Progress, int ResolvedLinks, bool & Cancel);
  47. typedef void __fastcall (__closure *TProcessFileEvent)
  48. (const UnicodeString FileName, const TRemoteFile * File, void * Param);
  49. typedef void __fastcall (__closure *TProcessFileEventEx)
  50. (const UnicodeString FileName, const TRemoteFile * File, void * Param, int Index);
  51. typedef int __fastcall (__closure *TFileOperationEvent)
  52. (void * Param1, void * Param2);
  53. typedef void __fastcall (__closure *TSynchronizeDirectory)
  54. (const UnicodeString LocalDirectory, const UnicodeString RemoteDirectory,
  55. bool & Continue, bool Collect);
  56. typedef void __fastcall (__closure *TDeleteLocalFileEvent)(
  57. const UnicodeString FileName, bool Alternative);
  58. typedef int __fastcall (__closure *TDirectoryModifiedEvent)
  59. (TTerminal * Terminal, const UnicodeString Directory, bool SubDirs);
  60. typedef void __fastcall (__closure *TInformationEvent)
  61. (TTerminal * Terminal, const UnicodeString & Str, bool Status, int Phase);
  62. typedef void __fastcall (__closure *TCustomCommandEvent)
  63. (TTerminal * Terminal, const UnicodeString & Command, bool & Handled);
  64. //---------------------------------------------------------------------------
  65. const unsigned int folNone = 0x00;
  66. const unsigned int folAllowSkip = 0x01;
  67. const unsigned int folRetryOnFatal = 0x02;
  68. /* TODO : Better user interface (query to user) */
  69. #define FILE_OPERATION_LOOP_BEGIN \
  70. { \
  71. bool DoRepeat; \
  72. do \
  73. { \
  74. DoRepeat = false; \
  75. try \
  76. #define FILE_OPERATION_LOOP_END_CUSTOM(MESSAGE, FLAGS, HELPKEYWORD) \
  77. catch (Exception & E) \
  78. { \
  79. FILE_OPERATION_LOOP_TERMINAL->FileOperationLoopEnd(E, OperationProgress, MESSAGE, FLAGS, L"", HELPKEYWORD); \
  80. DoRepeat = true; \
  81. } \
  82. } while (DoRepeat); \
  83. }
  84. #define FILE_OPERATION_LOOP_END_EX(MESSAGE, FLAGS) \
  85. FILE_OPERATION_LOOP_END_CUSTOM(MESSAGE, FLAGS, L"")
  86. #define FILE_OPERATION_LOOP_END(MESSAGE) \
  87. FILE_OPERATION_LOOP_END_EX(MESSAGE, folAllowSkip)
  88. //---------------------------------------------------------------------------
  89. enum TCurrentFSProtocol { cfsUnknown, cfsSCP, cfsSFTP, cfsFTP, cfsWebDAV, cfsS3 };
  90. //---------------------------------------------------------------------------
  91. const int cpDelete = 0x01;
  92. const int cpTemporary = 0x04;
  93. const int cpNoConfirmation = 0x08;
  94. const int cpAppend = 0x20;
  95. const int cpResume = 0x40;
  96. const int cpNoRecurse = 0x80;
  97. //---------------------------------------------------------------------------
  98. const int ccApplyToDirectories = 0x01;
  99. const int ccRecursive = 0x02;
  100. const int ccUser = 0x100;
  101. //---------------------------------------------------------------------------
  102. const int csIgnoreErrors = 0x01;
  103. //---------------------------------------------------------------------------
  104. const int ropNoReadDirectory = 0x02;
  105. //---------------------------------------------------------------------------
  106. const int boDisableNeverShowAgain = 0x01;
  107. const int bpMonospacedFont = 0x01;
  108. //---------------------------------------------------------------------------
  109. const int tfNone = 0x00;
  110. const int tfFirstLevel = 0x01;
  111. const int tfNewDirectory = 0x02;
  112. const int tfAutoResume = 0x04;
  113. const int tfPreCreateDir = 0x08;
  114. const int tfUseFileTransferAny = 0x10;
  115. //---------------------------------------------------------------------------
  116. class TTerminal : public TObject, public TSessionUI
  117. {
  118. public:
  119. // TScript::SynchronizeProc relies on the order
  120. enum TSynchronizeMode { smRemote, smLocal, smBoth };
  121. static const int spDelete = 0x01; // cannot be combined with spTimestamp
  122. static const int spNoConfirmation = 0x02; // has no effect for spTimestamp
  123. static const int spExistingOnly = 0x04; // is implicit for spTimestamp
  124. static const int spNoRecurse = 0x08;
  125. static const int spUseCache = 0x10; // cannot be combined with spTimestamp
  126. static const int spDelayProgress = 0x20; // cannot be combined with spTimestamp
  127. static const int spPreviewChanges = 0x40; // not used by core
  128. static const int spSubDirs = 0x80; // cannot be combined with spTimestamp
  129. static const int spTimestamp = 0x100;
  130. static const int spNotByTime = 0x200; // cannot be combined with spTimestamp and smBoth
  131. static const int spBySize = 0x400; // cannot be combined with smBoth, has opposite meaning for spTimestamp
  132. static const int spSelectedOnly = 0x800; // not used by core
  133. static const int spMirror = 0x1000;
  134. static const int spDefault = TTerminal::spNoConfirmation | TTerminal::spPreviewChanges;
  135. // for TranslateLockedPath()
  136. friend class TRemoteFile;
  137. // for ReactOnCommand()
  138. friend class TSCPFileSystem;
  139. friend class TSFTPFileSystem;
  140. friend class TFTPFileSystem;
  141. friend class TWebDAVFileSystem;
  142. friend class TS3FileSystem;
  143. friend class TTunnelUI;
  144. friend class TCallbackGuard;
  145. friend class TSecondaryTerminal;
  146. friend class TRetryOperationLoop;
  147. private:
  148. TSessionData * FSessionData;
  149. TSessionLog * FLog;
  150. TActionLog * FActionLog;
  151. TConfiguration * FConfiguration;
  152. UnicodeString FCurrentDirectory;
  153. UnicodeString FLockDirectory;
  154. Integer FExceptionOnFail;
  155. TRemoteDirectory * FFiles;
  156. int FInTransaction;
  157. bool FSuspendTransaction;
  158. TNotifyEvent FOnChangeDirectory;
  159. TReadDirectoryEvent FOnReadDirectory;
  160. TNotifyEvent FOnStartReadDirectory;
  161. TReadDirectoryProgressEvent FOnReadDirectoryProgress;
  162. TDeleteLocalFileEvent FOnDeleteLocalFile;
  163. TNotifyEvent FOnInitializeLog;
  164. TRemoteTokenList FMembership;
  165. TRemoteTokenList FGroups;
  166. TRemoteTokenList FUsers;
  167. bool FUsersGroupsLookedup;
  168. TFileOperationProgressEvent FOnProgress;
  169. TFileOperationFinished FOnFinished;
  170. TFileOperationProgressType * FOperationProgress;
  171. bool FUseBusyCursor;
  172. TRemoteDirectoryCache * FDirectoryCache;
  173. TRemoteDirectoryChangesCache * FDirectoryChangesCache;
  174. TSecureShell * FSecureShell;
  175. UnicodeString FLastDirectoryChange;
  176. TCurrentFSProtocol FFSProtocol;
  177. TTerminal * FCommandSession;
  178. bool FAutoReadDirectory;
  179. bool FReadingCurrentDirectory;
  180. bool * FClosedOnCompletion;
  181. TSessionStatus FStatus;
  182. int FOpening;
  183. RawByteString FRememberedPassword;
  184. RawByteString FRememberedTunnelPassword;
  185. TTunnelThread * FTunnelThread;
  186. TSecureShell * FTunnel;
  187. TSessionData * FTunnelData;
  188. TSessionLog * FTunnelLog;
  189. TTunnelUI * FTunnelUI;
  190. int FTunnelLocalPortNumber;
  191. UnicodeString FTunnelError;
  192. TQueryUserEvent FOnQueryUser;
  193. TPromptUserEvent FOnPromptUser;
  194. TDisplayBannerEvent FOnDisplayBanner;
  195. TExtendedExceptionEvent FOnShowExtendedException;
  196. TInformationEvent FOnInformation;
  197. TCustomCommandEvent FOnCustomCommand;
  198. TNotifyEvent FOnClose;
  199. TCallbackGuard * FCallbackGuard;
  200. TFindingFileEvent FOnFindingFile;
  201. bool FEnableSecureShellUsage;
  202. bool FCollectFileSystemUsage;
  203. bool FRememberedPasswordTried;
  204. bool FRememberedTunnelPasswordTried;
  205. int FNesting;
  206. UnicodeString FFingerprintScannedSHA256;
  207. UnicodeString FFingerprintScannedMD5;
  208. DWORD FLastProgressLogged;
  209. UnicodeString FDestFileName;
  210. bool FMultipleDestinationFiles;
  211. bool FFileTransferAny;
  212. void __fastcall CommandError(Exception * E, const UnicodeString Msg);
  213. unsigned int __fastcall CommandError(Exception * E, const UnicodeString Msg,
  214. unsigned int Answers, const UnicodeString HelpKeyword = L"");
  215. UnicodeString __fastcall GetCurrentDirectory();
  216. bool __fastcall GetExceptionOnFail() const;
  217. const TRemoteTokenList * __fastcall GetGroups();
  218. const TRemoteTokenList * __fastcall GetUsers();
  219. const TRemoteTokenList * __fastcall GetMembership();
  220. void __fastcall SetCurrentDirectory(UnicodeString value);
  221. void __fastcall SetExceptionOnFail(bool value);
  222. void __fastcall ReactOnCommand(int /*TFSCommand*/ Cmd);
  223. UnicodeString __fastcall GetUserName() const;
  224. bool __fastcall GetAreCachesEmpty() const;
  225. void __fastcall ClearCachedFileList(const UnicodeString Path, bool SubDirs);
  226. void __fastcall AddCachedFileList(TRemoteFileList * FileList);
  227. bool __fastcall GetCommandSessionOpened();
  228. TTerminal * __fastcall GetCommandSession();
  229. bool __fastcall GetResolvingSymlinks();
  230. bool __fastcall GetActive();
  231. UnicodeString __fastcall GetPassword();
  232. UnicodeString __fastcall GetRememberedPassword();
  233. UnicodeString __fastcall GetRememberedTunnelPassword();
  234. bool __fastcall GetStoredCredentialsTried();
  235. inline bool __fastcall InTransaction();
  236. void __fastcall SaveCapabilities(TFileSystemInfo & FileSystemInfo);
  237. void __fastcall CreateTargetDirectory(const UnicodeString & DirectoryPath, int Attrs, const TCopyParamType * CopyParam);
  238. static UnicodeString __fastcall SynchronizeModeStr(TSynchronizeMode Mode);
  239. static UnicodeString __fastcall SynchronizeParamsStr(int Params);
  240. protected:
  241. bool FReadCurrentDirectoryPending;
  242. bool FReadDirectoryPending;
  243. bool FTunnelOpening;
  244. TCustomFileSystem * FFileSystem;
  245. void __fastcall DoStartReadDirectory();
  246. void __fastcall DoReadDirectoryProgress(int Progress, int ResolvedLinks, bool & Cancel);
  247. void __fastcall DoReadDirectory(bool ReloadOnly);
  248. void __fastcall DoCreateDirectory(const UnicodeString DirName);
  249. void __fastcall DoDeleteFile(const UnicodeString FileName, const TRemoteFile * File,
  250. int Params);
  251. void __fastcall DoCustomCommandOnFile(UnicodeString FileName,
  252. const TRemoteFile * File, UnicodeString Command, int Params, TCaptureOutputEvent OutputEvent);
  253. void __fastcall DoRenameFile(const UnicodeString FileName, const TRemoteFile * File,
  254. const UnicodeString NewName, bool Move);
  255. void __fastcall DoCopyFile(const UnicodeString FileName, const TRemoteFile * File, const UnicodeString NewName);
  256. void __fastcall DoChangeFileProperties(const UnicodeString FileName,
  257. const TRemoteFile * File, const TRemoteProperties * Properties);
  258. void __fastcall DoChangeDirectory();
  259. void __fastcall DoInitializeLog();
  260. void __fastcall EnsureNonExistence(const UnicodeString FileName);
  261. void __fastcall LookupUsersGroups();
  262. void __fastcall FileModified(const TRemoteFile * File,
  263. const UnicodeString FileName, bool ClearDirectoryChange = false);
  264. int __fastcall FileOperationLoop(TFileOperationEvent CallBackFunc,
  265. TFileOperationProgressType * OperationProgress, unsigned int Flags,
  266. const UnicodeString Message, void * Param1 = NULL, void * Param2 = NULL);
  267. bool __fastcall GetIsCapable(TFSCapability Capability) const;
  268. bool __fastcall ProcessFiles(TStrings * FileList, TFileOperation Operation,
  269. TProcessFileEvent ProcessFile, void * Param = NULL, TOperationSide Side = osRemote,
  270. bool Ex = false);
  271. bool __fastcall ProcessFilesEx(TStrings * FileList, TFileOperation Operation,
  272. TProcessFileEventEx ProcessFile, void * Param = NULL, TOperationSide Side = osRemote);
  273. void __fastcall ProcessDirectory(const UnicodeString DirName,
  274. TProcessFileEvent CallBackFunc, void * Param = NULL, bool UseCache = false,
  275. bool IgnoreErrors = false);
  276. bool __fastcall DeleteContentsIfDirectory(
  277. const UnicodeString & FileName, const TRemoteFile * File, int Params, TRmSessionAction & Action);
  278. void __fastcall AnnounceFileListOperation();
  279. UnicodeString __fastcall TranslateLockedPath(UnicodeString Path, bool Lock);
  280. void __fastcall ReadDirectory(TRemoteFileList * FileList);
  281. void __fastcall CustomReadDirectory(TRemoteFileList * FileList);
  282. void __fastcall DoCreateLink(const UnicodeString FileName, const UnicodeString PointTo, bool Symbolic);
  283. bool __fastcall CreateLocalFile(const UnicodeString FileName,
  284. TFileOperationProgressType * OperationProgress, HANDLE * AHandle,
  285. bool NoConfirmation);
  286. void __fastcall OpenLocalFile(const UnicodeString FileName, unsigned int Access,
  287. int * Attrs, HANDLE * Handle, __int64 * ACTime, __int64 * MTime,
  288. __int64 * ATime, __int64 * Size, bool TryWriteReadOnly = true);
  289. void __fastcall OpenLocalFile(
  290. const UnicodeString & FileName, unsigned int Access, TLocalFileHandle & Handle, bool TryWriteReadOnly = true);
  291. bool __fastcall AllowLocalFileTransfer(UnicodeString FileName,
  292. const TCopyParamType * CopyParam, TFileOperationProgressType * OperationProgress);
  293. bool __fastcall HandleException(Exception * E);
  294. void __fastcall CalculateFileSize(UnicodeString FileName,
  295. const TRemoteFile * File, /*TCalculateSizeParams*/ void * Size);
  296. void __fastcall DoCalculateFileSize(UnicodeString FileName,
  297. const TRemoteFile * File, void * Param);
  298. bool __fastcall DoCalculateDirectorySize(const UnicodeString FileName,
  299. const TRemoteFile * File, TCalculateSizeParams * Params);
  300. void __fastcall CalculateLocalFileSize(const UnicodeString FileName,
  301. const TSearchRec Rec, /*__int64*/ void * Size);
  302. bool __fastcall CalculateLocalFilesSize(TStrings * FileList, __int64 & Size,
  303. const TCopyParamType * CopyParam, bool AllowDirs, TStrings * Files);
  304. TBatchOverwrite __fastcall EffectiveBatchOverwrite(
  305. const UnicodeString & SourceFullFileName, const TCopyParamType * CopyParam, int Params,
  306. TFileOperationProgressType * OperationProgress, bool Special);
  307. bool __fastcall CheckRemoteFile(
  308. const UnicodeString & FileName, const TCopyParamType * CopyParam,
  309. int Params, TFileOperationProgressType * OperationProgress);
  310. unsigned int __fastcall ConfirmFileOverwrite(
  311. const UnicodeString & SourceFullFileName, const UnicodeString & TargetFileName,
  312. const TOverwriteFileParams * FileParams, unsigned int Answers, TQueryParams * QueryParams,
  313. TOperationSide Side, const TCopyParamType * CopyParam, int Params,
  314. TFileOperationProgressType * OperationProgress, UnicodeString Message = L"");
  315. void __fastcall DoSynchronizeCollectDirectory(const UnicodeString LocalDirectory,
  316. const UnicodeString RemoteDirectory, TSynchronizeMode Mode,
  317. const TCopyParamType * CopyParam, int Params,
  318. TSynchronizeDirectory OnSynchronizeDirectory,
  319. TSynchronizeOptions * Options, int Level, TSynchronizeChecklist * Checklist);
  320. void __fastcall DoSynchronizeCollectFile(const UnicodeString FileName,
  321. const TRemoteFile * File, /*TSynchronizeData*/ void * Param);
  322. void __fastcall SynchronizeCollectFile(const UnicodeString FileName,
  323. const TRemoteFile * File, /*TSynchronizeData*/ void * Param);
  324. void __fastcall SynchronizeRemoteTimestamp(const UnicodeString FileName,
  325. const TRemoteFile * File, void * Param);
  326. void __fastcall SynchronizeLocalTimestamp(const UnicodeString FileName,
  327. const TRemoteFile * File, void * Param);
  328. void __fastcall DoSynchronizeProgress(const TSynchronizeData & Data, bool Collect);
  329. void __fastcall DeleteLocalFile(UnicodeString FileName,
  330. const TRemoteFile * File, void * Param);
  331. void __fastcall RecycleFile(UnicodeString FileName, const TRemoteFile * File);
  332. TStrings * __fastcall GetFixedPaths();
  333. void __fastcall DoStartup();
  334. virtual bool __fastcall DoQueryReopen(Exception * E);
  335. virtual void __fastcall FatalError(Exception * E, UnicodeString Msg, UnicodeString HelpKeyword = L"");
  336. void __fastcall ResetConnection();
  337. virtual bool __fastcall DoPromptUser(TSessionData * Data, TPromptKind Kind,
  338. UnicodeString Name, UnicodeString Instructions, TStrings * Prompts,
  339. TStrings * Response);
  340. void __fastcall OpenTunnel();
  341. void __fastcall CloseTunnel();
  342. void __fastcall DoInformation(const UnicodeString & Str, bool Status, int Phase = -1);
  343. bool __fastcall PromptUser(TSessionData * Data, TPromptKind Kind,
  344. UnicodeString Name, UnicodeString Instructions, UnicodeString Prompt, bool Echo,
  345. int MaxLen, UnicodeString & Result);
  346. void __fastcall FileFind(UnicodeString FileName, const TRemoteFile * File, void * Param);
  347. void __fastcall DoFilesFind(UnicodeString Directory, TFilesFindParams & Params, UnicodeString RealDirectory);
  348. bool __fastcall DoCreateLocalFile(const UnicodeString FileName,
  349. TFileOperationProgressType * OperationProgress, HANDLE * AHandle,
  350. bool NoConfirmation);
  351. void __fastcall LockFile(const UnicodeString FileName, const TRemoteFile * File, void * Param);
  352. void __fastcall UnlockFile(const UnicodeString FileName, const TRemoteFile * File, void * Param);
  353. void __fastcall DoLockFile(const UnicodeString & FileName, const TRemoteFile * File);
  354. void __fastcall DoUnlockFile(const UnicodeString & FileName, const TRemoteFile * File);
  355. virtual void __fastcall Information(const UnicodeString & Str, bool Status);
  356. virtual unsigned int __fastcall QueryUser(const UnicodeString Query,
  357. TStrings * MoreMessages, unsigned int Answers, const TQueryParams * Params,
  358. TQueryType QueryType = qtConfirmation);
  359. virtual unsigned int __fastcall QueryUserException(const UnicodeString Query,
  360. Exception * E, unsigned int Answers, const TQueryParams * Params,
  361. TQueryType QueryType = qtConfirmation);
  362. virtual bool __fastcall PromptUser(TSessionData * Data, TPromptKind Kind,
  363. UnicodeString Name, UnicodeString Instructions, TStrings * Prompts, TStrings * Results);
  364. virtual void __fastcall DisplayBanner(const UnicodeString & Banner);
  365. virtual void __fastcall Closed();
  366. virtual void __fastcall ProcessGUI();
  367. void __fastcall Progress(TFileOperationProgressType * OperationProgress);
  368. virtual void __fastcall HandleExtendedException(Exception * E);
  369. bool __fastcall IsListenerFree(unsigned int PortNumber);
  370. void __fastcall DoProgress(TFileOperationProgressType & ProgressData);
  371. void __fastcall DoFinished(TFileOperation Operation, TOperationSide Side, bool Temp,
  372. const UnicodeString & FileName, bool Success, TOnceDoneOperation & OnceDoneOperation);
  373. void __fastcall RollbackAction(TSessionAction & Action,
  374. TFileOperationProgressType * OperationProgress, Exception * E = NULL);
  375. void __fastcall DoAnyCommand(const UnicodeString Command, TCaptureOutputEvent OutputEvent,
  376. TCallSessionAction * Action);
  377. TRemoteFileList * __fastcall DoReadDirectoryListing(UnicodeString Directory, bool UseCache);
  378. RawByteString __fastcall EncryptPassword(const UnicodeString & Password);
  379. UnicodeString __fastcall DecryptPassword(const RawByteString & Password);
  380. UnicodeString __fastcall GetRemoteFileInfo(TRemoteFile * File);
  381. void __fastcall LogRemoteFile(TRemoteFile * File);
  382. UnicodeString __fastcall FormatFileDetailsForLog(const UnicodeString & FileName, TDateTime Modification, __int64 Size);
  383. void __fastcall LogFileDetails(const UnicodeString & FileName, TDateTime Modification, __int64 Size);
  384. void __fastcall LogFileDone(TFileOperationProgressType * OperationProgress, const UnicodeString & DestFileName);
  385. void __fastcall LogTotalTransferDetails(
  386. const UnicodeString TargetDir, const TCopyParamType * CopyParam,
  387. TFileOperationProgressType * OperationProgress, bool Parallel, TStrings * Files);
  388. void __fastcall LogTotalTransferDone(TFileOperationProgressType * OperationProgress);
  389. virtual TTerminal * __fastcall GetPasswordSource();
  390. void __fastcall DoEndTransaction(bool Inform);
  391. bool __fastcall VerifyCertificate(
  392. const UnicodeString & CertificateStorageKey, const UnicodeString & SiteKey,
  393. const UnicodeString & Fingerprint,
  394. const UnicodeString & CertificateSubject, int Failures);
  395. void __fastcall CacheCertificate(const UnicodeString & CertificateStorageKey,
  396. const UnicodeString & SiteKey, const UnicodeString & Fingerprint, int Failures);
  397. bool __fastcall ConfirmCertificate(
  398. TSessionInfo & SessionInfo, int Failures, const UnicodeString & CertificateStorageKey, bool CanRemember);
  399. void __fastcall CollectTlsUsage(const UnicodeString & TlsVersionStr);
  400. bool __fastcall LoadTlsCertificate(X509 *& Certificate, EVP_PKEY *& PrivateKey);
  401. bool __fastcall TryStartOperationWithFile(
  402. const UnicodeString & FileName, TFileOperation Operation1, TFileOperation Operation2 = foNone);
  403. void __fastcall StartOperationWithFile(
  404. const UnicodeString & FileName, TFileOperation Operation1, TFileOperation Operation2 = foNone);
  405. bool __fastcall CanRecurseToDirectory(const TRemoteFile * File);
  406. bool __fastcall DoOnCustomCommand(const UnicodeString & Command);
  407. bool __fastcall CanParallel(const TCopyParamType * CopyParam, int Params, TParallelOperation * ParallelOperation);
  408. void __fastcall CopyParallel(TParallelOperation * ParallelOperation, TFileOperationProgressType * OperationProgress);
  409. void __fastcall DoCopyToRemote(
  410. TStrings * FilesToCopy, const UnicodeString & TargetDir, const TCopyParamType * CopyParam, int Params,
  411. TFileOperationProgressType * OperationProgress, unsigned int Flags, TOnceDoneOperation & OnceDoneOperation);
  412. void __fastcall SourceRobust(
  413. const UnicodeString & FileName, const UnicodeString & TargetDir, const TCopyParamType * CopyParam, int Params,
  414. TFileOperationProgressType * OperationProgress, unsigned int Flags);
  415. void __fastcall Source(
  416. const UnicodeString & FileName, const UnicodeString & TargetDir, const TCopyParamType * CopyParam, int Params,
  417. TFileOperationProgressType * OperationProgress, unsigned int Flags, TUploadSessionAction & Action, bool & ChildError);
  418. void __fastcall DirectorySource(
  419. const UnicodeString & DirectoryName, const UnicodeString & TargetDir, const UnicodeString & DestDirectoryName,
  420. int Attrs, const TCopyParamType * CopyParam, int Params,
  421. TFileOperationProgressType * OperationProgress, unsigned int Flags);
  422. void __fastcall SelectTransferMode(
  423. const UnicodeString & BaseFileName, TOperationSide Side, const TCopyParamType * CopyParam,
  424. const TFileMasks::TParams & MaskParams);
  425. void __fastcall SelectSourceTransferMode(const TLocalFileHandle & Handle, const TCopyParamType * CopyParam);
  426. void __fastcall UpdateSource(const TLocalFileHandle & Handle, const TCopyParamType * CopyParam, int Params);
  427. void __fastcall DoCopyToLocal(
  428. TStrings * FilesToCopy, const UnicodeString & TargetDir, const TCopyParamType * CopyParam, int Params,
  429. TFileOperationProgressType * OperationProgress, unsigned int Flags, TOnceDoneOperation & OnceDoneOperation);
  430. void __fastcall SinkRobust(
  431. const UnicodeString & FileName, const TRemoteFile * File, const UnicodeString & TargetDir,
  432. const TCopyParamType * CopyParam, int Params, TFileOperationProgressType * OperationProgress, unsigned int Flags);
  433. void __fastcall Sink(
  434. const UnicodeString & FileName, const TRemoteFile * File, const UnicodeString & TargetDir,
  435. const TCopyParamType * CopyParam, int Params, TFileOperationProgressType * OperationProgress, unsigned int Flags,
  436. TDownloadSessionAction & Action);
  437. void __fastcall SinkFile(UnicodeString FileName, const TRemoteFile * File, void * Param);
  438. void __fastcall UpdateTargetAttrs(
  439. const UnicodeString & DestFullName, const TRemoteFile * File, const TCopyParamType * CopyParam, int Attrs);
  440. void __fastcall UpdateTargetTime(HANDLE Handle, TDateTime Modification, TDSTMode DSTMode);
  441. __property TFileOperationProgressType * OperationProgress = { read=FOperationProgress };
  442. public:
  443. __fastcall TTerminal(TSessionData * SessionData, TConfiguration * Configuration);
  444. __fastcall ~TTerminal();
  445. void __fastcall Open();
  446. void __fastcall Close();
  447. void __fastcall FingerprintScan(UnicodeString & SHA256, UnicodeString & MD5);
  448. void __fastcall Reopen(int Params);
  449. virtual void __fastcall DirectoryModified(const UnicodeString Path, bool SubDirs);
  450. virtual void __fastcall DirectoryLoaded(TRemoteFileList * FileList);
  451. void __fastcall ShowExtendedException(Exception * E);
  452. void __fastcall Idle();
  453. void __fastcall RecryptPasswords();
  454. bool __fastcall AllowedAnyCommand(const UnicodeString Command);
  455. void __fastcall AnyCommand(const UnicodeString Command, TCaptureOutputEvent OutputEvent);
  456. void __fastcall CloseOnCompletion(
  457. TOnceDoneOperation Operation = odoDisconnect, const UnicodeString & Message = L"",
  458. const UnicodeString & TargetLocalPath = L"", const UnicodeString & DestLocalFileName = L"");
  459. UnicodeString __fastcall AbsolutePath(UnicodeString Path, bool Local);
  460. void __fastcall BeginTransaction();
  461. void __fastcall ReadCurrentDirectory();
  462. void __fastcall ReadDirectory(bool ReloadOnly, bool ForceCache = false);
  463. TRemoteFileList * __fastcall ReadDirectoryListing(UnicodeString Directory, const TFileMasks & Mask);
  464. TRemoteFileList * __fastcall CustomReadDirectoryListing(UnicodeString Directory, bool UseCache);
  465. TRemoteFile * __fastcall ReadFileListing(UnicodeString Path);
  466. void __fastcall ReadFile(const UnicodeString FileName, TRemoteFile *& File);
  467. bool __fastcall FileExists(const UnicodeString FileName, TRemoteFile ** File = NULL);
  468. void __fastcall ReadSymlink(TRemoteFile * SymlinkFile, TRemoteFile *& File);
  469. bool __fastcall CopyToLocal(TStrings * FilesToCopy,
  470. const UnicodeString TargetDir, const TCopyParamType * CopyParam, int Params, TParallelOperation * ParallelOperation);
  471. bool __fastcall CopyToRemote(TStrings * FilesToCopy,
  472. const UnicodeString TargetDir, const TCopyParamType * CopyParam, int Params, TParallelOperation * ParallelOperation);
  473. int __fastcall CopyToParallel(TParallelOperation * ParallelOperation, TFileOperationProgressType * OperationProgress);
  474. void __fastcall LogParallelTransfer(TParallelOperation * ParallelOperation);
  475. void __fastcall CreateDirectory(const UnicodeString DirName,
  476. const TRemoteProperties * Properties = NULL);
  477. void __fastcall CreateLink(const UnicodeString FileName, const UnicodeString PointTo, bool Symbolic);
  478. void __fastcall DeleteFile(UnicodeString FileName,
  479. const TRemoteFile * File = NULL, void * Params = NULL);
  480. bool __fastcall DeleteFiles(TStrings * FilesToDelete, int Params = 0);
  481. bool __fastcall DeleteLocalFiles(TStrings * FileList, int Params = 0);
  482. bool __fastcall IsRecycledFile(UnicodeString FileName);
  483. void __fastcall CustomCommandOnFile(UnicodeString FileName,
  484. const TRemoteFile * File, void * AParams);
  485. void __fastcall CustomCommandOnFiles(UnicodeString Command, int Params,
  486. TStrings * Files, TCaptureOutputEvent OutputEvent);
  487. void __fastcall ChangeDirectory(const UnicodeString Directory);
  488. void __fastcall EndTransaction();
  489. void __fastcall HomeDirectory();
  490. UnicodeString __fastcall GetHomeDirectory();
  491. void __fastcall ChangeFileProperties(UnicodeString FileName,
  492. const TRemoteFile * File, /*const TRemoteProperties */ void * Properties);
  493. void __fastcall ChangeFilesProperties(TStrings * FileList,
  494. const TRemoteProperties * Properties);
  495. bool __fastcall LoadFilesProperties(TStrings * FileList);
  496. void __fastcall TerminalError(UnicodeString Msg);
  497. void __fastcall TerminalError(Exception * E, UnicodeString Msg, UnicodeString HelpKeyword = L"");
  498. void __fastcall ReloadDirectory();
  499. void __fastcall RefreshDirectory();
  500. void __fastcall RenameFile(const TRemoteFile * File, const UnicodeString NewName, bool CheckExistence);
  501. void __fastcall MoveFile(const UnicodeString FileName, const TRemoteFile * File,
  502. /*const TMoveFileParams*/ void * Param);
  503. bool __fastcall MoveFiles(TStrings * FileList, const UnicodeString Target,
  504. const UnicodeString FileMask);
  505. void __fastcall CopyFile(const UnicodeString FileName, const TRemoteFile * File,
  506. /*const TMoveFileParams*/ void * Param);
  507. bool __fastcall CopyFiles(TStrings * FileList, const UnicodeString Target,
  508. const UnicodeString FileMask);
  509. bool __fastcall CalculateFilesSize(TStrings * FileList, __int64 & Size,
  510. int Params, const TCopyParamType * CopyParam, bool AllowDirs,
  511. TCalculateSizeStats & Stats);
  512. void __fastcall CalculateFilesChecksum(const UnicodeString & Alg, TStrings * FileList,
  513. TStrings * Checksums, TCalculatedChecksumEvent OnCalculatedChecksum);
  514. void __fastcall ClearCaches();
  515. TSynchronizeChecklist * __fastcall SynchronizeCollect(const UnicodeString LocalDirectory,
  516. const UnicodeString RemoteDirectory, TSynchronizeMode Mode,
  517. const TCopyParamType * CopyParam, int Params,
  518. TSynchronizeDirectory OnSynchronizeDirectory, TSynchronizeOptions * Options);
  519. void __fastcall SynchronizeApply(TSynchronizeChecklist * Checklist,
  520. const UnicodeString LocalDirectory, const UnicodeString RemoteDirectory,
  521. const TCopyParamType * CopyParam, int Params,
  522. TSynchronizeDirectory OnSynchronizeDirectory);
  523. void __fastcall FilesFind(UnicodeString Directory, const TFileMasks & FileMask,
  524. TFileFoundEvent OnFileFound, TFindingFileEvent OnFindingFile);
  525. void __fastcall SpaceAvailable(const UnicodeString Path, TSpaceAvailable & ASpaceAvailable);
  526. void __fastcall LockFiles(TStrings * FileList);
  527. void __fastcall UnlockFiles(TStrings * FileList);
  528. TRemoteFileList * __fastcall DirectoryFileList(const UnicodeString Path, TDateTime Timestamp, bool CanLoad);
  529. void __fastcall MakeLocalFileList(const UnicodeString FileName,
  530. const TSearchRec Rec, void * Param);
  531. bool __fastcall FileOperationLoopQuery(Exception & E,
  532. TFileOperationProgressType * OperationProgress, const UnicodeString Message,
  533. unsigned int Flags, UnicodeString SpecialRetry = L"", UnicodeString HelpKeyword = L"");
  534. void __fastcall FileOperationLoopEnd(Exception & E,
  535. TFileOperationProgressType * OperationProgress, const UnicodeString & Message,
  536. unsigned int Flags, const UnicodeString & SpecialRetry, const UnicodeString & HelpKeyword);
  537. TUsableCopyParamAttrs __fastcall UsableCopyParamAttrs(int Params);
  538. bool __fastcall ContinueReopen(TDateTime Start);
  539. bool __fastcall QueryReopen(Exception * E, int Params,
  540. TFileOperationProgressType * OperationProgress);
  541. UnicodeString __fastcall PeekCurrentDirectory();
  542. void __fastcall FatalAbort();
  543. void __fastcall ReflectSettings();
  544. void __fastcall CollectUsage();
  545. bool __fastcall IsThisOrChild(TTerminal * Terminal);
  546. TTerminal * __fastcall CreateSecondarySession(const UnicodeString & Name, TSessionData * SessionData);
  547. void __fastcall FillSessionDataForCode(TSessionData * Data);
  548. const TSessionInfo & __fastcall GetSessionInfo();
  549. const TFileSystemInfo & __fastcall GetFileSystemInfo(bool Retrieve = false);
  550. void __fastcall inline LogEvent(const UnicodeString & Str);
  551. void __fastcall GetSupportedChecksumAlgs(TStrings * Algs);
  552. UnicodeString __fastcall ChangeFileName(const TCopyParamType * CopyParam,
  553. UnicodeString FileName, TOperationSide Side, bool FirstLevel);
  554. UnicodeString __fastcall GetBaseFileName(UnicodeString FileName);
  555. static UnicodeString __fastcall ExpandFileName(UnicodeString Path,
  556. const UnicodeString BasePath);
  557. __property TSessionData * SessionData = { read = FSessionData };
  558. __property TSessionLog * Log = { read = FLog };
  559. __property TActionLog * ActionLog = { read = FActionLog };
  560. __property TConfiguration * Configuration = { read = FConfiguration };
  561. __property bool Active = { read = GetActive };
  562. __property TSessionStatus Status = { read = FStatus };
  563. __property UnicodeString CurrentDirectory = { read = GetCurrentDirectory, write = SetCurrentDirectory };
  564. __property bool ExceptionOnFail = { read = GetExceptionOnFail, write = SetExceptionOnFail };
  565. __property TRemoteDirectory * Files = { read = FFiles };
  566. __property TNotifyEvent OnChangeDirectory = { read = FOnChangeDirectory, write = FOnChangeDirectory };
  567. __property TReadDirectoryEvent OnReadDirectory = { read = FOnReadDirectory, write = FOnReadDirectory };
  568. __property TNotifyEvent OnStartReadDirectory = { read = FOnStartReadDirectory, write = FOnStartReadDirectory };
  569. __property TReadDirectoryProgressEvent OnReadDirectoryProgress = { read = FOnReadDirectoryProgress, write = FOnReadDirectoryProgress };
  570. __property TDeleteLocalFileEvent OnDeleteLocalFile = { read = FOnDeleteLocalFile, write = FOnDeleteLocalFile };
  571. __property TNotifyEvent OnInitializeLog = { read = FOnInitializeLog, write = FOnInitializeLog };
  572. __property const TRemoteTokenList * Groups = { read = GetGroups };
  573. __property const TRemoteTokenList * Users = { read = GetUsers };
  574. __property const TRemoteTokenList * Membership = { read = GetMembership };
  575. __property TFileOperationProgressEvent OnProgress = { read=FOnProgress, write=FOnProgress };
  576. __property TFileOperationFinished OnFinished = { read=FOnFinished, write=FOnFinished };
  577. __property TCurrentFSProtocol FSProtocol = { read = FFSProtocol };
  578. __property bool UseBusyCursor = { read = FUseBusyCursor, write = FUseBusyCursor };
  579. __property UnicodeString UserName = { read=GetUserName };
  580. __property bool IsCapable[TFSCapability Capability] = { read = GetIsCapable };
  581. __property bool AreCachesEmpty = { read = GetAreCachesEmpty };
  582. __property bool CommandSessionOpened = { read = GetCommandSessionOpened };
  583. __property TTerminal * CommandSession = { read = GetCommandSession };
  584. __property bool AutoReadDirectory = { read = FAutoReadDirectory, write = FAutoReadDirectory };
  585. __property TStrings * FixedPaths = { read = GetFixedPaths };
  586. __property bool ResolvingSymlinks = { read = GetResolvingSymlinks };
  587. __property UnicodeString Password = { read = GetPassword };
  588. __property UnicodeString RememberedPassword = { read = GetRememberedPassword };
  589. __property UnicodeString RememberedTunnelPassword = { read = GetRememberedTunnelPassword };
  590. __property bool StoredCredentialsTried = { read = GetStoredCredentialsTried };
  591. __property TQueryUserEvent OnQueryUser = { read = FOnQueryUser, write = FOnQueryUser };
  592. __property TPromptUserEvent OnPromptUser = { read = FOnPromptUser, write = FOnPromptUser };
  593. __property TDisplayBannerEvent OnDisplayBanner = { read = FOnDisplayBanner, write = FOnDisplayBanner };
  594. __property TExtendedExceptionEvent OnShowExtendedException = { read = FOnShowExtendedException, write = FOnShowExtendedException };
  595. __property TInformationEvent OnInformation = { read = FOnInformation, write = FOnInformation };
  596. __property TCustomCommandEvent OnCustomCommand = { read = FOnCustomCommand, write = FOnCustomCommand };
  597. __property TNotifyEvent OnClose = { read = FOnClose, write = FOnClose };
  598. __property int TunnelLocalPortNumber = { read = FTunnelLocalPortNumber };
  599. };
  600. //---------------------------------------------------------------------------
  601. class TSecondaryTerminal : public TTerminal
  602. {
  603. public:
  604. __fastcall TSecondaryTerminal(TTerminal * MainTerminal,
  605. TSessionData * SessionData, TConfiguration * Configuration,
  606. const UnicodeString & Name);
  607. void __fastcall UpdateFromMain();
  608. __property TTerminal * MainTerminal = { read = FMainTerminal };
  609. protected:
  610. virtual void __fastcall DirectoryLoaded(TRemoteFileList * FileList);
  611. virtual void __fastcall DirectoryModified(const UnicodeString Path,
  612. bool SubDirs);
  613. virtual TTerminal * __fastcall GetPasswordSource();
  614. private:
  615. TTerminal * FMainTerminal;
  616. };
  617. //---------------------------------------------------------------------------
  618. class TTerminalList : public TObjectList
  619. {
  620. public:
  621. __fastcall TTerminalList(TConfiguration * AConfiguration);
  622. __fastcall ~TTerminalList();
  623. virtual TTerminal * __fastcall NewTerminal(TSessionData * Data);
  624. virtual void __fastcall FreeTerminal(TTerminal * Terminal);
  625. void __fastcall FreeAndNullTerminal(TTerminal * & Terminal);
  626. void __fastcall RecryptPasswords();
  627. __property TTerminal * Terminals[int Index] = { read=GetTerminal };
  628. protected:
  629. virtual TTerminal * __fastcall CreateTerminal(TSessionData * Data);
  630. private:
  631. TConfiguration * FConfiguration;
  632. TTerminal * __fastcall GetTerminal(int Index);
  633. };
  634. //---------------------------------------------------------------------------
  635. struct TCustomCommandParams
  636. {
  637. UnicodeString Command;
  638. int Params;
  639. TCaptureOutputEvent OutputEvent;
  640. };
  641. //---------------------------------------------------------------------------
  642. struct TCalculateSizeStats
  643. {
  644. TCalculateSizeStats();
  645. int Files;
  646. int Directories;
  647. int SymLinks;
  648. TStrings * FoundFiles;
  649. };
  650. //---------------------------------------------------------------------------
  651. struct TCalculateSizeParams
  652. {
  653. __int64 Size;
  654. int Params;
  655. const TCopyParamType * CopyParam;
  656. TCalculateSizeStats * Stats;
  657. bool AllowDirs;
  658. TCollectedFileList * Files;
  659. UnicodeString LastDirPath;
  660. bool Result;
  661. };
  662. //---------------------------------------------------------------------------
  663. struct TOverwriteFileParams
  664. {
  665. TOverwriteFileParams();
  666. __int64 SourceSize;
  667. __int64 DestSize;
  668. TDateTime SourceTimestamp;
  669. TDateTime DestTimestamp;
  670. TModificationFmt SourcePrecision;
  671. TModificationFmt DestPrecision;
  672. };
  673. //---------------------------------------------------------------------------
  674. typedef std::vector<TDateTime> TDateTimes;
  675. //---------------------------------------------------------------------------
  676. struct TMakeLocalFileListParams
  677. {
  678. TStrings * FileList;
  679. TDateTimes * FileTimes;
  680. bool IncludeDirs;
  681. bool Recursive;
  682. };
  683. //---------------------------------------------------------------------------
  684. struct TSynchronizeOptions
  685. {
  686. TSynchronizeOptions();
  687. ~TSynchronizeOptions();
  688. TStringList * Filter;
  689. bool __fastcall FilterFind(const UnicodeString & FileName);
  690. bool __fastcall MatchesFilter(const UnicodeString & FileName);
  691. };
  692. //---------------------------------------------------------------------------
  693. class TSynchronizeChecklist
  694. {
  695. friend class TTerminal;
  696. public:
  697. enum TAction { saNone, saUploadNew, saDownloadNew, saUploadUpdate,
  698. saDownloadUpdate, saDeleteRemote, saDeleteLocal };
  699. static const int ActionCount = saDeleteLocal;
  700. class TItem
  701. {
  702. friend class TTerminal;
  703. public:
  704. struct TFileInfo
  705. {
  706. UnicodeString FileName;
  707. UnicodeString Directory;
  708. TDateTime Modification;
  709. TModificationFmt ModificationFmt;
  710. __int64 Size;
  711. };
  712. TAction Action;
  713. bool IsDirectory;
  714. TFileInfo Local;
  715. TFileInfo Remote;
  716. int ImageIndex;
  717. bool Checked;
  718. TRemoteFile * RemoteFile;
  719. const UnicodeString& GetFileName() const;
  720. ~TItem();
  721. private:
  722. FILETIME FLocalLastWriteTime;
  723. TItem();
  724. };
  725. ~TSynchronizeChecklist();
  726. void __fastcall Update(const TItem * Item, bool Check, TAction Action);
  727. static TAction __fastcall Reverse(TAction Action);
  728. __property int Count = { read = GetCount };
  729. __property const TItem * Item[int Index] = { read = GetItem };
  730. protected:
  731. TSynchronizeChecklist();
  732. void Sort();
  733. void Add(TItem * Item);
  734. int GetCount() const;
  735. const TItem * GetItem(int Index) const;
  736. private:
  737. TList * FList;
  738. static int __fastcall Compare(void * Item1, void * Item2);
  739. };
  740. //---------------------------------------------------------------------------
  741. struct TSpaceAvailable
  742. {
  743. TSpaceAvailable();
  744. __int64 BytesOnDevice;
  745. __int64 UnusedBytesOnDevice;
  746. __int64 BytesAvailableToUser;
  747. __int64 UnusedBytesAvailableToUser;
  748. unsigned long BytesPerAllocationUnit;
  749. };
  750. //---------------------------------------------------------------------------
  751. class TRobustOperationLoop
  752. {
  753. public:
  754. TRobustOperationLoop(TTerminal * Terminal, TFileOperationProgressType * OperationProgress, bool * AnyTransfer = NULL);
  755. ~TRobustOperationLoop();
  756. bool TryReopen(Exception & E);
  757. bool ShouldRetry();
  758. bool Retry();
  759. private:
  760. TTerminal * FTerminal;
  761. TFileOperationProgressType * FOperationProgress;
  762. bool FRetry;
  763. bool * FAnyTransfer;
  764. bool FPrevAnyTransfer;
  765. TDateTime FStart;
  766. };
  767. //---------------------------------------------------------------------------
  768. class TCollectedFileList : public TObject
  769. {
  770. public:
  771. TCollectedFileList();
  772. int Add(const UnicodeString & FileName, TObject * Object, bool Dir);
  773. void DidNotRecurse(int Index);
  774. void Delete(int Index);
  775. int Count() const;
  776. UnicodeString GetFileName(int Index) const;
  777. TObject * GetObject(int Index) const;
  778. bool IsDir(int Index) const;
  779. bool IsRecursed(int Index) const;
  780. private:
  781. struct TFileData
  782. {
  783. UnicodeString FileName;
  784. TObject * Object;
  785. bool Dir;
  786. bool Recursed;
  787. };
  788. typedef std::vector<TFileData> TFileDataList;
  789. TFileDataList FList;
  790. };
  791. //---------------------------------------------------------------------------
  792. class TParallelOperation
  793. {
  794. public:
  795. TParallelOperation(TOperationSide Side);
  796. ~TParallelOperation();
  797. void Init(
  798. TStrings * AFiles, const UnicodeString & TargetDir, const TCopyParamType * CopyParam, int Params,
  799. TFileOperationProgressType * MainOperationProgress, const UnicodeString & MainName);
  800. bool IsInitialized();
  801. void WaitFor();
  802. bool ShouldAddClient();
  803. void AddClient();
  804. void RemoveClient();
  805. int GetNext(
  806. TTerminal * Terminal, UnicodeString & FileName, TObject *& Object, UnicodeString & TargetDir,
  807. bool & Dir, bool & Recursed);
  808. void Done(const UnicodeString & FileName, bool Dir, bool Success);
  809. __property TOperationSide Side = { read = FSide };
  810. __property const TCopyParamType * CopyParam = { read = FCopyParam };
  811. __property int Params = { read = FParams };
  812. __property UnicodeString TargetDir = { read = FTargetDir };
  813. __property TFileOperationProgressType * MainOperationProgress = { read = FMainOperationProgress };
  814. __property UnicodeString MainName = { read = FMainName };
  815. private:
  816. struct TDirectoryData
  817. {
  818. UnicodeString OppositePath;
  819. bool Exists;
  820. };
  821. std::unique_ptr<TStrings> FFileList;
  822. int FIndex;
  823. typedef std::map<UnicodeString, TDirectoryData> TDirectories;
  824. TDirectories FDirectories;
  825. UnicodeString FTargetDir;
  826. const TCopyParamType * FCopyParam;
  827. int FParams;
  828. bool FProbablyEmpty;
  829. int FClients;
  830. std::unique_ptr<TCriticalSection> FSection;
  831. TFileOperationProgressType * FMainOperationProgress;
  832. TOperationSide FSide;
  833. UnicodeString FMainName;
  834. bool CheckEnd(TCollectedFileList * Files);
  835. };
  836. //---------------------------------------------------------------------------
  837. struct TLocalFileHandle
  838. {
  839. TLocalFileHandle();
  840. ~TLocalFileHandle();
  841. void Dismiss();
  842. void Close();
  843. void Release();
  844. UnicodeString FileName;
  845. HANDLE Handle;
  846. int Attrs;
  847. bool Directory;
  848. TDateTime Modification;
  849. __int64 MTime;
  850. __int64 ATime;
  851. __int64 Size;
  852. };
  853. //---------------------------------------------------------------------------
  854. #endif