_onEnter: async function()

in source/stale-playlist-detector/detector.js [78:151]

• 71 lines of code
• 7 McCabe index (conditional complexity)

                    _onEnter: async function() {
                        // find the playlists with segments
                        let playlists = [];
                        await get_playlists_with_segments(classobject.options.origin_url, classobject.options.origin_url, playlists);
                        classobject.playlists = [];
                        // this handles the fresh and stale events emitted
                        var playlist_event_handler = (function() {
                            let detector = classobject;
                            return function(playlist) {
                                let total = detector.playlists.length;
                                let stale = 0;
                                let fresh = 0;
                                let report = {
                                    options: classobject.options,
                                    playlists: {}
                                };
                                for (let playlist of detector.playlists) {
                                    stale += (playlist.fsm.state == "stale");
                                    fresh += (playlist.fsm.state == "fresh");
                                    report.playlists[playlist.options.url] = {
                                        state: playlist.fsm.state,
                                        changed: playlist.last_sample.timeseconds,
                                        duration: playlist.last_sample.duration,
                                        mean_duration: playlist.mean_duration,
                                        median_duration: playlist.median_duration,
                                        min_duration: playlist.min_duration,
                                        max_duration: playlist.max_duration
                                    };
                                }
                                if (stale + fresh == total) {
                                    // only measure once all fsms have reported
                                    let fraction = stale / total;
                                    report.detector = {
                                        total: total,
                                        fresh: fresh,
                                        stale: stale,
                                        stale_playlist_percent: (fraction * 100),
                                        stale_tolerance_percent: (detector.options.stale_tolerance * 100)
                                    };
                                    logger.info(`${total} total playlists, ${fresh} fresh, ${stale} stale, ${fraction * 100}% stale, ${detector.options.stale_tolerance * 100}% stale tolerance`);
                                    if (fraction >= detector.options.stale_tolerance) {
                                        if (detector.last_notified_state != "stale") {
                                            report.detector.state = "stale";
                                            // notify
                                            report.detector.sequence = detector.internal_sequence++;
                                            notify(JSON.stringify(report), classobject.options);
                                            detector.last_notified_state = "stale";
                                        }
                                    } else {
                                        if (detector.last_notified_state != "fresh") {
                                            report.detector.state = "fresh";
                                            // notify
                                            report.detector.sequence = detector.internal_sequence++;
                                            notify(JSON.stringify(report), classobject.options);
                                            detector.last_notified_state = "fresh";
                                        }
                                    }
                                }
                            };
                        })();
                        for (let url of playlists) {
                            let playlist = new Playlist({
                                detector_options: options,
                                url: url,
                                description: url,
                                detector: classobject
                            });
                            playlist.fsm.on("fresh", playlist_event_handler);
                            playlist.fsm.on("stale", playlist_event_handler);
                            playlist.start();
                            classobject.playlists.push(playlist);
                        }
                        this.transition("check");
                    }