move the state of calling to its own slice
Audric Ackermann
3 years ago
parent
80566fd60e
commit
6f3625f99c
@ -0,0 +1,111 @@
|
||||
import { createSlice, PayloadAction } from '@reduxjs/toolkit';
|
||||
|
||||
export type CallStatusEnum = 'offering' | 'incoming' | 'connecting' | 'ongoing' | undefined;
|
||||
|
||||
export type CallStateType = {
|
||||
ongoingWith?: string;
|
||||
ongoingCallStatus?: CallStatusEnum;
|
||||
callIsInFullScreen: boolean;
|
||||
};
|
||||
|
||||
export const initialCallState: CallStateType = {
|
||||
ongoingWith: undefined,
|
||||
ongoingCallStatus: undefined,
|
||||
callIsInFullScreen: false,
|
||||
};
|
||||
|
||||
/**
|
||||
* This slice is the one holding the default joinable rooms fetched once in a while from the default opengroup v2 server.
|
||||
*/
|
||||
const callSlice = createSlice({
|
||||
name: 'call',
|
||||
initialState: initialCallState,
|
||||
reducers: {
|
||||
incomingCall(state: CallStateType, action: PayloadAction<{ pubkey: string }>) {
|
||||
const callerPubkey = action.payload.pubkey;
|
||||
if (state.ongoingWith && state.ongoingWith !== callerPubkey) {
|
||||
window.log.warn(
|
||||
`Got an incoming call action for ${callerPubkey} but we are already in a call.`
|
||||
);
|
||||
return state;
|
||||
}
|
||||
state.ongoingWith = callerPubkey;
|
||||
state.ongoingCallStatus = 'incoming';
|
||||
return state;
|
||||
},
|
||||
endCall(state: CallStateType) {
|
||||
state.ongoingCallStatus = undefined;
|
||||
state.ongoingWith = undefined;
|
||||
|
||||
return state;
|
||||
},
|
||||
answerCall(state: CallStateType, action: PayloadAction<{ pubkey: string }>) {
|
||||
const callerPubkey = action.payload.pubkey;
|
||||
|
||||
// to answer a call we need an incoming call form that specific pubkey
|
||||
|
||||
if (state.ongoingWith !== callerPubkey || state.ongoingCallStatus !== 'incoming') {
|
||||
window.log.info('cannot answer a call we are not displaying a dialog with');
|
||||
return state;
|
||||
}
|
||||
state.ongoingCallStatus = 'connecting';
|
||||
state.callIsInFullScreen = false;
|
||||
return state;
|
||||
},
|
||||
callConnected(state: CallStateType, action: PayloadAction<{ pubkey: string }>) {
|
||||
const callerPubkey = action.payload.pubkey;
|
||||
if (callerPubkey !== state.ongoingWith) {
|
||||
window.log.info('cannot answer a call we did not start or receive first');
|
||||
return state;
|
||||
}
|
||||
const existingCallState = state.ongoingCallStatus;
|
||||
|
||||
if (existingCallState !== 'connecting' && existingCallState !== 'offering') {
|
||||
window.log.info(
|
||||
'cannot answer a call we are not connecting (and so answered) to or offering a call'
|
||||
);
|
||||
return state;
|
||||
}
|
||||
|
||||
state.ongoingCallStatus = 'ongoing';
|
||||
state.callIsInFullScreen = false;
|
||||
return state;
|
||||
},
|
||||
startingCallWith(state: CallStateType, action: PayloadAction<{ pubkey: string }>) {
|
||||
if (state.ongoingWith) {
|
||||
window.log.warn('cannot start a call with an ongoing call already: ongoingWith');
|
||||
return state;
|
||||
}
|
||||
if (state.ongoingCallStatus) {
|
||||
window.log.warn('cannot start a call with an ongoing call already: ongoingCallStatus');
|
||||
return state;
|
||||
}
|
||||
|
||||
const callerPubkey = action.payload.pubkey;
|
||||
state.ongoingWith = callerPubkey;
|
||||
state.ongoingCallStatus = 'offering';
|
||||
state.callIsInFullScreen = false;
|
||||
|
||||
return state;
|
||||
},
|
||||
setFullScreenCall(state: CallStateType, action: PayloadAction<boolean>) {
|
||||
// only set in full screen if we have an ongoing call
|
||||
if (state.ongoingWith && state.ongoingCallStatus === 'ongoing' && action.payload) {
|
||||
state.callIsInFullScreen = true;
|
||||
}
|
||||
state.callIsInFullScreen = false;
|
||||
return state;
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
const { actions, reducer } = callSlice;
|
||||
export const {
|
||||
incomingCall,
|
||||
endCall,
|
||||
answerCall,
|
||||
callConnected,
|
||||
startingCallWith,
|
||||
setFullScreenCall,
|
||||
} = actions;
|
||||
export const callReducer = reducer;
|
||||
@ -0,0 +1,103 @@
|
||||
import { createSelector } from 'reselect';
|
||||
import { CallStateType } from '../ducks/call';
|
||||
import { ConversationsStateType, ReduxConversationType } from '../ducks/conversations';
|
||||
import { StateType } from '../reducer';
|
||||
import { getConversations, getSelectedConversationKey } from './conversations';
|
||||
|
||||
export const getCallState = (state: StateType): CallStateType => state.call;
|
||||
|
||||
// --- INCOMING CALLS
|
||||
export const getHasIncomingCallFrom = createSelector(getCallState, (state: CallStateType):
|
||||
| string
|
||||
| undefined => {
|
||||
return state.ongoingWith && state.ongoingCallStatus === 'incoming'
|
||||
? state.ongoingWith
|
||||
: undefined;
|
||||
});
|
||||
|
||||
export const getHasIncomingCall = createSelector(
|
||||
getHasIncomingCallFrom,
|
||||
(withConvo: string | undefined): boolean => !!withConvo
|
||||
);
|
||||
|
||||
// --- ONGOING CALLS
|
||||
export const getHasOngoingCallWith = createSelector(
|
||||
getConversations,
|
||||
getCallState,
|
||||
(convos: ConversationsStateType, callState: CallStateType): ReduxConversationType | undefined => {
|
||||
if (
|
||||
callState.ongoingWith &&
|
||||
(callState.ongoingCallStatus === 'connecting' ||
|
||||
callState.ongoingCallStatus === 'offering' ||
|
||||
callState.ongoingCallStatus === 'ongoing')
|
||||
) {
|
||||
return convos.conversationLookup[callState.ongoingWith] || undefined;
|
||||
}
|
||||
return undefined;
|
||||
}
|
||||
);
|
||||
|
||||
export const getHasOngoingCall = createSelector(
|
||||
getHasOngoingCallWith,
|
||||
(withConvo: ReduxConversationType | undefined): boolean => !!withConvo
|
||||
);
|
||||
|
||||
export const getHasOngoingCallWithPubkey = createSelector(
|
||||
getHasOngoingCallWith,
|
||||
(withConvo: ReduxConversationType | undefined): string | undefined => withConvo?.id
|
||||
);
|
||||
|
||||
export const getHasOngoingCallWithFocusedConvo = createSelector(
|
||||
getHasOngoingCallWithPubkey,
|
||||
getSelectedConversationKey,
|
||||
(withPubkey, selectedPubkey) => {
|
||||
return withPubkey && withPubkey === selectedPubkey;
|
||||
}
|
||||
);
|
||||
|
||||
export const getHasOngoingCallWithFocusedConvoIsOffering = createSelector(
|
||||
getCallState,
|
||||
getSelectedConversationKey,
|
||||
(callState: CallStateType, selectedConvoPubkey?: string): boolean => {
|
||||
if (
|
||||
!selectedConvoPubkey ||
|
||||
!callState.ongoingWith ||
|
||||
callState.ongoingCallStatus !== 'offering' ||
|
||||
selectedConvoPubkey !== callState.ongoingWith
|
||||
) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
);
|
||||
|
||||
export const getHasOngoingCallWithFocusedConvosIsConnecting = createSelector(
|
||||
getCallState,
|
||||
getSelectedConversationKey,
|
||||
(callState: CallStateType, selectedConvoPubkey?: string): boolean => {
|
||||
if (
|
||||
!selectedConvoPubkey ||
|
||||
!callState.ongoingWith ||
|
||||
callState.ongoingCallStatus !== 'connecting' ||
|
||||
selectedConvoPubkey !== callState.ongoingWith
|
||||
) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
);
|
||||
|
||||
export const getHasOngoingCallWithNonFocusedConvo = createSelector(
|
||||
getHasOngoingCallWithPubkey,
|
||||
getSelectedConversationKey,
|
||||
(withPubkey, selectedPubkey) => {
|
||||
return withPubkey && withPubkey !== selectedPubkey;
|
||||
}
|
||||
);
|
||||
|
||||
export const getCallIsInFullScreen = createSelector(
|
||||
getCallState,
|
||||
(callState): boolean => callState.callIsInFullScreen
|
||||
);
|
||||
Loading…
Reference in New Issue