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 - npm
- rsync - rsync
sources: sources:
- https://git.sr.ht/~emersion/gamja - https://codeberg.org/emersion/gamja.git
secrets: secrets:
- 77c7956b-003e-44f7-bb5c-2944b2047654 # deploy SSH key - 7a146c8e-aeb4-46e7-99bf-05af7486bbe9 # deploy SSH key
artifacts:
- gamja/gamja.tar.gz
tasks: tasks:
- setup: | - setup: |
cd gamja cd gamja
npm install --include=dev npm install --include=dev
- build: |
cd gamja
npm run build npm run build
tar -czf gamja.tar.gz -C dist .
- lint: |
cd gamja
npm run -- lint --max-warnings 0
- deploy: | - deploy: |
cd gamja/dist cd gamja/dist
[ "$(git rev-parse HEAD)" = "$(git rev-parse origin/master)" ] || complete-build [ "$(git rev-parse HEAD)" = "$(git rev-parse origin/master)" ] || complete-build
rsync --rsh="ssh -o StrictHostKeyChecking=no" -rP \ rsync --rsh="ssh -o StrictHostKeyChecking=no" -rP \
--delete --exclude=config.json \ --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. 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 ## Usage
@ -10,7 +10,7 @@ Requires an IRC WebSocket server.
First install dependencies: First install dependencies:
npm install --production npm install --omit=dev
Then [configure an HTTP server] to serve the gamja files. 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 ## 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]. in [#soju on Libera Chat].
## License ## License
@ -46,8 +46,8 @@ AGPLv3, see LICENSE.
Copyright (C) 2020 The gamja Contributors Copyright (C) 2020 The gamja Contributors
[gamja]: https://sr.ht/~emersion/gamja/ [gamja]: https://codeberg.org/emersion/gamja
[mailing list]: https://lists.sr.ht/~emersion/public-inbox [Codeberg]: https://codeberg.org/emersion/gamja
[issue tracker]: https://todo.sr.ht/~emersion/gamja [issue tracker]: https://todo.sr.ht/~emersion/gamja
[Parcel]: https://parceljs.org [Parcel]: https://parceljs.org
[configure an HTTP server]: doc/setup.md [configure an HTTP server]: doc/setup.md

View File

