Skip to content

Commit

Permalink
Fixes #23727: Group all node related access into one NodeFactRepository
Browse files Browse the repository at this point in the history
  • Loading branch information
fanf committed Nov 22, 2023
1 parent 0b251ab commit 1d93013
Show file tree
Hide file tree
Showing 128 changed files with 31,928 additions and 99,096 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -98,21 +98,9 @@ trait WriteOnlyMachineRepository[R] {
trait MachineRepository[R] extends ReadOnlyMachineRepository with WriteOnlyMachineRepository[R]

trait ReadOnlyFullInventoryRepository {

/**
* Retrieve a full ServerAndMachine.
* TODO: allows to lazy-load some heavy parts, like software, machine elements, etc.
*/
def get(id: NodeId, inventoryStatus: InventoryStatus): IOResult[Option[FullInventory]]
def get(id: NodeId): IOResult[Option[FullInventory]]
def getMachineId(id: NodeId, inventoryStatus: InventoryStatus): IOResult[Option[(MachineUuid, InventoryStatus)]]

def getAllInventories(inventoryStatus: InventoryStatus): IOResult[Map[NodeId, FullInventory]]

// get inventories for a set of nodes
def getInventories(inventoryStatus: InventoryStatus, nodeIds: Set[NodeId]): IOResult[Map[NodeId, FullInventory]]

def getAllNodeInventories(inventoryStatus: InventoryStatus): IOResult[Map[NodeId, NodeInventory]]
}

trait WriteOnlyFullInventoryRepository[R] {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -492,6 +492,8 @@ class FusionInventoryParser(
.setTo(NodeId(policyServerId))
.modify(_.node.main.id)
.setTo(NodeId(uuid))
.modify(_.machine.id.value)
.setTo(IdGenerator.md5Hash(uuid))
.modify(_.node.agents)
.setTo(agents.map(_._1.copy(capabilities = capabilities)))
.modify(_.node.customProperties)
Expand Down
Loading

0 comments on commit 1d93013

Please sign in to comment.