Message Store Exports

const RC = require('@ringcentral/sdk').SDK
var fs = require('fs')
var https = require('https');

var rcsdk = new RC({ server: "server_url", clientId: "client_id", clientSecret: "client_secret" });
var platform = rcsdk.platform();

platform.login({ username: "username", password: "password", extension: "extension_number" })

platform.on(platform.events.loginSuccess, function(e) {
  create_message_store_report()
});

async function create_message_store_report() {
  try {
    var endpoint = "/restapi/v1.0/account/~/message-store-report"
    var params = {
      dateFrom: "2019-03-01T00:00:00.000Z",
      dateTo: "2019-03-31T23:59:59.999Z"
    }
    var resp = await platform.post(endpoint, params)
    var jsonObj = await resp.json()
    get_message_store_report_task(jsonObj.id)
  } catch (e) {
    console.log(e)
  }
}

async function get_message_store_report_task(taskId) {
  console.log("check task creation status ...")
  try {
    var endpoint = "/restapi/v1.0/account/~/message-store-report/" + taskId
    var resp = await platform.get(endpoint)
    var jsonObj = await resp.json()
    if (jsonObj.status == "Completed") {
      get_message_store_report_archive(jsonObj.id)
    } else {
      setTimeout(function() {
        get_message_store_report_task(taskId)
      }, 10000);
    }
  } catch (e) {
    console.log(e)
  }
}

async function get_message_store_report_archive(taskId) {
  console.log("getting report uri ...")
  try {
    var endpoint = `/restapi/v1.0/account/~/message-store-report/${taskId}/archive`
    var resp = await platform.get(endpoint)
    var jsonObj = await resp.json()
    var date = new Date()
    for (var i = 0; i < jsonObj.records.length; i++) {
      var fileName = "message_store_content_" + date.toISOString() + "_" + i + ".zip"
      get_message_store_report_archive_content(jsonObj.records[i].uri, fileName)
    }
  } catch (e) {
    console.log(e)
  }
}

async function get_message_store_report_archive_content(contentUri, fileName) {
  var uri = platform.createUrl(contentUri, { addToken: true });
  download(uri, fileName, function() {
    console.log("Save report zip file to the local machine.")
  })
}

const download = function(uri, dest, cb) {
  var file = fs.createWriteStream(dest);
  var request = https.get(uri, function(response) {
    response.pipe(file);
    file.on('finish', function() {
      file.close(cb);
    });
  });
}

from ringcentral import SDK

sdk = SDK( "client_id", "client_secret", "server_url" )
platform = sdk.platform()
platform.login( "username", "extension", "password" )

def create_message_store_report() :
    endpoint = "/restapi/v1.0/account/~/message-store-report"
    params = {
    "dateFrom": "2019-01-01T00:00:00.000Z",
    "dateTo": "2019-03-31T23:59:59.999Z"
    }
    response = platform.post(endpoint, params)
    json = response.json()
    get_message_store_report_task(json.id)

def get_message_store_report_task(taskId):
    print("check task creation status ...")
    endpoint = "/restapi/v1.0/account/~/message-store-report/" + taskId
    response = platform.get(endpoint)
    json = response.json()
    if json.status == "Completed":
        get_message_store_report_archive(taskId)
    else:
        time.sleep(2)
        get_message_store_report_task(taskId)

def get_message_store_report_archive(taskId):
    print("getting report uri ...")
    endpoint = "/restapi/v1.0/account/~/message-store-report/"+ taskId +"/archive"
    response = platform.get(endpoint)
    jsonObj = response.json()
    length = len(jsonObj.records)
    dateLog = datetime.datetime.today().strftime("%Y_%m_%d_%H_%M")
    for i in range(length):
        fileName = "message_store_content_" + dateLog + "_" + str(i) + ".zip"
        get_message_store_report_archive_content(jsonObj.records[i].uri, fileName)

def get_message_store_report_archive_content(contentUri, zipFile):
    print("Save report zip file to the local machine.")
    uri = platform.create_url(contentUri, False, None, True);
    print (uri)
    fileHandler = urllib2.urlopen(uri)
    with open(zipFile, 'wb') as output:
        output.write(fileHandler.read())

