PowerBuilder

Google Drive - Resumable Upload

See more Google Drive Examples

Demonstrates how to do a resumable upload to Google Drive. PowerBuilder

integer li_rc
integer li_Success
oleobject loo_Http
oleobject loo_Json
oleobject loo_Resp
integer li_StatusCode
oleobject loo_SbSessionUri
string ls_SessionUri
oleobject loo_Req
oleobject loo_Url

li_Success = 0

// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.

li_Success = 1

// This example uses a previously obtained access token having permission for the 
// Google Drive scope. 
// See Get Google Drive OAuth2 Access Token

loo_Http = create oleobject
li_rc = loo_Http.ConnectToNewObject("Chilkat.Http")
if li_rc < 0 then
    destroy loo_Http
    MessageBox("Error","Connecting to COM object failed")
    return
end if

loo_Http.AuthToken = "GOOGLE_DRIVE_ACCESS_TOKEN"

// First we want to initiate the resumable upload.
// We send a POST to get a session URI, which will be used to upload the file, and resume if needed.

// Our POST will look like this:

// POST https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable HTTP/1.1
// Authorization: Bearer [YOUR_AUTH_TOKEN]          <-- Chilkat automatically adds this header because the AuthToken property was set.
// Content-Length: 38                               <-- Chilkat will automatically add this header.
// Content-Type: application/json; charset=UTF-8    <-- This is the type of this POST, and is specified in the call to HttpJson.
// X-Upload-Content-Type: application/zip           <-- The type of file we'll be uploading
// X-Upload-Content-Length: 1366807                 <-- The size of the file we'll be uploading
// 
// {
//   "name": "myObject"
// }

loo_Http.SetRequestHeader("X-Upload-Content-Type","application/zip")
loo_Http.SetRequestHeader("X-Upload-Content-Length","1366807")

loo_Json = create oleobject
li_rc = loo_Json.ConnectToNewObject("Chilkat.JsonObject")

loo_Json.UpdateString("name","myZip")

loo_Resp = create oleobject
li_rc = loo_Resp.ConnectToNewObject("Chilkat.HttpResponse")

li_Success = loo_Http.HttpJson("POST","https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable",loo_Json,"application/json",loo_Resp)
if li_Success = 0 then
    Write-Debug loo_Http.LastErrorText
    destroy loo_Http
    destroy loo_Json
    destroy loo_Resp
    return
end if

li_StatusCode = loo_Resp.StatusCode
if li_StatusCode <> 200 then
    Write-Debug loo_Resp.BodyStr
    Write-Debug "response status = " + string(li_StatusCode)
    destroy loo_Http
    destroy loo_Json
    destroy loo_Resp
    return
end if

// The session URI is in the "Location" response header:
loo_SbSessionUri = create oleobject
li_rc = loo_SbSessionUri.ConnectToNewObject("Chilkat.StringBuilder")

loo_SbSessionUri.Append(loo_Resp.GetHeaderField("Location"))
ls_SessionUri = loo_SbSessionUri.GetAsString()
Write-Debug "Session URI: " + ls_SessionUri

// Here's a sample session URI:  https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable&upload_id=AEnB2UrszR8lDqlo3mtXJw_0rYI_Hi1oVh1NPFcLfoyBq9NcSjk85kFopoZaVEgT38OSmLl0XsObPf4iCSJwHlrOvvIJQ_ckIQ

// -----------------------------------------------------------------------------
// The next step is to upload the file using the session URI:

// We'll send a PUT that looks like this:

// PUT https://www.googleapis.com/upload/drive/v3/files?uploadType=resumable&upload_id=xa298sd_sdlkj2 HTTP/1.1
// Content-Length: 1366807
// Content-Type: application/zip
// 
// [BYTES 0-1366806]

// First remove the X-Upload-Content-Type and X-Upload-Content-Length request headers we specified earlier, so they don't get sent with subsequent requests.
loo_Http.ClearHeaders()

// Because the file is likely large, we'll use HttpSReq which allows to to pass an HTTP request object where the body can be streamed directly from a file.
loo_Req = create oleobject
li_rc = loo_Req.ConnectToNewObject("Chilkat.HttpRequest")

loo_Req.ContentType = "application/zip"
loo_Req.HttpVerb = "PUT"

loo_Url = create oleobject
li_rc = loo_Url.ConnectToNewObject("Chilkat.Url")

loo_Url.ParseUrl(ls_SessionUri)

loo_Req.Path = loo_Url.PathWithQueryParams
Write-Debug "Path with Query Param: " + loo_Url.PathWithQueryParams

// Specify that the request body is to be streamed directly from a file.
li_Success = loo_Req.StreamBodyFromFile("qa_data/zips/big.zip")
if li_Success = 0 then
    Write-Debug loo_Req.LastErrorText
    destroy loo_Http
    destroy loo_Json
    destroy loo_Resp
    destroy loo_SbSessionUri
    destroy loo_Req
    destroy loo_Url
    return
end if

li_Success = loo_Http.HttpSReq(loo_Url.Host,loo_Url.Port,loo_Url.Ssl,loo_Req,loo_Resp)
if li_Success = 0 then
    Write-Debug loo_Http.LastErrorText
    destroy loo_Http
    destroy loo_Json
    destroy loo_Resp
    destroy loo_SbSessionUri
    destroy loo_Req
    destroy loo_Url
    return
end if

Write-Debug loo_Resp.BodyStr
Write-Debug "response status = " + string(loo_Resp.StatusCode)

// Sample output:

// {
//  "kind": "drive#file",
//  "id": "1rx20i53eurtkVQ-RT7Ry8Ct85PgPYMET",
//  "name": "myZip",
//  "mimeType": "application/zip"
// }
// 
// response status = 200


destroy loo_Http
destroy loo_Json
destroy loo_Resp
destroy loo_SbSessionUri
destroy loo_Req
destroy loo_Url