Store resources as components on singleton entities (v2)

assets/scenes/load_scene_example.scn.ron

@@ -1,7 +1,13 @@
 (
   resources: {
-    "scene::ResourceA": (
-      score: 1,
+    4294967299: (
+      components: {
+        "bevy_ecs::resource::ResourceComponent<scene::ResourceA>": ((
+          score: 1,
+        )),
+        "bevy_ecs::resource::IsResource": (),
+        "bevy_ecs::entity_disabling::Internal": (),
+      },
     ),
   },
   entities: {

crates/bevy_ecs/macros/src/component.rs

@@ -25,9 +25,24 @@ pub fn derive_resource(input: TokenStream) -> TokenStream {
     let struct_name = &ast.ident;
     let (impl_generics, type_generics, where_clause) = &ast.generics.split_for_impl();
 
+    let map_entities_impl = map_entities(
+        &ast.data,
+        &bevy_ecs_path,
+        Ident::new("self", Span::call_site()),
+        false,
+        false,
+        None,
+    );
+
     TokenStream::from(quote! {
         impl #impl_generics #bevy_ecs_path::resource::Resource for #struct_name #type_generics #where_clause {
         }
+
+        impl #impl_generics #bevy_ecs_path::entity::MapEntities for #struct_name #type_generics #where_clause {
+            fn map_entities<MAPENT: #bevy_ecs_path::entity::EntityMapper>(&mut self, mapper: &mut MAPENT) {
+                #map_entities_impl
+            }
+        }
     })
 }
 

crates/bevy_ecs/macros/src/lib.rs

@@ -600,7 +600,7 @@ pub fn derive_message(input: TokenStream) -> TokenStream {
 }
 
 /// Implement the `Resource` trait.
-#[proc_macro_derive(Resource)]
+#[proc_macro_derive(Resource, attributes(entities))]
 pub fn derive_resource(input: TokenStream) -> TokenStream {
     component::derive_resource(input)
 }
@@ -677,7 +677,7 @@ pub fn derive_resource(input: TokenStream) -> TokenStream {
 /// #[component(hook_name = function)]
 /// struct MyComponent;
 /// ```
-/// where `hook_name` is `on_add`, `on_insert`, `on_replace` or `on_remove`;  
+/// where `hook_name` is `on_add`, `on_insert`, `on_replace` or `on_remove`;
 /// `function` can be either a path, e.g. `some_function::<Self>`,
 /// or a function call that returns a function that can be turned into
 /// a `ComponentHook`, e.g. `get_closure("Hi!")`.

crates/bevy_ecs/src/component/info.rs

@@ -20,7 +20,7 @@ use crate::{
     },
     lifecycle::ComponentHooks,
     query::DebugCheckedUnwrap as _,
-    resource::Resource,
+    resource::{Resource, ResourceComponent},
     storage::SparseSetIndex,
 };
 
