Gittes-archive/lucida_lucida
2
0
Fork 0
mirror of https://git.gay/lucida/lucida synced 2025-12-11 20:15:14 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix stream ripping private tracks

Browse Source
This commit is contained in:
aria 2024-09-03 17:07:34 -04:00
parent 433aa37b8b
commit 52ab7f0b37
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/streamers/soundcloud/main.ts
View File

@ -212,7 +212,8 @@ export default class Soundcloud implements Streamer {
api.media.transcodings, api.media.transcodings,
api.track_authorization, api.track_authorization,
client, client,
this.oauthToken this.oauthToken,
path.split('/')[3]
) )
}, },
metadata: await parseTrack(api) metadata: await parseTrack(api)
@ -261,7 +262,7 @@ export default class Soundcloud implements Streamer {
} }
} }
default: default:
throw `Type "${type}" not supported.` throw new Error(`Type "${type}" not supported.`)
} }
} }
async #getRawTrackInfo(id: number | string, client: ScClient) { async #getRawTrackInfo(id: number | string, client: ScClient) {
@ -329,7 +330,8 @@ async function getStream(
transcodings: Array<SoundcloudTranscoding>, transcodings: Array<SoundcloudTranscoding>,
trackAuth: string, trackAuth: string,
client: ScClient, client: ScClient,
oauthToken?: string | undefined oauthToken?: string | undefined,
secretToken?: string | undefined
): Promise<GetStreamResponse> { ): Promise<GetStreamResponse> {
let filter = transcodings.filter((x) => x.quality == 'hq') let filter = transcodings.filter((x) => x.quality == 'hq')
if (hq == true && filter.length == 0) throw new Error('Could not find HQ format.') if (hq == true && filter.length == 0) throw new Error('Could not find HQ format.')
@ -338,14 +340,15 @@ async function getStream(
if (filter.length == 0) filter = transcodings.filter((x) => x.preset.startsWith('mp3_')) // then mp3 if (filter.length == 0) filter = transcodings.filter((x) => x.preset.startsWith('mp3_')) // then mp3
if (filter.length == 0) filter = transcodings.filter((x) => x.preset.startsWith('opus_')) // then opus if (filter.length == 0) filter = transcodings.filter((x) => x.preset.startsWith('opus_')) // then opus
if (filter.length == 0) throw new Error('Could not find applicable format.') // and this is just in case none of those exist if (filter.length == 0) throw new Error('Could not find applicable format.') // and this is just in case none of those exist
const transcoding = filter[0] const transcoding = filter[0]
const streamUrlResp = await fetch(
`${transcoding.url}?client_id=${client.id}&track_authorization=${trackAuth}`, let streamUrl = new URL(transcoding.url)
{ streamUrl.searchParams.append('client_id', client?.id)
headers: headers(oauthToken) streamUrl.searchParams.append('track_authorization', trackAuth)
}
) const streamUrlResp = await fetch(streamUrl.toString(), {
headers: headers(oauthToken)
})
const json = <{ url: string }>await streamUrlResp.json() const json = <{ url: string }>await streamUrlResp.json()
if (!json.url) throw new Error('Stream URL could not be retreieved.') if (!json.url) throw new Error('Stream URL could not be retreieved.')