@ -53,6 +53,7 @@ function markServerBufferUnread(app) {
} }
const join = { const join = {
name: "join",
usage: "<name> [password]", usage: "<name> [password]",
description: "Join a channel", description: "Join a channel",
execute: (app, args) => { execute: (app, args) => {
@ -69,6 +70,7 @@ const join = {
}; };
const kick = { const kick = {
name: "kick",
usage: "<nick> [comment]", usage: "<nick> [comment]",
description: "Remove a user from the channel", description: "Remove a user from the channel",
execute: (app, args) => { execute: (app, args) => {
@ -83,10 +85,11 @@ const kick = {
}; };
const ban = { const ban = {
name: "ban",
usage: "[nick]", usage: "[nick]",
description: "Ban a user from the channel, or display the current ban list", description: "Ban a user from the channel, or display the current ban list",
execute: (app, args) => { execute: (app, args) => {
if (args.length == 0) { if (args.length === 0) {
let activeChannel = getActiveChannel(app); let activeChannel = getActiveChannel(app);
getActiveClient(app).send({ getActiveClient(app).send({
command: "MODE", command: "MODE",
@ -111,20 +114,22 @@ function givemode(app, args, mode) {
}); });
} }
export default { const commands = [
"away": { {
name: "away",
usage: "[message]", usage: "[message]",
description: "Set away message", description: "Set away message",
execute: (app, args) => { execute: (app, args) => {
const params = [] const params = [];
if (args.length) { if (args.length) {
params.push(args.join(" ")); params.push(args.join(" "));
} }
getActiveClient(app).send({command: "AWAY", params}); getActiveClient(app).send({ command: "AWAY", params });
}, },
}, },
"ban": ban, ban,
"buffer": { {
name: "buffer",
usage: "<name>", usage: "<name>",
description: "Switch to a buffer", description: "Switch to a buffer",
execute: (app, args) => { execute: (app, args) => {
@ -138,39 +143,45 @@ export default {
throw new Error("Unknown buffer"); throw new Error("Unknown buffer");
}, },
}, },
"close": { {
name: "close",
description: "Close the current buffer", description: "Close the current buffer",
execute: (app, args) => { execute: (app, args) => {
let activeBuffer = app.state.buffers.get(app.state.activeBuffer); 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"); throw new Error("Not in a user or channel buffer");
} }
app.close(activeBuffer.id); app.close(activeBuffer.id);
}, },
}, },
"deop": { {
name: "deop",
usage: "<nick>", usage: "<nick>",
description: "Remove operator status for a user on this channel", description: "Remove operator status for a user on this channel",
execute: (app, args) => givemode(app, args, "-o"), execute: (app, args) => givemode(app, args, "-o"),
}, },
"devoice": { {
name: "devoice",
usage: "<nick>", usage: "<nick>",
description: "Remove voiced status for a user on this channel", description: "Remove voiced status for a user on this channel",
execute: (app, args) => givemode(app, args, "-v"), execute: (app, args) => givemode(app, args, "-v"),
}, },
"disconnect": { {
name: "disconnect",
description: "Disconnect from the server", description: "Disconnect from the server",
execute: (app, args) => { execute: (app, args) => {
app.disconnect(); app.disconnect();
}, },
}, },
"help": { {
name: "help",
description: "Show help menu", description: "Show help menu",
execute: (app, args) => { execute: (app, args) => {
app.openHelp(); app.openHelp();
}, },
}, },
"invite": { {
name: "invite",
usage: "<nick>", usage: "<nick>",
description: "Invite a user to the channel", description: "Invite a user to the channel",
execute: (app, args) => { execute: (app, args) => {
@ -179,15 +190,17 @@ export default {
throw new Error("Missing nick"); throw new Error("Missing nick");
} }
let activeChannel = getActiveChannel(app); let activeChannel = getActiveChannel(app);
getActiveClient(app).send({ command: "INVITE", params: [ getActiveClient(app).send({
nick, activeChannel, command: "INVITE",
]}); params: [nick, activeChannel],
});
}, },
}, },
"j": join, { ...join, name: "j" },
"join": join, join,
"kick": kick, kick,
"kickban": { {
name: "kickban",
usage: "<target>", usage: "<target>",
description: "Ban a user and removes them from the channel", description: "Ban a user and removes them from the channel",
execute: (app, args) => { execute: (app, args) => {
@ -195,7 +208,8 @@ export default {
ban.execute(app, args); ban.execute(app, args);
}, },
}, },
"lusers": { {
name: "lusers",
usage: "[<mask> [<target>]]", usage: "[<mask> [<target>]]",
description: "Request user statistics about the network", description: "Request user statistics about the network",
execute: (app, args) => { execute: (app, args) => {
@ -203,7 +217,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"me": { {
name: "me",
usage: "<action>", usage: "<action>",
description: "Send an action message to the current buffer", description: "Send an action message to the current buffer",
execute: (app, args) => { execute: (app, args) => {
@ -213,7 +228,8 @@ export default {
app.privmsg(target, text); app.privmsg(target, text);
}, },
}, },
"mode": { {
name: "mode",
usage: "[target] [modes] [mode args...]", usage: "[target] [modes] [mode args...]",
description: "Query or change a channel or user mode", description: "Query or change a channel or user mode",
execute: (app, args) => { execute: (app, args) => {
@ -225,7 +241,8 @@ export default {
getActiveClient(app).send({ command: "MODE", params: args }); getActiveClient(app).send({ command: "MODE", params: args });
}, },
}, },
"motd": { {
name: "motd",
usage: "[server]", usage: "[server]",
description: "Get the Message Of The Day", description: "Get the Message Of The Day",
execute: (app, args) => { execute: (app, args) => {
@ -233,7 +250,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"msg": { {
name: "msg",
usage: "<target> <message>", usage: "<target> <message>",
description: "Send a message to a nickname or a channel", description: "Send a message to a nickname or a channel",
execute: (app, args) => { execute: (app, args) => {
@ -242,7 +260,8 @@ export default {
getActiveClient(app).send({ command: "PRIVMSG", params: [target, text] }); getActiveClient(app).send({ command: "PRIVMSG", params: [target, text] });
}, },
}, },
"nick": { {
name: "nick",
usage: "<nick>", usage: "<nick>",
description: "Change current nickname", description: "Change current nickname",
execute: (app, args) => { execute: (app, args) => {
@ -250,7 +269,8 @@ export default {
getActiveClient(app).send({ command: "NICK", params: [newNick] }); getActiveClient(app).send({ command: "NICK", params: [newNick] });
}, },
}, },
"notice": { {
name: "notice",
usage: "<target> <message>", usage: "<target> <message>",
description: "Send a notice to a nickname or a channel", description: "Send a notice to a nickname or a channel",
execute: (app, args) => { execute: (app, args) => {
@ -259,12 +279,14 @@ export default {
getActiveClient(app).send({ command: "NOTICE", params: [target, text] }); getActiveClient(app).send({ command: "NOTICE", params: [target, text] });
}, },
}, },
"op": { {
name: "op",
usage: "<nick>", usage: "<nick>",
description: "Give a user operator status on this channel", description: "Give a user operator status on this channel",
execute: (app, args) => givemode(app, args, "+o"), execute: (app, args) => givemode(app, args, "+o"),
}, },
"part": { {
name: "part",
usage: "[reason]", usage: "[reason]",
description: "Leave a channel", description: "Leave a channel",
execute: (app, args) => { execute: (app, args) => {
@ -277,7 +299,8 @@ export default {
getActiveClient(app).send({ command: "PART", params }); getActiveClient(app).send({ command: "PART", params });
}, },
}, },
"query": { {
name: "query",
usage: "<nick> [message]", usage: "<nick> [message]",
description: "Open a buffer to send messages to a nickname", description: "Open a buffer to send messages to a nickname",
execute: (app, args) => { execute: (app, args) => {
@ -293,11 +316,12 @@ export default {
} }
}, },
}, },
"quiet": { {
name: "quiet",
usage: "[nick]", usage: "[nick]",
description: "Quiet a user in the channel, or display the current quiet list", description: "Quiet a user in the channel, or display the current quiet list",
execute: (app, args) => { execute: (app, args) => {
if (args.length == 0) { if (args.length === 0) {
getActiveClient(app).send({ getActiveClient(app).send({
command: "MODE", command: "MODE",
params: [getActiveChannel(app), "+q"], params: [getActiveChannel(app), "+q"],
@ -307,13 +331,15 @@ export default {
} }
}, },
}, },
"quit": { {
name: "quit",
description: "Quit", description: "Quit",
execute: (app, args) => { execute: (app, args) => {
app.close({ name: SERVER_BUFFER }); app.close({ name: SERVER_BUFFER });
}, },
}, },
"quote": { {
name: "quote",
usage: "<command>", usage: "<command>",
description: "Send a raw IRC command to the server", description: "Send a raw IRC command to the server",
execute: (app, args) => { execute: (app, args) => {
@ -326,13 +352,15 @@ export default {
getActiveClient(app).send(msg); getActiveClient(app).send(msg);
}, },
}, },
"reconnect": { {
name: "reconnect",
description: "Reconnect to the server", description: "Reconnect to the server",
execute: (app, args) => { execute: (app, args) => {
app.reconnect(); app.reconnect();
}, },
}, },
"setname": { {
name: "setname",
usage: "<realname>", usage: "<realname>",
description: "Change current realname", description: "Change current realname",
execute: (app, args) => { execute: (app, args) => {
@ -345,7 +373,8 @@ export default {
// TODO: save to local storage // TODO: save to local storage
}, },
}, },
"stats": { {
name: "stats",
usage: "<query> [server]", usage: "<query> [server]",
description: "Request server statistics", description: "Request server statistics",
execute: (app, args) => { execute: (app, args) => {
@ -361,7 +390,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"topic": { {
name: "topic",
usage: "<topic>", usage: "<topic>",
description: "Change the topic of the current channel", description: "Change the topic of the current channel",
execute: (app, args) => { execute: (app, args) => {
@ -373,31 +403,30 @@ export default {
getActiveClient(app).send({ command: "TOPIC", params }); getActiveClient(app).send({ command: "TOPIC", params });
}, },
}, },
"unban": { {
name: "unban",
usage: "<nick>", usage: "<nick>",
description: "Remove a user from the ban list", description: "Remove a user from the ban list",
execute: (app, args) => { execute: (app, args) => {
return setUserHostMode(app, args, "-b"); return setUserHostMode(app, args, "-b");
}, },
}, },
"unquiet": { {
name: "unquiet",
usage: "<nick>", usage: "<nick>",
description: "Remove a user from the quiet list", description: "Remove a user from the quiet list",
execute: (app, args) => { execute: (app, args) => {
return setUserHostMode(app, args, "-q"); return setUserHostMode(app, args, "-q");
}, },
}, },
"unvoice": { {
usage: "<nick>", name: "voice",
description: "Remove a user from the voiced list",
execute: (app, args) => givemode(app, args, "-v"),
},
"voice": {
usage: "<nick>", usage: "<nick>",
description: "Give a user voiced status on this channel", description: "Give a user voiced status on this channel",
execute: (app, args) => givemode(app, args, "+v"), execute: (app, args) => givemode(app, args, "+v"),
}, },
"who": { {
name: "who",
usage: "<mask>", usage: "<mask>",
description: "Retrieve a list of users", description: "Retrieve a list of users",
execute: (app, args) => { execute: (app, args) => {
@ -405,7 +434,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"whois": { {
name: "whois",
usage: "<nick>", usage: "<nick>",
description: "Retrieve information about a user", description: "Retrieve information about a user",
execute: (app, args) => { execute: (app, args) => {
@ -417,7 +447,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"whowas": { {
name: "whowas",
usage: "<nick> [count]", usage: "<nick> [count]",
description: "Retrieve information about an offline user", description: "Retrieve information about an offline user",
execute: (app, args) => { execute: (app, args) => {
@ -428,7 +459,8 @@ export default {
markServerBufferUnread(app); markServerBufferUnread(app);
}, },
}, },
"list": { {
name: "list",
usage: "[filter]", usage: "[filter]",
description: "Retrieve a list of channels from a network", description: "Retrieve a list of channels from a network",
execute: (app, args) => { execute: (app, args) => {
@ -436,4 +468,6 @@ export default {
markServerBufferUnread(app); 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 // NODE_ENV is set by the Parcel build system
try { try {
return process.env.NODE_ENV === "production"; return process.env.NODE_ENV === "production";
} catch (err) { } catch (_err) {
return false; return false;
} }
} }
@ -94,7 +94,7 @@ function splitHostPort(str) {
function fillConnectParams(params) { function fillConnectParams(params) {
let host = window.location.host || "localhost:8080"; let host = window.location.host || "localhost:8080";
let proto = "wss:"; let proto = "wss:";
if (window.location.protocol != "https:") { if (window.location.protocol !== "https:") {
proto = "ws:"; proto = "ws:";
} }
let path = window.location.pathname || "/"; let path = window.location.pathname || "/";
@ -323,6 +323,8 @@ export default class App extends Component {
} }
if (queryParams.debug === "1") { if (queryParams.debug === "1") {
this.debug = true; this.debug = true;
} else if (queryParams.debug === "0") {
this.debug = false;
} }
if (window.location.hash) { 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) { if (connectParams.autoconnect) {
this.setState({ connectForm: false }); this.setState({ connectForm: false });
@ -437,6 +439,9 @@ export default class App extends Component {
clientSecret: this.config.oauth2.client_secret, clientSecret: this.config.oauth2.client_secret,
}); });
username = data.username; username = data.username;
if (!username) {
console.warn("Username missing from OAuth 2.0 token introspection response");
}
} catch (err) { } catch (err) {
console.warn("Failed to introspect OAuth 2.0 token:", 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 }); let stored = this.bufferStore.get({ name, server: client.params });
if (client.caps.enabled.has("draft/chathistory") && stored) { 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({ this.bufferStore.put({
@ -510,7 +517,7 @@ export default class App extends Component {
this.setState((state) => { this.setState((state) => {
let updated; let updated;
[id, updated] = State.createBuffer(state, name, serverID, client); [id, updated] = State.createBuffer(state, name, serverID, client);
isNew = !!updated; isNew = Boolean(updated);
return updated; return updated;
}); });
if (isNew) { if (isNew) {
@ -541,13 +548,9 @@ export default class App extends Component {
let client = this.clients.get(buf.server); let client = this.clients.get(buf.server);
let stored = this.bufferStore.get({ name: buf.name, server: client.params }); let stored = this.bufferStore.get({ name: buf.name, server: client.params });
let prevReadReceipt = getReceipt(stored, ReceiptType.READ); let prevReadReceipt = getReceipt(stored, ReceiptType.READ);
// TODO: only mark as read if user scrolled at the bottom let update = State.updateBuffer(state, buf.id, { prevReadReceipt });
let update = State.updateBuffer(state, buf.id, {
unread: Unread.NONE,
prevReadReceipt,
});
return { ...update, activeBuffer: buf.id }; return { activeBuffer: buf.id, ...update };
}, () => { }, () => {
if (!buf) { if (!buf) {
return; return;
@ -557,6 +560,35 @@ export default class App extends Component {
this.buffer.current.focus(); 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); let client = this.clients.get(buf.server);
for (let notif of this.messageNotifications) { for (let notif of this.messageNotifications) {
@ -578,23 +610,46 @@ export default class App extends Component {
} }
} }
let server = this.state.servers.get(buf.server); this.updateDocumentTitle();
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;
}
}); });
} }
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) { prepareChatMessage(serverID, msg) {
// Treat server-wide broadcasts as highlights. They're sent by server // Treat server-wide broadcasts as highlights. They're sent by server
// operators and can contain important information. // operators and can contain important information.
@ -634,7 +689,7 @@ export default class App extends Component {
} }
let msgUnread = Unread.NONE; 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 target = msg.params[0];
let text = msg.params[1]; let text = msg.params[1];
@ -649,7 +704,7 @@ export default class App extends Component {
msgUnread = Unread.MESSAGE; 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; let title = "New " + kind + " from " + msg.prefix.name;
if (client.isChannel(bufName)) { if (client.isChannel(bufName)) {
title += " in " + 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 // Open a new buffer if the message doesn't come from me or is a
// self-message // 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); this.createBuffer(serverID, bufName);
} }
@ -719,7 +774,7 @@ export default class App extends Component {
let prevReadReceipt = buf.prevReadReceipt; let prevReadReceipt = buf.prevReadReceipt;
let receipts = { [ReceiptType.DELIVERED]: receiptFromMessage(msg) }; 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); unread = Unread.union(unread, msgUnread);
} else { } else {
receipts[ReceiptType.READ] = receiptFromMessage(msg); receipts[ReceiptType.READ] = receiptFromMessage(msg);
@ -740,6 +795,10 @@ export default class App extends Component {
this.sendReadReceipt(client, stored); this.sendReadReceipt(client, stored);
} }
return { unread, prevReadReceipt }; 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 client = this.clients.get(serverID);
let chatHistoryBatch = irc.findBatchByType(msg, "chathistory"); 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; let target, channel, affectedBuffers;
switch (msg.command) { switch (msg.command) {
case "MODE": case "MODE":
@ -864,7 +929,7 @@ export default class App extends Component {
if (client.cm(msg.prefix.name) === client.cm(client.serverPrefix.name)) { if (client.cm(msg.prefix.name) === client.cm(client.serverPrefix.name)) {
target = SERVER_BUFFER; target = SERVER_BUFFER;
} else { } 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 })) { if (context && client.isChannel(context) && State.getBuffer(this.state, { server: serverID, name: context })) {
target = context; target = context;
} else { } 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 // Don't open a new buffer if this is just a NOTICE or a garbage
// CTCP message // CTCP message
let openNewBuffer = true; let openNewBuffer = true;
@ -888,13 +961,6 @@ export default class App extends Component {
target = SERVER_BUFFER; 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]; return [target];
case "JOIN": case "JOIN":
channel = msg.params[0]; channel = msg.params[0];
@ -914,7 +980,7 @@ export default class App extends Component {
affectedBuffers.push(chatHistoryBatch.params[0]); affectedBuffers.push(chatHistoryBatch.params[0]);
} else { } else {
this.state.buffers.forEach((buf) => { this.state.buffers.forEach((buf) => {
if (buf.server != serverID) { if (buf.server !== serverID) {
return; return;
} }
if (!buf.members.has(msg.prefix.name)) { if (!buf.members.has(msg.prefix.name)) {
@ -932,7 +998,7 @@ export default class App extends Component {
affectedBuffers.push(chatHistoryBatch.params[0]); affectedBuffers.push(chatHistoryBatch.params[0]);
} else { } else {
this.state.buffers.forEach((buf) => { this.state.buffers.forEach((buf) => {
if (buf.server != serverID) { if (buf.server !== serverID) {
return; return;
} }
if (!buf.members.has(msg.prefix.name)) { if (!buf.members.has(msg.prefix.name)) {
@ -1009,6 +1075,7 @@ export default class App extends Component {
case "ACK": case "ACK":
case "BOUNCER": case "BOUNCER":
case "MARKREAD": case "MARKREAD":
case "REDACT":
// Ignore these // Ignore these
return []; return [];
default: default:
@ -1078,13 +1145,14 @@ export default class App extends Component {
this.openURL(this.autoOpenURL); this.openURL(this.autoOpenURL);
this.autoOpenURL = null; this.autoOpenURL = null;
} }
break;
case "JOIN": case "JOIN":
channel = msg.params[0]; channel = msg.params[0];
if (client.isMyNick(msg.prefix.name)) { if (client.isMyNick(msg.prefix.name)) {
this.syncBufferUnread(serverID, channel); this.syncBufferUnread(serverID, channel);
} }
if (channel == this.switchToChannel) { if (channel === this.switchToChannel) {
this.switchBuffer({ server: serverID, name: channel }); this.switchBuffer({ server: serverID, name: channel });
this.switchToChannel = null; this.switchToChannel = null;
} }
@ -1210,10 +1278,11 @@ export default class App extends Component {
closed, closed,
receipts: { [ReceiptType.READ]: readReceipt }, receipts: { [ReceiptType.READ]: readReceipt },
}); });
this.updateDocumentTitle();
}); });
break; break;
default: 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]; let description = msg.params[msg.params.length - 1];
this.showError(description); this.showError(description);
} }
@ -1461,7 +1530,7 @@ export default class App extends Component {
servers.delete(buf.server); servers.delete(buf.server);
let connectForm = state.connectForm; let connectForm = state.connectForm;
if (servers.size == 0) { if (servers.size === 0) {
connectForm = true; connectForm = true;
} }
@ -1517,7 +1586,7 @@ export default class App extends Component {
let name = parts[0].toLowerCase().slice(1); let name = parts[0].toLowerCase().slice(1);
let args = parts.slice(1); let args = parts.slice(1);
let cmd = commands[name]; let cmd = commands.get(name);
if (!cmd) { if (!cmd) {
this.showError(`Unknown command "${name}" (run "/help" to get a command list)`); this.showError(`Unknown command "${name}" (run "/help" to get a command list)`);
return; return;
@ -1532,7 +1601,7 @@ export default class App extends Component {
} }
privmsg(target, text) { privmsg(target, text) {
if (target == SERVER_BUFFER) { if (target === SERVER_BUFFER) {
this.showError("Cannot send message in server buffer"); this.showError("Cannot send message in server buffer");
return; return;
} }
@ -1649,8 +1718,8 @@ export default class App extends Component {
} }
if (prefix.startsWith("/")) { if (prefix.startsWith("/")) {
let repl = fromList(Object.keys(commands), prefix.slice(1)); let repl = fromList([...commands.keys()], prefix.slice(1));
return repl.map(cmd => "/" + cmd); return repl.map((cmd) => "/" + cmd);
} }
// TODO: consider using the CHANTYPES ISUPPORT token here // TODO: consider using the CHANTYPES ISUPPORT token here
@ -1677,7 +1746,7 @@ export default class App extends Component {
async handleBufferScrollTop() { async handleBufferScrollTop() {
let buf = this.state.buffers.get(this.state.activeBuffer); let buf = this.state.buffers.get(this.state.activeBuffer);
if (!buf || buf.type == BufferType.SERVER) { if (!buf || buf.type === BufferType.SERVER) {
return; return;
} }
@ -1856,7 +1925,7 @@ export default class App extends Component {
this.dismissDialog(); this.dismissDialog();
if (this.state.dialogData && this.state.dialogData.id) { if (this.state.dialogData && this.state.dialogData.id) {
if (Object.keys(attrs).length == 0) { if (Object.keys(attrs).length === 0) {
return; return;
} }
@ -1894,7 +1963,7 @@ export default class App extends Component {
handleOpenSettingsClick() { handleOpenSettingsClick() {
let showProtocolHandler = false; 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")) { if (client.caps.enabled.has("soju.im/bouncer-networks")) {
showProtocolHandler = true; showProtocolHandler = true;
break; break;
@ -1922,6 +1991,11 @@ export default class App extends Component {
} }
handleWindowFocus() { 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 // When the user focuses gamja, send a PING to make sure we detect any
// network errors ASAP // network errors ASAP
@ -1932,7 +2006,9 @@ export default class App extends Component {
this.lastFocusPingDate = now; this.lastFocusPingDate = now;
for (let client of this.clients.values()) { for (let client of this.clients.values()) {
client.send({ command: "PING", params: ["gamja"] }); if (client.status === Client.Status.REGISTERED) {
client.send({ command: "PING", params: ["gamja"] });
}
} }
} }
@ -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) { if (this.state.connectForm) {
let status = activeServer ? activeServer.status : ServerStatus.DISCONNECTED; let status = activeServer ? activeServer.status : ServerStatus.DISCONNECTED;
let connecting = status === ServerStatus.CONNECTING || status === ServerStatus.REGISTERING; let connecting = status === ServerStatus.CONNECTING || status === ServerStatus.REGISTERING;
@ -1986,7 +2067,7 @@ export default class App extends Component {
let bufferHeader = null; let bufferHeader = null;
if (activeBuffer) { if (activeBuffer) {
let activeUser = null; let activeUser = null;
if (activeBuffer.type == BufferType.NICK) { if (activeBuffer.type === BufferType.NICK) {
activeUser = activeServer.users.get(activeBuffer.name); activeUser = activeServer.users.get(activeBuffer.name);
} }
@ -2010,7 +2091,7 @@ export default class App extends Component {
} }
let memberList = null; let memberList = null;
if (activeBuffer && activeBuffer.type == BufferType.CHANNEL) { if (activeBuffer && activeBuffer.type === BufferType.CHANNEL) {
memberList = html` memberList = html`
<section <section
id="member-list" id="member-list"
@ -2195,7 +2276,6 @@ export default class App extends Component {
<${Buffer} <${Buffer}
buffer=${activeBuffer} buffer=${activeBuffer}
server=${activeServer} server=${activeServer}
bouncerNetwork=${activeBouncerNetwork}
settings=${this.state.settings} settings=${this.state.settings}
onChannelClick=${this.handleChannelClick} onChannelClick=${this.handleChannelClick}
onNickClick=${this.handleNickClick} onNickClick=${this.handleNickClick}
@ -2208,6 +2288,7 @@ export default class App extends Component {
${memberList} ${memberList}
<${Composer} <${Composer}
ref=${this.composer} ref=${this.composer}
client=${activeClient}
readOnly=${composerReadOnly} readOnly=${composerReadOnly}
onSubmit=${this.handleComposerSubmit} onSubmit=${this.handleComposerSubmit}
autocomplete=${this.autocomplete} autocomplete=${this.autocomplete}

View File

@ -19,7 +19,7 @@ export default class NetworkForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.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 linkify from "../lib/linkify.js";
import { strip as stripANSI } from "../lib/ansi.js"; import { strip as stripANSI } from "../lib/ansi.js";
import { BufferType, ServerStatus, getServerName } from "../state.js"; import { BufferType, ServerStatus, getServerName } from "../state.js";
@ -214,7 +214,7 @@ export default function BufferHeader(props) {
} }
let name = props.buffer.name; let name = props.buffer.name;
if (props.buffer.type == BufferType.SERVER) { if (props.buffer.type === BufferType.SERVER) {
name = getServerName(props.server, props.bouncerNetwork); name = getServerName(props.server, props.bouncerNetwork);
} }

View File

@ -1,5 +1,6 @@
import * as irc from "../lib/irc.js"; 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"; import { BufferType, Unread, ServerStatus, getBufferURL, getServerName } from "../state.js";
function BufferItem(props) { function BufferItem(props) {
@ -15,18 +16,20 @@ function BufferItem(props) {
} }
let name = props.buffer.name; let name = props.buffer.name;
if (props.buffer.type == BufferType.SERVER) { if (props.buffer.type === BufferType.SERVER) {
name = getServerName(props.server, props.bouncerNetwork); name = getServerName(props.server, props.bouncerNetwork);
} }
let title;
let classes = ["type-" + props.buffer.type]; let classes = ["type-" + props.buffer.type];
if (props.active) { if (props.active) {
classes.push("active"); classes.push("active");
} }
if (props.buffer.unread != Unread.NONE) { if (props.buffer.unread !== Unread.NONE) {
classes.push("unread-" + props.buffer.unread); 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; let isError = props.server.status === ServerStatus.DISCONNECTED;
if (props.bouncerNetwork && props.bouncerNetwork.error) { if (props.bouncerNetwork && props.bouncerNetwork.error) {
isError = true; isError = true;
@ -34,12 +37,20 @@ function BufferItem(props) {
if (isError) { if (isError) {
classes.push("error"); 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` return html`
<li class="${classes.join(" ")}"> <li class="${classes.join(" ")}">
<a <a
href=${getBufferURL(props.buffer)} href=${getBufferURL(props.buffer)}
title=${title}
onClick=${handleClick} onClick=${handleClick}
onMouseDown=${handleMouseDown} onMouseDown=${handleMouseDown}
>${name}</a> >${name}</a>
@ -47,7 +58,6 @@ function BufferItem(props) {
`; `;
} }
export default function BufferList(props) { export default function BufferList(props) {
let items = Array.from(props.buffers.values()).map((buf) => { let items = Array.from(props.buffers.values()).map((buf) => {
let server = props.servers.get(buf.server); let server = props.servers.get(buf.server);
@ -65,7 +75,7 @@ export default function BufferList(props) {
bouncerNetwork=${bouncerNetwork} bouncerNetwork=${bouncerNetwork}
onClick=${() => props.onBufferClick(buf)} onClick=${() => props.onBufferClick(buf)}
onClose=${() => props.onBufferClose(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(); 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; let colorIndex = djb2(props.nick) % 16 + 1;
return html` 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) { if (showSeconds) {
timestamp += ":--"; timestamp += ":--";
} }
return html`<spam class="timestamp">${timestamp}</span>`; return html`<span class="timestamp">${timestamp}</span>`;
} }
let hh = date.getHours().toString().padStart(2, "0"); let hh = date.getHours().toString().padStart(2, "0");
@ -84,7 +94,7 @@ function canFoldMessage(msg) {
class LogLine extends Component { class LogLine extends Component {
shouldComponentUpdate(nextProps) { shouldComponentUpdate(nextProps) {
return this.props.message !== nextProps.message; return this.props.message !== nextProps.message || this.props.redacted !== nextProps.redacted;
} }
render() { render() {
@ -98,7 +108,11 @@ class LogLine extends Component {
function createNick(nick) { function createNick(nick) {
return html` return html`
<${Nick} nick=${nick} onClick=${() => onNickClick(nick)}/> <${Nick}
nick=${nick}
user=${server.users.get(nick)}
onClick=${() => onNickClick(nick)}
/>
`; `;
} }
function createChannel(channel) { function createChannel(channel) {
@ -120,7 +134,7 @@ class LogLine extends Component {
let ctcp = irc.parseCTCP(msg); let ctcp = irc.parseCTCP(msg);
if (ctcp) { if (ctcp) {
if (ctcp.command == "ACTION") { if (ctcp.command === "ACTION") {
lineClass = "me-tell"; lineClass = "me-tell";
content = html`* ${createNick(msg.prefix.name)} ${linkify(stripANSI(ctcp.param), onChannelClick)}`; content = html`* ${createNick(msg.prefix.name)} ${linkify(stripANSI(ctcp.param), onChannelClick)}`;
} else { } else {
@ -129,15 +143,20 @@ class LogLine extends Component {
`; `;
} }
} else { } else {
lineClass = "talk";
let prefix = "<", suffix = ">"; let prefix = "<", suffix = ">";
if (msg.command == "NOTICE") { if (msg.command === "NOTICE") {
lineClass += " notice";
prefix = suffix = "-"; 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; let allowedPrefixes = server.statusMsg;
if (target !== buf.name && allowedPrefixes) { if (target !== buf.name && allowedPrefixes) {
let parts = irc.parseTargetPrefix(target, allowedPrefixes); let parts = irc.parseTargetPrefix(target, allowedPrefixes);
@ -182,19 +201,94 @@ class LogLine extends Component {
break; break;
case "MODE": case "MODE":
target = msg.params[0]; 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`
${user} has ${verb} ${membership} privileges ${preposition} ${createNick(arg)}
`;
break;
}
}
content = html` content = html`
* ${createNick(msg.prefix.name)} sets mode ${msg.params.slice(1).join(" ")} ${user} sets mode ${msg.params.slice(1).join(" ")}
`; `;
// TODO: case-mapping if (server.cm(buf.name) !== server.cm(target)) {
if (buf.name !== target) {
content = html`${content} on ${target}`; content = html`${content} on ${target}`;
} }
break; break;
case "TOPIC": case "TOPIC":
let topic = msg.params[1]; let topic = msg.params[1];
content = html` if (topic) {
${createNick(msg.prefix.name)} changed the topic to: ${linkify(stripANSI(topic), onChannelClick)} 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; break;
case "INVITE": case "INVITE":
invitee = msg.params[0]; invitee = msg.params[0];
@ -275,7 +369,7 @@ class LogLine extends Component {
content = html`${createNick(buf.name)} is offline`; content = html`${createNick(buf.name)} is offline`;
break; break;
default: default:
if (irc.isError(msg.command) && msg.command != irc.ERR_NOMOTD) { if (irc.isError(msg.command) && msg.command !== irc.ERR_NOMOTD) {
lineClass = "error"; lineClass = "error";
} }
content = html`${msg.command} ${linkify(msg.params.join(" "))}`; content = html`${msg.command} ${linkify(msg.params.join(" "))}`;
@ -325,11 +419,16 @@ class FoldGroup extends Component {
render() { render() {
let msgs = this.props.messages; let msgs = this.props.messages;
let buf = this.props.buffer; let buf = this.props.buffer;
let server = this.props.server;
let onNickClick = this.props.onNickClick; let onNickClick = this.props.onNickClick;
function createNick(nick) { function createNick(nick) {
return html` 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 server = this.props.server;
let bouncerNetwork = this.props.bouncerNetwork;
let settings = this.props.settings; let settings = this.props.settings;
let serverName = server.name; let serverName = server.name;
let children = []; let children = [];
if (buf.type == BufferType.SERVER) { if (buf.type === BufferType.SERVER) {
children.push(html`<${NotificationNagger}/>`); 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}/>`); 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` children.push(html`
<${AccountNagger} <${AccountNagger}
server=${server} server=${server}
@ -617,6 +715,7 @@ export default class Buffer extends Component {
message=${msg} message=${msg}
buffer=${buf} buffer=${buf}
server=${server} server=${server}
redacted=${buf.redacted.has(msg.tags.msgid)}
onChannelClick=${onChannelClick} onChannelClick=${onChannelClick}
onNickClick=${onNickClick} onNickClick=${onNickClick}
onVerifyClick=${onVerifyClick} onVerifyClick=${onVerifyClick}
@ -624,7 +723,38 @@ export default class Buffer extends Component {
`; `;
} }
function createFoldGroup(msgs) { 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 partIndexes = new Map();
let keep = []; let keep = [];
msgs.forEach((msg, i) => { msgs.forEach((msg, i) => {
@ -635,6 +765,8 @@ export default class Buffer extends Component {
keep[partIndexes.get(msg.prefix.name)] = false; keep[partIndexes.get(msg.prefix.name)] = false;
partIndexes.delete(msg.prefix.name); partIndexes.delete(msg.prefix.name);
keep.push(false); keep.push(false);
} else if (msg.command === "NICK" && msg.prefix.name === msg.params[0]) {
keep.push(false);
} else { } else {
keep.push(true); 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"/>`); sep.push(html`<${UnreadSeparator} key="unread"/>`);
hasUnreadSeparator = true; hasUnreadSeparator = true;
} }
@ -689,7 +821,7 @@ export default class Buffer extends Component {
if (sep.length > 0) { if (sep.length > 0) {
children.push(createFoldGroup(foldMessages)); children.push(createFoldGroup(foldMessages));
children.push(sep); children.push(...sep);
foldMessages = []; foldMessages = [];
} }

View File

@ -1,5 +1,16 @@
import { html, Component, createRef } from "../lib/index.js"; 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 { export default class Composer extends Component {
state = { state = {
text: "", text: "",
@ -13,6 +24,9 @@ export default class Composer extends Component {
this.handleInput = this.handleInput.bind(this); this.handleInput = this.handleInput.bind(this);
this.handleSubmit = this.handleSubmit.bind(this); this.handleSubmit = this.handleSubmit.bind(this);
this.handleInputKeyDown = this.handleInputKeyDown.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.handleWindowKeyDown = this.handleWindowKeyDown.bind(this);
this.handleWindowPaste = this.handleWindowPaste.bind(this); this.handleWindowPaste = this.handleWindowPaste.bind(this);
} }
@ -116,6 +130,108 @@ export default class Composer extends Component {
this.setState({ text: autocomplete.text }); 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) { handleWindowKeyDown(event) {
// If an <input> or <button> is focused, ignore. // If an <input> or <button> is focused, ignore.
if (document.activeElement && document.activeElement !== document.body) { if (document.activeElement && document.activeElement !== document.body) {
@ -173,6 +289,11 @@ export default class Composer extends Component {
return; return;
} }
if (event.clipboardData.files.length > 0) {
this.handleInputPaste(event);
return;
}
let text = event.clipboardData.getData("text"); let text = event.clipboardData.getData("text");
event.preventDefault(); event.preventDefault();
@ -228,6 +349,9 @@ export default class Composer extends Component {
placeholder=${placeholder} placeholder=${placeholder}
enterkeyhint="send" enterkeyhint="send"
onKeyDown=${this.handleInputKeyDown} onKeyDown=${this.handleInputKeyDown}
onPaste=${this.handleInputPaste}
onDragOver=${this.handleDragOver}
onDrop=${this.handleDrop}
maxlength=${this.props.maxLen} maxlength=${this.props.maxLen}
/> />
</form> </form>

View File

@ -34,7 +34,7 @@ export default class ConnectForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.setState({ [target.name]: value });
} }

View File

@ -21,13 +21,13 @@ export default class Dialog extends Component {
} }
handleBackdropClick(event) { handleBackdropClick(event) {
if (event.target.className == "dialog") { if (event.target.className === "dialog") {
this.dismiss(); this.dismiss();
} }
} }
handleKeyDown(event) { handleKeyDown(event) {
if (event.key == "Escape") { if (event.key === "Escape") {
this.dismiss(); 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 { keybindings } from "../keybindings.js";
import commands from "../commands.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) { if (!window.matchMedia("(pointer: none)").matches) {
l.push(html` l.push(html`
<dt><strong>Middle mouse click</strong></dt> <dt><strong>Middle mouse click</strong></dt>
@ -37,8 +42,8 @@ function KeyBindingsHelp() {
} }
function CommandsHelp() { function CommandsHelp() {
let l = Object.keys(commands).map((name) => { let l = [...commands.keys()].map((name) => {
let cmd = commands[name]; let cmd = commands.get(name);
let usage = [html`<strong>/${name}</strong>`]; let usage = [html`<strong>/${name}</strong>`];
if (cmd.usage) { if (cmd.usage) {

View File

@ -18,7 +18,7 @@ export default class JoinForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.setState({ [target.name]: value });
} }

View File

@ -22,26 +22,7 @@ class MemberItem extends Component {
} }
render() { render() {
// XXX: If we were feeling creative we could generate unique colors for let title;
// 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 user = this.props.user; let user = this.props.user;
let classes = ["nick"]; let classes = ["nick"];
if (user) { if (user) {

View File

@ -1,21 +1,14 @@
import { html, Component } from "../lib/index.js"; import { html } from "../lib/index.js";
import * as irc from "../lib/irc.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",
};
export default function Membership(props) { export default function Membership(props) {
if (!this.props.value) { if (!this.props.value) {
return null; 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` return html`
<span class="membership ${name}" title=${name}> <span class="membership ${name}" title=${name}>
${this.props.value} ${this.props.value}

View File

@ -37,7 +37,7 @@ export default class NetworkForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.setState({ [target.name]: value });
} }
@ -46,10 +46,10 @@ export default class NetworkForm extends Component {
let params = {}; let params = {};
Object.keys(defaultParams).forEach((k) => { 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; return;
} }
if (this.props.isNew && defaultParams[k] == this.state[k]) { if (this.props.isNew && defaultParams[k] === this.state[k]) {
return; return;
} }
params[k] = this.state[k]; params[k] = this.state[k];

View File

@ -15,7 +15,7 @@ export default class RegisterForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.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(); let store = new Map();
@ -11,10 +11,10 @@ export default class ScrollManager extends Component {
isAtBottom() { isAtBottom() {
let target = this.props.target.current; 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 target = this.props.target.current;
let sticky = target.querySelectorAll(this.props.stickTo); 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() { restoreScrollPosition() {
@ -48,13 +48,13 @@ export default class ScrollManager extends Component {
} }
} }
if (target.scrollTop == 0) { if (target.scrollTop === 0) {
this.props.onScrollTop(); this.props.onScrollTop();
} }
} }
handleScroll() { handleScroll() {
if (this.props.target.current.scrollTop == 0) { if (this.props.target.current.scrollTop === 0) {
this.props.onScrollTop(); this.props.onScrollTop();
} }
} }
@ -64,9 +64,9 @@ export default class ScrollManager extends Component {
this.props.target.current.addEventListener("scroll", this.handleScroll); this.props.target.current.addEventListener("scroll", this.handleScroll);
} }
componentWillReceiveProps(nextProps) { getSnapshotBeforeUpdate(prevProps) {
if (this.props.scrollKey !== nextProps.scrollKey || this.props.children !== nextProps.children) { if (this.props.scrollKey !== prevProps.scrollKey || this.props.children !== prevProps.children) {
this.saveScrollPosition(); this.saveScrollPosition(prevProps.scrollKey);
} }
} }
@ -79,7 +79,7 @@ export default class ScrollManager extends Component {
componentWillUnmount() { componentWillUnmount() {
this.props.target.current.removeEventListener("scroll", this.handleScroll); this.props.target.current.removeEventListener("scroll", this.handleScroll);
this.saveScrollPosition(); this.saveScrollPosition(this.props.scrollKey);
} }
render() { render() {

View File

@ -15,7 +15,7 @@ export default class SettingsForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.setState({ [target.name]: value }, () => {
this.props.onChange(this.state); this.props.onChange(this.state);
}); });

View File

@ -15,7 +15,7 @@ export default class RegisterForm extends Component {
handleInput(event) { handleInput(event) {
let target = event.target; 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.setState({ [target.name]: value });
} }

View File

@ -63,7 +63,8 @@ if (remoteHost) {
ws.close(); ws.close();
}); });
client.on("error", () => { client.on("error", (err) => {
console.log(err);
ws.close(WS_BAD_GATEWAY); 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 ## IRC server
The `server` object configures the 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_id` (string): OAuth 2.0 client ID.
- `client_secret` (string): OAuth 2.0 client secret. - `client_secret` (string): OAuth 2.0 client secret.
- `scope` (string): OAuth 2.0 scope. - `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] ## [soju]
Add a WebSocket listener to soju, e.g. `listen wss://127.0.0.1:8080`. Then Add a WebSocket listener to soju, e.g. `listen ws+insecure://127.0.0.1:8080`.
configure your reverse proxy to serve gamja files and proxy `/socket` to soju. Then configure your reverse proxy to serve gamja files and proxy `/socket` to
soju.
## [webircgateway] ## [webircgateway]
@ -38,6 +39,7 @@ location /socket {
proxy_http_version 1.1; proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade; proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "Upgrade"; proxy_set_header Connection "Upgrade";
proxy_set_header Host $host;
proxy_set_header X-Forwarded-For $remote_addr; proxy_set_header X-Forwarded-For $remote_addr;
proxy_set_header X-Forwarded-Proto $scheme; proxy_set_header X-Forwarded-Proto $scheme;
} }

View File

@ -3,10 +3,11 @@
gamja settings can be overridden using URL query parameters: gamja settings can be overridden using URL query parameters:
- `server`: path or URL to the WebSocket server - `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) - `channels`: comma-separated list of channels to join (`#` needs to be escaped)
- `open`: [IRC URL] to open - `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 Alternatively, the channels can be set with the URL fragment (ie, by just
appending the channel name to the gamja URL). 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) { function getSiblingBuffer(buffers, bufID, delta) {
let bufList = Array.from(buffers.values()); let bufList = Array.from(buffers.values());
@ -40,6 +40,8 @@ export const keybindings = [
}); });
}); });
return { buffers }; return { buffers };
}, () => {
app.updateDocumentTitle();
}); });
}, },
}, },
@ -119,9 +121,9 @@ export function setup(app) {
return; return;
} }
candidates = candidates.filter((binding) => { 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; return;
} }
event.preventDefault(); event.preventDefault();

View File

@ -51,7 +51,7 @@ export function strip(text) {
if (isDigit(text[i + 1])) { if (isDigit(text[i + 1])) {
i++; i++;
} }
if (text[i + 1] == "," && isDigit(text[i + 2])) { if (text[i + 1] === "," && isDigit(text[i + 2])) {
i += 2; i += 2;
if (isDigit(text[i + 1])) { if (isDigit(text[i + 1])) {
i++; i++;
@ -63,7 +63,7 @@ export function strip(text) {
break; break;
} }
i += HEX_COLOR_LENGTH; 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; i += 1 + HEX_COLOR_LENGTH;
} }
break; break;

View File

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

View File

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

View File

@ -1,3 +1,5 @@
import * as base64 from "./base64.js";
// RFC 1459 // RFC 1459
export const RPL_WELCOME = "001"; export const RPL_WELCOME = "001";
export const RPL_YOURHOST = "002"; export const RPL_YOURHOST = "002";
@ -72,8 +74,24 @@ export const ERR_SASLTOOLONG = "905";
export const ERR_SASLABORTED = "906"; export const ERR_SASLABORTED = "906";
export const ERR_SASLALREADY = "907"; export const ERR_SASLALREADY = "907";
export const STD_MEMBERSHIPS = "~&@%+"; export const STD_MEMBERSHIP_NAMES = {
export const STD_CHANTYPES = "#&+!"; "~": "owner",
"&": "admin",
"@": "operator",
"%": "halfop",
"+": "voice",
};
export const STD_MEMBERSHIP_MODES = {
"~": "q",
"&": "a",
"@": "o",
"%": "h",
"+": "v",
};
const STD_MEMBERSHIPS = "~&@%+";
const STD_CHANTYPES = "#&+!";
const tagEscapeMap = { const tagEscapeMap = {
";": "\\:", ";": "\\:",
@ -102,10 +120,10 @@ export function parseTags(s) {
let parts = s.split("=", 2); let parts = s.split("=", 2);
let k = parts[0]; let k = parts[0];
let v = null; let v = null;
if (parts.length == 2) { if (parts.length === 2) {
v = unescapeTag(parts[1]); v = unescapeTag(parts[1]);
if (v.endsWith("\\")) { if (v.endsWith("\\")) {
v = v.slice(0, v.length - 1) v = v.slice(0, v.length - 1);
} }
} }
tags[k] = v; tags[k] = v;
@ -127,12 +145,6 @@ export function formatTags(tags) {
} }
export function parsePrefix(s) { export function parsePrefix(s) {
let prefix = {
name: null,
user: null,
host: null,
};
let host = null; let host = null;
let i = s.indexOf("@"); let i = s.indexOf("@");
if (i > 0) { if (i > 0) {
@ -229,7 +241,7 @@ export function formatMessage(msg) {
s += msg.command; s += msg.command;
if (msg.params && msg.params.length > 0) { if (msg.params && msg.params.length > 0) {
for (let i = 0; i < msg.params.length - 1; i++) { 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]); let last = String(msg.params[msg.params.length - 1]);
@ -260,10 +272,11 @@ export function parseTargetPrefix(s, allowedPrefixes = STD_MEMBERSHIPS) {
const alphaNum = (() => { const alphaNum = (() => {
try { try {
return new RegExp(/^[\p{L}0-9]$/, "u"); return new RegExp(/^[\p{L}0-9]$/, "u");
} catch (e) { } catch (_e) {
return new RegExp(/^[a-zA-Z0-9]$/, "u"); return new RegExp(/^[a-zA-Z0-9]$/, "u");
} }
})(); })();
const space = new RegExp(/^\s$/);
function isWordBoundary(ch) { function isWordBoundary(ch) {
switch (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) { export function isHighlight(msg, nick, cm) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") { if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return false; return false;
} }
nick = cm(nick); 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 return false; // Our own messages aren't highlights
} }
@ -302,7 +340,7 @@ export function isHighlight(msg, nick, cm) {
if (i + nick.length < text.length) { if (i + nick.length < text.length) {
right = text[i + nick.length]; right = text[i + nick.length];
} }
if (isWordBoundary(left) && isWordBoundary(right)) { if (isWordBoundary(left) && isWordBoundary(right) && !isURIPrefix(text.slice(0, i))) {
return true; return true;
} }
@ -311,7 +349,7 @@ export function isHighlight(msg, nick, cm) {
} }
export function isServerBroadcast(msg) { export function isServerBroadcast(msg) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") { if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return false; return false;
} }
return msg.params[0].startsWith("$"); return msg.params[0].startsWith("$");
@ -349,7 +387,7 @@ export function formatDate(date) {
} }
export function parseCTCP(msg) { export function parseCTCP(msg) {
if (msg.command != "PRIVMSG" && msg.command != "NOTICE") { if (msg.command !== "PRIVMSG" && msg.command !== "NOTICE") {
return null; return null;
} }
@ -469,7 +507,7 @@ export class Isupport {
return stdChanModes; return stdChanModes;
} }
let chanModes = this.raw.get("CHANMODES").split(","); let chanModes = this.raw.get("CHANMODES").split(",");
if (chanModes.length != 4) { if (chanModes.length !== 4) {
console.error("Invalid CHANMODES: ", this.raw.get("CHANMODES")); console.error("Invalid CHANMODES: ", this.raw.get("CHANMODES"));
return stdChanModes; return stdChanModes;
} }
@ -500,6 +538,10 @@ export class Isupport {
} }
return parseInt(this.raw.get("LINELEN"), 10); return parseInt(this.raw.get("LINELEN"), 10);
} }
filehost() {
return this.raw.get("SOJU.IM/FILEHOST");
}
} }
export function getMaxPrivmsgLen(isupport, nick, target) { export function getMaxPrivmsgLen(isupport, nick, target) {
@ -530,13 +572,13 @@ export const CaseMapping = {
let ch = str[i]; let ch = str[i];
if ("A" <= ch && ch <= "Z") { if ("A" <= ch && ch <= "Z") {
ch = ch.toLowerCase(); ch = ch.toLowerCase();
} else if (ch == "{") { } else if (ch === "{") {
ch = "["; ch = "[";
} else if (ch == "}") { } else if (ch === "}") {
ch = "]"; ch = "]";
} else if (ch == "\\") { } else if (ch === "\\") {
ch = "|"; ch = "|";
} else if (ch == "~") { } else if (ch === "~") {
ch = "^"; ch = "^";
} }
out += ch; out += ch;
@ -550,11 +592,11 @@ export const CaseMapping = {
let ch = str[i]; let ch = str[i];
if ("A" <= ch && ch <= "Z") { if ("A" <= ch && ch <= "Z") {
ch = ch.toLowerCase(); ch = ch.toLowerCase();
} else if (ch == "{") { } else if (ch === "{") {
ch = "["; ch = "[";
} else if (ch == "}") { } else if (ch === "}") {
ch = "]"; ch = "]";
} else if (ch == "\\") { } else if (ch === "\\") {
ch = "|"; ch = "|";
} }
out += ch; out += ch;
@ -912,3 +954,19 @@ export class CapRegistry {
return { command: "CAP", params: ["REQ", l.join(" ")] }; 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("irc");
linkifyjs.registerCustomProtocol("ircs"); linkifyjs.registerCustomProtocol("ircs");
linkifyjs.registerCustomProtocol("geo", true);
linkifyjs.registerPlugin("ircChannel", ({ scanner, parser, utils }) => { const IRCChannelToken = linkifyjs.createTokenClass("ircChannel", {
const { POUND, DOMAIN, TLD, LOCALHOST, UNDERSCORE, DOT, HYPHEN } = scanner.tokens; isLink: true,
const START_STATE = parser.start; toHref() {
return "irc:///" + this.v;
},
});
const Channel = utils.createTokenClass("ircChannel", { linkifyjs.registerPlugin("ircChannel", ({ scanner, parser }) => {
isLink: true, const { POUND, UNDERSCORE, DOT, HYPHEN } = scanner.tokens;
toHref() { const { alphanumeric } = scanner.tokens.groups;
return "irc:///" + this.toString();
},
});
const HASH_STATE = START_STATE.tt(POUND); const Prefix = parser.start.tt(POUND);
const Channel = new linkifyjs.State(IRCChannelToken);
const Divider = Channel.tt(DOT);
const CHAN_STATE = HASH_STATE.tt(DOMAIN, Channel); Prefix.ta(alphanumeric, Channel);
HASH_STATE.tt(TLD, CHAN_STATE); Prefix.tt(POUND, Channel);
HASH_STATE.tt(LOCALHOST, CHAN_STATE); Prefix.tt(UNDERSCORE, Channel);
HASH_STATE.tt(POUND, CHAN_STATE); Prefix.tt(DOT, Divider);
Prefix.tt(HYPHEN, Channel);
CHAN_STATE.tt(UNDERSCORE, CHAN_STATE); Channel.ta(alphanumeric, Channel);
CHAN_STATE.tt(DOMAIN, CHAN_STATE); Channel.tt(POUND, Channel);
CHAN_STATE.tt(TLD, CHAN_STATE); Channel.tt(UNDERSCORE, Channel);
CHAN_STATE.tt(LOCALHOST, CHAN_STATE); Channel.tt(HYPHEN, Channel);
Divider.ta(alphanumeric, Channel);
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);
}); });
export default function linkify(text, onClick) { export default function linkify(text, onClick) {
@ -46,7 +43,7 @@ export default function linkify(text, onClick) {
return; return;
} }
const prefix = text.substring(last, match.start) const prefix = text.substring(last, match.start);
children.push(prefix); children.push(prefix);
children.push(html` children.push(html`
@ -61,7 +58,7 @@ export default function linkify(text, onClick) {
last = match.end; last = match.end;
}); });
const suffix = text.substring(last) const suffix = text.substring(last);
children.push(suffix); children.push(suffix);
return children; 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 // TODO: use the state param to prevent cross-site request
// forgery // forgery
let params = { let params = {
response_type: "code", "response_type": "code",
client_id: clientId, "client_id": clientId,
redirect_uri: redirectUri, "redirect_uri": redirectUri,
}; };
if (scope) { if (scope) {
params.scope = scope; params.scope = scope;
@ -66,12 +66,12 @@ function buildPostHeaders(clientId, clientSecret) {
export async function exchangeCode({ serverMetadata, redirectUri, code, clientId, clientSecret }) { export async function exchangeCode({ serverMetadata, redirectUri, code, clientId, clientSecret }) {
let data = { let data = {
grant_type: "authorization_code", "grant_type": "authorization_code",
code, code,
redirect_uri: redirectUri, "redirect_uri": redirectUri,
}; };
if (!clientSecret) { if (!clientSecret) {
data.client_id = clientId; data["client_id"] = clientId;
} }
let resp = await fetch(serverMetadata.token_endpoint, { let resp = await fetch(serverMetadata.token_endpoint, {

3687
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

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

View File

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

View File

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