root/src/public/js/Progress.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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
function Progress(onUpdateCallback) {
    this.seconds = 0;
    this.metaData = null;
    this.onUpdateCallback = onUpdateCallback;
    this.isPaused = false;
    this.isReady = false;
    this.onReadyCallbacks = [];
    this.onResetCallbacks = [];

    this.progressUpdateIntervalId = null;
    this.bindEvents();
    this.startUp();

    if (G.app.serverEvents.readyState == EventSource.OPEN) {
        this.startUp();
    }
}

Progress.prototype.isPlaying = function() {
    return this.metaData && this.metaData.duration !== -1;
}

Progress.prototype.onReady = function(callback) {
    if (!this.isReady) {
        this.onReadyCallbacks.push(callback);
    } else {
        callback();
    }
}

Progress.prototype.onReset = function(callback) {
    this.onResetCallbacks.push(callback);
}


Progress.prototype.startUp = function() {
    var self = this;

    function logError(a,b,c,d,e) {
        console.log("error",a,b,c,d,e);
    }

    $.getJSON("api/player/metaData", function(metaData) {
        self.initMetaData(metaData);
        $.getJSON("api/player/pauseStatus", function(data) {
            self.isPaused = data.status === "paused";
            $.getJSON("api/player/progress", function(data) {
                self.initProgress(data.seconds);
            }).error(logError);
        }).error(logError);
    }).error(logError);
}

Progress.prototype.initMetaData = function(metaData) {
    this.metaData = metaData;
    this.isReady = true;
    for (var i in this.onReadyCallbacks) {
        this.onReadyCallbacks[i]();
    }
}

Progress.prototype.initProgress = function(second) {
    this.set(second);

    // progress bar update
    window.clearInterval(this.progressUpdateIntervalId);
    var self = this;
    var lastDate = new Date();
    this.progressUpdateIntervalId = window.setInterval(function() {
        if (!self.isPaused) {
            var date = new Date();
            var diff = (date.getTime() - lastDate.getTime()) / 1000;
            lastDate = date;
            self.set(self.seconds + diff);
        }
    }, 50);
}

Progress.prototype.set = function(second) {
    this.seconds = Math.min(second, this.metaData.duration);
    if (this.seconds < this.metaData.duration) {
        this.onUpdateCallback(second, this.metaData.duration);
    }
}

Progress.prototype.reset = function() {
    this.isReady = false;
    window.clearInterval(this.progressUpdateIntervalId);
    if (this.metaData) {
        this.set(0);
    }
    this.metaData = null;
    this.seconds = 0;
    for (var i in this.onResetCallbacks) {
        this.onResetCallbacks[i]();
    }
}

Progress.prototype.bindEvents = function() {
    var self = this;

    this.onPlaybackStartedListener = function(event) {
        var data = JSON.parse(event.data);
        self.initMetaData(data.metaData);
        self.initProgress(data.seconds);
        self.isPaused = false;
    }

    this.onPlaybackEndedListener = function(event) {
        self.reset();
    }

    this.onPausedListener = function(event) {
        self.isPaused = true;
    }

    this.onUnpausedListener = function(event) {
        self.isPaused = false;
    }

    this.onJumpedListener = function(event) {
        var data = JSON.parse(event.data);
        if (self.isReady) {
            self.set(data.seconds);
        }
    }

    G.app.serverEvents.addEventListener("playbackStarted", this.onPlaybackStartedListener);
    G.app.serverEvents.addEventListener("playbackEnded", this.onPlaybackEndedListener);
    G.app.serverEvents.addEventListener("paused", this.onPausedListener);
    G.app.serverEvents.addEventListener("unpaused", this.onUnpausedListener);
    G.app.serverEvents.addEventListener("jumped", this.onJumpedListener);
}

Progress.prototype.unbindEvents = function() {
    window.clearInterval(this.progressUpdateIntervalId);

    G.app.serverEvents.removeEventListener("playbackStarted", this.onPlaybackStartedListener);
    G.app.serverEvents.removeEventListener("playbackEnded", this.onPlaybackEndedListener);
    G.app.serverEvents.removeEventListener("paused", this.onPausedListener);
    G.app.serverEvents.removeEventListener("unpaused", this.onUnpausedListener);
    G.app.serverEvents.removeEventListener("jumped", this.onJumpedListener);
}