mirror of
https://github.com/Chocobozzz/PeerTube.git
synced 2025-10-04 18:29:27 +02:00
Try to fix tests
This commit is contained in:
parent
63fa260a81
commit
34aa316f58
3 changed files with 45 additions and 11 deletions
|
@ -1,19 +1,39 @@
|
|||
import { wait } from '@shared/core-utils'
|
||||
import { HttpStatusCode } from '@shared/models'
|
||||
import { unwrapBody, unwrapTextOrDecode, unwrapBodyOrDecodeToJSON } from '../requests'
|
||||
import { unwrapBody, unwrapBodyOrDecodeToJSON, unwrapTextOrDecode } from '../requests'
|
||||
import { AbstractCommand, OverrideCommandOptions } from '../shared'
|
||||
|
||||
export class StreamingPlaylistsCommand extends AbstractCommand {
|
||||
|
||||
get (options: OverrideCommandOptions & {
|
||||
async get (options: OverrideCommandOptions & {
|
||||
url: string
|
||||
withRetry?: boolean // default false
|
||||
currentRetry?: number
|
||||
}) {
|
||||
return unwrapTextOrDecode(this.getRawRequest({
|
||||
...options,
|
||||
const { withRetry, currentRetry = 1 } = options
|
||||
|
||||
url: options.url,
|
||||
implicitToken: false,
|
||||
defaultExpectedStatus: HttpStatusCode.OK_200
|
||||
}))
|
||||
try {
|
||||
const result = await unwrapTextOrDecode(this.getRawRequest({
|
||||
...options,
|
||||
|
||||
url: options.url,
|
||||
implicitToken: false,
|
||||
defaultExpectedStatus: HttpStatusCode.OK_200
|
||||
}))
|
||||
|
||||
return result
|
||||
} catch (err) {
|
||||
if (!withRetry || currentRetry > 5) throw err
|
||||
|
||||
await wait(100)
|
||||
|
||||
return this.get({
|
||||
...options,
|
||||
|
||||
withRetry,
|
||||
currentRetry: currentRetry + 1
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
getFragmentedSegment (options: OverrideCommandOptions & {
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue