[lib] Check the timestamps when joining threads
ClosedPublic
Actions

Show All 15 Lines	import {
cookieSelector,		cookieSelector,
deviceTokenSelector,		deviceTokenSelector,
} from '../selectors/keyserver-selectors.js';		} from '../selectors/keyserver-selectors.js';
import { isLoggedInToKeyserver } from '../selectors/user-selectors.js';		import { isLoggedInToKeyserver } from '../selectors/user-selectors.js';
import { IdentityClientContext } from '../shared/identity-client-context.js';		import { IdentityClientContext } from '../shared/identity-client-context.js';
import { OlmSessionCreatorContext } from '../shared/olm-session-creator-context.js';		import { OlmSessionCreatorContext } from '../shared/olm-session-creator-context.js';
import type { BaseSocketProps } from '../socket/socket.react.js';		import type { BaseSocketProps } from '../socket/socket.react.js';
import { logInActionSources } from '../types/account-types.js';		import { logInActionSources } from '../types/account-types.js';
		import { authoritativeKeyserverID } from '../utils/authoritative-keyserver.js';
import { useDispatchActionPromise } from '../utils/redux-promise-utils.js';		import { useDispatchActionPromise } from '../utils/redux-promise-utils.js';
import { useSelector } from '../utils/redux-utils.js';		import { useSelector } from '../utils/redux-utils.js';
import { usingCommServicesAccessToken } from '../utils/services-utils.js';		import { usingCommServicesAccessToken } from '../utils/services-utils.js';
import sleep from '../utils/sleep.js';		import sleep from '../utils/sleep.js';
import { ashoatKeyserverID } from '../utils/validation-utils.js';

type Props = {		type Props = {
...BaseSocketProps,		...BaseSocketProps,
+socketComponent: React.ComponentType<BaseSocketProps>,		+socketComponent: React.ComponentType<BaseSocketProps>,
};		};

const AUTH_RETRY_DELAY_MS = 60000;		const AUTH_RETRY_DELAY_MS = 60000;
const CANCELLED_ERROR = 'cancelled';		const CANCELLED_ERROR = 'cancelled';
Show All 13 Lines	function KeyserverConnectionHandler(props: Props) {
const dataLoaded = useSelector(state => state.dataLoaded);		const dataLoaded = useSelector(state => state.dataLoaded);

const keyserverDeviceToken = useSelector(deviceTokenSelector(keyserverID));		const keyserverDeviceToken = useSelector(deviceTokenSelector(keyserverID));
// We have an assumption that we should be always connected to Ashoat's		// We have an assumption that we should be always connected to Ashoat's
// keyserver. It is possible that a token which it has is correct, so we can		// keyserver. It is possible that a token which it has is correct, so we can
// try to use it. In worst case it is invalid and our push-handler will try		// try to use it. In worst case it is invalid and our push-handler will try
// to fix it.		// to fix it.
const ashoatKeyserverDeviceToken = useSelector(		const ashoatKeyserverDeviceToken = useSelector(
deviceTokenSelector(ashoatKeyserverID),		deviceTokenSelector(authoritativeKeyserverID()),
);		);
const deviceToken = keyserverDeviceToken ?? ashoatKeyserverDeviceToken;		const deviceToken = keyserverDeviceToken ?? ashoatKeyserverDeviceToken;

const navInfo = useSelector(state => state.navInfo);		const navInfo = useSelector(state => state.navInfo);
const calendarFilters = useSelector(state => state.calendarFilters);		const calendarFilters = useSelector(state => state.calendarFilters);
const calendarQuery = React.useMemo(() => {		const calendarQuery = React.useMemo(() => {
const filters = filterThreadIDsInFilterList(		const filters = filterThreadIDsInFilterList(
calendarFilters,		calendarFilters,
▲ Show 20 Lines • Show All 94 Lines • ▼ Show 20 Lines	const promise = (async () => {
return;		return;
}		}

console.log(		console.log(
`Error while authenticating to keyserver with id ${keyserverID}`,		`Error while authenticating to keyserver with id ${keyserverID}`,
e,		e,
);		);

if (!dataLoaded && keyserverID === ashoatKeyserverID) {		if (!dataLoaded && keyserverID === authoritativeKeyserverID()) {
await dispatchActionPromise(logOutActionTypes, callLogOut());		await dispatchActionPromise(logOutActionTypes, callLogOut());
}		}
} finally {		} finally {
if (!cancelled) {		if (!cancelled) {
await sleep(AUTH_RETRY_DELAY_MS);		await sleep(AUTH_RETRY_DELAY_MS);
setAuthInProgress(false);		setAuthInProgress(false);
}		}
}		}
▲ Show 20 Lines • Show All 41 Lines • ▼ Show 20 Lines	React.useEffect(() => {
if (authInProgress) {		if (authInProgress) {
return;		return;
}		}

const [, cancel] = performAuth();		const [, cancel] = performAuth();
cancelPendingAuth.current = cancel;		cancelPendingAuth.current = cancel;
}, [authInProgress, hasAccessToken, isUserAuthenticated, performAuth]);		}, [authInProgress, hasAccessToken, isUserAuthenticated, performAuth]);

if (keyserverID !== ashoatKeyserverID) {		if (keyserverID !== authoritativeKeyserverID()) {
return null;		return null;
}		}
return <Socket {...socketProps} />;		return <Socket {...socketProps} />;
}		}

const Handler: React.ComponentType<Props> = React.memo<Props>(		const Handler: React.ComponentType<Props> = React.memo<Props>(
KeyserverConnectionHandler,		KeyserverConnectionHandler,
);		);

export default Handler;		export default Handler;

[lib] Check the timestamps when joining threadsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 43933

lib/shared/dm-ops/join-thread-spec.js

[lib] Check the timestamps when joining threads
ClosedPublic
Actions

Revision Contents
Changeset List