actions/discord-webhook
0
0
Fork 0
mirror of https://github.com/tsickert/discord-webhook.git synced 2025-02-03 21:16:41 -05:00
Code Issues Projects Releases Packages Wiki Activity

Attempt to use webhook

Browse source
This commit is contained in:
tsickert 2024-03-30 18:21:15 +00:00
parent 8b0595b302
commit 0f88348386
1 changed files with 48 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

80
src/webhook.ts
View file

@ -1,9 +1,9 @@
import * as core from '@actions/core'
import {ReadStream, createReadStream, readFileSync} from 'fs'
import FormData from 'form-data'
import axios from 'axios'
import blob from 'node:stream/consumers'
import {createReadStream, readFileSync} from 'fs'
import {HttpClient} from '@actions/http-client'
import {TypedResponse} from '@actions/http-client/lib/interfaces'
import http from 'http'
const WEBHOOK_URL = 'webhook-url'
const CONTENT = 'content'
@ -147,48 +147,64 @@ export async function executeWebhook(): Promise<void> {
if (filename !== '' || threadName !== '' || flags !== '') {
const formData = new FormData()
let fileStream: ReadStream | null = null
if (filename !== '') {
fileStream = createReadStream(filename)
formData.append('upload-file', fileStream)
formData.append(
'upload-file',
await blob(createReadStream(filename))
)
formData.append('payload_json', JSON.stringify(payload))
}
if (threadName !== '') {
formData.append('thread_name', threadName)
}
if (flags !== '') {
formData.append('flags', Number(flags))
formData.append('flags', flags)
}
const request = http.request({
const response = await axios({
method: 'POST',
headers: formData.getHeaders()
url: webhookUrl,
data: formData,
headers: {
'Content-Type': 'multipart/form-data'
}
})
formData.pipe(request)
if (response.status !== 200) {
if (filename !== '') {
core.error(`failed to upload file: ${response.statusText}`)
}
if (threadName !== '') {
core.error(`failed to create thread: ${threadName}`)
}
} else if (filename !== '') {
core.info(
`successfully uploaded file with status code: ${response.status}`
)
}
request
.on('response', response => {
if (response.statusCode !== 200) {
if (filename !== '') {
core.error(`failed to upload file: ${response.statusMessage}`)
}
if (threadName !== '') {
core.error(`failed to create thread: ${threadName}`)
}
} else if (filename !== '') {
core.info(
`successfully uploaded file with status code: ${response.statusCode}`
)
}
if (fileStream != null) {
fileStream.destroy()
}
response.destroy()
})
.on('error', err => {
core.error(err.message)
})
// request
// .on('response', response => {
// if (response.statusCode !== 200) {
// if (filename !== '') {
// core.error(`failed to upload file: ${response.statusMessage}`)
// }
// if (threadName !== '') {
// core.error(`failed to create thread: ${threadName}`)
// }
// } else if (filename !== '') {
// core.info(
// `successfully uploaded file with status code: ${response.statusCode}`
// )
// }
// if (fileStream != null) {
// fileStream.destroy()
// }
// response.destroy()
// })
// .on('error', err => {
// core.error(err.message)
// })
} else {
const response = await client.postJson(webhookUrl, payload)
await handleResponse(response)