Phase 64: managed timer fulfillment vertical

Makefile

@@ -32,16 +32,42 @@ include mk/phase62-idle-runtime-acceptance.mk
 include mk/phase62-retention-runtime-acceptance.mk
 include mk/phase63-runtime-acceptance.mk
 include mk/agent-tests.mk
+include mk/phase64-backend-agent-command-reservation-tests.mk
+include mk/phase64-native-timer-create-agent-contract-tests.mk
+include mk/phase64-native-timer-create-reservation-tests.mk
+include mk/phase64-native-timer-create-dispatch-state-tests.mk
+include mk/phase64-native-timer-create-outcome-completion-tests.mk
+include mk/phase64-native-timer-create-delivery-tests.mk
+include mk/phase64-native-timer-create-activation-tests.mk
+include mk/phase64-native-timer-create-local-state-tests.mk
+include mk/phase64-native-timer-create-executor-tests.mk
+include mk/phase64-suitebridge-native-timer-create-transport-tests.mk
+include mk/phase64-suitebridge-native-timer-create-command-service-tests.mk
+include mk/phase64-suitebridge-native-timer-create-real-mutation-tests.mk
+include mk/phase64-suitebridge-native-timer-command-path-wiring-tests.mk
 include mk/phase63-local-provider-tests.mk
 include mk/phase64-timer-intent-tests.mk
+include mk/phase64-timer-intent-application-tests.mk
+include mk/phase64-timer-assignment-fulfillment-tests.mk
+include mk/phase64-native-timer-specification-tests.mk
+include mk/phase64-vdr-timer-managed-correlation-tests.mk
+include mk/phase64-vdr-managed-timer-create-request-tests.mk
 include mk/phase64-native-timer-readback-expectation-tests.mk
+include mk/phase64-native-timer-create-readback-expectation-tests.mk
+include mk/phase64-native-timer-create-readback-evidence-tests.mk
+include mk/phase64-vdr-managed-timer-create-readback-evidence-tests.mk
+include mk/phase64-native-timer-create-readback-verification-tests.mk
 include mk/phase64-native-timer-present-readback-verification-tests.mk
 include mk/phase64-native-timer-inventory-evidence-tests.mk
 include mk/phase64-restfulapi-native-timer-inventory-reader-tests.mk
 include mk/phase64-native-timer-binding-absence-application-tests.mk
 include mk/phase64-native-timer-absence-readback-expectation-tests.mk
 include mk/phase64-native-timer-absence-readback-verification-tests.mk
 include mk/phase64-mutation-operation-repository-tests.mk
+include mk/phase64-native-timer-create-operation-preparation-tests.mk
+include mk/phase64-native-timer-modify-operation-tests.mk
+include mk/phase64-native-timer-modify-dispatch-tests.mk
+include mk/phase64-managed-timer-fulfillment-acceptance.mk
 include mk/phase64-native-timer-delete-operation-completion-tests.mk
 include mk/phase64-native-timer-delete-operation-preparation-tests.mk
 include mk/phase64-native-timer-delete-dispatch-tests.mk

apps/agent/main.cpp

@@ -1,5 +1,8 @@
 #include "BackendAgentClient.h"
 #include "BackendAgentCommandClient.h"
+#include "SuiteBridgeNativeTimerCreateTransport.h"
+#include "SuiteBridgeNativeTimerDeleteTransport.h"
+#include "SuiteBridgeNativeTimerModifyTransport.h"
 #include "SuiteBridgeSvdrpTransport.h"
 
 #include <algorithm>
@@ -120,6 +123,34 @@ int main(int argc, char** argv)
         return 78;
     }
 
