POST /v3/assets/multipart/upload
{
    "fileName": "FILE0013.MP4"
}

//200 OK
{
    "fileName": "FILE0013.MP4",
    "assetUrl": "https://s3.amazonaws.com/s3-bucket/9XXXXXX-7XX9-4XX5-bXX2-b07XXXXXX40b/FILE0013.MP4",
    "expiration": 1507790546000,
    "accessKey": "ASIAJCPLGOLJYYTKUXRQ",
    "secretKey": "TWfwinpU3YRUXzIN/UoSCqsoobOYKBAIpWMC4Si3",
    "sessionId": "9XXXXXX-7XX9-4XX5-bXX2-b07XXXXXX40b",
    "sessionToken": "FQoDYXdzEOf//////////wEaDDwBJ3jkRXXXXXXXXXXXXXXXXXXXXXXXvu8hRdXhhb9KEV3VUTiKxHJGmgkT3nd2FbNRJrWYLVG7acZk+Qr4XXXXXXXXXXXXXXXXXXXXG2g6K2tlh/QgMBGLBQ+/nMli2cKuh/CKGSZ3KibspxO+0t35v5rXXXXXXXXXXXXXXXXXXXXXXpYyhih7u1Q8iRSxmtjMf9uRg7RIZa8usnPRZhuAIU9Kc7Y+pJ8gIjTRZQdx5bdaU6hPJQXXXXXXXXXXXXXXXR9XK8Io4m49KzeXV6vKgAd9OV77f0kUc3mOVK2PMrzvOWCTykAjvYeC9XXXXXXXXXXXXXXXXXdEvuiDPZoMAPZ8cXRy3ts5WEr8eVBIaEj+nEtFQrAww3NCytRSXXXXXXXXXX208pDwsVNSMeKMKB/M4F",
    "objectKey": "9XXXXXX-7XX9-4XX5-bXX2-b07XXXXXX40b/FILE0013.MP4",
    "bucketName": "s3-bucket"
}

function uploadFileToS3(multipartUploadTicketResponse) {
  let { fileName, assetUrl, expiration, accessKey, secretKey, sessionId, sessionToken, objectKey, bucketName } = multipartUploadTicketResponse;
  console.log('\nmultipartUploadTicketResponse:', multipartUploadTicketResponse); // Logging out the multipart upload ticket response.

  globalSessionId = multipartUploadTicketResponse.sessionId;// Setting the SessionId that will be used to refresh the AWS credentials. Again, this is a UUID that identifies your specific upload session.

  const uploadBody = fs.createReadStream(filePath); // Specify the path to the file on your computer.

  let credentials = new AWS.Credentials({ accessKeyId: multipartUploadTicketResponse.accessKey, secretAccessKey: multipartUploadTicketResponse.secretKey, sessionToken: multipartUploadTicketResponse.sessionToken }); // Credentials Object used to authenitcate the multipart upload requests made to S3. These credentials are used each time an individual part of the file is uploaded.
  let service = new AWS.S3({ credentials }); // Service object that allows us to interact with AWS S3.
  let managedUpload = new AWS.S3.ManagedUpload({ params: { Bucket: multipartUploadTicketResponse.bucketName, Key: multipartUploadTicketResponse.objectKey, Body: uploadBody, }, service }); // This object handles uploading the file to S3 using multipart upload.

  managedUpload.promise().then(function () { // Calling this starts the multipart upload process.
    createAsset(multipartUploadTicketResponse.assetUrl); //We do not want to create the asset until the upload to S3 in finished.
  });

  managedUpload.on("httpUploadProgress", (progress) => {
    console.log(progress); // Logging out each part of the file that is uploaded to S3.
  });
};

POST /v3/assets
{
    "sourceUrl": "https://s3.amazonaws.com/s3-bucket/26a35865-282f-4aa2-b9af-1999d2c7835b/myfile.mov",
    "projectId": "0XXXCC-014B-2XX0-CF518DXXXX393E"
}

AWS.Credentials.prototype.refresh = function (callback) {
  var self = this;
  refreshTemporaryCredentials(function (err, response) {
    if (err) {
      callback(err);
    } else {
      console.log('\nCurrent SessionID: ', globalSessionId); // This will never change through out the entire upload of a single file.

      self.accessKeyId = response.data.accessKey; // Updating the accessKeyId.
      console.log('\nNew Access Key: ', response.data.accessKey)

      self.secretAccessKey = response.data.secretKey; // Updating the secretAccessKey.
      console.log('\nNew Secret Access Key: ', response.data.secretKey)

      self.sessionToken = response.data.sessionToken; // Updating the sessionToken.
      console.log('\nNew Session Token : ', response.data.sessionToken)

      callback();
    }
  });
};

