Skip to content

Commit d4d0409

Browse files
authored
Merge pull request #4 from Alusus/web_sockets
Added support for web sockets
2 parents 71832ae + ce5457c commit d4d0409

14 files changed

Lines changed: 2370 additions & 5 deletions

COPYING

Lines changed: 674 additions & 0 deletions
Large diffs are not rendered by default.

COPYING.LESSER

Lines changed: 165 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,165 @@
1+
GNU LESSER GENERAL PUBLIC LICENSE
2+
Version 3, 29 June 2007
3+
4+
Copyright (C) 2007 Free Software Foundation, Inc. <https://fsf.org/>
5+
Everyone is permitted to copy and distribute verbatim copies
6+
of this license document, but changing it is not allowed.
7+
8+
9+
This version of the GNU Lesser General Public License incorporates
10+
the terms and conditions of version 3 of the GNU General Public
11+
License, supplemented by the additional permissions listed below.
12+
13+
0. Additional Definitions.
14+
15+
As used herein, "this License" refers to version 3 of the GNU Lesser
16+
General Public License, and the "GNU GPL" refers to version 3 of the GNU
17+
General Public License.
18+
19+
"The Library" refers to a covered work governed by this License,
20+
other than an Application or a Combined Work as defined below.
21+
22+
An "Application" is any work that makes use of an interface provided
23+
by the Library, but which is not otherwise based on the Library.
24+
Defining a subclass of a class defined by the Library is deemed a mode
25+
of using an interface provided by the Library.
26+
27+
A "Combined Work" is a work produced by combining or linking an
28+
Application with the Library. The particular version of the Library
29+
with which the Combined Work was made is also called the "Linked
30+
Version".
31+
32+
The "Minimal Corresponding Source" for a Combined Work means the
33+
Corresponding Source for the Combined Work, excluding any source code
34+
for portions of the Combined Work that, considered in isolation, are
35+
based on the Application, and not on the Linked Version.
36+
37+
The "Corresponding Application Code" for a Combined Work means the
38+
object code and/or source code for the Application, including any data
39+
and utility programs needed for reproducing the Combined Work from the
40+
Application, but excluding the System Libraries of the Combined Work.
41+
42+
1. Exception to Section 3 of the GNU GPL.
43+
44+
You may convey a covered work under sections 3 and 4 of this License
45+
without being bound by section 3 of the GNU GPL.
46+
47+
2. Conveying Modified Versions.
48+
49+
If you modify a copy of the Library, and, in your modifications, a
50+
facility refers to a function or data to be supplied by an Application
51+
that uses the facility (other than as an argument passed when the
52+
facility is invoked), then you may convey a copy of the modified
53+
version:
54+
55+
a) under this License, provided that you make a good faith effort to
56+
ensure that, in the event an Application does not supply the
57+
function or data, the facility still operates, and performs
58+
whatever part of its purpose remains meaningful, or
59+
60+
b) under the GNU GPL, with none of the additional permissions of
61+
this License applicable to that copy.
62+
63+
3. Object Code Incorporating Material from Library Header Files.
64+
65+
The object code form of an Application may incorporate material from
66+
a header file that is part of the Library. You may convey such object
67+
code under terms of your choice, provided that, if the incorporated
68+
material is not limited to numerical parameters, data structure
69+
layouts and accessors, or small macros, inline functions and templates
70+
(ten or fewer lines in length), you do both of the following:
71+
72+
a) Give prominent notice with each copy of the object code that the
73+
Library is used in it and that the Library and its use are
74+
covered by this License.
75+
76+
b) Accompany the object code with a copy of the GNU GPL and this license
77+
document.
78+
79+
4. Combined Works.
80+
81+
You may convey a Combined Work under terms of your choice that,
82+
taken together, effectively do not restrict modification of the
83+
portions of the Library contained in the Combined Work and reverse
84+
engineering for debugging such modifications, if you also do each of
85+
the following:
86+
87+
a) Give prominent notice with each copy of the Combined Work that
88+
the Library is used in it and that the Library and its use are
89+
covered by this License.
90+
91+
b) Accompany the Combined Work with a copy of the GNU GPL and this license
92+
document.
93+
94+
c) For a Combined Work that displays copyright notices during
95+
execution, include the copyright notice for the Library among
96+
these notices, as well as a reference directing the user to the
97+
copies of the GNU GPL and this license document.
98+
99+
d) Do one of the following:
100+
101+
0) Convey the Minimal Corresponding Source under the terms of this
102+
License, and the Corresponding Application Code in a form
103+
suitable for, and under terms that permit, the user to
104+
recombine or relink the Application with a modified version of
105+
the Linked Version to produce a modified Combined Work, in the
106+
manner specified by section 6 of the GNU GPL for conveying
107+
Corresponding Source.
108+
109+
1) Use a suitable shared library mechanism for linking with the
110+
Library. A suitable mechanism is one that (a) uses at run time
111+
a copy of the Library already present on the user's computer
112+
system, and (b) will operate properly with a modified version
113+
of the Library that is interface-compatible with the Linked
114+
Version.
115+
116+
e) Provide Installation Information, but only if you would otherwise
117+
be required to provide such information under section 6 of the
118+
GNU GPL, and only to the extent that such information is
119+
necessary to install and execute a modified version of the
120+
Combined Work produced by recombining or relinking the
121+
Application with a modified version of the Linked Version. (If
122+
you use option 4d0, the Installation Information must accompany
123+
the Minimal Corresponding Source and Corresponding Application
124+
Code. If you use option 4d1, you must provide the Installation
125+
Information in the manner specified by section 6 of the GNU GPL
126+
for conveying Corresponding Source.)
127+
128+
5. Combined Libraries.
129+
130+
You may place library facilities that are a work based on the
131+
Library side by side in a single library together with other library
132+
facilities that are not Applications and are not covered by this
133+
License, and convey such a combined library under terms of your
134+
choice, if you do both of the following:
135+
136+
a) Accompany the combined library with a copy of the same work based
137+
on the Library, uncombined with any other library facilities,
138+
conveyed under the terms of this License.
139+
140+
b) Give prominent notice with the combined library that part of it
141+
is a work based on the Library, and explaining where to find the
142+
accompanying uncombined form of the same work.
143+
144+
6. Revised Versions of the GNU Lesser General Public License.
145+
146+
The Free Software Foundation may publish revised and/or new versions
147+
of the GNU Lesser General Public License from time to time. Such new
148+
versions will be similar in spirit to the present version, but may
149+
differ in detail to address new problems or concerns.
150+
151+
Each version is given a distinguishing version number. If the
152+
Library as you received it specifies that a certain numbered version
153+
of the GNU Lesser General Public License "or any later version"
154+
applies to it, you have the option of following the terms and
155+
conditions either of that published version or of any later version
156+
published by the Free Software Foundation. If the Library as you
157+
received it does not specify a version number of the GNU Lesser
158+
General Public License, you may choose any version of the GNU Lesser
159+
General Public License ever published by the Free Software Foundation.
160+
161+
If the Library as you received it specifies that a proxy can decide
162+
whether future versions of the GNU Lesser General Public License shall
163+
apply, that proxy's public statement of acceptance of any version is
164+
permanent authorization for you to choose that version for the
165+
Library.

