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.

handlers.go 86KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853
  1. // Copyright (c) 2012-2014 Jeremy Latt
  2. // Copyright (c) 2014-2015 Edmund Huber
  3. // Copyright (c) 2016-2018 Daniel Oaks <daniel@danieloaks.net>
  4. // Copyright (c) 2017-2018 Shivaram Lingamneni <slingamn@cs.stanford.edu>
  5. // released under the MIT license
  6. package irc
  7. import (
  8. "bytes"
  9. "encoding/base64"
  10. "encoding/json"
  11. "fmt"
  12. "net"
  13. "os"
  14. "runtime"
  15. "runtime/debug"
  16. "runtime/pprof"
  17. "sort"
  18. "strconv"
  19. "strings"
  20. "time"
  21. "github.com/goshuirc/irc-go/ircfmt"
  22. "github.com/goshuirc/irc-go/ircmatch"
  23. "github.com/goshuirc/irc-go/ircmsg"
  24. "github.com/oragono/oragono/irc/caps"
  25. "github.com/oragono/oragono/irc/custime"
  26. "github.com/oragono/oragono/irc/modes"
  27. "github.com/oragono/oragono/irc/passwd"
  28. "github.com/oragono/oragono/irc/sno"
  29. "github.com/oragono/oragono/irc/utils"
  30. "github.com/tidwall/buntdb"
  31. )
  32. // ACC [REGISTER|VERIFY] ...
  33. func accHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  34. // make sure reg is enabled
  35. if !server.AccountConfig().Registration.Enabled {
  36. rb.Add(nil, server.name, ERR_REG_UNSPECIFIED_ERROR, client.nick, "*", client.t("Account registration is disabled"))
  37. return false
  38. }
  39. subcommand := strings.ToLower(msg.Params[0])
  40. if subcommand == "register" {
  41. return accRegisterHandler(server, client, msg, rb)
  42. } else if subcommand == "verify" {
  43. return accVerifyHandler(server, client, msg, rb)
  44. } else {
  45. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, "ACC", msg.Params[0], client.t("Unknown subcommand"))
  46. }
  47. return false
  48. }
  49. // helper function to parse ACC callbacks, e.g., mailto:person@example.com, tel:16505551234
  50. func parseCallback(spec string, config *AccountConfig) (callbackNamespace string, callbackValue string) {
  51. callback := strings.ToLower(spec)
  52. if callback == "*" {
  53. callbackNamespace = "*"
  54. } else if strings.Contains(callback, ":") {
  55. callbackValues := strings.SplitN(callback, ":", 2)
  56. callbackNamespace, callbackValue = callbackValues[0], callbackValues[1]
  57. } else {
  58. // "the IRC server MAY choose to use mailto as a default"
  59. callbackNamespace = "mailto"
  60. callbackValue = callback
  61. }
  62. // ensure the callback namespace is valid
  63. // need to search callback list, maybe look at using a map later?
  64. for _, name := range config.Registration.EnabledCallbacks {
  65. if callbackNamespace == name {
  66. return
  67. }
  68. }
  69. // error value
  70. callbackNamespace = ""
  71. return
  72. }
  73. // ACC REGISTER <accountname> [callback_namespace:]<callback> [cred_type] :<credential>
  74. func accRegisterHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  75. // clients can't reg new accounts if they're already logged in
  76. if client.LoggedIntoAccount() {
  77. if server.AccountConfig().Registration.AllowMultiplePerConnection {
  78. server.accounts.Logout(client)
  79. } else {
  80. rb.Add(nil, server.name, ERR_REG_UNSPECIFIED_ERROR, client.nick, "*", client.t("You're already logged into an account"))
  81. return false
  82. }
  83. }
  84. // get and sanitise account name
  85. account := strings.TrimSpace(msg.Params[1])
  86. casefoldedAccount, err := CasefoldName(account)
  87. // probably don't need explicit check for "*" here... but let's do it anyway just to make sure
  88. if err != nil || msg.Params[1] == "*" {
  89. rb.Add(nil, server.name, ERR_REG_UNSPECIFIED_ERROR, client.nick, account, client.t("Account name is not valid"))
  90. return false
  91. }
  92. if len(msg.Params) < 4 {
  93. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.nick, msg.Command, client.t("Not enough parameters"))
  94. return false
  95. }
  96. callbackSpec := msg.Params[2]
  97. callbackNamespace, callbackValue := parseCallback(callbackSpec, server.AccountConfig())
  98. if callbackNamespace == "" {
  99. rb.Add(nil, server.name, ERR_REG_INVALID_CALLBACK, client.nick, account, callbackSpec, client.t("Callback namespace is not supported"))
  100. return false
  101. }
  102. // get credential type/value
  103. var credentialType, credentialValue string
  104. if len(msg.Params) > 4 {
  105. credentialType = strings.ToLower(msg.Params[3])
  106. credentialValue = msg.Params[4]
  107. } else {
  108. // exactly 4 params
  109. credentialType = "passphrase" // default from the spec
  110. credentialValue = msg.Params[3]
  111. }
  112. // ensure the credential type is valid
  113. var credentialValid bool
  114. for _, name := range server.AccountConfig().Registration.EnabledCredentialTypes {
  115. if credentialType == name {
  116. credentialValid = true
  117. }
  118. }
  119. if credentialType == "certfp" && client.certfp == "" {
  120. rb.Add(nil, server.name, ERR_REG_INVALID_CRED_TYPE, client.nick, credentialType, callbackNamespace, client.t("You are not using a TLS certificate"))
  121. return false
  122. }
  123. if !credentialValid {
  124. rb.Add(nil, server.name, ERR_REG_INVALID_CRED_TYPE, client.nick, credentialType, callbackNamespace, client.t("Credential type is not supported"))
  125. return false
  126. }
  127. var passphrase, certfp string
  128. if credentialType == "certfp" {
  129. certfp = client.certfp
  130. } else if credentialType == "passphrase" {
  131. passphrase = credentialValue
  132. }
  133. err = server.accounts.Register(client, account, callbackNamespace, callbackValue, passphrase, certfp)
  134. if err != nil {
  135. msg := "Unknown"
  136. code := ERR_UNKNOWNERROR
  137. if err == errCertfpAlreadyExists {
  138. msg = "An account already exists for your certificate fingerprint"
  139. } else if err == errAccountAlreadyRegistered {
  140. msg = "Account already exists"
  141. code = ERR_ACCOUNT_ALREADY_EXISTS
  142. }
  143. if err == errAccountAlreadyRegistered || err == errAccountCreation || err == errCertfpAlreadyExists {
  144. msg = err.Error()
  145. }
  146. rb.Add(nil, server.name, code, client.nick, "ACC", "REGISTER", client.t(msg))
  147. return false
  148. }
  149. // automatically complete registration
  150. if callbackNamespace == "*" {
  151. err := server.accounts.Verify(client, casefoldedAccount, "")
  152. if err != nil {
  153. return false
  154. }
  155. sendSuccessfulRegResponse(client, rb, false)
  156. } else {
  157. messageTemplate := client.t("Account created, pending verification; verification code has been sent to %s:%s")
  158. message := fmt.Sprintf(messageTemplate, callbackNamespace, callbackValue)
  159. rb.Add(nil, server.name, RPL_REG_VERIFICATION_REQUIRED, client.nick, casefoldedAccount, message)
  160. }
  161. return false
  162. }
  163. // helper function to dispatch messages when a client successfully registers
  164. func sendSuccessfulRegResponse(client *Client, rb *ResponseBuffer, forNS bool) {
  165. if forNS {
  166. rb.Notice(client.t("Account created"))
  167. } else {
  168. rb.Add(nil, client.server.name, RPL_REGISTRATION_SUCCESS, client.nick, client.AccountName(), client.t("Account created"))
  169. }
  170. sendSuccessfulSaslAuth(client, rb, forNS)
  171. }
  172. // sendSuccessfulSaslAuth means that a SASL auth attempt completed successfully, and is used to dispatch messages.
  173. func sendSuccessfulSaslAuth(client *Client, rb *ResponseBuffer, forNS bool) {
  174. account := client.AccountName()
  175. if forNS {
  176. rb.Notice(fmt.Sprintf(client.t("You're now logged in as %s"), client.AccountName()))
  177. } else {
  178. rb.Add(nil, client.server.name, RPL_LOGGEDIN, client.nick, client.nickMaskString, account, fmt.Sprintf(client.t("You are now logged in as %s"), account))
  179. rb.Add(nil, client.server.name, RPL_SASLSUCCESS, client.nick, client.t("Authentication successful"))
  180. }
  181. // dispatch account-notify
  182. for friend := range client.Friends(caps.AccountNotify) {
  183. friend.Send(nil, client.nickMaskString, "ACCOUNT", account)
  184. }
  185. client.server.snomasks.Send(sno.LocalAccounts, fmt.Sprintf(ircfmt.Unescape("Client $c[grey][$r%s$c[grey]] logged into account $c[grey][$r%s$c[grey]]"), client.nickMaskString, account))
  186. }
  187. // ACC VERIFY <accountname> <auth_code>
  188. func accVerifyHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  189. account := strings.TrimSpace(msg.Params[1])
  190. err := server.accounts.Verify(client, account, msg.Params[2])
  191. var code string
  192. var message string
  193. if err == errAccountVerificationInvalidCode {
  194. code = ERR_ACCOUNT_INVALID_VERIFY_CODE
  195. message = err.Error()
  196. } else if err == errAccountAlreadyVerified {
  197. code = ERR_ACCOUNT_ALREADY_VERIFIED
  198. message = err.Error()
  199. } else if err != nil {
  200. code = ERR_UNKNOWNERROR
  201. message = errAccountVerificationFailed.Error()
  202. }
  203. if err == nil {
  204. sendSuccessfulRegResponse(client, rb, false)
  205. } else {
  206. rb.Add(nil, server.name, code, client.nick, account, client.t(message))
  207. }
  208. return false
  209. }
  210. // AUTHENTICATE [<mechanism>|<data>|*]
  211. func authenticateHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  212. // sasl abort
  213. if !server.AccountConfig().AuthenticationEnabled || len(msg.Params) == 1 && msg.Params[0] == "*" {
  214. rb.Add(nil, server.name, ERR_SASLABORTED, client.nick, client.t("SASL authentication aborted"))
  215. client.saslInProgress = false
  216. client.saslMechanism = ""
  217. client.saslValue = ""
  218. return false
  219. }
  220. // start new sasl session
  221. if !client.saslInProgress {
  222. mechanism := strings.ToUpper(msg.Params[0])
  223. _, mechanismIsEnabled := EnabledSaslMechanisms[mechanism]
  224. if mechanismIsEnabled {
  225. client.saslInProgress = true
  226. client.saslMechanism = mechanism
  227. rb.Add(nil, server.name, "AUTHENTICATE", "+")
  228. } else {
  229. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed"))
  230. }
  231. return false
  232. }
  233. // continue existing sasl session
  234. rawData := msg.Params[0]
  235. if len(rawData) > 400 {
  236. rb.Add(nil, server.name, ERR_SASLTOOLONG, client.nick, client.t("SASL message too long"))
  237. client.saslInProgress = false
  238. client.saslMechanism = ""
  239. client.saslValue = ""
  240. return false
  241. } else if len(rawData) == 400 {
  242. client.saslValue += rawData
  243. // allow 4 'continuation' lines before rejecting for length
  244. if len(client.saslValue) > 400*4 {
  245. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed: Passphrase too long"))
  246. client.saslInProgress = false
  247. client.saslMechanism = ""
  248. client.saslValue = ""
  249. return false
  250. }
  251. return false
  252. }
  253. if rawData != "+" {
  254. client.saslValue += rawData
  255. }
  256. var data []byte
  257. var err error
  258. if client.saslValue != "+" {
  259. data, err = base64.StdEncoding.DecodeString(client.saslValue)
  260. if err != nil {
  261. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed: Invalid b64 encoding"))
  262. client.saslInProgress = false
  263. client.saslMechanism = ""
  264. client.saslValue = ""
  265. return false
  266. }
  267. }
  268. // call actual handler
  269. handler, handlerExists := EnabledSaslMechanisms[client.saslMechanism]
  270. // like 100% not required, but it's good to be safe I guess
  271. if !handlerExists {
  272. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed"))
  273. client.saslInProgress = false
  274. client.saslMechanism = ""
  275. client.saslValue = ""
  276. return false
  277. }
  278. // let the SASL handler do its thing
  279. exiting := handler(server, client, client.saslMechanism, data, rb)
  280. if client.LoggedIntoAccount() && server.AccountConfig().SkipServerPassword {
  281. client.SetAuthorized(true)
  282. }
  283. // wait 'til SASL is done before emptying the sasl vars
  284. client.saslInProgress = false
  285. client.saslMechanism = ""
  286. client.saslValue = ""
  287. return exiting
  288. }
  289. // AUTHENTICATE PLAIN
  290. func authPlainHandler(server *Server, client *Client, mechanism string, value []byte, rb *ResponseBuffer) bool {
  291. splitValue := bytes.Split(value, []byte{'\000'})
  292. var accountKey, authzid string
  293. if len(splitValue) == 3 {
  294. accountKey = string(splitValue[0])
  295. authzid = string(splitValue[1])
  296. if accountKey == "" {
  297. accountKey = authzid
  298. } else if accountKey != authzid {
  299. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed: authcid and authzid should be the same"))
  300. return false
  301. }
  302. } else {
  303. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed: Invalid auth blob"))
  304. return false
  305. }
  306. password := string(splitValue[2])
  307. err := server.accounts.AuthenticateByPassphrase(client, accountKey, password)
  308. if err != nil {
  309. msg := authErrorToMessage(server, err)
  310. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, fmt.Sprintf("%s: %s", client.t("SASL authentication failed"), client.t(msg)))
  311. return false
  312. }
  313. sendSuccessfulSaslAuth(client, rb, false)
  314. return false
  315. }
  316. func authErrorToMessage(server *Server, err error) (msg string) {
  317. if err == errAccountDoesNotExist || err == errAccountUnverified || err == errAccountInvalidCredentials {
  318. msg = err.Error()
  319. } else {
  320. server.logger.Error("internal", fmt.Sprintf("sasl authentication failure: %v", err))
  321. msg = "Unknown"
  322. }
  323. return
  324. }
  325. // AUTHENTICATE EXTERNAL
  326. func authExternalHandler(server *Server, client *Client, mechanism string, value []byte, rb *ResponseBuffer) bool {
  327. if client.certfp == "" {
  328. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, client.t("SASL authentication failed, you are not connecting with a certificate"))
  329. return false
  330. }
  331. err := server.accounts.AuthenticateByCertFP(client)
  332. if err != nil {
  333. msg := authErrorToMessage(server, err)
  334. rb.Add(nil, server.name, ERR_SASLFAIL, client.nick, fmt.Sprintf("%s: %s", client.t("SASL authentication failed"), client.t(msg)))
  335. return false
  336. }
  337. sendSuccessfulSaslAuth(client, rb, false)
  338. return false
  339. }
  340. // AWAY [<message>]
  341. func awayHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  342. var isAway bool
  343. var text string
  344. if len(msg.Params) > 0 {
  345. isAway = true
  346. text = msg.Params[0]
  347. awayLen := server.Limits().AwayLen
  348. if len(text) > awayLen {
  349. text = text[:awayLen]
  350. }
  351. }
  352. if isAway {
  353. client.flags[modes.Away] = true
  354. } else {
  355. delete(client.flags, modes.Away)
  356. }
  357. client.awayMessage = text
  358. var op modes.ModeOp
  359. if client.flags[modes.Away] {
  360. op = modes.Add
  361. rb.Add(nil, server.name, RPL_NOWAWAY, client.nick, client.t("You have been marked as being away"))
  362. } else {
  363. op = modes.Remove
  364. rb.Add(nil, server.name, RPL_UNAWAY, client.nick, client.t("You are no longer marked as being away"))
  365. }
  366. //TODO(dan): Should this be sent automagically as part of setting the flag/mode?
  367. modech := modes.ModeChanges{modes.ModeChange{
  368. Mode: modes.Away,
  369. Op: op,
  370. }}
  371. rb.Add(nil, server.name, "MODE", client.nick, modech.String())
  372. // dispatch away-notify
  373. for friend := range client.Friends(caps.AwayNotify) {
  374. if client.flags[modes.Away] {
  375. friend.SendFromClient("", client, nil, "AWAY", client.awayMessage)
  376. } else {
  377. friend.SendFromClient("", client, nil, "AWAY")
  378. }
  379. }
  380. return false
  381. }
  382. // CAP <subcmd> [<caps>]
  383. func capHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  384. subCommand := strings.ToUpper(msg.Params[0])
  385. capabilities := caps.NewSet()
  386. var capString string
  387. if len(msg.Params) > 1 {
  388. capString = msg.Params[1]
  389. strs := strings.Split(capString, " ")
  390. for _, str := range strs {
  391. if len(str) > 0 {
  392. capabilities.Enable(caps.Capability(str))
  393. }
  394. }
  395. }
  396. switch subCommand {
  397. case "LS":
  398. if !client.registered {
  399. client.capState = caps.NegotiatingState
  400. }
  401. if len(msg.Params) > 1 && msg.Params[1] == "302" {
  402. client.capVersion = 302
  403. }
  404. // weechat 1.4 has a bug here where it won't accept the CAP reply unless it contains
  405. // the server.name source... otherwise it doesn't respond to the CAP message with
  406. // anything and just hangs on connection.
  407. //TODO(dan): limit number of caps and send it multiline in 3.2 style as appropriate.
  408. rb.Add(nil, server.name, "CAP", client.nick, subCommand, SupportedCapabilities.String(client.capVersion, CapValues))
  409. case "LIST":
  410. rb.Add(nil, server.name, "CAP", client.nick, subCommand, client.capabilities.String(caps.Cap301, CapValues)) // values not sent on LIST so force 3.1
  411. case "REQ":
  412. if !client.registered {
  413. client.capState = caps.NegotiatingState
  414. }
  415. // make sure all capabilities actually exist
  416. for _, capability := range capabilities.List() {
  417. if !SupportedCapabilities.Has(capability) {
  418. rb.Add(nil, server.name, "CAP", client.nick, "NAK", capString)
  419. return false
  420. }
  421. }
  422. client.capabilities.Enable(capabilities.List()...)
  423. rb.Add(nil, server.name, "CAP", client.nick, "ACK", capString)
  424. case "END":
  425. if !client.Registered() {
  426. client.capState = caps.NegotiatedState
  427. }
  428. default:
  429. rb.Add(nil, server.name, ERR_INVALIDCAPCMD, client.nick, subCommand, client.t("Invalid CAP subcommand"))
  430. }
  431. return false
  432. }
  433. // CHANSERV [...]
  434. func csHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  435. server.chanservPrivmsgHandler(client, strings.Join(msg.Params, " "), rb)
  436. return false
  437. }
  438. // DEBUG <subcmd>
  439. func debugHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  440. param := strings.ToUpper(msg.Params[0])
  441. switch param {
  442. case "GCSTATS":
  443. stats := debug.GCStats{
  444. Pause: make([]time.Duration, 10),
  445. PauseQuantiles: make([]time.Duration, 5),
  446. }
  447. debug.ReadGCStats(&stats)
  448. rb.Notice(fmt.Sprintf("last GC: %s", stats.LastGC.Format(time.RFC1123)))
  449. rb.Notice(fmt.Sprintf("num GC: %d", stats.NumGC))
  450. rb.Notice(fmt.Sprintf("pause total: %s", stats.PauseTotal))
  451. rb.Notice(fmt.Sprintf("pause quantiles min%%: %s", stats.PauseQuantiles[0]))
  452. rb.Notice(fmt.Sprintf("pause quantiles 25%%: %s", stats.PauseQuantiles[1]))
  453. rb.Notice(fmt.Sprintf("pause quantiles 50%%: %s", stats.PauseQuantiles[2]))
  454. rb.Notice(fmt.Sprintf("pause quantiles 75%%: %s", stats.PauseQuantiles[3]))
  455. rb.Notice(fmt.Sprintf("pause quantiles max%%: %s", stats.PauseQuantiles[4]))
  456. case "NUMGOROUTINE":
  457. count := runtime.NumGoroutine()
  458. rb.Notice(fmt.Sprintf("num goroutines: %d", count))
  459. case "PROFILEHEAP":
  460. profFile := "oragono.mprof"
  461. file, err := os.Create(profFile)
  462. if err != nil {
  463. rb.Notice(fmt.Sprintf("error: %s", err))
  464. break
  465. }
  466. defer file.Close()
  467. pprof.Lookup("heap").WriteTo(file, 0)
  468. rb.Notice(fmt.Sprintf("written to %s", profFile))
  469. case "STARTCPUPROFILE":
  470. profFile := "oragono.prof"
  471. file, err := os.Create(profFile)
  472. if err != nil {
  473. rb.Notice(fmt.Sprintf("error: %s", err))
  474. break
  475. }
  476. if err := pprof.StartCPUProfile(file); err != nil {
  477. defer file.Close()
  478. rb.Notice(fmt.Sprintf("error: %s", err))
  479. break
  480. }
  481. rb.Notice(fmt.Sprintf("CPU profile writing to %s", profFile))
  482. case "STOPCPUPROFILE":
  483. pprof.StopCPUProfile()
  484. rb.Notice(fmt.Sprintf("CPU profiling stopped"))
  485. }
  486. return false
  487. }
  488. // DLINE [ANDKILL] [MYSELF] [duration] <ip>/<net> [ON <server>] [reason [| oper reason]]
  489. // DLINE LIST
  490. func dlineHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  491. // check oper permissions
  492. if !client.class.Capabilities["oper:local_ban"] {
  493. rb.Add(nil, server.name, ERR_NOPRIVS, client.nick, msg.Command, client.t("Insufficient oper privs"))
  494. return false
  495. }
  496. currentArg := 0
  497. // if they say LIST, we just list the current dlines
  498. if len(msg.Params) == currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "list" {
  499. bans := server.dlines.AllBans()
  500. if len(bans) == 0 {
  501. rb.Notice(client.t("No DLINEs have been set!"))
  502. }
  503. for key, info := range bans {
  504. rb.Notice(fmt.Sprintf(client.t("Ban - %[1]s - added by %[2]s - %[3]s"), key, info.OperName, info.BanMessage("%s")))
  505. }
  506. return false
  507. }
  508. // when setting a ban, if they say "ANDKILL" we should also kill all users who match it
  509. var andKill bool
  510. if len(msg.Params) > currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "andkill" {
  511. andKill = true
  512. currentArg++
  513. }
  514. // when setting a ban that covers the oper's current connection, we require them to say
  515. // "DLINE MYSELF" so that we're sure they really mean it.
  516. var dlineMyself bool
  517. if len(msg.Params) > currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "myself" {
  518. dlineMyself = true
  519. currentArg++
  520. }
  521. // duration
  522. duration, err := custime.ParseDuration(msg.Params[currentArg])
  523. durationIsUsed := err == nil
  524. if durationIsUsed {
  525. currentArg++
  526. }
  527. // get host
  528. if len(msg.Params) < currentArg+1 {
  529. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.nick, msg.Command, client.t("Not enough parameters"))
  530. return false
  531. }
  532. hostString := msg.Params[currentArg]
  533. currentArg++
  534. // check host
  535. var hostAddr net.IP
  536. var hostNet *net.IPNet
  537. _, hostNet, err = net.ParseCIDR(hostString)
  538. if err != nil {
  539. hostAddr = net.ParseIP(hostString)
  540. }
  541. if hostAddr == nil && hostNet == nil {
  542. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("Could not parse IP address or CIDR network"))
  543. return false
  544. }
  545. if hostNet == nil {
  546. hostString = hostAddr.String()
  547. if !dlineMyself && hostAddr.Equal(client.IP()) {
  548. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("This ban matches you. To DLINE yourself, you must use the command: /DLINE MYSELF <arguments>"))
  549. return false
  550. }
  551. } else {
  552. hostString = hostNet.String()
  553. if !dlineMyself && hostNet.Contains(client.IP()) {
  554. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("This ban matches you. To DLINE yourself, you must use the command: /DLINE MYSELF <arguments>"))
  555. return false
  556. }
  557. }
  558. // check remote
  559. if len(msg.Params) > currentArg && msg.Params[currentArg] == "ON" {
  560. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("Remote servers not yet supported"))
  561. return false
  562. }
  563. // get comment(s)
  564. reason := "No reason given"
  565. operReason := "No reason given"
  566. if len(msg.Params) > currentArg {
  567. tempReason := strings.TrimSpace(msg.Params[currentArg])
  568. if len(tempReason) > 0 && tempReason != "|" {
  569. tempReasons := strings.SplitN(tempReason, "|", 2)
  570. if tempReasons[0] != "" {
  571. reason = tempReasons[0]
  572. }
  573. if len(tempReasons) > 1 && tempReasons[1] != "" {
  574. operReason = tempReasons[1]
  575. } else {
  576. operReason = reason
  577. }
  578. }
  579. }
  580. operName := client.operName
  581. if operName == "" {
  582. operName = server.name
  583. }
  584. // assemble ban info
  585. var banTime *IPRestrictTime
  586. if durationIsUsed {
  587. banTime = &IPRestrictTime{
  588. Duration: duration,
  589. Expires: time.Now().Add(duration),
  590. }
  591. }
  592. info := IPBanInfo{
  593. Reason: reason,
  594. OperReason: operReason,
  595. OperName: operName,
  596. Time: banTime,
  597. }
  598. // save in datastore
  599. err = server.store.Update(func(tx *buntdb.Tx) error {
  600. dlineKey := fmt.Sprintf(keyDlineEntry, hostString)
  601. // assemble json from ban info
  602. b, err := json.Marshal(info)
  603. if err != nil {
  604. return err
  605. }
  606. tx.Set(dlineKey, string(b), nil)
  607. return nil
  608. })
  609. if err != nil {
  610. rb.Notice(fmt.Sprintf(client.t("Could not successfully save new D-LINE: %s"), err.Error()))
  611. return false
  612. }
  613. if hostNet == nil {
  614. server.dlines.AddIP(hostAddr, banTime, reason, operReason, operName)
  615. } else {
  616. server.dlines.AddNetwork(*hostNet, banTime, reason, operReason, operName)
  617. }
  618. var snoDescription string
  619. if durationIsUsed {
  620. rb.Notice(fmt.Sprintf(client.t("Added temporary (%[1]s) D-Line for %[2]s"), duration.String(), hostString))
  621. snoDescription = fmt.Sprintf(ircfmt.Unescape("%s [%s]$r added temporary (%s) D-Line for %s"), client.nick, operName, duration.String(), hostString)
  622. } else {
  623. rb.Notice(fmt.Sprintf(client.t("Added D-Line for %s"), hostString))
  624. snoDescription = fmt.Sprintf(ircfmt.Unescape("%s [%s]$r added D-Line for %s"), client.nick, operName, hostString)
  625. }
  626. server.snomasks.Send(sno.LocalXline, snoDescription)
  627. var killClient bool
  628. if andKill {
  629. var clientsToKill []*Client
  630. var killedClientNicks []string
  631. var toKill bool
  632. for _, mcl := range server.clients.AllClients() {
  633. if hostNet == nil {
  634. toKill = hostAddr.Equal(mcl.IP())
  635. } else {
  636. toKill = hostNet.Contains(mcl.IP())
  637. }
  638. if toKill {
  639. clientsToKill = append(clientsToKill, mcl)
  640. killedClientNicks = append(killedClientNicks, mcl.nick)
  641. }
  642. }
  643. for _, mcl := range clientsToKill {
  644. mcl.exitedSnomaskSent = true
  645. mcl.Quit(fmt.Sprintf(mcl.t("You have been banned from this server (%s)"), reason))
  646. if mcl == client {
  647. killClient = true
  648. } else {
  649. // if mcl == client, we kill them below
  650. mcl.destroy(false)
  651. }
  652. }
  653. // send snomask
  654. sort.Strings(killedClientNicks)
  655. server.snomasks.Send(sno.LocalKills, fmt.Sprintf(ircfmt.Unescape("%s [%s] killed %d clients with a DLINE $c[grey][$r%s$c[grey]]"), client.nick, operName, len(killedClientNicks), strings.Join(killedClientNicks, ", ")))
  656. }
  657. return killClient
  658. }
  659. // HELP [<query>]
  660. func helpHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  661. argument := strings.ToLower(strings.TrimSpace(strings.Join(msg.Params, " ")))
  662. if len(argument) < 1 {
  663. client.sendHelp("HELPOP", client.t(`HELPOP <argument>
  664. Get an explanation of <argument>, or "index" for a list of help topics.`), rb)
  665. return false
  666. }
  667. // handle index
  668. if argument == "index" {
  669. if client.flags[modes.Operator] {
  670. client.sendHelp("HELP", GetHelpIndex(client.languages, HelpIndexOpers), rb)
  671. } else {
  672. client.sendHelp("HELP", GetHelpIndex(client.languages, HelpIndex), rb)
  673. }
  674. return false
  675. }
  676. helpHandler, exists := Help[argument]
  677. if exists && (!helpHandler.oper || (helpHandler.oper && client.flags[modes.Operator])) {
  678. if helpHandler.textGenerator != nil {
  679. client.sendHelp(strings.ToUpper(argument), client.t(helpHandler.textGenerator(client)), rb)
  680. } else {
  681. client.sendHelp(strings.ToUpper(argument), client.t(helpHandler.text), rb)
  682. }
  683. } else {
  684. args := msg.Params
  685. args = append(args, client.t("Help not found"))
  686. rb.Add(nil, server.name, ERR_HELPNOTFOUND, args...)
  687. }
  688. return false
  689. }
  690. // INFO
  691. func infoHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  692. // we do the below so that the human-readable lines in info can be translated.
  693. for _, line := range infoString1 {
  694. rb.Add(nil, server.name, RPL_INFO, client.nick, line)
  695. }
  696. rb.Add(nil, server.name, RPL_INFO, client.nick, client.t("Oragono is released under the MIT license."))
  697. rb.Add(nil, server.name, RPL_INFO, client.nick, "")
  698. rb.Add(nil, server.name, RPL_INFO, client.nick, client.t("Thanks to Jeremy Latt for founding Ergonomadic, the project this is based on")+" <3")
  699. rb.Add(nil, server.name, RPL_INFO, client.nick, "")
  700. rb.Add(nil, server.name, RPL_INFO, client.nick, client.t("Core Developers:"))
  701. for _, line := range infoString2 {
  702. rb.Add(nil, server.name, RPL_INFO, client.nick, line)
  703. }
  704. rb.Add(nil, server.name, RPL_INFO, client.nick, client.t("Contributors and Former Developers:"))
  705. for _, line := range infoString3 {
  706. rb.Add(nil, server.name, RPL_INFO, client.nick, line)
  707. }
  708. // show translators for languages other than good ole' regular English
  709. tlines := server.languages.Translators()
  710. if 0 < len(tlines) {
  711. rb.Add(nil, server.name, RPL_INFO, client.nick, client.t("Translators:"))
  712. for _, line := range tlines {
  713. rb.Add(nil, server.name, RPL_INFO, client.nick, " "+line)
  714. }
  715. rb.Add(nil, server.name, RPL_INFO, client.nick, "")
  716. }
  717. rb.Add(nil, server.name, RPL_ENDOFINFO, client.nick, client.t("End of /INFO"))
  718. return false
  719. }
  720. // INVITE <nickname> <channel>
  721. func inviteHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  722. nickname := msg.Params[0]
  723. channelName := msg.Params[1]
  724. casefoldedNickname, err := CasefoldName(nickname)
  725. target := server.clients.Get(casefoldedNickname)
  726. if err != nil || target == nil {
  727. rb.Add(nil, server.name, ERR_NOSUCHNICK, client.nick, nickname, client.t("No such nick"))
  728. return false
  729. }
  730. casefoldedChannelName, err := CasefoldChannel(channelName)
  731. channel := server.channels.Get(casefoldedChannelName)
  732. if err != nil || channel == nil {
  733. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, channelName, client.t("No such channel"))
  734. return false
  735. }
  736. channel.Invite(target, client, rb)
  737. return false
  738. }
  739. // ISON <nick>{ <nick>}
  740. func isonHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  741. var nicks = msg.Params
  742. var err error
  743. var casefoldedNick string
  744. ison := make([]string, 0)
  745. for _, nick := range nicks {
  746. casefoldedNick, err = CasefoldName(nick)
  747. if err != nil {
  748. continue
  749. }
  750. if iclient := server.clients.Get(casefoldedNick); iclient != nil {
  751. ison = append(ison, iclient.nick)
  752. }
  753. }
  754. rb.Add(nil, server.name, RPL_ISON, client.nick, strings.Join(nicks, " "))
  755. return false
  756. }
  757. // JOIN <channel>{,<channel>} [<key>{,<key>}]
  758. func joinHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  759. // kill JOIN 0 requests
  760. if msg.Params[0] == "0" {
  761. rb.Notice(client.t("JOIN 0 is not allowed"))
  762. return false
  763. }
  764. // handle regular JOINs
  765. channels := strings.Split(msg.Params[0], ",")
  766. var keys []string
  767. if len(msg.Params) > 1 {
  768. keys = strings.Split(msg.Params[1], ",")
  769. }
  770. for i, name := range channels {
  771. var key string
  772. if len(keys) > i {
  773. key = keys[i]
  774. }
  775. err := server.channels.Join(client, name, key, rb)
  776. if err == errNoSuchChannel {
  777. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.Nick(), name, client.t("No such channel"))
  778. }
  779. }
  780. return false
  781. }
  782. // KICK <channel>{,<channel>} <user>{,<user>} [<comment>]
  783. func kickHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  784. channels := strings.Split(msg.Params[0], ",")
  785. users := strings.Split(msg.Params[1], ",")
  786. if (len(channels) != len(users)) && (len(users) != 1) {
  787. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.nick, "KICK", client.t("Not enough parameters"))
  788. return false
  789. }
  790. var kicks [][]string
  791. for index, channel := range channels {
  792. if len(users) == 1 {
  793. kicks = append(kicks, []string{channel, users[0]})
  794. } else {
  795. kicks = append(kicks, []string{channel, users[index]})
  796. }
  797. }
  798. var comment string
  799. if len(msg.Params) > 2 {
  800. comment = msg.Params[2]
  801. }
  802. for _, info := range kicks {
  803. chname := info[0]
  804. nickname := info[1]
  805. casefoldedChname, err := CasefoldChannel(chname)
  806. channel := server.channels.Get(casefoldedChname)
  807. if err != nil || channel == nil {
  808. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, chname, client.t("No such channel"))
  809. continue
  810. }
  811. casefoldedNickname, err := CasefoldName(nickname)
  812. target := server.clients.Get(casefoldedNickname)
  813. if err != nil || target == nil {
  814. rb.Add(nil, server.name, ERR_NOSUCHNICK, client.nick, nickname, client.t("No such nick"))
  815. continue
  816. }
  817. if comment == "" {
  818. comment = nickname
  819. }
  820. channel.Kick(client, target, comment, rb)
  821. }
  822. return false
  823. }
  824. // KILL <nickname> <comment>
  825. func killHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  826. nickname := msg.Params[0]
  827. comment := "<no reason supplied>"
  828. if len(msg.Params) > 1 {
  829. comment = msg.Params[1]
  830. }
  831. casefoldedNickname, err := CasefoldName(nickname)
  832. target := server.clients.Get(casefoldedNickname)
  833. if err != nil || target == nil {
  834. rb.Add(nil, client.server.name, ERR_NOSUCHNICK, client.nick, nickname, client.t("No such nick"))
  835. return false
  836. }
  837. quitMsg := fmt.Sprintf("Killed (%s (%s))", client.nick, comment)
  838. server.snomasks.Send(sno.LocalKills, fmt.Sprintf(ircfmt.Unescape("%s$r was killed by %s $c[grey][$r%s$c[grey]]"), target.nick, client.nick, comment))
  839. target.exitedSnomaskSent = true
  840. target.Quit(quitMsg)
  841. target.destroy(false)
  842. return false
  843. }
  844. // KLINE [ANDKILL] [MYSELF] [duration] <mask> [ON <server>] [reason [| oper reason]]
  845. // KLINE LIST
  846. func klineHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  847. // check oper permissions
  848. if !client.class.Capabilities["oper:local_ban"] {
  849. rb.Add(nil, server.name, ERR_NOPRIVS, client.nick, msg.Command, client.t("Insufficient oper privs"))
  850. return false
  851. }
  852. currentArg := 0
  853. // if they say LIST, we just list the current klines
  854. if len(msg.Params) == currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "list" {
  855. bans := server.klines.AllBans()
  856. if len(bans) == 0 {
  857. client.Notice("No KLINEs have been set!")
  858. }
  859. for key, info := range bans {
  860. client.Notice(fmt.Sprintf(client.t("Ban - %[1]s - added by %[2]s - %[3]s"), key, info.OperName, info.BanMessage("%s")))
  861. }
  862. return false
  863. }
  864. // when setting a ban, if they say "ANDKILL" we should also kill all users who match it
  865. var andKill bool
  866. if len(msg.Params) > currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "andkill" {
  867. andKill = true
  868. currentArg++
  869. }
  870. // when setting a ban that covers the oper's current connection, we require them to say
  871. // "KLINE MYSELF" so that we're sure they really mean it.
  872. var klineMyself bool
  873. if len(msg.Params) > currentArg+1 && strings.ToLower(msg.Params[currentArg]) == "myself" {
  874. klineMyself = true
  875. currentArg++
  876. }
  877. // duration
  878. duration, err := custime.ParseDuration(msg.Params[currentArg])
  879. durationIsUsed := err == nil
  880. if durationIsUsed {
  881. currentArg++
  882. }
  883. // get mask
  884. if len(msg.Params) < currentArg+1 {
  885. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.nick, msg.Command, client.t("Not enough parameters"))
  886. return false
  887. }
  888. mask := strings.ToLower(msg.Params[currentArg])
  889. currentArg++
  890. // check mask
  891. if !strings.Contains(mask, "!") && !strings.Contains(mask, "@") {
  892. mask = mask + "!*@*"
  893. } else if !strings.Contains(mask, "@") {
  894. mask = mask + "@*"
  895. }
  896. matcher := ircmatch.MakeMatch(mask)
  897. for _, clientMask := range client.AllNickmasks() {
  898. if !klineMyself && matcher.Match(clientMask) {
  899. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("This ban matches you. To KLINE yourself, you must use the command: /KLINE MYSELF <arguments>"))
  900. return false
  901. }
  902. }
  903. // check remote
  904. if len(msg.Params) > currentArg && msg.Params[currentArg] == "ON" {
  905. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("Remote servers not yet supported"))
  906. return false
  907. }
  908. // get oper name
  909. operName := client.operName
  910. if operName == "" {
  911. operName = server.name
  912. }
  913. // get comment(s)
  914. reason := "No reason given"
  915. operReason := "No reason given"
  916. if len(msg.Params) > currentArg {
  917. tempReason := strings.TrimSpace(msg.Params[currentArg])
  918. if len(tempReason) > 0 && tempReason != "|" {
  919. tempReasons := strings.SplitN(tempReason, "|", 2)
  920. if tempReasons[0] != "" {
  921. reason = tempReasons[0]
  922. }
  923. if len(tempReasons) > 1 && tempReasons[1] != "" {
  924. operReason = tempReasons[1]
  925. } else {
  926. operReason = reason
  927. }
  928. }
  929. }
  930. // assemble ban info
  931. var banTime *IPRestrictTime
  932. if durationIsUsed {
  933. banTime = &IPRestrictTime{
  934. Duration: duration,
  935. Expires: time.Now().Add(duration),
  936. }
  937. }
  938. info := IPBanInfo{
  939. Reason: reason,
  940. OperReason: operReason,
  941. OperName: operName,
  942. Time: banTime,
  943. }
  944. // save in datastore
  945. err = server.store.Update(func(tx *buntdb.Tx) error {
  946. klineKey := fmt.Sprintf(keyKlineEntry, mask)
  947. // assemble json from ban info
  948. b, err := json.Marshal(info)
  949. if err != nil {
  950. return err
  951. }
  952. tx.Set(klineKey, string(b), nil)
  953. return nil
  954. })
  955. if err != nil {
  956. rb.Notice(fmt.Sprintf(client.t("Could not successfully save new K-LINE: %s"), err.Error()))
  957. return false
  958. }
  959. server.klines.AddMask(mask, banTime, reason, operReason, operName)
  960. var snoDescription string
  961. if durationIsUsed {
  962. rb.Notice(fmt.Sprintf(client.t("Added temporary (%[1]s) K-Line for %[2]s"), duration.String(), mask))
  963. snoDescription = fmt.Sprintf(ircfmt.Unescape("%s [%s]$r added temporary (%s) K-Line for %s"), client.nick, operName, duration.String(), mask)
  964. } else {
  965. rb.Notice(fmt.Sprintf(client.t("Added K-Line for %s"), mask))
  966. snoDescription = fmt.Sprintf(ircfmt.Unescape("%s [%s]$r added K-Line for %s"), client.nick, operName, mask)
  967. }
  968. server.snomasks.Send(sno.LocalXline, snoDescription)
  969. var killClient bool
  970. if andKill {
  971. var clientsToKill []*Client
  972. var killedClientNicks []string
  973. for _, mcl := range server.clients.AllClients() {
  974. for _, clientMask := range mcl.AllNickmasks() {
  975. if matcher.Match(clientMask) {
  976. clientsToKill = append(clientsToKill, mcl)
  977. killedClientNicks = append(killedClientNicks, mcl.nick)
  978. }
  979. }
  980. }
  981. for _, mcl := range clientsToKill {
  982. mcl.exitedSnomaskSent = true
  983. mcl.Quit(fmt.Sprintf(mcl.t("You have been banned from this server (%s)"), reason))
  984. if mcl == client {
  985. killClient = true
  986. } else {
  987. // if mcl == client, we kill them below
  988. mcl.destroy(false)
  989. }
  990. }
  991. // send snomask
  992. sort.Strings(killedClientNicks)
  993. server.snomasks.Send(sno.LocalKills, fmt.Sprintf(ircfmt.Unescape("%s [%s] killed %d clients with a KLINE $c[grey][$r%s$c[grey]]"), client.nick, operName, len(killedClientNicks), strings.Join(killedClientNicks, ", ")))
  994. }
  995. return killClient
  996. }
  997. // LANGUAGE <code>{ <code>}
  998. func languageHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  999. alreadyDoneLanguages := make(map[string]bool)
  1000. var appliedLanguages []string
  1001. supportedLanguagesCount := server.languages.Count()
  1002. if supportedLanguagesCount < len(msg.Params) {
  1003. rb.Add(nil, client.server.name, ERR_TOOMANYLANGUAGES, client.nick, strconv.Itoa(supportedLanguagesCount), client.t("You specified too many languages"))
  1004. return false
  1005. }
  1006. for _, value := range msg.Params {
  1007. value = strings.ToLower(value)
  1008. // strip ~ from the language if it has it
  1009. value = strings.TrimPrefix(value, "~")
  1010. // silently ignore empty languages or those with spaces in them
  1011. if len(value) == 0 || strings.Contains(value, " ") {
  1012. continue
  1013. }
  1014. _, exists := server.languages.Info[value]
  1015. if !exists {
  1016. rb.Add(nil, client.server.name, ERR_NOLANGUAGE, client.nick, client.t("Languages are not supported by this server"))
  1017. return false
  1018. }
  1019. // if we've already applied the given language, skip it
  1020. _, exists = alreadyDoneLanguages[value]
  1021. if exists {
  1022. continue
  1023. }
  1024. appliedLanguages = append(appliedLanguages, value)
  1025. }
  1026. client.stateMutex.Lock()
  1027. if len(appliedLanguages) == 1 && appliedLanguages[0] == "en" {
  1028. // premature optimisation ahoy!
  1029. client.languages = []string{}
  1030. } else {
  1031. client.languages = appliedLanguages
  1032. }
  1033. client.stateMutex.Unlock()
  1034. params := []string{client.nick}
  1035. for _, lang := range appliedLanguages {
  1036. params = append(params, lang)
  1037. }
  1038. params = append(params, client.t("Language preferences have been set"))
  1039. rb.Add(nil, client.server.name, RPL_YOURLANGUAGESARE, params...)
  1040. return false
  1041. }
  1042. // LIST [<channel>{,<channel>}] [<elistcond>{,<elistcond>}]
  1043. func listHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1044. // get channels
  1045. var channels []string
  1046. for _, param := range msg.Params {
  1047. if 0 < len(param) && param[0] == '#' {
  1048. for _, channame := range strings.Split(param, ",") {
  1049. if 0 < len(channame) && channame[0] == '#' {
  1050. channels = append(channels, channame)
  1051. }
  1052. }
  1053. }
  1054. }
  1055. // get elist conditions
  1056. var matcher elistMatcher
  1057. for _, param := range msg.Params {
  1058. if len(param) < 1 {
  1059. continue
  1060. }
  1061. if param[0] == '<' {
  1062. param = param[1:]
  1063. val, err := strconv.Atoi(param)
  1064. if err != nil {
  1065. continue
  1066. }
  1067. matcher.MaxClientsActive = true
  1068. matcher.MaxClients = val - 1 // -1 because < means less than the given number
  1069. }
  1070. if param[0] == '>' {
  1071. param = param[1:]
  1072. val, err := strconv.Atoi(param)
  1073. if err != nil {
  1074. continue
  1075. }
  1076. matcher.MinClientsActive = true
  1077. matcher.MinClients = val + 1 // +1 because > means more than the given number
  1078. }
  1079. }
  1080. if len(channels) == 0 {
  1081. for _, channel := range server.channels.Channels() {
  1082. if !client.flags[modes.Operator] && channel.flags[modes.Secret] {
  1083. continue
  1084. }
  1085. if matcher.Matches(channel) {
  1086. client.RplList(channel, rb)
  1087. }
  1088. }
  1089. } else {
  1090. // limit regular users to only listing one channel
  1091. if !client.flags[modes.Operator] {
  1092. channels = channels[:1]
  1093. }
  1094. for _, chname := range channels {
  1095. casefoldedChname, err := CasefoldChannel(chname)
  1096. channel := server.channels.Get(casefoldedChname)
  1097. if err != nil || channel == nil || (!client.flags[modes.Operator] && channel.flags[modes.Secret]) {
  1098. if len(chname) > 0 {
  1099. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, chname, client.t("No such channel"))
  1100. }
  1101. continue
  1102. }
  1103. if matcher.Matches(channel) {
  1104. client.RplList(channel, rb)
  1105. }
  1106. }
  1107. }
  1108. rb.Add(nil, server.name, RPL_LISTEND, client.nick, client.t("End of LIST"))
  1109. return false
  1110. }
  1111. // LUSERS [<mask> [<server>]]
  1112. func lusersHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1113. //TODO(vegax87) Fix network statistics and additional parameters
  1114. var totalcount, invisiblecount, opercount int
  1115. for _, onlineusers := range server.clients.AllClients() {
  1116. totalcount++
  1117. if onlineusers.flags[modes.Invisible] {
  1118. invisiblecount++
  1119. }
  1120. if onlineusers.flags[modes.Operator] {
  1121. opercount++
  1122. }
  1123. }
  1124. rb.Add(nil, server.name, RPL_LUSERCLIENT, client.nick, fmt.Sprintf(client.t("There are %[1]d users and %[2]d invisible on %[3]d server(s)"), totalcount, invisiblecount, 1))
  1125. rb.Add(nil, server.name, RPL_LUSEROP, client.nick, fmt.Sprintf(client.t("%d IRC Operators online"), opercount))
  1126. rb.Add(nil, server.name, RPL_LUSERCHANNELS, client.nick, fmt.Sprintf(client.t("%d channels formed"), server.channels.Len()))
  1127. rb.Add(nil, server.name, RPL_LUSERME, client.nick, fmt.Sprintf(client.t("I have %[1]d clients and %[2]d servers"), totalcount, 1))
  1128. return false
  1129. }
  1130. // METADATA * SUB <key>{ <key>}
  1131. // METADATA * SUBS
  1132. // METADATA * UNSUB <key>{ <key>}
  1133. // METADATA <target> CLEAR
  1134. // METADATA <target> GET <key>{ <key>}
  1135. // METADATA <target> LIST
  1136. // METADATA <target> SET <key> [<value>]
  1137. // METADATA <target> SYNC
  1138. func metadataHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1139. handler, exists := metadataSubcommands[strings.ToLower(msg.Params[1])]
  1140. if !exists {
  1141. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown subcommand"))
  1142. return false
  1143. }
  1144. return handler(server, client, msg, rb)
  1145. }
  1146. // METADATA <target> CLEAR
  1147. func metadataClearHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1148. var mm *MetadataManager
  1149. targetString := msg.Params[0]
  1150. target, err := CasefoldChannel(targetString)
  1151. if err == nil {
  1152. channel := server.channels.Get(target)
  1153. if channel == nil {
  1154. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1155. return false
  1156. }
  1157. if !channel.ClientIsAtLeast(client, modes.ChannelOperator) {
  1158. rb.Add(nil, server.name, ERR_CHANOPRIVSNEEDED, client.nick, targetString, client.t("You're not a channel operator"))
  1159. return false
  1160. }
  1161. mm = channel.metadata
  1162. } else {
  1163. target, err = CasefoldName(targetString)
  1164. user := server.clients.Get(target)
  1165. if err != nil || user == nil {
  1166. if len(target) > 0 {
  1167. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1168. } else {
  1169. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown error"))
  1170. }
  1171. return false
  1172. }
  1173. if user != client {
  1174. rb.Add(nil, server.name, ERR_KEYNOPERMISSION, client.nick, target, "*", client.t("Permission denied"))
  1175. return false
  1176. }
  1177. mm = user.metadata
  1178. }
  1179. for _, key := range mm.Clear() {
  1180. rb.Add(nil, server.name, RPL_KEYVALUE, client.nick, target, key, "*")
  1181. }
  1182. rb.Add(nil, server.name, RPL_METADATAEND, client.nick, client.t("End of metadata"))
  1183. return false
  1184. }
  1185. // METADATA <target> GET <key>{ <key>}
  1186. func metadataGetHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1187. if len(msg.Params) < 3 {
  1188. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.Nick(), msg.Command, client.t("Not enough parameters"))
  1189. return false
  1190. }
  1191. var mm *MetadataManager
  1192. targetString := msg.Params[0]
  1193. target, err := CasefoldChannel(targetString)
  1194. if err == nil {
  1195. channel := server.channels.Get(target)
  1196. if channel == nil {
  1197. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1198. return false
  1199. }
  1200. if !channel.hasClient(client) {
  1201. rb.Add(nil, server.name, ERR_KEYNOPERMISSION, client.nick, target, client.t("You're not on that channel!"))
  1202. return false
  1203. }
  1204. mm = channel.metadata
  1205. } else {
  1206. target, err = CasefoldName(targetString)
  1207. user := server.clients.Get(target)
  1208. if err != nil || user == nil {
  1209. if len(target) > 0 {
  1210. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1211. } else {
  1212. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown error"))
  1213. }
  1214. return false
  1215. }
  1216. mm = user.metadata
  1217. }
  1218. for i, key := range msg.Params {
  1219. // only process actual keys, skip target and (sub)command name
  1220. if 1 < i {
  1221. key = strings.TrimSpace(strings.ToLower(key))
  1222. if !metadataKeyValid(key) {
  1223. rb.Add(nil, server.name, ERR_KEYINVALID, client.nick, key)
  1224. continue
  1225. }
  1226. value, exists := mm.Get(key)
  1227. if !exists {
  1228. rb.Add(nil, server.name, ERR_NOMATCHINGKEY, client.nick, target, key, client.t("No matching key"))
  1229. continue
  1230. }
  1231. rb.Add(nil, server.name, RPL_KEYVALUE, client.nick, target, key, "*", value)
  1232. }
  1233. }
  1234. return false
  1235. }
  1236. // METADATA <target> LIST
  1237. func metadataListHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1238. var mm *MetadataManager
  1239. targetString := msg.Params[0]
  1240. target, err := CasefoldChannel(targetString)
  1241. if err == nil {
  1242. channel := server.channels.Get(target)
  1243. if channel == nil {
  1244. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1245. return false
  1246. }
  1247. if !channel.hasClient(client) {
  1248. rb.Add(nil, server.name, ERR_KEYNOPERMISSION, client.nick, target, client.t("You're not on that channel!"))
  1249. return false
  1250. }
  1251. mm = channel.metadata
  1252. } else {
  1253. target, err = CasefoldName(targetString)
  1254. user := server.clients.Get(target)
  1255. if err != nil || user == nil {
  1256. if len(target) > 0 {
  1257. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1258. } else {
  1259. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown error"))
  1260. }
  1261. return false
  1262. }
  1263. mm = user.metadata
  1264. }
  1265. for key, value := range mm.List() {
  1266. rb.Add(nil, server.name, RPL_KEYVALUE, client.nick, target, key, "*", value)
  1267. }
  1268. rb.Add(nil, server.name, RPL_METADATAEND, client.nick, client.t("End of metadata"))
  1269. return false
  1270. }
  1271. // METADATA <target> SET <key> [<value>]
  1272. func metadataSetHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1273. if len(msg.Params) < 3 {
  1274. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.Nick(), msg.Command, client.t("Not enough parameters"))
  1275. return false
  1276. }
  1277. // retrieve key/value
  1278. key := strings.TrimSpace(strings.ToLower(msg.Params[2]))
  1279. if !metadataKeyValid(key) {
  1280. rb.Add(nil, server.name, ERR_KEYINVALID, client.nick, key)
  1281. return false
  1282. }
  1283. var settingValue bool
  1284. var value string
  1285. if 3 < len(msg.Params) {
  1286. settingValue = true
  1287. value = msg.Params[3]
  1288. }
  1289. // work on target
  1290. targetString := msg.Params[0]
  1291. target, err := CasefoldChannel(targetString)
  1292. if err == nil {
  1293. channel := server.channels.Get(target)
  1294. if channel == nil {
  1295. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1296. return false
  1297. }
  1298. if !channel.ClientIsAtLeast(client, modes.ChannelOperator) {
  1299. rb.Add(nil, server.name, ERR_CHANOPRIVSNEEDED, client.nick, targetString, client.t("You're not a channel operator"))
  1300. return false
  1301. }
  1302. if settingValue {
  1303. err := channel.metadata.Set(key, value, server.MetadataKeysLimit())
  1304. if err == errTooManyKeys {
  1305. rb.Add(nil, server.name, ERR_METADATALIMIT, client.nick, target, client.t("Metadata limit reached"))
  1306. return false
  1307. }
  1308. } else {
  1309. channel.metadata.Delete(key)
  1310. }
  1311. } else {
  1312. target, err = CasefoldName(targetString)
  1313. user := server.clients.Get(target)
  1314. if err != nil || user == nil {
  1315. if len(target) > 0 {
  1316. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1317. } else {
  1318. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown error"))
  1319. }
  1320. return false
  1321. }
  1322. if user != client {
  1323. rb.Add(nil, server.name, ERR_KEYNOPERMISSION, client.nick, target, "*", client.t("Permission denied"))
  1324. return false
  1325. }
  1326. if settingValue {
  1327. err := user.metadata.Set(key, value, server.MetadataKeysLimit())
  1328. if err == errTooManyKeys {
  1329. rb.Add(nil, server.name, ERR_METADATALIMIT, client.nick, target, client.t("Metadata limit reached"))
  1330. return false
  1331. }
  1332. } else {
  1333. user.metadata.Delete(key)
  1334. }
  1335. }
  1336. if settingValue {
  1337. rb.Add(nil, server.name, RPL_KEYVALUE, client.nick, target, key, "*", value)
  1338. } else {
  1339. rb.Add(nil, server.name, RPL_KEYVALUE, client.nick, target, key, "*")
  1340. }
  1341. rb.Add(nil, server.name, RPL_METADATAEND, client.nick, client.t("End of metadata"))
  1342. return false
  1343. }
  1344. func metadataSubHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1345. client.Notice("METADATA SUB not yet implemented")
  1346. return false
  1347. }
  1348. func metadataSubsHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1349. client.Notice("METADATA SUBS not yet implemented")
  1350. return false
  1351. }
  1352. // METADATA <target> SYNC
  1353. //TODO(dan): SYNC also returns e.g. metadata keys of friends in the given channel, etc.
  1354. //Note:
  1355. // One difference with list is that you can’t get a whole channel full of members metadata with it.
  1356. // With sync you can, you get targets you didn’t explicitly request. It’s more of a trigger than a request.
  1357. // And it’s mainly only useful for the delayed synchronisation function.
  1358. func metadataSyncHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1359. var mm *MetadataManager
  1360. targetString := msg.Params[0]
  1361. target, err := CasefoldChannel(targetString)
  1362. if err == nil {
  1363. channel := server.channels.Get(target)
  1364. if channel == nil {
  1365. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1366. return false
  1367. }
  1368. if !channel.hasClient(client) {
  1369. rb.Add(nil, server.name, ERR_KEYNOPERMISSION, client.nick, target, client.t("You're not on that channel!"))
  1370. return false
  1371. }
  1372. mm = channel.metadata
  1373. } else {
  1374. target, err = CasefoldName(targetString)
  1375. user := server.clients.Get(target)
  1376. if err != nil || user == nil {
  1377. if len(target) > 0 {
  1378. rb.Add(nil, server.name, ERR_TARGETINVALID, client.nick, target, client.t("Invalid metadata target"))
  1379. } else {
  1380. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "METADATA", client.t("Unknown error"))
  1381. }
  1382. return false
  1383. }
  1384. mm = user.metadata
  1385. }
  1386. for key, value := range mm.List() {
  1387. rb.Add(nil, server.name, "METADATA", target, key, "*", value)
  1388. }
  1389. return false
  1390. }
  1391. func metadataUnsubHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1392. client.Notice("METADATA UNSUB not yet implemented")
  1393. return false
  1394. }
  1395. // MODE <target> [<modestring> [<mode arguments>...]]
  1396. func modeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1397. _, errChan := CasefoldChannel(msg.Params[0])
  1398. if errChan == nil {
  1399. return cmodeHandler(server, client, msg, rb)
  1400. }
  1401. return umodeHandler(server, client, msg, rb)
  1402. }
  1403. // MODE <channel> [<modestring> [<mode arguments>...]]
  1404. func cmodeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1405. channelName, err := CasefoldChannel(msg.Params[0])
  1406. channel := server.channels.Get(channelName)
  1407. if err != nil || channel == nil {
  1408. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, msg.Params[0], client.t("No such channel"))
  1409. return false
  1410. }
  1411. // applied mode changes
  1412. applied := make(modes.ModeChanges, 0)
  1413. if 1 < len(msg.Params) {
  1414. // parse out real mode changes
  1415. params := msg.Params[1:]
  1416. changes, unknown := ParseChannelModeChanges(params...)
  1417. // alert for unknown mode changes
  1418. for char := range unknown {
  1419. rb.Add(nil, server.name, ERR_UNKNOWNMODE, client.nick, string(char), client.t("is an unknown mode character to me"))
  1420. }
  1421. if len(unknown) == 1 && len(changes) == 0 {
  1422. return false
  1423. }
  1424. // apply mode changes
  1425. applied = channel.ApplyChannelModeChanges(client, msg.Command == "SAMODE", changes, rb)
  1426. }
  1427. // save changes to banlist/exceptlist/invexlist
  1428. var banlistUpdated, exceptlistUpdated, invexlistUpdated bool
  1429. for _, change := range applied {
  1430. if change.Mode == modes.BanMask {
  1431. banlistUpdated = true
  1432. } else if change.Mode == modes.ExceptMask {
  1433. exceptlistUpdated = true
  1434. } else if change.Mode == modes.InviteMask {
  1435. invexlistUpdated = true
  1436. }
  1437. }
  1438. if (banlistUpdated || exceptlistUpdated || invexlistUpdated) && channel.IsRegistered() {
  1439. go server.channelRegistry.StoreChannel(channel, true)
  1440. }
  1441. // send out changes
  1442. if len(applied) > 0 {
  1443. //TODO(dan): we should change the name of String and make it return a slice here
  1444. args := append([]string{channel.name}, strings.Split(applied.String(), " ")...)
  1445. for _, member := range channel.Members() {
  1446. if member == client {
  1447. rb.Add(nil, client.nickMaskString, "MODE", args...)
  1448. } else {
  1449. member.Send(nil, client.nickMaskString, "MODE", args...)
  1450. }
  1451. }
  1452. } else {
  1453. args := append([]string{client.nick, channel.name}, channel.modeStrings(client)...)
  1454. rb.Add(nil, client.nickMaskString, RPL_CHANNELMODEIS, args...)
  1455. rb.Add(nil, client.nickMaskString, RPL_CHANNELCREATED, client.nick, channel.name, strconv.FormatInt(channel.createdTime.Unix(), 10))
  1456. }
  1457. return false
  1458. }
  1459. // MODE <client> [<modestring> [<mode arguments>...]]
  1460. func umodeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1461. nickname, err := CasefoldName(msg.Params[0])
  1462. target := server.clients.Get(nickname)
  1463. if err != nil || target == nil {
  1464. if len(msg.Params[0]) > 0 {
  1465. rb.Add(nil, server.name, ERR_NOSUCHNICK, client.nick, msg.Params[0], client.t("No such nick"))
  1466. }
  1467. return false
  1468. }
  1469. targetNick := target.Nick()
  1470. hasPrivs := client == target || msg.Command == "SAMODE"
  1471. if !hasPrivs {
  1472. if len(msg.Params) > 1 {
  1473. rb.Add(nil, server.name, ERR_USERSDONTMATCH, client.nick, client.t("Can't change modes for other users"))
  1474. } else {
  1475. rb.Add(nil, server.name, ERR_USERSDONTMATCH, client.nick, client.t("Can't view modes for other users"))
  1476. }
  1477. return false
  1478. }
  1479. // applied mode changes
  1480. applied := make(modes.ModeChanges, 0)
  1481. if 1 < len(msg.Params) {
  1482. // parse out real mode changes
  1483. params := msg.Params[1:]
  1484. changes, unknown := modes.ParseUserModeChanges(params...)
  1485. // alert for unknown mode changes
  1486. for char := range unknown {
  1487. rb.Add(nil, server.name, ERR_UNKNOWNMODE, client.nick, string(char), client.t("is an unknown mode character to me"))
  1488. }
  1489. if len(unknown) == 1 && len(changes) == 0 {
  1490. return false
  1491. }
  1492. // apply mode changes
  1493. applied = target.applyUserModeChanges(msg.Command == "SAMODE", changes)
  1494. }
  1495. if len(applied) > 0 {
  1496. rb.Add(nil, client.nickMaskString, "MODE", targetNick, applied.String())
  1497. } else if hasPrivs {
  1498. rb.Add(nil, target.nickMaskString, RPL_UMODEIS, targetNick, target.ModeString())
  1499. if client.flags[modes.LocalOperator] || client.flags[modes.Operator] {
  1500. masks := server.snomasks.String(client)
  1501. if 0 < len(masks) {
  1502. rb.Add(nil, target.nickMaskString, RPL_SNOMASKIS, targetNick, masks, client.t("Server notice masks"))
  1503. }
  1504. }
  1505. }
  1506. return false
  1507. }
  1508. // MONITOR <subcmd> [params...]
  1509. func monitorHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1510. handler, exists := monitorSubcommands[strings.ToLower(msg.Params[0])]
  1511. if !exists {
  1512. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.Nick(), "MONITOR", client.t("Unknown subcommand"))
  1513. return false
  1514. }
  1515. return handler(server, client, msg, rb)
  1516. }
  1517. // MONITOR - <target>{,<target>}
  1518. func monitorRemoveHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1519. if len(msg.Params) < 2 {
  1520. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.Nick(), msg.Command, client.t("Not enough parameters"))
  1521. return false
  1522. }
  1523. targets := strings.Split(msg.Params[1], ",")
  1524. for _, target := range targets {
  1525. cfnick, err := CasefoldName(target)
  1526. if err != nil {
  1527. continue
  1528. }
  1529. server.monitorManager.Remove(client, cfnick)
  1530. }
  1531. return false
  1532. }
  1533. // MONITOR + <target>{,<target>}
  1534. func monitorAddHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1535. if len(msg.Params) < 2 {
  1536. rb.Add(nil, server.name, ERR_NEEDMOREPARAMS, client.Nick(), msg.Command, client.t("Not enough parameters"))
  1537. return false
  1538. }
  1539. var online []string
  1540. var offline []string
  1541. limit := server.Limits().MonitorEntries
  1542. targets := strings.Split(msg.Params[1], ",")
  1543. for _, target := range targets {
  1544. // check name length
  1545. if len(target) < 1 || len(targets) > server.limits.NickLen {
  1546. continue
  1547. }
  1548. // add target
  1549. casefoldedTarget, err := CasefoldName(target)
  1550. if err != nil {
  1551. continue
  1552. }
  1553. err = server.monitorManager.Add(client, casefoldedTarget, limit)
  1554. if err == errMonitorLimitExceeded {
  1555. rb.Add(nil, server.name, ERR_MONLISTFULL, client.Nick(), strconv.Itoa(server.limits.MonitorEntries), strings.Join(targets, ","))
  1556. break
  1557. } else if err != nil {
  1558. continue
  1559. }
  1560. // add to online / offline lists
  1561. if targetClient := server.clients.Get(casefoldedTarget); targetClient == nil {
  1562. offline = append(offline, target)
  1563. } else {
  1564. online = append(online, targetClient.Nick())
  1565. }
  1566. }
  1567. if len(online) > 0 {
  1568. rb.Add(nil, server.name, RPL_MONONLINE, client.Nick(), strings.Join(online, ","))
  1569. }
  1570. if len(offline) > 0 {
  1571. rb.Add(nil, server.name, RPL_MONOFFLINE, client.Nick(), strings.Join(offline, ","))
  1572. }
  1573. return false
  1574. }
  1575. // MONITOR C
  1576. func monitorClearHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1577. server.monitorManager.RemoveAll(client)
  1578. return false
  1579. }
  1580. // MONITOR L
  1581. func monitorListHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1582. monitorList := server.monitorManager.List(client)
  1583. var nickList []string
  1584. for _, cfnick := range monitorList {
  1585. replynick := cfnick
  1586. // report the uncasefolded nick if it's available, i.e., the client is online
  1587. if mclient := server.clients.Get(cfnick); mclient != nil {
  1588. replynick = mclient.Nick()
  1589. }
  1590. nickList = append(nickList, replynick)
  1591. }
  1592. for _, line := range utils.ArgsToStrings(maxLastArgLength, nickList, ",") {
  1593. rb.Add(nil, server.name, RPL_MONLIST, client.Nick(), line)
  1594. }
  1595. rb.Add(nil, server.name, RPL_ENDOFMONLIST, "End of MONITOR list")
  1596. return false
  1597. }
  1598. // MONITOR S
  1599. func monitorStatusHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1600. var online []string
  1601. var offline []string
  1602. monitorList := server.monitorManager.List(client)
  1603. for _, name := range monitorList {
  1604. target := server.clients.Get(name)
  1605. if target == nil {
  1606. offline = append(offline, name)
  1607. } else {
  1608. online = append(online, target.Nick())
  1609. }
  1610. }
  1611. if len(online) > 0 {
  1612. for _, line := range utils.ArgsToStrings(maxLastArgLength, online, ",") {
  1613. rb.Add(nil, server.name, RPL_MONONLINE, client.Nick(), line)
  1614. }
  1615. }
  1616. if len(offline) > 0 {
  1617. for _, line := range utils.ArgsToStrings(maxLastArgLength, offline, ",") {
  1618. rb.Add(nil, server.name, RPL_MONOFFLINE, client.Nick(), line)
  1619. }
  1620. }
  1621. return false
  1622. }
  1623. // MOTD
  1624. func motdHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1625. server.MOTD(client, rb)
  1626. return false
  1627. }
  1628. // NAMES [<channel>{,<channel>} [target]]
  1629. func namesHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1630. var channels []string
  1631. if len(msg.Params) > 0 {
  1632. channels = strings.Split(msg.Params[0], ",")
  1633. }
  1634. // TODO: in a post-federation world, process `target` (server to forward request to)
  1635. if len(channels) == 0 {
  1636. for _, channel := range server.channels.Channels() {
  1637. channel.Names(client, rb)
  1638. }
  1639. return false
  1640. }
  1641. for _, chname := range channels {
  1642. channel := server.channels.Get(chname)
  1643. if channel != nil {
  1644. channel.Names(client, rb)
  1645. } else if chname != "" {
  1646. rb.Add(nil, server.name, RPL_ENDOFNAMES, client.Nick(), chname, client.t("End of NAMES list"))
  1647. }
  1648. }
  1649. return false
  1650. }
  1651. // NICK <nickname>
  1652. func nickHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1653. if client.Registered() {
  1654. performNickChange(server, client, client, msg.Params[0], rb)
  1655. } else {
  1656. client.SetPreregNick(msg.Params[0])
  1657. }
  1658. return false
  1659. }
  1660. // NOTICE <target>{,<target>} <message>
  1661. func noticeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1662. clientOnlyTags := utils.GetClientOnlyTags(msg.Tags)
  1663. targets := strings.Split(msg.Params[0], ",")
  1664. message := msg.Params[1]
  1665. // split privmsg
  1666. splitMsg := server.splitMessage(message, !client.capabilities.Has(caps.MaxLine))
  1667. for i, targetString := range targets {
  1668. // max of four targets per privmsg
  1669. if i > maxTargets-1 {
  1670. break
  1671. }
  1672. prefixes, targetString := modes.SplitChannelMembershipPrefixes(targetString)
  1673. lowestPrefix := modes.GetLowestChannelModePrefix(prefixes)
  1674. target, cerr := CasefoldChannel(targetString)
  1675. if cerr == nil {
  1676. channel := server.channels.Get(target)
  1677. if channel == nil {
  1678. // errors silently ignored with NOTICE as per RFC
  1679. continue
  1680. }
  1681. if !channel.CanSpeak(client) {
  1682. // errors silently ignored with NOTICE as per RFC
  1683. continue
  1684. }
  1685. msgid := server.generateMessageID()
  1686. channel.SplitNotice(msgid, lowestPrefix, clientOnlyTags, client, splitMsg, rb)
  1687. } else {
  1688. target, err := CasefoldName(targetString)
  1689. if err != nil {
  1690. continue
  1691. }
  1692. if target == "chanserv" {
  1693. server.chanservNoticeHandler(client, message, rb)
  1694. continue
  1695. } else if target == "nickserv" {
  1696. server.nickservNoticeHandler(client, message, rb)
  1697. continue
  1698. }
  1699. user := server.clients.Get(target)
  1700. if user == nil {
  1701. // errors silently ignored with NOTICE as per RFC
  1702. continue
  1703. }
  1704. if !user.capabilities.Has(caps.MessageTags) {
  1705. clientOnlyTags = nil
  1706. }
  1707. msgid := server.generateMessageID()
  1708. // restrict messages appropriately when +R is set
  1709. // intentionally make the sending user think the message went through fine
  1710. if !user.flags[modes.RegisteredOnly] || client.registered {
  1711. user.SendSplitMsgFromClient(msgid, client, clientOnlyTags, "NOTICE", user.nick, splitMsg)
  1712. }
  1713. if client.capabilities.Has(caps.EchoMessage) {
  1714. rb.AddSplitMessageFromClient(msgid, client, clientOnlyTags, "NOTICE", user.nick, splitMsg)
  1715. }
  1716. }
  1717. }
  1718. return false
  1719. }
  1720. // NPC <target> <sourcenick> <message>
  1721. func npcHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1722. target := msg.Params[0]
  1723. fakeSource := msg.Params[1]
  1724. message := msg.Params[2]
  1725. _, err := CasefoldName(fakeSource)
  1726. if err != nil {
  1727. client.Send(nil, client.server.name, ERR_CANNOTSENDRP, target, client.t("Fake source must be a valid nickname"))
  1728. return false
  1729. }
  1730. sourceString := fmt.Sprintf(npcNickMask, fakeSource, client.nick)
  1731. sendRoleplayMessage(server, client, sourceString, target, false, message, rb)
  1732. return false
  1733. }
  1734. // NPCA <target> <sourcenick> <message>
  1735. func npcaHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1736. target := msg.Params[0]
  1737. fakeSource := msg.Params[1]
  1738. message := msg.Params[2]
  1739. sourceString := fmt.Sprintf(npcNickMask, fakeSource, client.nick)
  1740. _, err := CasefoldName(fakeSource)
  1741. if err != nil {
  1742. client.Send(nil, client.server.name, ERR_CANNOTSENDRP, target, client.t("Fake source must be a valid nickname"))
  1743. return false
  1744. }
  1745. sendRoleplayMessage(server, client, sourceString, target, true, message, rb)
  1746. return false
  1747. }
  1748. // NICKSERV [params...]
  1749. func nsHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1750. server.nickservPrivmsgHandler(client, strings.Join(msg.Params, " "), rb)
  1751. return false
  1752. }
  1753. // OPER <name> <password>
  1754. func operHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1755. name, err := CasefoldName(msg.Params[0])
  1756. if err != nil {
  1757. rb.Add(nil, server.name, ERR_PASSWDMISMATCH, client.nick, client.t("Password incorrect"))
  1758. return true
  1759. }
  1760. if client.flags[modes.Operator] == true {
  1761. rb.Add(nil, server.name, ERR_UNKNOWNERROR, "OPER", client.t("You're already opered-up!"))
  1762. return false
  1763. }
  1764. server.configurableStateMutex.RLock()
  1765. oper := server.operators[name]
  1766. server.configurableStateMutex.RUnlock()
  1767. password := []byte(msg.Params[1])
  1768. err = passwd.ComparePassword(oper.Pass, password)
  1769. if (oper.Pass == nil) || (err != nil) {
  1770. rb.Add(nil, server.name, ERR_PASSWDMISMATCH, client.nick, client.t("Password incorrect"))
  1771. return true
  1772. }
  1773. client.operName = name
  1774. client.class = oper.Class
  1775. client.whoisLine = oper.WhoisLine
  1776. // push new vhost if one is set
  1777. if len(oper.Vhost) > 0 {
  1778. for fClient := range client.Friends(caps.ChgHost) {
  1779. fClient.SendFromClient("", client, nil, "CHGHOST", client.username, oper.Vhost)
  1780. }
  1781. // CHGHOST requires prefix nickmask to have original hostname, so do that before updating nickmask
  1782. client.vhost = oper.Vhost
  1783. client.updateNickMask("")
  1784. }
  1785. // set new modes
  1786. var applied modes.ModeChanges
  1787. if 0 < len(oper.Modes) {
  1788. modeChanges, unknownChanges := modes.ParseUserModeChanges(strings.Split(oper.Modes, " ")...)
  1789. applied = client.applyUserModeChanges(true, modeChanges)
  1790. if 0 < len(unknownChanges) {
  1791. var runes string
  1792. for r := range unknownChanges {
  1793. runes += string(r)
  1794. }
  1795. rb.Notice(fmt.Sprintf(client.t("Could not apply mode changes: +%s"), runes))
  1796. }
  1797. }
  1798. rb.Add(nil, server.name, RPL_YOUREOPER, client.nick, client.t("You are now an IRC operator"))
  1799. applied = append(applied, modes.ModeChange{
  1800. Mode: modes.Operator,
  1801. Op: modes.Add,
  1802. })
  1803. rb.Add(nil, server.name, "MODE", client.nick, applied.String())
  1804. server.snomasks.Send(sno.LocalOpers, fmt.Sprintf(ircfmt.Unescape("Client opered up $c[grey][$r%s$c[grey], $r%s$c[grey]]"), client.nickMaskString, client.operName))
  1805. // client may now be unthrottled by the fakelag system
  1806. client.resetFakelag()
  1807. client.flags[modes.Operator] = true
  1808. return false
  1809. }
  1810. // PART <channel>{,<channel>} [<reason>]
  1811. func partHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1812. channels := strings.Split(msg.Params[0], ",")
  1813. var reason string //TODO(dan): if this isn't supplied here, make sure the param doesn't exist in the PART message sent to other users
  1814. if len(msg.Params) > 1 {
  1815. reason = msg.Params[1]
  1816. }
  1817. for _, chname := range channels {
  1818. err := server.channels.Part(client, chname, reason, rb)
  1819. if err == errNoSuchChannel {
  1820. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, chname, client.t("No such channel"))
  1821. }
  1822. }
  1823. return false
  1824. }
  1825. // PASS <password>
  1826. func passHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1827. if client.Registered() {
  1828. rb.Add(nil, server.name, ERR_ALREADYREGISTRED, client.nick, client.t("You may not reregister"))
  1829. return false
  1830. }
  1831. // if no password exists, skip checking
  1832. if len(server.password) == 0 {
  1833. client.SetAuthorized(true)
  1834. return false
  1835. }
  1836. // check the provided password
  1837. password := []byte(msg.Params[0])
  1838. if passwd.ComparePassword(server.password, password) != nil {
  1839. rb.Add(nil, server.name, ERR_PASSWDMISMATCH, client.nick, client.t("Password incorrect"))
  1840. rb.Add(nil, server.name, "ERROR", client.t("Password incorrect"))
  1841. return true
  1842. }
  1843. client.SetAuthorized(true)
  1844. return false
  1845. }
  1846. // PING [params...]
  1847. func pingHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1848. rb.Add(nil, server.name, "PONG", msg.Params...)
  1849. return false
  1850. }
  1851. // PONG [params...]
  1852. func pongHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1853. // client gets touched when they send this command, so we don't need to do anything
  1854. return false
  1855. }
  1856. // PRIVMSG <target>{,<target>} <message>
  1857. func privmsgHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1858. clientOnlyTags := utils.GetClientOnlyTags(msg.Tags)
  1859. targets := strings.Split(msg.Params[0], ",")
  1860. message := msg.Params[1]
  1861. // split privmsg
  1862. splitMsg := server.splitMessage(message, !client.capabilities.Has(caps.MaxLine))
  1863. for i, targetString := range targets {
  1864. // max of four targets per privmsg
  1865. if i > maxTargets-1 {
  1866. break
  1867. }
  1868. prefixes, targetString := modes.SplitChannelMembershipPrefixes(targetString)
  1869. lowestPrefix := modes.GetLowestChannelModePrefix(prefixes)
  1870. // eh, no need to notify them
  1871. if len(targetString) < 1 {
  1872. continue
  1873. }
  1874. target, err := CasefoldChannel(targetString)
  1875. if err == nil {
  1876. channel := server.channels.Get(target)
  1877. if channel == nil {
  1878. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, targetString, client.t("No such channel"))
  1879. continue
  1880. }
  1881. if !channel.CanSpeak(client) {
  1882. rb.Add(nil, client.server.name, ERR_CANNOTSENDTOCHAN, channel.name, client.t("Cannot send to channel"))
  1883. continue
  1884. }
  1885. msgid := server.generateMessageID()
  1886. channel.SplitPrivMsg(msgid, lowestPrefix, clientOnlyTags, client, splitMsg, rb)
  1887. } else {
  1888. target, err = CasefoldName(targetString)
  1889. if target == "chanserv" {
  1890. server.chanservPrivmsgHandler(client, message, rb)
  1891. continue
  1892. } else if target == "nickserv" {
  1893. server.nickservPrivmsgHandler(client, message, rb)
  1894. continue
  1895. }
  1896. user := server.clients.Get(target)
  1897. if err != nil || user == nil {
  1898. if len(target) > 0 {
  1899. client.Send(nil, server.name, ERR_NOSUCHNICK, client.nick, target, "No such nick")
  1900. }
  1901. continue
  1902. }
  1903. if !user.capabilities.Has(caps.MessageTags) {
  1904. clientOnlyTags = nil
  1905. }
  1906. msgid := server.generateMessageID()
  1907. // restrict messages appropriately when +R is set
  1908. // intentionally make the sending user think the message went through fine
  1909. if !user.flags[modes.RegisteredOnly] || client.registered {
  1910. user.SendSplitMsgFromClient(msgid, client, clientOnlyTags, "PRIVMSG", user.nick, splitMsg)
  1911. }
  1912. if client.capabilities.Has(caps.EchoMessage) {
  1913. rb.AddSplitMessageFromClient(msgid, client, clientOnlyTags, "PRIVMSG", user.nick, splitMsg)
  1914. }
  1915. if user.flags[modes.Away] {
  1916. //TODO(dan): possibly implement cooldown of away notifications to users
  1917. rb.Add(nil, server.name, RPL_AWAY, user.nick, user.awayMessage)
  1918. }
  1919. }
  1920. }
  1921. return false
  1922. }
  1923. // PROXY TCP4/6 SOURCEIP DESTIP SOURCEPORT DESTPORT
  1924. // http://www.haproxy.org/download/1.8/doc/proxy-protocol.txt
  1925. func proxyHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1926. // only allow unregistered clients to use this command
  1927. if client.Registered() || client.proxiedIP != nil {
  1928. return false
  1929. }
  1930. for _, gateway := range server.ProxyAllowedFrom() {
  1931. if isGatewayAllowed(client.socket.conn.RemoteAddr(), gateway) {
  1932. proxiedIP := msg.Params[1]
  1933. // assume PROXY connections are always secure
  1934. return client.ApplyProxiedIP(proxiedIP, true)
  1935. }
  1936. }
  1937. client.Quit(client.t("PROXY command is not usable from your address"))
  1938. return true
  1939. }
  1940. // QUIT [<reason>]
  1941. func quitHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1942. reason := "Quit"
  1943. if len(msg.Params) > 0 {
  1944. reason += ": " + msg.Params[0]
  1945. }
  1946. client.Quit(reason)
  1947. return true
  1948. }
  1949. // REHASH
  1950. func rehashHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  1951. server.logger.Info("rehash", fmt.Sprintf("REHASH command used by %s", client.nick))
  1952. err := server.rehash()
  1953. if err == nil {
  1954. rb.Add(nil, server.name, RPL_REHASHING, client.nick, "ircd.yaml", client.t("Rehashing"))
  1955. } else {
  1956. server.logger.Error("rehash", fmt.Sprintln("Failed to rehash:", err.Error()))
  1957. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, "REHASH", err.Error())
  1958. }
  1959. return false
  1960. }
  1961. // RENAME <oldchan> <newchan> [<reason>]
  1962. func renameHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) (result bool) {
  1963. result = false
  1964. errorResponse := func(err error, name string) {
  1965. // TODO: send correct error codes, e.g., ERR_CANNOTRENAME, ERR_CHANNAMEINUSE
  1966. var code string
  1967. switch err {
  1968. case errNoSuchChannel:
  1969. code = ERR_NOSUCHCHANNEL
  1970. case errRenamePrivsNeeded:
  1971. code = ERR_CHANOPRIVSNEEDED
  1972. case errInvalidChannelName:
  1973. code = ERR_UNKNOWNERROR
  1974. case errChannelNameInUse:
  1975. code = ERR_UNKNOWNERROR
  1976. default:
  1977. code = ERR_UNKNOWNERROR
  1978. }
  1979. rb.Add(nil, server.name, code, client.Nick(), "RENAME", name, err.Error())
  1980. }
  1981. oldName := strings.TrimSpace(msg.Params[0])
  1982. newName := strings.TrimSpace(msg.Params[1])
  1983. if oldName == "" || newName == "" {
  1984. errorResponse(errInvalidChannelName, "<empty>")
  1985. return
  1986. }
  1987. casefoldedOldName, err := CasefoldChannel(oldName)
  1988. if err != nil {
  1989. errorResponse(errInvalidChannelName, oldName)
  1990. return
  1991. }
  1992. reason := "No reason"
  1993. if 2 < len(msg.Params) {
  1994. reason = msg.Params[2]
  1995. }
  1996. channel := server.channels.Get(oldName)
  1997. if channel == nil {
  1998. errorResponse(errNoSuchChannel, oldName)
  1999. return
  2000. }
  2001. //TODO(dan): allow IRCops to do this?
  2002. if !channel.ClientIsAtLeast(client, modes.Operator) {
  2003. errorResponse(errRenamePrivsNeeded, oldName)
  2004. return
  2005. }
  2006. founder := channel.Founder()
  2007. if founder != "" && founder != client.Account() {
  2008. //TODO(dan): Change this to ERR_CANNOTRENAME
  2009. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, "RENAME", oldName, client.t("Only channel founders can change registered channels"))
  2010. return false
  2011. }
  2012. // perform the channel rename
  2013. err = server.channels.Rename(oldName, newName)
  2014. if err != nil {
  2015. errorResponse(err, newName)
  2016. return
  2017. }
  2018. // rename succeeded, persist it
  2019. go server.channelRegistry.Rename(channel, casefoldedOldName)
  2020. // send RENAME messages
  2021. for _, mcl := range channel.Members() {
  2022. if mcl.capabilities.Has(caps.Rename) {
  2023. mcl.Send(nil, client.nickMaskString, "RENAME", oldName, newName, reason)
  2024. } else {
  2025. mcl.Send(nil, mcl.nickMaskString, "PART", oldName, fmt.Sprintf(mcl.t("Channel renamed: %s"), reason))
  2026. if mcl.capabilities.Has(caps.ExtendedJoin) {
  2027. mcl.Send(nil, mcl.nickMaskString, "JOIN", newName, mcl.AccountName(), mcl.realname)
  2028. } else {
  2029. mcl.Send(nil, mcl.nickMaskString, "JOIN", newName)
  2030. }
  2031. }
  2032. }
  2033. return false
  2034. }
  2035. // RESUME <oldnick> [timestamp]
  2036. func resumeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2037. oldnick := msg.Params[0]
  2038. if strings.Contains(oldnick, " ") {
  2039. rb.Add(nil, server.name, ERR_CANNOT_RESUME, "*", client.t("Cannot resume connection, old nickname contains spaces"))
  2040. return false
  2041. }
  2042. if client.Registered() {
  2043. rb.Add(nil, server.name, ERR_CANNOT_RESUME, oldnick, client.t("Cannot resume connection, connection registration has already been completed"))
  2044. return false
  2045. }
  2046. var timestamp *time.Time
  2047. if 1 < len(msg.Params) {
  2048. ts, err := time.Parse("2006-01-02T15:04:05.999Z", msg.Params[1])
  2049. if err == nil {
  2050. timestamp = &ts
  2051. } else {
  2052. rb.Add(nil, server.name, ERR_CANNOT_RESUME, oldnick, client.t("Timestamp is not in 2006-01-02T15:04:05.999Z format, ignoring it"))
  2053. }
  2054. }
  2055. client.resumeDetails = &ResumeDetails{
  2056. OldNick: oldnick,
  2057. Timestamp: timestamp,
  2058. }
  2059. return false
  2060. }
  2061. // SANICK <oldnick> <nickname>
  2062. func sanickHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2063. targetNick := strings.TrimSpace(msg.Params[0])
  2064. target := server.clients.Get(targetNick)
  2065. if target == nil {
  2066. rb.Add(nil, server.name, ERR_NOSUCHNICK, client.nick, msg.Params[0], client.t("No such nick"))
  2067. return false
  2068. }
  2069. performNickChange(server, client, target, msg.Params[1], rb)
  2070. return false
  2071. }
  2072. // SCENE <target> <message>
  2073. func sceneHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2074. target := msg.Params[0]
  2075. message := msg.Params[1]
  2076. sourceString := fmt.Sprintf(sceneNickMask, client.nick)
  2077. sendRoleplayMessage(server, client, sourceString, target, false, message, rb)
  2078. return false
  2079. }
  2080. // TAGMSG <target>{,<target>}
  2081. func tagmsgHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2082. clientOnlyTags := utils.GetClientOnlyTags(msg.Tags)
  2083. // no client-only tags, so we can drop it
  2084. if clientOnlyTags == nil {
  2085. return false
  2086. }
  2087. targets := strings.Split(msg.Params[0], ",")
  2088. for i, targetString := range targets {
  2089. // max of four targets per privmsg
  2090. if i > maxTargets-1 {
  2091. break
  2092. }
  2093. prefixes, targetString := modes.SplitChannelMembershipPrefixes(targetString)
  2094. lowestPrefix := modes.GetLowestChannelModePrefix(prefixes)
  2095. // eh, no need to notify them
  2096. if len(targetString) < 1 {
  2097. continue
  2098. }
  2099. target, err := CasefoldChannel(targetString)
  2100. if err == nil {
  2101. channel := server.channels.Get(target)
  2102. if channel == nil {
  2103. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, targetString, client.t("No such channel"))
  2104. continue
  2105. }
  2106. if !channel.CanSpeak(client) {
  2107. rb.Add(nil, client.server.name, ERR_CANNOTSENDTOCHAN, channel.name, client.t("Cannot send to channel"))
  2108. continue
  2109. }
  2110. msgid := server.generateMessageID()
  2111. channel.TagMsg(msgid, lowestPrefix, clientOnlyTags, client, rb)
  2112. } else {
  2113. target, err = CasefoldName(targetString)
  2114. user := server.clients.Get(target)
  2115. if err != nil || user == nil {
  2116. if len(target) > 0 {
  2117. client.Send(nil, server.name, ERR_NOSUCHNICK, client.nick, target, client.t("No such nick"))
  2118. }
  2119. continue
  2120. }
  2121. msgid := server.generateMessageID()
  2122. // end user can't receive tagmsgs
  2123. if !user.capabilities.Has(caps.MessageTags) {
  2124. continue
  2125. }
  2126. user.SendFromClient(msgid, client, clientOnlyTags, "TAGMSG", user.nick)
  2127. if client.capabilities.Has(caps.EchoMessage) {
  2128. rb.AddFromClient(msgid, client, clientOnlyTags, "TAGMSG", user.nick)
  2129. }
  2130. if user.flags[modes.Away] {
  2131. //TODO(dan): possibly implement cooldown of away notifications to users
  2132. rb.Add(nil, server.name, RPL_AWAY, user.nick, user.awayMessage)
  2133. }
  2134. }
  2135. }
  2136. return false
  2137. }
  2138. // TIME
  2139. func timeHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2140. rb.Add(nil, server.name, RPL_TIME, client.nick, server.name, time.Now().Format(time.RFC1123))
  2141. return false
  2142. }
  2143. // TOPIC <channel> [<topic>]
  2144. func topicHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2145. name, err := CasefoldChannel(msg.Params[0])
  2146. channel := server.channels.Get(name)
  2147. if err != nil || channel == nil {
  2148. if len(msg.Params[0]) > 0 {
  2149. rb.Add(nil, server.name, ERR_NOSUCHCHANNEL, client.nick, msg.Params[0], client.t("No such channel"))
  2150. }
  2151. return false
  2152. }
  2153. if len(msg.Params) > 1 {
  2154. channel.SetTopic(client, msg.Params[1], rb)
  2155. } else {
  2156. channel.SendTopic(client, rb)
  2157. }
  2158. return false
  2159. }
  2160. // UNDLINE <ip>|<net>
  2161. func unDLineHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2162. // check oper permissions
  2163. if !client.class.Capabilities["oper:local_unban"] {
  2164. rb.Add(nil, server.name, ERR_NOPRIVS, client.nick, msg.Command, client.t("Insufficient oper privs"))
  2165. return false
  2166. }
  2167. // get host
  2168. hostString := msg.Params[0]
  2169. // check host
  2170. var hostAddr net.IP
  2171. var hostNet *net.IPNet
  2172. _, hostNet, err := net.ParseCIDR(hostString)
  2173. if err != nil {
  2174. hostAddr = net.ParseIP(hostString)
  2175. }
  2176. if hostAddr == nil && hostNet == nil {
  2177. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("Could not parse IP address or CIDR network"))
  2178. return false
  2179. }
  2180. if hostNet == nil {
  2181. hostString = hostAddr.String()
  2182. } else {
  2183. hostString = hostNet.String()
  2184. }
  2185. // save in datastore
  2186. err = server.store.Update(func(tx *buntdb.Tx) error {
  2187. dlineKey := fmt.Sprintf(keyDlineEntry, hostString)
  2188. // check if it exists or not
  2189. val, err := tx.Get(dlineKey)
  2190. if val == "" {
  2191. return errNoExistingBan
  2192. } else if err != nil {
  2193. return err
  2194. }
  2195. tx.Delete(dlineKey)
  2196. return nil
  2197. })
  2198. if err != nil {
  2199. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, fmt.Sprintf(client.t("Could not remove ban [%s]"), err.Error()))
  2200. return false
  2201. }
  2202. if hostNet == nil {
  2203. server.dlines.RemoveIP(hostAddr)
  2204. } else {
  2205. server.dlines.RemoveNetwork(*hostNet)
  2206. }
  2207. rb.Notice(fmt.Sprintf(client.t("Removed D-Line for %s"), hostString))
  2208. server.snomasks.Send(sno.LocalXline, fmt.Sprintf(ircfmt.Unescape("%s$r removed D-Line for %s"), client.nick, hostString))
  2209. return false
  2210. }
  2211. // UNKLINE <mask>
  2212. func unKLineHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2213. // check oper permissions
  2214. if !client.class.Capabilities["oper:local_unban"] {
  2215. rb.Add(nil, server.name, ERR_NOPRIVS, client.nick, msg.Command, client.t("Insufficient oper privs"))
  2216. return false
  2217. }
  2218. // get host
  2219. mask := msg.Params[0]
  2220. if !strings.Contains(mask, "!") && !strings.Contains(mask, "@") {
  2221. mask = mask + "!*@*"
  2222. } else if !strings.Contains(mask, "@") {
  2223. mask = mask + "@*"
  2224. }
  2225. // save in datastore
  2226. err := server.store.Update(func(tx *buntdb.Tx) error {
  2227. klineKey := fmt.Sprintf(keyKlineEntry, mask)
  2228. // check if it exists or not
  2229. val, err := tx.Get(klineKey)
  2230. if val == "" {
  2231. return errNoExistingBan
  2232. } else if err != nil {
  2233. return err
  2234. }
  2235. tx.Delete(klineKey)
  2236. return nil
  2237. })
  2238. if err != nil {
  2239. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, fmt.Sprintf(client.t("Could not remove ban [%s]"), err.Error()))
  2240. return false
  2241. }
  2242. server.klines.RemoveMask(mask)
  2243. rb.Notice(fmt.Sprintf(client.t("Removed K-Line for %s"), mask))
  2244. server.snomasks.Send(sno.LocalXline, fmt.Sprintf(ircfmt.Unescape("%s$r removed K-Line for %s"), client.nick, mask))
  2245. return false
  2246. }
  2247. // USER <username> * 0 <realname>
  2248. func userHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2249. if client.Registered() {
  2250. rb.Add(nil, server.name, ERR_ALREADYREGISTRED, client.nick, client.t("You may not reregister"))
  2251. return false
  2252. }
  2253. if client.username != "" && client.realname != "" {
  2254. return false
  2255. }
  2256. // confirm that username is valid
  2257. //
  2258. _, err := CasefoldName(msg.Params[0])
  2259. if err != nil {
  2260. rb.Add(nil, "", "ERROR", client.t("Malformed username"))
  2261. return true
  2262. }
  2263. if !client.HasUsername() {
  2264. client.username = "~" + msg.Params[0]
  2265. // don't bother updating nickmask here, it's not valid anyway
  2266. }
  2267. if client.realname == "" {
  2268. client.realname = msg.Params[3]
  2269. }
  2270. return false
  2271. }
  2272. // USERHOST <nickname>{ <nickname>}
  2273. func userhostHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2274. returnedNicks := make(map[string]bool)
  2275. for i, nickname := range msg.Params {
  2276. if i >= 10 {
  2277. break
  2278. }
  2279. casefoldedNickname, err := CasefoldName(nickname)
  2280. target := server.clients.Get(casefoldedNickname)
  2281. if err != nil || target == nil {
  2282. rb.Add(nil, client.server.name, ERR_NOSUCHNICK, client.nick, nickname, client.t("No such nick"))
  2283. return false
  2284. }
  2285. if returnedNicks[casefoldedNickname] {
  2286. continue
  2287. }
  2288. // to prevent returning multiple results for a single nick
  2289. returnedNicks[casefoldedNickname] = true
  2290. var isOper, isAway string
  2291. if target.flags[modes.Operator] {
  2292. isOper = "*"
  2293. }
  2294. if target.flags[modes.Away] {
  2295. isAway = "-"
  2296. } else {
  2297. isAway = "+"
  2298. }
  2299. rb.Add(nil, client.server.name, RPL_USERHOST, client.nick, fmt.Sprintf("%s%s=%s%s@%s", target.nick, isOper, isAway, target.username, target.hostname))
  2300. }
  2301. return false
  2302. }
  2303. // VERSION
  2304. func versionHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2305. rb.Add(nil, server.name, RPL_VERSION, client.nick, Ver, server.name)
  2306. client.RplISupport(rb)
  2307. return false
  2308. }
  2309. // WEBIRC <password> <gateway> <hostname> <ip> [:flag1 flag2=x flag3]
  2310. func webircHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2311. // only allow unregistered clients to use this command
  2312. if client.Registered() || client.proxiedIP != nil {
  2313. return false
  2314. }
  2315. // process flags
  2316. var secure bool
  2317. if 4 < len(msg.Params) {
  2318. for _, x := range strings.Split(msg.Params[4], " ") {
  2319. // split into key=value
  2320. var key string
  2321. if strings.Contains(x, "=") {
  2322. y := strings.SplitN(x, "=", 2)
  2323. key, _ = y[0], y[1]
  2324. } else {
  2325. key = x
  2326. }
  2327. lkey := strings.ToLower(key)
  2328. if lkey == "tls" || lkey == "secure" {
  2329. // only accept "tls" flag if the gateway's connection to us is secure as well
  2330. if client.flags[modes.TLS] || utils.AddrIsLocal(client.socket.conn.RemoteAddr()) {
  2331. secure = true
  2332. }
  2333. }
  2334. }
  2335. }
  2336. for _, info := range server.WebIRCConfig() {
  2337. for _, gateway := range info.Hosts {
  2338. if isGatewayAllowed(client.socket.conn.RemoteAddr(), gateway) {
  2339. // confirm password and/or fingerprint
  2340. givenPassword := msg.Params[0]
  2341. if 0 < len(info.Password) && passwd.ComparePasswordString(info.Password, givenPassword) != nil {
  2342. continue
  2343. }
  2344. if 0 < len(info.Fingerprint) && client.certfp != info.Fingerprint {
  2345. continue
  2346. }
  2347. proxiedIP := msg.Params[3]
  2348. return client.ApplyProxiedIP(proxiedIP, secure)
  2349. }
  2350. }
  2351. }
  2352. client.Quit(client.t("WEBIRC command is not usable from your address or incorrect password given"))
  2353. return true
  2354. }
  2355. // WHO [<mask> [o]]
  2356. func whoHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2357. if msg.Params[0] == "" {
  2358. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, "WHO", client.t("First param must be a mask or channel"))
  2359. return false
  2360. }
  2361. var mask string
  2362. if len(msg.Params) > 0 {
  2363. casefoldedMask, err := Casefold(msg.Params[0])
  2364. if err != nil {
  2365. rb.Add(nil, server.name, ERR_UNKNOWNERROR, "WHO", client.t("Mask isn't valid"))
  2366. return false
  2367. }
  2368. mask = casefoldedMask
  2369. }
  2370. friends := client.Friends()
  2371. //TODO(dan): is this used and would I put this param in the Modern doc?
  2372. // if not, can we remove it?
  2373. //var operatorOnly bool
  2374. //if len(msg.Params) > 1 && msg.Params[1] == "o" {
  2375. // operatorOnly = true
  2376. //}
  2377. if mask[0] == '#' {
  2378. // TODO implement wildcard matching
  2379. //TODO(dan): ^ only for opers
  2380. channel := server.channels.Get(mask)
  2381. if channel != nil {
  2382. whoChannel(client, channel, friends, rb)
  2383. }
  2384. } else {
  2385. for mclient := range server.clients.FindAll(mask) {
  2386. client.rplWhoReply(nil, mclient, rb)
  2387. }
  2388. }
  2389. rb.Add(nil, server.name, RPL_ENDOFWHO, client.nick, mask, client.t("End of WHO list"))
  2390. return false
  2391. }
  2392. // WHOIS [<target>] <mask>{,<mask>}
  2393. func whoisHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2394. var masksString string
  2395. //var target string
  2396. if len(msg.Params) > 1 {
  2397. //target = msg.Params[0]
  2398. masksString = msg.Params[1]
  2399. } else {
  2400. masksString = msg.Params[0]
  2401. }
  2402. if len(strings.TrimSpace(masksString)) < 1 {
  2403. rb.Add(nil, server.name, ERR_UNKNOWNERROR, client.nick, msg.Command, client.t("No masks given"))
  2404. return false
  2405. }
  2406. if client.flags[modes.Operator] {
  2407. masks := strings.Split(masksString, ",")
  2408. for _, mask := range masks {
  2409. casefoldedMask, err := Casefold(mask)
  2410. if err != nil {
  2411. rb.Add(nil, client.server.name, ERR_NOSUCHNICK, client.nick, mask, client.t("No such nick"))
  2412. continue
  2413. }
  2414. matches := server.clients.FindAll(casefoldedMask)
  2415. if len(matches) == 0 {
  2416. rb.Add(nil, client.server.name, ERR_NOSUCHNICK, client.nick, mask, client.t("No such nick"))
  2417. continue
  2418. }
  2419. for mclient := range matches {
  2420. client.getWhoisOf(mclient, rb)
  2421. }
  2422. }
  2423. } else {
  2424. // only get the first request
  2425. casefoldedMask, err := Casefold(strings.Split(masksString, ",")[0])
  2426. mclient := server.clients.Get(casefoldedMask)
  2427. if err != nil || mclient == nil {
  2428. rb.Add(nil, client.server.name, ERR_NOSUCHNICK, client.nick, masksString, client.t("No such nick"))
  2429. // fall through, ENDOFWHOIS is always sent
  2430. } else {
  2431. client.getWhoisOf(mclient, rb)
  2432. }
  2433. }
  2434. rb.Add(nil, server.name, RPL_ENDOFWHOIS, client.nick, masksString, client.t("End of /WHOIS list"))
  2435. return false
  2436. }
  2437. // WHOWAS <nickname> [<count> [<server>]]
  2438. func whowasHandler(server *Server, client *Client, msg ircmsg.IrcMessage, rb *ResponseBuffer) bool {
  2439. nicknames := strings.Split(msg.Params[0], ",")
  2440. var count int64
  2441. if len(msg.Params) > 1 {
  2442. count, _ = strconv.ParseInt(msg.Params[1], 10, 64)
  2443. }
  2444. //var target string
  2445. //if len(msg.Params) > 2 {
  2446. // target = msg.Params[2]
  2447. //}
  2448. for _, nickname := range nicknames {
  2449. results := server.whoWas.Find(nickname, count)
  2450. if len(results) == 0 {
  2451. if len(nickname) > 0 {
  2452. rb.Add(nil, server.name, ERR_WASNOSUCHNICK, client.nick, nickname, client.t("There was no such nickname"))
  2453. }
  2454. } else {
  2455. for _, whoWas := range results {
  2456. rb.Add(nil, server.name, RPL_WHOWASUSER, client.nick, whoWas.nickname, whoWas.username, whoWas.hostname, "*", whoWas.realname)
  2457. }
  2458. }
  2459. if len(nickname) > 0 {
  2460. rb.Add(nil, server.name, RPL_ENDOFWHOWAS, client.nick, nickname, client.t("End of WHOWAS"))
  2461. }
  2462. }
  2463. return false
  2464. }