Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d9c797f3f5 | ||
|
|
9b2ec91dd6 |
@@ -57,7 +57,7 @@ import { createUploadAtom, UploadSuccess } from '../../../state/upload';
|
|||||||
import { CompactUploadCardRenderer } from '../../../components/upload-card';
|
import { CompactUploadCardRenderer } from '../../../components/upload-card';
|
||||||
import { useCapabilities } from '../../../hooks/useCapabilities';
|
import { useCapabilities } from '../../../hooks/useCapabilities';
|
||||||
import { Presence, useUserPresence } from '../../../hooks/useUserPresence';
|
import { Presence, useUserPresence } from '../../../hooks/useUserPresence';
|
||||||
import { noteLocalStatusWrite } from '../../../utils/ownStatusSync';
|
import { DND_STATUS_SENTINEL, noteLocalStatusWrite } from '../../../utils/ownStatusSync';
|
||||||
import { ProfileDecoration } from './ProfileDecoration';
|
import { ProfileDecoration } from './ProfileDecoration';
|
||||||
import { EmojiBoard } from '../../../components/emoji-board';
|
import { EmojiBoard } from '../../../components/emoji-board';
|
||||||
import { useStatusPresets } from '../../../hooks/useStatusPresets';
|
import { useStatusPresets } from '../../../hooks/useStatusPresets';
|
||||||
@@ -396,7 +396,8 @@ function ProfileStatus() {
|
|||||||
const [presenceStatus] = useSetting(settingsAtom, 'presenceStatus');
|
const [presenceStatus] = useSetting(settingsAtom, 'presenceStatus');
|
||||||
const [hidePresence] = useSetting(settingsAtom, 'hidePresence');
|
const [hidePresence] = useSetting(settingsAtom, 'hidePresence');
|
||||||
|
|
||||||
const initialStatus = presence?.status ?? localStorage.getItem(STATUS_MSG_KEY(userId)) ?? '';
|
const serverStatus = presence?.status === DND_STATUS_SENTINEL ? undefined : presence?.status;
|
||||||
|
const initialStatus = serverStatus ?? localStorage.getItem(STATUS_MSG_KEY(userId)) ?? '';
|
||||||
const [statusMsg, setStatusMsg] = useState<string>(initialStatus);
|
const [statusMsg, setStatusMsg] = useState<string>(initialStatus);
|
||||||
// True while the user has unsaved local edits — prevents a server presence
|
// True while the user has unsaved local edits — prevents a server presence
|
||||||
// echo from overwriting what the user is currently typing/inserting.
|
// echo from overwriting what the user is currently typing/inserting.
|
||||||
@@ -442,6 +443,9 @@ function ProfileStatus() {
|
|||||||
pendingAppliedRef.current = null; // window elapsed — accept external changes
|
pendingAppliedRef.current = null; // window elapsed — accept external changes
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
// [Gitea #283] "dnd" is the Do Not Disturb sentinel, not something the user
|
||||||
|
// typed: don't show it in the status field or keep it as their status.
|
||||||
|
if (remoteStatus === DND_STATUS_SENTINEL) return;
|
||||||
if (remoteStatus) {
|
if (remoteStatus) {
|
||||||
setStatusMsg(remoteStatus);
|
setStatusMsg(remoteStatus);
|
||||||
localStorage.setItem(STATUS_MSG_KEY(userId), remoteStatus);
|
localStorage.setItem(STATUS_MSG_KEY(userId), remoteStatus);
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import { useEffect, useRef } from 'react';
|
import { useEffect, useRef } from 'react';
|
||||||
|
import { SetPresence } from 'matrix-js-sdk';
|
||||||
import { PresenceDeduper, PresenceWrite } from '../utils/presenceWrite';
|
import { PresenceDeduper, PresenceWrite } from '../utils/presenceWrite';
|
||||||
import { useMatrixClient } from './useMatrixClient';
|
import { useMatrixClient } from './useMatrixClient';
|
||||||
import { getLastLocalStatusWrite, pickHeartbeatStatus } from '../utils/ownStatusSync';
|
import { getLastLocalStatusWrite, pickHeartbeatStatus } from '../utils/ownStatusSync';
|
||||||
@@ -90,11 +91,21 @@ export function usePresenceUpdater() {
|
|||||||
return status;
|
return status;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
// [Gitea #282] A one-off PUT /presence doesn't stick: the SDK long-polls
|
||||||
|
// /sync with set_presence=online by default and Synapse treats every sync
|
||||||
|
// as "online", so Invisible / Idle / DND flipped back within seconds. Tell
|
||||||
|
// the sync loop which presence to report too (as Element does).
|
||||||
|
const syncPresence = (presence: SetPresence) => {
|
||||||
|
mx.setSyncPresence(presence).catch(() => undefined);
|
||||||
|
};
|
||||||
|
|
||||||
const setOnline = async () => {
|
const setOnline = async () => {
|
||||||
|
syncPresence(SetPresence.Online);
|
||||||
const status = await resolveStatus();
|
const status = await resolveStatus();
|
||||||
return send({ presence: 'online', ...(status ? { status_msg: status } : {}) }, 'online');
|
return send({ presence: 'online', ...(status ? { status_msg: status } : {}) }, 'online');
|
||||||
};
|
};
|
||||||
const setUnavailable = async (statusMsg?: string) => {
|
const setUnavailable = async (statusMsg?: string) => {
|
||||||
|
syncPresence(SetPresence.Unavailable);
|
||||||
const status = await resolveStatus();
|
const status = await resolveStatus();
|
||||||
return send(
|
return send(
|
||||||
{
|
{
|
||||||
@@ -104,7 +115,10 @@ export function usePresenceUpdater() {
|
|||||||
'unavailable',
|
'unavailable',
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
const setOffline = () => send({ presence: 'offline', status_msg: '' }, 'offline');
|
const setOffline = () => {
|
||||||
|
syncPresence(SetPresence.Offline);
|
||||||
|
return send({ presence: 'offline', status_msg: '' }, 'offline');
|
||||||
|
};
|
||||||
|
|
||||||
// Manual presence overrides — no activity tracking needed.
|
// Manual presence overrides — no activity tracking needed.
|
||||||
if (hidePresence || presenceStatus === 'invisible') {
|
if (hidePresence || presenceStatus === 'invisible') {
|
||||||
|
|||||||
@@ -48,3 +48,34 @@ test("a fresh local save wins over a server read that hasn't caught up", () => {
|
|||||||
'previous',
|
'previous',
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test('pickHeartbeatStatus: the "dnd" sentinel is never adopted as the user status (#283)', () => {
|
||||||
|
const base = { lastLocalWriteAt: 0, now: 100_000 };
|
||||||
|
// leaving DND: the server still says "dnd" → restore the real local status
|
||||||
|
assert.equal(
|
||||||
|
pickHeartbeatStatus({
|
||||||
|
...base,
|
||||||
|
local: '🎮 Gaming',
|
||||||
|
server: { presence: 'unavailable', status_msg: 'dnd' },
|
||||||
|
}),
|
||||||
|
'🎮 Gaming',
|
||||||
|
);
|
||||||
|
// a local copy that had absorbed the sentinel becomes empty, not "dnd"
|
||||||
|
assert.equal(
|
||||||
|
pickHeartbeatStatus({
|
||||||
|
...base,
|
||||||
|
local: 'dnd',
|
||||||
|
server: { presence: 'online', status_msg: 'dnd' },
|
||||||
|
}),
|
||||||
|
'',
|
||||||
|
);
|
||||||
|
// ordinary statuses are unaffected
|
||||||
|
assert.equal(
|
||||||
|
pickHeartbeatStatus({
|
||||||
|
...base,
|
||||||
|
local: 'old',
|
||||||
|
server: { presence: 'online', status_msg: 'new' },
|
||||||
|
}),
|
||||||
|
'new',
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|||||||
@@ -9,6 +9,9 @@
|
|||||||
* overridden by a server read that hasn't caught up yet.
|
* overridden by a server read that hasn't caught up yet.
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
/** The status_msg Lotus sends for Do Not Disturb (see usePresenceUpdater). */
|
||||||
|
export const DND_STATUS_SENTINEL = 'dnd';
|
||||||
|
|
||||||
/** Trust this device's own copy for this long after it saved or cleared it. */
|
/** Trust this device's own copy for this long after it saved or cleared it. */
|
||||||
export const LOCAL_WRITE_GRACE_MS = 15_000;
|
export const LOCAL_WRITE_GRACE_MS = 15_000;
|
||||||
|
|
||||||
@@ -37,7 +40,12 @@ export const pickHeartbeatStatus = ({
|
|||||||
lastLocalWriteAt: number;
|
lastLocalWriteAt: number;
|
||||||
now: number;
|
now: number;
|
||||||
}): string => {
|
}): string => {
|
||||||
if (!server || server.presence === 'offline') return local;
|
// [Gitea #283] Lotus encodes Do Not Disturb as status_msg "dnd", so a device
|
||||||
if (now - writtenAt < LOCAL_WRITE_GRACE_MS) return local;
|
// leaving DND must not adopt that sentinel as the user's status — keep (and
|
||||||
|
// so restore) the real one it holds locally.
|
||||||
|
const mine = local === DND_STATUS_SENTINEL ? '' : local;
|
||||||
|
if (!server || server.presence === 'offline') return mine;
|
||||||
|
if (now - writtenAt < LOCAL_WRITE_GRACE_MS) return mine;
|
||||||
|
if (server.status_msg === DND_STATUS_SENTINEL) return mine;
|
||||||
return server.status_msg ?? '';
|
return server.status_msg ?? '';
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user