(client: any, doc: any)
| 923 | else if (downloaded && typeof downloaded === "string" && fs.existsSync(downloaded)) buffer = await waitForStableFile(downloaded); |
| 924 | if (!buffer || buffer.length === 0) buffer = await waitForStableFile(mediaPath); |
| 925 | return buffer && buffer.length > 0 ? buffer : undefined; |
| 926 | } catch (err: any) { |
| 927 | console.warn("quote media download failed", err?.message || err); |
| 928 | return undefined; |
| 929 | } finally { |
| 930 | try { if (fs.existsSync(mediaPath)) fs.unlinkSync(mediaPath); } catch (err) { |
| 931 | console.debug("[quote] waitForStableFile loop error:", err?.message || err); |
| 932 | } |
| 933 | } |
| 934 | } |
| 935 | |
| 936 | async function downloadMessageMedia(msg: Api.Message, enabled: boolean): Promise<Buffer | undefined> { |
| 937 | if (!enabled || !(msg as any).media) return undefined; |
| 938 | const client = (msg as any).client ?? await getGlobalClient().catch(() => undefined); |
no test coverage detected