blob: 05daa8c8a4c9aa85b833c693597b75d52c8a6dc9 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
# IrcStates
port of [jesopo/ircstates](https://github.com/jesopo/ircstates)
bare bones irc client state
see the full example in [StatesSample/Client.cs](../Examples/States/Client.cs)
internal class Client
{
private readonly byte[] _bytes;
private readonly StatefulEncoder _encoder;
private readonly string _host;
private readonly string _nick;
private readonly int _port;
private readonly Server _server;
private readonly Socket _socket;
public Client(string host, int port, string nick)
{
_server = new Server("test");
_socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
_encoder = new StatefulEncoder();
_host = host;
_port = port;
_nick = nick;
_bytes = new byte[1024];
}
private void Send(string raw)
{
_encoder.Push(new Line(raw));
}
public void Start()
{
_socket.Connect(_host, _port);
while (!_socket.Connected) Thread.Sleep(1000);
Send("USER test 0 * test");
Send($"NICK {_nick}");
while (true)
{
while (_encoder.PendingBytes.Any())
{
var bytesSent = _socket.Send(_encoder.PendingBytes);
var sentLines = _encoder.Pop(bytesSent);
foreach (var line in sentLines) Console.WriteLine($"> {line.Format()}");
}
var bytesReceived = _socket.Receive(_bytes);
if (bytesReceived == 0)
{
Console.WriteLine("! disconnected");
_socket.Shutdown(SocketShutdown.Both);
_socket.Close();
break;
}
var receivedLines = _server.Receive(_bytes, bytesReceived);
foreach (var (line, _) in receivedLines)
{
Console.WriteLine($"< {line.Format()}");
switch (line.Command)
{
case Commands.Privmsg:
if (line.Params[1].Contains(_server.NickName))
Send($"PRIVMSG {line.Params[0]} :hi {line.Hostmask.NickName}!");
break;
case "PING":
Send($"PONG :{line.Params[0]}");
break;
case Numeric.RPL_WELCOME:
if (!_server.HasChannel("#test")) Send("JOIN #test");
break;
}
}
}
}
}
|
