vbatts/microservices-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Add logs

Browse source
This commit is contained in:
Ace Nassri 2018-06-25 15:47:39 -07:00
parent 296841756d
commit f6ab191e2f
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/currencyservice/server.js
View file

@ -31,6 +31,7 @@ const shopProto = grpc.load(PROTO_PATH).hipstershop;
let _data; let _data;
function _getCurrencyData (callback) { function _getCurrencyData (callback) {
if (!_data) { if (!_data) {
console.log('Fetching currency data...')
request(DATA_URL, (err, res) => { request(DATA_URL, (err, res) => {
if (err) { if (err) {
throw new Error(`Error getting data: ${err}`); throw new Error(`Error getting data: ${err}`);
@ -52,6 +53,7 @@ function _getCurrencyData (callback) {
}); });
}); });
} else { } else {
console.log('Using cached currency data...')
callback(_data); callback(_data);
} }
} }
@ -70,6 +72,7 @@ function _carry (amount) {
* Lists the supported currencies * Lists the supported currencies
*/ */
function getSupportedCurrencies (call, callback) { function getSupportedCurrencies (call, callback) {
console.log('Getting supported currencies...')
_getCurrencyData((data) => { _getCurrencyData((data) => {
callback(null, {currency_codes: Object.keys(data)}); callback(null, {currency_codes: Object.keys(data)});
}); });
@ -79,6 +82,7 @@ function getSupportedCurrencies (call, callback) {
* Converts between currencies * Converts between currencies
*/ */
function convert (call, callback) { function convert (call, callback) {
console.log('Starting conversion request...')
try { try {
_getCurrencyData((data) => { _getCurrencyData((data) => {
const request = call.request; const request = call.request;
@ -97,9 +101,11 @@ function convert (call, callback) {
}); });
target.fractional = Math.round(target.fractional); target.fractional = Math.round(target.fractional);
console.log('Conversion request successful.')
callback(null, {currency_code: request.to_code, amount: target}); callback(null, {currency_code: request.to_code, amount: target});
}); });
} catch (err) { } catch (err) {
console.error('Conversion request failed.')
callback(err.message); callback(err.message);
} }
} }
@ -109,6 +115,7 @@ function convert (call, callback) {
* CurrencyConverter service at the sample server port * CurrencyConverter service at the sample server port
*/ */
function main () { function main () {
console.log(`Starting gRPC server on port ${PORT}...`);
const server = new grpc.Server(); const server = new grpc.Server();
server.addService(shopProto.CurrencyService.service, {getSupportedCurrencies, convert}); server.addService(shopProto.CurrencyService.service, {getSupportedCurrencies, convert});
server.bind(`0.0.0.0:${PORT}`, grpc.ServerCredentials.createInsecure()); server.bind(`0.0.0.0:${PORT}`, grpc.ServerCredentials.createInsecure());