Terminal.h 38 KB

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