Arquitectura P2P

El contrato P2P define nombres, topics y rutas compartidas entre máquina y ruta.

Archivo principal:

• Contract/src/main/java/co/ada/contract/P2PContract.kt

• P2PContract.Names.MACHINE_NAME = “MACHINE-”
• P2PContract.Names.OPERATOR_NAME = “OPERATOR-”

• P2PContract.Topics.MACHINE_STATE = “p2p.machine.state”

• MACHINE_WEIGHT = “/p2p/machine/weight”
• MACHINE_CONFIGURATION = “/p2p/machine/configuration”
• DELIVERIES_PAGE(page, size) = “/p2p/machine/deliveries/$page/$size”
• DELIVERY(id) = “/p2p/machine/delivery/$id”
• DELIVERY_SYNCHRONIZED(id) = “/p2p/machine/delivery/synchronized/$id”

Archivo principal:

• Contract/src/main/java/co/ada/contract/P2PModels.kt

• P2PMachineState
  • id, name, unsyncedDeliveries, machineStatus, stateName, shiftName, etc.
• P2PWeight
  • weight para actualización de peso.
• P2PDeliveriesPageResponse
  • lista de deliveryIds y metadatos de paginación.
• P2PDeliveryData
  • detalle completo de una entrega.
• P2PDeliveryDeletionResponse
  • respuesta de confirmación de eliminación.
• P2PMachineConfiguration
  • parámetros de la máquina: umbrales, debug, tiempos.
• P2PMachineConfigurationUpdateRequest / Response
  • payload para la actualización de configuración.

Archivo principal:

• Contract/src/main/java/co/ada/contract/P2PGestor.kt

Responsabilidades:

• inicializar DirectConnection.
• establecer el nombre local de peer.
• habilitar auto-conexión.
• exponer peers, machines y operators.
• recoger eventos de descubrimiento.

• machines: peers que comienzan con MACHINE-.
• operators: peers que comienzan con OPERATOR-.

Archivo principal:

• RutaPAEDomain/src/main/java/co/ada/rutapaedomain/p2p/P2PManager.kt

• start(): arranca el P2P, consolida alias de máquinas y suscribe a eventos.
• close(): detiene el gestor y cancela jobs.
• discoverableMachineIds(): IDs locales de máquinas detectables.
• discoveredMachineCandidates(): máquinas detectadas sin registro local.
• discoveredMachineHotspots(): hotspots de máquina disponibles.
• connectMachine(machineDatabaseId): conecta a una máquina conocida.
• connectDiscoveredMachine(address): conecta a un peer descubierto.
• connectMachineHotspot(ssid): une y resuelve un hotspot de máquina.
• getMachineConfiguration(machineDatabaseId): obtiene configuración desde la máquina.
• updateMachineConfiguration(…): actualiza parámetros de configuración.
• notifyDeliverySynchronized(…): marca una entrega remota como sincronizada.
• syncDeliveriesFromMachine(machineDatabaseId): descarga entregas remotas desde la máquina.

• P2PManager extrae IDs de peer basándose en prefijos MACHINE-.
• Aplica normalización de IDs temporales (tmp-…) y IDs oficiales.
• Cuando el dispositivo reporta un P2PMachineState.id oficial, reconcilia alias temporales.

• DirectConnection.connect(peer): conecta con un peer ya descubierto.
• DirectConnection.connectHotspot(hotspot): une a un hotspot reportado por la máquina.

Si el hotspot no puede unirse automáticamente, la app busca un peer descubierto que represente la misma máquina y lo usa como respaldo.