( ctx context.Context, req *connect.Request[v1pb.DeleteRevisionRequest], )
| 274 | } |
| 275 | |
| 276 | func (s *RevisionService) DeleteRevision( |
| 277 | ctx context.Context, |
| 278 | req *connect.Request[v1pb.DeleteRevisionRequest], |
| 279 | ) (*connect.Response[emptypb.Empty], error) { |
| 280 | request := req.Msg |
| 281 | instanceID, databaseName, revisionID, err := common.GetInstanceDatabaseRevisionID(request.Name) |
| 282 | if err != nil { |
| 283 | return nil, connect.NewError(connect.CodeInvalidArgument, errors.Wrapf(err, "failed to parse %v", request.Name)) |
| 284 | } |
| 285 | user, ok := GetUserFromContext(ctx) |
| 286 | if !ok { |
| 287 | return nil, connect.NewError(connect.CodeInternal, errors.Errorf("user not found")) |
| 288 | } |
| 289 | if err := s.store.DeleteRevision(ctx, revisionID, instanceID, databaseName, user.Email); err != nil { |
| 290 | return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to delete revision %v", request.Name)) |
| 291 | } |
| 292 | return connect.NewResponse(&emptypb.Empty{}), nil |
| 293 | } |
| 294 | |
| 295 | func convertToRevisions(parent string, projectID string, revisions []*store.RevisionMessage) []*v1pb.Revision { |
| 296 | var rs []*v1pb.Revision |
nothing calls this directly
no test coverage detected