All files / State/Concurrency/Subscribers subscribeToConcurrencyApiResponse.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
1x
 
6x
 
 
 
 
3x
1x
 
1x
 
 
 
 
 
 
 
 
 
 
 
 
1x
 
1x
 
 
 
 
 
 
 
 
import isEmpty from '../../../Shared/Utils/isEmpty';
 
const subscribeToConcurrencyApiResponse = (
    concurrencyApiResponse$,
    concurrencyStore,
) =>
    concurrencyApiResponse$
        .subscribe(concurrencyResponse => {
            const updateResponse = concurrencyResponse && concurrencyResponse.updateResponse;
 
            Iif (
                isEmpty(updateResponse) ||
                !updateResponse.id ||
                !updateResponse.encryptedLock ||
                !updateResponse.sequenceToken
            )  {
                return concurrencyStore.actions.disableFeature();
            }
 
            const {
                id,
                encryptedLock,
                sequenceToken,
            } = concurrencyResponse.updateResponse;
 
            concurrencyStore.actions.updateConcurrency({
                encryptedLock,
                sequenceToken,
                lockId: id,
            });
        });
 
export default subscribeToConcurrencyApiResponse;