mirror of
https://github.com/grpc/grpc-node.git
synced 2025-12-08 18:23:54 +00:00
Merge pull request #2474 from murgatroid99/import_examples
Import examples from core repository
This commit is contained in:
Michael Lumish
GitHub
commit
3098d69e40
49
examples/README.md
Normal file
49
examples/README.md
Normal file
@ -0,0 +1,49 @@
|
||||
gRPC in 3 minutes (Node.js)
|
||||
===========================
|
||||
|
||||
PREREQUISITES
|
||||
-------------
|
||||
|
||||
- `node`: This requires Node 8.13.0 or greater.
|
||||
|
||||
INSTALL
|
||||
-------
|
||||
|
||||
```sh
|
||||
$ # Get the gRPC repository
|
||||
$ export REPO_ROOT=grpc-node # REPO root can be any directory of your choice
|
||||
$ git clone -b RELEASE_TAG_HERE https://github.com/grpc/grpc-node $REPO_ROOT
|
||||
$ cd $REPO_ROOT
|
||||
|
||||
$ cd examples
|
||||
$ 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 ./helloworld/dynamic_codegen/greeter_server.js &
|
||||
$ # OR
|
||||
$ node ./helloworld/static_codegen/greeter_server.js &
|
||||
```
|
||||
|
||||
- Run the client
|
||||
|
||||
```sh
|
||||
$ # from this directory
|
||||
$ node ./helloworld/dynamic_codegen/greeter_client.js
|
||||
$ # OR
|
||||
$ node ./helloworld/static_codegen/greeter_client.js
|
||||
```
|
||||
|
||||
TUTORIAL
|
||||
--------
|
||||
You can find a more detailed tutorial in [gRPC Basics: Node.js][]
|
||||
|
||||
[gRPC Basics: Node.js]:https://grpc.io/docs/languages/node/basics
|
||||
57
examples/helloworld/dynamic_codegen/greeter_client.js
Normal file
57
examples/helloworld/dynamic_codegen/greeter_client.js
Normal file
@ -0,0 +1,57 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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();
|
||||
52
examples/helloworld/dynamic_codegen/greeter_server.js
Normal file
52
examples/helloworld/dynamic_codegen/greeter_server.js
Normal file
@ -0,0 +1,52 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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();
|
||||
7
examples/helloworld/static_codegen/README.md
Normal file
7
examples/helloworld/static_codegen/README.md
Normal file
@ -0,0 +1,7 @@
|
||||
This is the static code generation variant of the Hello World. 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:../helloworld/static_codegen/ --grpc_out=grpc_js:../helloworld/static_codegen/ helloworld.proto
|
||||
```
|
||||
50
examples/helloworld/static_codegen/greeter_client.js
Normal file
50
examples/helloworld/static_codegen/greeter_client.js
Normal file
@ -0,0 +1,50 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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();
|
||||
45
examples/helloworld/static_codegen/greeter_server.js
Normal file
45
examples/helloworld/static_codegen/greeter_server.js
Normal file
@ -0,0 +1,45 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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();
|
||||
61
examples/helloworld/static_codegen/helloworld_grpc_pb.js
Normal file
61
examples/helloworld/static_codegen/helloworld_grpc_pb.js
Normal file
@ -0,0 +1,61 @@
|
||||
// GENERATED CODE -- DO NOT EDIT!
|
||||
|
||||
// Original file comments:
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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);
|
||||
319
examples/helloworld/static_codegen/helloworld_pb.js
Normal file
319
examples/helloworld/static_codegen/helloworld_pb.js
Normal file
@ -0,0 +1,319 @@
|
||||
// source: helloworld.proto
|
||||
/**
|
||||
* @fileoverview
|
||||
* @enhanceable
|
||||
* @suppress {messageConventions} JS Compiler reports an error if a variable or
|
||||
* field starts with 'MSG_' and isn't a translatable message.
|
||||
* @public
|
||||
*/
|
||||
// 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_<name>, 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_<name>, 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);
|
||||
13
examples/package.json
Normal file
13
examples/package.json
Normal file
@ -0,0 +1,13 @@
|
||||
{
|
||||
"name": "grpc-examples",
|
||||
"version": "0.1.0",
|
||||
"dependencies": {
|
||||
"@grpc/proto-loader": "^0.6.0",
|
||||
"async": "^1.5.2",
|
||||
"google-protobuf": "^3.0.0",
|
||||
"@grpc/grpc-js": "^1.8.0",
|
||||
"@grpc/grpc-js-xds": "^1.8.0",
|
||||
"lodash": "^4.6.1",
|
||||
"minimist": "^1.2.0"
|
||||
}
|
||||
}
|
||||
82
examples/protos/BUILD
Normal file
82
examples/protos/BUILD
Normal file
@ -0,0 +1,82 @@
|
||||
# Copyright 2020 the gRPC authors.
|
||||
#
|
||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||
# you may not use this file except in compliance with the License.
|
||||
# You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||
# 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.
|
||||
|
||||
load("@rules_proto//proto:defs.bzl", "proto_library")
|
||||
load("//bazel:cc_grpc_library.bzl", "cc_grpc_library")
|
||||
load("//bazel:grpc_build_system.bzl", "grpc_proto_library")
|
||||
load("//bazel:python_rules.bzl", "py_grpc_library", "py_proto_library")
|
||||
|
||||
licenses(["notice"])
|
||||
|
||||
package(default_visibility = ["//visibility:public"])
|
||||
|
||||
grpc_proto_library(
|
||||
name = "auth_sample",
|
||||
srcs = ["auth_sample.proto"],
|
||||
)
|
||||
|
||||
grpc_proto_library(
|
||||
name = "hellostreamingworld",
|
||||
srcs = ["hellostreamingworld.proto"],
|
||||
)
|
||||
|
||||
# The following three rules demonstrate the usage of the cc_grpc_library rule in
|
||||
# in a mode compatible with the native proto_library and cc_proto_library rules.
|
||||
proto_library(
|
||||
name = "helloworld_proto",
|
||||
srcs = ["helloworld.proto"],
|
||||
)
|
||||
|
||||
cc_proto_library(
|
||||
name = "helloworld_cc_proto",
|
||||
deps = [":helloworld_proto"],
|
||||
)
|
||||
|
||||
cc_grpc_library(
|
||||
name = "helloworld_cc_grpc",
|
||||
srcs = [":helloworld_proto"],
|
||||
grpc_only = True,
|
||||
deps = [":helloworld_cc_proto"],
|
||||
)
|
||||
|
||||
grpc_proto_library(
|
||||
name = "route_guide",
|
||||
srcs = ["route_guide.proto"],
|
||||
)
|
||||
|
||||
proto_library(
|
||||
name = "keyvaluestore_proto",
|
||||
srcs = ["keyvaluestore.proto"],
|
||||
)
|
||||
|
||||
grpc_proto_library(
|
||||
name = "keyvaluestore",
|
||||
srcs = ["keyvaluestore.proto"],
|
||||
)
|
||||
|
||||
py_proto_library(
|
||||
name = "helloworld_py_pb2",
|
||||
deps = [":helloworld_proto"],
|
||||
)
|
||||
|
||||
py_grpc_library(
|
||||
name = "helloworld_py_pb2_grpc",
|
||||
srcs = [":helloworld_proto"],
|
||||
deps = [":helloworld_py_pb2"],
|
||||
)
|
||||
|
||||
proto_library(
|
||||
name = "route_guide_proto",
|
||||
srcs = [":route_guide.proto"],
|
||||
)
|
||||
8
examples/protos/README.md
Normal file
8
examples/protos/README.md
Normal file
@ -0,0 +1,8 @@
|
||||
# Example protos
|
||||
|
||||
## Contents
|
||||
|
||||
- [helloworld.proto]
|
||||
- The simple example used in the overview.
|
||||
- [route_guide.proto]
|
||||
- An example service described in detail in the tutorial.
|
||||
42
examples/protos/auth_sample.proto
Normal file
42
examples/protos/auth_sample.proto
Normal file
@ -0,0 +1,42 @@
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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.
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
package grpc.testing;
|
||||
|
||||
option objc_class_prefix = "AUTH";
|
||||
|
||||
// Unary request.
|
||||
message Request {
|
||||
// Whether Response should include username.
|
||||
bool fill_username = 4;
|
||||
|
||||
// Whether Response should include OAuth scope.
|
||||
bool fill_oauth_scope = 5;
|
||||
}
|
||||
|
||||
// Unary response, as configured by the request.
|
||||
message Response {
|
||||
// The user the request came from, for verifying authentication was
|
||||
// successful.
|
||||
string username = 2;
|
||||
// OAuth scope.
|
||||
string oauth_scope = 3;
|
||||
}
|
||||
|
||||
service TestService {
|
||||
// One request followed by one response.
|
||||
rpc UnaryCall(Request) returns (Response);
|
||||
}
|
||||
39
examples/protos/hellostreamingworld.proto
Normal file
39
examples/protos/hellostreamingworld.proto
Normal file
@ -0,0 +1,39 @@
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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.
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
option java_package = "ex.grpc";
|
||||
option objc_class_prefix = "HSW";
|
||||
|
||||
package hellostreamingworld;
|
||||
|
||||
// The greeting service definition.
|
||||
service MultiGreeter {
|
||||
// Sends multiple greetings
|
||||
rpc sayHello (HelloRequest) returns (stream HelloReply) {}
|
||||
}
|
||||
|
||||
// The request message containing the user's name and how many greetings
|
||||
// they want.
|
||||
message HelloRequest {
|
||||
string name = 1;
|
||||
string num_greetings = 2;
|
||||
}
|
||||
|
||||
// A response message containing a greeting
|
||||
message HelloReply {
|
||||
string message = 1;
|
||||
}
|
||||
|
||||
40
examples/protos/helloworld.proto
Normal file
40
examples/protos/helloworld.proto
Normal file
@ -0,0 +1,40 @@
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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.
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
option java_multiple_files = true;
|
||||
option java_package = "io.grpc.examples.helloworld";
|
||||
option java_outer_classname = "HelloWorldProto";
|
||||
option objc_class_prefix = "HLW";
|
||||
|
||||
package helloworld;
|
||||
|
||||
// The greeting service definition.
|
||||
service Greeter {
|
||||
// Sends a greeting
|
||||
rpc SayHello (HelloRequest) returns (HelloReply) {}
|
||||
|
||||
rpc SayHelloStreamReply (HelloRequest) returns (stream HelloReply) {}
|
||||
}
|
||||
|
||||
// The request message containing the user's name.
|
||||
message HelloRequest {
|
||||
string name = 1;
|
||||
}
|
||||
|
||||
// The response message containing the greetings
|
||||
message HelloReply {
|
||||
string message = 1;
|
||||
}
|
||||
33
examples/protos/keyvaluestore.proto
Normal file
33
examples/protos/keyvaluestore.proto
Normal file
@ -0,0 +1,33 @@
|
||||
// Copyright 2018 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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.
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
package keyvaluestore;
|
||||
|
||||
// A simple key-value storage service
|
||||
service KeyValueStore {
|
||||
// Provides a value for each key request
|
||||
rpc GetValues (stream Request) returns (stream Response) {}
|
||||
}
|
||||
|
||||
// The request message containing the key
|
||||
message Request {
|
||||
string key = 1;
|
||||
}
|
||||
|
||||
// The response message containing the value associated with the key
|
||||
message Response {
|
||||
string value = 1;
|
||||
}
|
||||
111
examples/protos/route_guide.proto
Normal file
111
examples/protos/route_guide.proto
Normal file
@ -0,0 +1,111 @@
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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.
|
||||
|
||||
syntax = "proto3";
|
||||
|
||||
option java_multiple_files = true;
|
||||
option java_package = "io.grpc.examples.routeguide";
|
||||
option java_outer_classname = "RouteGuideProto";
|
||||
option objc_class_prefix = "RTG";
|
||||
|
||||
package routeguide;
|
||||
|
||||
// Interface exported by the server.
|
||||
service RouteGuide {
|
||||
// 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.
|
||||
rpc GetFeature(Point) returns (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.
|
||||
rpc ListFeatures(Rectangle) returns (stream Feature) {}
|
||||
|
||||
// A client-to-server streaming RPC.
|
||||
//
|
||||
// Accepts a stream of Points on a route being traversed, returning a
|
||||
// RouteSummary when traversal is completed.
|
||||
rpc RecordRoute(stream Point) returns (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).
|
||||
rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
|
||||
}
|
||||
|
||||
// Points are represented as latitude-longitude pairs in the E7 representation
|
||||
// (degrees multiplied by 10**7 and rounded to the nearest integer).
|
||||
// Latitudes should be in the range +/- 90 degrees and longitude should be in
|
||||
// the range +/- 180 degrees (inclusive).
|
||||
message Point {
|
||||
int32 latitude = 1;
|
||||
int32 longitude = 2;
|
||||
}
|
||||
|
||||
// A latitude-longitude rectangle, represented as two diagonally opposite
|
||||
// points "lo" and "hi".
|
||||
message Rectangle {
|
||||
// One corner of the rectangle.
|
||||
Point lo = 1;
|
||||
|
||||
// The other corner of the rectangle.
|
||||
Point hi = 2;
|
||||
}
|
||||
|
||||
// A feature names something at a given point.
|
||||
//
|
||||
// If a feature could not be named, the name is empty.
|
||||
message Feature {
|
||||
// The name of the feature.
|
||||
string name = 1;
|
||||
|
||||
// The point where the feature is detected.
|
||||
Point location = 2;
|
||||
}
|
||||
|
||||
// A RouteNote is a message sent while at a given point.
|
||||
message RouteNote {
|
||||
// The location from which the message is sent.
|
||||
Point location = 1;
|
||||
|
||||
// The message to be sent.
|
||||
string message = 2;
|
||||
}
|
||||
|
||||
// A RouteSummary is received in response to a RecordRoute rpc.
|
||||
//
|
||||
// It contains the number of individual points received, the number of
|
||||
// detected features, and the total distance covered as the cumulative sum of
|
||||
// the distance between each point.
|
||||
message RouteSummary {
|
||||
// The number of points received.
|
||||
int32 point_count = 1;
|
||||
|
||||
// The number of known features passed while traversing the route.
|
||||
int32 feature_count = 2;
|
||||
|
||||
// The distance covered in metres.
|
||||
int32 distance = 3;
|
||||
|
||||
// The duration of the traversal in seconds.
|
||||
int32 elapsed_time = 4;
|
||||
}
|
||||
5
examples/routeguide/README.md
Normal file
5
examples/routeguide/README.md
Normal file
@ -0,0 +1,5 @@
|
||||
# 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
|
||||
237
examples/routeguide/dynamic_codegen/route_guide_client.js
Normal file
237
examples/routeguide/dynamic_codegen/route_guide_client.js
Normal file
@ -0,0 +1,237 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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;
|
||||
601
examples/routeguide/dynamic_codegen/route_guide_db.json
Normal file
601
examples/routeguide/dynamic_codegen/route_guide_db.json
Normal file
@ -0,0 +1,601 @@
|
||||
[{
|
||||
"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"
|
||||
}]
|
||||
245
examples/routeguide/dynamic_codegen/route_guide_server.js
Normal file
245
examples/routeguide/dynamic_codegen/route_guide_server.js
Normal file
@ -0,0 +1,245 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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;
|
||||
7
examples/routeguide/static_codegen/README.md
Normal file
7
examples/routeguide/static_codegen/README.md
Normal file
@ -0,0 +1,7 @@
|
||||
This is the static code generation variant of the Route Guide example. 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:../routeguide/static_codegen/ --grpc_out=grpc_js:../routeguide/static_codegen/ route_guide.proto
|
||||
```
|
||||
237
examples/routeguide/static_codegen/route_guide_client.js
Normal file
237
examples/routeguide/static_codegen/route_guide_client.js
Normal file
@ -0,0 +1,237 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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;
|
||||
601
examples/routeguide/static_codegen/route_guide_db.json
Normal file
601
examples/routeguide/static_codegen/route_guide_db.json
Normal file
@ -0,0 +1,601 @@
|
||||
[{
|
||||
"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"
|
||||
}]
|
||||
146
examples/routeguide/static_codegen/route_guide_grpc_pb.js
Normal file
146
examples/routeguide/static_codegen/route_guide_grpc_pb.js
Normal file
@ -0,0 +1,146 @@
|
||||
// GENERATED CODE -- DO NOT EDIT!
|
||||
|
||||
// Original file comments:
|
||||
// Copyright 2015 gRPC authors.
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// 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);
|
||||
1069
examples/routeguide/static_codegen/route_guide_pb.js
Normal file
1069
examples/routeguide/static_codegen/route_guide_pb.js
Normal file
File diff suppressed because it is too large
Load Diff
244
examples/routeguide/static_codegen/route_guide_server.js
Normal file
244
examples/routeguide/static_codegen/route_guide_server.js
Normal file
@ -0,0 +1,244 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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;
|
||||
62
examples/xds/greeter_client.js
Normal file
62
examples/xds/greeter_client.js
Normal file
@ -0,0 +1,62 @@
|
||||
/*
|
||||
*
|
||||
* Copyright 2015 gRPC authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* 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.
|
||||
*
|
||||
*/
|
||||
|
||||
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();
|
||||
Loading…
x
Reference in New Issue
Block a user