delta client/server infrastructure

src/app/delta/CMakeLists.txt

@@ -0,0 +1,32 @@
+
+add_library(delta-service delta.proto)
+target_link_libraries(delta-service
+  PUBLIC
+    protobuf::libprotobuf
+    gRPC::grpc
+    gRPC::grpc++
+)
+
+target_include_directories(delta-service
+  PUBLIC
+    ${CMAKE_CURRENT_BINARY_DIR}
+    ${PROTOBUF_INCLUDE_PATH}
+)
+
+get_target_property(grpc_cpp_plugin_location gRPC::grpc_cpp_plugin LOCATION)
+
+# compile the message types
+protobuf_generate(TARGET delta-service LANGUAGE cpp)
+
+# compile the GRPC services
+protobuf_generate(
+  TARGET
+    delta-service
+  LANGUAGE
+    grpc
+  GENERATE_EXTENSIONS
+    .grpc.pb.h
+    .grpc.pb.cc
+  PLUGIN
+    "protoc-gen-grpc=${grpc_cpp_plugin_location}"
+)

src/app/delta/client.cc

@@ -0,0 +1,53 @@
+#include "client.h"
+
+#include <google/protobuf/message.h>
+#include <grpc/support/log.h>
+#include <grpcpp/ext/proto_server_reflection_plugin.h>
+#include <grpcpp/grpcpp.h>
+#include <grpcpp/health_check_service_interface.h>
+
+#include "absl/status/status.h"
+#include "src/app/delta/delta.grpc.pb.h"
+#include "src/app/delta/delta.pb.h"
+
+namespace yaze {
+namespace app {
+namespace delta {
+
+using grpc::Channel;
+using grpc::ClientAsyncResponseReader;
+using grpc::ClientContext;
+using grpc::CompletionQueue;
+using grpc::Server;
+using grpc::ServerBuilder;
+using grpc::Status;
+
+void Client::CreateChannel() {
+  auto channel = grpc::CreateChannel("localhost:50051",
+                                     grpc::InsecureChannelCredentials());
+  stub_ = ::YazeDelta::NewStub(channel);
+}
+
+absl::Status Client::InitRepo(std::string author_name,
+                              std::string project_name) {
+  Repository new_repo;
+  new_repo.set_author_name(author_name);
+  new_repo.set_project_name(project_name);
+
+  InitRequest request;
+  request.set_allocated_repo(&new_repo);
+
+  InitResponse response;
+  Status status = stub_->Init(&rpc_context, request, &response);
+
+  if (!status.ok()) {
+    std::cerr << status.error_code() << ": " << status.error_message()
+              << std::endl;
+    return absl::InternalError(status.error_message());
+  }
+  return absl::OkStatus();
+}
+
+}  // namespace delta
+}  // namespace app
+}  // namespace yaze

src/app/delta/client.h

@@ -0,0 +1,44 @@
+#ifndef YAZE_APP_DELTA_CLIENT_H
+#define YAZE_APP_DELTA_CLIENT_H
+
+#include <google/protobuf/message.h>
+#include <grpc/support/log.h>
+#include <grpcpp/ext/proto_server_reflection_plugin.h>
+#include <grpcpp/grpcpp.h>
+#include <grpcpp/health_check_service_interface.h>
+
+#include <vector>
+
+#include "absl/status/status.h"
+#include "src/app/delta/delta.grpc.pb.h"
+#include "src/app/delta/delta.pb.h"
+
+
+namespace yaze {
+namespace app {
+namespace delta {
+
+using grpc::Channel;
+using grpc::ClientAsyncResponseReader;
+using grpc::ClientContext;
+using grpc::CompletionQueue;
+using grpc::Server;
+using grpc::ServerBuilder;
+using grpc::Status;
+
+class Client {
+ public:
+  void CreateChannel();
+  absl::Status InitRepo(std::string author_name, std::string project_name);
+
+ private:
+  ClientContext rpc_context;
+  std::vector<Repository> repos_;
+  std::unique_ptr<YazeDelta::Stub> stub_;
+};
+
+}  // namespace delta
+}  // namespace app
+}  // namespace yaze
+
+#endif

src/app/delta/delta.cc

