|
1 | 1 | import { EventEmitter } from "https://deno.land/[email protected]/node/events.ts"; |
2 | 2 | import { WebSocketCloseEvent } from "https://deno.land/[email protected]/ws/mod.ts"; |
3 | | -import { soxa } from "https://deno.land/x/soxa/mod.ts" |
4 | 3 | import { Socket, SocketData } from "./api/Socket.ts"; |
5 | 4 | import { Player } from "./api/Player.ts"; |
6 | 5 |
|
7 | | -import type { LoadTracksResponse } from "./@types"; |
| 6 | +import type { LoadTracksResponse } from "./@types/track.d.ts"; |
8 | 7 |
|
9 | 8 | const defaults = { |
10 | 9 | resuming: { key: Math.random().toString(32), timeout: 60000 }, |
@@ -184,15 +183,17 @@ export class Manager extends EventEmitter { |
184 | 183 | * @param query The search query. |
185 | 184 | */ |
186 | 185 | public async search(query: string): Promise<LoadTracksResponse> { |
187 | | - return new Promise(async (resolve, reject) => { |
188 | | - const socket = this.ideal[0]; |
189 | | - if (!socket) |
190 | | - throw new Error("Manager#create(): No available sockets.") |
191 | | - |
192 | | - soxa.get(`http${socket.secure ? "s" : ""}://${socket.address}/loadtracks?identifier=${query}`) |
193 | | - .then((r) => resolve(r.data)) |
194 | | - .catch(e => reject(e)); |
| 186 | + const socket = this.ideal[0]; |
| 187 | + if (!socket) |
| 188 | + throw new Error("Manager#create(): No available sockets.") |
| 189 | + |
| 190 | + const resp = await fetch(`http${socket.secure ? "s" : ""}://${socket.address}/loadtracks?identifier=${encodeURIComponent(query ?? '')}`, { |
| 191 | + headers: { Authorization: socket.password ?? 'youshallnotpass' }, |
| 192 | + method: 'GET', |
195 | 193 | }); |
| 194 | + |
| 195 | + const data = await resp.json(); |
| 196 | + return data; |
196 | 197 | } |
197 | 198 | } |
198 | 199 |
|
@@ -247,7 +248,7 @@ export interface ManagerOptions { |
247 | 248 | reconnect?: ReconnectOptions; |
248 | 249 | } |
249 | 250 |
|
250 | | -export interface ReconnectOptions { |
| 251 | +interface ReconnectOptions { |
251 | 252 | /** |
252 | 253 | * The total amount of reconnect tries |
253 | 254 | */ |
|
0 commit comments