[services-lib] Add method to download blobs
ClosedPublic
Actions

Show First 20 Lines • Show All 342 Lines • ▼ Show 20 Lines	query.append(SQL`
ORDER BY tw.threadID, tw.time DESC, tw.id DESC		ORDER BY tw.threadID, tw.time DESC, tw.id DESC
`);		`);

const [result] = await dbQuery(query);		const [result] = await dbQuery(query);
const derivedMessages = await fetchDerivedMessages(result, viewer);		const derivedMessages = await fetchDerivedMessages(result, viewer);
const messages = await parseMessageSQLResult(result, derivedMessages, viewer);		const messages = await parseMessageSQLResult(result, derivedMessages, viewer);

const rawMessageInfos = [];		const rawMessageInfos = [];
const threadToMessageCount = new Map();		const threadToMessageCount = new Map<string, number>();
for (const message of messages) {		for (const message of messages) {
const { rawMessageInfo } = message;		const { rawMessageInfo } = message;
rawMessageInfos.push(rawMessageInfo);		rawMessageInfos.push(rawMessageInfo);
const { threadID } = rawMessageInfo;		const { threadID } = rawMessageInfo;
const currentCountValue = threadToMessageCount.get(threadID);		const currentCountValue = threadToMessageCount.get(threadID);
const currentCount = currentCountValue ? currentCountValue : 0;		const currentCount = currentCountValue ? currentCountValue : 0;
threadToMessageCount.set(threadID, currentCount + 1);		threadToMessageCount.set(threadID, currentCount + 1);
}		}
▲ Show 20 Lines • Show All 479 Lines • ▼ Show 20 Lines	SELECT m.id, (
ORDER BY time DESC, id DESC		ORDER BY time DESC, id DESC
LIMIT 1		LIMIT 1
) content		) content
FROM messages m		FROM messages m
WHERE m.id IN(${messageIDs})		WHERE m.id IN(${messageIDs})
`;		`;

const [result] = await dbQuery(latestEditedMessageQuery);		const [result] = await dbQuery(latestEditedMessageQuery);
const latestContentByID = new Map();		const latestContentByID = new Map<string, EditMessageContent>();
for (const row of result) {		for (const row of result) {
if (!row.content) {		if (!row.content) {
continue;		continue;
}		}
const content = JSON.parse(row.content);		const content = JSON.parse(row.content);
latestContentByID.set(row.id.toString(), content);		latestContentByID.set(row.id.toString(), content);
}		}

▲ Show 20 Lines • Show All 181 Lines • Show Last 20 Lines

[services-lib] Add method to download blobsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 29818

services/comm-services-lib/src/blob/client.rs

[services-lib] Add method to download blobs
ClosedPublic
Actions

Revision Contents
Changeset List