Add live find-slot with use_live_data flag

When use_live_data is true, compute find-slot using the cached resource
summary for capacity data and live orchestrator DB reservations for
allocation data instead of proxying to the Reports API.

- Add use_live_data boolean to find-slot swagger spec
- Add _find_slot_live() with sliding window search in orchestrator_handler
- Add get_link_allocations() and get_component_allocations() DB methods
  through the full management actor chain for lightweight reservation queries

Author: kthare10

fabric_cf/actor/core/apis/abc_actor_management_object.py

@@ -294,6 +294,20 @@ def get_links(self, *, node_id: str, rsv_type: list[str], states: list[int], sta
         @return Dictionary with link node id as key and cumulative bandwidth.
         """
 
+    def get_link_allocations(self, *, rsv_type: list[str], states: list[int],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation link allocation data with lease times.
+        @return list of dicts with keys: link_node_id, bw, lease_start, lease_end, site
+        """
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation component allocation data with lease times and host info.
+        @return list of dicts with keys: host, site, lease_start, lease_end, component, bdf
+        """
+
     def get_slices(self, *, slice_id: ID, caller: AuthToken, slice_name: str = None, email: str = None,
                    states: List[int] = None, project: str = None, limit: int = None,
                    offset: int = None, user_id: str = None, search: str = None,

fabric_cf/actor/core/apis/abc_database.py

@@ -205,6 +205,29 @@ def get_links(self, *, node_id: str, states: list[int], rsv_type: list[str], sta
         @return Dictionary with link node id as the key and value cumulative bw.
         """
 
+    @abstractmethod
+    def get_link_allocations(self, *, states: list[int], rsv_type: list[str],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation link allocation data with lease times.
+        @param states: list of reservation states to include
+        @param rsv_type: list of reservation types (ServiceType strings)
+        @param start: start of time range
+        @param end: end of time range
+        @return list of dicts with keys: link_node_id, bw, lease_start, lease_end, site
+        """
+
+    @abstractmethod
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation component allocation data with lease times and host info.
+        @param states: list of reservation states to include
+        @param start: start of time range
+        @param end: end of time range
+        @return list of dicts with keys: host, site, lease_start, lease_end, component, bdf
+        """
+
     @abstractmethod
     def get_client_reservations(self, *, slice_id: ID = None) -> List[ABCReservationMixin]:
         """

fabric_cf/actor/core/apis/abc_mgmt_actor.py

@@ -208,6 +208,22 @@ def get_links(self, *, node_id: str, rsv_type: list[str], states: list[int], sta
         """
         raise NotImplementedError
 
+    def get_link_allocations(self, *, rsv_type: list[str], states: list[int],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation link allocation data with lease times.
+        @return list of dicts with keys: link_node_id, bw, lease_start, lease_end, site
+        """
+        raise NotImplementedError
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation component allocation data with lease times and host info.
+        @return list of dicts with keys: host, site, lease_start, lease_end, component, bdf
+        """
+        raise NotImplementedError
+
     @abstractmethod
     def get_sites(self, *, site: str) -> List[SiteAvro] or None:
         """

fabric_cf/actor/core/manage/actor_management_object.py

@@ -441,6 +441,14 @@ def get_links(self, *, node_id: str, rsv_type: list[str], states: list[int], sta
         return self.db.get_links(node_id=node_id, rsv_type=rsv_type, states=states, start=start,
                                  end=end, excludes=excludes)
 
+    def get_link_allocations(self, *, rsv_type: list[str], states: list[int],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        return self.db.get_link_allocations(states=states, rsv_type=rsv_type, start=start, end=end)
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        return self.db.get_component_allocations(states=states, start=start, end=end)
+
     def get_reservations(self, *, caller: AuthToken, states: List[int] = None,
                          slice_id: ID = None, rid: ID = None, oidc_claim_sub: str = None,
                          email: str = None, rid_list: List[str] = None, type: str = None,

fabric_cf/actor/core/manage/local/local_actor.py

@@ -145,6 +145,23 @@ def get_links(self, *, node_id: str, rsv_type: list[str], states: list[int], sta
         except Exception as e:
             self.on_exception(e=e, traceback_str=traceback.format_exc())
 
+    def get_link_allocations(self, *, rsv_type: list[str], states: list[int],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        try:
+            return self.manager.get_link_allocations(rsv_type=rsv_type, states=states,
+                                                     start=start, end=end)
+        except Exception as e:
+            self.on_exception(e=e, traceback_str=traceback.format_exc())
+        return []
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        try:
+            return self.manager.get_component_allocations(states=states, start=start, end=end)
+        except Exception as e:
+            self.on_exception(e=e, traceback_str=traceback.format_exc())
+        return []
+
     def get_sites(self, *, site: str) -> List[SiteAvro] or None:
         self.clear_last()
         try:

fabric_cf/actor/core/plugins/db/actor_database.py

@@ -631,6 +631,28 @@ def get_links(self, *, node_id: str, states: list[int], rsv_type: list[str], sta
             if self.lock.locked():
                 self.lock.release()
 
+    def get_link_allocations(self, *, states: list[int], rsv_type: list[str],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        try:
+            return self.db.get_link_allocations(states=states, rsv_type=rsv_type, start=start, end=end)
+        except Exception as e:
+            self.logger.error(e)
+        finally:
+            if self.lock.locked():
+                self.lock.release()
+        return []
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        try:
+            return self.db.get_component_allocations(states=states, start=start, end=end)
+        except Exception as e:
+            self.logger.error(e)
+        finally:
+            if self.lock.locked():
+                self.lock.release()
+        return []
+
     def get_reservations(self, *, slice_id: ID = None, graph_node_id: str = None, project_id: str = None,
                          email: str = None, oidc_sub: str = None, rid: ID = None, states: list[int] = None,
                          site: str = None, rsv_type: list[str] = None, start: datetime = None,

fabric_cf/actor/db/psql_database.py

@@ -1050,6 +1050,122 @@ def get_links(self, *, node_id: str, states: list[int], rsv_type: list[str],
             raise e
         return result
 
+    def get_link_allocations(self, *, states: list[int], rsv_type: list[str],
+                             start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation link allocation data with lease times.
+
+        Each dict contains: link_node_id, bw, lease_start, lease_end.
+        This avoids deserializing full slivers for network service reservations.
+
+        @param states: list of reservation states to include
+        @param rsv_type: list of reservation types (ServiceType strings)
+        @param start: start of time range
+        @param end: end of time range
+        @return list of dicts with link allocation data
+        """
+        result = []
+        session = self.get_session()
+        try:
+            lease_end_filter = True
+            if start is not None or end is not None:
+                if start is not None and end is not None:
+                    lease_end_filter = or_(
+                        and_(start <= Reservations.lease_end, Reservations.lease_end <= end),
+                        and_(start <= Reservations.lease_start, Reservations.lease_start <= end),
+                        and_(Reservations.lease_start <= start, Reservations.lease_end >= end)
+                    )
+                elif start is not None:
+                    lease_end_filter = start <= Reservations.lease_end
+                elif end is not None:
+                    lease_end_filter = Reservations.lease_end <= end
+
+            rows = (
+                session.query(
+                    Links.node_id,
+                    Links.bw,
+                    Reservations.lease_start,
+                    Reservations.lease_end,
+                    Reservations.site,
+                )
+                .join(Reservations, Links.reservation_id == Reservations.rsv_id)
+                .filter(Reservations.rsv_type.in_(rsv_type))
+                .filter(Reservations.rsv_state.in_(states))
+                .filter(lease_end_filter)
+                .all()
+            )
+
+            for row in rows:
+                result.append({
+                    "link_node_id": row[0],
+                    "bw": row[1] or 0,
+                    "lease_start": row[2],
+                    "lease_end": row[3],
+                    "site": row[4],
+                })
+        except Exception as e:
+            self.logger.error(Constants.EXCEPTION_OCCURRED.format(e))
+            raise e
+        return result
+
+    def get_component_allocations(self, *, states: list[int],
+                                  start: datetime = None, end: datetime = None) -> list[dict]:
+        """
+        Return per-reservation component allocation data with lease times and host info.
+
+        Each dict contains: host, site, lease_start, lease_end, component (name), bdf.
+        This avoids deserializing full slivers for component counting.
+
+        @param states: list of reservation states to include
+        @param start: start of time range
+        @param end: end of time range
+        @return list of dicts with component allocation data
+        """
+        result = []
+        session = self.get_session()
+        try:
+            lease_end_filter = True
+            if start is not None or end is not None:
+                if start is not None and end is not None:
+                    lease_end_filter = or_(
+                        and_(start <= Reservations.lease_end, Reservations.lease_end <= end),
+                        and_(start <= Reservations.lease_start, Reservations.lease_start <= end),
+                        and_(Reservations.lease_start <= start, Reservations.lease_end >= end)
+                    )
+                elif start is not None:
+                    lease_end_filter = start <= Reservations.lease_end
+                elif end is not None:
+                    lease_end_filter = Reservations.lease_end <= end
+
+            rows = (
+                session.query(
+                    Reservations.host,
+                    Reservations.site,
+                    Reservations.lease_start,
+                    Reservations.lease_end,
+                    Components.component,
+                    Components.bdf,
+                )
+                .join(Components, Components.reservation_id == Reservations.rsv_id)
+                .filter(Reservations.rsv_state.in_(states))
+                .filter(lease_end_filter)
+                .all()
+            )
+
+            for row in rows:
+                result.append({
+                    "host": row[0],
+                    "site": row[1],
+                    "lease_start": row[2],
+                    "lease_end": row[3],
+                    "component": row[4],
+                    "bdf": row[5],
+                })
+        except Exception as e:
+            self.logger.error(Constants.EXCEPTION_OCCURRED.format(e))
+            raise e
+        return result
+
     def get_reservations_by_rids(self, *, rsv_resid_list: list) -> list:
         """
         Get Reservations for an actor by reservation ids