franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Listen for errors on got stream

Browse Source
This commit is contained in:
Adhiraj Singh
2021-01-14 12:44:55 +05:30
parent 2b50e4e6cc
commit 35aa857ab5
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/WAConnection/6.MessagesSend.ts
View File

@@ -40,7 +40,7 @@ export class WAConnection extends Base {
type: MessageType, type: MessageType,
options: MessageOptions = {}, options: MessageOptions = {},
) { ) {
const content = await this.prepareMessageContent ( const content = await this.prepareMessageContent(
message, message,
type, type,
options options

3
src/WAConnection/Utils.ts
View File

@@ -294,8 +294,9 @@ export async function generateThumbnail(file: string, mediaType: MessageType, in
} }
} }
export const getGotStream = async(url: string | URL, options: Options & { isStream?: true } = {}) => { export const getGotStream = async(url: string | URL, options: Options & { isStream?: true } = {}) => {
const fetched = got.stream(url, options) const fetched = got.stream(url, { ...options, isStream: true })
await new Promise((resolve, reject) => { await new Promise((resolve, reject) => {
fetched.once('error', reject)
fetched.once('response', ({statusCode: status}: Response) => { fetched.once('response', ({statusCode: status}: Response) => {
if (status >= 400) { if (status >= 400) {
reject(new BaileysError ( reject(new BaileysError (