Examples/simple_chat_room.alusus

Lines changed: 140 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,140 @@
1+
/*
2+
* Simple web socket based chat example
3+
*
4+
* Copyright (C) 2026 Sarmad Abdullah
5+
*
6+
* This library is free software; you can redistribute it and/or
7+
* modify it under the terms of the GNU Lesser General Public
8+
* License as published by the Free Software Foundation; either
9+
* version 3 of the License, or (at your option) any later version.
10+
*
11+
* This library is distributed in the hope that it will be useful,
12+
* but WITHOUT ANY WARRANTY; without even the implied warranty of
13+
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14+
* Lesser General Public License for more details.
15+
*
16+
* You should have received a copy of the GNU Lesser General Public
17+
* License along with this library; if not, see <https://www.gnu.org/licenses/>.
18+
*/
19+
20+
import "Srl/Console.alusus";
21+
import "Srl/String.alusus";
22+
import "Apm.alusus";
23+
Apm.importFile("Alusus/Http");
24+
25+
module WebSocketChat {
26+
use Srl;
27+
28+
class Client {
29+
def conn: ptr[Http.Connection];
30+
}
31+
32+
def clients: array[Client, 32];
33+
def clientCount: Int = 0;
34+
35+
func onWebSocketConnect(conn: ptr[Http.Connection], _: ptr[Void]): Int {
36+
clients(clientCount).conn = conn;
37+
clientCount += 1;
38+
39+
Console.print("Client connected\n");
40+
return 0;
41+
}
42+
43+
func onWebSocketReady(conn: ptr[Http.Connection], _: ptr[Void]): Void {
44+
Http.writeTextToWebSocket(conn, "Connected to chat");
45+
}
46+
47+
func onWebSocketData(
48+
conn: ptr[Http.Connection],
49+
opcode: Int,
50+
data: CharsPtr,
51+
len: ArchWord,
52+
_: ptr[Void]
53+
): Int {
54+
if (opcode & 1) == 0 return 1;
55+
56+
def i: Int = 0;
57+
while i < clientCount and clients(i).conn != conn {
58+
++i;
59+
}
60+
def msg: String = String.format("user %i: %s", i + 1, String(data, len).buf);
61+
for i = 0, i < clientCount, ++i {
62+
Http.writeTextToWebSocket(clients(i).conn, msg);
63+
}
64+
65+
return 1;
66+
}
67+
68+
func onWebSocketClose(conn: ptr[Http.Connection], _: ptr[Void]): Void {
69+
def i: Int = 0;
70+
while i < clientCount {
71+
if clients(i).conn == conn {
72+
def j: Int = i;
73+
while j < clientCount - 1 {
74+
clients(j).conn = clients(j + 1).conn;
75+
++j;
76+
}
77+
78+
--clientCount;
79+
break;
80+
}
81+
i += 1;
82+
}
83+
84+
Console.print("Client disconnected\n");
85+
}
86+
87+
func handleHttpRequest(conn: ptr[Http.Connection]): Int {
88+
def req: ptr[Http.RequestInfo] = Http.getRequestInfo(conn);
89+
90+
if String.isEqual(req~cnt.localUri, "/websocket") return 0;
91+
92+
if String.isEqual(req~cnt.localUri, "/") {
93+
def html: CharsPtr =
94+
"<!DOCTYPE html><html><body>"
95+
"<h2>Broadcast Chat</h2>"
96+
"<input id='msg' placeholder='Message'>"
97+
"<button onclick='send()'>Send</button>"
98+
"<div id='box'></div>"
99+
"<script>"
100+
"const ws=new WebSocket('ws://'+location.host+'/websocket');"
101+
"function send(){"
102+
"ws.send(msg.value);"
103+
"msg.value='';"
104+
"}"
105+
"ws.onmessage=e=>{"
106+
"let d=document.createElement('div');"
107+
"d.textContent=e.data;"
108+
"box.appendChild(d);};"
109+
"</script></body></html>";
110+
111+
Http.print(conn, "HTTP/1.1 200 OK\r\n");
112+
Http.print(conn, "Content-Length: %d\r\n\r\n", String.getLength(html));
113+
Http.print(conn, html);
114+
return 1;
115+
}
116+
117+
return 1;
118+
}
119+
120+
func start() {
121+
def ctx: ptr[Http.Context] = Http.startServer(handleHttpRequest~ptr, {
122+
"listening_ports", "8080"
123+
});
124+
125+
Http.setWebSocketHandler(
126+
ctx,
127+
"/websocket",
128+
onWebSocketConnect~ptr,
129+
onWebSocketReady~ptr,
130+
onWebSocketData~ptr,
131+
onWebSocketClose~ptr
132+
);
133+
134+
Console.print("Server running on 8080\n");
135+
Console.getChar();
136+
Http.stopServer(ctx);
137+
}
138+
}
139+
140+
WebSocketChat.start();

Examples/simple_server.alusus

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,22 @@
1+
/*
2+
* Simple HTTP server example
3+
*
4+
* Copyright (C) 2026 Sarmad Abdullah
5+
*
6+
* This library is free software; you can redistribute it and/or
7+
* modify it under the terms of the GNU Lesser General Public
8+
* License as published by the Free Software Foundation; either
9+
* version 3 of the License, or (at your option) any later version.
10+
*
11+
* This library is distributed in the hope that it will be useful,
12+
* but WITHOUT ANY WARRANTY; without even the implied warranty of
13+
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14+
* Lesser General Public License for more details.
15+
*
16+
* You should have received a copy of the GNU Lesser General Public
17+
* License along with this library; if not, see <https://www.gnu.org/licenses/>.
18+
*/
19+
120
import "Srl/Console.alusus";
221
import "Srl/String.alusus";
322
import "Srl/Memory.alusus";

0 commit comments

Comments
 (0)