create_message_store_report()

<?php
require('vendor/autoload.php');

$rcsdk = new RingCentral\SDK\SDK( "client_id", "client_secret", "server_url" );

$platform = $rcsdk->platform();
$platform->login( "username", "extension_number", "password" );

create_message_store_report();

function create_message_store_report(){
    global $platform;
    echo ("create report ...\n");
    $endpoint = "/account/~/message-store-report";
    try {
    $response = $platform->post($endpoint,
        array(
        'dateFrom' => "2019-03-01T00:00:00.000Z",
        'dateTo' => "2019-03-31T23:59:59.999Z",
        ));
    $json = $response->json();
    get_message_store_report_task($json->id);
    }catch(\RingCentral\SDK\Http\ApiException $e) {
    echo($e);
    }
}

function get_message_store_report_task($taskId){
    global $platform;
    echo ("check task creation status ...\n");
    $endpoint = "/account/~/message-store-report/" . $taskId;
    try {
    $response = $platform->get($endpoint);
    $json = $response->json();
    if ($json->status == "Completed")
        get_message_store_report_archive($json->id);
    else if ($json->status == "Accepted" || $json->status == "InProgress"){
        sleep(2);
        get_message_store_report_task($taskId);
    }else
      echo ($json->status);
    }catch(\RingCentral\SDK\Http\ApiException $e) {
    echo($e);
    }
}

function get_message_store_report_archive($taskId){
    global $platform;
    echo ("getting report uri ...\n");
    $endpoint = "/account/~/message-store-report/" . $taskId . "/archive";
    try {
    $response = $platform->get($endpoint);
    $json = $response->json();
    for ($i=0; $i < count($json->records); $i++){
        $fileName = "message_store_content_" . date("Y_m_d_H_i", time()) . "_" . $i . ".zip";
        get_message_store_report_archive_content($json->records[$i]->uri, $fileName);
    }
    echo ("Done!\n");
    }catch(\RingCentral\SDK\Http\ApiException $e) {
    echo($e);
    }
}

function get_message_store_report_archive_content($contentUri, $fileName){
    global $platform;
    global $archiveFolder;
    echo ("Save report zip file to the local machine.\n");
    $uri = $platform->createUrl($contentUri, array(
    'addServer' => false,
    'addMethod' => 'GET',
    'addToken'  => true
    ));
    $dest = $archiveFolder.$fileName;
    file_put_contents($dest, fopen($uri, 'r'));
}

using System;
using System.Threading.Tasks;
using RingCentral;

namespace Export_MessageStore
{
class Program
{
  static RestClient rcsdk;
  static void Main(string[] args)
  {
    rcsdk = new RestClient("client_id", "client_secret", "server_url");
    await rcsdk.Authorize("username", "extension_number", "password");
    export_message_store().Wait();
  }
  static private async Task export_message_store()
  {
    var parameters = new CreateMessageStoreReportRequest();
    parameters.dateFrom = "2019-01-01T00:00:00.000Z";
    parameters.dateTo = "2019-03-31T23:59:59.999Z";

    var response = await rcsdk.Restapi().Account().MessageStoreReport().Post(parameters);
    var jsonStr = JsonConvert.SerializeObject(response);
    Console.WriteLine(jsonStr);
    bool polling = true;
    while (polling)
    {
      Console.WriteLine("check task creation status ...");
      Thread.Sleep(5000);
      response = await rcsdk.Restapi().Account().MessageStoreReport(response.id).Get();
      if (response.status != "InProgress")
      {
        polling = false;
      }
    }
    if (response.status == "Completed")
    {
      var resp = await rcsdk.Restapi().Account().MessageStoreReport(response.id).Archive().List();
      DateTime value = DateTime.Now;
      var dateStr = value.ToString("yyyy-MM-dd-HH_mm");
      for (var i = 0; i < resp.records.Length; i++)
      {
        var fileName = "message_store_content_" + dateStr + "_" + i + ".zip";
        var contentUrl = resp.records[i].uri + "?access_token=" + rcsdk.token.access_token;
        WebClient webClient = new WebClient();
        webClient.DownloadFile(contentUrl, fileName);
      }
    }
  }
}
}

