77 lines
2 KiB
D
77 lines
2 KiB
D
|
import std.functional;
|
||
|
|
|
||
|
|
import vibe.vibe;
|
||
|
|
|
||
|
|
import kerstezelprotocol;
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
struct VertaalContext {
|
||
|
|
import std.typetuple;
|
||
|
|
// Throw an error when an translation string is missing/mistyped.
|
||
|
|
enum enforceExistingKeys = true;
|
||
|
|
// The list of supported languages (the same family of languages will
|
||
|
|
// automatically be matched to the closest candidate, e.g. en_GB->en_US)
|
||
|
|
alias languages = TypeTuple!("en_GB", "nl_NL");
|
||
|
|
// The base name of the translation files - the full names will be
|
||
|
|
// kerstman.en_US.po and kerstman.de_DE.po. Any number of these mixin
|
||
|
|
// statements can be used.
|
||
|
|
mixin translationModule!"kerstman";
|
||
|
|
}
|
||
|
|
|
||
|
|
@translationContext!VertaalContext
|
||
|
|
class KerstezelService {
|
||
|
|
|
||
|
|
@path("/")
|
||
|
|
void getIndex() {
|
||
|
|
render!"index.dt";
|
||
|
|
}
|
||
|
|
|
||
|
|
@path("/arreslee")
|
||
|
|
void getArreslee(scope WebSocket bus) {
|
||
|
|
runTask((WebSocket bus) {
|
||
|
|
while(bus.connected) {
|
||
|
|
string commando = bus.receiveText;
|
||
|
|
if (commando == "trommel") {
|
||
|
|
kerstmanTaak.send(TrommelCommando());
|
||
|
|
} else {
|
||
|
|
logInfo("Onbekend commando:" ~ commando);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}, bus);
|
||
|
|
|
||
|
|
while (bus.connected) {
|
||
|
|
int uitzend_aantal = staatGebeurtenis.emitCount;
|
||
|
|
bus.send(staat.serializeToJsonString());
|
||
|
|
// Wordt elke 30 seconden wakker om de verbinding in leven
|
||
|
|
// te houden en/of te detecteren dat deze juist gestopt is.
|
||
|
|
staatGebeurtenis.wait(30.seconds, uitzend_aantal);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
void main() {
|
||
|
|
import vibe.http.router;
|
||
|
|
|
||
|
|
auto settings = new HTTPServerSettings;
|
||
|
|
settings.port = 8090;
|
||
|
|
settings.bindAddresses = ["::", "0.0.0.0"];
|
||
|
|
|
||
|
|
auto router = new URLRouter;
|
||
|
|
router.registerWebInterface(new KerstezelService);
|
||
|
|
|
||
|
|
auto fsettings = new HTTPFileServerSettings;
|
||
|
|
fsettings.serverPathPrefix = "/statisch";
|
||
|
|
router.get("*", serveStaticFiles("statisch/", fsettings));
|
||
|
|
|
||
|
|
listenHTTP(settings, router);
|
||
|
|
|
||
|
|
logInfo("Please open http://127.0.0.1:8080/ in your browser.");
|
||
|
|
if (!listenTCP(9305, toDelegate(&kerstezelProtocolLuister), "0.0.0.0")) {
|
||
|
|
logWarn("Kon kerstezelProtocol niet starten");
|
||
|
|
}
|
||
|
|
runApplication();
|
||
|
|
}
|