Page MenuHomePhabricator
Differential D13269

[identity] Replace handle_db_error mapping with question mark
ClosedPublic
Actions

Authored by bartek on Sep 9 2024, 6:06 AM.
Tags
None
Referenced Files
Unknown Object (File)
Mar 15 2025, 4:05 AM
Unknown Object (File)
Mar 9 2025, 9:55 AM
Unknown Object (File)
Mar 6 2025, 5:49 AM
Unknown Object (File)
Mar 5 2025, 10:04 PM
Unknown Object (File)
Mar 5 2025, 1:50 PM
Unknown Object (File)
Feb 26 2025, 11:38 AM
Unknown Object (File)
Feb 26 2025, 11:38 AM
Unknown Object (File)
Feb 26 2025, 11:37 AM
View All 54 Files
Subscribers
ashoat
tomek

Details

Reviewers
varun
Commits
rCOMMad4441eb9c2b: [identity] Replace handle_db_error mapping with question mark
Summary

Follow up https://phab.comm.dev/D13226?id=43848#inline-76241

Depends on D13226

Test Plan

Cargo check

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
services/
identity/
src/
221 lines
grpc_services/
149 lines

Diff 44136

View Options

services/identity/src/client_service.rs

Show First 20 Lines • Show All 500 Lines • ▼ Show 20 Lines if (message.type === serverSocketMessageTypes.ERROR) {
currentUserInfo, currentUserInfo,
cookie: newerCookie, cookie: newerCookie,
}, },
preRequestUserState: this.initializedWithUserState, preRequestUserState: this.initializedWithUserState,
error: null, error: null,
logInActionSource: logInActionSource:
logInActionSources.socketAuthErrorResolutionAttempt, logInActionSources.socketAuthErrorResolutionAttempt,
keyserverID: ashoatKeyserverID, keyserverID: ashoatKeyserverID,
urlPrefix: this.props.urlPrefix,
}, },
}); });
} }
this.invalidationRecoveryInProgress = false; this.invalidationRecoveryInProgress = false;
} }
}; };
addListener: (listener: SocketListener) => void = listener => { addListener: (listener: SocketListener) => void = listener => {
▲ Show 20 Lines • Show All 120 Lines • ▼ Show 20 Lines if (stateSyncMessage.payload.type === stateSyncPayloadTypes.FULL) {
this.props.dispatch({ this.props.dispatch({
type: setNewSessionActionType, type: setNewSessionActionType,
payload: { payload: {
sessionChange: { cookieInvalidated: false, sessionID }, sessionChange: { cookieInvalidated: false, sessionID },
preRequestUserState: this.initializedWithUserState, preRequestUserState: this.initializedWithUserState,
error: null, error: null,
logInActionSource: undefined, logInActionSource: undefined,
keyserverID: ashoatKeyserverID, keyserverID: ashoatKeyserverID,
urlPrefix: this.props.urlPrefix,
}, },
}); });
} }
} else { } else {
const { type, ...actionPayload } = stateSyncMessage.payload; const { type, ...actionPayload } = stateSyncMessage.payload;
this.props.dispatch({ this.props.dispatch({
type: incrementalStateSyncActionType, type: incrementalStateSyncActionType,
payload: { payload: {
▲ Show 20 Lines • Show All 167 Lines • Show Last 20 Lines
View Options

services/identity/src/grpc_services/authenticated.rs

Show First 20 Lines • Show All 500 Lines • ▼ Show 20 Lines if (message.type === serverSocketMessageTypes.ERROR) {
currentUserInfo, currentUserInfo,
cookie: newerCookie, cookie: newerCookie,
}, },
preRequestUserState: this.initializedWithUserState, preRequestUserState: this.initializedWithUserState,
error: null, error: null,
logInActionSource: logInActionSource:
logInActionSources.socketAuthErrorResolutionAttempt, logInActionSources.socketAuthErrorResolutionAttempt,
keyserverID: ashoatKeyserverID, keyserverID: ashoatKeyserverID,
urlPrefix: this.props.urlPrefix,
}, },
}); });
} }
this.invalidationRecoveryInProgress = false; this.invalidationRecoveryInProgress = false;
} }
}; };
addListener: (listener: SocketListener) => void = listener => { addListener: (listener: SocketListener) => void = listener => {
▲ Show 20 Lines • Show All 120 Lines • ▼ Show 20 Lines if (stateSyncMessage.payload.type === stateSyncPayloadTypes.FULL) {
this.props.dispatch({ this.props.dispatch({
type: setNewSessionActionType, type: setNewSessionActionType,
payload: { payload: {
sessionChange: { cookieInvalidated: false, sessionID }, sessionChange: { cookieInvalidated: false, sessionID },
preRequestUserState: this.initializedWithUserState, preRequestUserState: this.initializedWithUserState,
error: null, error: null,
logInActionSource: undefined, logInActionSource: undefined,
keyserverID: ashoatKeyserverID, keyserverID: ashoatKeyserverID,
urlPrefix: this.props.urlPrefix,
}, },
}); });
} }
} else { } else {
const { type, ...actionPayload } = stateSyncMessage.payload; const { type, ...actionPayload } = stateSyncMessage.payload;
this.props.dispatch({ this.props.dispatch({
type: incrementalStateSyncActionType, type: incrementalStateSyncActionType,
payload: { payload: {
▲ Show 20 Lines • Show All 167 Lines • Show Last 20 Lines