From 1bf3f56c9798e8e162ffe1383bcef22580e1defb Mon Sep 17 00:00:00 2001 From: Michael Lumish Date: Thu, 22 Jun 2023 17:48:33 -0700 Subject: [PATCH] [examples] Replace Node example files with references to the new location (#33522) This change is part of a migration of the Node examples from this repository to the grpc/grpc-node repository, along with grpc/grpc-node#2474. I replaced the files with references to the new location instead of deleting them so that people following links in existing external resources would find information about the new location instead of an unhelpful 404 error. I discovered that even some of the individual `.js` files are linked from other places, so to be safe I performed this replacement on every file in the directory. --- examples/node/README.md | 51 +- examples/node/dynamic_codegen/README.md | 2 +- .../node/dynamic_codegen/greeter_client.js | 40 +- .../node/dynamic_codegen/greeter_server.js | 35 +- .../dynamic_codegen/route_guide/README.md | 6 +- .../route_guide/route_guide_client.js | 220 +--- .../route_guide/route_guide_db.json | 602 +--------- .../route_guide/route_guide_server.js | 228 +--- examples/node/package.json | 13 +- examples/node/static_codegen/README.md | 9 +- .../node/static_codegen/greeter_client.js | 33 +- .../node/static_codegen/greeter_server.js | 28 +- .../node/static_codegen/helloworld_grpc_pb.js | 45 +- examples/node/static_codegen/helloworld_pb.js | 310 +---- .../node/static_codegen/route_guide/README.md | 6 +- .../route_guide/route_guide_client.js | 220 +--- .../route_guide/route_guide_db.json | 602 +--------- .../route_guide/route_guide_grpc_pb.js | 130 +- .../route_guide/route_guide_pb.js | 1060 +---------------- .../route_guide/route_guide_server.js | 227 +--- examples/node/xds/greeter_client.js | 45 +- examples/node/xds/package.json | 11 +- 22 files changed, 22 insertions(+), 3901 deletions(-) diff --git a/examples/node/README.md b/examples/node/README.md index b45488b8b56..6262c1432ad 100644 --- a/examples/node/README.md +++ b/examples/node/README.md @@ -1,50 +1 @@ -gRPC in 3 minutes (Node.js) -=========================== - -PREREQUISITES -------------- - -- `node`: This requires Node 0.12.x or greater. - -INSTALL -------- - - ```sh - $ # Get the gRPC repository - $ export REPO_ROOT=grpc # REPO root can be any directory of your choice - $ git clone -b RELEASE_TAG_HERE https://github.com/grpc/grpc $REPO_ROOT - $ cd $REPO_ROOT - - $ cd examples/node - $ npm install - ``` - -TRY IT! -------- - -There are two ways to generate the code needed to work with protocol buffers in Node.js - one approach uses [Protobuf.js](https://github.com/dcodeIO/ProtoBuf.js/) to dynamically generate the code at runtime, the other uses code statically generated using the protocol buffer compiler `protoc`. The examples behave identically, and either server can be used with either client. - - - Run the server - - ```sh - $ # from this directory - $ node ./dynamic_codegen/greeter_server.js & - $ # OR - $ node ./static_codegen/greeter_server.js & - ``` - - - Run the client - - ```sh - $ # from this directory - $ node ./dynamic_codegen/greeter_client.js - $ # OR - $ node ./static_codegen/greeter_client.js - ``` - -TUTORIAL --------- -You can find a more detailed tutorial in [gRPC Basics: Node.js][] - -[Install gRPC Node]:../../src/node -[gRPC Basics: Node.js]:https://grpc.io/docs/languages/node/basics +These examples have been moved to [the grpc/grpc-node repository](https://github.com/grpc/grpc-node/tree/master/examples). diff --git a/examples/node/dynamic_codegen/README.md b/examples/node/dynamic_codegen/README.md index 1a6ec17a3ee..6262c1432ad 100644 --- a/examples/node/dynamic_codegen/README.md +++ b/examples/node/dynamic_codegen/README.md @@ -1 +1 @@ -This is the dynamic code generation variant of the Node examples. Code in these examples is generated at runtime using Protobuf.js. +These examples have been moved to [the grpc/grpc-node repository](https://github.com/grpc/grpc-node/tree/master/examples). diff --git a/examples/node/dynamic_codegen/greeter_client.js b/examples/node/dynamic_codegen/greeter_client.js index c1274b11f3e..143661be833 100644 --- a/examples/node/dynamic_codegen/greeter_client.js +++ b/examples/node/dynamic_codegen/greeter_client.js @@ -16,42 +16,4 @@ * */ -var PROTO_PATH = __dirname + '/../../protos/helloworld.proto'; - -var parseArgs = require('minimist'); -var grpc = require('@grpc/grpc-js'); -var protoLoader = require('@grpc/proto-loader'); -var packageDefinition = protoLoader.loadSync( - PROTO_PATH, - {keepCase: true, - longs: String, - enums: String, - defaults: true, - oneofs: true - }); -var hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld; - -function main() { - var argv = parseArgs(process.argv.slice(2), { - string: 'target' - }); - var target; - if (argv.target) { - target = argv.target; - } else { - target = 'localhost:50051'; - } - var client = new hello_proto.Greeter(target, - grpc.credentials.createInsecure()); - var user; - if (argv._.length > 0) { - user = argv._[0]; - } else { - user = 'world'; - } - client.sayHello({name: user}, function(err, response) { - console.log('Greeting:', response.message); - }); -} - -main(); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/dynamic_codegen/greeter_server.js b/examples/node/dynamic_codegen/greeter_server.js index c606cd8cc36..143661be833 100644 --- a/examples/node/dynamic_codegen/greeter_server.js +++ b/examples/node/dynamic_codegen/greeter_server.js @@ -16,37 +16,4 @@ * */ -var PROTO_PATH = __dirname + '/../../protos/helloworld.proto'; - -var grpc = require('@grpc/grpc-js'); -var protoLoader = require('@grpc/proto-loader'); -var packageDefinition = protoLoader.loadSync( - PROTO_PATH, - {keepCase: true, - longs: String, - enums: String, - defaults: true, - oneofs: true - }); -var hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld; - -/** - * Implements the SayHello RPC method. - */ -function sayHello(call, callback) { - callback(null, {message: 'Hello ' + call.request.name}); -} - -/** - * Starts an RPC server that receives requests for the Greeter service at the - * sample server port - */ -function main() { - var server = new grpc.Server(); - server.addService(hello_proto.Greeter.service, {sayHello: sayHello}); - server.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => { - server.start(); - }); -} - -main(); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/dynamic_codegen/route_guide/README.md b/examples/node/dynamic_codegen/route_guide/README.md index fcd147054a6..6262c1432ad 100644 --- a/examples/node/dynamic_codegen/route_guide/README.md +++ b/examples/node/dynamic_codegen/route_guide/README.md @@ -1,5 +1 @@ -# gRPC Basics: Node.js sample code - -The files in this folder are the samples used in [gRPC Basics: Node.js][], a detailed tutorial for using gRPC in Node.js. - -[gRPC Basics: Node.js]:https://grpc.io/docs/languages/node/basics +These examples have been moved to [the grpc/grpc-node repository](https://github.com/grpc/grpc-node/tree/master/examples). diff --git a/examples/node/dynamic_codegen/route_guide/route_guide_client.js b/examples/node/dynamic_codegen/route_guide/route_guide_client.js index 3af8858ae85..143661be833 100644 --- a/examples/node/dynamic_codegen/route_guide/route_guide_client.js +++ b/examples/node/dynamic_codegen/route_guide/route_guide_client.js @@ -16,222 +16,4 @@ * */ -var PROTO_PATH = __dirname + '/../../../protos/route_guide.proto'; - -var async = require('async'); -var fs = require('fs'); -var parseArgs = require('minimist'); -var path = require('path'); -var _ = require('lodash'); -var grpc = require('@grpc/grpc-js'); -var protoLoader = require('@grpc/proto-loader'); -var packageDefinition = protoLoader.loadSync( - PROTO_PATH, - {keepCase: true, - longs: String, - enums: String, - defaults: true, - oneofs: true - }); -var routeguide = grpc.loadPackageDefinition(packageDefinition).routeguide; -var client = new routeguide.RouteGuide('localhost:50051', - grpc.credentials.createInsecure()); - -var COORD_FACTOR = 1e7; - -/** - * Run the getFeature demo. Calls getFeature with a point known to have a - * feature and a point known not to have a feature. - * @param {function} callback Called when this demo is complete - */ -function runGetFeature(callback) { - var next = _.after(2, callback); - function featureCallback(error, feature) { - if (error) { - callback(error); - return; - } - if (feature.name === '') { - console.log('Found no feature at ' + - feature.location.latitude/COORD_FACTOR + ', ' + - feature.location.longitude/COORD_FACTOR); - } else { - console.log('Found feature called "' + feature.name + '" at ' + - feature.location.latitude/COORD_FACTOR + ', ' + - feature.location.longitude/COORD_FACTOR); - } - next(); - } - var point1 = { - latitude: 409146138, - longitude: -746188906 - }; - var point2 = { - latitude: 0, - longitude: 0 - }; - client.getFeature(point1, featureCallback); - client.getFeature(point2, featureCallback); -} - -/** - * Run the listFeatures demo. Calls listFeatures with a rectangle containing all - * of the features in the pre-generated database. Prints each response as it - * comes in. - * @param {function} callback Called when this demo is complete - */ -function runListFeatures(callback) { - var rectangle = { - lo: { - latitude: 400000000, - longitude: -750000000 - }, - hi: { - latitude: 420000000, - longitude: -730000000 - } - }; - console.log('Looking for features between 40, -75 and 42, -73'); - var call = client.listFeatures(rectangle); - call.on('data', function(feature) { - console.log('Found feature called "' + feature.name + '" at ' + - feature.location.latitude/COORD_FACTOR + ', ' + - feature.location.longitude/COORD_FACTOR); - }); - call.on('end', callback); -} - -/** - * Run the recordRoute demo. Sends several randomly chosen points from the - * pre-generated feature database with a variable delay in between. Prints the - * statistics when they are sent from the server. - * @param {function} callback Called when this demo is complete - */ -function runRecordRoute(callback) { - var argv = parseArgs(process.argv, { - string: 'db_path' - }); - fs.readFile(path.resolve(argv.db_path), function(err, data) { - if (err) { - callback(err); - return; - } - var feature_list = JSON.parse(data); - - var num_points = 10; - var call = client.recordRoute(function(error, stats) { - if (error) { - callback(error); - return; - } - console.log('Finished trip with', stats.point_count, 'points'); - console.log('Passed', stats.feature_count, 'features'); - console.log('Travelled', stats.distance, 'meters'); - console.log('It took', stats.elapsed_time, 'seconds'); - callback(); - }); - /** - * Constructs a function that asynchronously sends the given point and then - * delays sending its callback - * @param {number} lat The latitude to send - * @param {number} lng The longitude to send - * @return {function(function)} The function that sends the point - */ - function pointSender(lat, lng) { - /** - * Sends the point, then calls the callback after a delay - * @param {function} callback Called when complete - */ - return function(callback) { - console.log('Visiting point ' + lat/COORD_FACTOR + ', ' + - lng/COORD_FACTOR); - call.write({ - latitude: lat, - longitude: lng - }); - _.delay(callback, _.random(500, 1500)); - }; - } - var point_senders = []; - for (var i = 0; i < num_points; i++) { - var rand_point = feature_list[_.random(0, feature_list.length - 1)]; - point_senders[i] = pointSender(rand_point.location.latitude, - rand_point.location.longitude); - } - async.series(point_senders, function() { - call.end(); - }); - }); -} - -/** - * Run the routeChat demo. Send some chat messages, and print any chat messages - * that are sent from the server. - * @param {function} callback Called when the demo is complete - */ -function runRouteChat(callback) { - var call = client.routeChat(); - call.on('data', function(note) { - console.log('Got message "' + note.message + '" at ' + - note.location.latitude + ', ' + note.location.longitude); - }); - - call.on('end', callback); - - var notes = [{ - location: { - latitude: 0, - longitude: 0 - }, - message: 'First message' - }, { - location: { - latitude: 0, - longitude: 1 - }, - message: 'Second message' - }, { - location: { - latitude: 1, - longitude: 0 - }, - message: 'Third message' - }, { - location: { - latitude: 0, - longitude: 0 - }, - message: 'Fourth message' - }]; - for (var i = 0; i < notes.length; i++) { - var note = notes[i]; - console.log('Sending message "' + note.message + '" at ' + - note.location.latitude + ', ' + note.location.longitude); - call.write(note); - } - call.end(); -} - -/** - * Run all of the demos in order - */ -function main() { - async.series([ - runGetFeature, - runListFeatures, - runRecordRoute, - runRouteChat - ]); -} - -if (require.main === module) { - main(); -} - -exports.runGetFeature = runGetFeature; - -exports.runListFeatures = runListFeatures; - -exports.runRecordRoute = runRecordRoute; - -exports.runRouteChat = runRouteChat; +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/dynamic_codegen/route_guide/route_guide_db.json b/examples/node/dynamic_codegen/route_guide/route_guide_db.json index 9d6a980ab7d..068bd9a379f 100644 --- a/examples/node/dynamic_codegen/route_guide/route_guide_db.json +++ b/examples/node/dynamic_codegen/route_guide/route_guide_db.json @@ -1,601 +1 @@ -[{ - "location": { - "latitude": 407838351, - "longitude": -746143763 - }, - "name": "Patriots Path, Mendham, NJ 07945, USA" -}, { - "location": { - "latitude": 408122808, - "longitude": -743999179 - }, - "name": "101 New Jersey 10, Whippany, NJ 07981, USA" -}, { - "location": { - "latitude": 413628156, - "longitude": -749015468 - }, - "name": "U.S. 6, Shohola, PA 18458, USA" -}, { - "location": { - "latitude": 419999544, - "longitude": -740371136 - }, - "name": "5 Conners Road, Kingston, NY 12401, USA" -}, { - "location": { - "latitude": 414008389, - "longitude": -743951297 - }, - "name": "Mid Hudson Psychiatric Center, New Hampton, NY 10958, USA" -}, { - "location": { - "latitude": 419611318, - "longitude": -746524769 - }, - "name": "287 Flugertown Road, Livingston Manor, NY 12758, USA" -}, { - "location": { - "latitude": 406109563, - "longitude": -742186778 - }, - "name": "4001 Tremley Point Road, Linden, NJ 07036, USA" -}, { - "location": { - "latitude": 416802456, - "longitude": -742370183 - }, - "name": "352 South Mountain Road, Wallkill, NY 12589, USA" -}, { - "location": { - "latitude": 412950425, - "longitude": -741077389 - }, - "name": "Bailey Turn Road, Harriman, NY 10926, USA" -}, { - "location": { - "latitude": 412144655, - "longitude": -743949739 - }, - "name": "193-199 Wawayanda Road, Hewitt, NJ 07421, USA" -}, { - "location": { - "latitude": 415736605, - "longitude": -742847522 - }, - "name": "406-496 Ward Avenue, Pine Bush, NY 12566, USA" -}, { - "location": { - "latitude": 413843930, - "longitude": -740501726 - }, - "name": "162 Merrill Road, Highland Mills, NY 10930, USA" -}, { - "location": { - "latitude": 410873075, - "longitude": -744459023 - }, - "name": "Clinton Road, West Milford, NJ 07480, USA" -}, { - "location": { - "latitude": 412346009, - "longitude": -744026814 - }, - "name": "16 Old Brook Lane, Warwick, NY 10990, USA" -}, { - "location": { - "latitude": 402948455, - "longitude": -747903913 - }, - "name": "3 Drake Lane, Pennington, NJ 08534, USA" -}, { - "location": { - "latitude": 406337092, - "longitude": -740122226 - }, - "name": "6324 8th Avenue, Brooklyn, NY 11220, USA" -}, { - "location": { - "latitude": 406421967, - "longitude": -747727624 - }, - "name": "1 Merck Access Road, Whitehouse Station, NJ 08889, USA" -}, { - "location": { - "latitude": 416318082, - "longitude": -749677716 - }, - "name": "78-98 Schalck Road, Narrowsburg, NY 12764, USA" -}, { - "location": { - "latitude": 415301720, - "longitude": -748416257 - }, - "name": "282 Lakeview Drive Road, Highland Lake, NY 12743, USA" -}, { - "location": { - "latitude": 402647019, - "longitude": -747071791 - }, - "name": "330 Evelyn Avenue, Hamilton Township, NJ 08619, USA" -}, { - "location": { - "latitude": 412567807, - "longitude": -741058078 - }, - "name": "New York State Reference Route 987E, Southfields, NY 10975, USA" -}, { - "location": { - "latitude": 416855156, - "longitude": -744420597 - }, - "name": "103-271 Tempaloni Road, Ellenville, NY 12428, USA" -}, { - "location": { - "latitude": 404663628, - "longitude": -744820157 - }, - "name": "1300 Airport Road, North Brunswick Township, NJ 08902, USA" -}, { - "location": { - "latitude": 407113723, - "longitude": -749746483 - }, - "name": "" -}, { - "location": { - "latitude": 402133926, - "longitude": -743613249 - }, - "name": "" -}, { - "location": { - "latitude": 400273442, - "longitude": -741220915 - }, - "name": "" -}, { - "location": { - "latitude": 411236786, - "longitude": -744070769 - }, - "name": "" -}, { - "location": { - "latitude": 411633782, - "longitude": -746784970 - }, - "name": "211-225 Plains Road, Augusta, NJ 07822, USA" -}, { - "location": { - "latitude": 415830701, - "longitude": -742952812 - }, - "name": "" -}, { - "location": { - "latitude": 413447164, - "longitude": -748712898 - }, - "name": "165 Pedersen Ridge Road, Milford, PA 18337, USA" -}, { - "location": { - "latitude": 405047245, - "longitude": -749800722 - }, - "name": "100-122 Locktown Road, Frenchtown, NJ 08825, USA" -}, { - "location": { - "latitude": 418858923, - "longitude": -746156790 - }, - "name": "" -}, { - "location": { - "latitude": 417951888, - "longitude": -748484944 - }, - "name": "650-652 Willi Hill Road, Swan Lake, NY 12783, USA" -}, { - "location": { - "latitude": 407033786, - "longitude": -743977337 - }, - "name": "26 East 3rd Street, New Providence, NJ 07974, USA" -}, { - "location": { - "latitude": 417548014, - "longitude": -740075041 - }, - "name": "" -}, { - "location": { - "latitude": 410395868, - "longitude": -744972325 - }, - "name": "" -}, { - "location": { - "latitude": 404615353, - "longitude": -745129803 - }, - "name": "" -}, { - "location": { - "latitude": 406589790, - "longitude": -743560121 - }, - "name": "611 Lawrence Avenue, Westfield, NJ 07090, USA" -}, { - "location": { - "latitude": 414653148, - "longitude": -740477477 - }, - "name": "18 Lannis Avenue, New Windsor, NY 12553, USA" -}, { - "location": { - "latitude": 405957808, - "longitude": -743255336 - }, - "name": "82-104 Amherst Avenue, Colonia, NJ 07067, USA" -}, { - "location": { - "latitude": 411733589, - "longitude": -741648093 - }, - "name": "170 Seven Lakes Drive, Sloatsburg, NY 10974, USA" -}, { - "location": { - "latitude": 412676291, - "longitude": -742606606 - }, - "name": "1270 Lakes Road, Monroe, NY 10950, USA" -}, { - "location": { - "latitude": 409224445, - "longitude": -748286738 - }, - "name": "509-535 Alphano Road, Great Meadows, NJ 07838, USA" -}, { - "location": { - "latitude": 406523420, - "longitude": -742135517 - }, - "name": "652 Garden Street, Elizabeth, NJ 07202, USA" -}, { - "location": { - "latitude": 401827388, - "longitude": -740294537 - }, - "name": "349 Sea Spray Court, Neptune City, NJ 07753, USA" -}, { - "location": { - "latitude": 410564152, - "longitude": -743685054 - }, - "name": "13-17 Stanley Street, West Milford, NJ 07480, USA" -}, { - "location": { - "latitude": 408472324, - "longitude": -740726046 - }, - "name": "47 Industrial Avenue, Teterboro, NJ 07608, USA" -}, { - "location": { - "latitude": 412452168, - "longitude": -740214052 - }, - "name": "5 White Oak Lane, Stony Point, NY 10980, USA" -}, { - "location": { - "latitude": 409146138, - "longitude": -746188906 - }, - "name": "Berkshire Valley Management Area Trail, Jefferson, NJ, USA" -}, { - "location": { - "latitude": 404701380, - "longitude": -744781745 - }, - "name": "1007 Jersey Avenue, New Brunswick, NJ 08901, USA" -}, { - "location": { - "latitude": 409642566, - "longitude": -746017679 - }, - "name": "6 East Emerald Isle Drive, Lake Hopatcong, NJ 07849, USA" -}, { - "location": { - "latitude": 408031728, - "longitude": -748645385 - }, - "name": "1358-1474 New Jersey 57, Port Murray, NJ 07865, USA" -}, { - "location": { - "latitude": 413700272, - "longitude": -742135189 - }, - "name": "367 Prospect Road, Chester, NY 10918, USA" -}, { - "location": { - "latitude": 404310607, - "longitude": -740282632 - }, - "name": "10 Simon Lake Drive, Atlantic Highlands, NJ 07716, USA" -}, { - "location": { - "latitude": 409319800, - "longitude": -746201391 - }, - "name": "11 Ward Street, Mount Arlington, NJ 07856, USA" -}, { - "location": { - "latitude": 406685311, - "longitude": -742108603 - }, - "name": "300-398 Jefferson Avenue, Elizabeth, NJ 07201, USA" -}, { - "location": { - "latitude": 419018117, - "longitude": -749142781 - }, - "name": "43 Dreher Road, Roscoe, NY 12776, USA" -}, { - "location": { - "latitude": 412856162, - "longitude": -745148837 - }, - "name": "Swan Street, Pine Island, NY 10969, USA" -}, { - "location": { - "latitude": 416560744, - "longitude": -746721964 - }, - "name": "66 Pleasantview Avenue, Monticello, NY 12701, USA" -}, { - "location": { - "latitude": 405314270, - "longitude": -749836354 - }, - "name": "" -}, { - "location": { - "latitude": 414219548, - "longitude": -743327440 - }, - "name": "" -}, { - "location": { - "latitude": 415534177, - "longitude": -742900616 - }, - "name": "565 Winding Hills Road, Montgomery, NY 12549, USA" -}, { - "location": { - "latitude": 406898530, - "longitude": -749127080 - }, - "name": "231 Rocky Run Road, Glen Gardner, NJ 08826, USA" -}, { - "location": { - "latitude": 407586880, - "longitude": -741670168 - }, - "name": "100 Mount Pleasant Avenue, Newark, NJ 07104, USA" -}, { - "location": { - "latitude": 400106455, - "longitude": -742870190 - }, - "name": "517-521 Huntington Drive, Manchester Township, NJ 08759, USA" -}, { - "location": { - "latitude": 400066188, - "longitude": -746793294 - }, - "name": "" -}, { - "location": { - "latitude": 418803880, - "longitude": -744102673 - }, - "name": "40 Mountain Road, Napanoch, NY 12458, USA" -}, { - "location": { - "latitude": 414204288, - "longitude": -747895140 - }, - "name": "" -}, { - "location": { - "latitude": 414777405, - "longitude": -740615601 - }, - "name": "" -}, { - "location": { - "latitude": 415464475, - "longitude": -747175374 - }, - "name": "48 North Road, Forestburgh, NY 12777, USA" -}, { - "location": { - "latitude": 404062378, - "longitude": -746376177 - }, - "name": "" -}, { - "location": { - "latitude": 405688272, - "longitude": -749285130 - }, - "name": "" -}, { - "location": { - "latitude": 400342070, - "longitude": -748788996 - }, - "name": "" -}, { - "location": { - "latitude": 401809022, - "longitude": -744157964 - }, - "name": "" -}, { - "location": { - "latitude": 404226644, - "longitude": -740517141 - }, - "name": "9 Thompson Avenue, Leonardo, NJ 07737, USA" -}, { - "location": { - "latitude": 410322033, - "longitude": -747871659 - }, - "name": "" -}, { - "location": { - "latitude": 407100674, - "longitude": -747742727 - }, - "name": "" -}, { - "location": { - "latitude": 418811433, - "longitude": -741718005 - }, - "name": "213 Bush Road, Stone Ridge, NY 12484, USA" -}, { - "location": { - "latitude": 415034302, - "longitude": -743850945 - }, - "name": "" -}, { - "location": { - "latitude": 411349992, - "longitude": -743694161 - }, - "name": "" -}, { - "location": { - "latitude": 404839914, - "longitude": -744759616 - }, - "name": "1-17 Bergen Court, New Brunswick, NJ 08901, USA" -}, { - "location": { - "latitude": 414638017, - "longitude": -745957854 - }, - "name": "35 Oakland Valley Road, Cuddebackville, NY 12729, USA" -}, { - "location": { - "latitude": 412127800, - "longitude": -740173578 - }, - "name": "" -}, { - "location": { - "latitude": 401263460, - "longitude": -747964303 - }, - "name": "" -}, { - "location": { - "latitude": 412843391, - "longitude": -749086026 - }, - "name": "" -}, { - "location": { - "latitude": 418512773, - "longitude": -743067823 - }, - "name": "" -}, { - "location": { - "latitude": 404318328, - "longitude": -740835638 - }, - "name": "42-102 Main Street, Belford, NJ 07718, USA" -}, { - "location": { - "latitude": 419020746, - "longitude": -741172328 - }, - "name": "" -}, { - "location": { - "latitude": 404080723, - "longitude": -746119569 - }, - "name": "" -}, { - "location": { - "latitude": 401012643, - "longitude": -744035134 - }, - "name": "" -}, { - "location": { - "latitude": 404306372, - "longitude": -741079661 - }, - "name": "" -}, { - "location": { - "latitude": 403966326, - "longitude": -748519297 - }, - "name": "" -}, { - "location": { - "latitude": 405002031, - "longitude": -748407866 - }, - "name": "" -}, { - "location": { - "latitude": 409532885, - "longitude": -742200683 - }, - "name": "" -}, { - "location": { - "latitude": 416851321, - "longitude": -742674555 - }, - "name": "" -}, { - "location": { - "latitude": 406411633, - "longitude": -741722051 - }, - "name": "3387 Richmond Terrace, Staten Island, NY 10303, USA" -}, { - "location": { - "latitude": 413069058, - "longitude": -744597778 - }, - "name": "261 Van Sickle Road, Goshen, NY 10924, USA" -}, { - "location": { - "latitude": 418465462, - "longitude": -746859398 - }, - "name": "" -}, { - "location": { - "latitude": 411733222, - "longitude": -744228360 - }, - "name": "" -}, { - "location": { - "latitude": 410248224, - "longitude": -747127767 - }, - "name": "3 Hasta Way, Newton, NJ 07860, USA" -}] +"These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples" diff --git a/examples/node/dynamic_codegen/route_guide/route_guide_server.js b/examples/node/dynamic_codegen/route_guide/route_guide_server.js index a0cf0d3c655..143661be833 100644 --- a/examples/node/dynamic_codegen/route_guide/route_guide_server.js +++ b/examples/node/dynamic_codegen/route_guide/route_guide_server.js @@ -16,230 +16,4 @@ * */ -var PROTO_PATH = __dirname + '/../../../protos/route_guide.proto'; - -var fs = require('fs'); -var parseArgs = require('minimist'); -var path = require('path'); -var _ = require('lodash'); -var grpc = require('@grpc/grpc-js'); -var protoLoader = require('@grpc/proto-loader'); -var packageDefinition = protoLoader.loadSync( - PROTO_PATH, - {keepCase: true, - longs: String, - enums: String, - defaults: true, - oneofs: true - }); -var routeguide = grpc.loadPackageDefinition(packageDefinition).routeguide; - -var COORD_FACTOR = 1e7; - -/** - * For simplicity, a point is a record type that looks like - * {latitude: number, longitude: number}, and a feature is a record type that - * looks like {name: string, location: point}. feature objects with name==='' - * are points with no feature. - */ - -/** - * List of feature objects at points that have been requested so far. - */ -var feature_list = []; - -/** - * Get a feature object at the given point, or creates one if it does not exist. - * @param {point} point The point to check - * @return {feature} The feature object at the point. Note that an empty name - * indicates no feature - */ -function checkFeature(point) { - var feature; - // Check if there is already a feature object for the given point - for (var i = 0; i < feature_list.length; i++) { - feature = feature_list[i]; - if (feature.location.latitude === point.latitude && - feature.location.longitude === point.longitude) { - return feature; - } - } - var name = ''; - feature = { - name: name, - location: point - }; - return feature; -} - -/** - * getFeature request handler. Gets a request with a point, and responds with a - * feature object indicating whether there is a feature at that point. - * @param {EventEmitter} call Call object for the handler to process - * @param {function(Error, feature)} callback Response callback - */ -function getFeature(call, callback) { - callback(null, checkFeature(call.request)); -} - -/** - * listFeatures request handler. Gets a request with two points, and responds - * with a stream of all features in the bounding box defined by those points. - * @param {Writable} call Writable stream for responses with an additional - * request property for the request value. - */ -function listFeatures(call) { - var lo = call.request.lo; - var hi = call.request.hi; - var left = _.min([lo.longitude, hi.longitude]); - var right = _.max([lo.longitude, hi.longitude]); - var top = _.max([lo.latitude, hi.latitude]); - var bottom = _.min([lo.latitude, hi.latitude]); - // For each feature, check if it is in the given bounding box - _.each(feature_list, function(feature) { - if (feature.name === '') { - return; - } - if (feature.location.longitude >= left && - feature.location.longitude <= right && - feature.location.latitude >= bottom && - feature.location.latitude <= top) { - call.write(feature); - } - }); - call.end(); -} - -/** - * Calculate the distance between two points using the "haversine" formula. - * The formula is based on http://mathforum.org/library/drmath/view/51879.html. - * @param start The starting point - * @param end The end point - * @return The distance between the points in meters - */ -function getDistance(start, end) { - function toRadians(num) { - return num * Math.PI / 180; - } - var R = 6371000; // earth radius in metres - var lat1 = toRadians(start.latitude / COORD_FACTOR); - var lat2 = toRadians(end.latitude / COORD_FACTOR); - var lon1 = toRadians(start.longitude / COORD_FACTOR); - var lon2 = toRadians(end.longitude / COORD_FACTOR); - - var deltalat = lat2-lat1; - var deltalon = lon2-lon1; - var a = Math.sin(deltalat/2) * Math.sin(deltalat/2) + - Math.cos(lat1) * Math.cos(lat2) * - Math.sin(deltalon/2) * Math.sin(deltalon/2); - var c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1-a)); - return R * c; -} - -/** - * recordRoute handler. Gets a stream of points, and responds with statistics - * about the "trip": number of points, number of known features visited, total - * distance traveled, and total time spent. - * @param {Readable} call The request point stream. - * @param {function(Error, routeSummary)} callback The callback to pass the - * response to - */ -function recordRoute(call, callback) { - var point_count = 0; - var feature_count = 0; - var distance = 0; - var previous = null; - // Start a timer - var start_time = process.hrtime(); - call.on('data', function(point) { - point_count += 1; - if (checkFeature(point).name !== '') { - feature_count += 1; - } - /* For each point after the first, add the incremental distance from the - * previous point to the total distance value */ - if (previous != null) { - distance += getDistance(previous, point); - } - previous = point; - }); - call.on('end', function() { - callback(null, { - point_count: point_count, - feature_count: feature_count, - // Cast the distance to an integer - distance: distance|0, - // End the timer - elapsed_time: process.hrtime(start_time)[0] - }); - }); -} - -var route_notes = {}; - -/** - * Turn the point into a dictionary key. - * @param {point} point The point to use - * @return {string} The key for an object - */ -function pointKey(point) { - return point.latitude + ' ' + point.longitude; -} - -/** - * routeChat handler. Receives a stream of message/location pairs, and responds - * with a stream of all previous messages at each of those locations. - * @param {Duplex} call The stream for incoming and outgoing messages - */ -function routeChat(call) { - call.on('data', function(note) { - var key = pointKey(note.location); - /* For each note sent, respond with all previous notes that correspond to - * the same point */ - if (route_notes.hasOwnProperty(key)) { - _.each(route_notes[key], function(note) { - call.write(note); - }); - } else { - route_notes[key] = []; - } - // Then add the new note to the list - route_notes[key].push(JSON.parse(JSON.stringify(note))); - }); - call.on('end', function() { - call.end(); - }); -} - -/** - * Get a new server with the handler functions in this file bound to the methods - * it serves. - * @return {Server} The new server object - */ -function getServer() { - var server = new grpc.Server(); - server.addService(routeguide.RouteGuide.service, { - getFeature: getFeature, - listFeatures: listFeatures, - recordRoute: recordRoute, - routeChat: routeChat - }); - return server; -} - -if (require.main === module) { - // If this is run as a script, start a server on an unused port - var routeServer = getServer(); - routeServer.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => { - var argv = parseArgs(process.argv, { - string: 'db_path' - }); - fs.readFile(path.resolve(argv.db_path), function(err, data) { - if (err) throw err; - feature_list = JSON.parse(data); - routeServer.start(); - }); - }); -} - -exports.getServer = getServer; +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/package.json b/examples/node/package.json index 73153dee4d6..068bd9a379f 100644 --- a/examples/node/package.json +++ b/examples/node/package.json @@ -1,12 +1 @@ -{ - "name": "grpc-examples", - "version": "0.1.0", - "dependencies": { - "@grpc/proto-loader": "^0.5.0", - "async": "^1.5.2", - "google-protobuf": "^3.0.0", - "@grpc/grpc-js": "^1.1.0", - "lodash": "^4.6.1", - "minimist": "^1.2.0" - } -} +"These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples" diff --git a/examples/node/static_codegen/README.md b/examples/node/static_codegen/README.md index bc087ec4fa7..6262c1432ad 100644 --- a/examples/node/static_codegen/README.md +++ b/examples/node/static_codegen/README.md @@ -1,8 +1 @@ -This is the static code generation variant of the Node examples. Code in these examples is pre-generated using protoc and the Node gRPC protoc plugin, and the generated code can be found in various `*_pb.js` files. The command line sequence for generating those files is as follows (assuming that `protoc` and `grpc_node_plugin` are present, and starting in the directory which contains this README.md file): - -```sh -cd ../../protos -npm install -g grpc-tools -grpc_tools_node_protoc --js_out=import_style=commonjs,binary:../node/static_codegen/ --grpc_out=grpc_js:../node/static_codegen helloworld.proto -grpc_tools_node_protoc --js_out=import_style=commonjs,binary:../node/static_codegen/route_guide/ --grpc_out=grpc_js:../node/static_codegen/route_guide/ route_guide.proto -``` +These examples have been moved to [the grpc/grpc-node repository](https://github.com/grpc/grpc-node/tree/master/examples). diff --git a/examples/node/static_codegen/greeter_client.js b/examples/node/static_codegen/greeter_client.js index 668a3f8e441..143661be833 100644 --- a/examples/node/static_codegen/greeter_client.js +++ b/examples/node/static_codegen/greeter_client.js @@ -16,35 +16,4 @@ * */ -var parseArgs = require('minimist'); -var messages = require('./helloworld_pb'); -var services = require('./helloworld_grpc_pb'); - -var grpc = require('@grpc/grpc-js'); - -function main() { - var argv = parseArgs(process.argv.slice(2), { - string: 'target' - }); - var target; - if (argv.target) { - target = argv.target; - } else { - target = 'localhost:50051'; - } - var client = new services.GreeterClient(target, - grpc.credentials.createInsecure()); - var request = new messages.HelloRequest(); - var user; - if (argv._.length > 0) { - user = argv._[0]; - } else { - user = 'world'; - } - request.setName(user); - client.sayHello(request, function(err, response) { - console.log('Greeting:', response.getMessage()); - }); -} - -main(); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/greeter_server.js b/examples/node/static_codegen/greeter_server.js index 7a3e87d8050..143661be833 100644 --- a/examples/node/static_codegen/greeter_server.js +++ b/examples/node/static_codegen/greeter_server.js @@ -16,30 +16,4 @@ * */ -var messages = require('./helloworld_pb'); -var services = require('./helloworld_grpc_pb'); - -var grpc = require('@grpc/grpc-js'); - -/** - * Implements the SayHello RPC method. - */ -function sayHello(call, callback) { - var reply = new messages.HelloReply(); - reply.setMessage('Hello ' + call.request.getName()); - callback(null, reply); -} - -/** - * Starts an RPC server that receives requests for the Greeter service at the - * sample server port - */ -function main() { - var server = new grpc.Server(); - server.addService(services.GreeterService, {sayHello: sayHello}); - server.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => { - server.start(); - }); -} - -main(); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/helloworld_grpc_pb.js b/examples/node/static_codegen/helloworld_grpc_pb.js index 85dc0f0b7c4..e672648e105 100644 --- a/examples/node/static_codegen/helloworld_grpc_pb.js +++ b/examples/node/static_codegen/helloworld_grpc_pb.js @@ -14,48 +14,5 @@ // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. -// -'use strict'; -var grpc = require('@grpc/grpc-js'); -var helloworld_pb = require('./helloworld_pb.js'); - -function serialize_helloworld_HelloReply(arg) { - if (!(arg instanceof helloworld_pb.HelloReply)) { - throw new Error('Expected argument of type helloworld.HelloReply'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_helloworld_HelloReply(buffer_arg) { - return helloworld_pb.HelloReply.deserializeBinary(new Uint8Array(buffer_arg)); -} - -function serialize_helloworld_HelloRequest(arg) { - if (!(arg instanceof helloworld_pb.HelloRequest)) { - throw new Error('Expected argument of type helloworld.HelloRequest'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_helloworld_HelloRequest(buffer_arg) { - return helloworld_pb.HelloRequest.deserializeBinary(new Uint8Array(buffer_arg)); -} - - -// The greeting service definition. -var GreeterService = exports.GreeterService = { - // Sends a greeting -sayHello: { - path: '/helloworld.Greeter/SayHello', - requestStream: false, - responseStream: false, - requestType: helloworld_pb.HelloRequest, - responseType: helloworld_pb.HelloReply, - requestSerialize: serialize_helloworld_HelloRequest, - requestDeserialize: deserialize_helloworld_HelloRequest, - responseSerialize: serialize_helloworld_HelloReply, - responseDeserialize: deserialize_helloworld_HelloReply, - }, -}; -exports.GreeterClient = grpc.makeGenericClientConstructor(GreeterService); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/helloworld_pb.js b/examples/node/static_codegen/helloworld_pb.js index e6768028139..943736802db 100644 --- a/examples/node/static_codegen/helloworld_pb.js +++ b/examples/node/static_codegen/helloworld_pb.js @@ -8,312 +8,4 @@ */ // GENERATED CODE -- DO NOT EDIT! -var jspb = require('google-protobuf'); -var goog = jspb; -var global = Function('return this')(); - -goog.exportSymbol('proto.helloworld.HelloReply', null, global); -goog.exportSymbol('proto.helloworld.HelloRequest', null, global); -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.helloworld.HelloRequest = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.helloworld.HelloRequest, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.helloworld.HelloRequest.displayName = 'proto.helloworld.HelloRequest'; -} -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.helloworld.HelloReply = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.helloworld.HelloReply, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.helloworld.HelloReply.displayName = 'proto.helloworld.HelloReply'; -} - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.helloworld.HelloRequest.prototype.toObject = function(opt_includeInstance) { - return proto.helloworld.HelloRequest.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.helloworld.HelloRequest} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.helloworld.HelloRequest.toObject = function(includeInstance, msg) { - var f, obj = { - name: jspb.Message.getFieldWithDefault(msg, 1, "") - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.helloworld.HelloRequest} - */ -proto.helloworld.HelloRequest.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.helloworld.HelloRequest; - return proto.helloworld.HelloRequest.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.helloworld.HelloRequest} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.helloworld.HelloRequest} - */ -proto.helloworld.HelloRequest.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = /** @type {string} */ (reader.readString()); - msg.setName(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.helloworld.HelloRequest.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.helloworld.HelloRequest.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.helloworld.HelloRequest} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.helloworld.HelloRequest.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getName(); - if (f.length > 0) { - writer.writeString( - 1, - f - ); - } -}; - - -/** - * optional string name = 1; - * @return {string} - */ -proto.helloworld.HelloRequest.prototype.getName = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); -}; - - -/** - * @param {string} value - * @return {!proto.helloworld.HelloRequest} returns this - */ -proto.helloworld.HelloRequest.prototype.setName = function(value) { - return jspb.Message.setProto3StringField(this, 1, value); -}; - - - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.helloworld.HelloReply.prototype.toObject = function(opt_includeInstance) { - return proto.helloworld.HelloReply.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.helloworld.HelloReply} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.helloworld.HelloReply.toObject = function(includeInstance, msg) { - var f, obj = { - message: jspb.Message.getFieldWithDefault(msg, 1, "") - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.helloworld.HelloReply} - */ -proto.helloworld.HelloReply.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.helloworld.HelloReply; - return proto.helloworld.HelloReply.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.helloworld.HelloReply} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.helloworld.HelloReply} - */ -proto.helloworld.HelloReply.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = /** @type {string} */ (reader.readString()); - msg.setMessage(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.helloworld.HelloReply.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.helloworld.HelloReply.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.helloworld.HelloReply} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.helloworld.HelloReply.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getMessage(); - if (f.length > 0) { - writer.writeString( - 1, - f - ); - } -}; - - -/** - * optional string message = 1; - * @return {string} - */ -proto.helloworld.HelloReply.prototype.getMessage = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); -}; - - -/** - * @param {string} value - * @return {!proto.helloworld.HelloReply} returns this - */ -proto.helloworld.HelloReply.prototype.setMessage = function(value) { - return jspb.Message.setProto3StringField(this, 1, value); -}; - - -goog.object.extend(exports, proto.helloworld); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/route_guide/README.md b/examples/node/static_codegen/route_guide/README.md index fcd147054a6..6262c1432ad 100644 --- a/examples/node/static_codegen/route_guide/README.md +++ b/examples/node/static_codegen/route_guide/README.md @@ -1,5 +1 @@ -# gRPC Basics: Node.js sample code - -The files in this folder are the samples used in [gRPC Basics: Node.js][], a detailed tutorial for using gRPC in Node.js. - -[gRPC Basics: Node.js]:https://grpc.io/docs/languages/node/basics +These examples have been moved to [the grpc/grpc-node repository](https://github.com/grpc/grpc-node/tree/master/examples). diff --git a/examples/node/static_codegen/route_guide/route_guide_client.js b/examples/node/static_codegen/route_guide/route_guide_client.js index 0ab40a8a550..143661be833 100644 --- a/examples/node/static_codegen/route_guide/route_guide_client.js +++ b/examples/node/static_codegen/route_guide/route_guide_client.js @@ -16,222 +16,4 @@ * */ -var messages = require('./route_guide_pb'); -var services = require('./route_guide_grpc_pb'); - -var async = require('async'); -var fs = require('fs'); -var parseArgs = require('minimist'); -var path = require('path'); -var _ = require('lodash'); -var grpc = require('@grpc/grpc-js'); - -var client = new services.RouteGuideClient('localhost:50051', - grpc.credentials.createInsecure()); - -var COORD_FACTOR = 1e7; - -/** - * Run the getFeature demo. Calls getFeature with a point known to have a - * feature and a point known not to have a feature. - * @param {function} callback Called when this demo is complete - */ -function runGetFeature(callback) { - var next = _.after(2, callback); - function featureCallback(error, feature) { - if (error) { - callback(error); - return; - } - var latitude = feature.getLocation().getLatitude(); - var longitude = feature.getLocation().getLongitude(); - if (feature.getName() === '') { - console.log('Found no feature at ' + - latitude/COORD_FACTOR + ', ' + longitude/COORD_FACTOR); - } else { - console.log('Found feature called "' + feature.getName() + '" at ' + - latitude/COORD_FACTOR + ', ' + longitude/COORD_FACTOR); - } - next(); - } - var point1 = new messages.Point(); - point1.setLatitude(409146138); - point1.setLongitude(-746188906); - var point2 = new messages.Point(); - point2.setLatitude(0); - point2.setLongitude(0); - client.getFeature(point1, featureCallback); - client.getFeature(point2, featureCallback); -} - -/** - * Run the listFeatures demo. Calls listFeatures with a rectangle containing all - * of the features in the pre-generated database. Prints each response as it - * comes in. - * @param {function} callback Called when this demo is complete - */ -function runListFeatures(callback) { - var rect = new messages.Rectangle(); - var lo = new messages.Point(); - lo.setLatitude(400000000); - lo.setLongitude(-750000000); - rect.setLo(lo); - var hi = new messages.Point(); - hi.setLatitude(420000000); - hi.setLongitude(-730000000); - rect.setHi(hi); - console.log('Looking for features between 40, -75 and 42, -73'); - var call = client.listFeatures(rect); - call.on('data', function(feature) { - console.log('Found feature called "' + feature.getName() + '" at ' + - feature.getLocation().getLatitude()/COORD_FACTOR + ', ' + - feature.getLocation().getLongitude()/COORD_FACTOR); - }); - call.on('end', callback); -} - -/** - * Run the recordRoute demo. Sends several randomly chosen points from the - * pre-generated feature database with a variable delay in between. Prints the - * statistics when they are sent from the server. - * @param {function} callback Called when this demo is complete - */ -function runRecordRoute(callback) { - var argv = parseArgs(process.argv, { - string: 'db_path' - }); - fs.readFile(path.resolve(argv.db_path), function(err, data) { - if (err) { - callback(err); - return; - } - // Transform the loaded features to Feature objects - var feature_list = _.map(JSON.parse(data), function(value) { - var feature = new messages.Feature(); - feature.setName(value.name); - var location = new messages.Point(); - location.setLatitude(value.location.latitude); - location.setLongitude(value.location.longitude); - feature.setLocation(location); - return feature; - }); - - var num_points = 10; - var call = client.recordRoute(function(error, stats) { - if (error) { - callback(error); - return; - } - console.log('Finished trip with', stats.getPointCount(), 'points'); - console.log('Passed', stats.getFeatureCount(), 'features'); - console.log('Travelled', stats.getDistance(), 'meters'); - console.log('It took', stats.getElapsedTime(), 'seconds'); - callback(); - }); - /** - * Constructs a function that asynchronously sends the given point and then - * delays sending its callback - * @param {messages.Point} location The point to send - * @return {function(function)} The function that sends the point - */ - function pointSender(location) { - /** - * Sends the point, then calls the callback after a delay - * @param {function} callback Called when complete - */ - return function(callback) { - console.log('Visiting point ' + location.getLatitude()/COORD_FACTOR + - ', ' + location.getLongitude()/COORD_FACTOR); - call.write(location); - _.delay(callback, _.random(500, 1500)); - }; - } - var point_senders = []; - for (var i = 0; i < num_points; i++) { - var rand_point = feature_list[_.random(0, feature_list.length - 1)]; - point_senders[i] = pointSender(rand_point.getLocation()); - } - async.series(point_senders, function() { - call.end(); - }); - }); -} - -/** - * Run the routeChat demo. Send some chat messages, and print any chat messages - * that are sent from the server. - * @param {function} callback Called when the demo is complete - */ -function runRouteChat(callback) { - var call = client.routeChat(); - call.on('data', function(note) { - console.log('Got message "' + note.getMessage() + '" at ' + - note.getLocation().getLatitude() + ', ' + - note.getLocation().getLongitude()); - }); - - call.on('end', callback); - - var notes = [{ - location: { - latitude: 0, - longitude: 0 - }, - message: 'First message' - }, { - location: { - latitude: 0, - longitude: 1 - }, - message: 'Second message' - }, { - location: { - latitude: 1, - longitude: 0 - }, - message: 'Third message' - }, { - location: { - latitude: 0, - longitude: 0 - }, - message: 'Fourth message' - }]; - for (var i = 0; i < notes.length; i++) { - var note = notes[i]; - console.log('Sending message "' + note.message + '" at ' + - note.location.latitude + ', ' + note.location.longitude); - var noteMsg = new messages.RouteNote(); - noteMsg.setMessage(note.message); - var location = new messages.Point(); - location.setLatitude(note.location.latitude); - location.setLongitude(note.location.longitude); - noteMsg.setLocation(location); - call.write(noteMsg); - } - call.end(); -} - -/** - * Run all of the demos in order - */ -function main() { - async.series([ - runGetFeature, - runListFeatures, - runRecordRoute, - runRouteChat - ]); -} - -if (require.main === module) { - main(); -} - -exports.runGetFeature = runGetFeature; - -exports.runListFeatures = runListFeatures; - -exports.runRecordRoute = runRecordRoute; - -exports.runRouteChat = runRouteChat; +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/route_guide/route_guide_db.json b/examples/node/static_codegen/route_guide/route_guide_db.json index 9d6a980ab7d..068bd9a379f 100644 --- a/examples/node/static_codegen/route_guide/route_guide_db.json +++ b/examples/node/static_codegen/route_guide/route_guide_db.json @@ -1,601 +1 @@ -[{ - "location": { - "latitude": 407838351, - "longitude": -746143763 - }, - "name": "Patriots Path, Mendham, NJ 07945, USA" -}, { - "location": { - "latitude": 408122808, - "longitude": -743999179 - }, - "name": "101 New Jersey 10, Whippany, NJ 07981, USA" -}, { - "location": { - "latitude": 413628156, - "longitude": -749015468 - }, - "name": "U.S. 6, Shohola, PA 18458, USA" -}, { - "location": { - "latitude": 419999544, - "longitude": -740371136 - }, - "name": "5 Conners Road, Kingston, NY 12401, USA" -}, { - "location": { - "latitude": 414008389, - "longitude": -743951297 - }, - "name": "Mid Hudson Psychiatric Center, New Hampton, NY 10958, USA" -}, { - "location": { - "latitude": 419611318, - "longitude": -746524769 - }, - "name": "287 Flugertown Road, Livingston Manor, NY 12758, USA" -}, { - "location": { - "latitude": 406109563, - "longitude": -742186778 - }, - "name": "4001 Tremley Point Road, Linden, NJ 07036, USA" -}, { - "location": { - "latitude": 416802456, - "longitude": -742370183 - }, - "name": "352 South Mountain Road, Wallkill, NY 12589, USA" -}, { - "location": { - "latitude": 412950425, - "longitude": -741077389 - }, - "name": "Bailey Turn Road, Harriman, NY 10926, USA" -}, { - "location": { - "latitude": 412144655, - "longitude": -743949739 - }, - "name": "193-199 Wawayanda Road, Hewitt, NJ 07421, USA" -}, { - "location": { - "latitude": 415736605, - "longitude": -742847522 - }, - "name": "406-496 Ward Avenue, Pine Bush, NY 12566, USA" -}, { - "location": { - "latitude": 413843930, - "longitude": -740501726 - }, - "name": "162 Merrill Road, Highland Mills, NY 10930, USA" -}, { - "location": { - "latitude": 410873075, - "longitude": -744459023 - }, - "name": "Clinton Road, West Milford, NJ 07480, USA" -}, { - "location": { - "latitude": 412346009, - "longitude": -744026814 - }, - "name": "16 Old Brook Lane, Warwick, NY 10990, USA" -}, { - "location": { - "latitude": 402948455, - "longitude": -747903913 - }, - "name": "3 Drake Lane, Pennington, NJ 08534, USA" -}, { - "location": { - "latitude": 406337092, - "longitude": -740122226 - }, - "name": "6324 8th Avenue, Brooklyn, NY 11220, USA" -}, { - "location": { - "latitude": 406421967, - "longitude": -747727624 - }, - "name": "1 Merck Access Road, Whitehouse Station, NJ 08889, USA" -}, { - "location": { - "latitude": 416318082, - "longitude": -749677716 - }, - "name": "78-98 Schalck Road, Narrowsburg, NY 12764, USA" -}, { - "location": { - "latitude": 415301720, - "longitude": -748416257 - }, - "name": "282 Lakeview Drive Road, Highland Lake, NY 12743, USA" -}, { - "location": { - "latitude": 402647019, - "longitude": -747071791 - }, - "name": "330 Evelyn Avenue, Hamilton Township, NJ 08619, USA" -}, { - "location": { - "latitude": 412567807, - "longitude": -741058078 - }, - "name": "New York State Reference Route 987E, Southfields, NY 10975, USA" -}, { - "location": { - "latitude": 416855156, - "longitude": -744420597 - }, - "name": "103-271 Tempaloni Road, Ellenville, NY 12428, USA" -}, { - "location": { - "latitude": 404663628, - "longitude": -744820157 - }, - "name": "1300 Airport Road, North Brunswick Township, NJ 08902, USA" -}, { - "location": { - "latitude": 407113723, - "longitude": -749746483 - }, - "name": "" -}, { - "location": { - "latitude": 402133926, - "longitude": -743613249 - }, - "name": "" -}, { - "location": { - "latitude": 400273442, - "longitude": -741220915 - }, - "name": "" -}, { - "location": { - "latitude": 411236786, - "longitude": -744070769 - }, - "name": "" -}, { - "location": { - "latitude": 411633782, - "longitude": -746784970 - }, - "name": "211-225 Plains Road, Augusta, NJ 07822, USA" -}, { - "location": { - "latitude": 415830701, - "longitude": -742952812 - }, - "name": "" -}, { - "location": { - "latitude": 413447164, - "longitude": -748712898 - }, - "name": "165 Pedersen Ridge Road, Milford, PA 18337, USA" -}, { - "location": { - "latitude": 405047245, - "longitude": -749800722 - }, - "name": "100-122 Locktown Road, Frenchtown, NJ 08825, USA" -}, { - "location": { - "latitude": 418858923, - "longitude": -746156790 - }, - "name": "" -}, { - "location": { - "latitude": 417951888, - "longitude": -748484944 - }, - "name": "650-652 Willi Hill Road, Swan Lake, NY 12783, USA" -}, { - "location": { - "latitude": 407033786, - "longitude": -743977337 - }, - "name": "26 East 3rd Street, New Providence, NJ 07974, USA" -}, { - "location": { - "latitude": 417548014, - "longitude": -740075041 - }, - "name": "" -}, { - "location": { - "latitude": 410395868, - "longitude": -744972325 - }, - "name": "" -}, { - "location": { - "latitude": 404615353, - "longitude": -745129803 - }, - "name": "" -}, { - "location": { - "latitude": 406589790, - "longitude": -743560121 - }, - "name": "611 Lawrence Avenue, Westfield, NJ 07090, USA" -}, { - "location": { - "latitude": 414653148, - "longitude": -740477477 - }, - "name": "18 Lannis Avenue, New Windsor, NY 12553, USA" -}, { - "location": { - "latitude": 405957808, - "longitude": -743255336 - }, - "name": "82-104 Amherst Avenue, Colonia, NJ 07067, USA" -}, { - "location": { - "latitude": 411733589, - "longitude": -741648093 - }, - "name": "170 Seven Lakes Drive, Sloatsburg, NY 10974, USA" -}, { - "location": { - "latitude": 412676291, - "longitude": -742606606 - }, - "name": "1270 Lakes Road, Monroe, NY 10950, USA" -}, { - "location": { - "latitude": 409224445, - "longitude": -748286738 - }, - "name": "509-535 Alphano Road, Great Meadows, NJ 07838, USA" -}, { - "location": { - "latitude": 406523420, - "longitude": -742135517 - }, - "name": "652 Garden Street, Elizabeth, NJ 07202, USA" -}, { - "location": { - "latitude": 401827388, - "longitude": -740294537 - }, - "name": "349 Sea Spray Court, Neptune City, NJ 07753, USA" -}, { - "location": { - "latitude": 410564152, - "longitude": -743685054 - }, - "name": "13-17 Stanley Street, West Milford, NJ 07480, USA" -}, { - "location": { - "latitude": 408472324, - "longitude": -740726046 - }, - "name": "47 Industrial Avenue, Teterboro, NJ 07608, USA" -}, { - "location": { - "latitude": 412452168, - "longitude": -740214052 - }, - "name": "5 White Oak Lane, Stony Point, NY 10980, USA" -}, { - "location": { - "latitude": 409146138, - "longitude": -746188906 - }, - "name": "Berkshire Valley Management Area Trail, Jefferson, NJ, USA" -}, { - "location": { - "latitude": 404701380, - "longitude": -744781745 - }, - "name": "1007 Jersey Avenue, New Brunswick, NJ 08901, USA" -}, { - "location": { - "latitude": 409642566, - "longitude": -746017679 - }, - "name": "6 East Emerald Isle Drive, Lake Hopatcong, NJ 07849, USA" -}, { - "location": { - "latitude": 408031728, - "longitude": -748645385 - }, - "name": "1358-1474 New Jersey 57, Port Murray, NJ 07865, USA" -}, { - "location": { - "latitude": 413700272, - "longitude": -742135189 - }, - "name": "367 Prospect Road, Chester, NY 10918, USA" -}, { - "location": { - "latitude": 404310607, - "longitude": -740282632 - }, - "name": "10 Simon Lake Drive, Atlantic Highlands, NJ 07716, USA" -}, { - "location": { - "latitude": 409319800, - "longitude": -746201391 - }, - "name": "11 Ward Street, Mount Arlington, NJ 07856, USA" -}, { - "location": { - "latitude": 406685311, - "longitude": -742108603 - }, - "name": "300-398 Jefferson Avenue, Elizabeth, NJ 07201, USA" -}, { - "location": { - "latitude": 419018117, - "longitude": -749142781 - }, - "name": "43 Dreher Road, Roscoe, NY 12776, USA" -}, { - "location": { - "latitude": 412856162, - "longitude": -745148837 - }, - "name": "Swan Street, Pine Island, NY 10969, USA" -}, { - "location": { - "latitude": 416560744, - "longitude": -746721964 - }, - "name": "66 Pleasantview Avenue, Monticello, NY 12701, USA" -}, { - "location": { - "latitude": 405314270, - "longitude": -749836354 - }, - "name": "" -}, { - "location": { - "latitude": 414219548, - "longitude": -743327440 - }, - "name": "" -}, { - "location": { - "latitude": 415534177, - "longitude": -742900616 - }, - "name": "565 Winding Hills Road, Montgomery, NY 12549, USA" -}, { - "location": { - "latitude": 406898530, - "longitude": -749127080 - }, - "name": "231 Rocky Run Road, Glen Gardner, NJ 08826, USA" -}, { - "location": { - "latitude": 407586880, - "longitude": -741670168 - }, - "name": "100 Mount Pleasant Avenue, Newark, NJ 07104, USA" -}, { - "location": { - "latitude": 400106455, - "longitude": -742870190 - }, - "name": "517-521 Huntington Drive, Manchester Township, NJ 08759, USA" -}, { - "location": { - "latitude": 400066188, - "longitude": -746793294 - }, - "name": "" -}, { - "location": { - "latitude": 418803880, - "longitude": -744102673 - }, - "name": "40 Mountain Road, Napanoch, NY 12458, USA" -}, { - "location": { - "latitude": 414204288, - "longitude": -747895140 - }, - "name": "" -}, { - "location": { - "latitude": 414777405, - "longitude": -740615601 - }, - "name": "" -}, { - "location": { - "latitude": 415464475, - "longitude": -747175374 - }, - "name": "48 North Road, Forestburgh, NY 12777, USA" -}, { - "location": { - "latitude": 404062378, - "longitude": -746376177 - }, - "name": "" -}, { - "location": { - "latitude": 405688272, - "longitude": -749285130 - }, - "name": "" -}, { - "location": { - "latitude": 400342070, - "longitude": -748788996 - }, - "name": "" -}, { - "location": { - "latitude": 401809022, - "longitude": -744157964 - }, - "name": "" -}, { - "location": { - "latitude": 404226644, - "longitude": -740517141 - }, - "name": "9 Thompson Avenue, Leonardo, NJ 07737, USA" -}, { - "location": { - "latitude": 410322033, - "longitude": -747871659 - }, - "name": "" -}, { - "location": { - "latitude": 407100674, - "longitude": -747742727 - }, - "name": "" -}, { - "location": { - "latitude": 418811433, - "longitude": -741718005 - }, - "name": "213 Bush Road, Stone Ridge, NY 12484, USA" -}, { - "location": { - "latitude": 415034302, - "longitude": -743850945 - }, - "name": "" -}, { - "location": { - "latitude": 411349992, - "longitude": -743694161 - }, - "name": "" -}, { - "location": { - "latitude": 404839914, - "longitude": -744759616 - }, - "name": "1-17 Bergen Court, New Brunswick, NJ 08901, USA" -}, { - "location": { - "latitude": 414638017, - "longitude": -745957854 - }, - "name": "35 Oakland Valley Road, Cuddebackville, NY 12729, USA" -}, { - "location": { - "latitude": 412127800, - "longitude": -740173578 - }, - "name": "" -}, { - "location": { - "latitude": 401263460, - "longitude": -747964303 - }, - "name": "" -}, { - "location": { - "latitude": 412843391, - "longitude": -749086026 - }, - "name": "" -}, { - "location": { - "latitude": 418512773, - "longitude": -743067823 - }, - "name": "" -}, { - "location": { - "latitude": 404318328, - "longitude": -740835638 - }, - "name": "42-102 Main Street, Belford, NJ 07718, USA" -}, { - "location": { - "latitude": 419020746, - "longitude": -741172328 - }, - "name": "" -}, { - "location": { - "latitude": 404080723, - "longitude": -746119569 - }, - "name": "" -}, { - "location": { - "latitude": 401012643, - "longitude": -744035134 - }, - "name": "" -}, { - "location": { - "latitude": 404306372, - "longitude": -741079661 - }, - "name": "" -}, { - "location": { - "latitude": 403966326, - "longitude": -748519297 - }, - "name": "" -}, { - "location": { - "latitude": 405002031, - "longitude": -748407866 - }, - "name": "" -}, { - "location": { - "latitude": 409532885, - "longitude": -742200683 - }, - "name": "" -}, { - "location": { - "latitude": 416851321, - "longitude": -742674555 - }, - "name": "" -}, { - "location": { - "latitude": 406411633, - "longitude": -741722051 - }, - "name": "3387 Richmond Terrace, Staten Island, NY 10303, USA" -}, { - "location": { - "latitude": 413069058, - "longitude": -744597778 - }, - "name": "261 Van Sickle Road, Goshen, NY 10924, USA" -}, { - "location": { - "latitude": 418465462, - "longitude": -746859398 - }, - "name": "" -}, { - "location": { - "latitude": 411733222, - "longitude": -744228360 - }, - "name": "" -}, { - "location": { - "latitude": 410248224, - "longitude": -747127767 - }, - "name": "3 Hasta Way, Newton, NJ 07860, USA" -}] +"These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples" diff --git a/examples/node/static_codegen/route_guide/route_guide_grpc_pb.js b/examples/node/static_codegen/route_guide/route_guide_grpc_pb.js index 83c839dc85c..e672648e105 100644 --- a/examples/node/static_codegen/route_guide/route_guide_grpc_pb.js +++ b/examples/node/static_codegen/route_guide/route_guide_grpc_pb.js @@ -14,133 +14,5 @@ // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. -// -'use strict'; -var grpc = require('@grpc/grpc-js'); -var route_guide_pb = require('./route_guide_pb.js'); - -function serialize_routeguide_Feature(arg) { - if (!(arg instanceof route_guide_pb.Feature)) { - throw new Error('Expected argument of type routeguide.Feature'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_routeguide_Feature(buffer_arg) { - return route_guide_pb.Feature.deserializeBinary(new Uint8Array(buffer_arg)); -} - -function serialize_routeguide_Point(arg) { - if (!(arg instanceof route_guide_pb.Point)) { - throw new Error('Expected argument of type routeguide.Point'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_routeguide_Point(buffer_arg) { - return route_guide_pb.Point.deserializeBinary(new Uint8Array(buffer_arg)); -} - -function serialize_routeguide_Rectangle(arg) { - if (!(arg instanceof route_guide_pb.Rectangle)) { - throw new Error('Expected argument of type routeguide.Rectangle'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_routeguide_Rectangle(buffer_arg) { - return route_guide_pb.Rectangle.deserializeBinary(new Uint8Array(buffer_arg)); -} - -function serialize_routeguide_RouteNote(arg) { - if (!(arg instanceof route_guide_pb.RouteNote)) { - throw new Error('Expected argument of type routeguide.RouteNote'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_routeguide_RouteNote(buffer_arg) { - return route_guide_pb.RouteNote.deserializeBinary(new Uint8Array(buffer_arg)); -} - -function serialize_routeguide_RouteSummary(arg) { - if (!(arg instanceof route_guide_pb.RouteSummary)) { - throw new Error('Expected argument of type routeguide.RouteSummary'); - } - return Buffer.from(arg.serializeBinary()); -} - -function deserialize_routeguide_RouteSummary(buffer_arg) { - return route_guide_pb.RouteSummary.deserializeBinary(new Uint8Array(buffer_arg)); -} - - -// Interface exported by the server. -var RouteGuideService = exports.RouteGuideService = { - // A simple RPC. -// -// Obtains the feature at a given position. -// -// A feature with an empty name is returned if there's no feature at the given -// position. -getFeature: { - path: '/routeguide.RouteGuide/GetFeature', - requestStream: false, - responseStream: false, - requestType: route_guide_pb.Point, - responseType: route_guide_pb.Feature, - requestSerialize: serialize_routeguide_Point, - requestDeserialize: deserialize_routeguide_Point, - responseSerialize: serialize_routeguide_Feature, - responseDeserialize: deserialize_routeguide_Feature, - }, - // A server-to-client streaming RPC. -// -// Obtains the Features available within the given Rectangle. Results are -// streamed rather than returned at once (e.g. in a response message with a -// repeated field), as the rectangle may cover a large area and contain a -// huge number of features. -listFeatures: { - path: '/routeguide.RouteGuide/ListFeatures', - requestStream: false, - responseStream: true, - requestType: route_guide_pb.Rectangle, - responseType: route_guide_pb.Feature, - requestSerialize: serialize_routeguide_Rectangle, - requestDeserialize: deserialize_routeguide_Rectangle, - responseSerialize: serialize_routeguide_Feature, - responseDeserialize: deserialize_routeguide_Feature, - }, - // A client-to-server streaming RPC. -// -// Accepts a stream of Points on a route being traversed, returning a -// RouteSummary when traversal is completed. -recordRoute: { - path: '/routeguide.RouteGuide/RecordRoute', - requestStream: true, - responseStream: false, - requestType: route_guide_pb.Point, - responseType: route_guide_pb.RouteSummary, - requestSerialize: serialize_routeguide_Point, - requestDeserialize: deserialize_routeguide_Point, - responseSerialize: serialize_routeguide_RouteSummary, - responseDeserialize: deserialize_routeguide_RouteSummary, - }, - // A Bidirectional streaming RPC. -// -// Accepts a stream of RouteNotes sent while a route is being traversed, -// while receiving other RouteNotes (e.g. from other users). -routeChat: { - path: '/routeguide.RouteGuide/RouteChat', - requestStream: true, - responseStream: true, - requestType: route_guide_pb.RouteNote, - responseType: route_guide_pb.RouteNote, - requestSerialize: serialize_routeguide_RouteNote, - requestDeserialize: deserialize_routeguide_RouteNote, - responseSerialize: serialize_routeguide_RouteNote, - responseDeserialize: deserialize_routeguide_RouteNote, - }, -}; -exports.RouteGuideClient = grpc.makeGenericClientConstructor(RouteGuideService); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/route_guide/route_guide_pb.js b/examples/node/static_codegen/route_guide/route_guide_pb.js index a032bec4c4f..7f9ea73adc4 100644 --- a/examples/node/static_codegen/route_guide/route_guide_pb.js +++ b/examples/node/static_codegen/route_guide/route_guide_pb.js @@ -8,1062 +8,4 @@ */ // GENERATED CODE -- DO NOT EDIT! -var jspb = require('google-protobuf'); -var goog = jspb; -var global = Function('return this')(); - -goog.exportSymbol('proto.routeguide.Feature', null, global); -goog.exportSymbol('proto.routeguide.Point', null, global); -goog.exportSymbol('proto.routeguide.Rectangle', null, global); -goog.exportSymbol('proto.routeguide.RouteNote', null, global); -goog.exportSymbol('proto.routeguide.RouteSummary', null, global); -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.routeguide.Point = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.routeguide.Point, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.routeguide.Point.displayName = 'proto.routeguide.Point'; -} -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.routeguide.Rectangle = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.routeguide.Rectangle, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.routeguide.Rectangle.displayName = 'proto.routeguide.Rectangle'; -} -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.routeguide.Feature = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.routeguide.Feature, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.routeguide.Feature.displayName = 'proto.routeguide.Feature'; -} -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.routeguide.RouteNote = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.routeguide.RouteNote, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.routeguide.RouteNote.displayName = 'proto.routeguide.RouteNote'; -} -/** - * Generated by JsPbCodeGenerator. - * @param {Array=} opt_data Optional initial data array, typically from a - * server response, or constructed directly in Javascript. The array is used - * in place and becomes part of the constructed object. It is not cloned. - * If no data is provided, the constructed object will be empty, but still - * valid. - * @extends {jspb.Message} - * @constructor - */ -proto.routeguide.RouteSummary = function(opt_data) { - jspb.Message.initialize(this, opt_data, 0, -1, null, null); -}; -goog.inherits(proto.routeguide.RouteSummary, jspb.Message); -if (goog.DEBUG && !COMPILED) { - /** - * @public - * @override - */ - proto.routeguide.RouteSummary.displayName = 'proto.routeguide.RouteSummary'; -} - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.routeguide.Point.prototype.toObject = function(opt_includeInstance) { - return proto.routeguide.Point.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.routeguide.Point} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Point.toObject = function(includeInstance, msg) { - var f, obj = { - latitude: jspb.Message.getFieldWithDefault(msg, 1, 0), - longitude: jspb.Message.getFieldWithDefault(msg, 2, 0) - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.routeguide.Point} - */ -proto.routeguide.Point.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.routeguide.Point; - return proto.routeguide.Point.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.routeguide.Point} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.routeguide.Point} - */ -proto.routeguide.Point.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = /** @type {number} */ (reader.readInt32()); - msg.setLatitude(value); - break; - case 2: - var value = /** @type {number} */ (reader.readInt32()); - msg.setLongitude(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.routeguide.Point.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.routeguide.Point.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.routeguide.Point} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Point.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getLatitude(); - if (f !== 0) { - writer.writeInt32( - 1, - f - ); - } - f = message.getLongitude(); - if (f !== 0) { - writer.writeInt32( - 2, - f - ); - } -}; - - -/** - * optional int32 latitude = 1; - * @return {number} - */ -proto.routeguide.Point.prototype.getLatitude = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.Point} returns this - */ -proto.routeguide.Point.prototype.setLatitude = function(value) { - return jspb.Message.setProto3IntField(this, 1, value); -}; - - -/** - * optional int32 longitude = 2; - * @return {number} - */ -proto.routeguide.Point.prototype.getLongitude = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 2, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.Point} returns this - */ -proto.routeguide.Point.prototype.setLongitude = function(value) { - return jspb.Message.setProto3IntField(this, 2, value); -}; - - - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.routeguide.Rectangle.prototype.toObject = function(opt_includeInstance) { - return proto.routeguide.Rectangle.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.routeguide.Rectangle} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Rectangle.toObject = function(includeInstance, msg) { - var f, obj = { - lo: (f = msg.getLo()) && proto.routeguide.Point.toObject(includeInstance, f), - hi: (f = msg.getHi()) && proto.routeguide.Point.toObject(includeInstance, f) - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.routeguide.Rectangle} - */ -proto.routeguide.Rectangle.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.routeguide.Rectangle; - return proto.routeguide.Rectangle.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.routeguide.Rectangle} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.routeguide.Rectangle} - */ -proto.routeguide.Rectangle.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = new proto.routeguide.Point; - reader.readMessage(value,proto.routeguide.Point.deserializeBinaryFromReader); - msg.setLo(value); - break; - case 2: - var value = new proto.routeguide.Point; - reader.readMessage(value,proto.routeguide.Point.deserializeBinaryFromReader); - msg.setHi(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.routeguide.Rectangle.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.routeguide.Rectangle.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.routeguide.Rectangle} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Rectangle.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getLo(); - if (f != null) { - writer.writeMessage( - 1, - f, - proto.routeguide.Point.serializeBinaryToWriter - ); - } - f = message.getHi(); - if (f != null) { - writer.writeMessage( - 2, - f, - proto.routeguide.Point.serializeBinaryToWriter - ); - } -}; - - -/** - * optional Point lo = 1; - * @return {?proto.routeguide.Point} - */ -proto.routeguide.Rectangle.prototype.getLo = function() { - return /** @type{?proto.routeguide.Point} */ ( - jspb.Message.getWrapperField(this, proto.routeguide.Point, 1)); -}; - - -/** - * @param {?proto.routeguide.Point|undefined} value - * @return {!proto.routeguide.Rectangle} returns this -*/ -proto.routeguide.Rectangle.prototype.setLo = function(value) { - return jspb.Message.setWrapperField(this, 1, value); -}; - - -/** - * Clears the message field making it undefined. - * @return {!proto.routeguide.Rectangle} returns this - */ -proto.routeguide.Rectangle.prototype.clearLo = function() { - return this.setLo(undefined); -}; - - -/** - * Returns whether this field is set. - * @return {boolean} - */ -proto.routeguide.Rectangle.prototype.hasLo = function() { - return jspb.Message.getField(this, 1) != null; -}; - - -/** - * optional Point hi = 2; - * @return {?proto.routeguide.Point} - */ -proto.routeguide.Rectangle.prototype.getHi = function() { - return /** @type{?proto.routeguide.Point} */ ( - jspb.Message.getWrapperField(this, proto.routeguide.Point, 2)); -}; - - -/** - * @param {?proto.routeguide.Point|undefined} value - * @return {!proto.routeguide.Rectangle} returns this -*/ -proto.routeguide.Rectangle.prototype.setHi = function(value) { - return jspb.Message.setWrapperField(this, 2, value); -}; - - -/** - * Clears the message field making it undefined. - * @return {!proto.routeguide.Rectangle} returns this - */ -proto.routeguide.Rectangle.prototype.clearHi = function() { - return this.setHi(undefined); -}; - - -/** - * Returns whether this field is set. - * @return {boolean} - */ -proto.routeguide.Rectangle.prototype.hasHi = function() { - return jspb.Message.getField(this, 2) != null; -}; - - - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.routeguide.Feature.prototype.toObject = function(opt_includeInstance) { - return proto.routeguide.Feature.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.routeguide.Feature} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Feature.toObject = function(includeInstance, msg) { - var f, obj = { - name: jspb.Message.getFieldWithDefault(msg, 1, ""), - location: (f = msg.getLocation()) && proto.routeguide.Point.toObject(includeInstance, f) - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.routeguide.Feature} - */ -proto.routeguide.Feature.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.routeguide.Feature; - return proto.routeguide.Feature.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.routeguide.Feature} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.routeguide.Feature} - */ -proto.routeguide.Feature.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = /** @type {string} */ (reader.readString()); - msg.setName(value); - break; - case 2: - var value = new proto.routeguide.Point; - reader.readMessage(value,proto.routeguide.Point.deserializeBinaryFromReader); - msg.setLocation(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.routeguide.Feature.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.routeguide.Feature.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.routeguide.Feature} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.Feature.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getName(); - if (f.length > 0) { - writer.writeString( - 1, - f - ); - } - f = message.getLocation(); - if (f != null) { - writer.writeMessage( - 2, - f, - proto.routeguide.Point.serializeBinaryToWriter - ); - } -}; - - -/** - * optional string name = 1; - * @return {string} - */ -proto.routeguide.Feature.prototype.getName = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 1, "")); -}; - - -/** - * @param {string} value - * @return {!proto.routeguide.Feature} returns this - */ -proto.routeguide.Feature.prototype.setName = function(value) { - return jspb.Message.setProto3StringField(this, 1, value); -}; - - -/** - * optional Point location = 2; - * @return {?proto.routeguide.Point} - */ -proto.routeguide.Feature.prototype.getLocation = function() { - return /** @type{?proto.routeguide.Point} */ ( - jspb.Message.getWrapperField(this, proto.routeguide.Point, 2)); -}; - - -/** - * @param {?proto.routeguide.Point|undefined} value - * @return {!proto.routeguide.Feature} returns this -*/ -proto.routeguide.Feature.prototype.setLocation = function(value) { - return jspb.Message.setWrapperField(this, 2, value); -}; - - -/** - * Clears the message field making it undefined. - * @return {!proto.routeguide.Feature} returns this - */ -proto.routeguide.Feature.prototype.clearLocation = function() { - return this.setLocation(undefined); -}; - - -/** - * Returns whether this field is set. - * @return {boolean} - */ -proto.routeguide.Feature.prototype.hasLocation = function() { - return jspb.Message.getField(this, 2) != null; -}; - - - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.routeguide.RouteNote.prototype.toObject = function(opt_includeInstance) { - return proto.routeguide.RouteNote.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.routeguide.RouteNote} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.RouteNote.toObject = function(includeInstance, msg) { - var f, obj = { - location: (f = msg.getLocation()) && proto.routeguide.Point.toObject(includeInstance, f), - message: jspb.Message.getFieldWithDefault(msg, 2, "") - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.routeguide.RouteNote} - */ -proto.routeguide.RouteNote.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.routeguide.RouteNote; - return proto.routeguide.RouteNote.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.routeguide.RouteNote} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.routeguide.RouteNote} - */ -proto.routeguide.RouteNote.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = new proto.routeguide.Point; - reader.readMessage(value,proto.routeguide.Point.deserializeBinaryFromReader); - msg.setLocation(value); - break; - case 2: - var value = /** @type {string} */ (reader.readString()); - msg.setMessage(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.routeguide.RouteNote.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.routeguide.RouteNote.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.routeguide.RouteNote} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.RouteNote.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getLocation(); - if (f != null) { - writer.writeMessage( - 1, - f, - proto.routeguide.Point.serializeBinaryToWriter - ); - } - f = message.getMessage(); - if (f.length > 0) { - writer.writeString( - 2, - f - ); - } -}; - - -/** - * optional Point location = 1; - * @return {?proto.routeguide.Point} - */ -proto.routeguide.RouteNote.prototype.getLocation = function() { - return /** @type{?proto.routeguide.Point} */ ( - jspb.Message.getWrapperField(this, proto.routeguide.Point, 1)); -}; - - -/** - * @param {?proto.routeguide.Point|undefined} value - * @return {!proto.routeguide.RouteNote} returns this -*/ -proto.routeguide.RouteNote.prototype.setLocation = function(value) { - return jspb.Message.setWrapperField(this, 1, value); -}; - - -/** - * Clears the message field making it undefined. - * @return {!proto.routeguide.RouteNote} returns this - */ -proto.routeguide.RouteNote.prototype.clearLocation = function() { - return this.setLocation(undefined); -}; - - -/** - * Returns whether this field is set. - * @return {boolean} - */ -proto.routeguide.RouteNote.prototype.hasLocation = function() { - return jspb.Message.getField(this, 1) != null; -}; - - -/** - * optional string message = 2; - * @return {string} - */ -proto.routeguide.RouteNote.prototype.getMessage = function() { - return /** @type {string} */ (jspb.Message.getFieldWithDefault(this, 2, "")); -}; - - -/** - * @param {string} value - * @return {!proto.routeguide.RouteNote} returns this - */ -proto.routeguide.RouteNote.prototype.setMessage = function(value) { - return jspb.Message.setProto3StringField(this, 2, value); -}; - - - - - -if (jspb.Message.GENERATE_TO_OBJECT) { -/** - * Creates an object representation of this proto. - * Field names that are reserved in JavaScript and will be renamed to pb_name. - * Optional fields that are not set will be set to undefined. - * To access a reserved field use, foo.pb_, eg, foo.pb_default. - * For the list of reserved names please see: - * net/proto2/compiler/js/internal/generator.cc#kKeyword. - * @param {boolean=} opt_includeInstance Deprecated. whether to include the - * JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @return {!Object} - */ -proto.routeguide.RouteSummary.prototype.toObject = function(opt_includeInstance) { - return proto.routeguide.RouteSummary.toObject(opt_includeInstance, this); -}; - - -/** - * Static version of the {@see toObject} method. - * @param {boolean|undefined} includeInstance Deprecated. Whether to include - * the JSPB instance for transitional soy proto support: - * http://goto/soy-param-migration - * @param {!proto.routeguide.RouteSummary} msg The msg instance to transform. - * @return {!Object} - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.RouteSummary.toObject = function(includeInstance, msg) { - var f, obj = { - pointCount: jspb.Message.getFieldWithDefault(msg, 1, 0), - featureCount: jspb.Message.getFieldWithDefault(msg, 2, 0), - distance: jspb.Message.getFieldWithDefault(msg, 3, 0), - elapsedTime: jspb.Message.getFieldWithDefault(msg, 4, 0) - }; - - if (includeInstance) { - obj.$jspbMessageInstance = msg; - } - return obj; -}; -} - - -/** - * Deserializes binary data (in protobuf wire format). - * @param {jspb.ByteSource} bytes The bytes to deserialize. - * @return {!proto.routeguide.RouteSummary} - */ -proto.routeguide.RouteSummary.deserializeBinary = function(bytes) { - var reader = new jspb.BinaryReader(bytes); - var msg = new proto.routeguide.RouteSummary; - return proto.routeguide.RouteSummary.deserializeBinaryFromReader(msg, reader); -}; - - -/** - * Deserializes binary data (in protobuf wire format) from the - * given reader into the given message object. - * @param {!proto.routeguide.RouteSummary} msg The message object to deserialize into. - * @param {!jspb.BinaryReader} reader The BinaryReader to use. - * @return {!proto.routeguide.RouteSummary} - */ -proto.routeguide.RouteSummary.deserializeBinaryFromReader = function(msg, reader) { - while (reader.nextField()) { - if (reader.isEndGroup()) { - break; - } - var field = reader.getFieldNumber(); - switch (field) { - case 1: - var value = /** @type {number} */ (reader.readInt32()); - msg.setPointCount(value); - break; - case 2: - var value = /** @type {number} */ (reader.readInt32()); - msg.setFeatureCount(value); - break; - case 3: - var value = /** @type {number} */ (reader.readInt32()); - msg.setDistance(value); - break; - case 4: - var value = /** @type {number} */ (reader.readInt32()); - msg.setElapsedTime(value); - break; - default: - reader.skipField(); - break; - } - } - return msg; -}; - - -/** - * Serializes the message to binary data (in protobuf wire format). - * @return {!Uint8Array} - */ -proto.routeguide.RouteSummary.prototype.serializeBinary = function() { - var writer = new jspb.BinaryWriter(); - proto.routeguide.RouteSummary.serializeBinaryToWriter(this, writer); - return writer.getResultBuffer(); -}; - - -/** - * Serializes the given message to binary data (in protobuf wire - * format), writing to the given BinaryWriter. - * @param {!proto.routeguide.RouteSummary} message - * @param {!jspb.BinaryWriter} writer - * @suppress {unusedLocalVariables} f is only used for nested messages - */ -proto.routeguide.RouteSummary.serializeBinaryToWriter = function(message, writer) { - var f = undefined; - f = message.getPointCount(); - if (f !== 0) { - writer.writeInt32( - 1, - f - ); - } - f = message.getFeatureCount(); - if (f !== 0) { - writer.writeInt32( - 2, - f - ); - } - f = message.getDistance(); - if (f !== 0) { - writer.writeInt32( - 3, - f - ); - } - f = message.getElapsedTime(); - if (f !== 0) { - writer.writeInt32( - 4, - f - ); - } -}; - - -/** - * optional int32 point_count = 1; - * @return {number} - */ -proto.routeguide.RouteSummary.prototype.getPointCount = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 1, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.RouteSummary} returns this - */ -proto.routeguide.RouteSummary.prototype.setPointCount = function(value) { - return jspb.Message.setProto3IntField(this, 1, value); -}; - - -/** - * optional int32 feature_count = 2; - * @return {number} - */ -proto.routeguide.RouteSummary.prototype.getFeatureCount = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 2, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.RouteSummary} returns this - */ -proto.routeguide.RouteSummary.prototype.setFeatureCount = function(value) { - return jspb.Message.setProto3IntField(this, 2, value); -}; - - -/** - * optional int32 distance = 3; - * @return {number} - */ -proto.routeguide.RouteSummary.prototype.getDistance = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 3, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.RouteSummary} returns this - */ -proto.routeguide.RouteSummary.prototype.setDistance = function(value) { - return jspb.Message.setProto3IntField(this, 3, value); -}; - - -/** - * optional int32 elapsed_time = 4; - * @return {number} - */ -proto.routeguide.RouteSummary.prototype.getElapsedTime = function() { - return /** @type {number} */ (jspb.Message.getFieldWithDefault(this, 4, 0)); -}; - - -/** - * @param {number} value - * @return {!proto.routeguide.RouteSummary} returns this - */ -proto.routeguide.RouteSummary.prototype.setElapsedTime = function(value) { - return jspb.Message.setProto3IntField(this, 4, value); -}; - - -goog.object.extend(exports, proto.routeguide); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/static_codegen/route_guide/route_guide_server.js b/examples/node/static_codegen/route_guide/route_guide_server.js index eb1fd283df1..143661be833 100644 --- a/examples/node/static_codegen/route_guide/route_guide_server.js +++ b/examples/node/static_codegen/route_guide/route_guide_server.js @@ -16,229 +16,4 @@ * */ -var messages = require('./route_guide_pb'); -var services = require('./route_guide_grpc_pb'); - -var fs = require('fs'); -var parseArgs = require('minimist'); -var path = require('path'); -var _ = require('lodash'); -var grpc = require('@grpc/grpc-js'); - -var COORD_FACTOR = 1e7; - -/** - * For simplicity, a point is a record type that looks like - * {latitude: number, longitude: number}, and a feature is a record type that - * looks like {name: string, location: point}. feature objects with name==='' - * are points with no feature. - */ - -/** - * List of feature objects at points that have been requested so far. - */ -var feature_list = []; - -/** - * Get a feature object at the given point, or creates one if it does not exist. - * @param {point} point The point to check - * @return {feature} The feature object at the point. Note that an empty name - * indicates no feature - */ -function checkFeature(point) { - var feature; - // Check if there is already a feature object for the given point - for (var i = 0; i < feature_list.length; i++) { - feature = feature_list[i]; - if (feature.getLocation().getLatitude() === point.getLatitude() && - feature.getLocation().getLongitude() === point.getLongitude()) { - return feature; - } - } - var name = ''; - feature = new messages.Feature(); - feature.setName(name); - feature.setLocation(point); - return feature; -} - -/** - * getFeature request handler. Gets a request with a point, and responds with a - * feature object indicating whether there is a feature at that point. - * @param {EventEmitter} call Call object for the handler to process - * @param {function(Error, feature)} callback Response callback - */ -function getFeature(call, callback) { - callback(null, checkFeature(call.request)); -} - -/** - * listFeatures request handler. Gets a request with two points, and responds - * with a stream of all features in the bounding box defined by those points. - * @param {Writable} call Writable stream for responses with an additional - * request property for the request value. - */ -function listFeatures(call) { - var lo = call.request.getLo(); - var hi = call.request.getHi(); - var left = _.min([lo.getLongitude(), hi.getLongitude()]); - var right = _.max([lo.getLongitude(), hi.getLongitude()]); - var top = _.max([lo.getLatitude(), hi.getLatitude()]); - var bottom = _.min([lo.getLatitude(), hi.getLatitude()]); - // For each feature, check if it is in the given bounding box - _.each(feature_list, function(feature) { - if (feature.getName() === '') { - return; - } - if (feature.getLocation().getLongitude() >= left && - feature.getLocation().getLongitude() <= right && - feature.getLocation().getLatitude() >= bottom && - feature.getLocation().getLatitude() <= top) { - call.write(feature); - } - }); - call.end(); -} - -/** - * Calculate the distance between two points using the "haversine" formula. - * The formula is based on http://mathforum.org/library/drmath/view/51879.html. - * @param start The starting point - * @param end The end point - * @return The distance between the points in meters - */ -function getDistance(start, end) { - function toRadians(num) { - return num * Math.PI / 180; - } - var R = 6371000; // earth radius in metres - var lat1 = toRadians(start.getLatitude() / COORD_FACTOR); - var lat2 = toRadians(end.getLatitude() / COORD_FACTOR); - var lon1 = toRadians(start.getLongitude() / COORD_FACTOR); - var lon2 = toRadians(end.getLongitude() / COORD_FACTOR); - - var deltalat = lat2-lat1; - var deltalon = lon2-lon1; - var a = Math.sin(deltalat/2) * Math.sin(deltalat/2) + - Math.cos(lat1) * Math.cos(lat2) * - Math.sin(deltalon/2) * Math.sin(deltalon/2); - var c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1-a)); - return R * c; -} - -/** - * recordRoute handler. Gets a stream of points, and responds with statistics - * about the "trip": number of points, number of known features visited, total - * distance traveled, and total time spent. - * @param {Readable} call The request point stream. - * @param {function(Error, routeSummary)} callback The callback to pass the - * response to - */ -function recordRoute(call, callback) { - var point_count = 0; - var feature_count = 0; - var distance = 0; - var previous = null; - // Start a timer - var start_time = process.hrtime(); - call.on('data', function(point) { - point_count += 1; - if (checkFeature(point).name !== '') { - feature_count += 1; - } - /* For each point after the first, add the incremental distance from the - * previous point to the total distance value */ - if (previous != null) { - distance += getDistance(previous, point); - } - previous = point; - }); - call.on('end', function() { - var summary = new messages.RouteSummary(); - summary.setPointCount(point_count); - summary.setFeatureCount(feature_count); - // Cast the distance to an integer - summary.setDistance(distance|0); - // End the timer - summary.setElapsedTime(process.hrtime(start_time)[0]); - callback(null, summary); - }); -} - -var route_notes = {}; - -/** - * Turn the point into a dictionary key. - * @param {point} point The point to use - * @return {string} The key for an object - */ -function pointKey(point) { - return point.getLatitude() + ' ' + point.getLongitude(); -} - -/** - * routeChat handler. Receives a stream of message/location pairs, and responds - * with a stream of all previous messages at each of those locations. - * @param {Duplex} call The stream for incoming and outgoing messages - */ -function routeChat(call) { - call.on('data', function(note) { - var key = pointKey(note.getLocation()); - /* For each note sent, respond with all previous notes that correspond to - * the same point */ - if (route_notes.hasOwnProperty(key)) { - _.each(route_notes[key], function(note) { - call.write(note); - }); - } else { - route_notes[key] = []; - } - // Then add the new note to the list - route_notes[key].push(note); - }); - call.on('end', function() { - call.end(); - }); -} - -/** - * Get a new server with the handler functions in this file bound to the methods - * it serves. - * @return {Server} The new server object - */ -function getServer() { - var server = new grpc.Server(); - server.addService(services.RouteGuideService, { - getFeature: getFeature, - listFeatures: listFeatures, - recordRoute: recordRoute, - routeChat: routeChat - }); - return server; -} - -if (require.main === module) { - // If this is run as a script, start a server on an unused port - var routeServer = getServer(); - routeServer.bindAsync('0.0.0.0:50051', grpc.ServerCredentials.createInsecure(), () => { - var argv = parseArgs(process.argv, { - string: 'db_path' - }); - fs.readFile(path.resolve(argv.db_path), function(err, data) { - if (err) throw err; - // Transform the loaded features to Feature objects - feature_list = _.map(JSON.parse(data), function(value) { - var feature = new messages.Feature(); - feature.setName(value.name); - var location = new messages.Point(); - location.setLatitude(value.location.latitude); - location.setLongitude(value.location.longitude); - feature.setLocation(location); - return feature; - }); - routeServer.start(); - }); - }); -} - -exports.getServer = getServer; +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/xds/greeter_client.js b/examples/node/xds/greeter_client.js index 986a38fd4ca..143661be833 100644 --- a/examples/node/xds/greeter_client.js +++ b/examples/node/xds/greeter_client.js @@ -16,47 +16,4 @@ * */ -var PROTO_PATH = __dirname + '/../../protos/helloworld.proto'; - -var parseArgs = require('minimist'); -var grpc = require('@grpc/grpc-js'); -var grpc_xds = require('@grpc/grpc-js-xds'); -grpc_xds.register(); - -var protoLoader = require('@grpc/proto-loader'); -var packageDefinition = protoLoader.loadSync( - PROTO_PATH, - {keepCase: true, - longs: String, - enums: String, - defaults: true, - oneofs: true - }); -var hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld; - -function main() { - var argv = parseArgs(process.argv.slice(2), { - string: 'target' - }); - var target; - if (argv.target) { - target = argv.target; - } else { - target = 'localhost:50051'; - } - var client = new hello_proto.Greeter(target, - grpc.credentials.createInsecure()); - var user; - if (argv._.length > 0) { - user = argv._[0]; - } else { - user = 'world'; - } - client.sayHello({name: user}, function(err, response) { - if (err) throw err; - console.log('Greeting:', response.message); - client.close(); - }); -} - -main(); +// These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples diff --git a/examples/node/xds/package.json b/examples/node/xds/package.json index bbedf6b54e8..068bd9a379f 100644 --- a/examples/node/xds/package.json +++ b/examples/node/xds/package.json @@ -1,10 +1 @@ -{ - "name": "grpc-examples-xds", - "version": "0.1.0", - "dependencies": { - "@grpc/proto-loader": "^0.5.0", - "@grpc/grpc-js": "^1.2.0", - "@grpc/grpc-js-xds": "^1.2.0", - "minimist": "^1.2.0" - } -} +"These examples have been moved to https://github.com/grpc/grpc-node/tree/master/examples"