Initial commit

Author: gitpushdashf

.flake8

@@ -0,0 +1,4 @@
+[flake8]
+max-line-length = 88
+extend-ignore = E203
+exclude = dist,.venv,.env,env,venv,.cache

.gitignore

@@ -0,0 +1,7 @@
+dist/
+*_pb.js
+node_modules/
+package-lock.json
+.venv
+__pycache__
+*.pyc

Makefile

@@ -0,0 +1,20 @@
+.venv:
+	python3 -m venv .venv
+
+python-lint:
+	black --check server.py
+	flake8 server.py
+
+python-install: .venv
+	.venv/bin/python3 -m pip install -r requirements.txt
+
+protostubs:
+	protoc -I=. helloworld.proto --js_out=import_style=commonjs:. --grpc-web_out=import_style=commonjs,mode=grpcwebtext:.
+	PATH=.venv/bin .venv/bin/python3 -m grpc_tools.protoc --proto_path=. --python_out=. --grpc_python_out=. --mypy_out=. --mypy_grpc_out=. helloworld.proto
+
+webpack:
+	npx webpack client.js
+
+all: protostubs webpack
+
+install: python-install

README.md

@@ -0,0 +1,11 @@
+# Note
+
+This came from: https://github.com/grpc/grpc-web/tree/master/net/grpc/gateway/examples/helloworld
+
+# Install
+
+ * `brew install protoc-gen-grpc-web`
+ * `npm install`
+ * `make all`
+
+# Also see: [original-README.md](original-README.md)

client.js

@@ -0,0 +1,55 @@
+/**
+ *
+ * Copyright 2018 Google LLC
+ *
+ * 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
+ *
+ *     https://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.
+ *
+ */
+
+console.log("We're logging in the console.");
+
+const {HelloRequest, RepeatHelloRequest,
+       HelloReply} = require('./helloworld_pb.js');
+const {GreeterClient} = require('./helloworld_grpc_web_pb.js');
+
+var client = new GreeterClient('http://127.0.0.1:5000', null, null);
+
+// simple unary call
+var request = new HelloRequest();
+request.setName('A very big world');
+
+client.sayHello(request, {}, (err, response) => {
+  if (err) {
+    console.log(`Unexpected error for sayHello: code = ${err.code}` +
+                `, message = "${err.message}"`);
+  } else {
+    console.log(response.getMessage());
+  }
+});
+
+
+// server streaming call
+/*
+var streamRequest = new RepeatHelloRequest();
+streamRequest.setName('World');
+streamRequest.setCount(5);
+
+var stream = client.sayRepeatHello(streamRequest, {});
+stream.on('data', (response) => {
+  console.log(response.getMessage());
+});
+stream.on('error', (err) => {
+  console.log(`Unexpected stream error: code = ${err.code}` +
+              `, message = "${err.message}"`);
+});
+*/

envoy.yaml

@@ -0,0 +1,55 @@
+admin:
+  access_log_path: /tmp/admin_access.log
+  address:
+    socket_address: { address: 0.0.0.0, port_value: 9901 }
+
+static_resources:
+  listeners:
+  - name: listener_0
+    address:
+      socket_address: { address: 0.0.0.0, port_value: 8080 }
+    filter_chains:
+    - filters:
+      - name: envoy.filters.network.http_connection_manager
+        typed_config:
+          "@type": type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
+          codec_type: auto
+          stat_prefix: ingress_http
+          route_config:
+            name: local_route
+            virtual_hosts:
+            - name: local_service
+              domains: ["*"]
+              routes:
+              - match: { prefix: "/" }
+                route:
+                  cluster: greeter_service
+                  max_stream_duration:
+                    grpc_timeout_header_max: 0s
+              cors:
+                allow_origin_string_match:
+                - prefix: "*"
+                allow_methods: GET, PUT, DELETE, POST, OPTIONS
+                allow_headers: keep-alive,user-agent,cache-control,content-type,content-transfer-encoding,custom-header-1,x-accept-content-transfer-encoding,x-accept-response-streaming,x-user-agent,x-grpc-web,grpc-timeout
+                max_age: "1728000"
+                expose_headers: custom-header-1,grpc-status,grpc-message
+          http_filters:
+          - name: envoy.filters.http.grpc_web
+          - name: envoy.filters.http.cors
+          - name: envoy.filters.http.router
+  clusters:
+  - name: greeter_service
+    connect_timeout: 0.25s
+    type: logical_dns
+    http2_protocol_options: {}
+    lb_policy: round_robin
+    # win/mac hosts: Use address: host.docker.internal instead of address: localhost in the line below
+    load_assignment:
+      cluster_name: cluster_0
+      endpoints:
+        - lb_endpoints:
+            - endpoint:
+                address:
+                  socket_address:
+                    address: 0.0.0.0
+                    port_value: 9090

helloworld.proto

@@ -0,0 +1,37 @@
+// Copyright 2018 Google LLC
+//
+// 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
+//
+//     https://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 helloworld;
+
+service Greeter {
+  // unary call
+  rpc SayHello(HelloRequest) returns (HelloReply);
+  // server streaming call
+  rpc SayRepeatHello(RepeatHelloRequest) returns (stream HelloReply);
+}
+
+message HelloRequest {
+  string name = 1;
+}
+
+message RepeatHelloRequest {
+  string name = 1;
+  int32 count = 2;
+}
+
+message HelloReply {
+  string message = 1;
+}