import com.ringcentral.*;
import com.ringcentral.definitions.*;
import java.io.BufferedInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URL;

public class Export_MessageStore {
  static RestClient rcsdk;
  public static void main(String[] args) {
    var obj = new Export_MessageStore();
    rcsdk = new RestClient("client_id", "client_secret", "server_url");
    try {
      rcsdk.authorize("username", "extension_number", "password");
      obj.export_message_store();
    } catch (RestException | IOException e) {
      e.printStackTrace();
    }
  }

  public static void export_message_store() throws RestException, IOException {
    var parameters = new CreateMessageStoreReportRequest();
    parameters.dateFrom = "2019-01-01T00:00:00.000Z";
    parameters.dateTo = "2019-03-31T23:59:59.999Z";

    var response =  rcsdk.restapi().account().messagestorereport().post(parameters);
    var taskId = response.id;
    boolean polling = true;
    while (polling)
    {
      System.out.println("check task creation status ...");
      try {
        Thread.sleep(5000);
        response = rcsdk.restapi().account().messagestorereport(taskId).get();
        if (!response.status.equals("InProgress"))
          polling = false;
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
    if (response.status.equals("Completed")) {
      SimpleDateFormat formatter= new SimpleDateFormat("yyyy-MM-dd-HH_mm");
      Date date = new Date(System.currentTimeMillis());
      var dateStr = formatter.format(date);
      var resp = rcsdk.restapi().account().messagestorereport(response.id).archive().list();
      for (var i = 0; i < resp.records.length; i++)
      {
        var fileName = "./src/test/resources/message_store_content_" + dateStr + "_" + i + ".zip";
        var contentUrl = resp.records[i].uri + "?access_token=" + rcsdk.token.access_token;
        try (BufferedInputStream inputStream = new BufferedInputStream(new URL(contentUrl).openStream());
             FileOutputStream fileOS = new FileOutputStream(fileName)) {
          byte data[] = new byte[1024];
          int byteContent;
          while ((byteContent = inputStream.read(data, 0, 1024)) != -1) {
            fileOS.write(data, 0, byteContent);
          }
        } catch (IOException e) {
          // handles IO exceptions
        }
      }
    }
  }
}

require 'ringcentral'
require "open-uri"

$rc = RingCentral.new( 'client_id', 'client_secret', 'server_url')
$rc.authorize( username:  'username', extension: 'extension_number', password:  'password')

def create_message_store_report()
    endpoint = "/restapi/v1.0/account/~/message-store-report"
    response = $rc.post(endpoint, payload: {
          dateFrom: "2019-01-01T00:00:00.000Z",
          dateTo: "2019-03-31T23:59:59.999Z"
      })
    puts response.body['id']
    puts response.body['status']
    get_message_store_report_task(response.body['id'])
end

def get_message_store_report_task(taskId)
    puts "check task creation status ..."
    endpoint = "/restapi/v1.0/account/~/message-store-report/" + taskId
    response = $rc.get(endpoint)
    if response.body['status'] == "Completed"
      get_message_store_report_archive(taskId)
    else
      sleep(2)
      get_message_store_report_task(taskId)
  end
end

def get_message_store_report_archive(taskId)
    puts "getting report uri ..."
    endpoint = "/restapi/v1.0/account/~/message-store-report/"+ taskId +"/archive"
    response = $rc.get(endpoint)
    length = response.body['records'].length
    dateLog = Time.now.strftime("%Y_%m_%d_%H_%M")
    for i in (0...length)
        fileName = "message_store_content_" + dateLog + "_" + i.to_s + ".zip"
        get_message_store_report_archive_content(response.body['records'][i]['uri'], fileName)
    end
end

def get_message_store_report_archive_content(contentUri, zipFile)
    puts "Save report zip file to the local machine."
    uri = contentUri + "?access_token=" + $rc.token['access_token']
    open(uri) do |data|
       File.open(zipFile, "wb") do |file|
         file.write(data.read)
       end
    end
end

create_message_store_report()