You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

commands.go 7.5KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385
  1. // Copyright (c) 2012-2014 Jeremy Latt
  2. // Copyright (c) 2014-2015 Edmund Huber
  3. // Copyright (c) 2016-2017 Daniel Oaks <daniel@danieloaks.net>
  4. // released under the MIT license
  5. package irc
  6. import (
  7. "github.com/ergochat/irc-go/ircmsg"
  8. )
  9. // Command represents a command accepted from a client.
  10. type Command struct {
  11. handler func(server *Server, client *Client, msg ircmsg.Message, rb *ResponseBuffer) bool
  12. usablePreReg bool
  13. allowedInBatch bool // allowed in client-to-server batches
  14. minParams int
  15. capabs []string
  16. }
  17. // Run runs this command with the given client/message.
  18. func (cmd *Command) Run(server *Server, client *Client, session *Session, msg ircmsg.Message) (exiting bool) {
  19. rb := NewResponseBuffer(session)
  20. rb.Label = GetLabel(msg)
  21. exiting = func() bool {
  22. defer rb.Send(true)
  23. if !client.registered && !cmd.usablePreReg {
  24. rb.Add(nil, server.name, ERR_NOTREGISTERED, "*", client.t("You need to register before you can use that command"))
  25. return false
  26. }
  27. if len(cmd.capabs) > 0 && !client.HasRoleCapabs(cmd.capabs...) {
  28. rb.Add(nil, server.name, ERR_NOPRIVILEGES, client.Nick(), client.t("Permission Denied"))
  29. return false
  30. }
  31. if len(msg.Params) < cmd.minParams {
  32. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.Nick(), msg.Command, rb.target.t("Not enough parameters"))
  33. return false
  34. }
  35. if session.batch.label != "" && !cmd.allowedInBatch {
  36. rb.Add(nil, server.name, "FAIL", "BATCH", "MULTILINE_INVALID", client.t("Command not allowed during a multiline batch"))
  37. session.EndMultilineBatch("")
  38. return false
  39. }
  40. return cmd.handler(server, client, msg, rb)
  41. }()
  42. // after each command, see if we can send registration to the client
  43. if !exiting && !client.registered {
  44. exiting = server.tryRegister(client, session)
  45. }
  46. if client.registered {
  47. client.Touch(session) // even if `exiting`, we bump the lastSeen timestamp
  48. }
  49. return exiting
  50. }
  51. // fake handler for unknown commands (see #994: this ensures the response tags are correct)
  52. var unknownCommand = Command{
  53. handler: unknownCommandHandler,
  54. usablePreReg: true,
  55. }
  56. var invalidUtf8Command = Command{
  57. handler: invalidUtf8Handler,
  58. usablePreReg: true,
  59. }
  60. // Commands holds all commands executable by a client connected to us.
  61. var Commands map[string]Command
  62. func init() {
  63. Commands = map[string]Command{
  64. "ACCEPT": {
  65. handler: acceptHandler,
  66. minParams: 1,
  67. },
  68. "AMBIANCE": {
  69. handler: sceneHandler,
  70. minParams: 2,
  71. },
  72. "AUTHENTICATE": {
  73. handler: authenticateHandler,
  74. usablePreReg: true,
  75. minParams: 1,
  76. },
  77. "AWAY": {
  78. handler: awayHandler,
  79. usablePreReg: true,
  80. minParams: 0,
  81. },
  82. "BATCH": {
  83. handler: batchHandler,
  84. minParams: 1,
  85. allowedInBatch: true,
  86. },
  87. "CAP": {
  88. handler: capHandler,
  89. usablePreReg: true,
  90. minParams: 1,
  91. },
  92. "CHATHISTORY": {
  93. handler: chathistoryHandler,
  94. minParams: 4,
  95. },
  96. "DEBUG": {
  97. handler: debugHandler,
  98. minParams: 1,
  99. capabs: []string{"rehash"},
  100. },
  101. "DEFCON": {
  102. handler: defconHandler,
  103. capabs: []string{"defcon"},
  104. },
  105. "DEOPER": {
  106. handler: deoperHandler,
  107. minParams: 0,
  108. },
  109. "DLINE": {
  110. handler: dlineHandler,
  111. minParams: 1,
  112. capabs: []string{"ban"},
  113. },
  114. "EXTJWT": {
  115. handler: extjwtHandler,
  116. minParams: 1,
  117. },
  118. "HELP": {
  119. handler: helpHandler,
  120. minParams: 0,
  121. },
  122. "HELPOP": {
  123. handler: helpHandler,
  124. minParams: 0,
  125. },
  126. "HISTORY": {
  127. handler: historyHandler,
  128. minParams: 1,
  129. },
  130. "INFO": {
  131. handler: infoHandler,
  132. },
  133. "INVITE": {
  134. handler: inviteHandler,
  135. minParams: 2,
  136. },
  137. "ISON": {
  138. handler: isonHandler,
  139. minParams: 1,
  140. },
  141. "JOIN": {
  142. handler: joinHandler,
  143. minParams: 1,
  144. },
  145. "KICK": {
  146. handler: kickHandler,
  147. minParams: 2,
  148. },
  149. "KILL": {
  150. handler: killHandler,
  151. minParams: 1,
  152. capabs: []string{"kill"},
  153. },
  154. "KLINE": {
  155. handler: klineHandler,
  156. minParams: 1,
  157. capabs: []string{"ban"},
  158. },
  159. "LANGUAGE": {
  160. handler: languageHandler,
  161. usablePreReg: true,
  162. minParams: 1,
  163. },
  164. "LIST": {
  165. handler: listHandler,
  166. minParams: 0,
  167. },
  168. "LUSERS": {
  169. handler: lusersHandler,
  170. minParams: 0,
  171. },
  172. "MARKREAD": {
  173. handler: markReadHandler,
  174. minParams: 0, // send FAIL instead of ERR_NEEDMOREPARAMS
  175. },
  176. "MODE": {
  177. handler: modeHandler,
  178. minParams: 1,
  179. },
  180. "MONITOR": {
  181. handler: monitorHandler,
  182. minParams: 1,
  183. },
  184. "MOTD": {
  185. handler: motdHandler,
  186. minParams: 0,
  187. },
  188. "NAMES": {
  189. handler: namesHandler,
  190. minParams: 0,
  191. },
  192. "NICK": {
  193. handler: nickHandler,
  194. usablePreReg: true,
  195. minParams: 1,
  196. },
  197. "NOTICE": {
  198. handler: messageHandler,
  199. minParams: 2,
  200. allowedInBatch: true,
  201. },
  202. "NPC": {
  203. handler: npcHandler,
  204. minParams: 3,
  205. },
  206. "NPCA": {
  207. handler: npcaHandler,
  208. minParams: 3,
  209. },
  210. "OPER": {
  211. handler: operHandler,
  212. minParams: 1,
  213. },
  214. "PART": {
  215. handler: partHandler,
  216. minParams: 1,
  217. },
  218. "PASS": {
  219. handler: passHandler,
  220. usablePreReg: true,
  221. minParams: 1,
  222. },
  223. "PERSISTENCE": {
  224. handler: persistenceHandler,
  225. minParams: 1,
  226. },
  227. "PING": {
  228. handler: pingHandler,
  229. usablePreReg: true,
  230. minParams: 1,
  231. },
  232. "PONG": {
  233. handler: pongHandler,
  234. usablePreReg: true,
  235. minParams: 1,
  236. },
  237. "PRIVMSG": {
  238. handler: messageHandler,
  239. minParams: 2,
  240. allowedInBatch: true,
  241. },
  242. "RELAYMSG": {
  243. handler: relaymsgHandler,
  244. minParams: 3,
  245. },
  246. "REGISTER": {
  247. handler: registerHandler,
  248. minParams: 3,
  249. usablePreReg: true,
  250. },
  251. "RENAME": {
  252. handler: renameHandler,
  253. minParams: 2,
  254. },
  255. "SAJOIN": {
  256. handler: sajoinHandler,
  257. minParams: 1,
  258. capabs: []string{"sajoin"},
  259. },
  260. "SANICK": {
  261. handler: sanickHandler,
  262. minParams: 2,
  263. capabs: []string{"samode"},
  264. },
  265. "SAMODE": {
  266. handler: modeHandler,
  267. minParams: 1,
  268. capabs: []string{"samode"},
  269. },
  270. "SCENE": {
  271. handler: sceneHandler,
  272. minParams: 2,
  273. },
  274. "SETNAME": {
  275. handler: setnameHandler,
  276. minParams: 1,
  277. },
  278. "SUMMON": {
  279. handler: summonHandler,
  280. },
  281. "TAGMSG": {
  282. handler: messageHandler,
  283. minParams: 1,
  284. },
  285. "QUIT": {
  286. handler: quitHandler,
  287. usablePreReg: true,
  288. minParams: 0,
  289. },
  290. "REDACT": {
  291. handler: redactHandler,
  292. minParams: 2,
  293. },
  294. "REHASH": {
  295. handler: rehashHandler,
  296. minParams: 0,
  297. capabs: []string{"rehash"},
  298. },
  299. "TIME": {
  300. handler: timeHandler,
  301. minParams: 0,
  302. },
  303. "TOPIC": {
  304. handler: topicHandler,
  305. minParams: 1,
  306. },
  307. "UBAN": {
  308. handler: ubanHandler,
  309. minParams: 1,
  310. capabs: []string{"ban"},
  311. },
  312. "UNDLINE": {
  313. handler: unDLineHandler,
  314. minParams: 1,
  315. capabs: []string{"ban"},
  316. },
  317. "UNINVITE": {
  318. handler: inviteHandler,
  319. minParams: 2,
  320. },
  321. "UNKLINE": {
  322. handler: unKLineHandler,
  323. minParams: 1,
  324. capabs: []string{"ban"},
  325. },
  326. "USER": {
  327. handler: userHandler,
  328. usablePreReg: true,
  329. minParams: 4,
  330. },
  331. "USERHOST": {
  332. handler: userhostHandler,
  333. minParams: 1,
  334. },
  335. "USERS": {
  336. handler: usersHandler,
  337. },
  338. "VERIFY": {
  339. handler: verifyHandler,
  340. usablePreReg: true,
  341. minParams: 2,
  342. },
  343. "VERSION": {
  344. handler: versionHandler,
  345. minParams: 0,
  346. },
  347. "WEBIRC": {
  348. handler: webircHandler,
  349. usablePreReg: true,
  350. minParams: 4,
  351. },
  352. "WHO": {
  353. handler: whoHandler,
  354. minParams: 1,
  355. },
  356. "WHOIS": {
  357. handler: whoisHandler,
  358. minParams: 1,
  359. },
  360. "WHOWAS": {
  361. handler: whowasHandler,
  362. minParams: 1,
  363. },
  364. "ZNC": {
  365. handler: zncHandler,
  366. minParams: 1,
  367. },
  368. }
  369. initializeServices()
  370. }