function refreshTemporaryCredentials(callback) {
  axios.post('https://api.shift.io/v3/assets/multipart/upload', { "fileName": fileName, "sessionId": globalSessionId }, {
    headers: {
      'x-key': apiKey,
      'x-secret': apiSecret,
      'Content-Type': 'application/json',
    },
  })
    .then(response => {
      console.log('\nFinished creating new temporary Credentials');
      callback(null, response);
    })
    .catch(error => {
      console.error('\nError creating multipart upload ticket:', error.response);
    });
}

  const refreshInterval = setInterval(() => {
    credentials.refresh((err) => {
      if (err) {
        console.error('\nError refreshing temporary credentials:', err);
      } else {
        console.log('\nTemporary Credentials have been successfully refreshed.\n');
      }
    });
  }, 1800000); //1,800,000 milliseconds = 30 minutes. Reducing this number will increase the frequency at which your temporary credentials are refreshed.
  //If this number exceeds 3,599,999(59m 59s) then your upload will fail before your temporary credentials are refreshed. 

// This example was written using a Mac Computer.
// I ran `brew install node` to install the latest version of node. Which comes with npm
// Then i ran the commands `npm install aws-sdk && npm install axios && npm install fs`
// Save this file as multipartUpload.js
// Run this file using the latest version of Node with the command `node multipartUpload.js`
// Make sure to fill the variables on lines 15-18!

// Imports
const AWS = require('aws-sdk/global');
const S3 = require('aws-sdk/clients/s3');
const axios = require('axios');
const fs = require('fs');

// Global Variables
const apiKey = 'API_KEY_HERE'; // API Key for a specific ADMIN tied to a specific MediaSilo account. Example 23f9a04f-4a30-48fd-b1d9-0f8e699c2dbf
const apiSecret = 'API_SECRET_HERE'; // Secret Key for a specific ADMIN tied to a specific MediaSilo account. Example 1c975a31f4c6a4d7d7957f2512d514e5
const projectId = 'PROJECT_UUID_HERE'; //This ID references a real project in your Mediasilo account. This will be the final destination for the new asset. Example 550ddaa8-8be3-4f01-a828-6dad63e04863
let filePath = 'FULL_FILE_PATH_HERE'; //The exact path to the file on your computer. Example /Users/Maverick/Desktop/TestMedia/Videos/TopGun.mp4
let fileName = filePath.replace(/^.*?([^\\\/]*)$/, '$1'); //The name of your file which is extracted from the file path.
let globalSessionId; // This is a UUID that is used to identify your upload session. It is used to refresh credentials. This will be set after the createMultipartUploadTicket() function is called.

/*******************************************************************************************************
* Step 1: Create Multipart Upload Ticket
* Create a multipart upload ticket using the endpoint POST /v3/assets/multipart/upload. 
* This will have all the information needed to upload the asset to S3. 
* This includes fileName, sessionId, assetUrl, expiration, accessKey, secretKey,
* sessionToken, objectKey(path in S3 where the file is stored), and bucketName.
*
* Step 2: Upload File into S3
* Upload the asset to S3. Once the upload into S3 is complete, the assetUrl will be
* accessible to create the asset in your Mediasilo account. Although the assetUrl is
* returned in the multipart upload ticket, the assetUrl is not accessible until the upload
* is complete. For uploads that will take longer than one hour,
* see Step 4 below on Refreshing Credentials.
*
* Step 3: Create Asset
* Create the asset. Using the assetUrl and projectId, create the asset inside the
* desired project. The projectId is the UUID of an EXISTING project inside of your
* Mediasilo account.
*
* Step 4(Optional): Refreshing Temporary Credentials
* The Temporary Credentials, accessKey, secretKey, and sessionToken expire after 1 hour 
* from the time they were created or refreshed. When requesting temporary credentials,
* you pass in the file name. When you start uploading the file to S3, the sessionId is the
* reference to your specific upload session for an individual file. To refresh temporary credentials
* we use the same endpoint from Step 1 POST /v3/assets/multipart/upload. But this time we pass in the
* fileName and the sessionId. This way, the refreshed credentials have access to that specific
* upload session. The new refreshed credentials are interchangeable with the original credentials
* because they have the same exact access. There is a code example on refreshing credentials
* using the Mediasilo API further down this page.
*******************************************************************************************************/

// Function call to start the upload process
startAssetCreateProcess();

function startAssetCreateProcess() {
  createMultipartUploadTicket();
}

// ***** STEP 1 *****
function createMultipartUploadTicket() {
  /*
  *This is the POST request that is made to the API that returns the              
  *information needed to uploada file to S3, then later create an asset 
  */
  axios.post('https://api.shift.io/v3/assets/multipart/upload', { fileName }, {
    headers: {
      'x-key': apiKey,
      'x-secret': apiSecret,
      'Content-Type': 'application/json',
    },
  })
    .then(response => {
      console.log('\nFinished creating the multipart upload ticket.');
      uploadFileToS3(response.data);
    })
    .catch(error => {
      console.error('\nError creating multipart upload ticket:', error.response);
    });
}

