pjfanning opened a new pull request, #376: URL: https://github.com/apache/pekko-persistence-r2dbc/pull/376
Ports three PRs from [akka/akka-persistence-r2dbc](https://github.com/akka/akka-persistence-r2dbc) to this Pekko fork. These changes are now available under the Apache License, version 2.0. akka-persistence-r2dbc v1.1.0 ## Changes ### PR 382 — fix: include tags in pubsub envelope - `PubSub.scala`: unwrap `Tagged(payload, tags)` from the persisted representation and pass `tags` through to the `EventEnvelope` published via pub-sub - `R2dbcJournal.scala`: remove the stale `eventsByTagNotImplementedLogged` var and related log-once helper (no longer needed) ### PR 377 — feat: tags in events by slice query - `QueryDao.scala`: include `tags` column in `eventsBySlicesRangeSql` and `selectOneEventSql`, read tags from result rows in `rowsBySlices` and `loadEvent` - `EventsByPersistenceIdDao.scala`: include `tags` column in query and read tags from rows; rename `internalEventsByPersistenceId` → `internalCurrentEventsByPersistenceId` - `R2dbcReadJournal.scala` (scaladsl): populate `tags` in `createEnvelope` and `deserializeBySliceRow`; update `currentEventsByPersistenceId` to use `internalCurrentEventsByPersistenceId` - `R2dbcReadJournal.scala` (javadsl): forward `tags` via scaladsl delegate ### PR 373 — fix: save offset for pid/seqNr of the processed envelope - New `OffsetPidSeqNr.scala`: lightweight wrapper `OffsetPidSeqNr(offset, pidSeqNr: Option[(String, Long)])` with two factory methods - `R2dbcOffsetStore.scala`: change `saveOffset`, `saveOffsetInTx`, `saveOffsets`, `saveOffsetsInTx` from generic `Offset` to `OffsetPidSeqNr`; each call now stores exactly the one pid/seqNr that was processed rather than the full `seen` map - `R2dbcProjectionImpl.scala`: add `extractOffsetPidSeqNr` helper (handles `EventEnvelope`, `UpdatedDurableState`, `DeletedDurableState`); thread it through `adaptedHandlerForExactlyOnce`, `adaptedHandlerForGrouped`, `saveOffsetAndReport`, `saveOffsetsAndReport` - `R2dbcOffsetStoreSpec.scala`: wrap all `saveOffset` calls with `OffsetPidSeqNr(offset)` - `R2dbcTimestampOffsetStoreSpec.scala`: wrap all `saveOffset`/`saveOffsets` calls; expand multi-pid offsets to multiple single-pid saves References: - https://github.com/akka/akka-persistence-r2dbc/pull/382 - https://github.com/akka/akka-persistence-r2dbc/pull/377 - https://github.com/akka/akka-persistence-r2dbc/pull/373 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