+    std::unique_ptr<vdrsuite::agent::SuiteBridgeNativeTimerCreateTransport>
+        nativeTimerCreateTransport;
+    std::unique_ptr<vdrsuite::agent::SuiteBridgeNativeTimerDeleteTransport>
+        nativeTimerDeleteTransport;
+    std::unique_ptr<vdrsuite::agent::SuiteBridgeNativeTimerModifyTransport>
+        nativeTimerModifyTransport;
+    if (!config.suiteBridgeHost.empty())
+    {
+        vdrsuite::agent::SuiteBridgeSvdrpTransportConfig timerTransportConfig;
+        timerTransportConfig.host = config.suiteBridgeHost;
+        timerTransportConfig.port = config.suiteBridgePort;
+        nativeTimerCreateTransport = std::make_unique<
+            vdrsuite::agent::SuiteBridgeNativeTimerCreateTransport>(
+                timerTransportConfig);
+        nativeTimerDeleteTransport = std::make_unique<
+            vdrsuite::agent::SuiteBridgeNativeTimerDeleteTransport>(
+                timerTransportConfig);
+        nativeTimerModifyTransport = std::make_unique<
+            vdrsuite::agent::SuiteBridgeNativeTimerModifyTransport>(
+                timerTransportConfig);
+        config.nativeTimerCreateTransport =
+            nativeTimerCreateTransport.get();
+        config.nativeTimerDeleteTransport =
+            nativeTimerDeleteTransport.get();
+        config.nativeTimerModifyTransport =
+            nativeTimerModifyTransport.get();
+    }
+
     std::unique_ptr<vdrsuite::agent::SuiteBridgeSvdrpTransport> nativeTransport;
     if (nativeProbe)
     {

core/agent/include/BackendAgentClient.h

@@ -6,6 +6,13 @@
 #include <string>
 #include <vector>
 
+namespace vdrsuite::agent
+{
+class IBackendAgentNativeTimerCreateTransport;
+class IBackendAgentNativeTimerDeleteTransport;
+class IBackendAgentNativeTimerModifyTransport;
+}
+
 struct BackendAgentClientConfig
 {
     std::string controlPlaneUrl;
@@ -19,6 +26,14 @@ struct BackendAgentClientConfig
     std::vector<std::string> adapters;
     std::vector<std::string> observationDomains = {"backend-health"};
     std::vector<std::string> commandTypes;
+    std::string suiteBridgeHost;
+    int suiteBridgePort = 0;
+    vdrsuite::agent::IBackendAgentNativeTimerCreateTransport*
+        nativeTimerCreateTransport = nullptr;
+    vdrsuite::agent::IBackendAgentNativeTimerDeleteTransport*
+        nativeTimerDeleteTransport = nullptr;
+    vdrsuite::agent::IBackendAgentNativeTimerModifyTransport*
+        nativeTimerModifyTransport = nullptr;
     int heartbeatIntervalSeconds = 30;
     int reconnectInitialSeconds = 1;
     int reconnectMaximumSeconds = 30;

core/agent/include/BackendAgentCommandClient.h

@@ -11,6 +11,8 @@ namespace vdrsuite::agent
 {
 class IBackendAgentNativeProbeTransport;
 class IBackendAgentNativeTimerDeleteTransport;
+class IBackendAgentNativeTimerCreateTransport;
+class IBackendAgentNativeTimerModifyTransport;
 }
 
 struct BackendAgentCommandClientConfig
@@ -19,6 +21,8 @@ struct BackendAgentCommandClientConfig
     std::vector<std::string> commandTypes;
     vdrsuite::agent::IBackendAgentNativeProbeTransport* nativeProbeTransport = nullptr;
     vdrsuite::agent::IBackendAgentNativeTimerDeleteTransport* nativeTimerDeleteTransport = nullptr;
+    vdrsuite::agent::IBackendAgentNativeTimerCreateTransport* nativeTimerCreateTransport = nullptr;
+    vdrsuite::agent::IBackendAgentNativeTimerModifyTransport* nativeTimerModifyTransport = nullptr;
 };
 
 struct BackendAgentCommandClientContext

core/agent/include/BackendAgentCommandDelivery.h

@@ -28,6 +28,7 @@ class BackendAgentCommandRepository
         const BackendAgentCommandAssignment& assignment,
         const vdrsuite::agent::BackendAgentLocalProviderSelection* selection = nullptr);
     bool ensureNativeTimerDeleteAssignmentSchema();
