Thread messaging message store

const RC = require('@ringcentral/sdk').SDK

// Instantiate the SDK and get the platform instance
var rcsdk = new RC({
    server: "https://platform.ringcentral.com",
    clientId: "RC_APP_CLIENT_ID",
    clientSecret: "RC_APP_CLIENT_SECRET"
});
var platform = rcsdk.platform();

/* Authenticate a user using a personal JWT token */
platform.login({ jwt: "RC_USER_JWT" })

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

platform.on(platform.events.loginError, function(e){
    console.log("Unable to authenticate to platform. Check credentials.", e.message)
    process.exit(1)
});

/*
  Read thread messages
*/
async function list_messages(){
  try{
    let queryParams = {
      // threadStatus: "Open",
      // threadId: "...",
      // ownerExtensionIds: ["..."],
      // messageIds: ["..."],
      // creationTimeFrom: "...",
      // creationTimeTo: "...",
      perPage: 10
    }

    let endpoint = `/restapi/v1.0/account/~/message-threads/messages`
    var resp = await platform.get(endpoint, queryParams)
    var jsonObj = await resp.json()
    for (let msg of jsonObj.records){
      // Parse and handle the message data

      // Check if this message has attachment(s)
      if (msg.attachments.length)
        await get_message_attachments(msg.attachments)
    }
  }catch(e){
    console.log(await e.message)
  }
}

/*
  Download attachment(s) and save to a local file
*/
async function get_message_attachments(attachments){
  let fs = require('fs')
  try {
    for (var attachment of attachments){
      var fileName = attachment.filename
      let resp = await platform.get(attachment.contentUri)
      let buffer = await resp.buffer()
      fs.writeFileSync(fileName, buffer)
    }
  }catch(e){
    console.log(e.message)
  }
}

import json
from ringcentral import SDK

#
# Read thread messages
#
def list_messages():
    try:
        query_params = {
            # "threadStatus": "Open",
            # "threadId": "...",
            # "ownerExtensionIds": ["..."],
            # "messageIds": ["..."],
            # "creationTimeFrom": "...",
            # "creationTimeTo": "...",
            "perPage": 10
        }

        endpoint = "/restapi/v1.0/account/~/message-threads/messages"

        resp = platform.get(endpoint, query_params)
        jsonObj = resp.json_dict()
        for msg in jsonObj['records']:
            # Parse and handle the message data

            # Check if this message has attachment(s)
            if msg.get("attachments"):
                get_message_attachments(msg["attachments"])
    except Exception as e:
        print(str(e))
#
# Download attachment(s) and save to a local file
#
def get_message_attachments(attachments):
    for attachment in attachments:
        fileName = str(attachment["filename"])
        try:
            res = platform.get(attachment["contentUri"])
            file = open(("%s" % (fileName)),'wb')
            file.write(res.body())
            file.close()
        except ApiException as e:
            print (e.getMessage())

# Authenticate a user using a personal JWT token
def login():
    try:
      platform.login( jwt= "RC_USER_JWT" )
      list_messages()
    except Exception as e:
      print ("Unable to authenticate to platform. Check credentials." + str(e))

# Instantiate the SDK and get the platform instance
rcsdk = SDK("RC_APP_CLIENT_ID", "RC_APP_CLIENT_SECRET", "https://platform.ringcentral.com")
platform = rcsdk.platform()

login()

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

// Instantiate the SDK and get the platform instance
$rcsdk = new RingCentral\SDK\SDK( "RC_APP_CLIENT_ID", "RC_APP_CLIENT_SECRET", "https://platform.ringcentral.com" );
$platform = $rcsdk->platform();

/* Authenticate a user using a personal JWT token */
try {
  $platform->login(["jwt" => "RC_USER_JWT"]);
}catch (\RingCentral\SDK\Http\ApiException $e) {
  exit("Unable to authenticate to platform. Check credentials. " . $e->message . PHP_EOL);
}
list_messages();

/*
  Read thread messages
*/
function list_messages() {
    global $platform;
    try {
        $queryParams = [
            // 'threadStatus' => 'Open',
            // 'threadId' => '...',
            // 'ownerExtensionIds' => ['...'],
            // 'messageIds' => ['...'],
            // 'creationTimeFrom' => '...',
            // 'creationTimeTo' => '...',
            'perPage' => 10
        ];

        $endpoint = '/restapi/v1.0/account/~/message-threads/messages';
        $response = $platform->get($endpoint, $queryParams);
        $jsonObj = $response->json();

        foreach ($jsonObj->records as $msg) {
            // Parse and handle the message data

            // Check if this message has attachment(s)
            if (!empty($msg->attachments)) {
                get_message_attachments($msg->attachments);
            }
        }
    } catch (Exception $e) {
        echo $e->getMessage();
    }
}

/*
 Download attachment(s) and save to a local file
*/
function get_message_attachments($attachments) {
  global $platform;
  try {
    foreach ($attachments as $attachment){
      $res = $platform->get($attachment->contentUri);
      file_put_contents($attachment->filename, $res->raw());
    }
  }catch (ApiException $e) {
    $message = $e->getMessage();
    print 'Expected HTTP Error: ' . $message . PHP_EOL;
  }
}
?>

require 'ringcentral'

#
# Read thread messages
#
def list_messages()
  begin
    query_params = {
      # threadStatus: "Open",
      # threadId: "...",
      # ownerExtensionIds: ["..."],
      # messageIds: ["..."],
      # creationTimeFrom: "...",
      # creationTimeTo: "...",
      perPage: 100
    }

    endpoint = "/restapi/v1.0/account/~/message-threads/messages"

    resp = $platform.get(endpoint, query_params)
    for msg in resp.body['records'] do
      # Parse and handle the message data

      # Check if this message has attachment(s)
      if msg["attachments"] && !msg["attachments"].empty?
        get_message_attachments(msg["attachments"])
      end
    end
  rescue StandardError => e
    puts e.message
  end
end

#
# Download attachment(s) and save to a local file
#
def get_message_attachments(attachments)
  begin
    for attachment in attachments
      fileName = attachment['filename']
      begin
        res = $platform.get(attachment['contentUri'])
        file = File.open(fileName, "w")
        file.write(res.body)
      rescue IOError => e
        puts e.getMessage()
      end
    end
  rescue StandardError => e
    puts (e)
  end
end

# Authenticate a user using a personal JWT token
def login()
  begin
    $platform.authorize( jwt: "RC_USER_JWT" )
    list_messages()
  rescue StandardError => e
    puts ("Unable to authenticate to platform. Check credentials." + e.to_s)
  end
end

# Instantiate the SDK and get the platform instance
$platform = RingCentral.new( "RC_APP_CLIENT_ID", "RC_APP_CLIENT_SECRET", "https://platform.ringcentral.com" )

login()