diff --git a/common/src/main/protobuf/model/schedule.proto b/common/src/main/protobuf/model/schedule.proto index 02a8a41..23ea5d0 100644 --- a/common/src/main/protobuf/model/schedule.proto +++ b/common/src/main/protobuf/model/schedule.proto @@ -47,6 +47,10 @@ message CronTab { required string cron = 4; optional google.protobuf.Timestamp lastTriggered = 5 [(scalapb.field).type = "java.util.Date"]; optional google.protobuf.Timestamp nextTriggered = 6 [(scalapb.field).type = "java.util.Date"]; + // Story 13.7 — cross-service correlation id. Carried onto the derived Schedule in + // cronTabToSchedule so cron-based recurring renewals reach the consumer with the originating + // id. ScalaPB → correlationId: Option[String] + withCorrelationId. + optional string correlation_id = 7; } // Scheduler diff --git a/common/src/main/scala/app/softnetwork/scheduler/model/package.scala b/common/src/main/scala/app/softnetwork/scheduler/model/package.scala index dabd9ad..770de1f 100644 --- a/common/src/main/scala/app/softnetwork/scheduler/model/package.scala +++ b/common/src/main/scala/app/softnetwork/scheduler/model/package.scala @@ -116,6 +116,7 @@ package object model { .withScheduledDate(date) // .withRepeatedly(true) .withCronTab(cronTab.uuid) + .copy(correlationId = cronTab.correlationId) ) case _ => None }