Compare commits
No commits in common. "2151fff0faa03da4ef02363e3786c37ff8faa0e9" and "079c47962a65f7e50eeb0fde1214f9ebe9934ed1" have entirely different histories.
2151fff0fa
...
079c47962a
100
priv/chat.html
100
priv/chat.html
@ -1,100 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<title>Chat with Websockets</title>
|
|
||||||
<link rel="stylesheet" href="./default.css">
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="content">
|
|
||||||
<h1 class="content-title">Chat with websockets</h1>
|
|
||||||
|
|
||||||
<div class="content-body">
|
|
||||||
<input autofocus label="Nick" id="nick"></input>
|
|
||||||
<textarea hidden disabled id="wfc-output"></textarea>
|
|
||||||
<input hidden id="wfc-input"></input>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<script>
|
|
||||||
let nelt = document.getElementById('nick');
|
|
||||||
let ielt = document.getElementById('wfc-input');
|
|
||||||
let oelt = document.getElementById('wfc-output');
|
|
||||||
let ws = new WebSocket("/ws/chat");
|
|
||||||
let nick = '';
|
|
||||||
|
|
||||||
// when user hits any key while typing in nick
|
|
||||||
function on_nick(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = nelt.value;
|
|
||||||
let trimmed = contents.trim();
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = trimmed.length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
nick = trimmed;
|
|
||||||
let msg_obj = ['nick', nick];
|
|
||||||
let msg_str = JSON.stringify(msg_obj);
|
|
||||||
console.log('message to server:', contents.trim());
|
|
||||||
// query backend for result
|
|
||||||
ws.send(msg_str);
|
|
||||||
|
|
||||||
// delete element from dom
|
|
||||||
nelt.remove();
|
|
||||||
oelt.hidden = false;
|
|
||||||
ielt.hidden = false;
|
|
||||||
ielt.autofocus = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// when user hits any key while typing in ielt
|
|
||||||
function on_input_key(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = ielt.value;
|
|
||||||
let trimmed = contents.trim();
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = trimmed.length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
let msg_obj = ['chat', trimmed];
|
|
||||||
let msg_str = JSON.stringify(msg_obj);
|
|
||||||
console.log('message to server:', contents.trim());
|
|
||||||
// query backend for result
|
|
||||||
ws.send(msg_str);
|
|
||||||
|
|
||||||
// clear input
|
|
||||||
ielt.value = '';
|
|
||||||
|
|
||||||
// add to output
|
|
||||||
oelt.value += '> ';
|
|
||||||
oelt.value += trimmed;
|
|
||||||
oelt.value += '\n';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function main() {
|
|
||||||
nelt.addEventListener('keydown', on_nick);
|
|
||||||
ielt.addEventListener('keydown', on_input_key);
|
|
||||||
ws.onmessage =
|
|
||||||
function (msg_evt) {
|
|
||||||
console.log('message from server:', msg_evt);
|
|
||||||
let msg_str = msg_evt.data;
|
|
||||||
let msg_obj = JSON.parse(msg_str);
|
|
||||||
|
|
||||||
oelt.value += msg_obj.nick;
|
|
||||||
oelt.value += '> ';
|
|
||||||
oelt.value += msg_obj.msg;
|
|
||||||
oelt.value += '\n';
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
main();
|
|
||||||
</script>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
@ -10,12 +10,15 @@
|
|||||||
<h1 class="content-title">WFC Demo</h1>
|
<h1 class="content-title">WFC Demo</h1>
|
||||||
|
|
||||||
<ul>
|
<ul>
|
||||||
<li><a href="/chat.html">Websocket Chatroom</a></li>
|
<li>
|
||||||
<li><a href="/ws-test-echo.html">Websocket Echo Test</a></li>
|
<a href="/ws-test-echo.html">Websocket Echo Test</a>
|
||||||
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
|
||||||
<div class="content-body">
|
<div class="content-body">
|
||||||
<textarea disabled id="wfc-output"></textarea>
|
<textarea id="wfc-output"
|
||||||
|
disabled
|
||||||
|
></textarea>
|
||||||
<input autofocus id="wfc-input"></input>
|
<input autofocus id="wfc-input"></input>
|
||||||
|
|
||||||
<h2>Settings</h2>
|
<h2>Settings</h2>
|
||||||
|
|||||||
@ -1,100 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<title>Chat with Websockets</title>
|
|
||||||
<link rel="stylesheet" href="./default.css">
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="content">
|
|
||||||
<h1 class="content-title">Chat with websockets</h1>
|
|
||||||
|
|
||||||
<div class="content-body">
|
|
||||||
<input autofocus label="Nick" id="nick"></input>
|
|
||||||
<textarea hidden disabled id="wfc-output"></textarea>
|
|
||||||
<input hidden id="wfc-input"></input>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<script>
|
|
||||||
let nelt = document.getElementById('nick');
|
|
||||||
let ielt = document.getElementById('wfc-input');
|
|
||||||
let oelt = document.getElementById('wfc-output');
|
|
||||||
let ws = new WebSocket("/ws/chat");
|
|
||||||
let nick = '';
|
|
||||||
|
|
||||||
// when user hits any key while typing in nick
|
|
||||||
function on_nick(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = nelt.value;
|
|
||||||
let trimmed = contents.trim();
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = trimmed.length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
nick = trimmed;
|
|
||||||
let msg_obj = ['nick', nick];
|
|
||||||
let msg_str = JSON.stringify(msg_obj);
|
|
||||||
console.log('message to server:', contents.trim());
|
|
||||||
// query backend for result
|
|
||||||
ws.send(msg_str);
|
|
||||||
|
|
||||||
// delete element from dom
|
|
||||||
nelt.remove();
|
|
||||||
oelt.hidden = false;
|
|
||||||
ielt.hidden = false;
|
|
||||||
ielt.autofocus = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// when user hits any key while typing in ielt
|
|
||||||
function on_input_key(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = ielt.value;
|
|
||||||
let trimmed = contents.trim();
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = trimmed.length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
let msg_obj = ['chat', trimmed];
|
|
||||||
let msg_str = JSON.stringify(msg_obj);
|
|
||||||
console.log('message to server:', contents.trim());
|
|
||||||
// query backend for result
|
|
||||||
ws.send(msg_str);
|
|
||||||
|
|
||||||
// clear input
|
|
||||||
ielt.value = '';
|
|
||||||
|
|
||||||
// add to output
|
|
||||||
oelt.value += '> ';
|
|
||||||
oelt.value += trimmed;
|
|
||||||
oelt.value += '\n';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function main() {
|
|
||||||
nelt.addEventListener('keydown', on_nick);
|
|
||||||
ielt.addEventListener('keydown', on_input_key);
|
|
||||||
ws.onmessage =
|
|
||||||
function (msg_evt) {
|
|
||||||
console.log('message from server:', msg_evt);
|
|
||||||
let msg_str = msg_evt.data;
|
|
||||||
let msg_obj = JSON.parse(msg_str);
|
|
||||||
|
|
||||||
oelt.value += msg_obj.nick;
|
|
||||||
oelt.value += '> ';
|
|
||||||
oelt.value += msg_obj.msg;
|
|
||||||
oelt.value += '\n';
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
main();
|
|
||||||
</script>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
@ -1,95 +0,0 @@
|
|||||||
/* color pallette */
|
|
||||||
* {
|
|
||||||
--white: #f7f8fb;
|
|
||||||
--lgray0: #f5fbfd;
|
|
||||||
--lgray1: #daddd6;
|
|
||||||
--lgray2: #d3d8d5;
|
|
||||||
--mgray1: #687864;
|
|
||||||
--dgreen1: #21341e;
|
|
||||||
--lgreen1: #e5eef2;
|
|
||||||
--black: #003d27;
|
|
||||||
|
|
||||||
--sans: Helvetica, Liberation Sans, FreeSans, Roboto, sans-serif;
|
|
||||||
--mono: Liberation Mono, FreeMono, Roboto Mono, monospace;
|
|
||||||
--fsdef: 12pt;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* body */
|
|
||||||
body {
|
|
||||||
background: var(--white);
|
|
||||||
color: var(--dgray1);
|
|
||||||
font-size: var(--fsdef);
|
|
||||||
font-family: var(--sans);
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
line-height: 1.4;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
.content {
|
|
||||||
max-width: 800px;
|
|
||||||
margin: 0 auto;
|
|
||||||
/*
|
|
||||||
background: #ff0;
|
|
||||||
*/
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/* add some top padding to content */
|
|
||||||
|
|
||||||
.content-title {
|
|
||||||
text-align: center;
|
|
||||||
text-decoration: underline;
|
|
||||||
}
|
|
||||||
|
|
||||||
.content-body {
|
|
||||||
width: 100%;
|
|
||||||
margin: 0 auto;
|
|
||||||
/*
|
|
||||||
background: #f00;
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
padding-left: 10px;
|
|
||||||
padding-right: 10px;
|
|
||||||
|
|
||||||
box-sizing: border-box;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* element-specific styling */
|
|
||||||
|
|
||||||
a {
|
|
||||||
color: var(--mgray1);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
#wfc-input {
|
|
||||||
font-family: var(--mono);
|
|
||||||
font-size: var(--fsdef);
|
|
||||||
background: var(--lgreen1);
|
|
||||||
|
|
||||||
width: 100%;
|
|
||||||
|
|
||||||
box-sizing: border-box;
|
|
||||||
|
|
||||||
border-radius: 6px;
|
|
||||||
border: 1px solid var(--lgray1);
|
|
||||||
|
|
||||||
padding: 5px;
|
|
||||||
}
|
|
||||||
|
|
||||||
#wfc-output {
|
|
||||||
background: var(--lgray0);
|
|
||||||
font-family: var(--mono);
|
|
||||||
font-size: var(--fsdef);
|
|
||||||
|
|
||||||
width: 100%;
|
|
||||||
resize: vertical;
|
|
||||||
|
|
||||||
box-sizing: border-box;
|
|
||||||
|
|
||||||
border-radius: 6px;
|
|
||||||
border: 1px solid var(--lgray1);
|
|
||||||
|
|
||||||
padding: 5px;
|
|
||||||
}
|
|
||||||
@ -1,138 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<title>WF Compiler Demo</title>
|
|
||||||
<link rel="stylesheet" href="./default.css">
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="content">
|
|
||||||
<h1 class="content-title">WFC Demo</h1>
|
|
||||||
|
|
||||||
<ul>
|
|
||||||
<li><a href="/chat.html">Websocket Chatroom</a></li>
|
|
||||||
<li><a href="/ws-test-echo.html">Websocket Echo Test</a></li>
|
|
||||||
</ul>
|
|
||||||
|
|
||||||
<div class="content-body">
|
|
||||||
<textarea disabled id="wfc-output"></textarea>
|
|
||||||
<input autofocus id="wfc-input"></input>
|
|
||||||
|
|
||||||
<h2>Settings</h2>
|
|
||||||
<input type="checkbox" checked id="auto-resize-output">Auto-resize output</input> <br>
|
|
||||||
<input type="checkbox" checked id="auto-scroll" >Auto-scroll output to bottom</input>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<script>
|
|
||||||
let ielt = document.getElementById('wfc-input');
|
|
||||||
let oelt = document.getElementById('wfc-output');
|
|
||||||
let MAX_OELT_HEIGHT = 300;
|
|
||||||
|
|
||||||
function auto_resize_output() {
|
|
||||||
// if the user has manually resized their output, we do nothing
|
|
||||||
if (document.getElementById('auto-resize-output').checked) {
|
|
||||||
// resize it automagically up to 500px
|
|
||||||
if (oelt.scrollHeight < MAX_OELT_HEIGHT) {
|
|
||||||
oelt.style.height = String(oelt.scrollHeight) + 'px';
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
oelt.style.height = String(MAX_OELT_HEIGHT) + 'px';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function auto_scroll_to_bottom() {
|
|
||||||
if (document.getElementById('auto-scroll').checked) {
|
|
||||||
// scroll to bottom
|
|
||||||
oelt.scrollTop = oelt.scrollHeight;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async function on_server_return(response) {
|
|
||||||
console.log('on_server_return:', response);
|
|
||||||
if (response.ok) {
|
|
||||||
let jsbs = await response.json();
|
|
||||||
console.log('jsbs', jsbs);
|
|
||||||
// jsbs: {ok: true, result: string} | {ok: false, error: string}
|
|
||||||
if (jsbs.ok) {
|
|
||||||
// this means got a result back from server
|
|
||||||
// put it in
|
|
||||||
oelt.value += jsbs.result;
|
|
||||||
oelt.value += '\n';
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
// this is an error at the WFC level
|
|
||||||
oelt.value += jsbs.error;
|
|
||||||
oelt.value += '\n';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// this means we sent an invalid request
|
|
||||||
else {
|
|
||||||
oelt.value += 'HTTP ERROR, SEE BROWSER CONSOLE\n'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function on_some_bullshit(x) {
|
|
||||||
console.log('on_some_bullshit:', x);
|
|
||||||
oelt.value += 'NETWORK ERROR, SEE BROWSER CONSOLE\n'
|
|
||||||
}
|
|
||||||
|
|
||||||
function fetch_wfcin(user_line) {
|
|
||||||
let req_body_obj = {wfcin: user_line};
|
|
||||||
// let req_body_str = JSON.stringify(req_body_obj, undefined, 4);
|
|
||||||
let req_body_str = JSON.stringify(req_body_obj);
|
|
||||||
|
|
||||||
let req_options = {method: 'POST',
|
|
||||||
headers: {'content-type': 'application/json'},
|
|
||||||
body: req_body_str};
|
|
||||||
|
|
||||||
let response_promise = fetch('/wfcin', req_options);
|
|
||||||
|
|
||||||
response_promise.then(on_server_return, on_some_bullshit);
|
|
||||||
|
|
||||||
// this is a promise for a response
|
|
||||||
//console.log(response_promise);
|
|
||||||
}
|
|
||||||
|
|
||||||
// when user hits any key
|
|
||||||
function on_input_key(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = ielt.value;
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = contents.trim().length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
// put in output
|
|
||||||
// // if it's nonempty add a newline
|
|
||||||
// if (oelt.value.length > 0) {
|
|
||||||
// oelt.value += '\n';
|
|
||||||
// }
|
|
||||||
oelt.value += '> ' + contents + '\n';
|
|
||||||
oelt.hidden = false;
|
|
||||||
|
|
||||||
// query backend for result
|
|
||||||
fetch_wfcin(contents.trim());
|
|
||||||
|
|
||||||
// clear input
|
|
||||||
ielt.value = '';
|
|
||||||
|
|
||||||
// auto-resize
|
|
||||||
auto_resize_output();
|
|
||||||
auto_scroll_to_bottom();
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function main() {
|
|
||||||
ielt.addEventListener('keydown', on_input_key);
|
|
||||||
}
|
|
||||||
|
|
||||||
main();
|
|
||||||
</script>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
@ -1,56 +0,0 @@
|
|||||||
/* header */
|
|
||||||
div#header {
|
|
||||||
background: var(--lgray2);
|
|
||||||
height: 50px;
|
|
||||||
width: 100%;
|
|
||||||
}
|
|
||||||
|
|
||||||
img#header-logo {
|
|
||||||
height: 40px;
|
|
||||||
margin-top: 5px;
|
|
||||||
margin-bottom: 5px;
|
|
||||||
margin-left: 5px;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
.main {
|
|
||||||
padding-top: 20px;
|
|
||||||
}
|
|
||||||
|
|
||||||
.content-diagram {
|
|
||||||
max-width: 100%;
|
|
||||||
margin: 0 auto;
|
|
||||||
padding: 0 auto;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/* Pandoc makes some wacky choices with how it lays out code blocks
|
|
||||||
*
|
|
||||||
* this means all <code> blocks that do not have a <pre> block as an ancestor
|
|
||||||
*
|
|
||||||
* ie the `inline code`
|
|
||||||
*/
|
|
||||||
code:not(pre *) {
|
|
||||||
border-radius: 6px;
|
|
||||||
border: 1px solid var(--lgray1);
|
|
||||||
padding-left: 3px;
|
|
||||||
padding-right: 3px;
|
|
||||||
padding-top: 1px;
|
|
||||||
padding-bottom: 1px;
|
|
||||||
background: var(--lgreen1);
|
|
||||||
}
|
|
||||||
|
|
||||||
/* this is specifically for ```fenced blocks``` */
|
|
||||||
pre {
|
|
||||||
border-radius: 6px;
|
|
||||||
border: 1px solid var(--lgray1);
|
|
||||||
padding: 5px;
|
|
||||||
background: var(--lgreen1);
|
|
||||||
overflow: scroll;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* All `unfenced` or ```fenced``` blocks */
|
|
||||||
code {
|
|
||||||
font-family: Liberation Mono, Roboto Mono, monospace;
|
|
||||||
color: var(--dgreen1);
|
|
||||||
}
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="en">
|
|
||||||
<head>
|
|
||||||
<meta charset="utf-8">
|
|
||||||
<title>Websockets echo test</title>
|
|
||||||
<link rel="stylesheet" href="./default.css">
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="content">
|
|
||||||
<h1 class="content-title">Websockets echo test</h1>
|
|
||||||
|
|
||||||
<div class="content-body">
|
|
||||||
<textarea id="wfc-output"
|
|
||||||
disabled></textarea>
|
|
||||||
<input autofocus id="wfc-input"></input>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<script>
|
|
||||||
let ielt = document.getElementById('wfc-input');
|
|
||||||
let oelt = document.getElementById('wfc-output');
|
|
||||||
let ws = new WebSocket("/ws/echo");
|
|
||||||
|
|
||||||
// when user hits any key while typing in ielt
|
|
||||||
function on_input_key(evt) {
|
|
||||||
if (evt.key === 'Enter') {
|
|
||||||
// don't do default thing
|
|
||||||
evt.preventDefault();
|
|
||||||
// grab contents
|
|
||||||
let contents = ielt.value;
|
|
||||||
let trimmed = contents.trim();
|
|
||||||
// if contents are nonempty
|
|
||||||
let nonempty_contents = trimmed.length > 0;
|
|
||||||
if (nonempty_contents) {
|
|
||||||
console.log('message to server:', contents.trim());
|
|
||||||
// query backend for result
|
|
||||||
ws.send(contents.trim());
|
|
||||||
|
|
||||||
// clear input
|
|
||||||
ielt.value = '';
|
|
||||||
|
|
||||||
// add to output
|
|
||||||
oelt.value += '> ';
|
|
||||||
oelt.value += trimmed;
|
|
||||||
oelt.value += '\n';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function main() {
|
|
||||||
ielt.addEventListener('keydown', on_input_key);
|
|
||||||
ws.onmessage =
|
|
||||||
function (msg_evt) {
|
|
||||||
console.log('message from server:', msg_evt);
|
|
||||||
let msg_str = msg_evt.data;
|
|
||||||
oelt.value += '< ';
|
|
||||||
oelt.value += msg_str;
|
|
||||||
oelt.value += '\n';
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
main();
|
|
||||||
</script>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
262
src/fd_chat.erl
262
src/fd_chat.erl
@ -1,262 +0,0 @@
|
|||||||
% @doc
|
|
||||||
% controller for chat
|
|
||||||
-module(fd_chat).
|
|
||||||
-vsn("0.1.0").
|
|
||||||
-behavior(gen_server).
|
|
||||||
-author("Peter Harpending <peterharpending@qpq.swiss>").
|
|
||||||
-copyright("Peter Harpending <peterharpending@qpq.swiss>").
|
|
||||||
-license("BSD-2-Clause-FreeBSD").
|
|
||||||
|
|
||||||
-export([
|
|
||||||
join/1,
|
|
||||||
relay/1,
|
|
||||||
nick_available/1
|
|
||||||
]).
|
|
||||||
-export([start_link/0]).
|
|
||||||
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
|
||||||
code_change/3, terminate/2]).
|
|
||||||
|
|
||||||
-include("$zx_include/zx_logger.hrl").
|
|
||||||
|
|
||||||
|
|
||||||
-record(o, {pid :: pid(),
|
|
||||||
nick :: string()}).
|
|
||||||
-type orator() :: #o{}.
|
|
||||||
|
|
||||||
-record(s, {orators = [] :: [orator()]}).
|
|
||||||
|
|
||||||
-type state() :: #s{}.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
%%% Service Interface
|
|
||||||
|
|
||||||
-spec join(Nick) -> Result
|
|
||||||
when Nick :: string(),
|
|
||||||
Result :: ok
|
|
||||||
| {error, Reason :: any()}.
|
|
||||||
|
|
||||||
join(Nick) ->
|
|
||||||
gen_server:call(?MODULE, {join, Nick}).
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-spec nick_available(Nick) -> Result
|
|
||||||
when Nick :: string(),
|
|
||||||
Result :: boolean().
|
|
||||||
|
|
||||||
nick_available(Nick) ->
|
|
||||||
gen_server:call(?MODULE, {nick_available, Nick}).
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-spec relay(Message) -> ok
|
|
||||||
when Message :: string().
|
|
||||||
|
|
||||||
relay(Message) ->
|
|
||||||
gen_server:cast(?MODULE, {relay, self(), Message}).
|
|
||||||
|
|
||||||
|
|
||||||
%%% Startup Functions
|
|
||||||
|
|
||||||
|
|
||||||
-spec start_link() -> Result
|
|
||||||
when Result :: {ok, pid()}
|
|
||||||
| {error, Reason :: term()}.
|
|
||||||
%% @private
|
|
||||||
%% This should only ever be called by fd_chat_orators (the service-level supervisor).
|
|
||||||
|
|
||||||
start_link() ->
|
|
||||||
gen_server:start_link({local, ?MODULE}, ?MODULE, none, []).
|
|
||||||
|
|
||||||
|
|
||||||
-spec init(none) -> {ok, state()}.
|
|
||||||
%% @private
|
|
||||||
%% Called by the supervisor process to give the process a chance to perform any
|
|
||||||
%% preparatory work necessary for proper function.
|
|
||||||
|
|
||||||
init(none) ->
|
|
||||||
ok = tell("~p Starting.", [?MODULE]),
|
|
||||||
State = #s{},
|
|
||||||
{ok, State}.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
%%% gen_server Message Handling Callbacks
|
|
||||||
|
|
||||||
|
|
||||||
-spec handle_call(Message, From, State) -> Result
|
|
||||||
when Message :: term(),
|
|
||||||
From :: {pid(), reference()},
|
|
||||||
State :: state(),
|
|
||||||
Result :: {reply, Response, NewState}
|
|
||||||
| {noreply, State},
|
|
||||||
Response :: term(),
|
|
||||||
NewState :: state().
|
|
||||||
%% @private
|
|
||||||
%% The gen_server:handle_call/3 callback.
|
|
||||||
%% See: http://erlang.org/doc/man/gen_server.html#Module:handle_call-3
|
|
||||||
|
|
||||||
handle_call({join, Nick}, {Pid, _}, State) ->
|
|
||||||
{Reply, NewState} = do_join(Pid, Nick, State),
|
|
||||||
{reply, Reply, NewState};
|
|
||||||
handle_call({nick_available, Nick}, _, State = #s{orators = Orators}) ->
|
|
||||||
Reply = is_nick_available(Nick, Orators),
|
|
||||||
{reply, Reply, State};
|
|
||||||
handle_call(Unexpected, From, State) ->
|
|
||||||
ok = tell("~p Unexpected call from ~tp: ~tp~n", [?MODULE, From, Unexpected]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
-spec handle_cast(Message, State) -> {noreply, NewState}
|
|
||||||
when Message :: term(),
|
|
||||||
State :: state(),
|
|
||||||
NewState :: state().
|
|
||||||
%% @private
|
|
||||||
%% The gen_server:handle_cast/2 callback.
|
|
||||||
%% See: http://erlang.org/doc/man/gen_server.html#Module:handle_cast-2
|
|
||||||
|
|
||||||
handle_cast({relay, From, Message}, State = #s{orators = Orators}) ->
|
|
||||||
do_relay(From, Message, Orators),
|
|
||||||
{noreply, State};
|
|
||||||
handle_cast(Unexpected, State) ->
|
|
||||||
ok = tell("~p Unexpected cast: ~tp~n", [?MODULE, Unexpected]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
-spec handle_info(Message, State) -> {noreply, NewState}
|
|
||||||
when Message :: term(),
|
|
||||||
State :: state(),
|
|
||||||
NewState :: state().
|
|
||||||
%% @private
|
|
||||||
%% The gen_server:handle_info/2 callback.
|
|
||||||
%% See: http://erlang.org/doc/man/gen_server.html#Module:handle_info-2
|
|
||||||
|
|
||||||
handle_info(Msg = {'DOWN', _Mon, process, _Pid, _Reason}, State) ->
|
|
||||||
NewState = handle_down(Msg, State),
|
|
||||||
{noreply, NewState};
|
|
||||||
handle_info(Unexpected, State) ->
|
|
||||||
ok = tell("~p Unexpected info: ~tp~n", [?MODULE, Unexpected]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
%%% OTP Service Functions
|
|
||||||
|
|
||||||
-spec code_change(OldVersion, State, Extra) -> Result
|
|
||||||
when OldVersion :: {down, Version} | Version,
|
|
||||||
Version :: term(),
|
|
||||||
State :: state(),
|
|
||||||
Extra :: term(),
|
|
||||||
Result :: {ok, NewState}
|
|
||||||
| {error, Reason :: term()},
|
|
||||||
NewState :: state().
|
|
||||||
%% @private
|
|
||||||
%% The gen_server:code_change/3 callback.
|
|
||||||
%% See: http://erlang.org/doc/man/gen_server.html#Module:code_change-3
|
|
||||||
|
|
||||||
code_change(_, State, _) ->
|
|
||||||
{ok, State}.
|
|
||||||
|
|
||||||
|
|
||||||
-spec terminate(Reason, State) -> no_return()
|
|
||||||
when Reason :: normal
|
|
||||||
| shutdown
|
|
||||||
| {shutdown, term()}
|
|
||||||
| term(),
|
|
||||||
State :: state().
|
|
||||||
%% @private
|
|
||||||
%% The gen_server:terminate/2 callback.
|
|
||||||
%% See: http://erlang.org/doc/man/gen_server.html#Module:terminate-2
|
|
||||||
|
|
||||||
terminate(_, _) ->
|
|
||||||
ok.
|
|
||||||
|
|
||||||
|
|
||||||
%%% internals
|
|
||||||
|
|
||||||
-spec do_join(Pid, Nick, State) -> {Reply, NewState}
|
|
||||||
when Pid :: pid(),
|
|
||||||
Nick :: string(),
|
|
||||||
Reply :: ok | {error, Reason :: any()},
|
|
||||||
NewState :: State.
|
|
||||||
|
|
||||||
do_join(Pid, Nick, State = #s{orators = Orators}) ->
|
|
||||||
case ensure_can_join(Pid, Nick, Orators) of
|
|
||||||
ok -> do_join2(Pid, Nick, State);
|
|
||||||
Error -> {Error, State}
|
|
||||||
end.
|
|
||||||
|
|
||||||
|
|
||||||
do_join2(Pid, Nick, State = #s{orators = Orators}) ->
|
|
||||||
_Monitor = erlang:monitor(process, Pid),
|
|
||||||
NewOrator = #o{pid = Pid, nick = Nick},
|
|
||||||
NewOrators = [NewOrator | Orators],
|
|
||||||
NewState = State#s{orators = NewOrators},
|
|
||||||
{ok, NewState}.
|
|
||||||
|
|
||||||
|
|
||||||
-spec ensure_can_join(Pid, Nick, Orators) -> Result
|
|
||||||
when Pid :: pid(),
|
|
||||||
Nick :: string(),
|
|
||||||
Orators :: [orator()],
|
|
||||||
Result :: ok
|
|
||||||
| {error, Reason},
|
|
||||||
Reason :: any().
|
|
||||||
% @private
|
|
||||||
% ensures both Pid and Nick are unique
|
|
||||||
|
|
||||||
ensure_can_join(Pid, _ , [#o{pid = Pid} | _ ]) -> {error, already_joined};
|
|
||||||
ensure_can_join(_ , Nick, [#o{nick = Nick} | _ ]) -> {error, {nick_taken, Nick}};
|
|
||||||
ensure_can_join(Pid, Nick, [_ | Rest]) -> ensure_can_join(Pid, Nick, Rest);
|
|
||||||
ensure_can_join(_ , _ , [] ) -> ok.
|
|
||||||
|
|
||||||
|
|
||||||
-spec is_nick_available(Nick, Orators) -> boolean()
|
|
||||||
when Nick :: string(),
|
|
||||||
Orators :: [orator()].
|
|
||||||
|
|
||||||
is_nick_available(Nick, [#o{nick = Nick} | _ ]) -> false;
|
|
||||||
is_nick_available(Nick, [_ | Rest]) -> is_nick_available(Nick, Rest);
|
|
||||||
is_nick_available(_ , [] ) -> true.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-spec handle_down(Msg, State) -> NewState
|
|
||||||
when Msg :: {'DOWN', Mon, process, Pid, Reason},
|
|
||||||
Mon :: erlang:monitor(),
|
|
||||||
Pid :: pid(),
|
|
||||||
Reason :: any(),
|
|
||||||
State :: state(),
|
|
||||||
NewState :: State.
|
|
||||||
|
|
||||||
handle_down(Msg = {'DOWN', _, process, Pid, _}, State = #s{orators = Orators}) ->
|
|
||||||
NewOrators = hdn(Msg, Pid, Orators, []),
|
|
||||||
NewState = State#s{orators = NewOrators},
|
|
||||||
NewState.
|
|
||||||
|
|
||||||
% encountered item, removing
|
|
||||||
hdn(_, Pid, [#o{pid = Pid} | Rest], Acc) -> Rest ++ Acc;
|
|
||||||
hdn(Msg, Pid, [Skip | Rest], Acc) -> hdn(Msg, Pid, Rest, [Skip | Acc]);
|
|
||||||
hdn(Msg, _, [] , Acc) ->
|
|
||||||
log("~tp: Unexpected message: ~tp", [?MODULE, Msg]),
|
|
||||||
Acc.
|
|
||||||
|
|
||||||
|
|
||||||
do_relay(Pid, Message, Orators) ->
|
|
||||||
case lists:keyfind(Pid, #o.pid, Orators) of
|
|
||||||
#o{nick = Nick} ->
|
|
||||||
do_relay2(Nick, Message, Orators);
|
|
||||||
false ->
|
|
||||||
tell("~tp: Message received from outsider ~tp: ~tp", [?MODULE, Pid, Message]),
|
|
||||||
error
|
|
||||||
end.
|
|
||||||
|
|
||||||
% skip
|
|
||||||
do_relay2(Nick, Msg, [#o{nick = Nick} | Rest]) ->
|
|
||||||
do_relay2(Nick, Msg, Rest);
|
|
||||||
do_relay2(Nick, Msg, [#o{pid = Pid} | Rest]) ->
|
|
||||||
Pid ! {chat, {relay, Nick, Msg}},
|
|
||||||
do_relay2(Nick, Msg, Rest);
|
|
||||||
do_relay2(_, _, []) ->
|
|
||||||
ok.
|
|
||||||
@ -226,7 +226,6 @@ route(Sock, get, Route, Request) ->
|
|||||||
case Route of
|
case Route of
|
||||||
<<"/">> -> home(Sock);
|
<<"/">> -> home(Sock);
|
||||||
<<"/default.css">> -> default_css(Sock);
|
<<"/default.css">> -> default_css(Sock);
|
||||||
<<"/chat.html">> -> chat_html(Sock);
|
|
||||||
<<"/ws-test-echo.html">> -> ws_test_echo_html(Sock);
|
<<"/ws-test-echo.html">> -> ws_test_echo_html(Sock);
|
||||||
<<"/ws/echo">> -> ws_echo(Sock, Request);
|
<<"/ws/echo">> -> ws_echo(Sock, Request);
|
||||||
_ -> http_err(Sock, 404)
|
_ -> http_err(Sock, 404)
|
||||||
@ -319,19 +318,6 @@ ws_test_echo_html(Sock) ->
|
|||||||
http_err(Sock, 500)
|
http_err(Sock, 500)
|
||||||
end.
|
end.
|
||||||
|
|
||||||
chat_html(Sock) ->
|
|
||||||
%% fixme: cache
|
|
||||||
Path_IH = filename:join([zx:get_home(), "priv", "chat.html"]),
|
|
||||||
case file:read_file(Path_IH) of
|
|
||||||
{ok, Body} ->
|
|
||||||
Resp = #response{headers = [{"content-type", "text/html"}],
|
|
||||||
body = Body},
|
|
||||||
respond(Sock, Resp);
|
|
||||||
Error ->
|
|
||||||
io:format("~p error: ~p~n", [self(), Error]),
|
|
||||||
http_err(Sock, 500)
|
|
||||||
end.
|
|
||||||
|
|
||||||
wfcin(Sock, #request{enctype = json,
|
wfcin(Sock, #request{enctype = json,
|
||||||
cookies = Cookies,
|
cookies = Cookies,
|
||||||
body = #{"wfcin" := Input}}) ->
|
body = #{"wfcin" := Input}}) ->
|
||||||
|
|||||||
@ -1,125 +0,0 @@
|
|||||||
% @doc static file cache
|
|
||||||
-module(fd_static_cache).
|
|
||||||
|
|
||||||
-behavior(gen_server).
|
|
||||||
|
|
||||||
-export([
|
|
||||||
start_link/0,
|
|
||||||
query/1, set/2, unset/1,
|
|
||||||
%%---
|
|
||||||
%% everything below here runs in process context
|
|
||||||
%%--
|
|
||||||
%% gen_server callbacks
|
|
||||||
init/1, handle_call/3, handle_cast/2, handle_info/2,
|
|
||||||
code_change/3, terminate/2
|
|
||||||
]).
|
|
||||||
|
|
||||||
-include("$zx_include/zx_logger.hrl").
|
|
||||||
|
|
||||||
-record(f, {http_path :: binary(),
|
|
||||||
fs_path :: file:filename(),
|
|
||||||
last_modified :: file:date_time(),
|
|
||||||
mime_type :: string(),
|
|
||||||
contents :: binary()}).
|
|
||||||
-type context() :: wfc_eval_context:context().
|
|
||||||
|
|
||||||
-record(s,
|
|
||||||
{cookies = #{} :: #{Cookie :: binary() := context()}}).
|
|
||||||
% -type state() :: #s{}.
|
|
||||||
|
|
||||||
|
|
||||||
%%--------------------------------
|
|
||||||
%% api (runs in context of caller)
|
|
||||||
%%--------------------------------
|
|
||||||
|
|
||||||
-spec start_link() -> {ok, pid()} | {error, term()}.
|
|
||||||
start_link() ->
|
|
||||||
gen_server:start_link({local, ?MODULE}, ?MODULE, none, []).
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-spec query(Cookie) -> {ok, Context} | error
|
|
||||||
when Cookie :: binary(),
|
|
||||||
Context :: context().
|
|
||||||
|
|
||||||
query(Cookie) ->
|
|
||||||
gen_server:call(?MODULE, {query, Cookie}).
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-spec set(Cookie, Context) -> ok
|
|
||||||
when Cookie :: binary(),
|
|
||||||
Context :: context().
|
|
||||||
|
|
||||||
set(Cookie, Context) ->
|
|
||||||
gen_server:cast(?MODULE, {set, Cookie, Context}).
|
|
||||||
|
|
||||||
|
|
||||||
-spec unset(Cookie) -> ok
|
|
||||||
when Cookie :: binary().
|
|
||||||
|
|
||||||
unset(Cookie) ->
|
|
||||||
gen_server:cast(?MODULE, {unset, Cookie}).
|
|
||||||
|
|
||||||
|
|
||||||
%%----------------------
|
|
||||||
%% gen-server bs
|
|
||||||
%%----------------------
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
init(none) ->
|
|
||||||
log(info, "starting fd_cache"),
|
|
||||||
InitState = #s{},
|
|
||||||
{ok, InitState}.
|
|
||||||
|
|
||||||
|
|
||||||
handle_call({query, Cookie}, _, State) ->
|
|
||||||
Result = do_query(Cookie, State),
|
|
||||||
{reply, Result, State};
|
|
||||||
handle_call(Unexpected, From, State) ->
|
|
||||||
tell("~tp: unexpected call from ~tp: ~tp", [?MODULE, Unexpected, From]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
handle_cast({set, Cookie, Context}, State) ->
|
|
||||||
NewState = do_set(Cookie, Context, State),
|
|
||||||
{noreply, NewState};
|
|
||||||
handle_cast({unset, Cookie}, State) ->
|
|
||||||
NewState = do_unset(Cookie, State),
|
|
||||||
{noreply, NewState};
|
|
||||||
handle_cast(Unexpected, State) ->
|
|
||||||
tell("~tp: unexpected cast: ~tp", [?MODULE, Unexpected]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
handle_info(Unexpected, State) ->
|
|
||||||
tell("~tp: unexpected info: ~tp", [?MODULE, Unexpected]),
|
|
||||||
{noreply, State}.
|
|
||||||
|
|
||||||
|
|
||||||
code_change(_, State, _) ->
|
|
||||||
{ok, State}.
|
|
||||||
|
|
||||||
terminate(_, _) ->
|
|
||||||
ok.
|
|
||||||
|
|
||||||
|
|
||||||
%%---------------------
|
|
||||||
%% doers
|
|
||||||
%%---------------------
|
|
||||||
|
|
||||||
do_set(Cookie, Context, State = #s{cookies = Cookies}) ->
|
|
||||||
NewCookies = maps:put(Cookie, Context, Cookies),
|
|
||||||
NewState = State#s{cookies = NewCookies},
|
|
||||||
NewState.
|
|
||||||
|
|
||||||
|
|
||||||
do_unset(Cookie, State = #s{cookies = Cookies}) ->
|
|
||||||
NewCookies = maps:remove(Cookie, Cookies),
|
|
||||||
NewState = State#s{cookies = NewCookies},
|
|
||||||
NewState.
|
|
||||||
|
|
||||||
|
|
||||||
do_query(Cookie, _State = #s{cookies = Cookies}) ->
|
|
||||||
maps:find(Cookie, Cookies).
|
|
||||||
@ -42,17 +42,11 @@ init([]) ->
|
|||||||
5000,
|
5000,
|
||||||
supervisor,
|
supervisor,
|
||||||
[fd_clients]},
|
[fd_clients]},
|
||||||
Chat = {fd_chat,
|
|
||||||
{fd_chat, start_link, []},
|
|
||||||
permanent,
|
|
||||||
5000,
|
|
||||||
worker,
|
|
||||||
[fd_chat]},
|
|
||||||
Cache = {fd_cache,
|
Cache = {fd_cache,
|
||||||
{fd_cache, start_link, []},
|
{fd_cache, start_link, []},
|
||||||
permanent,
|
permanent,
|
||||||
5000,
|
5000,
|
||||||
worker,
|
worker,
|
||||||
[fd_cache]},
|
[fd_cache]},
|
||||||
Children = [Clients, Chat, Cache],
|
Children = [Clients, Cache],
|
||||||
{ok, {RestartStrategy, Children}}.
|
{ok, {RestartStrategy, Children}}.
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user