开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Ftp客户端 > 查看源码
RemoteAdmin.cpp
资源名称：warftpd.zip　[点击查看]
上传用户：surprise9
上传日期：2007-01-04
资源大小：426k
文件大小：25k
源码类别：

Ftp客户端

开发平台：

Visual C++

RemoteAdmin.cpp：源码内容
  1. // This is part of the WAR SOFTWARE SERIES initiated by Jarle Aase
  2. // Copyright 1996 by Jarle Aase. All rights reserved.
  3. // See the "War Software Series Licende Agreement" for details concerning 
  4. // use and distribution.
  5. // ---
  6. // This source code, executables and programs containing source code or
  7. // binaries or proprietetary technology from the War Software Series are
  8. // NOT alloed used, viewed or tested by any governmental agencies in
  9. // any countries. This includes the government, departments, police, 
  10. // military etc.
  11. // ---
  12. // This file is intended for use with Tab space = 2
  13. // Created and maintained in MSVC Developer Studio
  14. // ---
  15. // NAME : RemoteAdmin.cpp
  16. // PURPOSE : Remote administration daemon interface
  17. // PROGRAM : 
  18. // DATE : Nov. 4 1996
  19. // AUTHOR : Jarle Aase
  20. // ---
  21. // REVISION HISTORY
  22. //
  25. #include "stdafx.h"
  26. #include "WarDaemon.h"
  29. #ifdef _DEBUG
  30. #define new DEBUG_NEW
  31. #undef THIS_FILE
  32. static char THIS_FILE[] = __FILE__;
  33. #endif
  35. ////////////////////////////////////////////////////////////////////
  36. // Admin Command parser
  38. enum // Token ID's
  39. {
  40. TOK_QUIT = TOK_START_TAB, TOK_LIST, TOK_OPTS, TOK_OPT, TOK_SET, TOK_USER, TOK_USRS,
  41. TOK_CREA, TOK_DELE, TOK_SHOW, TOK_ON, TOK_OFF, TOK_EVNT, TOK_STAT, TOK_VER, TOK_GET,
  42. TOK_FIND, TOK_SHDN, TOK_GROUP, TOK_CLASS, TOK_VSERVER, TOK_RENAME, TOK_DIR, TOK_CHMOD,
  43. TOK_GOONL, TOK_GOOFFLN, TOK_RESTART, TOK_EXTENSIONS, TOK_DLL,
  44. };
  46. static STokenTab BaseTokens[] =
  47. {
  48. {TOK_QUIT, "QUIT" },
  49. {TOK_LIST, "LIST" },
  50. {TOK_SHOW, "SHOW" },
  51. {TOK_SET, "SET" },
  52. {TOK_GET, "GET" },
  53. {TOK_OPTS, "OPTIONS"},
  54. {TOK_OPT, "OPTION" },
  55. {TOK_USER, "USER" },
  56. {TOK_USRS, "USERS" },
  57. {TOK_CREA, "CREATE" },
  58. {TOK_DELE, "DELETE" },
  59. {TOK_EVNT, "EVENTS" },
  60. {TOK_ON, "ON", },
  61. {TOK_OFF, "OFF" },
  62. {TOK_STAT,  "STATUS"},
  63. {TOK_VER,   "VERSION"},
  64. {TOK_FIND, "FIND"},
  65. {TOK_SHDN, "SHUTDOWN"},
  66. {TOK_GROUP, "GROUP"},
  67. {TOK_CLASS, "CLASS"},
  68. {TOK_VSERVER,"VSERVER"},
  69. {TOK_RENAME, "RENAME"},
  70. {TOK_DIR,  "DIR"},
  71. {TOK_CHMOD,  "CHMOD"},
  72. {TOK_GOONL,  "GOONLINE"},
  73. {TOK_GOOFFLN,"GOOFFLINE"},
  74. {TOK_RESTART,"RESTART"},
  75. {TOK_EXTENSIONS,"EXTENSIONS"},
  76. {TOK_DLL, "DLL"},
  77. {TOK_INVALID, "" }
  78. };
  81. enum // Commands recognized on this level
  82. {
  83. CMD_QUIT = CMD_START_TREE, CMD_LOPT, CMD_SOPT, CMD_LUSR, CMD_CRUS, CMD_SHUS, CMD_STUS,
  84. CMD_EVON, CMD_EVOF, CMD_STAT, CMD_VER, CMD_GOPT, CMD_FUNA, CMD_FUNO, CMD_GUOP, CMD_SHDN,
  85. CMD_LUST, CMD_CRGR, CMD_CRCL, CMD_CRVS, CMD_DELUS, CMD_RENUS, CMD_LDIR, CMD_CHMOD,
  86. CMD_GONL, CMD_GOOF, CMD_RSTR, CMD_LIEX, CMD_GETEXT, CMD_GETDLL, CMD_SETDLL,
  87. };
  89. static SCommandTree ListUserCmds[] =
  90. {
  91. {TOK_INT, CMD_LUST, PROCESS, 0,  NULL, 0, LEX_WANT_STRING, "LIST USERS <type> <pattern>" },
  92. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  93. };
  96. static SCommandTree ListCmds[] =
  97. {
  98. {TOK_OPTS, CMD_LOPT, PROCESS, 0,  NULL, 0, LEX_WANT_STRING, "LIST OPTIONS (list option groups)" },
  99. {TOK_USRS, CMD_INVALID, PROCESS, CMDF_PARAMETER,  ListUserCmds, ' ', LEX_WANT_INT, "" },
  100. {TOK_USRS, CMD_LUSR, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "LIST USERS <pattern>" },
  101. {TOK_DIR,  CMD_LDIR, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "LIST DIR <path>" },
  102. {TOK_EXTENSIONS, CMD_LIEX, PROCESS, 0, NULL, 0, 0, "LIST EXTENSIONS"},
  103. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  104. };
  106. static SCommandTree EventCmds[] =
  107. {
  108. {TOK_ON, CMD_EVON, PROCESS, 0,  NULL, 0, 0, "SET EVENTS n ON (Torn on events)" },
  109. {TOK_OFF, CMD_EVOF, PROCESS, 0,  NULL, 0, 0, "SET EVENTS n OFF (Turns off events)" },
  110. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  111. };
  113. static SCommandTree EventNum[] =
  114. {
  115. {TOK_INT, CMD_INVALID, PROCESS, 0, EventCmds, 0, LEX_WANT_CMD, "" },
  116. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  117. };
  120. static SCommandTree SetCmds[] =
  121. {
  122. {TOK_OPT,  CMD_SOPT, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "SET OPTION <optgrp/option=value>" },
  123. {TOK_USER, CMD_STUS, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "SET USER <user/option=value>" },
  124. {TOK_EVNT, CMD_INVALID, PROCESS, 0, EventNum, ' ', LEX_WANT_INT, "SET EVENTS n <ON or OFF>" },
  125. {TOK_DLL,  CMD_SETDLL, PROCESS, CMDF_PARAMETER, NULL, 0, LEX_WANT_STRING, "SET DLL <name> = 1 | 0" },
  126. {TOK_INVALID, CMD_INVALID, 0, 0,   NULL, 0,   0,             NULL}
  127. };
  129. static SCommandTree GetUserCmds[] =
  130. {
  131. {TOK_OPT,  CMD_GUOP, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "GET USER OPTION <User/option>" },
  132. {TOK_INVALID, CMD_INVALID, 0, 0,   NULL, 0,   0,             NULL}
  133. };
  135. static SCommandTree GetCmds[] =
  136. {
  137. {TOK_OPT,  CMD_GOPT, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "GET OPTION <optgrp/option>" },
  138. {TOK_USER, CMD_INVALID, PROCESS, CMDF_PARAMETER, GetUserCmds, ' ', LEX_WANT_CMD, "GET USER <what>" },
  139. {TOK_EXTENSIONS, CMD_LIEX, PROCESS, CMDF_PARAMETER, NULL, 0, LEX_WANT_STRING, "GET EXTENSION <name>" },
  140. {TOK_DLL, CMD_GETDLL, PROCESS, CMDF_PARAMETER, NULL, 0, LEX_WANT_STRING, "GET DLL <name>"},
  141. {TOK_INVALID, CMD_INVALID, 0, 0,   NULL, 0,   0,             NULL}
  142. };
  145. static SCommandTree CreaCmds[] =
  146. {
  147. {TOK_USER, CMD_CRUS, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "CREATE USER name" },
  148. {TOK_GROUP, CMD_CRGR, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "CREATE GROUP name" },
  149. {TOK_CLASS, CMD_CRCL, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "CREATE CLASS name" },
  150. {TOK_VSERVER, CMD_CRVS, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "CREATE VSERVER name" },
  151. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  152. };
  154. static SCommandTree FunaCmds[] =
  155. {
  156. {TOK_USER, CMD_FUNA, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_INT, "FIND USER <ID> <type>" },
  157. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  158. };
  161. static SCommandTree FindCmds[] =
  162. {
  163. {TOK_USER, CMD_FUNO, PROCESS, CMDF_PARAMETER,  NULL, ' ', LEX_WANT_INT, "FIND USER <number>" },
  164. {TOK_USER, CMD_INVALID, PROCESS, CMDF_PARAMETER,  FunaCmds, ' ', LEX_WANT_STRING, "FIND USER <ID> <type>" },
  165. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  166. };
  168. static SCommandTree ShowCmds[] =
  169. {
  170. {TOK_USER, CMD_SHUS, PROCESS,  CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "SHOW USER name" },
  171. {TOK_VER,  CMD_VER , PRELOGIN, 0,  NULL, 0, LEX_WANT_STRING, "SHOW VERSION (show server version)" },
  172. {TOK_STAT, CMD_STAT, PROCESS,  0,  NULL, 0, LEX_WANT_STRING, "SHOW STATUS (show server status)" },
  173. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  174. };
  176. static SCommandTree DeleCmds[] =
  177. {
  178. {TOK_USER, CMD_DELUS, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "DELTE USER <num>" },
  179. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  180. };
  182. static SCommandTree RenameUserCmds[] =
  183. {
  184. {TOK_USER, CMD_RENUS, PROCESS, CMDF_PARAMETER,  NULL, 0, LEX_WANT_STRING, "RENAME USER <num> <new name>" },
  185. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  186. };
  188. static SCommandTree RenameCmds[] =
  189. {
  190. {TOK_USER, CMD_INVALID, PROCESS, CMDF_PARAMETER,  RenameUserCmds, ' ', LEX_WANT_STRING, "RENAME USER <num> <new name>" },
  191. {TOK_INVALID, CMD_INVALID, 0,  0,  NULL, 0,   0,             NULL}
  192. };
  194. // Command tree
  195. static SCommandTree BaseCmds[] =
  196. {
  197. {TOK_QUIT, CMD_QUIT, PRELOGIN,  0, NULL, ' ', 0, "QUIT (end session)" },
  198. {TOK_LIST, CMD_INVALID, PROCESS, CMDF_PARAMETER, ListCmds, ' ', LEX_WANT_CMD, "LIST <what>" },
  199. {TOK_SET,  CMD_INVALID, PROCESS, CMDF_PARAMETER, SetCmds, ' ', LEX_WANT_CMD, "SET <what>" },
  200. {TOK_GET,  CMD_INVALID, PROCESS, CMDF_PARAMETER, GetCmds, ' ', LEX_WANT_CMD, "GET <what>" },
  201. {TOK_CREA, CMD_INVALID, PROCESS, CMDF_PARAMETER, CreaCmds, ' ', LEX_WANT_CMD, "CREATE <what>" },
  202. {TOK_DELE, CMD_INVALID, PROCESS, CMDF_PARAMETER, DeleCmds,   ' ', LEX_WANT_CMD, "DELETE <what>" },
  203. {TOK_RENAME, CMD_INVALID, PROCESS, CMDF_PARAMETER, RenameCmds,   ' ', LEX_WANT_CMD, "DELETE <what>" },
  204. {TOK_SHOW, CMD_INVALID, PROCESS, CMDF_PARAMETER, ShowCmds,   ' ', LEX_WANT_CMD, "SHOW <what>" },
  205. {TOK_FIND, CMD_INVALID, PROCESS, CMDF_PARAMETER, FindCmds,   ' ', LEX_WANT_CMD, "FIND <what>" },
  206. {TOK_SHDN, CMD_SHDN, PROCESS, 0, NULL, ' ', LEX_WANT_BOOL, "SHUTDOWN (terminate the server)" },
  207. {TOK_CHMOD, CMD_CHMOD, PROCESS, CMDF_PARAMETER, NULL,     0, LEX_WANT_STRING, "CHMOD" },
  208. {TOK_GOONL, CMD_GONL,   PROCESS, 0,               NULL,       ' ', LEX_WANT_CMD, "GOONLINE (go online)"},
  209. {TOK_GOOFFLN, CMD_GOOF, PROCESS, 0,               NULL,       ' ', LEX_WANT_CMD, "GOOFFLINE (go offline)"},
  210. {TOK_RESTART, CMD_RSTR, PROCESS, 0,               NULL,       ' ', LEX_WANT_CMD, "RESTART (Restart server)"},
  211. {TOK_INVALID, CMD_INVALID, 0,    0, NULL, 0,  0,             NULL}
  212. };
  215. CAdminParser::CAdminParser()
  216. {
  217. m_Commands = (SCommandTree *) BaseCmds;
  218. m_Tokens = (STokenTab *) BaseTokens;
  219. }
  221. ///////////////////////////////////////////////////////////////////////////////////////
  222. // CDaemonMaintananceSocket
  224. IMPLEMENT_DYNAMIC(CDaemonMaintananceSocket, CTextSock);
  226. CDaemonMaintananceSocket::CDaemonMaintananceSocket()
  227. {
  228. // Increase login counter
  229. m_pFsys = NULL;
  230. CDaemonStatusSvr::IncOperatorCnt(TRUE);
  231. }
  233. CDaemonMaintananceSocket::~CDaemonMaintananceSocket()
  234. {
  235. if (m_pFsys)
  236. {
  237. m_pFsys->Logout();
  238. }
  239. CDaemonStatusSvr::IncOperatorCnt(FALSE);
  240. }
  242. BOOL CDaemonMaintananceSocket::OnCommand(LPCSTR Text)
  243. {
  244. if (!CTextSock::OnCommand(Text))
  245. return FALSE;
  247. BOOL Rval = TRUE;
  248. CCmdArgs Args;
  249. int CmdID;
  250. CString cBuf;
  251. int ival;
  252. USER MyUser;
  254. // EXT module
  255. if (PrcSockExt(CSock::iOnCommand,0,(WPARAM)0,(LPARAM)&Text))
  256. return TRUE;
  258. // Login
  259. switch(m_State)
  260. {
  261. case PRELOGIN: // We want username
  262. SendCtrlMsg(331,"Password: ", FALSE, FALSE);
  263. if (m_LocalEcho)
  264. m_LocalEcho = '*';
  265. m_State = GOTNAME;
  266. m_ArgSave = Text;
  267. break;
  269. case GOTNAME: // We want password
  270. if (((m_User = CUsr::Login(LT_REMOTE, m_ArgSave, Text, this)) == 0)
  271. || !CUsr::IsAdmin(m_User))
  272. {
  273. SendCtrlMsg(521,"Goodbye. Connection closed.");
  274. delete this;
  275. return FALSE;
  276. }
  277. m_State = PROCESS;
  278. SendMsg(230,"Logged in.");
  279. NotifyLogin(ENL_UPDATE, "");
  281. // Password is OK. Move on to Process..
  282. goto prompt;
  284. case PROCESS:
  285. // Parse command
  286. CmdID = m_Parser.ParseCmd(Text,Args, m_State);
  288. switch(CmdID)
  289. {
  290. case CMD_LIEX: // LIST EXTENSIONS
  291. SendMsg(200,"%s", CAPIHandler::ListAll());
  292. break;
  294. case CMD_GETDLL: // Get a dll from the server
  295. {
  296. LPCSTR p = Args.Arg(2);
  297. if (p && (p = strrchr(p, '.')))
  298. {
  299. if (!stricmp(p,".dll"))
  300. {
  301. if (SendFile(NULL, Args.Arg(2)))
  302. break; // SendFile will reply
  303. }
  304. }
  305. }
  306. LogMsg(LOGF_FILEACC,"CMD_GETDLL - File send '%s' failed.", Args.Arg(2));
  307. SendMsg(550, "File send failed");
  308. break;
  310. case CMD_SETDLL: // Enable/disable dll
  311. if (CAPIHandler::GetPtr() && CAPIHandler::GetPtr()->EnableDll(Args.Arg(2)))
  312. SendMsg(200, "DLL command OK.");
  313. else
  314. SendMsg(550, "DLL command failed.");
  315. break;
  317. case CMD_QUIT:
  318. SendMsg(221,"Goodbye. Connection closed.");
  319. LogMsg(LOGF_INOUT,"User from %s has logged off.", m_PeerName);
  320. delete this;
  321. return FALSE;
  322. break;
  324. case CMD_LOPT: // list options
  325. if (COptions::ListOptions(Args.m_argc > 2 ? Args.Arg(2) : "",cBuf))
  326. SendMsg(200, cBuf);
  327. else
  328. SendMsg(550,"Unknown option group.");
  329. break;
  331. case CMD_SOPT: // Set option
  332. if (Args.m_argc != 3)
  333. SendMsg(501,"Missing required parameter.");
  334. else if (COptions::SetOption(Args[2], TRUE))
  335. SendMsg(200, "OK");
  336. else
  337. SendMsg(550,"Failed to set option. (syntax: Group/Option=new value)");
  338. break;
  340. case CMD_GOPT: // Get option
  341. if (Args.m_argc != 3)
  342. SendMsg(501,"Missing required parameter.");
  343. else if (COptions::GetOption(Args[2], cBuf, TRUE))
  344. SendMsg(200, "%s", cBuf);
  345. else
  346. SendMsg(550,"Failed to get option. (syntax: Group/Option)");
  347. break;
  349. case CMD_LUSR: // List users
  350. if (CUsr::ListUsers(UT_USER, Args.m_argc > 2 ? Args.Arg(2) : "",cBuf, m_LocalEcho))
  351. SendCtrlMsg(200, cBuf);
  352. else
  353. SendCtrlMsg(550,"No match.");
  354. break;
  356. case CMD_LUST: // List users (with type)
  357. if (CUsr::ListUsers(
  358. atoi(Args.Arg(2)), Args.m_argc > 3 ? Args.Arg(3) : "",cBuf, m_LocalEcho))
  359. SendCtrlMsg(200, cBuf);
  360. else
  361. SendCtrlMsg(550,"No match.");
  362. break;
  364. case CMD_CRUS: // Create user name
  365. if ((ival = CUsr::AddUser(UT_USER,Args.Arg(2))) == 0)
  366. SendMsg(550,"Failed to create user <%s>.", Args.Arg(2));
  367. else
  368. SendMsg(200,"User %d <%s> created. Account is not activated.", ival, Args.Arg(2));
  369. break;
  371. case CMD_CRGR: // Create group name
  372. if ((ival = CUsr::AddUser(UT_GROUP,Args.Arg(2))) == 0)
  373. SendMsg(550,"Failed to create user <%s>.", Args.Arg(2));
  374. else
  375. SendMsg(200,"User %d <%s> created. Account is not activated.", ival, Args.Arg(2));
  376. break;
  378. case CMD_CRCL: // Create class name
  379. if ((ival = CUsr::AddUser(UT_CLASS,Args.Arg(2))) == 0)
  380. SendMsg(550,"Failed to create user <%s>.", Args.Arg(2));
  381. else
  382. SendMsg(200,"User %d <%s> created. Account is not activated.", ival, Args.Arg(2));
  383. break;
  385. case CMD_CRVS: // Create virtual server name
  386. if ((ival = CUsr::AddUser(UT_SYSTEM,Args.Arg(2))) == 0)
  387. SendMsg(550,"Failed to create user <%s>.", Args.Arg(2));
  388. else
  389. SendMsg(200,"User %d <%s> created. Account is not activated.", ival, Args.Arg(2));
  390. break;
  392. case CMD_DELUS: // Delete user
  393. if (!CUsr::DeleteUser(Args.Arg(2)))
  394. SendMsg(550,"Failed to delete user <%s>.", Args.Arg(2));
  395. else
  396. SendMsg(200,"User <%s> deleted.", Args.Arg(2));
  397. break;
  399. case CMD_RENUS: // Rename user
  400. if (!CUsr::RenameUser(Args.Arg(2), Args.Arg(3)))
  401. SendMsg(550,"Failed to Rename user <%s>.", Args.Arg(2));
  402. else
  403. SendMsg(200,"User <%s>.", Args.Arg(2));
  404. break;
  406. case CMD_SHUS: // Show user
  407. if (Args.m_argc != 3)
  408. SendMsg(501,"Missing required parameter.");
  409. else if (CUsr::ListUserParams(UT_USER,Args.Arg(2), cBuf))
  410. SendMsg(200, cBuf);
  411. else
  412. SendMsg(550,"User <%s> not found.", Args.Arg(2));
  413. break;
  415. case CMD_FUNO: // Find user number
  416. ASSERT(Args.m_argc == 3);
  418. if (!CUsr::FindUser(atoi(Args.Arg(2)), cBuf))
  419. SendMsg(550,"User #%s not found.", Args.Arg(2));
  420. else
  421. SendMsg(200,"%s", cBuf);
  422. break;
  424. case CMD_FUNA: // Find user name
  425. ASSERT(Args.m_argc == 4);
  427. if ((MyUser = CUsr::FindUser(atoi(Args.Arg(3)), Args.Arg(2))) == INVALID_USER_VALUE)
  428. SendMsg(550,"User %s not found.", Args.Arg(2));
  429. else
  430. SendMsg(200,"%d", MyUser);
  431. break;
  433. case CMD_STUS: // Set user
  434. if (Args.m_argc != 3)
  435. SendMsg(501,"Missing required parameter.");
  436. else if (CUsr::SetUserOption(UT_USER, Args.Arg(2)))
  437. SendMsg(200, "OK");
  438. else
  439. SendMsg(550,"Failed to set User option. (syntax: User/Option=new value)");
  440. break;
  442. case CMD_GUOP:
  443. ASSERT(Args.m_argc == 4);
  444. if (CUsr::GetUserOption(UT_USER, Args.Arg(3), cBuf))
  445. SendMsg(200, "%s", cBuf);
  446. else
  447. SendMsg(550,"Failed to get User option. (syntax: User/Option=default value)");
  448. break;
  450. case CMD_EVON: //
  451. if (m_Events->Register(atoi(Args.Arg(2))))
  452. SendMsg(200, "Events %d (0x%x) is enabled.", 
  453. m_Events->m_EventTypes, m_Events->m_EventTypes);
  454. else
  455. SendMsg(550,"Failed to register one or more events");
  456. break;
  458. case CMD_EVOF:
  459. m_Events->Close(atoi(Args.Arg(2)));
  460. SendMsg(200, "Event(s) %d is closed", atoi(Args.Arg(2)));
  461. break;
  463. case CMD_STAT:
  464. CDaemonStatusSvr::GetStats(cBuf);
  465. SendMsg(200, cBuf);
  466. break;
  468. case CMD_VER:
  469. SendMsg(200, "%s %s%s %s",
  470. CProgramInfo::m_PROGRAM,
  471. CProgramInfo::m_VERSION,
  472. #ifdef _DEBUG
  473. "-DEBUG",
  474. #else
  475. "",
  476. #endif // DEBUG
  477. CProgramInfo::m_COPYRIGHT);
  478. break;
  480. case CMD_SHDN: // Shutdown
  481. SendMsg(200, "System is shutting down.");
  482. CDaemonNotificationWnd::GetWin()->PostMessage(WM_COMMAND, ID_MENU_STOPANDQUIT);
  483. break;
  485. case CMD_GONL: // Go online
  486. SendMsg(200, "OK");
  487. CDaemonNotificationWnd::GetWin()->PostMessage(WM_COMMAND, ID_MENU_GOONLINE);
  488. break;
  490. case CMD_GOOF: // Go offline
  491. SendMsg(200, "OK");
  492. CDaemonNotificationWnd::GetWin()->PostMessage(WM_COMMAND, ID_MENU_GOOFFLINE);
  493. break;
  495. case CMD_RSTR: // Restart
  496. SendMsg(200, "System is restarting down.");
  497. CDaemonNotificationWnd::GetWin()->PostMessage(WM_COMMAND, ID_MENU_RESTART);
  498. break;
  500. case CMD_LDIR: // List directory
  501. {
  502. /*
  503. CFileInfoList List;
  504. if (CFsys::GetFsys()->BldFileInfoList(m_User, "", List, "", Args.Arg(2), TRUE))
  505. {
  506. List.ListRaw(cBuf);
  507. SendMsg(200, "%s", cBuf);
  508. }
  509. else*/
  510. if (m_pFsys)
  511. m_pFsys->Logout();
  512. m_pFsys = new CRAFsys((LPVOID *)&m_pFsys);
  513. if (!m_pFsys->List(Args.Arg(2), this))
  514. {
  515. SendMsg(550, "Failed to list directory '%s'", Args.Arg(2));
  516. }
  517. }
  518. break;
  520. case CMD_CHMOD: 
  521. {
  522. if (m_pFsys)
  523. m_pFsys->Logout();
  524. m_pFsys = new CRAFsys((LPVOID *)&m_pFsys);
  526. CCmdArgs MyArgs("chmod", Args[1], m_Parser);
  527. if (!m_pFsys->ChMod(MyArgs, this))
  528. {
  529. SendMsg(451, "chmod failed.");
  530. LogMsg(LOGF_WARNINGS,"chmod failed before callback");
  531. }
  532. }
  533. break;
  535. // Command errors
  536. case CMD_MISSING_PARAMETER:
  537. SendMsg(501,"Missing parameter in command %s", Text);
  538. break;
  539. case CMD_UNKNOWN_COMMAND:
  540. SendMsg(500, "%s: unrecognized command.", Text);
  541. break;
  542. case CMD_NOT_IMPLEMENTED:
  543. SendMsg(502, "%s: command not implemented.", Text);
  544. break;
  545. case CMD_BAD_LEVEL:
  546. SendMsg(530, "Please login with USER and PASS.");
  547. break;
  548. case CMD_PARSE_ERROR:
  549. case CMD_UNKNOWN_PARAMETER:
  550. SendMsg(500,"'%s': command not understood.", Text);
  551. break;
  552. default:
  553. SendMsg(502,"%s: Command not implemented.", Args.Arg(0));
  554. break;
  555. }
  557. prompt:
  558. if (!m_LocalEcho)
  559. break;
  561. SendCtrlMsg(230,"Command: ", FALSE, FALSE);
  562. break;
  564. default:
  565. SendCtrlMsg(451,"Server error. Unhandled value in m_State.nCommand: ", FALSE, FALSE);
  566. }
  568. if ((m_LocalEcho == '*') && (m_State != GOTNAME))
  569. m_LocalEcho = 1;
  571. return Rval;;
  572. }
  575. void CDaemonMaintananceSocket::Virgin()
  576. {
  577. CTextSock::Virgin();
  578. }
  580. BOOL CDaemonMaintananceSocket::ProcessTelnetNegotiation(int ch1, int ch2)
  581. {
  582. return CTextSock::ProcessTelnetNegotiation(ch1, ch2);
  583. }
  585. void CDaemonMaintananceSocket::InsertPendingText()
  586. {
  587. CTextSock::InsertPendingText();
  588. }
  590. BOOL CDaemonMaintananceSocket::ExpandMacro(LPSTR *To, LPCSTR MacroName, int AvailBytes)
  591. {
  592.  if (CTextSock::ExpandMacro(To, MacroName, AvailBytes))
  593. return TRUE;
  595. // TODO: Add expansion here and return TRUE if the macro was expanded
  596. return FALSE;
  597. }
  601. void CDaemonMaintananceSocket::OnConnect( int nErrorCode )
  602. {
  603. try
  604. {
  605. _OnConnect(nErrorCode);
  606. }
  607. catch(CSocketException *pExc)
  608. {
  609. LogMsg(LOGF_DEBUG,"CDaemonMaintananceSocket::OnConnect(%d) - Caught exception '%s' from module %s",
  610. nErrorCode, pExc->m_ErrorText, pExc->m_ErrorText);
  612. if (!OnHandleWinsockErr(pExc->m_ErrorNum))
  613. delete this;
  615. delete pExc;
  616. }
  617. catch(...)
  618. {
  619. CLog::GetLog()->LogMsg(LOGF_ERROR,"CDaemonMaintananceSocket::OnConnect(%d) - Caught unknown exception", nErrorCode);
  620. }
  621. }
  623. void CDaemonMaintananceSocket::_OnConnect( int nErrorCode )
  624. {
  625. CTextSock::OnConnect(nErrorCode);
  626. }
  628. void CDaemonMaintananceSocket::OnClose( int nErrorCode )
  629. {
  630. try
  631. {
  632. CTextSock::OnClose(nErrorCode);
  633. }
  634. catch(CSocketException *pExc)
  635. {
  636. LogMsg(LOGF_DEBUG,"CDaemonMaintananceSocket::OnClose(%d) - Caught exception '%s' from module %s",
  637. nErrorCode, pExc->m_ErrorText, pExc->m_ErrorText);
  639. if (!OnHandleWinsockErr(pExc->m_ErrorNum))
  640. delete this;
  642. delete pExc;
  643. }
  644. catch(...)
  645. {
  646. CLog::GetLog()->LogMsg(LOGF_ERROR,"CDaemonMaintananceSocket::OnClose(%d) - Caught unknown exception", nErrorCode);
  647. }
  648. }
  650. void CDaemonMaintananceSocket::OnSend( int nErrorCode )
  651. {
  652. try
  653. {
  654. CTextSock::OnSend(nErrorCode);
  655. }
  656. catch(CSocketException *pExc)
  657. {
  658. LogMsg(LOGF_DEBUG,"CDaemonMaintananceSocket::OnSend(%d) - Caught exception '%s' from module %s",
  659. nErrorCode, pExc->m_ErrorText, pExc->m_ErrorText);
  661. if (!OnHandleWinsockErr(pExc->m_ErrorNum))
  662. delete this;
  664. delete pExc;
  665. }
  666. catch(...)
  667. {
  668. CLog::GetLog()->LogMsg(LOGF_ERROR,"CDaemonMaintananceSocket::OnSend(%d) - Caught unknown exception", nErrorCode);
  669. }
  670. }
  672. void CDaemonMaintananceSocket::OnOutOfBandData( int nErrorCode )
  673. {
  674. try
  675. {
  676. CTextSock::OnOutOfBandData(nErrorCode);
  677. }
  678. catch(CSocketException *pExc)
  679. {
  680. LogMsg(LOGF_DEBUG,"CDaemonMaintananceSocket::OnOutOfBandData(%d) - Caught exception '%s' from module %s",
  681. nErrorCode, pExc->m_ErrorText, pExc->m_ErrorText);
  683. if (!OnHandleWinsockErr(pExc->m_ErrorNum))
  684. delete this;
  686. delete pExc;
  687. }
  688. catch(...)
  689. {
  690. CLog::GetLog()->LogMsg(LOGF_ERROR,"CDaemonMaintananceSocket::OnOutOfBandData(%d) - Caught unknown exception", nErrorCode);
  691. }
  692. }
  694. void CDaemonMaintananceSocket::OnReceive( int nErrorCode )
  695. {
  696. try
  697. {
  698. CTextSock::OnReceive(nErrorCode);
  699. }
  700. catch(CSocketException *pExc)
  701. {
  702. LogMsg(LOGF_DEBUG,"CDaemonMaintananceSocket::OnReceive(%d) - Caught exception '%s' from module %s",
  703. nErrorCode, pExc->m_ErrorText, pExc->m_ErrorText);
  705. if (!OnHandleWinsockErr(pExc->m_ErrorNum))
  706. delete this;
  708. delete pExc;
  709. }
  710. catch(...)
  711. {
  712. CLog::GetLog()->LogMsg(LOGF_ERROR,"CDaemonMaintananceSocket::OnReceive(%d) - Caught unknown exception", nErrorCode);
  713. }
  714. }
  717. //////////////////////////////////////////////////////////////////////////////////////////
  718. // CRAFsys
  720. CRAFsys::CRAFsys(LPVOID *pRef)
  721. :CUserFsys(pRef)
  722. {
  723. m_NextStep = 0;
  724. m_AsyncSelectMaskSaved = 0;
  725. m_StateSaved = 0;
  726. m_pSock = NULL;
  727. }
  729. BOOL CRAFsys::SetOnHold()
  730. {
  731. m_AsyncSelectMaskSaved = m_pSock->m_AsyncSelectMask;
  732. m_StateSaved = m_pSock->m_State;
  734. // Prevent socket read/write events
  735. m_pSock->m_AsyncSelectMask &= ~(FD_READ);
  736. m_pSock->AsyncSelect(m_pSock->m_AsyncSelectMask);
  738. // Set block state
  739. m_pSock->m_State = HOLD;
  740. return TRUE;
  741. }
  743. void CRAFsys::ReleaseHold()
  744. {
  745. m_pSock->m_State = m_StateSaved;
  746. m_pSock->m_AsyncSelectMask = m_AsyncSelectMaskSaved;
  747. m_pSock->AsyncSelect(m_pSock->m_AsyncSelectMask);
  748. }
  750. void CRAFsys::CheckForZombie()
  751. {
  752. CUserFsys::CheckForZombie();
  753. }
  756. BOOL CRAFsys::Create(CDaemonMaintananceSocket *pSock)
  757. {
  758. m_pSock = pSock;
  759. m_IsAdmin = CUsr::IsAdmin(m_pSock->m_User);
  760. USER Class = CUsr::GetUserClass(m_pSock->m_User);
  761. return CUserFsys::Create("/", "/", m_pSock->m_User, Class, pSock->m_SocketName);
  762. }
  764. // Called after the file system is initialized
  765. // for the user
  766. BOOL CRAFsys::OnCreate(int nErrorCode)
  767. {
  768. CUserFsys::OnCreate(nErrorCode);
  770. if (nErrorCode)
  771. {
  772. m_pSock->SendMsg(421, "Internal error - unable to initialize your file system");
  773. m_pSock->LogMsg(LOGF_ERROR,"Unable to initialize the users file system.");
  774. delete this;
  775. return FALSE;
  776. }
  778. return NextStep();
  779. }
  781. BOOL CRAFsys::NextStep()
  782. {
  783. switch(m_NextStep)
  784. {
  785. case DOLIST:
  786. if (!DoList())
  787. {
  788. m_pSock->SendMsg(421, "Internal error - unable to proceed with list");
  789. m_pSock->LogMsg(LOGF_ERROR,"Unable to initialize the users file system.");
  790. delete this;
  791. return FALSE;
  792. }
  793. break;
  794. case DOCHMOD:
  795. if (!DoChmod())
  796. {
  797. m_pSock->SendMsg(421, "Internal error - unable to proceed with list");
  798. m_pSock->LogMsg(LOGF_ERROR,"Unable to initialize the users file system.");
  799. delete this;
  800. return FALSE;
  801. }
  802. break;
  803. default:
  804. m_pSock->SendMsg(421, "Internal error - Invalid next step %d", m_NextStep);
  805. m_pSock->LogMsg(LOGF_ERROR,"Internal error - Invalid next step %d", m_NextStep);
  806. delete this;
  807. return FALSE;
  808. }
  810. return TRUE;
  811. }
  814. BOOL CRAFsys::List(LPCSTR Path, CDaemonMaintananceSocket *pSock)
  815. {
  816. m_Path = Path;
  818. // Create the file system
  819. m_NextStep = DOLIST;
  820. return Create(pSock);
  821. }
  823. BOOL CRAFsys::DoList()
  824. {
  825. m_NextStep = 0;
  826. m_FsysPath1 = m_Path;
  827. return ProcessRequest(FSM_WLST, (WPARAM)this, 0);
  828. }
  830. BOOL CRAFsys::OnWlist(int nErrorCode)
  831. {
  832. // List raw.
  833. if (nErrorCode)
  834. m_pSock->SendMsg(550, "WLIST failed with error code %d", nErrorCode);
  835. else
  836. m_pSock->SendMsg(200, "%s", m_FsysPath2);
  838. Logout();
  839. return TRUE;
  840. }
  842. BOOL CRAFsys::ChMod(CCmdArgs& Args, CDaemonMaintananceSocket *pSock)
  843. {
  844. m_CmdArgStore = Args;
  846. // Create the file system
  847. m_NextStep = DOCHMOD;
  848. return Create(pSock);
  849. }
  851. BOOL CRAFsys::DoChmod()
  852. {
  853. m_NextStep = 0;
  854. m_FsysPath1 = m_Path;
  855. return CUserFsys::ChMod(m_CmdArgStore);
  856. }
  859. BOOL CRAFsys::OnChmod(int nErrorCode)
  860. {
  861. if (nErrorCode && m_Output.IsEmpty())
  862. {
  863. m_pSock->SendMsg(551, "chmod failed.");
  864. m_pSock->LogMsg(LOGF_WARNINGS,"chmod failed after callback, error %d", nErrorCode);
  865. }
  866. else
  867. {
  868. m_pSock->SuspendMacros();
  869. m_pSock->SendMsg(200, "chmod: %s", m_Output);
  870. m_pSock->EnableMacros();
  871. }
  873. Logout();
  874. return TRUE;
  875. }