feat: implement GetOperation (#38)

cmd/ydbcp/main.go

@@ -422,8 +422,37 @@ func (s *server) CancelOperation(ctx context.Context, request *pb.CancelOperatio
 }
 
 func (s *server) GetOperation(ctx context.Context, request *pb.GetOperationRequest) (*pb.Operation, error) {
-	//TODO implement me
-	panic("implement me")
+	xlog.Debug(ctx, "GetOperation", zap.String("request", request.String()))
+	requestId, err := types.ParseObjectId(request.GetId())
+	if err != nil {
+		return nil, fmt.Errorf("failed to parse uuid %s: %w", request.GetId(), err)
+	}
+	operations, err := s.driver.SelectOperations(
+		ctx, queries.NewReadTableQuery(
+			queries.WithTableName("Operations"),
+			queries.WithSelectFields(queries.AllOperationFields...),
+			queries.WithQueryFilters(
+				queries.QueryFilter{
+					Field:  "id",
+					Values: []table_types.Value{table_types.UUIDValue(requestId)},
+				},
+			),
+		),
+	)
+	if err != nil {
+		xlog.Error(ctx, "can't select operations", zap.Error(err))
+		return nil, err
+	}
+	if len(operations) == 0 {
+		return nil, errors.New("no operation with such Id") // TODO: Permission denied?
+	}
+	// TODO: Need to check access to operation resource by operationID
+	if _, err := s.checkAuth(ctx, auth.PermissionBackupGet, operations[0].GetContainerId(), ""); err != nil {
+		return nil, err
+	}
+
+	xlog.Debug(ctx, "GetOperation", zap.String("operation", types.OperationToString(operations[0])))
+	return operations[0].Proto(), nil
 }
 
 func main() {

internal/types/backup.go

@@ -104,6 +104,7 @@ type OperationState string
 type Operation interface {
 	GetId() ObjectID
 	SetId(id ObjectID)
+	GetContainerId() string
 	GetType() OperationType
 	SetType(t OperationType)
 	GetState() OperationState
@@ -132,6 +133,9 @@ func (o *TakeBackupOperation) GetId() ObjectID {
 func (o *TakeBackupOperation) SetId(id ObjectID) {
 	o.Id = id
 }
+func (o *TakeBackupOperation) GetContainerId() string {
+	return o.ContainerID
+}
 func (o *TakeBackupOperation) GetType() OperationType {
 	return OperationTypeTB
 }
@@ -186,6 +190,9 @@ func (o *RestoreBackupOperation) GetId() ObjectID {
 func (o *RestoreBackupOperation) SetId(id ObjectID) {
 	o.Id = id
 }
+func (o *RestoreBackupOperation) GetContainerId() string {
+	return o.ContainerID
+}
 func (o *RestoreBackupOperation) GetType() OperationType {
 	return OperationTypeRB
 }
@@ -240,6 +247,9 @@ func (o *GenericOperation) GetId() ObjectID {
 func (o *GenericOperation) SetId(id ObjectID) {
 	o.Id = id
 }
+func (o *GenericOperation) GetContainerId() string {
+	return o.ContainerID
+}
 func (o *GenericOperation) GetType() OperationType {
 	return o.Type
 }

pkg/proto/ydbcp/v1alpha1/operation_service.proto

@@ -40,5 +40,5 @@ message CancelOperationRequest {
 }
 
 message GetOperationRequest {
-    string operation_id = 1;
+    string id = 1;
 }