+    bool ensureNativeTimerModifyAssignmentSchema();
     std::optional<BackendAgentCommandAssignment> findAssignmentForOperation(
         const std::string& backendId,
         const std::string& operationId,

core/agent/include/BackendAgentCommandReservation.h

@@ -0,0 +1,95 @@
+#pragma once
+
+#include "BackendAgentCommand.h"
+#include "BackendAgentLocalProvider.h"
+
+#include <optional>
+#include <string>
+
+class BackendAgentCommandRepository;
+class Database;
+
+enum class BackendAgentCommandReservationStatus
+{
+    reserved,
+    alreadyReserved,
+    activated,
+    alreadyActivated,
+    notFound,
+    conflict,
+    storageError,
+    invalid,
+};
+
+struct BackendAgentCommandReservation
+{
+    BackendAgentCommandAssignment assignment;
+    bool localProviderSelectionPresent = false;
+    vdrsuite::agent::BackendAgentLocalProviderSelection localProviderSelection;
+    std::string assignmentFingerprint;
+    std::string localProviderSelectionIdentity;
+};
+
+struct BackendAgentCommandReservationResult
+{
+    BackendAgentCommandReservationStatus status =
+        BackendAgentCommandReservationStatus::storageError;
+    BackendAgentCommandReservation reservation;
+
+    bool ok() const
+    {
+        return status == BackendAgentCommandReservationStatus::reserved
+            || status == BackendAgentCommandReservationStatus::alreadyReserved;
+    }
+};
+
+struct BackendAgentCommandActivationResult
+{
+    BackendAgentCommandReservationStatus status =
+        BackendAgentCommandReservationStatus::storageError;
+    BackendAgentCommandAssignment assignment;
+
+    bool ok() const
+    {
+        return status == BackendAgentCommandReservationStatus::activated
+            || status == BackendAgentCommandReservationStatus::alreadyActivated;
+    }
+};
+
+class BackendAgentCommandReservationRepository
+{
+public:
+    explicit BackendAgentCommandReservationRepository(Database& database);
+
+    bool ensureSchema();
+
+    BackendAgentCommandReservationResult reserve(
+        const BackendAgentCommandAssignment& assignment,
+        const vdrsuite::agent::BackendAgentLocalProviderSelection* selection = nullptr);
+
+    BackendAgentCommandReservationResult findByCommandId(
+        const std::string& commandId) const;
+
+    BackendAgentCommandReservationResult findForOperation(
+        const std::string& backendId,
+        const std::string& operationId,
+        const std::string& commandType) const;
+
+private:
+    Database& database_;
+};
+
+class BackendAgentCommandReservationActivationService
+{
+public:
+    BackendAgentCommandReservationActivationService(
+        BackendAgentCommandReservationRepository& reservationRepository,
+        BackendAgentCommandRepository& commandRepository);
+
+    BackendAgentCommandActivationResult activate(
+        const std::string& commandId);
+
+private:
+    BackendAgentCommandReservationRepository& reservationRepository_;
+    BackendAgentCommandRepository& commandRepository_;
+};

core/agent/include/BackendAgentCommandStateExtension.h

@@ -1,16 +1,22 @@
 #pragma once
 
 #include "BackendAgentCommand.h"
+#include "BackendAgentNativeTimerCreateLocalState.h"
 #include "BackendAgentNativeTimerDeleteLocalState.h"
+#include "BackendAgentNativeTimerModifyLocalState.h"
 
 #include <cstdint>
 #include <string>
 
 namespace vdrsuite::agent
 {
 
+inline constexpr const char* kBackendAgentNativeTimerCreateLocalStateExtensionType =
+    "vdr.timer.create.local-state.v1";
 inline constexpr const char* kBackendAgentNativeTimerDeleteLocalStateExtensionType =
     "vdr.timer.delete.local-state.v1";
+inline constexpr const char* kBackendAgentNativeTimerModifyLocalStateExtensionType =
+    "vdr.timer.modify.local-state.v1";
 
 struct BackendAgentCommandStateExtension
 {
@@ -42,6 +48,17 @@ bool backendAgentCommandStateExtensionValidateSupported(
     const BackendAgentCommandAssignment& assignment,
     std::string& reasonCode);
 
+std::string backendAgentNativeTimerCreateCommandStateExtension(
+    const BackendAgentCommandAssignment& assignment,
+    const BackendAgentNativeTimerCreateLocalState& state,
+    std::string& reasonCode);
+
+bool backendAgentNativeTimerCreateParseCommandStateExtension(
+    const std::string& encoded,
+    const BackendAgentCommandAssignment& assignment,
+    BackendAgentNativeTimerCreateLocalState& state,
+    std::string& reasonCode);
+
 std::string backendAgentNativeTimerDeleteCommandStateExtension(
     const BackendAgentCommandAssignment& assignment,
     const BackendAgentNativeTimerDeleteLocalState& state,
@@ -53,4 +70,15 @@ bool backendAgentNativeTimerDeleteParseCommandStateExtension(
     BackendAgentNativeTimerDeleteLocalState& state,
     std::string& reasonCode);
 
+std::string backendAgentNativeTimerModifyCommandStateExtension(
+    const BackendAgentCommandAssignment& assignment,
+    const BackendAgentNativeTimerModifyLocalState& state,
+    std::string& reasonCode);
+
+bool backendAgentNativeTimerModifyParseCommandStateExtension(
+    const std::string& encoded,
+    const BackendAgentCommandAssignment& assignment,
+    BackendAgentNativeTimerModifyLocalState& state,
+    std::string& reasonCode);
+
 }

core/agent/include/BackendAgentNativeTimerCreate.h

@@ -0,0 +1,100 @@
+#pragma once
+
+#include "BackendAgentLocalProvider.h"
+
+#include <cstdint>
+#include <string>
+
+namespace vdrsuite::agent
+{
+
+constexpr const char* kBackendAgentNativeTimerCreateCommandType = "vdr.timer.create";
+constexpr const char* kBackendAgentNativeTimerCreateAuthorityDomain = "vdr.timer";
+constexpr const char* kBackendAgentNativeTimerCreateCapability = "vdr.timer.create";
+constexpr const char* kBackendAgentNativeTimerCreateProviderId = "suitebridge:local";
+constexpr const char* kBackendAgentNativeTimerCreateProviderKind = "suitebridge";
+constexpr std::uint64_t kBackendAgentNativeTimerCreatePayloadVersion = 1;
+
+struct BackendAgentNativeTimerCreateSpecification
+{
+    std::string channelId;
+    std::string title;
+    std::string directory;
+    std::string day;
+    std::string weekdays = "-------";
+    std::string startTime;
+    std::string endTime;
+    std::int32_t priority = 50;
+    std::int32_t lifetime = 99;
+    bool enabled = true;
+    bool vps = false;
+};
+
+struct BackendAgentNativeTimerCreateCommand
+{
+    std::string commandId;
+    std::string requestFingerprint;
+    std::string operationId;
+    std::string operationRevision;
+    std::string timerAssignmentId;
+    std::string expectedAssignmentRevision;
+    std::string expectedIntentRevision;
+    std::uint64_t assignmentEpoch = 0;
+    std::string nativeTimerBindingId;
+    std::string expectedSpecificationFingerprint;
+    std::string jobId;
+    std::string attemptId;
+    std::uint64_t claimEpoch = 0;
+    std::string backendId;
+    std::string agentId;
+    std::string agentInstanceId;
+    std::uint64_t backendGeneration = 0;
+    std::int64_t controlPlaneClaimedAt = 0;
+    BackendAgentNativeTimerCreateSpecification specification;
+    BackendAgentLocalProviderSelection localProviderSelection;
+};
+
+enum class BackendAgentNativeTimerCreateOutcomeCategory
+{
+    rejectedWithoutEffect,
+    acceptedUnverified,
+    outcomeUnknown,
+};
+
+struct BackendAgentNativeTimerCreateEvidence
+{
+    std::string commandId;
+    std::string requestFingerprint;
+    std::string operationId;
+    std::string operationRevision;
+    std::string timerAssignmentId;
+    std::string nativeTimerBindingId;
+    std::string jobId;
+    std::string attemptId;
+    std::uint64_t claimEpoch = 0;
+    std::string backendId;
+    std::string agentId;
+    std::string agentInstanceId;
+    std::uint64_t backendGeneration = 0;
+    std::string providerInstanceEpoch;
+    std::int64_t localStartingPersistedAt = 0;
+    BackendAgentNativeTimerCreateOutcomeCategory outcome =
+        BackendAgentNativeTimerCreateOutcomeCategory::outcomeUnknown;
+    std::int64_t dispatchStartedAt = 0;
+    std::int64_t completedAt = 0;
+    std::string evidenceReference;
+};
+
+bool backendAgentNativeTimerCreateSpecificationValid(
+    const BackendAgentNativeTimerCreateSpecification& specification);
+std::string backendAgentNativeTimerCreateSpecificationFingerprint(
+    const BackendAgentNativeTimerCreateSpecification& specification);
+bool backendAgentNativeTimerCreateValidCommand(
+    const BackendAgentNativeTimerCreateCommand& command,
+    std::string& reasonCode);
+bool backendAgentNativeTimerCreateEvidenceMatches(
+    const BackendAgentNativeTimerCreateEvidence& evidence,
+    const BackendAgentNativeTimerCreateCommand& command,
+    std::string& reasonCode);
+
+} // namespace vdrsuite::agent