[XAPID-377] Added OAuth token for getting signed URL
diff --git a/uploader.go b/uploader.go index 29241ba..0b84151 100644 --- a/uploader.go +++ b/uploader.go
@@ -57,17 +57,12 @@ if (err != nil) { return false, err } else { - log.Debugf("signed URL : %s", signedUrl) - return true, nil - //return uploadFileToDatastore(completeFilePath, signedUrl) + return uploadFileToDatastore(completeFilePath, signedUrl) } } func getSignedUrl(tenant, relativeFilePath, completeFilePath string) (string, error) { - //uapCollectionUrl := config.GetString(uapServerBase) + "/analytics" - - // localTesting - uapCollectionUrl := config.GetString(uapServerBase) + "/v1/upload/location" + uapCollectionUrl := config.GetString(uapServerBase) + "/analytics" req, err := http.NewRequest("GET", uapCollectionUrl, nil) if err != nil { @@ -81,8 +76,8 @@ q.Add("dataset", "api") q.Add("tenant", tenant) - q.Add("relativeFilePath", relativeFilePath) - q.Add("contentType", "application/x-gzip") + q.Add("relative_file_path", relativeFilePath) + q.Add("file_content_type", "application/x-gzip") req.URL.RawQuery = q.Encode() addHeaders(req)