Method BatchGetDatabases

backend/api/v1/database_service.go:77–132

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

}

func (s *DatabaseService) BatchGetDatabases(ctx context.Context, req *connect.Request[v1pb.BatchGetDatabasesRequest]) (*connect.Response[v1pb.BatchGetDatabasesResponse], error) {
	user, ok := GetUserFromContext(ctx)
	if !ok {
		return nil, connect.NewError(connect.CodeInternal, errors.Errorf("user not found"))
	}

	// Parse parent to extract project ID filter if specified.
	var projectIDFilter *string
	if strings.HasPrefix(req.Msg.Parent, common.ProjectNamePrefix) {
		projectID, err := common.GetProjectID(req.Msg.Parent)
		if err != nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Errorf("invalid parent %q", req.Msg.Parent))
		}
		projectIDFilter = new(projectID)
	}
	// For instances/{instance} or "-" (wildcard), no project filter is applied.
	databases := make([]*v1pb.Database, 0, len(req.Msg.Names))
	for _, name := range req.Msg.Names {
		instanceID, databaseName, err := common.GetInstanceDatabaseID(name)
		if err != nil {
			return nil, connect.NewError(connect.CodeInvalidArgument, errors.Wrapf(err, "failed to parse %q", name))
		}
		databaseMessage, err := s.store.GetDatabase(ctx, &store.FindDatabaseMessage{
			Workspace:    common.GetWorkspaceIDFromContext(ctx),
			InstanceID:   &instanceID,
			DatabaseName: &databaseName,
			ShowDeleted:  true,
		})
		if err != nil {
			return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to get database"))
		}
		if databaseMessage == nil {
			// Ignore deleted database.
			continue
		}
		// If parent specifies a project, validate database belongs to that project.
		if projectIDFilter != nil && databaseMessage.ProjectID != *projectIDFilter {
			// Ignore database not in the specified project.
			continue
		}
		ok, err := s.iamManager.CheckPermission(ctx, permission.DatabasesGet, user, common.GetWorkspaceIDFromContext(ctx), databaseMessage.ProjectID)
		if err != nil {
			return nil, connect.NewError(connect.CodeInternal, errors.Errorf("failed to check permission with error: %v", err.Error()))
		}
		if !ok {
			// Ignore no permission database.
			continue
		}
		database, err := s.convertToDatabase(ctx, databaseMessage)
		if err != nil {
			return nil, connect.NewError(connect.CodeInternal, errors.Wrapf(err, "failed to convert database"))
		}
		databases = append(databases, database)
	}
	return connect.NewResponse(&v1pb.BatchGetDatabasesResponse{Databases: databases}), nil
}

func getVariableAndValueFromExpr(expr celast.Expr) (string, any) {