+ refreshFetch (url: string, options?: Object) {
+ return fetch(url, options)
+ .then((res: Response) => {
+ if (res.status !== 401) return res
+
+ // 401 unauthorized is not catch-ed, but then-ed
+ const error = res
+
+ const refreshingTokenPromise = new Promise((resolve, reject) => {
+ const clientId: string = peertubeLocalStorage.getItem(this.LOCAL_STORAGE_OAUTH_CLIENT_KEYS.CLIENT_ID)
+ const clientSecret: string = peertubeLocalStorage.getItem(this.LOCAL_STORAGE_OAUTH_CLIENT_KEYS.CLIENT_SECRET)
+ const headers = new Headers()
+ headers.set('Content-Type', 'application/x-www-form-urlencoded')
+ const data = {
+ refresh_token: this.userTokens.refreshToken,
+ client_id: clientId,
+ client_secret: clientSecret,
+ response_type: 'code',
+ grant_type: 'refresh_token'
+ }
+
+ fetch('/api/v1/users/token', {
+ headers,
+ method: 'POST',
+ body: objectToUrlEncoded(data)
+ })
+ .then(res => res.json())
+ .then((obj: UserRefreshToken) => {
+ this.userTokens.accessToken = obj.access_token
+ this.userTokens.refreshToken = obj.refresh_token
+ this.userTokens.save()
+
+ this.setHeadersFromTokens()
+
+ resolve()
+ })
+ .catch((refreshTokenError: any) => {
+ reject(refreshTokenError)
+ })
+ })
+
+ return refreshingTokenPromise
+ .catch(() => {
+ // If refreshing fails, continue with original error
+ throw error
+ })
+ .then(() => fetch(url, {
+ ...options,
+ headers: this.headers
+ }))
+ })
+ }
+
+ getPlaylistUrl (id: string) {
+ return window.location.origin + '/api/v1/video-playlists/' + id
+ }
+