scriptNET-STHLM/nextcloud-artifacts-action
1
0
Fork 0
mirror of https://github.com/trympet/nextcloud-artifacts-action.git synced 2025-04-24 20:16:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

use buffered upload

Browse Source
This commit is contained in:
Trym Lund Flogard 2021-06-08 16:56:45 +02:00
parent 995999b60c
commit 935313b418
1 changed files with 2 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/nextcloud/NextcloudClient.ts
View File

@ -29,7 +29,7 @@ export class NextcloudClient {
private password: string private password: string
) { ) {
this.guid = uuidv4() this.guid = uuidv4()
this.headers = { Authorization: 'Basic ' + btoa(`${this.username}:${this.password}`) } this.headers = { Authorization: 'Basic ' + Buffer.from(`${this.username}:${this.password}`).toString('base64') }
this.davClient = webdav.createClient(`${this.endpoint.href}remote.php/dav/files/${this.username}`, { this.davClient = webdav.createClient(`${this.endpoint.href}remote.php/dav/files/${this.username}`, {
username: this.username, username: this.username,
password: this.password password: this.password
@ -125,28 +125,8 @@ export class NextcloudClient {
const remoteFilePath = `${remoteFileDir}/${this.artifact}.zip` const remoteFilePath = `${remoteFileDir}/${this.artifact}.zip`
core.debug(`Transferring file... (${file})`) core.debug(`Transferring file... (${file})`)
const fileStat = await fs.stat(file) await this.davClient.putFileContents(remoteFilePath, await fs.readFile(file));
const fileStream = fsSync.createReadStream(file)
const fileStreamPromise = new Promise<void>((resolve, reject) => {
fileStream.on('error', e => reject(e)).on('close', () => resolve())
})
const remoteStream = this.davClient.createWriteStream(remoteFilePath, {
headers: { 'Content-Length': fileStat.size.toString() }
})
const remoteStreamPromise = new Promise<void>((resolve, reject) => {
remoteStream.on('error', e => reject(e)).on('finish', () => resolve())
})
fileStream.pipe(remoteStream)
const timer = setTimeout(() => {}, 20_000)
await Promise.all([fileStreamPromise, remoteStreamPromise])
// HACK: Nextcloud has not fully processed the file, despite returning 200.
// Waiting for 1s seems to do the trick.
await new Promise(resolve => setTimeout(resolve, 1_000))
clearTimeout(timer)
return remoteFilePath return remoteFilePath
} }