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

Add recommendation service impl

Browse source
This commit is contained in:
Nipuna Marcus 2019-11-16 11:53:40 +05:30
parent 79da8cf7dd
commit 23dc2cb521
4 changed files with 943 additions and 89 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/recommendationservice_ballerina/Ballerina.toml
View file

@ -1,5 +1,5 @@
[project] [project]
org-name= "recommendationservice" org-name= "recommendationservice"
version= "1.0" version= "0.1.0"
[dependencies] [dependencies]

63
src/recommendationservice_ballerina/src/recommendationservice/RecommendationService_sample_service.bal
View file

@ -1,13 +1,70 @@
import ballerina/grpc; import ballerina/grpc;
import ballerina/io;
import ballerina/kubernetes;
listener grpc:Listener ep = new (9090); // Product catalog client.
ProductCatalogServiceBlockingClient productCat = new ("http://productcatalogservice:3550");
service RecommendationService on ep { @kubernetes:Service {
serviceType: "ClusterIP",
name: "recommendationservice"
}
service RecommendationService on new grpc:Listener(8080) {
resource function ListRecommendations(grpc:Caller caller, ListRecommendationsRequest value) { resource function ListRecommendations(grpc:Caller caller, ListRecommendationsRequest value) {
// Implementation goes here. Empty req = {};
// Fetch list of products from product catalog stub
var products = productCat->ListProducts(req);
if (products is grpc:Error) {
io:println("Error from Connector: " + products.reason() + " - "
+ <string>products.detail()["message"]);
// You should return a ListRecommendationsResponse // You should return a ListRecommendationsResponse
ListRecommendationsRequest resp = {
user_id: value.user_id,
product_ids: ["9SIQT8TOJO", "6E92ZMYYFZ", "LS4PSXUNUM"]
};
io:println(resp);
var e = caller->send(resp);
e = caller->complete();
} else {
ListProductsResponse listProductResponse;
grpc:Headers headers;
[listProductResponse, headers] = products;
Product[] productList = listProductResponse.products;
// Extract product id from the product list.
string[] productIds = [];
int i = 0;
foreach Product v in productList {
productIds[i] = v.id;
i += 1;
}
// Filter products which already available in the request.
string[] filtered_products = [];
int j = 0;
foreach string item in productIds {
boolean isExist = false;
foreach string v in value.product_ids {
if (item == v) {
isExist = true;
}
}
if (!isExist) {
filtered_products[j] = item;
j += 1;
} }
} }
// Send the list of recommentations
ListRecommendationsRequest resp = {
user_id: value.user_id,
product_ids: filtered_products.reverse()
};
io:println(resp);
var e = caller->send(resp);
e = caller->complete();
}
}
}

880
src/recommendationservice_ballerina/src/recommendationservice/demo_pb.bal Normal file
View file

File diff suppressed because one or more lines are too long

83
src/recommendationservice_ballerina/src/recommendationservice/recommendationservice_pb.bal
View file

@ -1,83 +0,0 @@
import ballerina/grpc;
public type RecommendationServiceBlockingClient client object {
*grpc:AbstractClientEndpoint;
private grpc:Client grpcClient;
public function __init(string url, grpc:ClientConfiguration? config = ()) {
// initialize client endpoint.
grpc:Client c = new(url, config);
grpc:Error? result = c.initStub(self, "blocking", ROOT_DESCRIPTOR, getDescriptorMap());
if (result is grpc:Error) {
error err = result;
panic err;
} else {
self.grpcClient = c;
}
}
public remote function ListRecommendations(ListRecommendationsRequest req, grpc:Headers? headers = ()) returns ([ListRecommendationsResponse, grpc:Headers]|grpc:Error) {
var payload = check self.grpcClient->blockingExecute("hipstershop.RecommendationService/ListRecommendations", req, headers);
grpc:Headers resHeaders = new;
anydata result = ();
[result, resHeaders] = payload;
var value = typedesc<ListRecommendationsResponse>.constructFrom(result);
if (value is ListRecommendationsResponse) {
return [value, resHeaders];
} else {
return grpc:prepareError(grpc:INTERNAL_ERROR, "Error while constructing the message", value);
}
}
};
public type RecommendationServiceClient client object {
*grpc:AbstractClientEndpoint;
private grpc:Client grpcClient;
public function __init(string url, grpc:ClientConfiguration? config = ()) {
// initialize client endpoint.
grpc:Client c = new(url, config);
grpc:Error? result = c.initStub(self, "non-blocking", ROOT_DESCRIPTOR, getDescriptorMap());
if (result is grpc:Error) {
error err = result;
panic err;
} else {
self.grpcClient = c;
}
}
public remote function ListRecommendations(ListRecommendationsRequest req, service msgListener, grpc:Headers? headers = ()) returns (grpc:Error?) {
return self.grpcClient->nonBlockingExecute("hipstershop.RecommendationService/ListRecommendations", req, msgListener, headers);
}
};
public type ListRecommendationsRequest record {|
string user_id;
string[] product_ids;
|};
public type ListRecommendationsResponse record {|
string[] product_ids;
|};
const string ROOT_DESCRIPTOR = "0A1B7265636F6D6D656E646174696F6E736572766963652E70726F746F120B6869707374657273686F7022560A1A4C6973745265636F6D6D656E646174696F6E735265717565737412170A07757365725F69641801200128095206757365724964121F0A0B70726F647563745F696473180220032809520A70726F64756374496473223E0A1B4C6973745265636F6D6D656E646174696F6E73526573706F6E7365121F0A0B70726F647563745F696473180120032809520A70726F647563744964733283010A155265636F6D6D656E646174696F6E53657276696365126A0A134C6973745265636F6D6D656E646174696F6E7312272E6869707374657273686F702E4C6973745265636F6D6D656E646174696F6E73526571756573741A282E6869707374657273686F702E4C6973745265636F6D6D656E646174696F6E73526573706F6E73652200620670726F746F33";
function getDescriptorMap() returns map<string> {
return {
"recommendationservice.proto":"0A1B7265636F6D6D656E646174696F6E736572766963652E70726F746F120B6869707374657273686F7022560A1A4C6973745265636F6D6D656E646174696F6E735265717565737412170A07757365725F69641801200128095206757365724964121F0A0B70726F647563745F696473180220032809520A70726F64756374496473223E0A1B4C6973745265636F6D6D656E646174696F6E73526573706F6E7365121F0A0B70726F647563745F696473180120032809520A70726F647563744964733283010A155265636F6D6D656E646174696F6E53657276696365126A0A134C6973745265636F6D6D656E646174696F6E7312272E6869707374657273686F702E4C6973745265636F6D6D656E646174696F6E73526571756573741A282E6869707374657273686F702E4C6973745265636F6D6D656E646174696F6E73526573706F6E73652200620670726F746F33"
};
}