@@ -18,7 +18,6 @@ int main(int argc, char** argv) {
 
   auto entry_status = controller.onEntry();
   if (!entry_status.ok()) {
-    // TODO(@scawful): log the specific error
     return EXIT_FAILURE;
   }
 

src/app/delta/delta.proto

@@ -4,9 +4,13 @@ option cc_enable_arenas = true;
 service YazeDelta {
   rpc Init(InitRequest) returns (InitResponse) {}
 
+  rpc Clone(CloneRequest) returns (CloneResponse) {}
+
   rpc Push(PushRequest) returns (PushResponse) {}
   rpc Pull(PullRequest) returns (PullResponse) {}
 
+  rpc Sync(stream SyncRequest) returns (stream SyncResponse) {}
+
   rpc CreateBranch(CreateBranchRequest) returns (CreateBranchResponse) {}
   rpc DeleteBranch(DeleteBranchRequest) returns (DeleteBranchResponse) {}
 
@@ -14,19 +18,55 @@ service YazeDelta {
   rpc UndoMerge(UndoMergeRequest) returns (UndoMergeResponse) {}
 }
 
-message InitRequest {
-  string project_name = 1;
-  repeated uint16_t bytes = 2;
+message Commit {
+  int64 commit_id = 1;
+  int64 parent_commit_id = 2;
+  string author_name = 3;
+  string message_header = 4;
+  optional string message_body = 5;
+  bytes data = 6;
+  int64 signature = 7;
 }
 
+message Branch {
+  string branch_name = 1;
+  optional string parent_name = 2;
+  repeated Commit commits = 3;
+}
+
+message Repository {
+  string project_name = 1;
+  string author_name = 2;
+  int64 signature = 3;
+  optional bool locked = 4;
+  optional string password = 5;
+  repeated Branch tree = 6;
+}
+
+message InitRequest {
+  Repository repo = 1;
+}
+
+message InitResponse {
+  int32 response = 1;
+}
+
+message CloneRequest {}
+
+message CloneResponse {}
+
 message PushRequest {
-  string username = 1;
+  string author_name = 1;
 }
 message PushResponse {}
 
 message PullRequest {}
 message PullResponse {}
 
+message SyncRequest {}
+
+message SyncResponse {}
+
 message CreateBranchRequest {}
 message CreateBranchResponse {}
 

src/app/delta/service.cc

@@ -0,0 +1,42 @@
+#include "service.h"
+
+#include <google/protobuf/message.h>
+#include <grpc/support/log.h>
+#include <grpcpp/ext/proto_server_reflection_plugin.h>
+#include <grpcpp/grpcpp.h>
+#include <grpcpp/health_check_service_interface.h>
+
+#include "absl/status/status.h"
+#include "src/app/delta/delta.grpc.pb.h"
+#include "src/app/delta/delta.pb.h"
+
+namespace yaze {
+namespace app {
+namespace delta {
+
+using grpc::Channel;
+using grpc::ClientAsyncResponseReader;
+using grpc::ClientContext;
+using grpc::CompletionQueue;
+using grpc::Server;
+using grpc::ServerBuilder;
+using grpc::Status;
+
+Status DeltaService::Init(grpc::ServerContext* context,
+                          const InitRequest* request, InitResponse* reply) {
+  return Status::OK;
+}
+
+Status DeltaService::Push(grpc::ServerContext* context,
+                          const PushRequest* request, PushResponse* reply) {
+  return Status::OK;
+}
+
+Status DeltaService::Pull(grpc::ServerContext* context,
+                          const PullRequest* request, PullResponse* reply) {
+  return Status::OK;
+}
+
+}  // namespace delta
+}  // namespace app
+}  // namespace yaze

src/app/delta/service.h

@@ -0,0 +1,37 @@
+#ifndef YAZE_APP_DELTA_SERVICE_H
+#define YAZE_APP_DELTA_SERVICE_H
+
+#include <google/protobuf/message.h>
+#include <grpc/support/log.h>
+#include <grpcpp/ext/proto_server_reflection_plugin.h>
+#include <grpcpp/grpcpp.h>
+#include <grpcpp/health_check_service_interface.h>
+
+#include <vector>
+
+#include "absl/status/status.h"
+#include "src/app/delta/delta.grpc.pb.h"
+#include "src/app/delta/delta.pb.h"
+
+namespace yaze {
+namespace app {
+namespace delta {
+
+class DeltaService final : public ::YazeDelta::Service {
+ public:
+  Status Init(grpc::ServerContext* context, const InitRequest* request,
+              InitResponse* reply) override;
+
+  Status Push(grpc::ServerContext* context, const PushRequest* request,
+              PushResponse* reply) override;
+
+  Status Pull(grpc::ServerContext* context, const PullRequest* request,
+              PullResponse* reply) override;
+
+ private:
+  std::vector<Repository> repos_;
+};
+
+}  // namespace delta
+}  // namespace app
+}  // namespace yaze