Tidy up the storage service logs

This commit is contained in:
Josh Perez 2020-10-07 19:44:55 -04:00 committed by Josh Perez
parent 776b500142
commit c7308b485b
2 changed files with 33 additions and 32 deletions

View file

@ -185,9 +185,8 @@ async function generateManifest(
storageItem = await encryptRecord(storageID, storageRecord); storageItem = await encryptRecord(storageID, storageRecord);
} catch (err) { } catch (err) {
window.log.error( window.log.error(
`storageService.generateManifest: encrypt record failed: ${ 'storageService.generateManifest: encrypt record failed:',
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
}`
); );
throw err; throw err;
} }
@ -268,7 +267,7 @@ async function generateManifest(
) { ) {
window.log.info( window.log.info(
'storageService.generateManifest: removing duplicate identifier from manifest', 'storageService.generateManifest: removing duplicate identifier from manifest',
storageID identifier.type
); );
manifestRecordKeys.delete(identifier); manifestRecordKeys.delete(identifier);
} }
@ -282,7 +281,7 @@ async function generateManifest(
if (hasDeleteKey) { if (hasDeleteKey) {
window.log.info( window.log.info(
'storageService.generateManifest: removing key which has been deleted', 'storageService.generateManifest: removing key which has been deleted',
storageID identifier.type
); );
manifestRecordKeys.delete(identifier); manifestRecordKeys.delete(identifier);
} }
@ -291,8 +290,7 @@ async function generateManifest(
if (identifier.type === ITEM_TYPE.ACCOUNT) { if (identifier.type === ITEM_TYPE.ACCOUNT) {
if (hasAccountType) { if (hasAccountType) {
window.log.info( window.log.info(
'storageService.generateManifest: removing duplicate account', 'storageService.generateManifest: removing duplicate account'
storageID
); );
manifestRecordKeys.delete(identifier); manifestRecordKeys.delete(identifier);
} }
@ -401,9 +399,8 @@ async function uploadManifest(
}); });
} catch (err) { } catch (err) {
window.log.error( window.log.error(
`storageService.uploadManifest: failed! ${ 'storageService.uploadManifest: failed!',
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
}`
); );
if (err.code === 409) { if (err.code === 409) {
@ -535,9 +532,8 @@ async function fetchManifest(
} }
} catch (err) { } catch (err) {
window.log.error( window.log.error(
`storageService.fetchManifest: failed! ${ 'storageService.fetchManifest: failed!',
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
}`
); );
if (err.code === 404) { if (err.code === 404) {
@ -592,15 +588,12 @@ async function mergeRecord(
hasConflict = await mergeAccountRecord(storageID, storageRecord.account); hasConflict = await mergeAccountRecord(storageID, storageRecord.account);
} else { } else {
isUnsupported = true; isUnsupported = true;
window.log.info( window.log.info('storageService.mergeRecord: Unknown record:', itemType);
`storageService.mergeRecord: Unknown record: ${itemType}::${storageID}`
);
} }
} catch (err) { } catch (err) {
hasError = true; hasError = true;
window.log.error( window.log.error(
'storageService.mergeRecord: merging record failed', 'storageService.mergeRecord: merging record failed',
storageID,
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
); );
} }
@ -656,7 +649,17 @@ async function processManifest(
}); });
window.log.info( window.log.info(
`storageService.processManifest: localKeys.length ${localKeys.length}` 'storageService.processManifest: local keys:',
localKeys.length
);
window.log.info(
'storageService.processManifest: incl. unknown records:',
unknownRecordsArray.length
);
window.log.info(
'storageService.processManifest: incl. records with errors:',
recordsWithErrors.length
); );
const remoteKeys = Array.from(remoteKeysTypeMap.keys()); const remoteKeys = Array.from(remoteKeysTypeMap.keys());
@ -671,7 +674,8 @@ async function processManifest(
const remoteOnly = Array.from(remoteOnlySet); const remoteOnly = Array.from(remoteOnlySet);
window.log.info( window.log.info(
`storageService.processManifest: remoteOnly.length ${remoteOnly.length}` 'storageService.processManifest: remote keys',
remoteOnly.length
); );
const readOperation = new window.textsecure.protobuf.ReadOperation(); const readOperation = new window.textsecure.protobuf.ReadOperation();
@ -830,9 +834,8 @@ async function processManifest(
const storageID = conversation.get('storageID'); const storageID = conversation.get('storageID');
if (storageID && !remoteOnlySet.has(storageID)) { if (storageID && !remoteOnlySet.has(storageID)) {
window.log.info( window.log.info(
'storageService.processManifest: conversation was not included in remote force push, clearing storageID', 'storageService.processManifest: clearing storageID',
conversation.debugID(), conversation.debugID()
storageID
); );
conversation.unset('storageID'); conversation.unset('storageID');
} }
@ -870,9 +873,8 @@ async function processManifest(
consecutiveConflicts = 0; consecutiveConflicts = 0;
} catch (err) { } catch (err) {
window.log.error( window.log.error(
`storageService.processManifest: failed! ${ 'storageService.processManifest: failed!',
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
}`
); );
} }
@ -918,9 +920,8 @@ async function sync(): Promise<void> {
} }
} catch (err) { } catch (err) {
window.log.error( window.log.error(
`storageService.sync: error processing manifest ${ 'storageService.sync: error processing manifest',
err && err.stack ? err.stack : String(err) err && err.stack ? err.stack : String(err)
}`
); );
// When we're told to backoff, backoff to the max which should be // When we're told to backoff, backoff to the max which should be

View file

@ -68,9 +68,8 @@ function applyUnknownFields(
): void { ): void {
if (conversation.get('storageUnknownFields')) { if (conversation.get('storageUnknownFields')) {
window.log.info( window.log.info(
`storageService.applyUnknownFields: Applying unknown fields for ${conversation.get( 'storageService.applyUnknownFields: Applying unknown fields for',
'id' conversation.get('id')
)}`
); );
// eslint-disable-next-line no-param-reassign // eslint-disable-next-line no-param-reassign
record.__unknownFields = base64ToArrayBuffer( record.__unknownFields = base64ToArrayBuffer(
@ -628,7 +627,8 @@ export async function mergeAccountRecord(
if (!conversationId) { if (!conversationId) {
window.log.error( window.log.error(
`mergeAccountRecord: missing conversation id. looking based on ${pinnedConversation.identifier}` 'mergeAccountRecord: missing conversation id. looking based on',
pinnedConversation.identifier
); );
return undefined; return undefined;
} }