Moved commit "Add start and end times to Operations API" from ydb repo

Author: pixcc

include/ydb-cpp-sdk/client/types/operation/operation.h

@@ -5,6 +5,7 @@
 #include <library/cpp/threading/future/future.h>
 
 #include <google/protobuf/stubs/status.h>
+#include <google/protobuf/timestamp.pb.h>
 #include <google/protobuf/util/json_util.h>
 
 namespace Ydb {
@@ -31,6 +32,8 @@ class TOperation {
     const TOperationId& Id() const;
     bool Ready() const;
     const TStatus& Status() const;
+    TInstant StartTime() const;
+    TInstant EndTime() const;
 
     std::string ToString() const;
     std::string ToJsonString() const;
@@ -46,4 +49,6 @@ class TOperation {
 
 using TAsyncOperation = NThreading::TFuture<TOperation>;
 
+TInstant ProtoTimestampToInstant(const google::protobuf::Timestamp& timestamp);
+
 } // namespace NYdb

src/client/export/export.cpp

@@ -24,12 +24,6 @@ using namespace Ydb::Export;
 /// Common
 namespace {
 
-TInstant ProtoTimestampToInstant(const google::protobuf::Timestamp& timestamp) {
-    ui64 us = timestamp.seconds() * 1000000;
-    us += timestamp.nanos() / 1000;
-    return TInstant::MicroSeconds(us);
-}
-
 std::vector<TExportItemProgress> ItemsProgressFromProto(const google::protobuf::RepeatedPtrField<ExportItemProgress>& proto) {
     std::vector<TExportItemProgress> result(proto.size());
 

src/client/import/import.cpp

@@ -19,12 +19,6 @@ using namespace Ydb::Import;
 /// Common
 namespace {
 
-TInstant ProtoTimestampToInstant(const google::protobuf::Timestamp& timestamp) {
-    ui64 us = timestamp.seconds() * 1000000;
-    us += timestamp.nanos() / 1000;
-    return TInstant::MicroSeconds(us);
-}
-
 std::vector<TImportItemProgress> ItemsProgressFromProto(const google::protobuf::RepeatedPtrField<Ydb::Import::ImportItemProgress>& proto) {
     std::vector<TImportItemProgress> result;
     result.reserve(proto.size());

src/client/types/operation/operation.cpp

@@ -21,6 +21,8 @@ class TOperation::TImpl {
         : Id_(operation.id(), true /* allowEmpty */)
         , Status_(std::move(status))
         , Ready_(operation.ready())
+        , StartTime_(ProtoTimestampToInstant(operation.start_time()))
+        , EndTime_(ProtoTimestampToInstant(operation.end_time()))
         , Operation_(std::move(operation))
     {
     }
@@ -37,6 +39,14 @@ class TOperation::TImpl {
         return Status_;
     }
 
+    TInstant StartTime() const {
+        return StartTime_;
+    }
+
+    TInstant EndTime() const {
+        return EndTime_;
+    }
+
     const Ydb::Operations::Operation& GetProto() const {
         return Operation_;
     }
@@ -45,6 +55,8 @@ class TOperation::TImpl {
     const TOperationId Id_;
     const TStatus Status_;
     const bool Ready_;
+    const TInstant StartTime_;
+    const TInstant EndTime_;
     const Ydb::Operations::Operation Operation_;
 };
 
@@ -68,6 +80,14 @@ const TStatus& TOperation::Status() const {
     return Impl_->Status();
 }
 
+TInstant TOperation::StartTime() const {
+    return Impl_->StartTime();
+}
+
+TInstant TOperation::EndTime() const {
+    return Impl_->EndTime();
+}
+
 std::string TOperation::ToString() const {
     TString result;
     TStringOutput out(result);
@@ -92,4 +112,10 @@ const Ydb::Operations::Operation& TOperation::GetProto() const {
     return Impl_->GetProto();
 }
 
+TInstant ProtoTimestampToInstant(const google::protobuf::Timestamp& timestamp) {
+    ui64 us = timestamp.seconds() * 1000000;
+    us += timestamp.nanos() / 1000;
+    return TInstant::MicroSeconds(us);
+}
+
 } // namespace NYdb