@@ -290,18 +290,7 @@ impl ComponentDescriptor {
     ///
     /// The [`StorageType`] for resources is always [`StorageType::Table`].
     pub fn new_resource<T: Resource>() -> Self {
-        Self {
-            name: DebugName::type_name::<T>(),
-            // PERF: `SparseStorage` may actually be a more
-            // reasonable choice as `storage_type` for resources.
-            storage_type: StorageType::Table,
-            is_send_and_sync: true,
-            type_id: Some(TypeId::of::<T>()),
-            layout: Layout::new::<T>(),
-            drop: needs_drop::<T>().then_some(Self::drop_ptr::<T> as _),
-            mutable: true,
-            clone_behavior: ComponentCloneBehavior::Default,
-        }
+        Self::new::<ResourceComponent<T>>()
     }
 
     pub(super) fn new_non_send<T: Any>(storage_type: StorageType) -> Self {
@@ -348,7 +337,6 @@ impl ComponentDescriptor {
 pub struct Components {
     pub(super) components: Vec<Option<ComponentInfo>>,
     pub(super) indices: TypeIdMap<ComponentId>,
-    pub(super) resource_indices: TypeIdMap<ComponentId>,
     // This is kept internal and local to verify that no deadlocks can occor.
     pub(super) queued: bevy_platform::sync::RwLock<QueuedComponents>,
 }
@@ -587,8 +575,12 @@ impl Components {
 
     /// Type-erased equivalent of [`Components::valid_resource_id()`].
     #[inline]
+    #[deprecated(
+        since = "0.18.0",
+        note = "Use valid_resource_id::<R>() or get_valid_id(TypeId::of::<ResourceComponent<R>>()) for normal resources. Use get_valid_id(TypeId::of::<R>()) for non-send resources."
+    )]
     pub fn get_valid_resource_id(&self, type_id: TypeId) -> Option<ComponentId> {
-        self.resource_indices.get(&type_id).copied()
+        self.indices.get(&type_id).copied()
     }
 
     /// Returns the [`ComponentId`] of the given [`Resource`] type `T` if it is fully registered.
@@ -613,7 +605,7 @@ impl Components {
     /// * [`Components::get_resource_id()`]
     #[inline]
     pub fn valid_resource_id<T: Resource>(&self) -> Option<ComponentId> {
-        self.get_valid_resource_id(TypeId::of::<T>())
+        self.get_valid_id(TypeId::of::<ResourceComponent<T>>())
     }
 
     /// Type-erased equivalent of [`Components::component_id()`].
@@ -665,15 +657,12 @@ impl Components {
 
     /// Type-erased equivalent of [`Components::resource_id()`].
     #[inline]
+    #[deprecated(
+        since = "0.18.0",
+        note = "Use resource_id::<R>() or get_id(TypeId::of::<ResourceComponent<R>>()) instead for normal resources. Use get_id(TypeId::of::<R>()) for non-send resources."
+    )]
     pub fn get_resource_id(&self, type_id: TypeId) -> Option<ComponentId> {
-        self.resource_indices.get(&type_id).copied().or_else(|| {
-            self.queued
-                .read()
-                .unwrap_or_else(PoisonError::into_inner)
-                .resources
-                .get(&type_id)
-                .map(|queued| queued.id)
-        })
+        self.get_id(type_id)
     }
 
     /// Returns the [`ComponentId`] of the given [`Resource`] type `T`.
@@ -705,7 +694,7 @@ impl Components {
     /// * [`Components::get_resource_id()`]
     #[inline]
     pub fn resource_id<T: Resource>(&self) -> Option<ComponentId> {
-        self.get_resource_id(TypeId::of::<T>())
+        self.get_id(TypeId::of::<ResourceComponent<T>>())
     }
 
     /// # Safety
@@ -724,7 +713,7 @@ impl Components {
         unsafe {
             self.register_component_inner(component_id, descriptor);
         }
-        let prev = self.resource_indices.insert(type_id, component_id);
+        let prev = self.indices.insert(type_id, component_id);
         debug_assert!(prev.is_none());
     }
 

crates/bevy_ecs/src/component/register.rs

@@ -10,7 +10,7 @@ use crate::{
         Component, ComponentDescriptor, ComponentId, Components, RequiredComponents, StorageType,
     },
     query::DebugCheckedUnwrap as _,
-    resource::Resource,
+    resource::{IsResource, Resource, ResourceComponent},
 };
 
 /// Generates [`ComponentId`]s.
@@ -289,12 +289,7 @@ impl<'w> ComponentsRegistrator<'w> {
     /// * [`ComponentsRegistrator::register_resource_with_descriptor()`]
     #[inline]
     pub fn register_resource<T: Resource>(&mut self) -> ComponentId {
-        // SAFETY: The [`ComponentDescriptor`] matches the [`TypeId`]
-        unsafe {
-            self.register_resource_with(TypeId::of::<T>(), || {
-                ComponentDescriptor::new_resource::<T>()
-            })
-        }
+        self.register_component::<ResourceComponent<T>>()
     }
 
     /// Registers a [non-send resource](crate::system::NonSend) of type `T` with this instance.
@@ -310,6 +305,37 @@ impl<'w> ComponentsRegistrator<'w> {
         }
     }
 
+    // Adds the necessary resource hooks and required components.
+    // This ensures that a resource registered with a custom descriptor functions as expected.
+    // Panics if the component is not registered.
+    // This has no effect on non-send resources.
+    fn add_resource_hooks_and_required_components(&mut self, id: ComponentId) {
+        if self
+            .get_info(id)
+            .expect("component was just registered")
+            .is_send_and_sync()
+        {
+            let hooks = self
+                .components
+                .get_hooks_mut(id)
+                .expect("component was just registered");
+            hooks.on_add(crate::resource::on_add_hook);
+            hooks.on_remove(crate::resource::on_remove_hook);
+
+            let is_resource_id = self.register_component::<IsResource>();
+            // SAFETY:
+            // - The IsResource component id matches
+            // - The constructor constructs an IsResource
+            unsafe {
+                let _ = self.components.register_required_components::<IsResource>(
+                    id,
+                    is_resource_id,
+                    || IsResource,
+                );
+            }
+        }
+    }
+
     /// Same as [`Components::register_resource_unchecked`] but handles safety.
     ///
     /// # Safety
@@ -321,7 +347,7 @@ impl<'w> ComponentsRegistrator<'w> {
         type_id: TypeId,
         descriptor: impl FnOnce() -> ComponentDescriptor,
     ) -> ComponentId {
-        if let Some(id) = self.resource_indices.get(&type_id) {
+        if let Some(id) = self.indices.get(&type_id) {
             return *id;
         }
 
@@ -344,6 +370,10 @@ impl<'w> ComponentsRegistrator<'w> {
             self.components
                 .register_resource_unchecked(type_id, id, descriptor());
         }
+
+        // registering a resource with this method leaves hooks and required_components empty, so we add them afterwards
+        self.add_resource_hooks_and_required_components(id);
+
         id
     }
 
@@ -368,6 +398,10 @@ impl<'w> ComponentsRegistrator<'w> {
         unsafe {
             self.components.register_component_inner(id, descriptor);
         }
+
+        // registering a resource with this method leaves hooks and required_components empty, so we add them afterwards
+        self.add_resource_hooks_and_required_components(id);
+
         id
     }
 
@@ -619,26 +653,7 @@ impl<'w> ComponentsQueuedRegistrator<'w> {
     /// See type level docs for details.
     #[inline]
     pub fn queue_register_resource<T: Resource>(&self) -> ComponentId {
-        let type_id = TypeId::of::<T>();
-        self.get_resource_id(type_id).unwrap_or_else(|| {
-            // SAFETY: We just checked that this type was not already registered.
-            unsafe {
-                self.register_arbitrary_resource(
-                    type_id,
-                    ComponentDescriptor::new_resource::<T>(),
-                    move |registrator, id, descriptor| {
-                        // SAFETY: We just checked that this is not currently registered or queued, and if it was registered since, this would have been dropped from the queue.
-                        // SAFETY: Id uniqueness handled by caller, and the type_id matches descriptor.
-                        #[expect(unused_unsafe, reason = "More precise to specify.")]
-                        unsafe {
-                            registrator
-                                .components
-                                .register_resource_unchecked(type_id, id, descriptor);
-                        }
-                    },
-                )
-            }
-        })
+        self.queue_register_component::<ResourceComponent<T>>()
     }
 
     /// This is a queued version of [`ComponentsRegistrator::register_non_send`].
@@ -654,7 +669,7 @@ impl<'w> ComponentsQueuedRegistrator<'w> {
     #[inline]
     pub fn queue_register_non_send<T: Any>(&self) -> ComponentId {
         let type_id = TypeId::of::<T>();
-        self.get_resource_id(type_id).unwrap_or_else(|| {
+        self.get_id(type_id).unwrap_or_else(|| {
             // SAFETY: We just checked that this type was not already registered.
             unsafe {
                 self.register_arbitrary_resource(
@@ -695,6 +710,9 @@ impl<'w> ComponentsQueuedRegistrator<'w> {
                     .components
                     .register_component_inner(id, descriptor);
             }
+
+            // registering a resource with this method leaves hooks and required_components empty, so we add them afterwards
+            registrator.add_resource_hooks_and_required_components(id);
         })
     }
 }

crates/bevy_ecs/src/lib.rs

@@ -1236,7 +1236,7 @@ mod tests {
 
     #[test]
     fn resource() {
-        use crate::resource::Resource;
+        use crate::resource::{Resource, ResourceComponent};
 
         #[derive(Resource, PartialEq, Debug)]
         struct Num(i32);
@@ -1253,7 +1253,7 @@ mod tests {
         world.insert_resource(Num(123));
         let resource_id = world
             .components()
-            .get_resource_id(TypeId::of::<Num>())
+            .get_id(TypeId::of::<ResourceComponent<Num>>())
             .unwrap();
 
         assert_eq!(world.resource::<Num>().0, 123);
@@ -1310,7 +1310,7 @@ mod tests {
 
         let current_resource_id = world
             .components()
-            .get_resource_id(TypeId::of::<Num>())
+            .get_id(TypeId::of::<ResourceComponent<Num>>())
             .unwrap();
         assert_eq!(
             resource_id, current_resource_id,
@@ -1794,7 +1794,7 @@ mod tests {
     fn try_insert_batch() {
         let mut world = World::default();
         let e0 = world.spawn(A(0)).id();
-        let e1 = Entity::from_raw_u32(1).unwrap();
+        let e1 = Entity::from_raw_u32(10_000).unwrap();
 
         let values = vec![(e0, (A(1), B(0))), (e1, (A(0), B(1)))];
 
@@ -1818,7 +1818,7 @@ mod tests {
     fn try_insert_batch_if_new() {
         let mut world = World::default();
         let e0 = world.spawn(A(0)).id();
-        let e1 = Entity::from_raw_u32(1).unwrap();
+        let e1 = Entity::from_raw_u32(10_000).unwrap();
 
         let values = vec![(e0, (A(1), B(0))), (e1, (A(0), B(1)))];
 

crates/bevy_ecs/src/name.rs

@@ -278,7 +278,7 @@ mod tests {
         let mut query = world.query::<NameOrEntity>();
         let d1 = query.get(&world, e1).unwrap();
         // NameOrEntity Display for entities without a Name should be {index}v{generation}
-        assert_eq!(d1.to_string(), "0v0");
+        assert_eq!(d1.to_string(), "1v0");
         let d2 = query.get(&world, e2).unwrap();
         // NameOrEntity Display for entities with a Name should be the Name
         assert_eq!(d2.to_string(), "MyName");