All files / Api/Playback/Subscribers subscribeToAssetUpdateWithConfig.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
35
36
37
38
39
1x
 
1x
 
 
 
 
 
 
6x
 
 
 
 
3x
1x
4x
 
1x
1x
 
1x
 
 
 
1x
 
 
 
 
 
 
 
 
1x
 
 
 
 
import { Util } from 'playback-web-player';
 
import inferStreamingProtocol from '../../Utils/inferStreamingProtocol';
 
/**
 * @param {Observable<[Asset, Config]>} assetUpdateWithConfig$
 * @param {Observable}
 */
 
const subscribeToAssetUpdateWithConfig = (
    assetUpdateWithConfig$,
    playbackApiRequest$
) =>
    assetUpdateWithConfig$
        .subscribe(([latestAsset, latestConfig]) => {
            const { environment } = latestConfig;
            const { authToken, playerId, platform, language } = environment;
 
            const userDevice = Util.getUserDevice(window.navigator.userAgent);
            const assetFormat = inferStreamingProtocol(userDevice);
 
            Iif (typeof authToken !== 'string' || !authToken) {
                throw new TypeError('A valid `authToken` must be provided');
            }
 
            const request = {
                assetId: latestAsset.assetId,
                playerId,
                platform,
                language,
                assetFormat,
                authToken,
            };
 
            playbackApiRequest$.next(request);
        });
 
export default subscribeToAssetUpdateWithConfig;