aboutsummaryrefslogtreecommitdiffhomepage
path: root/server
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2021-09-07 15:16:26 +0200
committerChocobozzz <me@florianbigard.com>2021-09-07 15:16:26 +0200
commitfb72d2e1c24cd4660fd6611ef723c5827c47294c (patch)
treec2a2991a9e6944cd3d22c87e34de096a47b8db9e /server
parent6f9719b568fad75959a1404b6927b7a278061c41 (diff)
downloadPeerTube-fb72d2e1c24cd4660fd6611ef723c5827c47294c.tar.gz
PeerTube-fb72d2e1c24cd4660fd6611ef723c5827c47294c.tar.zst
PeerTube-fb72d2e1c24cd4660fd6611ef723c5827c47294c.zip
Fix infohash with object storage
Diffstat (limited to 'server')
-rw-r--r--server/lib/job-queue/handlers/move-to-object-storage.ts4
-rw-r--r--server/tests/api/videos/video-hls.ts7
2 files changed, 11 insertions, 0 deletions
diff --git a/server/lib/job-queue/handlers/move-to-object-storage.ts b/server/lib/job-queue/handlers/move-to-object-storage.ts
index 0bebc0fc2..4beca3d75 100644
--- a/server/lib/job-queue/handlers/move-to-object-storage.ts
+++ b/server/lib/job-queue/handlers/move-to-object-storage.ts
@@ -4,6 +4,7 @@ import { join } from 'path'
4import { logger } from '@server/helpers/logger' 4import { logger } from '@server/helpers/logger'
5import { updateTorrentUrls } from '@server/helpers/webtorrent' 5import { updateTorrentUrls } from '@server/helpers/webtorrent'
6import { CONFIG } from '@server/initializers/config' 6import { CONFIG } from '@server/initializers/config'
7import { P2P_MEDIA_LOADER_PEER_VERSION } from '@server/initializers/constants'
7import { storeHLSFile, storeWebTorrentFile } from '@server/lib/object-storage' 8import { storeHLSFile, storeWebTorrentFile } from '@server/lib/object-storage'
8import { getHLSDirectory, getHlsResolutionPlaylistFilename } from '@server/lib/paths' 9import { getHLSDirectory, getHlsResolutionPlaylistFilename } from '@server/lib/paths'
9import { moveToNextState } from '@server/lib/video-state' 10import { moveToNextState } from '@server/lib/video-state'
@@ -84,6 +85,9 @@ async function doAfterLastJob (video: MVideoWithAllFiles, isNewVideo: boolean) {
84 85
85 playlist.storage = VideoStorage.OBJECT_STORAGE 86 playlist.storage = VideoStorage.OBJECT_STORAGE
86 87
88 playlist.assignP2PMediaLoaderInfoHashes(video, playlist.VideoFiles)
89 playlist.p2pMediaLoaderPeerVersion = P2P_MEDIA_LOADER_PEER_VERSION
90
87 await playlist.save() 91 await playlist.save()
88 } 92 }
89 93
diff --git a/server/tests/api/videos/video-hls.ts b/server/tests/api/videos/video-hls.ts
index 4685bf3b6..91124725f 100644
--- a/server/tests/api/videos/video-hls.ts
+++ b/server/tests/api/videos/video-hls.ts
@@ -14,6 +14,7 @@ import {
14 createMultipleServers, 14 createMultipleServers,
15 doubleFollow, 15 doubleFollow,
16 expectStartWith, 16 expectStartWith,
17 hlsInfohashExist,
17 makeRawRequest, 18 makeRawRequest,
18 ObjectStorageCommand, 19 ObjectStorageCommand,
19 PeerTubeServer, 20 PeerTubeServer,
@@ -88,9 +89,15 @@ async function checkHlsPlaylist (options: {
88 89
89 const masterPlaylist = await server.streamingPlaylists.get({ url: hlsPlaylist.playlistUrl }) 90 const masterPlaylist = await server.streamingPlaylists.get({ url: hlsPlaylist.playlistUrl })
90 91
92 let i = 0
91 for (const resolution of resolutions) { 93 for (const resolution of resolutions) {
92 expect(masterPlaylist).to.contain(`${resolution}.m3u8`) 94 expect(masterPlaylist).to.contain(`${resolution}.m3u8`)
93 expect(masterPlaylist).to.contain(`${resolution}.m3u8`) 95 expect(masterPlaylist).to.contain(`${resolution}.m3u8`)
96
97 const url = 'http://' + videoDetails.account.host
98 await hlsInfohashExist(url, hlsPlaylist.playlistUrl, i)
99
100 i++
94 } 101 }
95 } 102 }
96 103