Compare commits

...

121 Commits

Author SHA1 Message Date
Simon Ser
caf6e9978b Upgrade @stylistic/eslint-plugin-js to v4 2025-03-20 20:03:05 +01:00
Simon Ser
fbfa123dca Upgrade globals to v16 2025-03-20 20:02:57 +01:00
Simon Ser
cd45ead256 Upgrade dependencies 2025-03-20 19:59:59 +01:00
Simon Ser
fcc80a85e3 Only send PING to registered connections on focus 2025-02-28 17:43:13 +01:00
Simon Ser
76b6931ebb components/buffer: flatten separators when appending to children
Nested "key" attributes in arrays don't work. "key" attributes
need to all be in the same array. (Alternatively, we could've used
a fragment and set a key on that.)
2025-02-24 00:29:11 +01:00
Simon Ser
7d068fd1fe Enable @stylistic/js/comma-spacing lint 2025-02-20 17:58:24 +01:00
Simon Ser
735dd8fd8c Enable @stylistic/js/block-spacing lint 2025-02-20 17:57:08 +01:00
Simon Ser
c461f4903e Enable @stylistic/js/arrow-spacing lint 2025-02-20 17:56:19 +01:00
Simon Ser
f897e7d11b Enable @stylistic/js/array-bracket-spacing lint 2025-02-20 17:51:46 +01:00
Simon Ser
95749ba516 Enable @stylistic/js/array-bracket-newline lint 2025-02-20 17:50:35 +01:00
Simon Ser
39a2bc4a3d Enable @stylistic/js/object-curly-newline lint 2025-02-20 17:47:52 +01:00
Simon Ser
614ed5c895 Enable @stylistic/js/brace-style lint 2025-02-20 17:43:17 +01:00
Simon Ser
8d96f93fb5 Enable @stylistic/js/object-curly-spacing lint 2025-02-20 17:42:19 +01:00
Simon Ser
9922d11654 Upgrade @stylistic/eslint-plugin-js to v3 2025-02-17 00:18:13 +01:00
Simon Ser
57c5f2b1cc Upgrade dependencies 2025-02-17 00:15:12 +01:00
Simon Ser
0cc1c53fa4 ci: switch to alpine/latest 2025-02-10 14:09:51 +01:00
Simon Ser
93d7d22726 ci: upload build as artifact 2025-02-10 14:08:43 +01:00
Calvin Lee
136353b2b5 Sort servers alphanumerically 2025-02-07 22:43:03 +00:00
delthas
7dd21177bc Add support for incoming REDACT
This does not include support for redacting messages, only reading
incoming REDACT messages.

See: https://github.com/ircv3/ircv3-specifications/pull/524
2025-02-07 00:26:02 +00:00
Simon Ser
ca0cfdcc28 readme: fix screenshot 2025-02-05 22:40:54 +01:00
vyneer
1e3903c014
Fix /help not showing any commands 2025-01-28 17:03:17 +03:00
Calvin Lee
5146b0cad8 eslint: add lint enforcing camelCase
snake_case is needed in one place in the codebase to format URL arguments.
Co-authored-by: Calvin Lee <pounce@integraldoma.in>
Co-committed-by: Calvin Lee <pounce@integraldoma.in>
2025-01-27 16:29:58 +00:00
Markus Unterwaditzer
513cf825a5 Add nick-caret class
I'd like to apply a userstyle to this text, and in order to do that I need a CSS class.
Co-authored-by: Markus Unterwaditzer <markus-tarpit+git@unterwaditzer.net>
Co-committed-by: Markus Unterwaditzer <markus-tarpit+git@unterwaditzer.net>
2025-01-27 12:25:26 +00:00
Simon Ser
9fef11564d Upgrade dependencies 2025-01-20 23:16:11 +01:00
Simon Ser
9dda4ee438 eslint: add a few more rules 2025-01-20 23:02:23 +01:00
Simon Ser
9299f79bab Make debug=0 URL param disable debug logs 2025-01-19 21:11:58 +01:00
Simon Ser
e4088304bf Upgrade preact, once again
Seems to not cause regressions like it did last time. Crossing
fingers now.
2025-01-07 17:06:08 +01:00
Simon Ser
6ea3601718 dev-server: print remote server errors 2025-01-05 21:52:15 +01:00
emersion
bcf3741ab4 readme: fix screenshot link 2024-12-20 21:37:04 +00:00
Simon Ser
ec5e67336f components/buffer: handle TOPIC clear messages 2024-12-03 09:19:53 +01:00
Umar Getagazov
4d988c98d0 Fix tag name typo in the Timestamp component 2024-11-28 12:37:51 +00:00
Simon Ser
62895d59ff Upgrade dependencies 2024-11-23 21:02:08 +01:00
Simon Ser
2f1bf8a2fe lib/client: don't mutate input argument in fetchHistoryBetween() 2024-11-16 12:45:08 +01:00
Simon Ser
75eb175e24 eslint: enable object-shorthand 2024-11-16 12:28:17 +01:00
Simon Ser
db0a69dcfd commands: use Map instead of object 2024-11-16 12:27:34 +01:00
Simon Ser
9c2beac7dd eslint: enable no-implicit-coercion 2024-11-16 12:18:17 +01:00
Simon Ser
8ff1cd8317 eslint: add no-invalid-this and prefer-arrow-callback 2024-11-15 02:19:28 +01:00
Simon Ser
f6e8f83d4e components/app: simplify connectParams object field 2024-11-15 02:19:28 +01:00
Simon Ser
18fa0ebc6a readme: switch from --production to --omit=dev
The former is deprecated.
2024-11-13 01:18:58 +01:00
Simon Ser
afa09cfc25 lib/client: fix typo
That one turned out to be surprisingly tricky to dig out.
2024-11-12 23:11:10 +01:00
Simon Ser
977752e0f2 lib/client: bind handleOnline to this
It's used as a callback to removeEventListener().
2024-11-12 23:10:38 +01:00
Simon Ser
4bce52f162 ci: temporarily switch to alpine/edge
It has a more up-to-date nodejs version which doesn't deadlock in
"npm install".
2024-11-12 23:10:34 +01:00
Simon Ser
75ec7cd212 lib/client: don't throttle reconnections if opened long ago
If a connection was opened a long time ago, and recently got broken,
try to reconnect immediately.
2024-11-12 23:10:30 +01:00
Simon Ser
24e6767cab client: reconnect immediately if network comes online during backoff 2024-11-12 23:10:22 +01:00
Simon Ser
ad165389f0 Fix nick colors in members list
Closes: https://todo.sr.ht/~emersion/gamja/164
2024-11-10 21:04:28 +01:00
Simon Ser
daef362931 Upgrade dependencies 2024-10-23 20:31:08 +02:00
Calvin Lee
3ba0bfe3e6 change sorting of channels in the sidebar 2024-10-23 01:54:51 +00:00
Simon Ser
b67cd10c64 Remove usage of == and != 2024-10-14 00:56:36 +02:00
Simon Ser
205a617c51 Move to Codeberg 2024-10-11 15:07:43 +02:00
Simon Ser
4145907d36 ci: use new SSH key for deployments 2024-10-11 00:25:02 +02:00
Simon Ser
c6e63d5724 components/composer: add support for multiple file upload 2024-09-29 15:31:25 +02:00
xse
2f6efb56de components/composer: handle drag and drop file upload 2024-09-29 15:21:56 +02:00
Simon Ser
cf54beacc2 lint: turn on @stylistic/js/arrow-parens 2024-09-29 11:54:21 +02:00
Simon Ser
69485716a0 lint: turn on @stylistic/js/comma-dangle 2024-09-29 11:50:57 +02:00
Simon Ser
b9d12bc8cd lint: turn on @stylistic/js/semi 2024-09-29 11:49:17 +02:00
Simon Ser
b93db7ac0e ci: fail when ESLint reports warnings 2024-09-29 11:45:56 +02:00
Simon Ser
d96e34da79 Wire up stylistic to ESLint 2024-09-29 11:45:42 +02:00
Simon Ser
78bfd16f25 Remove two remaining single quote strings 2024-09-29 11:45:13 +02:00
Simon Ser
07ae5f7167 Disallow var keyword 2024-09-28 22:07:39 +02:00
Simon Ser
312c755c11 eslint: fix global ignore for dist/ 2024-09-28 21:57:35 +02:00
Simon Ser
a03ad28438 Update dependencies 2024-09-28 21:50:03 +02:00
Simon Ser
f389ea6ffd eslint: ignore dist/ directory 2024-09-28 21:49:13 +02:00
Simon Ser
7c445d0bc9 Add ESLint 2024-09-28 21:45:45 +02:00
Simon Ser
97920ff7f6 Prefix unused variables with an underscore 2024-09-28 21:44:23 +02:00
Simon Ser
b89fd604d0 Remove unnecessary break statements 2024-09-28 21:44:03 +02:00
Simon Ser
6693cc0c78 Remove unused variables 2024-09-28 21:43:23 +02:00
Simon Ser
6747c03a75 components/app: add missing break 2024-09-28 21:36:35 +02:00
Simon Ser
35e924258a components/buffer: drop leading asterisk for MODE messages
This is inconsistent with other messages.
2024-09-08 12:50:00 +02:00
Simon Ser
26792ec386 components/buffer: add human-readable channel mode changes
References: https://todo.sr.ht/~emersion/gamja/162
2024-09-08 12:48:07 +02:00
Simon Ser
a3b375ab3f components/membership: fix operator color 2024-09-08 12:47:37 +02:00
Simon Ser
e1a15ceeb9 components/membership: fix missing import 2024-09-07 17:59:01 +02:00
Simon Ser
9e68316467 components/buffer: use case-mapping when displaying MODE messages 2024-09-07 12:45:49 +02:00
Simon Ser
6be24e8ed9 lib/irc: unexport STD_MEMBERSHIPS and STD_CHANTYPES 2024-09-07 12:37:10 +02:00
Simon Ser
301f133272 lib/irc: move over STD_MEMBERSHIP_NAMES 2024-09-07 12:36:13 +02:00
Simon Ser
9bcfd088c2 components/member-list: remove dead code 2024-09-07 12:31:07 +02:00
Simon Ser
39de184734 readme: accept patches on Codeberg 2024-09-03 21:08:13 +02:00
Simon Ser
2c0f2a80e9 lib/irc: remove stray hardcoded constant 2024-08-13 00:29:00 +02:00
Simon Ser
1c5dc652a9 Downgrade preact to v10.17.1 once again
Seeing this again:

    DOMException: Node.insertBefore: Child to insert before is not a child of this node

Ref https://github.com/preactjs/preact/issues/4221
2024-07-12 09:07:02 +02:00
Simon Ser
b06ebc0267 Upgrade dependencies 2024-07-08 14:43:18 +02:00
Simon Ser
f657a81824 components/buffer-list: fix text color when active and unread
Previously this couldn't happen, but now we don't mark the active
buffer as read when the window doesn't have focus.
2024-07-08 08:33:24 +02:00
Simon Ser
c69869209f components/scroll-manager: relax scroll check
See https://developer.mozilla.org/en-US/docs/Web/API/Element/scrollHeight#determine_if_an_element_has_been_totally_scrolled
2024-07-02 09:00:30 +02:00
Simon Ser
331a2f0c4e components/scroll-manager: use getSnapshotBeforeUpdate
componentWillReceiveProps is deprecated.
2024-07-02 08:59:43 +02:00
Simon Ser
6c324d44a1 lib/client: add support for AUTHENTICATE chunking
SASL responses need to be split into 400 byte chunks before being
sent to the server.
2024-06-30 23:44:14 +02:00
Simon Ser
d9f7faad88 components/app: warn when username is missing for OAuth introspection
Makes things easier to debug.
2024-06-25 17:54:48 +02:00
Simon Ser
f698d7a250 doc/url-params: document wildcard in nick param 2024-05-09 22:56:58 +02:00
Simon Ser
0f273b9699 components/app: fix STATUSMSG NOTICE when target buffer is closed 2024-04-30 11:22:22 +02:00
Simon Ser
3d03c0dbcf components/app: update prevReadReceipt only when switching buffer
We don't want the unread separator to move around when the tab gets
focus, for instance.
2024-04-25 19:32:10 +02:00
sitting33
0b7726819d Show number of highlights in window title
Co-authored-by: Simon Ser <contact@emersion.fr>
Closes: https://todo.sr.ht/~emersion/gamja/134
2024-04-25 16:49:19 +02:00
Simon Ser
8faff95631 components/app: include bouncer network name in window title
Co-authored-by: sitting33 <me@sit.sh>
2024-04-25 16:34:05 +02:00
Simon Ser
4d6f14ab0b components/app: introduce updateDocumentTitle()
The logic in here will get more involved once we add unread counts
and such.
2024-04-25 16:23:23 +02:00
sitting33
9924f08794 Don't mark messages as read when window is not in focus 2024-04-25 16:07:41 +02:00
sitting33
f79b6bfaa1 components/app: split switchBuffer() and markBufferAsRead()
We'll want to mark as read independently in response to focus events.
2024-04-25 15:59:47 +02:00
Simon Ser
269e034581 Hide replies to our own internal WHO commands
References: https://todo.sr.ht/~emersion/gamja/88
2024-04-17 23:45:44 +02:00
Simon Ser
1ea7c30744 lib/client: fix number of field check in RPL_WHOSPCRPL
The first field is the client.
2024-04-17 23:29:54 +02:00
Simon Ser
87e88cccca Add support for soju.im/filehost
For now, only handle paste events containing files.

