Show First 20 Lines • Show All 416 Lines • ▼ Show 20 Lines	): Promise<StateCheckResult> {
for (const key of invalidKeys) {		for (const key of invalidKeys) {
const [innerHashKey, id] = key.split('\|');		const [innerHashKey, id] = key.split('\|');
if (innerHashKey && id) {		if (innerHashKey && id) {
idsToFetch[innerHashKey]?.add(id);		idsToFetch[innerHashKey]?.add(id);
}		}
}		}

const fetchPromises = {};		const fetchPromises = {};
if (shouldFetchAll[serverStateSyncSpecs.threads.hashKey]) {		for (const spec of values(serverStateSyncSpecs)) {
fetchPromises.threadInfos = serverStateSyncSpecs.threads.fetch(		if (shouldFetchAll[spec.hashKey]) {
		fetchPromises[spec.hashKey] = spec.fetch(viewer, query);
		} else if (idsToFetch[spec.innerHashKey]?.size > 0) {
		fetchPromises[spec.hashKey] = spec.fetch(
viewer,		viewer,
query,		query,
);		idsToFetch[spec.innerHashKey],
} else if (idsToFetch[serverStateSyncSpecs.threads.innerHashKey]?.size > 0) {
fetchPromises.threadInfos = serverStateSyncSpecs.threads.fetch(
viewer,
query,
idsToFetch[serverStateSyncSpecs.threads.innerHashKey],
);
}
if (shouldFetchAll[serverStateSyncSpecs.entries.hashKey]) {
fetchPromises.entryInfos = serverStateSyncSpecs.entries.fetch(
viewer,
query,
);
} else if (idsToFetch[serverStateSyncSpecs.entries.innerHashKey]?.size > 0) {
fetchPromises.entryInfos = serverStateSyncSpecs.entries.fetch(
viewer,
query,
idsToFetch[serverStateSyncSpecs.entries.innerHashKey],
);		);
}		}
if (shouldFetchAll[serverStateSyncSpecs.users.hashKey]) {
fetchPromises.userInfos = serverStateSyncSpecs.users.fetch(viewer, query);
} else if (idsToFetch[serverStateSyncSpecs.users.innerHashKey]?.size > 0) {
fetchPromises.userInfos = serverStateSyncSpecs.users.fetch(
viewer,
query,
idsToFetch[serverStateSyncSpecs.users.innerHashKey],
);
}
if (shouldFetchAll[serverStateSyncSpecs.currentUser.hashKey]) {
fetchPromises.currentUserInfo = serverStateSyncSpecs.currentUser.fetch(
viewer,
query,
);
}		}
const fetchedData = await promiseAll(fetchPromises);		const fetchedData = await promiseAll(fetchPromises);

const hashesToCheck = {},		const hashesToCheck = {},
failUnmentioned = {},		failUnmentioned = {},
stateChanges = {};		stateChanges = {};
for (const key of invalidKeys) {		for (const key of invalidKeys) {
if (key === 'threadInfos') {		if (key === 'threadInfos') {
// Instead of returning all threadInfos, we want to narrow down and figure		// Instead of returning all threadInfos, we want to narrow down and figure
// out which threadInfos don't match first		// out which threadInfos don't match first
const { threadInfos } = fetchedData;		const threadInfos = fetchedData[serverStateSyncSpecs.threads.hashKey];
for (const threadID in threadInfos) {		for (const threadID in threadInfos) {
hashesToCheck[`threadInfo\|${threadID}`] = hash(threadInfos[threadID]);		hashesToCheck[`threadInfo\|${threadID}`] = hash(threadInfos[threadID]);
}		}
failUnmentioned.threadInfos = true;		failUnmentioned.threadInfos = true;
} else if (key === 'entryInfos') {		} else if (key === 'entryInfos') {
// Instead of returning all entryInfos, we want to narrow down and figure		// Instead of returning all entryInfos, we want to narrow down and figure
// out which entryInfos don't match first		// out which entryInfos don't match first
const { entryInfos } = fetchedData;		const entryInfos = fetchedData[serverStateSyncSpecs.entries.hashKey];
for (const entryID in entryInfos) {		for (const entryID in entryInfos) {
const entryInfo = entryInfos[entryID];		const entryInfo = entryInfos[entryID];
invariant(entryInfo, 'should be set');		invariant(entryInfo, 'should be set');
hashesToCheck[`entryInfo\|${entryID}`] = hash(entryInfo);		hashesToCheck[`entryInfo\|${entryID}`] = hash(entryInfo);
}		}
failUnmentioned.entryInfos = true;		failUnmentioned.entryInfos = true;
} else if (key === 'userInfos') {		} else if (key === 'userInfos') {
// Instead of returning all userInfos, we want to narrow down and figure		// Instead of returning all userInfos, we want to narrow down and figure
// out which userInfos don't match first		// out which userInfos don't match first
const { userInfos } = fetchedData;		const userInfos = fetchedData[serverStateSyncSpecs.users.hashKey];
for (const userID in userInfos) {		for (const userID in userInfos) {
hashesToCheck[`userInfo\|${userID}`] = hash(userInfos[userID]);		hashesToCheck[`userInfo\|${userID}`] = hash(userInfos[userID]);
}		}
failUnmentioned.userInfos = true;		failUnmentioned.userInfos = true;
} else if (key === 'currentUserInfo') {		} else if (key === 'currentUserInfo') {
stateChanges.currentUserInfo = fetchedData.currentUserInfo;		stateChanges.currentUserInfo =
		fetchedData[serverStateSyncSpecs.currentUser.hashKey];
} else if (key.startsWith('threadInfo\|')) {		} else if (key.startsWith('threadInfo\|')) {
const [, threadID] = key.split('\|');		const [, threadID] = key.split('\|');
const { threadInfos } = fetchedData;		const threadInfos = fetchedData[serverStateSyncSpecs.threads.hashKey];
const threadInfo = threadInfos[threadID];		const threadInfo = threadInfos[threadID];
if (!threadInfo) {		if (!threadInfo) {
if (!stateChanges.deleteThreadIDs) {		if (!stateChanges.deleteThreadIDs) {
stateChanges.deleteThreadIDs = [];		stateChanges.deleteThreadIDs = [];
}		}
stateChanges.deleteThreadIDs.push(threadID);		stateChanges.deleteThreadIDs.push(threadID);
continue;		continue;
}		}
if (!stateChanges.rawThreadInfos) {		if (!stateChanges.rawThreadInfos) {
stateChanges.rawThreadInfos = [];		stateChanges.rawThreadInfos = [];
}		}
stateChanges.rawThreadInfos.push(threadInfo);		stateChanges.rawThreadInfos.push(threadInfo);
} else if (key.startsWith('entryInfo\|')) {		} else if (key.startsWith('entryInfo\|')) {
const [, entryID] = key.split('\|');		const [, entryID] = key.split('\|');
const entryInfo = fetchedData.entryInfos[entryID];		const entryInfos = fetchedData[serverStateSyncSpecs.entries.hashKey];
		const entryInfo = entryInfos[entryID];
if (!entryInfo) {		if (!entryInfo) {
if (!stateChanges.deleteEntryIDs) {		if (!stateChanges.deleteEntryIDs) {
stateChanges.deleteEntryIDs = [];		stateChanges.deleteEntryIDs = [];
}		}
stateChanges.deleteEntryIDs.push(entryID);		stateChanges.deleteEntryIDs.push(entryID);
continue;		continue;
}		}
if (!stateChanges.rawEntryInfos) {		if (!stateChanges.rawEntryInfos) {
stateChanges.rawEntryInfos = [];		stateChanges.rawEntryInfos = [];
}		}
stateChanges.rawEntryInfos.push(entryInfo);		stateChanges.rawEntryInfos.push(entryInfo);
} else if (key.startsWith('userInfo\|')) {		} else if (key.startsWith('userInfo\|')) {
const { userInfos: fetchedUserInfos } = fetchedData;
const [, userID] = key.split('\|');		const [, userID] = key.split('\|');
const userInfo = fetchedUserInfos[userID];		const userInfos = fetchedData[serverStateSyncSpecs.users.hashKey];
		const userInfo = userInfos[userID];
if (!userInfo \|\| !userInfo.username) {		if (!userInfo \|\| !userInfo.username) {
if (!stateChanges.deleteUserInfoIDs) {		if (!stateChanges.deleteUserInfoIDs) {
stateChanges.deleteUserInfoIDs = [];		stateChanges.deleteUserInfoIDs = [];
}		}
stateChanges.deleteUserInfoIDs.push(userID);		stateChanges.deleteUserInfoIDs.push(userID);
} else {		} else {
if (!stateChanges.userInfos) {		if (!stateChanges.userInfos) {
stateChanges.userInfos = [];		stateChanges.userInfos = [];
Show All 29 Lines

[keyserver] Fetch specific data using specsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 30580

keyserver/src/socket/session-utils.js

[keyserver] Fetch specific data using specs
ClosedPublic
Actions

Revision Contents
Changeset List