{

// Main application module. This application depends on the Angular 'ngAnimate' module.

// As the name implies, 'ngAnimate' provides animation using CSS styles which allows visual

// feedback when the status of the service is updated.

var app = angular.module('NewsWidget',['ngAnimate']);

// Application session configuration

// Define the session (TREP, RDP/ERT) you wish to use to access streaming services. To define your session,

// update the following setting:

// session: undefined

//

// Eg: session: 'RDP' // RDP/ERT Session

// session: 'ADS' // TREP/ADS Session

app.constant('config', {

session: 'RDP', // 'ADS' or 'RDP'.

// TREP (ADS) session.

// This section defines the connection and authentication requirements to connect directly into the

// streaming services from your locally installed TREP installation.

// Load this example directly within your browswer.

adsSession: {

wsServer: 'ewa', // Address of our ADS Elektron WebSocket server. Eg: 'elektron'

wsPort: '15000', // Address port of our ADS Elektron Websccket server. Eg: 15000

wsLogin: { // Elektron WebSocket login credentials

user: 'user', // User name. Optional. Default: desktop login.

appId: '256', // AppID. Optional. Default: '256'

position: '127.0.0.1' // Position. Optional. Default: '127.0.0.1'

}

},

// ERT (Elektron Real Time) in Cloud session.

// This section defines authenticastion to access RDP (Refinitiv Data Platform)/ERT.

// Start the local HTTP server (provided) and within your browser, specify the URL: http://localhost:8080/quoteObject.html

rdpSession: {

wsLogin: {

user: '',

password: '',

clientId: undefined

},

restAuthHostName: 'https://api.refinitiv.com/auth/oauth2/v1/token',

restServiceDiscovery: 'https://api.refinitiv.com/streaming/pricing/v1/',

wsLocation: 'us-east-1a'

},

//wsService: 'ELEKTRON_EDGE' // Optional. Elektron WebSocket service hosting realtime market data

});

// ****************************************************************

// Custom filters used when displaying data in our widget

// ****************************************************************

// ricList

// Extract the RICs from the subject array and format as a simple list of rics, space separated.

app.filter('ricList', function() {

return( function(rics) {

// Filter out the "R:" portion for each entry

var result = rics.map(ric => ric.substr(2));

if (result.length > 0) {

var list = "";

for (var i = 0; i < result.length; i++)

list = list + result[i] + " ";

return(list);

}

return("");

});

});

//******************************************************************************************

// Sharable Services

//

// widgetStatus - Capture the status messages generated from the Elektron WebSocket server

// and display as a pull-down list to see history.

//******************************************************************************************

app.factory('widgetStatus', $timeout => {

let statusList = [];

return ({

list: function () { return (statusList); },

update: function (txt,msg) {

}

});

});

//***********************************

// Translation code

// added by James Sullivan 2019/09/19

// Needs a paid API key from the Google API Console: https://console.developers.google.com/apis/credentials

// Unfortunately free and trial keys are too slow to keep up with speed of news

// NOTE NOT SECURE this key is exposed on the client so only use for internal demo purposes

//

const apiKey = '';

window.onload = function() {

}

var storyTranslationObj = {

sourceLang: 'en',

targetLang: 'ja',

textToTranslate: 'This is a news story.',

format: "text"

};

var headlineTranslationObj = {

sourceLang: 'en',

targetLang: 'ja',

textToTranslate: 'This is a news headline.',

format: "text"

};

function translationURL(data) {

}

var noStoryData = new Map ([

['en', 'No story available'], // default

['ko', '뉴스 기사가 없습니다'],

['pt', 'Nenhuma notícia disponível'],

['es', 'No hay noticias disponibles'],

['zh', '没有可用的新闻报导'],

['ja', '利用可能なニュース記事はありません'],

]);

var noStory = new Proxy(noStoryData, {

get: function(target, id) {

return target.has(id) ? target.get(id) : target.get("en");

},

});

//**********************************************************************************************

// User-defined Directives

//

// animateOnChange - Directive to show change in our view.

//**********************************************************************************************

app.directive('animateOnChange', $animate => {

return ((scope, elem, attr) => {

scope.$watch(attr.animateOnChange, (newVal, oldVal) => {

if (newVal != oldVal) {

$animate.enter(elem, elem.parent(), elem, () => $animate.leave(elem));

}

})

});

});

// Widget Controller

// This controller manages all interaction, behavior and display within our application.

app.controller('widgetController', function ($scope, $rootScope, widgetStatus, config )

{

// Some initialization

$scope.statusList = widgetStatus.list();

this.filter = "";

this.selectedFilter = "";

this.alreadySelectedStory = null;

this.selectedStory = null;

this.selectedLanguage = ""

this.needsConfiguration = (config.session === undefined);

// *****************************************************************

// For simplicity, we capture all the MRN stories, in memory, as

// they stream to us.

// *****************************************************************

this.stories = []; // Our data model. Collection of ews stories.

// Define the WebSocket interface to manage our streaming services

this.ertController = new ERTWebSocketController();

// RDP Authentication

// Only applicable if a user chooses an ERT Session.

this.rdpController = new ERTRESTController();

// Initialize our session

switch (config.session) {

case 'ADS':

widgetStatus.update("Connecting to the WebSocket streaming service on ["+ config.adsSession.wsServer + ":" + config.adsSession.wsPort + "]");

this.ertController.connectADS(config.adsSession.wsServer, config.adsSession.wsPort, config.adsSession.wsLogin.user,

config.adsSession.wsLogin.appId, config.adsSession.wsLogin.position);

break;

case 'RDP':

widgetStatus.update("Authenticating with RDP using " + config.rdpSession.restAuthHostName + "...");

this.rdpController.get_access_token({

'username': config.rdpSession.wsLogin.user,

'password': config.rdpSession.wsLogin.password,

'clientId': config.rdpSession.wsLogin.clientId,

'location': config.rdpSession.wsLocation

});

break;

}

this.selectStory = function(story) {

}

this.alreadySelectedStory = function(){

if(this.selectedStory != null) { this.selectStory(this.selectedStory) } else{null;}

}

this.makeStoryTranslationRequest = function(data, mySelectedStory) {

}

this.selectedStoryText = function() {

}

//***********************************************************************************

// ERTRESTController.onStatus

//

// Capture all ERTRESTController status messages.

// RDP/ERT uses OAuth 2.0 authentication and requires clients to use access tokens to

// retrieve streaming content. In addition, RDP/ERT requires clients to continuously

// refresh the access token to continue uninterrupted service.

//

// The following callback will capture the events related to retrieving and

// continuously updating the tokens in order to provide the streaming interface these

// details to maintain uninterrupted service.

//***********************************************************************************

this.rdpController.onStatus((eventCode, msg) => {

let status = this.rdpController.status;

switch (eventCode) {

case status.getRefreshToken: // Get Access token form RDP (re-refresh Token case)

this.auth_obj = msg;

widgetStatus.update("RDP Authentication Refresh success. Refreshing ERT stream...");

this.ertController.refreshERT(msg);

break;

case status.getService: // Get Service Discovery information form RDP

// Connect into ERT in Cloud Elektron WebSocket server

this.ertController.connectERT(msg.hostList, msg.portList, msg.access_token, config.rdpSession.appId, config.rdpSession.position);

break;

case status.authenError: // Get Authentication fail error form RDP

widgetStatus.update("Elektron Real Time in Cloud authentication failed. See console.", msg);

break;

case status.getServiceError: // Get Service Discovery fail error form RDP

widgetStatus.update("Elektron Real Time in Cloud Service Discovery failed. See console.", msg);

break;

}

});

//*******************************************************************************

// ERTWebSocketController.onStatus

//

// Capture all ERTWebSocketController status messages.

//*******************************************************************************

this.ertController.onStatus( (eventCode, msg) => {

let status = this.ertController.status;

switch (eventCode) {

case status.connected:

// ERTWebSocketController first reports success then will automatically

// attempt to log in to the ERT WebSocket server...

console.log(`Successfully connected into the ERT WebSocket server: ${msg.server}:${msg.port}`);

break;

case status.disconnected:

widgetStatus.update(`Connection to ERT streaming server: ${msg.server}:${msg.port} is down/unavailable`);

break;

case status.loginResponse:

this.processLogin(msg);

break;

case status.msgStatus:

// Report potential issues with our requested market data item

this.error = (msg.Key ? msg.Key.Name+":" : "");

this.error += msg.State.Text;

widgetStatus.update("Status response for item: " + this.error);

break;

case status.msgError:

// Report invalid usage errors

widgetStatus.update(`Invalid usage: ${msg.Text}. ${msg.Debug.Message}`);

break;

case status.tokenExpire:

widgetStatus.update("Elektron Data Platform Authentication Expired");

break;

case status.refreshSuccess:

widgetStatus.update("Elektron Data Platform Authentication Refresh success")

break;

case status.processingError:

// Report any general controller issues

widgetStatus.update(msg);

break;

}

});

//*********************************************************************************

// processLogin

// Determine if we have successfully logged into our WebSocket server. Within

// our Login response, we need to check the following stanza:

//

// "State": {

// "Stream": <stream state>, "Open" | "Closed"

// "Data": <data state>, "Ok" | "Suspect"

// "Text": <reason>

// }

//

// If we logged in, open the news stream.

//*********************************************************************************

this.processLogin = function (msg) {

};

//********************************************************************************************

// TRWebSocketController.onNews

// Capture all news stories generated from MRN. All stories presented here are complete and

// decompressed. We simply store each story within our data model.

//********************************************************************************************

this.ertController.onNews( (ric, story) => {

$scope.$apply( () => {

// Abstract API request function

function makeHeadlineTranslationRequest(data, storiesPointer) {

}

// Store the new story

if(story.headline.length > 0) {

if(this.selectedLanguage == '' || apiKey == '' || story.language == this.selectedLanguage) {

// 'no need to translate'

story.translatedHeadline = story.headline;

this.stories.unshift(story);

} else {

// 'translating from ' + story.language + ' to ' + this.selectedLanguage

headlineTranslationObj.textToTranslate = story.headline;

headlineTranslationObj.targetLang = this.selectedLanguage;

headlineTranslationObj.sourceLang = story.language;

makeHeadlineTranslationRequest(headlineTranslationObj, this.stories);

}

}

// Simple trim to keep the stories in memory manageable

if ( this.stories.length > 1000 )

this.stories.pop();

});

});

});