Co-authored-by: Alex McGrath <amk@amk.ie>
2024-04-16 13:22:24 +02:00
Simon Ser
97b9efcc9f Upgrade dependencies 2024-04-10 14:24:34 +02:00
Simon Ser
7ec9ae7faa Upgrade preact to v10.20.2 2024-04-09 20:45:22 +02:00
Simon Ser
ebcb731e2f components/buffer: fold NICK change chains 2024-03-29 16:08:04 +01:00
Simon Ser
23ceda5523 Revert "Upgrade preact to v10.20.0"
This reverts commit e843fe3ecb8b875a15ed2f14da6a7d347abcafff.

Unfortunately the fix doesn't seem to work for us…
2024-03-20 12:07:43 +01:00
Simon Ser
e843fe3ecb Upgrade preact to v10.20.0
The upstream preact bug [1] has been fixed now!

[1]: https://github.com/preactjs/preact/issues/4221
2024-03-20 10:44:11 +01:00
Simon Ser
5171e0010d doc/setup: use plaintext HTTP listener for soju 2024-03-19 14:27:44 +01:00
Ángel Castañeda
5db432b57a docs/setup: proxy pass host header to websocket server 2024-03-19 14:26:57 +01:00
Simon Ser
3584c1eb10 lib/irc: fix whitespace RegExp test in isURIPrefix 2024-03-13 15:41:04 +01:00
Martijn Braam
c1c7c91c38 Prevent zalgo in IRC messages
the overflow: auto; rule is enough to prevent zalgo from drawing over
other IRC messages containing it to a single line.
2024-03-12 09:29:37 +01:00
Simon Ser
2fe2ce6912 lib/irc: fix assignment to undefined variable in isURIPrefix 2024-03-07 23:04:40 +01:00
Simon Ser
57f7b1c011 lib/irc: fix whitespace split in isURIPrefix
We want to get the last index of whitespace, not the first one.
2024-03-07 11:40:37 +01:00
Simon Ser
5d3738bc40 lib/irc: ignore highlights in URLs 2024-03-02 12:36:30 +01:00
Simon Ser
429b4595e7 lib/client: print raw messages in debug mode
Browser consoles aren't super helpful in general and just show
the command name, require extra clicks to see the params.
2024-03-01 15:03:09 +01:00
Simon Ser
038cc68ee4 components/buffer-list: show realname as tooltip 2024-02-20 22:50:09 +01:00
Simon Ser
15cc546876 components/buffer: show realname as tooltip 2024-02-20 22:48:03 +01:00
Simon Ser
a514104c55 commands: drop unvoice
We have devoice already, and that's the one defined in popular
clients such as WeeChat.
2024-02-15 16:40:41 +01:00
Simon Ser
7e5e94cda0 components/help: always show autocomplete keybind 2024-02-15 16:37:32 +01:00
Simon Ser
75d721c02d components/help: add autocomplete 2024-02-15 16:34:16 +01:00
Simon Ser
141fc3e07c Pin preact to v10.17.1
We can't upgrade due to this bug:
https://github.com/preactjs/preact/issues/4221
2024-01-10 20:30:29 +01:00
Simon Ser
b38777e92a lib/linkify: add geo URI scheme 2024-01-10 11:38:23 +01:00
Simon Ser
0640ff8712 Upgrade linkifyjs to v4 2024-01-10 11:33:20 +01:00
Simon Ser
67b2b07506 Upgrade dependencies
Leave preact and linkifyjs alone because they cause breakage.
2024-01-10 10:50:30 +01:00
Simon Ser
15e451f7f8 doc/config-file: indicate where errors are logged 2024-01-07 22:16:56 +01:00
Simon Ser
617a3a7485 Downgrade preact to 10.17.1
References: https://github.com/preactjs/preact/issues/4221
2023-11-29 17:46:16 +01:00
Simon Ser
4f828db244 Downgrade preact to 10.18.2
References: https://github.com/preactjs/preact/issues/4221
2023-11-28 15:13:02 +01:00
Simon Ser
bc19829673 Upgrade dependencies 2023-11-26 18:22:32 +01:00
37 changed files with 3218 additions and 1735 deletions

View File

@ -3,17 +3,25 @@ packages:
- npm
- rsync
sources:
- https://git.sr.ht/~emersion/gamja
- https://codeberg.org/emersion/gamja.git
secrets:
- 77c7956b-003e-44f7-bb5c-2944b2047654 # deploy SSH key
- 7a146c8e-aeb4-46e7-99bf-05af7486bbe9 # deploy SSH key
artifacts:
- gamja/gamja.tar.gz
tasks:
- setup: |
cd gamja
npm install --include=dev
- build: |
cd gamja
npm run build
tar -czf gamja.tar.gz -C dist .
- lint: |
cd gamja
npm run -- lint --max-warnings 0
- deploy: |
cd gamja/dist
[ "$(git rev-parse HEAD)" = "$(git rev-parse origin/master)" ] || complete-build
rsync --rsh="ssh -o StrictHostKeyChecking=no" -rP \
--delete --exclude=config.json \
. deploy@sheeta.emersion.fr:/srv/http/gamja
. deploy-gamja@sheeta.emersion.fr:/srv/http/gamja

View File

