diff --git a/package.json b/package.json index fe42bb2..880998d 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "Miru", - "version": "2.0.3", + "version": "2.0.4", "author": "ThaUnknown_ ", "main": "src/index.js", "homepage": "https://github.com/ThaUnknown/miru#readme", diff --git a/src/renderer/src/lib/pages/watchtogether/WatchTogether.svelte b/src/renderer/src/lib/pages/watchtogether/WatchTogether.svelte index 8645428..0ee91c0 100644 --- a/src/renderer/src/lib/pages/watchtogether/WatchTogether.svelte +++ b/src/renderer/src/lib/pages/watchtogether/WatchTogether.svelte @@ -64,10 +64,10 @@ }) queueMicrotask(() => { - client.on('torrent', ({ detail }) => { - if (!detail.every((v, i) => v === playerState.file[i])) { - playerState.file = detail - emit('torrent', { file: detail }) + client.on('magnet', ({ detail }) => { + if (detail.hash !== playerState.hash) { + playerState.hash = detail.hash + emit('torrent', detail) } }) }) @@ -81,7 +81,7 @@ const playerState = { paused: null, time: null, - file: [] + hash: null } function cancel() { @@ -153,9 +153,9 @@ break } case 'torrent': { - if (!data.file.every((v, i) => v === playerState.file[i])) { - playerState.file = data.file - add(data.file) + if (data.hash !== playerState.hash) { + playerState.hash = data.hash + add(data.magnet) } break } diff --git a/src/renderer/src/modules/torrentworker.js b/src/renderer/src/modules/torrentworker.js index b7263bf..c0becf2 100644 --- a/src/renderer/src/modules/torrentworker.js +++ b/src/renderer/src/modules/torrentworker.js @@ -41,6 +41,7 @@ class TorrentClient extends WebTorrent { }) this.dispatch('files', files) this.dispatch('pieces', torrent.pieces.length) + this.dispatch('magnet', { magnet: torrent.magnetURI, hash: torrent.infoHash }) this.dispatch('torrent', Array.from(torrent.torrentFile)) })