Method BatchCreateRevisions

backend/api/v1/revision_service.go:127–165

(
	ctx context.Context,
	req *connect.Request[v1pb.BatchCreateRevisionsRequest],
)

}

func (s *RevisionService) BatchCreateRevisions(
	ctx context.Context,
	req *connect.Request[v1pb.BatchCreateRevisionsRequest],
) (*connect.Response[v1pb.BatchCreateRevisionsResponse], error) {
	request := req.Msg
	instanceID, databaseName, err := common.GetInstanceDatabaseID(request.Parent)
	if err != nil {
		return nil, connect.NewError(connect.CodeInvalidArgument, errors.Wrapf(err, "failed to parse %q", request.Parent))
	}
	database, err := s.store.GetDatabase(ctx, &store.FindDatabaseMessage{
		Workspace:    common.GetWorkspaceIDFromContext(ctx),
		InstanceID:   &instanceID,
		DatabaseName: &databaseName,
	})
	if err != nil {
		return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to get database"))
	}
	if database == nil {
		return nil, connect.NewError(connect.CodeNotFound, errors.Errorf("database %v not found", request.Parent))
	}

	var revisions []*v1pb.Revision
	for _, r := range request.Requests {
		// Validate parent matches
		if r.Parent != request.Parent {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("request parent %q does not match batch parent %q", r.Parent, request.Parent))
		}
		revisions = append(revisions, r.Revision)
	}

	createdRevisions, err := s.createRevisions(ctx, request.Parent, revisions, database)
	if err != nil {
		return nil, err
	}

	return connect.NewResponse(&v1pb.BatchCreateRevisionsResponse{
		Revisions: createdRevisions,
	}), nil
}

func (s *RevisionService) createRevisions(
	ctx context.Context,