@ -2,7 +2,7 @@
A simple IRC web client.
![screenshot](https://l.sr.ht/7Npm.png)
<img src="https://fs.emersion.fr/protected/img/gamja/main.png" alt="Screenshot" width="800">
## Usage
@ -10,7 +10,7 @@ Requires an IRC WebSocket server.
First install dependencies:
npm install --production
npm install --omit=dev
Then [configure an HTTP server] to serve the gamja files.
@ -37,7 +37,7 @@ gamja can be configured via a [configuration file] and via [URL parameters].
## Contributing
Send patches on the [mailing list], report bugs on the [issue tracker]. Discuss
Send patches on [Codeberg], report bugs on the [issue tracker]. Discuss
in [#soju on Libera Chat].
## License
@ -46,8 +46,8 @@ AGPLv3, see LICENSE.
Copyright (C) 2020 The gamja Contributors
[gamja]: https://sr.ht/~emersion/gamja/
[mailing list]: https://lists.sr.ht/~emersion/public-inbox
[gamja]: https://codeberg.org/emersion/gamja
[Codeberg]: https://codeberg.org/emersion/gamja
[issue tracker]: https://todo.sr.ht/~emersion/gamja
[Parcel]: https://parceljs.org
[configure an HTTP server]: doc/setup.md

View File

@ -53,6 +53,7 @@ function markServerBufferUnread(app) {
}
const join = {
name: "join",
usage: "<name> [password]",
description: "Join a channel",
execute: (app, args) => {
@ -69,6 +70,7 @@ const join = {
};
const kick = {
name: "kick",
usage: "<nick> [comment]",
description: "Remove a user from the channel",
execute: (app, args) => {
@ -83,10 +85,11 @@ const kick = {
};
const ban = {
name: "ban",
usage: "[nick]",
description: "Ban a user from the channel, or display the current ban list",
execute: (app, args) => {
if (args.length == 0) {
if (args.length === 0) {
let activeChannel = getActiveChannel(app);
getActiveClient(app).send({
command: "MODE",
@ -111,20 +114,22 @@ function givemode(app, args, mode) {
});
}
export default {
"away": {
const commands = [
{
name: "away",
usage: "[message]",
description: "Set away message",
execute: (app, args) => {
const params = []
const params = [];
if (args.length) {
params.push(args.join(" "));
}
getActiveClient(app).send({ command: "AWAY", params });
},
},
"ban": ban,
"buffer": {
ban,
{
name: "buffer",
usage: "<name>",
description: "Switch to a buffer",
execute: (app, args) => {
@ -138,39 +143,45 @@ export default {
throw new Error("Unknown buffer");
},
},
"close": {
{
name: "close",
description: "Close the current buffer",
execute: (app, args) => {
let activeBuffer = app.state.buffers.get(app.state.activeBuffer);
if (!activeBuffer || activeBuffer.type == BufferType.SERVER) {
if (!activeBuffer || activeBuffer.type === BufferType.SERVER) {
throw new Error("Not in a user or channel buffer");
}
app.close(activeBuffer.id);
},
},
"deop": {
{
name: "deop",
usage: "<nick>",
description: "Remove operator status for a user on this channel",
execute: (app, args) => givemode(app, args, "-o"),
},
"devoice": {
{
name: "devoice",
usage: "<nick>",
description: "Remove voiced status for a user on this channel",
execute: (app, args) => givemode(app, args, "-v"),
},
"disconnect": {
{
name: "disconnect",
description: "Disconnect from the server",
execute: (app, args) => {
app.disconnect();
},
},
"help": {
{
name: "help",
description: "Show help menu",
execute: (app, args) => {
app.openHelp();
},
},
"invite": {
{
name: "invite",
usage: "<nick>",
description: "Invite a user to the channel",
execute: (app, args) => {
@ -179,15 +190,17 @@ export default {
throw new Error("Missing nick");
}
let activeChannel = getActiveChannel(app);
getActiveClient(app).send({ command: "INVITE", params: [
nick, activeChannel,
]});
getActiveClient(app).send({
command: "INVITE",
params: [nick, activeChannel],
});
},
},
"j": join,
"join": join,
"kick": kick,
"kickban": {
{ ...join, name: "j" },
join,
kick,
{
name: "kickban",
usage: "<target>",
description: "Ban a user and removes them from the channel",
execute: (app, args) => {
@ -195,7 +208,8 @@ export default {
ban.execute(app, args);
},
},
"lusers": {
{
name: "lusers",
usage: "[<mask> [<target>]]",
description: "Request user statistics about the network",
execute: (app, args) => {
@ -203,7 +217,8 @@ export default {
markServerBufferUnread(app);
},
},
"me": {
{
name: "me",
usage: "<action>",
description: "Send an action message to the current buffer",
execute: (app, args) => {
@ -213,7 +228,8 @@ export default {
app.privmsg(target, text);
},
},
"mode": {
{
name: "mode",
usage: "[target] [modes] [mode args...]",
description: "Query or change a channel or user mode",
execute: (app, args) => {
@ -225,7 +241,8 @@ export default {
getActiveClient(app).send({ command: "MODE", params: args });
},
},
"motd": {
{
name: "motd",
usage: "[server]",
description: "Get the Message Of The Day",
execute: (app, args) => {
@ -233,7 +250,8 @@ export default {
markServerBufferUnread(app);
},
},
"msg": {
{
name: "msg",
usage: "<target> <message>",
description: "Send a message to a nickname or a channel",
execute: (app, args) => {
@ -242,7 +260,8 @@ export default {
getActiveClient(app).send({ command: "PRIVMSG", params: [target, text] });
},
},
"nick": {
{
name: "nick",
usage: "<nick>",
description: "Change current nickname",
execute: (app, args) => {
@ -250,7 +269,8 @@ export default {
getActiveClient(app).send({ command: "NICK", params: [newNick] });
},
},
"notice": {
{
name: "notice",
usage: "<target> <message>",
description: "Send a notice to a nickname or a channel",
execute: (app, args) => {
@ -259,12 +279,14 @@ export default {
getActiveClient(app).send({ command: "NOTICE", params: [target, text] });
},
},
"op": {
{
name: "op",
usage: "<nick>",
description: "Give a user operator status on this channel",
execute: (app, args) => givemode(app, args, "+o"),
},
"part": {
{
name: "part",
usage: "[reason]",
description: "Leave a channel",
execute: (app, args) => {
@ -277,7 +299,8 @@ export default {
getActiveClient(app).send({ command: "PART", params });
},
},
"query": {
{
name: "query",
usage: "<nick> [message]",
description: "Open a buffer to send messages to a nickname",
execute: (app, args) => {
@ -293,11 +316,12 @@ export default {
}
},
},
"quiet": {
{
name: "quiet",
usage: "[nick]",
description: "Quiet a user in the channel, or display the current quiet list",
execute: (app, args) => {
if (args.length == 0) {
if (args.length === 0) {
getActiveClient(app).send({
command: "MODE",
params: [getActiveChannel(app), "+q"],
@ -307,13 +331,15 @@ export default {
}
},
},
"quit": {
{
name: "quit",
description: "Quit",
execute: (app, args) => {
app.close({ name: SERVER_BUFFER });
},
},
"quote": {
{
name: "quote",
usage: "<command>",
description: "Send a raw IRC command to the server",
execute: (app, args) => {
@ -326,13 +352,15 @@ export default {
getActiveClient(app).send(msg);
},
},
"reconnect": {
{
name: "reconnect",
description: "Reconnect to the server",
execute: (app, args) => {
app.reconnect();
},
},
"setname": {
{
name: "setname",
usage: "<realname>",
description: "Change current realname",
execute: (app, args) => {
@ -345,7 +373,8 @@ export default {
// TODO: save to local storage
},
},
"stats": {
{
name: "stats",
usage: "<query> [server]",
description: "Request server statistics",
execute: (app, args) => {
@ -361,7 +390,8 @@ export default {
markServerBufferUnread(app);
},
},
"topic": {
{
name: "topic",
usage: "<topic>",
description: "Change the topic of the current channel",
execute: (app, args) => {
@ -373,31 +403,30 @@ export default {
getActiveClient(app).send({ command: "TOPIC", params });
},
},
"unban": {
{
name: "unban",
usage: "<nick>",
description: "Remove a user from the ban list",
execute: (app, args) => {
return setUserHostMode(app, args, "-b");
},
},
"unquiet": {
{
name: "unquiet",
usage: "<nick>",
description: "Remove a user from the quiet list",
execute: (app, args) => {
return setUserHostMode(app, args, "-q");
},
},
"unvoice": {
usage: "<nick>",
description: "Remove a user from the voiced list",
execute: (app, args) => givemode(app, args, "-v"),
},
"voice": {
{
name: "voice",
usage: "<nick>",
description: "Give a user voiced status on this channel",
execute: (app, args) => givemode(app, args, "+v"),
},
"who": {
{
name: "who",
usage: "<mask>",
description: "Retrieve a list of users",
execute: (app, args) => {
@ -405,7 +434,8 @@ export default {
markServerBufferUnread(app);
},
},
"whois": {
{
name: "whois",
usage: "<nick>",
description: "Retrieve information about a user",
execute: (app, args) => {
@ -417,7 +447,8 @@ export default {
markServerBufferUnread(app);
},
},
"whowas": {
{
name: "whowas",
usage: "<nick> [count]",
description: "Retrieve information about an offline user",
execute: (app, args) => {
@ -428,7 +459,8 @@ export default {
markServerBufferUnread(app);
},
},
"list": {
{
name: "list",
usage: "[filter]",
description: "Retrieve a list of channels from a network",
execute: (app, args) => {
@ -436,4 +468,6 @@ export default {
markServerBufferUnread(app);
},
},
};
];
export default new Map(commands.map((cmd) => [cmd.name, cmd]));

View File

@ -55,7 +55,7 @@ function isProduction() {
// NODE_ENV is set by the Parcel build system
try {
return process.env.NODE_ENV === "production";
} catch (err) {
} catch (_err) {
return false;
}
}
@ -94,7 +94,7 @@ function splitHostPort(str) {
function fillConnectParams(params) {
let host = window.location.host || "localhost:8080";
let proto = "wss:";
if (window.location.protocol != "https:") {
if (window.location.protocol !== "https:") {
proto = "ws:";
}
let path = window.location.pathname || "/";
@ -323,6 +323,8 @@ export default class App extends Component {
}
if (queryParams.debug === "1") {
this.debug = true;
} else if (queryParams.debug === "0") {
this.debug = false;
}
if (window.location.hash) {
@ -383,7 +385,7 @@ export default class App extends Component {
}
}
this.setState({ loading: false, connectParams: connectParams });
this.setState({ loading: false, connectParams });
if (connectParams.autoconnect) {
this.setState({ connectForm: false });
@ -437,6 +439,9 @@ export default class App extends Component {
clientSecret: this.config.oauth2.client_secret,
});
username = data.username;
if (!username) {
console.warn("Username missing from OAuth 2.0 token introspection response");
}
} catch (err) {
console.warn("Failed to introspect OAuth 2.0 token:", err);
}
@ -493,7 +498,9 @@ export default class App extends Component {
let stored = this.bufferStore.get({ name, server: client.params });
if (client.caps.enabled.has("draft/chathistory") && stored) {
this.setBufferState({ server: serverID, name }, { unread: stored.unread });
this.setBufferState({ server: serverID, name }, { unread: stored.unread }, () => {
this.updateDocumentTitle();
});
}
this.bufferStore.put({
@ -510,7 +517,7 @@ export default class App extends Component {
this.setState((state) => {
let updated;
[id, updated] = State.createBuffer(state, name, serverID, client);
isNew = !!updated;
isNew = Boolean(updated);
return updated;
});
if (isNew) {
@ -541,13 +548,9 @@ export default class App extends Component {
let client = this.clients.get(buf.server);
let stored = this.bufferStore.get({ name: buf.name, server: client.params });
let prevReadReceipt = getReceipt(stored, ReceiptType.READ);
// TODO: only mark as read if user scrolled at the bottom
let update = State.updateBuffer(state, buf.id, {
unread: Unread.NONE,
prevReadReceipt,
});
let update = State.updateBuffer(state, buf.id, { prevReadReceipt });
return { ...update, activeBuffer: buf.id };
return { activeBuffer: buf.id, ...update };
}, () => {
if (!buf) {
return;
@ -557,6 +560,35 @@ export default class App extends Component {
this.buffer.current.focus();
}
let server = this.state.servers.get(buf.server);
if (buf.type === BufferType.NICK && !server.users.has(buf.name)) {
this.whoUserBuffer(buf.name, buf.server);
}
if (buf.type === BufferType.CHANNEL && !buf.hasInitialWho) {
this.whoChannelBuffer(buf.name, buf.server);
}
this.updateDocumentTitle();
});
// TODO: only mark as read if user scrolled at the bottom
this.markBufferAsRead(id);
}
markBufferAsRead(id) {
let buf;
this.setState((state) => {
buf = State.getBuffer(state, id);
if (!buf) {
return;
}
return State.updateBuffer(state, buf.id, { unread: Unread.NONE });
}, () => {
if (!buf) {
return;
}
let client = this.clients.get(buf.server);
for (let notif of this.messageNotifications) {
@ -578,23 +610,46 @@ export default class App extends Component {
}
}
let server = this.state.servers.get(buf.server);
if (buf.type === BufferType.NICK && !server.users.has(buf.name)) {
this.whoUserBuffer(buf.name, buf.server);
}
if (buf.type === BufferType.CHANNEL && !buf.hasInitialWho) {
this.whoChannelBuffer(buf.name, buf.server);
}
if (buf.type !== BufferType.SERVER) {
document.title = buf.name + ' · ' + this.baseTitle;
} else {
document.title = this.baseTitle;
}
this.updateDocumentTitle();
});
}
updateDocumentTitle() {
let buf = State.getBuffer(this.state, this.state.activeBuffer);
let server;
if (buf) {
server = this.state.servers.get(buf.server);
}
let bouncerNetwork;
if (server.bouncerNetID) {
bouncerNetwork = this.state.bouncerNetworks.get(server.bouncerNetID);
}
let numUnread = 0;
for (let buffer of this.state.buffers.values()) {
if (Unread.compare(buffer.unread, Unread.HIGHLIGHT) >= 0) {
numUnread++;
}
}
let parts = [];
if (buf && buf.type !== BufferType.SERVER) {
parts.push(buf.name);
}
if (bouncerNetwork) {
parts.push(getServerName(server, bouncerNetwork));
}
parts.push(this.baseTitle);
let title = "";
if (numUnread > 0) {
title = `(${numUnread}) `;
}
title += parts.join(" · ");
document.title = title;
}
prepareChatMessage(serverID, msg) {
// Treat server-wide broadcasts as highlights. They're sent by server
// operators and can contain important information.
@ -634,7 +689,7 @@ export default class App extends Component {
}
let msgUnread = Unread.NONE;
if ((msg.command == "PRIVMSG" || msg.command == "NOTICE") && !isRead) {
if ((msg.command === "PRIVMSG" || msg.command === "NOTICE") && !isRead) {
let target = msg.params[0];
let text = msg.params[1];
@ -649,7 +704,7 @@ export default class App extends Component {
msgUnread = Unread.MESSAGE;
}
if (msgUnread == Unread.HIGHLIGHT && !isDelivered && !irc.parseCTCP(msg)) {
if (msgUnread === Unread.HIGHLIGHT && !isDelivered && !irc.parseCTCP(msg)) {
let title = "New " + kind + " from " + msg.prefix.name;
if (client.isChannel(bufName)) {
title += " in " + bufName;
@ -707,7 +762,7 @@ export default class App extends Component {
// Open a new buffer if the message doesn't come from me or is a
// self-message
if ((!client.isMyNick(msg.prefix.name) || client.isMyNick(bufName)) && (msg.command != "PART" && msg.comand != "QUIT" && msg.command != irc.RPL_MONONLINE && msg.command != irc.RPL_MONOFFLINE)) {
if ((!client.isMyNick(msg.prefix.name) || client.isMyNick(bufName)) && (msg.command !== "PART" && msg.command !== "QUIT" && msg.command !== irc.RPL_MONONLINE && msg.command !== irc.RPL_MONOFFLINE)) {
this.createBuffer(serverID, bufName);
}
@ -719,7 +774,7 @@ export default class App extends Component {
let prevReadReceipt = buf.prevReadReceipt;
let receipts = { [ReceiptType.DELIVERED]: receiptFromMessage(msg) };
if (this.state.activeBuffer !== buf.id) {
if (this.state.activeBuffer !== buf.id || !document.hasFocus()) {
unread = Unread.union(unread, msgUnread);
} else {
receipts[ReceiptType.READ] = receiptFromMessage(msg);
@ -740,6 +795,10 @@ export default class App extends Component {
this.sendReadReceipt(client, stored);
}
return { unread, prevReadReceipt };
}, () => {
if (msgUnread === Unread.HIGHLIGHT) {
this.updateDocumentTitle();
}
});
}
@ -849,6 +908,12 @@ export default class App extends Component {
let client = this.clients.get(serverID);
let chatHistoryBatch = irc.findBatchByType(msg, "chathistory");
// Reply triggered by some command sent by us, not worth displaying to
// the user
if (msg.internal) {
return [];
}
let target, channel, affectedBuffers;
switch (msg.command) {
case "MODE":
@ -864,7 +929,7 @@ export default class App extends Component {
if (client.cm(msg.prefix.name) === client.cm(client.serverPrefix.name)) {
target = SERVER_BUFFER;
} else {
let context = msg.tags['+draft/channel-context'];
let context = msg.tags["+draft/channel-context"];
if (context && client.isChannel(context) && State.getBuffer(this.state, { server: serverID, name: context })) {
target = context;
} else {
@ -873,6 +938,14 @@ export default class App extends Component {
}
}
let allowedPrefixes = client.isupport.statusMsg();
if (allowedPrefixes) {
let parts = irc.parseTargetPrefix(target, allowedPrefixes);
if (client.isChannel(parts.name)) {
target = parts.name;
}
}
// Don't open a new buffer if this is just a NOTICE or a garbage
// CTCP message
let openNewBuffer = true;
@ -888,13 +961,6 @@ export default class App extends Component {
target = SERVER_BUFFER;
}
let allowedPrefixes = client.isupport.statusMsg();
if (allowedPrefixes) {
let parts = irc.parseTargetPrefix(target, allowedPrefixes);
if (client.isChannel(parts.name)) {
target = parts.name;
}
}
return [target];
case "JOIN":
channel = msg.params[0];
@ -914,7 +980,7 @@ export default class App extends Component {
affectedBuffers.push(chatHistoryBatch.params[0]);
} else {
this.state.buffers.forEach((buf) => {
if (buf.server != serverID) {
if (buf.server !== serverID) {
return;
}
if (!buf.members.has(msg.prefix.name)) {
@ -932,7 +998,7 @@ export default class App extends Component {
affectedBuffers.push(chatHistoryBatch.params[0]);
} else {
this.state.buffers.forEach((buf) => {
if (buf.server != serverID) {
if (buf.server !== serverID) {
return;
}
if (!buf.members.has(msg.prefix.name)) {
@ -1009,6 +1075,7 @@ export default class App extends Component {
case "ACK":
case "BOUNCER":
case "MARKREAD":
case "REDACT":
// Ignore these
return [];
default:
@ -1078,13 +1145,14 @@ export default class App extends Component {
this.openURL(this.autoOpenURL);
this.autoOpenURL = null;
}
break;
case "JOIN":
channel = msg.params[0];
if (client.isMyNick(msg.prefix.name)) {
this.syncBufferUnread(serverID, channel);
}
if (channel == this.switchToChannel) {
if (channel === this.switchToChannel) {
this.switchBuffer({ server: serverID, name: channel });
this.switchToChannel = null;
}
@ -1210,10 +1278,11 @@ export default class App extends Component {
closed,
receipts: { [ReceiptType.READ]: readReceipt },
});
this.updateDocumentTitle();
});
break;
default:
if (irc.isError(msg.command) && msg.command != irc.ERR_NOMOTD) {
if (irc.isError(msg.command) && msg.command !== irc.ERR_NOMOTD) {
let description = msg.params[msg.params.length - 1];
this.showError(description);
}
@ -1461,7 +1530,7 @@ export default class App extends Component {
servers.delete(buf.server);
let connectForm = state.connectForm;
if (servers.size == 0) {
if (servers.size === 0) {
connectForm = true;
}
@ -1517,7 +1586,7 @@ export default class App extends Component {
let name = parts[0].toLowerCase().slice(1);
let args = parts.slice(1);
let cmd = commands[name];
let cmd = commands.get(name);
if (!cmd) {
this.showError(`Unknown command "${name}" (run "/help" to get a command list)`);
return;
@ -1532,7 +1601,7 @@ export default class App extends Component {
}
privmsg(target, text) {
if (target == SERVER_BUFFER) {
if (target === SERVER_BUFFER) {
this.showError("Cannot send message in server buffer");
return;
}
@ -1649,8 +1718,8 @@ export default class App extends Component {
}
if (prefix.startsWith("/")) {
let repl = fromList(Object.keys(commands), prefix.slice(1));
return repl.map(cmd => "/" + cmd);
let repl = fromList([...commands.keys()], prefix.slice(1));
return repl.map((cmd) => "/" + cmd);
}
// TODO: consider using the CHANTYPES ISUPPORT token here
@ -1677,7 +1746,7 @@ export default class App extends Component {
async handleBufferScrollTop() {
let buf = this.state.buffers.get(this.state.activeBuffer);
if (!buf || buf.type == BufferType.SERVER) {
if (!buf || buf.type === BufferType.SERVER) {
return;
}
@ -1856,7 +1925,7 @@ export default class App extends Component {
this.dismissDialog();
if (this.state.dialogData && this.state.dialogData.id) {
if (Object.keys(attrs).length == 0) {
if (Object.keys(attrs).length === 0) {
return;
}
@ -1894,7 +1963,7 @@ export default class App extends Component {
handleOpenSettingsClick() {
let showProtocolHandler = false;
for (let [id, client] of this.clients) {
for (let [_id, client] of this.clients) {
if (client.caps.enabled.has("soju.im/bouncer-networks")) {
showProtocolHandler = true;
break;
@ -1922,6 +1991,11 @@ export default class App extends Component {
}
handleWindowFocus() {
if (this.state.activeBuffer) {
// TODO: only do this if scrolled at the bottom
this.markBufferAsRead(this.state.activeBuffer);
}
// When the user focuses gamja, send a PING to make sure we detect any
// network errors ASAP
@ -1932,9 +2006,11 @@ export default class App extends Component {
this.lastFocusPingDate = now;
for (let client of this.clients.values()) {
if (client.status === Client.Status.REGISTERED) {
client.send({ command: "PING", params: ["gamja"] });
}
}
}
componentDidMount() {
this.baseTitle = document.title;
@ -1967,6 +2043,11 @@ export default class App extends Component {
}
}
let activeClient = null;
if (activeBuffer) {
activeClient = this.clients.get(activeBuffer.server);
}
if (this.state.connectForm) {
let status = activeServer ? activeServer.status : ServerStatus.DISCONNECTED;
let connecting = status === ServerStatus.CONNECTING || status === ServerStatus.REGISTERING;
@ -1986,7 +2067,7 @@ export default class App extends Component {
let bufferHeader = null;
if (activeBuffer) {
let activeUser = null;
if (activeBuffer.type == BufferType.NICK) {
if (activeBuffer.type === BufferType.NICK) {
activeUser = activeServer.users.get(activeBuffer.name);
}
@ -2010,7 +2091,7 @@ export default class App extends Component {
}
let memberList = null;
if (activeBuffer && activeBuffer.type == BufferType.CHANNEL) {
if (activeBuffer && activeBuffer.type === BufferType.CHANNEL) {
memberList = html`
<section
id="member-list"
@ -2195,7 +2276,6 @@ export default class App extends Component {
<${Buffer}
buffer=${activeBuffer}
server=${activeServer}
bouncerNetwork=${activeBouncerNetwork}
settings=${this.state.settings}
onChannelClick=${this.handleChannelClick}
onNickClick=${this.handleNickClick}
@ -2208,6 +2288,7 @@ export default class App extends Component {
${memberList}
<${Composer}
ref=${this.composer}
client=${activeClient}
readOnly=${composerReadOnly}
onSubmit=${this.handleComposerSubmit}
autocomplete=${this.autocomplete}

View File

@ -19,7 +19,7 @@ export default class NetworkForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}

View File

@ -1,4 +1,4 @@
import { html, Component } from "../lib/index.js";
import { html } from "../lib/index.js";
import linkify from "../lib/linkify.js";
import { strip as stripANSI } from "../lib/ansi.js";
import { BufferType, ServerStatus, getServerName } from "../state.js";
@ -214,7 +214,7 @@ export default function BufferHeader(props) {
}
let name = props.buffer.name;
if (props.buffer.type == BufferType.SERVER) {
if (props.buffer.type === BufferType.SERVER) {
name = getServerName(props.server, props.bouncerNetwork);
}

View File

@ -1,5 +1,6 @@
import * as irc from "../lib/irc.js";
import { html, Component } from "../lib/index.js";
import { strip as stripANSI } from "../lib/ansi.js";
import { html } from "../lib/index.js";
import { BufferType, Unread, ServerStatus, getBufferURL, getServerName } from "../state.js";
function BufferItem(props) {
@ -15,18 +16,20 @@ function BufferItem(props) {
}
let name = props.buffer.name;
if (props.buffer.type == BufferType.SERVER) {
if (props.buffer.type === BufferType.SERVER) {
name = getServerName(props.server, props.bouncerNetwork);
}
let title;
let classes = ["type-" + props.buffer.type];
if (props.active) {
classes.push("active");
}
if (props.buffer.unread != Unread.NONE) {
if (props.buffer.unread !== Unread.NONE) {
classes.push("unread-" + props.buffer.unread);
}
if (props.buffer.type === BufferType.SERVER) {
switch (props.buffer.type) {
case BufferType.SERVER:
let isError = props.server.status === ServerStatus.DISCONNECTED;
if (props.bouncerNetwork && props.bouncerNetwork.error) {
isError = true;
@ -34,12 +37,20 @@ function BufferItem(props) {
if (isError) {
classes.push("error");
}
break;
case BufferType.NICK:
let user = props.server.users.get(name);
if (user && irc.isMeaningfulRealname(user.realname, name)) {
title = stripANSI(user.realname);
}
break;
}
return html`
<li class="${classes.join(" ")}">
<a
href=${getBufferURL(props.buffer)}
title=${title}
onClick=${handleClick}
onMouseDown=${handleMouseDown}
>${name}</a>
@ -47,7 +58,6 @@ function BufferItem(props) {
`;
}
export default function BufferList(props) {
let items = Array.from(props.buffers.values()).map((buf) => {
let server = props.servers.get(buf.server);
@ -65,7 +75,7 @@ export default function BufferList(props) {
bouncerNetwork=${bouncerNetwork}
onClick=${() => props.onBufferClick(buf)}
onClose=${() => props.onBufferClose(buf)}
active=${props.activeBuffer == buf.id}
active=${props.activeBuffer === buf.id}
/>
`;
});

View File

@ -21,9 +21,19 @@ function Nick(props) {
props.onClick();
}
let title;
if (props.user && irc.isMeaningfulRealname(props.user.realname, props.nick)) {
title = stripANSI(props.user.realname);
}
let colorIndex = djb2(props.nick) % 16 + 1;
return html`
<a href=${irc.formatURL({ entity: props.nick })} class="nick nick-${colorIndex}" onClick=${handleClick}>${props.nick}</a>
<a
href=${irc.formatURL({ entity: props.nick })}
title=${title}
class="nick nick-${colorIndex}"
onClick=${handleClick}
>${props.nick}</a>
`;
}
@ -33,7 +43,7 @@ function _Timestamp({ date, url, showSeconds }) {
if (showSeconds) {
timestamp += ":--";
}
return html`<spam class="timestamp">${timestamp}</span>`;
return html`<span class="timestamp">${timestamp}</span>`;
}
let hh = date.getHours().toString().padStart(2, "0");
@ -84,7 +94,7 @@ function canFoldMessage(msg) {
class LogLine extends Component {
shouldComponentUpdate(nextProps) {
return this.props.message !== nextProps.message;
return this.props.message !== nextProps.message || this.props.redacted !== nextProps.redacted;
}
render() {
@ -98,7 +108,11 @@ class LogLine extends Component {
function createNick(nick) {
return html`
<${Nick} nick=${nick} onClick=${() => onNickClick(nick)}/>
<${Nick}
nick=${nick}
user=${server.users.get(nick)}
onClick=${() => onNickClick(nick)}
/>
`;
}
function createChannel(channel) {
@ -120,7 +134,7 @@ class LogLine extends Component {
let ctcp = irc.parseCTCP(msg);
if (ctcp) {
if (ctcp.command == "ACTION") {
if (ctcp.command === "ACTION") {
lineClass = "me-tell";
content = html`* ${createNick(msg.prefix.name)} ${linkify(stripANSI(ctcp.param), onChannelClick)}`;
} else {
@ -129,15 +143,20 @@ class LogLine extends Component {
`;
}
} else {
lineClass = "talk";
let prefix = "<", suffix = ">";
if (msg.command == "NOTICE") {
if (msg.command === "NOTICE") {
lineClass += " notice";
prefix = suffix = "-";
}
content = html`${prefix}${createNick(msg.prefix.name)}${suffix} ${linkify(stripANSI(text), onChannelClick)}`;
if (this.props.redacted) {
content = html`<i>This message has been deleted.</i>`;
} else {
content = html`${linkify(stripANSI(text), onChannelClick)}`;
lineClass += " talk";
}
content = html`<span class="nick-caret">${prefix}</span>${createNick(msg.prefix.name)}<span class="nick-caret">${suffix}</span> ${content}`;
}
let status = null;
let allowedPrefixes = server.statusMsg;
if (target !== buf.name && allowedPrefixes) {
let parts = irc.parseTargetPrefix(target, allowedPrefixes);
@ -182,19 +201,94 @@ class LogLine extends Component {
break;
case "MODE":
target = msg.params[0];
let modeStr = msg.params[1];
let user = html`${createNick(msg.prefix.name)}`;
// TODO: use irc.forEachChannelModeUpdate()
if (buf.type === BufferType.CHANNEL && modeStr.length === 2 && server.cm(buf.name) === server.cm(target)) {
let plusMinus = modeStr[0];
let mode = modeStr[1];
let arg = msg.params[2];
let verb;
switch (mode) {
case "b":
verb = plusMinus === "+" ? "added" : "removed";
content = html`${user} has ${verb} a ban on ${arg}`;
break;
case "e":
verb = plusMinus === "+" ? "added" : "removed";
content = html`${user} has ${verb} a ban exemption on ${arg}`;
break;
case "l":
if (plusMinus === "+") {
content = html`${user} has set the channel user limit to ${arg}`;
} else {
content = html`${user} has unset the channel user limit`;
}
break;
case "i":
verb = plusMinus === "+" ? "marked": "unmarked";
content = html`${user} has ${verb} as invite-only`;
break;
case "m":
verb = plusMinus === "+" ? "marked": "unmarked";
content = html`${user} has ${verb} as moderated`;
break;
case "s":
verb = plusMinus === "+" ? "marked": "unmarked";
content = html`${user} has ${verb} as secret`;
break;
case "t":
verb = plusMinus === "+" ? "locked": "unlocked";
content = html`${user} has ${verb} the channel topic`;
break;
case "n":
verb = plusMinus === "+" ? "allowed": "denied";
content = html`${user} has ${verb} external messages to this channel`;
break;
}
if (content) {
break;
}
// Channel membership modes
let membership;
for (let prefix in irc.STD_MEMBERSHIP_MODES) {
if (irc.STD_MEMBERSHIP_MODES[prefix] === mode) {
membership = irc.STD_MEMBERSHIP_NAMES[prefix];
break;
}
}
if (membership && arg) {
let verb = plusMinus === "+" ? "granted" : "revoked";
let preposition = plusMinus === "+" ? "to" : "from";
content = html`
* ${createNick(msg.prefix.name)} sets mode ${msg.params.slice(1).join(" ")}
${user} has ${verb} ${membership} privileges ${preposition} ${createNick(arg)}
`;
// TODO: case-mapping
if (buf.name !== target) {
break;
}
}
content = html`
${user} sets mode ${msg.params.slice(1).join(" ")}
`;
if (server.cm(buf.name) !== server.cm(target)) {
content = html`${content} on ${target}`;
}
break;
case "TOPIC":
let topic = msg.params[1];
if (topic) {
content = html`
${createNick(msg.prefix.name)} changed the topic to: ${linkify(stripANSI(topic), onChannelClick)}
`;
} else {
content = html`
${createNick(msg.prefix.name)} cleared the topic
`;
}
break;
case "INVITE":
invitee = msg.params[0];
@ -275,7 +369,7 @@ class LogLine extends Component {
content = html`${createNick(buf.name)} is offline`;
break;
default:
if (irc.isError(msg.command) && msg.command != irc.ERR_NOMOTD) {
if (irc.isError(msg.command) && msg.command !== irc.ERR_NOMOTD) {
lineClass = "error";
}
content = html`${msg.command} ${linkify(msg.params.join(" "))}`;
@ -325,11 +419,16 @@ class FoldGroup extends Component {
render() {
let msgs = this.props.messages;
let buf = this.props.buffer;
let server = this.props.server;
let onNickClick = this.props.onNickClick;
function createNick(nick) {
return html`
<${Nick} nick=${nick} onClick=${() => onNickClick(nick)}/>
<${Nick}
nick=${nick}
user=${server.users.get(nick)}
onClick=${() => onNickClick(nick)}
/>
`;
}
@ -585,18 +684,17 @@ export default class Buffer extends Component {
}
let server = this.props.server;
let bouncerNetwork = this.props.bouncerNetwork;
let settings = this.props.settings;
let serverName = server.name;
let children = [];
if (buf.type == BufferType.SERVER) {
if (buf.type === BufferType.SERVER) {
children.push(html`<${NotificationNagger}/>`);
}
if (buf.type == BufferType.SERVER && server.isBouncer && !server.bouncerNetID) {
if (buf.type === BufferType.SERVER && server.isBouncer && !server.bouncerNetID) {
children.push(html`<${ProtocolHandlerNagger} bouncerName=${serverName}/>`);
}
if (buf.type == BufferType.SERVER && server.status == ServerStatus.REGISTERED && server.supportsSASLPlain && !server.account) {
if (buf.type === BufferType.SERVER && server.status === ServerStatus.REGISTERED && server.supportsSASLPlain && !server.account) {
children.push(html`
<${AccountNagger}
server=${server}
@ -617,6 +715,7 @@ export default class Buffer extends Component {
message=${msg}
buffer=${buf}
server=${server}
redacted=${buf.redacted.has(msg.tags.msgid)}
onChannelClick=${onChannelClick}
onNickClick=${onNickClick}
onVerifyClick=${onVerifyClick}
@ -624,7 +723,38 @@ export default class Buffer extends Component {
`;
}
function createFoldGroup(msgs) {
// Filter out PART → JOIN pairs
// Merge NICK change chains
let nickChanges = new Map();
let mergedMsgs = [];
for (let msg of msgs) {
let keep = true;
switch (msg.command) {
case "PART":
case "QUIT":
nickChanges.delete(msg.prefix.name);
break;
case "NICK":
let prev = nickChanges.get(msg.prefix.name);
if (!prev) {
// Future NICK messages may mutate this one
msg = { ...msg };
nickChanges.set(msg.params[0], msg);
break;
}
prev.params = msg.params;
nickChanges.delete(msg.prefix.name);
nickChanges.set(msg.params[0], prev);
keep = false;
break;
}
if (keep) {
mergedMsgs.push(msg);
}
}
msgs = mergedMsgs;
// Filter out PART → JOIN pairs, as well as no-op NICKs from previous step
let partIndexes = new Map();
let keep = [];
msgs.forEach((msg, i) => {
@ -635,6 +765,8 @@ export default class Buffer extends Component {
keep[partIndexes.get(msg.prefix.name)] = false;
partIndexes.delete(msg.prefix.name);
keep.push(false);
} else if (msg.command === "NICK" && msg.prefix.name === msg.params[0]) {
keep.push(false);
} else {
keep.push(true);
}
@ -676,7 +808,7 @@ export default class Buffer extends Component {
}
}
if (!hasUnreadSeparator && buf.type != BufferType.SERVER && !isMessageBeforeReceipt(msg, buf.prevReadReceipt)) {
if (!hasUnreadSeparator && buf.type !== BufferType.SERVER && !isMessageBeforeReceipt(msg, buf.prevReadReceipt)) {
sep.push(html`<${UnreadSeparator} key="unread"/>`);
hasUnreadSeparator = true;
}
@ -689,7 +821,7 @@ export default class Buffer extends Component {
if (sep.length > 0) {
children.push(createFoldGroup(foldMessages));
children.push(sep);
children.push(...sep);
foldMessages = [];
}

View File

@ -1,5 +1,16 @@
import { html, Component, createRef } from "../lib/index.js";
function encodeContentDisposition(filename) {
// Encode filename according to RFC 5987 if necessary. Note,
// encodeURIComponent will percent-encode a superset of attr-char.
let encodedFilename = encodeURIComponent(filename);
if (encodedFilename === filename) {
return "attachment; filename=\"" + filename + "\"";
} else {
return "attachment; filename*=UTF-8''" + encodedFilename;
}
}
export default class Composer extends Component {
state = {
text: "",
@ -13,6 +24,9 @@ export default class Composer extends Component {
this.handleInput = this.handleInput.bind(this);
this.handleSubmit = this.handleSubmit.bind(this);
this.handleInputKeyDown = this.handleInputKeyDown.bind(this);
this.handleInputPaste = this.handleInputPaste.bind(this);
this.handleDragOver = this.handleDragOver.bind(this);
this.handleDrop = this.handleDrop.bind(this);
this.handleWindowKeyDown = this.handleWindowKeyDown.bind(this);
this.handleWindowPaste = this.handleWindowPaste.bind(this);
}
@ -116,6 +130,108 @@ export default class Composer extends Component {
this.setState({ text: autocomplete.text });
}
canUploadFiles() {
let client = this.props.client;
return client && client.isupport.filehost() && !this.props.readOnly;
}
async uploadFile(file) {
let client = this.props.client;
let endpoint = client.isupport.filehost();
let auth;
if (client.params.saslPlain) {
let params = client.params.saslPlain;
auth = "Basic " + btoa(params.username + ":" + params.password);
} else if (client.params.saslOauthBearer) {
auth = "Bearer " + client.params.saslOauthBearer.token;
}
let headers = {
"Content-Length": file.size,
"Content-Disposition": encodeContentDisposition(file.name),
};
if (file.type) {
headers["Content-Type"] = file.type;
}
if (auth) {
headers["Authorization"] = auth;
}
// TODO: show a loading UI while uploading
// TODO: show a cancel button
let resp = await fetch(endpoint, {
method: "POST",
body: file,
headers,
credentials: "include",
});
if (!resp.ok) {
throw new Error(`HTTP request failed (${resp.status})`);
}
let loc = resp.headers.get("Location");
if (!loc) {
throw new Error("filehost response missing Location header field");
}
return new URL(loc, endpoint);
}
async uploadFileList(fileList) {
let promises = [];
for (let file of fileList) {
promises.push(this.uploadFile(file));
}
let urls = await Promise.all(promises);
this.setState((state) => {
if (state.text) {
return { text: state.text + " " + urls.join(" ") };
} else {
return { text: urls.join(" ") };
}
});
}
async handleInputPaste(event) {
if (event.clipboardData.files.length === 0 || !this.canUploadFiles()) {
return;
}
event.preventDefault();
event.stopImmediatePropagation();
await this.uploadFileList(event.clipboardData.files);
}
handleDragOver(event) {
if (event.dataTransfer.items.length === 0 || !this.canUploadFiles()) {
return;
}
for (let item of event.dataTransfer.items) {
if (item.kind !== "file") {
return;
}
}
event.preventDefault();
}
async handleDrop(event) {
if (event.dataTransfer.files.length === 0 || !this.canUploadFiles()) {
return;
}
event.preventDefault();
event.stopImmediatePropagation();
await this.uploadFileList(event.dataTransfer.files);
}
handleWindowKeyDown(event) {
// If an <input> or <button> is focused, ignore.
if (document.activeElement && document.activeElement !== document.body) {
@ -173,6 +289,11 @@ export default class Composer extends Component {
return;
}
if (event.clipboardData.files.length > 0) {
this.handleInputPaste(event);
return;
}
let text = event.clipboardData.getData("text");
event.preventDefault();
@ -228,6 +349,9 @@ export default class Composer extends Component {
placeholder=${placeholder}
enterkeyhint="send"
onKeyDown=${this.handleInputKeyDown}
onPaste=${this.handleInputPaste}
onDragOver=${this.handleDragOver}
onDrop=${this.handleDrop}
maxlength=${this.props.maxLen}
/>
</form>

View File

@ -34,7 +34,7 @@ export default class ConnectForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}

View File

@ -21,13 +21,13 @@ export default class Dialog extends Component {
}
handleBackdropClick(event) {
if (event.target.className == "dialog") {
if (event.target.className === "dialog") {
this.dismiss();
}
}
handleKeyDown(event) {
if (event.key == "Escape") {
if (event.key === "Escape") {
this.dismiss();
}
}

View File

@ -1,4 +1,4 @@
import { html, Component } from "../lib/index.js";
import { html } from "../lib/index.js";
import { keybindings } from "../keybindings.js";
import commands from "../commands.js";
@ -26,6 +26,11 @@ function KeyBindingsHelp() {
`;
});
l.push(html`
<dt><kbd>Tab</kbd></dt>
<dd>Automatically complete nickname or channel</dd>
`);
if (!window.matchMedia("(pointer: none)").matches) {
l.push(html`
<dt><strong>Middle mouse click</strong></dt>
@ -37,8 +42,8 @@ function KeyBindingsHelp() {
}
function CommandsHelp() {
let l = Object.keys(commands).map((name) => {
let cmd = commands[name];
let l = [...commands.keys()].map((name) => {
let cmd = commands.get(name);
let usage = [html`<strong>/${name}</strong>`];
if (cmd.usage) {

View File

@ -18,7 +18,7 @@ export default class JoinForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}

View File

@ -22,26 +22,7 @@ class MemberItem extends Component {
}
render() {
// XXX: If we were feeling creative we could generate unique colors for
// each item in ISUPPORT CHANMODES. But I am not feeling creative.
const membmap = {
"~": "owner",
"&": "admin",
"@": "op",
"%": "halfop",
"+": "voice",
};
const membclass = membmap[this.props.membership[0]] || "";
let membership = "";
if (this.props.membership) {
membership = html`
<span class="membership ${membclass}" title=${membclass}>
${this.props.membership}
</span>
`;
};
let title = null;
let title;
let user = this.props.user;
let classes = ["nick"];
if (user) {

View File

@ -1,21 +1,14 @@
import { html, Component } from "../lib/index.js";
// XXX: If we were feeling creative we could generate unique colors for
// each item in ISUPPORT CHANMODES. But I am not feeling creative.
const names = {
"~": "owner",
"&": "admin",
"@": "op",
"%": "halfop",
"+": "voice",
};
import { html } from "../lib/index.js";
import * as irc from "../lib/irc.js";
export default function Membership(props) {
if (!this.props.value) {
return null;
}
const name = names[this.props.value[0]] || "";
// XXX: If we were feeling creative we could generate unique colors for
// each item in ISUPPORT CHANMODES. But I am not feeling creative.
const name = irc.STD_MEMBERSHIP_NAMES[this.props.value[0]] || "";
return html`
<span class="membership ${name}" title=${name}>
${this.props.value}

View File

@ -37,7 +37,7 @@ export default class NetworkForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}
@ -46,10 +46,10 @@ export default class NetworkForm extends Component {
let params = {};
Object.keys(defaultParams).forEach((k) => {
if (!this.props.isNew && this.prevParams[k] == this.state[k]) {
if (!this.props.isNew && this.prevParams[k] === this.state[k]) {
return;
}
if (this.props.isNew && defaultParams[k] == this.state[k]) {
if (this.props.isNew && defaultParams[k] === this.state[k]) {
return;
}
params[k] = this.state[k];

View File

@ -15,7 +15,7 @@ export default class RegisterForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}

View File

@ -1,4 +1,4 @@
import { html, Component } from "../lib/index.js";
import { Component } from "../lib/index.js";
let store = new Map();
@ -11,10 +11,10 @@ export default class ScrollManager extends Component {
isAtBottom() {
let target = this.props.target.current;
return target.scrollTop >= target.scrollHeight - target.offsetHeight;
return Math.abs(target.scrollHeight - target.clientHeight - target.scrollTop) <= 10;
}
saveScrollPosition() {
saveScrollPosition(scrollKey) {
let target = this.props.target.current;
let sticky = target.querySelectorAll(this.props.stickTo);
@ -29,7 +29,7 @@ export default class ScrollManager extends Component {
}
}
store.set(this.props.scrollKey, stickToKey);
store.set(scrollKey, stickToKey);
}
restoreScrollPosition() {
@ -48,13 +48,13 @@ export default class ScrollManager extends Component {
}
}
if (target.scrollTop == 0) {
if (target.scrollTop === 0) {
this.props.onScrollTop();
}
}
handleScroll() {
if (this.props.target.current.scrollTop == 0) {
if (this.props.target.current.scrollTop === 0) {
this.props.onScrollTop();
}
}
@ -64,9 +64,9 @@ export default class ScrollManager extends Component {
this.props.target.current.addEventListener("scroll", this.handleScroll);
}
componentWillReceiveProps(nextProps) {
if (this.props.scrollKey !== nextProps.scrollKey || this.props.children !== nextProps.children) {
this.saveScrollPosition();
getSnapshotBeforeUpdate(prevProps) {
if (this.props.scrollKey !== prevProps.scrollKey || this.props.children !== prevProps.children) {
this.saveScrollPosition(prevProps.scrollKey);
}
}
@ -79,7 +79,7 @@ export default class ScrollManager extends Component {
componentWillUnmount() {
this.props.target.current.removeEventListener("scroll", this.handleScroll);
this.saveScrollPosition();
this.saveScrollPosition(this.props.scrollKey);
}
render() {

View File

@ -15,7 +15,7 @@ export default class SettingsForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value }, () => {
this.props.onChange(this.state);
});

View File

@ -15,7 +15,7 @@ export default class RegisterForm extends Component {
handleInput(event) {
let target = event.target;
let value = target.type == "checkbox" ? target.checked : target.value;
let value = target.type === "checkbox" ? target.checked : target.value;
this.setState({ [target.name]: value });
}

View File

@ -63,7 +63,8 @@ if (remoteHost) {
ws.close();
});
client.on("error", () => {
client.on("error", (err) => {
console.log(err);
ws.close(WS_BAD_GATEWAY);
});
});

View File

@ -15,6 +15,9 @@ gamja can be configured using a `config.json` file at the root. Example:
}
```
Errors while parsing the configuration file are logged in the
[browser's web console].
## IRC server
The `server` object configures the IRC server.
@ -43,3 +46,5 @@ The `oauth2` object configures OAuth 2.0 authentication.
- `client_id` (string): OAuth 2.0 client ID.
- `client_secret` (string): OAuth 2.0 client secret.
- `scope` (string): OAuth 2.0 scope.
[browser's web console]: https://firefox-source-docs.mozilla.org/devtools-user/web_console/index.html

View File

@ -5,8 +5,9 @@ the same HTTP server is used as a reverse proxy for the IRC WebSocket.
## [soju]
Add a WebSocket listener to soju, e.g. `listen wss://127.0.0.1:8080`. Then
configure your reverse proxy to serve gamja files and proxy `/socket` to soju.
Add a WebSocket listener to soju, e.g. `listen ws+insecure://127.0.0.1:8080`.
Then configure your reverse proxy to serve gamja files and proxy `/socket` to
soju.
## [webircgateway]
@ -38,6 +39,7 @@ location /socket {
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "Upgrade";
proxy_set_header Host $host;
proxy_set_header X-Forwarded-For $remote_addr;
proxy_set_header X-Forwarded-Proto $scheme;
}

View File

@ -3,10 +3,11 @@
gamja settings can be overridden using URL query parameters:
- `server`: path or URL to the WebSocket server
- `nick`: nickname
- `nick`: nickname (if the character `*` appears in the string, it will be
replaced with a randomly generated value)
- `channels`: comma-separated list of channels to join (`#` needs to be escaped)
- `open`: [IRC URL] to open
- `debug`: if set to 1, debug mode is enabled
- `debug`: enable debug logs if set to `1`, disable debug logs if set to `0`
Alternatively, the channels can be set with the URL fragment (ie, by just
appending the channel name to the gamja URL).

56
eslint.config.js Normal file
View File

@ -0,0 +1,56 @@
import globals from "globals";
import js from "@eslint/js";
import stylisticJs from "@stylistic/eslint-plugin-js";
export default [
{
ignores: ["dist/"],
},
js.configs.recommended,
{
languageOptions: {
globals: {
...globals.browser,
"process": "readonly",
},
},
plugins: { "@stylistic/js": stylisticJs },
rules: {
"no-case-declarations": "off",
"no-unused-vars": ["error", {
args: "none",
caughtErrorsIgnorePattern: "^_",
destructuredArrayIgnorePattern: "^_",
}],
"no-var": "error",
"no-eval": "error",
"no-implied-eval": "error",
"eqeqeq": "error",
"no-invalid-this": "error",
"no-extend-native": "error",
"prefer-arrow-callback": "error",
"no-implicit-globals": "error",
"no-throw-literal": "error",
"no-implicit-coercion": "warn",
"object-shorthand": "warn",
"curly": "warn",
"camelcase": "warn",
"@stylistic/js/indent": ["warn", "tab"],
"@stylistic/js/quotes": ["warn", "double"],
"@stylistic/js/semi": "warn",
"@stylistic/js/brace-style": ["warn", "1tbs"],
"@stylistic/js/comma-dangle": ["warn", "always-multiline"],
"@stylistic/js/comma-spacing": "warn",
"@stylistic/js/arrow-parens": "warn",
"@stylistic/js/arrow-spacing": "warn",
"@stylistic/js/block-spacing": "warn",
"@stylistic/js/object-curly-spacing": ["warn", "always"],
"@stylistic/js/object-curly-newline": ["warn", {
multiline: true,
consistent: true,
}],
"@stylistic/js/array-bracket-spacing": ["warn", "never"],
"@stylistic/js/array-bracket-newline": ["warn", "consistent"],
},
},
];

View File

@ -1,4 +1,4 @@
import { ReceiptType, Unread, BufferType, SERVER_BUFFER, receiptFromMessage } from "./state.js";
import { ReceiptType, Unread, BufferType, receiptFromMessage } from "./state.js";
function getSiblingBuffer(buffers, bufID, delta) {
let bufList = Array.from(buffers.values());
@ -40,6 +40,8 @@ export const keybindings = [
});
});
return { buffers };
}, () => {
app.updateDocumentTitle();
});
},
},
@ -119,9 +121,9 @@ export function setup(app) {
return;
}
candidates = candidates.filter((binding) => {
return !!binding.altKey == event.altKey && !!binding.ctrlKey == event.ctrlKey;
return Boolean(binding.altKey) === event.altKey && Boolean(binding.ctrlKey) === event.ctrlKey;
});
if (candidates.length != 1) {
if (candidates.length !== 1) {
return;
}
event.preventDefault();

View File

@ -51,7 +51,7 @@ export function strip(text) {
if (isDigit(text[i + 1])) {
i++;
}
if (text[i + 1] == "," && isDigit(text[i + 2])) {
if (text[i + 1] === "," && isDigit(text[i + 2])) {
i += 2;
if (isDigit(text[i + 1])) {
i++;
@ -63,7 +63,7 @@ export function strip(text) {
break;
}
i += HEX_COLOR_LENGTH;
if (text[i + 1] == "," && isHexColor(text.slice(i + 2))) {
if (text[i + 1] === "," && isHexColor(text.slice(i + 2))) {
i += 1 + HEX_COLOR_LENGTH;
}
break;

View File

@ -12,26 +12,26 @@ export function encode(data) {
return btoa(data);
}
var encoder = new TextEncoder();
var bytes = encoder.encode(data);
let encoder = new TextEncoder();
let bytes = encoder.encode(data);
var trailing = bytes.length % 3;
var out = "";
for (var i = 0; i < bytes.length - trailing; i += 3) {
var u24 = (bytes[i] << 16) + (bytes[i + 1] << 8) + bytes[i + 2];
let trailing = bytes.length % 3;
let out = "";
for (let i = 0; i < bytes.length - trailing; i += 3) {
let u24 = (bytes[i] << 16) + (bytes[i + 1] << 8) + bytes[i + 2];
out += alphabet[(u24 >> 18) & 0x3F];
out += alphabet[(u24 >> 12) & 0x3F];
out += alphabet[(u24 >> 6) & 0x3F];
out += alphabet[u24 & 0x3F];
}
if (trailing == 1) {
var u8 = bytes[bytes.length - 1];
if (trailing === 1) {
let u8 = bytes[bytes.length - 1];
out += alphabet[u8 >> 2];
out += alphabet[(u8 << 4) & 0x3F];
out += "==";
} else if (trailing == 2) {
var u16 = (bytes[bytes.length - 2] << 8) + bytes[bytes.length - 1];
} else if (trailing === 2) {
let u16 = (bytes[bytes.length - 2] << 8) + bytes[bytes.length - 1];
out += alphabet[u16 >> 10];
out += alphabet[(u16 >> 4) & 0x3F];
out += alphabet[(u16 << 2) & 0x3F];

View File

@ -1,5 +1,4 @@
import * as irc from "./irc.js";
import * as base64 from "./base64.js";
// Static list of capabilities that are always requested when supported by the
// server
@ -22,6 +21,7 @@ const permanentCaps = [
"draft/account-registration",
"draft/chathistory",
"draft/extended-monitor",
"draft/message-redaction",
"draft/read-marker",
"soju.im/bouncer-networks",
@ -75,8 +75,8 @@ class IRCError extends Error {
class Backoff {
n = 0;
constructor(min, max) {
this.min = min;
constructor(base, max) {
this.base = base;
this.max = max;
}
@ -87,10 +87,10 @@ class Backoff {
next() {
if (this.n === 0) {
this.n = 1;
return this.min;
return 0;
}
let dur = this.n * this.min;
let dur = this.n * this.base;
if (dur > this.max) {
dur = this.max;
} else {
@ -135,6 +135,7 @@ export default class Client extends EventTarget {
autoReconnect = true;
reconnectTimeoutID = null;
reconnectBackoff = new Backoff(RECONNECT_MIN_DELAY_MSEC, RECONNECT_MAX_DELAY_MSEC);
lastReconnectDate = new Date(0);
pingIntervalID = null;
pendingCmds = {
WHO: Promise.resolve(null),
@ -148,6 +149,8 @@ export default class Client extends EventTarget {
constructor(params) {
super();
this.handleOnline = this.handleOnline.bind(this);
this.params = { ...this.params, ...params };
this.reconnect();
@ -160,6 +163,7 @@ export default class Client extends EventTarget {
console.log("Connecting to " + this.params.url);
this.setStatus(Client.Status.CONNECTING);
this.lastReconnectDate = new Date();
try {
this.ws = new WebSocket(this.params.url);
@ -202,15 +206,16 @@ export default class Client extends EventTarget {
this.monitored = new irc.CaseMapMap(null, irc.CaseMapping.RFC1459);
if (this.autoReconnect) {
window.addEventListener("online", this.handleOnline);
if (!navigator.onLine) {
console.info("Waiting for network to go back online");
const handleOnline = () => {
window.removeEventListener("online", handleOnline);
this.reconnect();
};
window.addEventListener("online", handleOnline);
} else {
let delay = this.reconnectBackoff.next();
let sinceLastReconnect = new Date().getTime() - this.lastReconnectDate.getTime();
if (sinceLastReconnect < RECONNECT_MIN_DELAY_MSEC) {
delay = Math.max(delay, RECONNECT_MIN_DELAY_MSEC);
}
console.info("Reconnecting to server in " + (delay / 1000) + " seconds");
clearTimeout(this.reconnectTimeoutID);
this.reconnectTimeoutID = setTimeout(() => {
@ -227,6 +232,8 @@ export default class Client extends EventTarget {
clearTimeout(this.reconnectTimeoutID);
this.reconnectTimeoutID = null;
window.removeEventListener("online", this.handleOnline);
this.setPingInterval(0);
if (this.ws) {
@ -246,6 +253,13 @@ export default class Client extends EventTarget {
this.dispatchEvent(new CustomEvent("error", { detail: err }));
}
handleOnline() {
window.removeEventListener("online", this.handleOnline);
if (this.autoReconnect && this.status === Client.Status.DISCONNECTED) {
this.reconnect();
}
}
handleOpen() {
console.log("Connection opened");
this.setStatus(Client.Status.REGISTERING);
@ -287,11 +301,13 @@ export default class Client extends EventTarget {
return;
}
let msg = irc.parseMessage(event.data);
let raw = event.data;
if (this.debug) {
console.debug("Received:", msg);
console.debug("Received:", raw);
}
let msg = irc.parseMessage(raw);
// If the prefix is missing, assume it's coming from the server on the
// other end of the connection
if (!msg.prefix) {
@ -310,7 +326,6 @@ export default class Client extends EventTarget {
}
let deleteBatch = null;
let k;
switch (msg.command) {
case irc.RPL_WELCOME:
if (this.params.saslPlain && !this.supportsCap) {
@ -354,7 +369,7 @@ export default class Client extends EventTarget {
case "AUTHENTICATE":
// Both PLAIN and EXTERNAL expect an empty challenge
let challengeStr = msg.params[0];
if (challengeStr != "+") {
if (challengeStr !== "+") {
this.dispatchError(new Error("Expected an empty challenge, got: " + challengeStr));
this.send({ command: "AUTHENTICATE", params: ["*"] });
}
@ -425,7 +440,7 @@ export default class Client extends EventTarget {
case irc.ERR_NOPERMFORHOST:
case irc.ERR_YOUREBANNEDCREEP:
this.dispatchError(new IRCError(msg));
if (this.status != Client.Status.REGISTERED) {
if (this.status !== Client.Status.REGISTERED) {
this.disconnect();
}
break;
@ -433,7 +448,6 @@ export default class Client extends EventTarget {
if (this.status === Client.Status.REGISTERED) {
break;
}
let reason = msg.params[msg.params.length - 1];
if (msg.params[0] === "BOUNCER" && msg.params[2] === "BIND") {
this.dispatchError(new Error("Failed to bind to bouncer network", {
cause: new IRCError(msg),
@ -465,18 +479,16 @@ export default class Client extends EventTarget {
console.log(`Starting SASL ${mechanism} authentication`);
// Send the first SASL response immediately to avoid a roundtrip
let initialResp = null;
let initialResp;
switch (mechanism) {
case "PLAIN":
let respStr = base64.encode("\0" + params.username + "\0" + params.password);
initialResp = { command: "AUTHENTICATE", params: [respStr] };
initialResp = "\0" + params.username + "\0" + params.password;
break;
case "EXTERNAL":
initialResp = { command: "AUTHENTICATE", params: ["+"] };
initialResp = "";
break;
case "OAUTHBEARER":
let raw = "n,,\x01auth=Bearer " + params.token + "\x01\x01";
initialResp = { command: "AUTHENTICATE", params: [base64.encode(raw)] };
initialResp = "n,,\x01auth=Bearer " + params.token + "\x01\x01";
break;
default:
throw new Error(`Unknown authentication mechanism '${mechanism}'`);
@ -495,7 +507,9 @@ export default class Client extends EventTarget {
throw new IRCError(msg);
}
});
this.send(initialResp);
for (let msg of irc.generateAuthenticateMessages(initialResp)) {
this.send(msg);
}
return promise;
}
@ -529,16 +543,19 @@ export default class Client extends EventTarget {
return this.roundtrip(msg, (msg) => {
switch (msg.command) {
case irc.RPL_WHOREPLY:
msg.internal = true;
l.push(this.parseWhoReply(msg));
break;
case irc.RPL_WHOSPCRPL:
if (msg.params.length !== fields.length || msg.params[1] !== token) {
if (msg.params.length !== fields.length + 1 || msg.params[1] !== token) {
break;
}
msg.internal = true;
l.push(this.parseWhoReply(msg));
break;
case irc.RPL_ENDOFWHO:
if (msg.params[1] === mask) {
msg.internal = true;
return l;
}
break;
@ -654,7 +671,7 @@ export default class Client extends EventTarget {
switch (subCmd) {
case "LS":
this.supportsCap = true;
if (args[0] == "*") {
if (args[0] === "*") {
break;
}
@ -708,9 +725,10 @@ export default class Client extends EventTarget {
if (!this.ws) {
throw new Error("Failed to send IRC message " + msg.command + ": socket is closed");
}
this.ws.send(irc.formatMessage(msg));
let raw = irc.formatMessage(msg);
this.ws.send(raw);
if (this.debug) {
console.debug("Sent:", msg);
console.debug("Sent:", raw);
}
}
@ -725,7 +743,7 @@ export default class Client extends EventTarget {
}
isMyNick(nick) {
return this.cm(nick) == this.cm(this.nick);
return this.cm(nick) === this.cm(this.nick);
}
isChannel(name) {
@ -735,7 +753,7 @@ export default class Client extends EventTarget {
isNick(name) {
// A dollar sign is used for server-wide broadcasts
return !this.isServer(name) && !this.isChannel(name) && !name.startsWith('$');
return !this.isServer(name) && !this.isChannel(name) && !name.startsWith("$");
}
setPingInterval(sec) {
@ -772,7 +790,7 @@ export default class Client extends EventTarget {
let msg = event.detail.message;
let msgLabel = irc.getMessageLabel(msg);
if (msgLabel && msgLabel != label) {
if (msgLabel && msgLabel !== label) {
return;
}
@ -821,7 +839,9 @@ export default class Client extends EventTarget {
this.removeEventListener("status", handleStatus);
};
this.addEventListener("message", handleMessage);
// Turn on capture to handle messages before external users and
// have the opportunity to set the "internal" flag
this.addEventListener("message", handleMessage, { capture: true });
this.addEventListener("status", handleStatus);
this.send(msg);
});
@ -834,7 +854,7 @@ export default class Client extends EventTarget {
}
let msg = {
command: "JOIN",
params: params,
params,
};
return this.roundtrip(msg, (msg) => {
switch (msg.command) {
@ -860,7 +880,6 @@ export default class Client extends EventTarget {
fetchBatch(msg, batchType) {
let batchName = null;
let messages = [];
let cmd = msg.command;
return this.roundtrip(msg, (msg) => {
if (batchName) {
let batch = msg.batch;
@ -922,7 +941,7 @@ export default class Client extends EventTarget {
}
if (messages.length >= max) {
// There are still more messages to fetch
after.time = messages[messages.length - 1].tags.time;
after = { ...after, time: messages[messages.length - 1].tags.time };
return await this.fetchHistoryBetween(target, after, before, limit);
}
return { messages };

View File

@ -4,5 +4,5 @@ import { h } from "../node_modules/preact/dist/preact.module.js";
import htm from "../node_modules/htm/dist/htm.module.js";
export const html = htm.bind(h);
import * as linkifyjs from "../node_modules/linkifyjs/dist/linkify.module.js";
import * as linkifyjs from "../node_modules/linkifyjs/dist/linkify.es.js";
export { linkifyjs };

View File

@ -1,3 +1,5 @@
import * as base64 from "./base64.js";
// RFC 1459
export const RPL_WELCOME = "001";
export const RPL_YOURHOST = "002";
@ -72,8 +74,24 @@ export const ERR_SASLTOOLONG = "905";
export const ERR_SASLABORTED = "906";
export const ERR_SASLALREADY = "907";
export const STD_MEMBERSHIPS = "~&@%+";
export const STD_CHANTYPES = "#&+!";
export const STD_MEMBERSHIP_NAMES = {
"~": "owner",
"&": "admin",
"@": "operator",
"%": "halfop",
"+": "voice",
};
export const STD_MEMBERSHIP_MODES = {
"~": "q",
"&": "a",
"@": "o",
"%": "h",
"+": "v",
};
const STD_MEMBERSHIPS = "~&@%+";
const STD_CHANTYPES = "#&+!";
const tagEscapeMap = {
";": "\\:",
@ -102,10 +120,10 @@ export function parseTags(s) {
let parts = s.split("=", 2);
let k = parts[0];
let v = null;
if (parts.length == 2) {
if (parts.length === 2) {
v = unescapeTag(parts[1]);
if (v.endsWith("\\")) {
v = v.slice(0, v.length - 1)
v = v.slice(0, v.length - 1);
}
}
tags[k] = v;
@ -127,12 +145,6 @@ export function formatTags(tags) {
}
export function parsePrefix(s) {
let prefix = {
name: null,
user: null,
host: null,
};
let host = null;
let i = s.indexOf("@");
if (i > 0) {
@ -229,7 +241,7 @@ export function formatMessage(msg) {
s += msg.command;
if (msg.params && msg.params.length > 0) {
for (let i = 0; i < msg.params.length - 1; i++) {
s += " " + msg.params[i]
s += " " + msg.params[i];
}
let last = String(msg.params[msg.params.length - 1]);
@ -260,10 +272,11 @@ export function parseTargetPrefix(s, allowedPrefixes = STD_MEMBERSHIPS) {
const alphaNum = (() => {
try {
return new RegExp(/^[\p{L}0-9]$/, "u");
} catch (e) {
} catch (_e) {
return new RegExp(/^[a-zA-Z0-9]$/, "u");
}
})();
const space = new RegExp(/^\s$/);
function isWordBoundary(ch) {
switch (ch) {
@ -276,14 +289,39 @@ function isWordBoundary(ch) {
}
}
function isURIPrefix(text) {
for (let i = text.length - 1; i >= 0; i--) {
if (space.test(text[i])) {
text = text.slice(i);
break;
}
}
let i = text.indexOf("://");
if (i <= 0) {
return false;
}
// See RFC 3986 section 3
let ch = text[i - 1];
switch (ch) {
case "+":
case "-":
case ".":
return true;
default:
return alphaNum.test(ch);
}
}
export function isHighlight(msg, nick, cm) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") {
if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return false;
}
nick = cm(nick);
if (msg.prefix && cm(msg.prefix.name) == nick) {
if (msg.prefix && cm(msg.prefix.name) === nick) {
return false; // Our own messages aren't highlights
}
@ -302,7 +340,7 @@ export function isHighlight(msg, nick, cm) {
if (i + nick.length < text.length) {
right = text[i + nick.length];
}
if (isWordBoundary(left) && isWordBoundary(right)) {
if (isWordBoundary(left) && isWordBoundary(right) && !isURIPrefix(text.slice(0, i))) {
return true;
}
@ -311,7 +349,7 @@ export function isHighlight(msg, nick, cm) {
}
export function isServerBroadcast(msg) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") {
if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return false;
}
return msg.params[0].startsWith("$");
@ -349,7 +387,7 @@ export function formatDate(date) {
}
export function parseCTCP(msg) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") {
if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return null;
}
@ -469,7 +507,7 @@ export class Isupport {
return stdChanModes;
}
let chanModes = this.raw.get("CHANMODES").split(",");
if (chanModes.length != 4) {
if (chanModes.length !== 4) {
console.error("Invalid CHANMODES: ", this.raw.get("CHANMODES"));
return stdChanModes;
}
@ -500,6 +538,10 @@ export class Isupport {
}
return parseInt(this.raw.get("LINELEN"), 10);
}
filehost() {
return this.raw.get("SOJU.IM/FILEHOST");
}
}
export function getMaxPrivmsgLen(isupport, nick, target) {
@ -530,13 +572,13 @@ export const CaseMapping = {
let ch = str[i];
if ("A" <= ch && ch <= "Z") {
ch = ch.toLowerCase();
} else if (ch == "{") {
} else if (ch === "{") {
ch = "[";
} else if (ch == "}") {
} else if (ch === "}") {
ch = "]";
} else if (ch == "\\") {
} else if (ch === "\\") {
ch = "|";
} else if (ch == "~") {
} else if (ch === "~") {
ch = "^";
}
out += ch;
@ -550,11 +592,11 @@ export const CaseMapping = {
let ch = str[i];
if ("A" <= ch && ch <= "Z") {
ch = ch.toLowerCase();
} else if (ch == "{") {
} else if (ch === "{") {
ch = "[";
} else if (ch == "}") {
} else if (ch === "}") {
ch = "]";
} else if (ch == "\\") {
} else if (ch === "\\") {
ch = "|";
}
out += ch;
@ -912,3 +954,19 @@ export class CapRegistry {
return { command: "CAP", params: ["REQ", l.join(" ")] };
}
}
const maxSASLLength = 400;
export function generateAuthenticateMessages(payload) {
let encoded = base64.encode(payload);
// <= instead of < because we need to send a final empty response if the
// last chunk is exactly 400 bytes long
let msgs = [];
for (let i = 0; i <= encoded.length; i += maxSASLLength) {
let chunk = encoded.substring(i, i + maxSASLLength);
msgs.push({ command: "AUTHENTICATE", params: [chunk || "+"] });
}
return msgs;
}

View File

@ -4,36 +4,33 @@ linkifyjs.options.defaults.defaultProtocol = "https";
linkifyjs.registerCustomProtocol("irc");
linkifyjs.registerCustomProtocol("ircs");
linkifyjs.registerCustomProtocol("geo", true);
linkifyjs.registerPlugin("ircChannel", ({ scanner, parser, utils }) => {
const { POUND, DOMAIN, TLD, LOCALHOST, UNDERSCORE, DOT, HYPHEN } = scanner.tokens;
const START_STATE = parser.start;
const Channel = utils.createTokenClass("ircChannel", {
const IRCChannelToken = linkifyjs.createTokenClass("ircChannel", {
isLink: true,
toHref() {
return "irc:///" + this.toString();
return "irc:///" + this.v;
},
});
const HASH_STATE = START_STATE.tt(POUND);
linkifyjs.registerPlugin("ircChannel", ({ scanner, parser }) => {
const { POUND, UNDERSCORE, DOT, HYPHEN } = scanner.tokens;
const { alphanumeric } = scanner.tokens.groups;
const CHAN_STATE = HASH_STATE.tt(DOMAIN, Channel);
HASH_STATE.tt(TLD, CHAN_STATE);
HASH_STATE.tt(LOCALHOST, CHAN_STATE);
HASH_STATE.tt(POUND, CHAN_STATE);
const Prefix = parser.start.tt(POUND);
const Channel = new linkifyjs.State(IRCChannelToken);
const Divider = Channel.tt(DOT);
CHAN_STATE.tt(UNDERSCORE, CHAN_STATE);
CHAN_STATE.tt(DOMAIN, CHAN_STATE);
CHAN_STATE.tt(TLD, CHAN_STATE);
CHAN_STATE.tt(LOCALHOST, CHAN_STATE);
const CHAN_DIVIDER_STATE = CHAN_STATE.tt(DOT);
CHAN_DIVIDER_STATE.tt(UNDERSCORE, CHAN_STATE);
CHAN_DIVIDER_STATE.tt(DOMAIN, CHAN_STATE);
CHAN_DIVIDER_STATE.tt(TLD, CHAN_STATE);
CHAN_DIVIDER_STATE.tt(LOCALHOST, CHAN_STATE);
Prefix.ta(alphanumeric, Channel);
Prefix.tt(POUND, Channel);
Prefix.tt(UNDERSCORE, Channel);
Prefix.tt(DOT, Divider);
Prefix.tt(HYPHEN, Channel);
Channel.ta(alphanumeric, Channel);
Channel.tt(POUND, Channel);
Channel.tt(UNDERSCORE, Channel);
Channel.tt(HYPHEN, Channel);
Divider.ta(alphanumeric, Channel);
});
export default function linkify(text, onClick) {
@ -46,7 +43,7 @@ export default function linkify(text, onClick) {
return;
}
const prefix = text.substring(last, match.start)
const prefix = text.substring(last, match.start);
children.push(prefix);
children.push(html`
@ -61,7 +58,7 @@ export default function linkify(text, onClick) {
last = match.end;
});
const suffix = text.substring(last)
const suffix = text.substring(last);
children.push(suffix);
return children;

View File

@ -43,9 +43,9 @@ export function redirectAuthorize({ serverMetadata, clientId, redirectUri, scope
// TODO: use the state param to prevent cross-site request
// forgery
let params = {
response_type: "code",
client_id: clientId,
redirect_uri: redirectUri,
"response_type": "code",
"client_id": clientId,
"redirect_uri": redirectUri,
};
if (scope) {
params.scope = scope;
@ -66,12 +66,12 @@ function buildPostHeaders(clientId, clientSecret) {
export async function exchangeCode({ serverMetadata, redirectUri, code, clientId, clientSecret }) {
let data = {
grant_type: "authorization_code",
"grant_type": "authorization_code",
code,
redirect_uri: redirectUri,
"redirect_uri": redirectUri,
};
if (!clientSecret) {
data.client_id = clientId;
data["client_id"] = clientId;
}
let resp = await fetch(serverMetadata.token_endpoint, {

3691
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@ -3,12 +3,16 @@
"type": "module",
"dependencies": {
"htm": "^3.0.4",
"linkifyjs": "^3.0.2",
"preact": "^10.5.9"
"linkifyjs": "^4.1.3",
"preact": "^10.17.1"
},
"devDependencies": {
"@eslint/js": "^9.11.1",
"@parcel/packager-raw-url": "^2.0.0",
"@parcel/transformer-webmanifest": "^2.0.0",
"@stylistic/eslint-plugin-js": "^4.2.0",
"eslint": "^9.11.1",
"globals": "^16.0.0",
"node-static": "^0.7.11",
"parcel": "^2.0.0",
"split": "^1.0.1",
@ -16,7 +20,8 @@
},
"scripts": {
"start": "node ./dev-server.js",
"build": "parcel build"
"build": "parcel build",
"lint": "eslint"
},
"private": true,
"targets": {

View File

@ -136,22 +136,59 @@ function updateState(state, updater) {
}
function isServerBuffer(buf) {
return buf.type == BufferType.SERVER;
return buf.type === BufferType.SERVER;
}
function isChannelBuffer(buf) {
return buf.type === BufferType.CHANNEL;
}
function trimStartCharacter(s, c) {
let i = 0;
for (; i < s.length; ++i) {
if (s[i] !== c) {
break;
}
}
return s.substring(i);
}
function getBouncerNetworkNameFromBuffer(state, buffer) {
let server = state.servers.get(buffer.server);
let network = state.bouncerNetworks.get(server.bouncerNetID);
if (!network) {
return null;
}
return getServerName(server, network);
}
/* Returns 1 if a should appear after b, -1 if a should appear before b, or
* 0 otherwise. */
function compareBuffers(a, b) {
if (a.server != b.server) {
function compareBuffers(state, a, b) {
if (a.server !== b.server) {
let aServerName = getBouncerNetworkNameFromBuffer(state, a);
let bServerName = getBouncerNetworkNameFromBuffer(state, b);
if (aServerName && bServerName && aServerName !== bServerName) {
return aServerName.localeCompare(bServerName);
}
return a.server > b.server ? 1 : -1;
}
if (isServerBuffer(a) != isServerBuffer(b)) {
if (isServerBuffer(a) !== isServerBuffer(b)) {
return isServerBuffer(b) ? 1 : -1;
}
if (a.name != b.name) {
return a.name.localeCompare(b.name);
if (isChannelBuffer(a) && isChannelBuffer(b)) {
const strippedA = trimStartCharacter(a.name, a.name[0]);
const strippedB = trimStartCharacter(b.name, b.name[0]);
const cmp = strippedA.localeCompare(strippedB);
if (cmp !== 0) {
return cmp;
}
return 0;
// if they are the same when stripped, fallthough to default logic
}
return a.name.localeCompare(b.name);
}
function updateMembership(membership, letter, add, client) {
@ -178,7 +215,7 @@ function updateMembership(membership, letter, add, client) {
/* Insert a message in an immutable list of sorted messages. */
function insertMessage(list, msg) {
if (list.length == 0) {
if (list.length === 0) {
return [msg];
} else if (!irc.findBatchByType(msg, "chathistory") || list[list.length - 1].tags.time <= msg.tags.time) {
return list.concat(msg);
@ -318,7 +355,7 @@ export const State = {
let id = lastBufferID;
let type;
if (name == SERVER_BUFFER) {
if (name === SERVER_BUFFER) {
type = BufferType.SERVER;
} else if (client.isChannel(name)) {
type = BufferType.CHANNEL;
@ -338,10 +375,11 @@ export const State = {
hasInitialWho: false, // if channel
members: new irc.CaseMapMap(null, client.cm), // if channel
messages: [],
redacted: new Set(),
unread: Unread.NONE,
prevReadReceipt: null,
});
bufferList = bufferList.sort(compareBuffers);
bufferList = bufferList.sort((a, b) => compareBuffers(state, a, b));
let buffers = new Map(bufferList.map((buf) => [buf.id, buf]));
return [id, { buffers }];
},
@ -394,7 +432,7 @@ export const State = {
case irc.RPL_ISUPPORT:
buffers = new Map(state.buffers);
state.buffers.forEach((buf) => {
if (buf.server != serverID) {
if (buf.server !== serverID) {
return;
}
let members = new irc.CaseMapMap(buf.members, client.cm);
@ -452,10 +490,9 @@ export const State = {
});
return { members };
});
break;
case irc.RPL_ENDOFWHO:
target = msg.params[1];
if (msg.list.length == 0 && !client.isChannel(target) && target.indexOf("*") < 0) {
if (msg.list.length === 0 && !client.isChannel(target) && target.indexOf("*") < 0) {
// Not a channel nor a mask, likely a nick
return updateUser(target, (user) => {
return { offline: true };
@ -483,12 +520,11 @@ export const State = {
return { users };
});
}
break;
case "JOIN":
channel = msg.params[0];
if (client.isMyNick(msg.prefix.name)) {
let [id, update] = State.createBuffer(state, channel, serverID, client);
let [_id, update] = State.createBuffer(state, channel, serverID, client);
state = { ...state, ...update };
}
@ -546,7 +582,7 @@ export const State = {
case "QUIT":
buffers = new Map(state.buffers);
state.buffers.forEach((buf) => {
if (buf.server != serverID) {
if (buf.server !== serverID) {
return;
}
if (!buf.members.has(msg.prefix.name)) {
@ -572,7 +608,7 @@ export const State = {
buffers = new Map(state.buffers);
state.buffers.forEach((buf) => {
if (buf.server != serverID) {
if (buf.server !== serverID) {
return;
}
if (!buf.members.has(msg.prefix.name)) {
@ -613,7 +649,7 @@ export const State = {
return updateUser(msg.prefix.name, { account });
case "AWAY":
let awayMessage = msg.params[0];
return updateUser(msg.prefix.name, { away: !!awayMessage });
return updateUser(msg.prefix.name, { away: Boolean(awayMessage) });
case "TOPIC":
channel = msg.params[0];
topic = msg.params[1];
@ -644,13 +680,21 @@ export const State = {
return { members };
});
case "REDACT":
target = msg.params[0];
if (client.isMyNick(target)) {
target = msg.prefix.name;
}
return updateBuffer(target, (buf) => {
return { redacted: new Set(buf.redacted).add(msg.params[1]) };
});
case irc.RPL_MONONLINE:
case irc.RPL_MONOFFLINE:
targets = msg.params[1].split(",");
for (let target of targets) {
let prefix = irc.parsePrefix(target);
let update = updateUser(prefix.name, { offline: msg.command == irc.RPL_MONOFFLINE });
let update = updateUser(prefix.name, { offline: msg.command === irc.RPL_MONOFFLINE });
state = { ...state, ...update };
}

View File

@ -154,10 +154,6 @@ button.danger:hover {
padding: 2px 10px;
box-sizing: border-box;
}
#buffer-list li.active a {
color: white;
background-color: var(--gray);
}
#buffer-list li.error a {
color: red;
}
@ -167,6 +163,10 @@ button.danger:hover {
#buffer-list li.unread-highlight a {
color: #22009b;
}
#buffer-list li.active a {
color: white;
background-color: var(--gray);
}
#buffer-list li:not(.type-server) a {
padding-left: 20px;
}
@ -302,7 +302,7 @@ button.danger:hover {
.membership.admin {
color: blue;
}
.membership.op {
.membership.operator {
color: var(--green);
}
.membership.halfop {
@ -364,9 +364,15 @@ a {
color: var(--green);
}
#buffer-list li a, a.timestamp, a.nick {
color: var(--gray);
text-decoration: none;
}
#buffer-list li a,
a.nick {
color: var(--main-color);
}
a.timestamp {
color: var(--gray);
}
#buffer-list li a:hover, #buffer-list li a:active,
a.timestamp:hover, a.timestamp:active,
a.nick:hover, a.nick:active {
@ -388,6 +394,7 @@ details summary[role="button"] {
}
#buffer .logline {
white-space: pre-wrap;
overflow: auto;
}
#buffer .talk, #buffer .motd {
color: var(--main-color);
@ -590,16 +597,16 @@ ul.switcher-list .server {
scrollbar-color: var(--gray) transparent;
}
#buffer-list li.active a {
color: var(--sidebar-background);
background-color: white;
}
#buffer-list li.unread-message a {
color: var(--green);
}
#buffer-list li.unread-highlight a {
color: #0062cc;
}
#buffer-list li.active a {
color: var(--sidebar-background);
background-color: white;
}
#buffer-header .status-gone {
color: #fb885b;
@ -629,11 +636,6 @@ ul.switcher-list .server {
border-color: #3897ff;
}
#buffer-list li a,
a.nick {
color: var(--main-color);
}
#buffer {
background: var(--main-background);
}