// ***** STEP 2 *****
function uploadFileToS3(multipartUploadTicketResponse) {
  let { fileName, assetUrl, expiration, accessKey, secretKey, sessionId, sessionToken, objectKey, bucketName } = multipartUploadTicketResponse;
  console.log('\nmultipartUploadTicketResponse:', multipartUploadTicketResponse); // Logging out the multipart upload ticket response.

  globalSessionId = multipartUploadTicketResponse.sessionId;// Setting the SessionId that will be used to refresh the AWS credentials. Again, this is a UUID that identifies your specific upload session.

  const uploadBody = fs.createReadStream(filePath); // Specify the path to the file on your computer.

  let credentials = new AWS.Credentials({ accessKeyId: multipartUploadTicketResponse.accessKey, secretAccessKey: multipartUploadTicketResponse.secretKey, sessionToken: multipartUploadTicketResponse.sessionToken }); // Credentials Object used to authenitcate the multipart upload requests made to S3. These credentials are used each time an individual part of the file is uploaded.
  let service = new AWS.S3({ credentials }); // Service object that allows us to interact with AWS S3.
  let managedUpload = new AWS.S3.ManagedUpload({ params: { Bucket: multipartUploadTicketResponse.bucketName, Key: multipartUploadTicketResponse.objectKey, Body: uploadBody, }, service }); // This object handles uploading the file to S3 using multipart upload.

  managedUpload.promise().then(function () { // Calling this starts the multipart upload process.
    createAsset(multipartUploadTicketResponse.assetUrl); //We do not want to create the asset until the upload to S3 in finished.
  });

  managedUpload.on("httpUploadProgress", (progress) => {
    console.log(progress); // Logging out each part of the file that is uploaded to S3.
  });

  /*
  *Required for Step 4
  *
  *Temporary Credentials expire 1 hour after they are created or refreshed. 
  *This interval will refresh the temporary credentials every 30 minutes.
  *This ensures that uploads needing longer than one hour will complete.
  */
  const refreshInterval = setInterval(() => {
    credentials.refresh((err) => {
      if (err) {
        console.error('\nError refreshing temporary credentials:', err);
      } else {
        console.log('\nTemporary Credentials have been successfully refreshed.\n');
      }
    });
  }, 1800000); //1,800,000 milliseconds = 30 minutes. Reducing this number will increase the frequency at which your temporary credentials are refreshed.
  //If this number exceeds 3,599,999(59m 59s) then your upload will fail before your temporary credentials are refreshed. 
};

// ***** STEP 3 *****
function createAsset(assetPath) {
  /*
  *This is the POST request that is made to the API that creates your asset.
  *This will return the id of the asset that was created. 
  */
  axios.post('https://api.shift.io/v3/assets', { sourceUrl: assetPath, projectId }, {
    headers: {
      'x-key': apiKey,
      'x-secret': apiSecret,
      'Content-Type': 'application/json',
    },
  })
    .then(response => {
      console.log('\nAsset Created! Response:', response.data); // All Done! Your asset has been created.
      process.exit(); // Exit the script after successfully creating the asset in the Mediasilo Project.
    })
    .catch(error => {
      console.error('Error creating asset:', error.response.data);
    });
}

/*
*Required for Step 4
*
*This function is almost identical to the createMultipartUploadTicket. The main difference
*is that we are passing along a sessionId with a fileName when we make the POST request. 
*With the addition of the sessonId, the will API know to refresh your credentials.
* 
*This refresh function actually returns new temporary credentials. The access key
*and secret key will be different than the previous keys that you obtained from Step 1. The two important things to understand
*are that one, the new temporary credentials have the exact same permissions as the previous credentials,
*and two, the expireTime on the new temporary credentials is roughly one hour from the time you refreshed them.
*This allows the credentials to be interchangeable, even in the middle of an upload. 
*/
function refreshTemporaryCredentials(callback) {
  axios.post('https://api.shift.io/v3/assets/multipart/upload', { "fileName": fileName, "sessionId": globalSessionId }, {
    headers: {
      'x-key': apiKey,
      'x-secret': apiSecret,
      'Content-Type': 'application/json',
    },
  })
    .then(response => {
      console.log('\nFinished creating new temporary Credentials');
      callback(null, response);
    })
    .catch(error => {
      console.error('\nError creating multipart upload ticket:', error.response);
    });
}

// ***** STEP 4 *****
/*
*This block of code defines how the refresh() function will work.
*Any AWS.Credentials object that is created may use this refresh function.
*You can see that we using our refreshTemporaryCredentials() function from above.
*Then we take the response from that function and set the new values for our
*accessKeyId, secretAccessKey, and sessionToken.
*/
AWS.Credentials.prototype.refresh = function (callback) {
  var self = this;
  refreshTemporaryCredentials(function (err, response) {
    if (err) {
      callback(err);
    } else {
      console.log('\nCurrent SessionID: ', globalSessionId); // This will never change through out the entire upload of a single file.

      self.accessKeyId = response.data.accessKey; // Updating the accessKeyId.
      console.log('\nNew Access Key: ', response.data.accessKey)

      self.secretAccessKey = response.data.secretKey; // Updating the secretAccessKey.
      console.log('\nNew Secret Access Key: ', response.data.secretKey)

      self.sessionToken = response.data.sessionToken; // Updating the sessionToken.
      console.log('\nNew Session Token : ', response.data.sessionToken)

      callback();
    }
  });
};