@@ -100,7 +100,7 @@ fn main() {
100100 // Filter empty strings from channel names
101101 let sanitized_chans: Vec < String > = matches. value_of ( "channels" )
102102 . map ( |chans| {
103- chans. split ( "," )
103+ chans. split ( ',' )
104104 . filter ( |x| * x != "" )
105105 . map ( |x| x. to_string ( ) )
106106 . collect ( )
@@ -130,13 +130,13 @@ fn main() {
130130 let cfg = Config {
131131 nickname : Some ( nick) ,
132132 server : Some ( server) ,
133- port : port ,
133+ port,
134134 use_ssl : Some ( ssl) ,
135135 channels : Some ( channels. clone ( ) ) ,
136136 ..Default :: default ( )
137137 } ;
138138
139- let server = match IrcClient :: from_config ( cfg) {
139+ let client = match IrcClient :: from_config ( cfg) {
140140 Ok ( val) => val,
141141 Err ( e) => {
142142 error ! ( "{}" , e) ;
@@ -145,11 +145,11 @@ fn main() {
145145 } ;
146146
147147 // Connect to IRC on its own thread
148- let irc_server = server . clone ( ) ;
148+ let irc_client = client . clone ( ) ;
149149 let ( sirc, rirc) = chan:: sync ( 0 ) ;
150150
151151 debug ! ( "Spawning IRC client..." ) ;
152- spawn ( move || run_irc ( irc_server , raw_out, quiet, sirc) ) ;
152+ spawn ( move || run_irc ( irc_client , raw_out, quiet, sirc) ) ;
153153
154154 // Wait until we've joined all the channels we need to
155155 let mut join_count = 0 ;
@@ -159,7 +159,7 @@ fn main() {
159159 chan_select ! {
160160 signal. recv( ) -> signal => {
161161 debug!( "Received signal {:?}; quitting" , signal) ;
162- server . send_quit( "#|" ) . unwrap( ) ;
162+ client . send_quit( "#|" ) . unwrap( ) ;
163163 return ;
164164 } ,
165165 rirc. recv( ) -> action => match action {
@@ -170,7 +170,7 @@ fn main() {
170170 Some ( Action :: Join ) => join_count += 1 ,
171171 Some ( Action :: Quit ) => {
172172 debug!( "QUIT received while attempting to join channels" ) ;
173- server . send_quit( "#|" ) . unwrap( ) ;
173+ client . send_quit( "#|" ) . unwrap( ) ;
174174 return ;
175175 } ,
176176 Some ( Action :: JoinFail ( err) ) => {
@@ -179,7 +179,7 @@ fn main() {
179179 } ,
180180 Some ( Action :: IoError ( err) ) => {
181181 error!( "{}" , err) ;
182- server . send_quit( "#|" ) . unwrap( ) ;
182+ client . send_quit( "#|" ) . unwrap( ) ;
183183 return ;
184184 } ,
185185 _ => ( )
@@ -190,11 +190,11 @@ fn main() {
190190 info ! ( "Joined {} channels" , join_count) ;
191191
192192 // Open stdin and write it to the desired channels
193- let io_server = server . clone ( ) ;
193+ let io_client = client . clone ( ) ;
194194 let ( sio, rio) = chan:: sync ( 0 ) ;
195195
196196 debug ! ( "Spawning stdin reader..." ) ;
197- spawn ( move || run_io ( io_server , channels, raw_in, sio) ) ;
197+ spawn ( move || run_io ( io_client , channels, raw_in, sio) ) ;
198198
199199 loop {
200200 chan_select ! {
@@ -230,14 +230,14 @@ fn main() {
230230 }
231231
232232 info ! ( "Quitting!" ) ;
233- server . send_quit ( "#|" ) . unwrap ( ) ;
233+ client . send_quit ( "#|" ) . unwrap ( ) ;
234234}
235235
236236/// Manage IRC connection; read and print messages; signal on JOIN or QUIT
237- fn run_irc ( server : IrcClient , raw : bool , quiet : bool , sjoin : chan:: Sender < Action > ) {
238- server . identify ( ) . unwrap_or_else ( |err| sjoin. send ( From :: from ( err) ) ) ;
237+ fn run_irc ( client : IrcClient , raw : bool , quiet : bool , sjoin : chan:: Sender < Action > ) {
238+ client . identify ( ) . unwrap_or_else ( |err| sjoin. send ( From :: from ( err) ) ) ;
239239
240- let res = server . for_each_incoming ( |msg| {
240+ let res = client . for_each_incoming ( |msg| {
241241 if raw {
242242 print ! ( "{}" , msg) ;
243243 stdout ( ) . flush ( ) . unwrap_or_else ( |err| sjoin. send ( From :: from ( err) ) ) ;
@@ -292,7 +292,7 @@ fn run_irc(server: IrcClient, raw: bool, quiet: bool, sjoin: chan::Sender<Action
292292}
293293
294294/// Read stdin and write each line to channels/the server
295- fn run_io ( server : IrcClient , channels : Vec < String > , raw : bool , sdone : chan:: Sender < Action > ) {
295+ fn run_io ( client : IrcClient , channels : Vec < String > , raw : bool , sdone : chan:: Sender < Action > ) {
296296 let stdin = BufReader :: new ( std:: io:: stdin ( ) ) ;
297297 for line in stdin. lines ( ) {
298298 match line {
@@ -301,13 +301,13 @@ fn run_io(server: IrcClient, channels: Vec<String>, raw: bool, sdone: chan::Send
301301 let raw_line = ln + "\r \n " ; // IRC line terminator
302302 match Message :: from_str ( & raw_line) {
303303 Ok ( msg) => {
304- server . send ( msg) . unwrap_or_else ( |err| sdone. send ( From :: from ( err) ) )
304+ client . send ( msg) . unwrap_or_else ( |err| sdone. send ( From :: from ( err) ) )
305305 }
306306 Err ( err) => sdone. send ( From :: from ( err) ) ,
307307 }
308308 } else {
309309 for channel in & channels {
310- server . send_privmsg ( & channel, & ln)
310+ client . send_privmsg ( & channel, & ln)
311311 . unwrap_or_else ( |err| sdone. send ( From :: from ( err) ) ) ;
312312 }
313313 }
0 commit comments