Show All 17 Lines	import {
messageKey,		messageKey,
robotextForMessageInfo,		robotextForMessageInfo,
sortMessageInfoList,		sortMessageInfoList,
} from '../shared/message-utils.js';		} from '../shared/message-utils.js';
import { messageSpecs } from '../shared/messages/message-specs.js';		import { messageSpecs } from '../shared/messages/message-specs.js';
import {		import {
getSidebarItems,		getSidebarItems,
getAllInitialSidebarItems,		getAllInitialSidebarItems,
getAllFinalSidebarItems,		getCandidateSidebarItemsForThreadList,
type SidebarItem,		type SidebarItem,
} from '../shared/sidebar-item-utils.js';		} from '../shared/sidebar-item-utils.js';
import { threadInChatList, threadIsPending } from '../shared/thread-utils.js';		import { threadInChatList, threadIsPending } from '../shared/thread-utils.js';
import { messageTypes } from '../types/message-types-enum.js';		import { messageTypes } from '../types/message-types-enum.js';
import {		import {
type ComposableMessageInfo,		type ComposableMessageInfo,
isComposableMessageType,		isComposableMessageType,
type LocalMessageInfo,		type LocalMessageInfo,
▲ Show 20 Lines • Show All 71 Lines • ▼ Show 20 Lines	threadInfo => {
type: 'chatThreadItem',		type: 'chatThreadItem',
threadInfo,		threadInfo,
mostRecentNonLocalMessage,		mostRecentNonLocalMessage,
};		};

const getFinalChatThreadItem = async () => {		const getFinalChatThreadItem = async () => {
const lastUpdatedTimePromise = lastUpdatedTime();		const lastUpdatedTimePromise = lastUpdatedTime();

		const candidateSidebarItemsPromise =
		getCandidateSidebarItemsForThreadList(sidebars);

const lastUpdatedTimeIncludingSidebarsPromise = (async () => {		const lastUpdatedTimeIncludingSidebarsPromise = (async () => {
const lastUpdatedTimePromises = [		const candidateSidebarItems = await candidateSidebarItemsPromise;
lastUpdatedTimePromise,		const lastUpdatedTimes = candidateSidebarItems.map(
...sidebars.map(sidebar => sidebar.lastUpdatedTime()),		sidebarItem => sidebarItem.lastUpdatedTime,
];		);
const lastUpdatedTimes = await Promise.all(lastUpdatedTimePromises);
const max = lastUpdatedTimes.reduce((a, b) => Math.max(a, b), -1);		const max = lastUpdatedTimes.reduce((a, b) => Math.max(a, b), -1);
return max;		return max;
})();		})();

const [		const [
lastUpdatedTimeResult,		lastUpdatedTimeResult,
lastUpdatedTimeIncludingSidebars,		lastUpdatedTimeIncludingSidebars,
allSidebarItems,		candidateSidebarItems,
] = await Promise.all([		] = await Promise.all([
lastUpdatedTimePromise,		lastUpdatedTimePromise,
lastUpdatedTimeIncludingSidebarsPromise,		lastUpdatedTimeIncludingSidebarsPromise,
getAllFinalSidebarItems(sidebars),		candidateSidebarItemsPromise,
]);		]);

return {		return {
...chatThreadItemBase,		...chatThreadItemBase,
sidebars: getSidebarItems(allSidebarItems),		sidebars: getSidebarItems(candidateSidebarItems),
lastUpdatedTime: lastUpdatedTimeResult,		lastUpdatedTime: lastUpdatedTimeResult,
lastUpdatedTimeIncludingSidebars: lastUpdatedTimeIncludingSidebars,		lastUpdatedTimeIncludingSidebars: lastUpdatedTimeIncludingSidebars,
};		};
};		};

const lastUpdatedAtLeastTimeIncludingSidebars =		const lastUpdatedAtLeastTimeIncludingSidebars =
sidebars.length > 0		sidebars.length > 0
? Math.max(lastUpdatedAtLeastTime, sidebars[0].lastUpdatedAtLeastTime)		? Math.max(lastUpdatedAtLeastTime, sidebars[0].lastUpdatedAtLeastTime)
▲ Show 20 Lines • Show All 639 Lines • Show Last 20 Lines

[identity] Return use_new_flow in V1 login RPCsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 46240

services/identity/src/client_service.rs

[identity] Return use_new_flow in V1 login RPCs
ClosedPublic
Actions

Revision Contents
Changeset List