Implement message parsing and constructing

This commit is contained in:
Les De Ridder 2017-03-11 03:44:02 +01:00
commit 8ec20b7167
No known key found for this signature in database
GPG Key ID: 5EC132DFA85DB372
4 changed files with 118 additions and 0 deletions

7
.gitignore vendored Normal file
View File

@ -0,0 +1,7 @@
.dub
docs.json
__dummy.html
*.o
*.obj
__test__*__
ircd

7
dub.sdl Normal file
View File

@ -0,0 +1,7 @@
name "ircd"
description "An Internet Relay Chat server in D"
authors "Les De Ridder"
copyright "Copyright © 2017, Les De Ridder"
license "NCSA"
dependency "vibe-d" version="~>0.7.30"
versions "VibeDefaultMain"

11
dub.selections.json Normal file
View File

@ -0,0 +1,11 @@
{
"fileVersion": 1,
"versions": {
"diet-ng": "1.2.0",
"libasync": "0.7.9",
"libevent": "2.0.2+2.0.16",
"memutils": "0.4.9",
"openssl": "1.1.5+1.0.1g",
"vibe-d": "0.7.30"
}
}

93
source/app.d Normal file
View File

@ -0,0 +1,93 @@
import vibe.d;
import std.stdio;
import std.functional;
import std.array;
import std.algorithm;
import std.conv;
shared static this()
{
listenTCP(6667, toDelegate(&handleConnection), "127.0.0.1");
}
struct Message
{
string prefix;
string command;
string[] parameters;
bool prefixedParameter;
static Message fromString(string line)
{
string prefix = null;
if(line.startsWith(':'))
{
line = line[1 .. $];
prefix = line[0 .. line.indexOf(' ')];
line = line[prefix.length + 1 .. $];
}
auto command = line[0 .. line.indexOf(' ')];
line = line[command.length + 1 .. $];
string[] params = [];
bool prefixedParam;
while(true)
{
if(line.startsWith(':'))
{
params ~= line[1 .. $];
prefixedParam = true;
break;
}
else if(line.canFind(' '))
{
auto param = line[0 .. line.indexOf(' ')];
line = line[param.length + 1 .. $];
params ~= param;
}
else
{
params ~= line;
break;
}
}
return Message(prefix, command, params, prefixedParam);
}
string toString()
{
auto message = "";
if(prefix != null)
{
message = ":" ~ prefix ~ " ";
}
message ~= command ~ " ";
if(parameters.length > 1)
{
message ~= parameters[0 .. $-1].join(' ') ~ " ";
if(parameters[$-1].canFind(' ') || prefixedParameter)
{
message ~= ":";
}
}
message ~= parameters[$-1];
return message;
}
}
void handleConnection(TCPConnection connection)
{
writeln("connection opened");
while(connection.connected)
{
auto message = Message.fromString((cast(string)connection.readLine()).chomp);
writeln("C> " ~ message.toString);
}
writeln("connection closed");
}