4 Commits

2 changed files with 31 additions and 96 deletions
+1
View File
@@ -1,2 +1,3 @@
token.txt token.txt
trimUploader.ini trimUploader.ini
ZiplineUploader.exe
+29 -95
View File
@@ -8,125 +8,59 @@ trimPattern := IniRead("trimUploader.ini", "location", "trimPattern", "*_trim.mp
ziplineURL := IniRead("trimUploader.ini", "location", "ziplineURL", "PROVIDE ZIPLINE URL") ziplineURL := IniRead("trimUploader.ini", "location", "ziplineURL", "PROVIDE ZIPLINE URL")
ziplineFolder := IniRead("trimUploader.ini", "location", "ziplineFolder", "PROVIDE FOLDER ID") ziplineFolder := IniRead("trimUploader.ini", "location", "ziplineFolder", "PROVIDE FOLDER ID")
ziplineToken := IniRead("trimUploader.ini", "location", "ziplineToken", "PROVIDE ZIPLINE TOKEN") ziplineToken := IniRead("trimUploader.ini", "location", "ziplineToken", "PROVIDE ZIPLINE TOKEN")
chunkSize := IniRead("trimUploader.ini", "location", "chunkSize", "26214400")
chunkThreshold := IniRead("trimUploader.ini", "location", "chunkThreshold", "99614720")
IniWrite(momentsPath, "trimUploader.ini", "location", "momentsPath") IniWrite(momentsPath, "trimUploader.ini", "location", "momentsPath")
IniWrite(trimPattern, "trimUploader.ini", "location", "trimPattern") IniWrite(trimPattern, "trimUploader.ini", "location", "trimPattern")
IniWrite(ziplineURL, "trimUploader.ini", "location", "ziplineURL") IniWrite(ziplineURL, "trimUploader.ini", "location", "ziplineURL")
IniWrite(ziplineFolder, "trimUploader.ini", "location", "ziplineFolder") IniWrite(ziplineFolder, "trimUploader.ini", "location", "ziplineFolder")
IniWrite(ziplineToken, "trimUploader.ini", "location", "ziplineToken") IniWrite(ziplineToken, "trimUploader.ini", "location", "ziplineToken")
IniWrite(chunkSize, "trimUploader.ini", "location", "chunkSize")
IniWrite(chunkThreshold, "trimUploader.ini", "location", "chunkThreshold")
loop { loop {
uploadedURLs := "" uploadedURLs := ""
uploadedFiles := 0 uploadedFiles := 0
Loop Files momentsPath "\" trimPattern, "F" { Loop Files momentsPath "\" trimPattern, "F" {
; Check file size to avoid upload mid export
fileSize := 0 fileSize := 0
while (fileSize < FileGetSize()) { while (fileSize < FileGetSize()) {
fileSize := FileGetSize()
Sleep(200) Sleep(200)
fileSize := FileGetSize()
} }
chunkNum := Floor(fileSize / chunkSize) ; ; Build curl command
filePath := A_LoopFileFullPath ; cmd := 'curl -s -H "Authorization: ' ziplineToken '" '
fileName := A_LoopFileName ; cmd .= '-H "x-zipline-original-name: true" '
; cmd .= '-H "x-zipline-p-format: name" '
; cmd .= '-H "x-zipline-folder: ' ziplineFolder '" '
; cmd .= '-H "x-zipline-filename: ' StrReplace(A_LoopFileName, ".mp4", "") '" '
; cmd .= '-F "file=@' A_LoopFileFullPath ';type=video/mp4" '
; cmd .= '"' ZiplineURL '/api/upload"'
if (chunkNum > 0) { ; ; MsgBox(cmd)
; -------------------------
; 2. UPLOAD CHUNKS
; -------------------------
fileToUpload := FileOpen(filePath, "r")
chunkIndex := 0
partialIdentifier := ""
mime := "video/mp4"
while !fileToUpload.AtEOF { ; ; Run curl and capture output
chunk := fileToUpload.Read(chunkSize) ; RunWait(A_ComSpec " /c " cmd " | clip", , "Hide")
; output := A_Clipboard
tmpChunk := A_Temp "\chunk.tmp"
try {
FileDelete tmpChunk
} catch Error {
}
FileAppend chunk, tmpChunk, "RAW"
MsgBox FileGetSize(tmpChunk)
uploadCmd := 'curl -s -X POST '
; uploadCmd .= '-H "content-type: multipart/form-data;" '
uploadCmd .= Format('-H "Authorization: {1}" ', ziplineToken)
uploadCmd .= '-H "x-zipline-format: name" '
uploadCmd .= '-H "x-zipline-original-name: true" '
uploadCmd .= Format('-H "x-zipline-p-content-length: {1}" ', fileSize)
uploadCmd .= Format('-H "x-zipline-p-content-type: {1}" ', mime)
uploadCmd .= Format('-H "x-zipline-p-filename: {1}" ', fileName)
; uploadCmd .= Format('-H "x-zipline-folder: {1}" ', ziplineFolder)
if (chunkIndex > 0) {
uploadCmd .= Format('-H "x-zipline-p-identifier: {1}" ', partialIdentifier)
}
if (chunkIndex = chunkNum) {
uploadCmd .= '-H "x-zipline-p-lastchunk: true" '
} else {
uploadCmd .= '-H "x-zipline-p-lastchunk: false" '
}
uploadCmd .= Format('-F "file=@{1}" ', tmpChunk)
uploadCmd .= Format('"{1}/api/upload/partial"', ziplineURL,)
MsgBox uploadCmd
resp := RunWaitGet(uploadCmd)
partialResult := JsonExtract(resp, "partialSuccess")
if (chunkIndex = 0) {
partialIdentifier := JsonExtract(resp, "partialIdentifier")
}
if !partialResult {
MsgBox "Chunk upload failed at index " chunkIndex "`nResponse:`n" resp
return
}
chunkIndex++
}
fileToUpload.Close()
finishResp := RunWaitGet(resp)
finalUrl := JsonExtract(finishResp, "url")
}
; Extract URL from JSON ; Extract URL from JSON
if ( not finalUrl = "") { ; if RegExMatch(output, '"url":"(.*?)"', &m) {
uploadedURLs .= finalUrl "`n" ; url := m[1]
uploadedFiles++ ; uploadedURLs .= url "`n"
; uploadedFiles++
FileCopy(A_LoopFileFullPath, "\\192.168.0.20\nextcloud\fireshare\fireshare_videos\*.*")
FileDelete(A_LoopFileFullPath)
try { ; try {
FileDelete(A_LoopFileFullPath) ; } catch Error {
} catch Error {
} ; }
} else { ; } else {
MsgBox "Failed to extract URL.`nResponse:`n" finishResp ; MsgBox "Failed to extract URL.`nResponse:`n" output
} ; }
} }
if ( not uploadedURLs = "") { ; if ( not uploadedURLs = "") {
A_Clipboard := uploadedURLs ; A_Clipboard := uploadedURLs
TrayTip "Zipline Upload", "Uploaded " uploadedFiles " file(s)", 1 ; TrayTip "Zipline Upload", "Uploaded " uploadedFiles " file(s)", 1
} ; }
Sleep(5000) Sleep(5000)
} }
RunWaitGet(cmd, options := "Hide") {
tmp := A_Temp "\curl_out.txt"
RunWait(A_ComSpec ' /c ' cmd ' > "' tmp '"', , options)
return FileRead(tmp)
}
JsonExtract(json, key) {
if RegExMatch(json, '"' key '":"(.*?)"', &m)
return m[1]
return ""
}