Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat(Cosmos): Handle blind write of events+unfolds idempotently #463

Draft
wants to merge 1 commit into
base: master
Choose a base branch
from
Draft

feat(Cosmos): Handle blind write of events+unfolds idempotently #463

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion src/Equinox.CosmosStore/CosmosStore.fs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ type SyncResponse = { etag: string; n: int64; conflicts: Unfold[]; e: Event[] }

module internal SyncStoredProc =

let [<Literal>] name = "EquinoxEventsInTip4" // NB need to rename/number for any breaking change
let [<Literal>] name = "EquinoxEventsInTip5" // NB need to rename/number for any breaking change
let [<Literal>] body = """
// Manages the merging of the supplied Request Batch into the stream, potentially storing events in the Tip

Expand All @@ -410,6 +410,10 @@ function sync(req, expIndex, expEtag, maxEventsInTip, maxStringifyLen) {
} else if (!current && ((expIndex === -2 && expEtag !== null) || expIndex > 0)) {
// If there is no Tip page, the writer has no possible reason for writing at an index other than zero, and an etag exp must be fulfilled
response.setBody({ etag: null, n: 0, conflicts: [], e: [] });
} else if (current && expIndex !== -2 && current.n === expIndex + req.e.length && req.u.length > 0) {
// For CosmosStoreSink blind write of events and unfolds; all the events are present, we just need to update unfolds
req.e = [];
executeUpsert(current);
} else if (current && ((expIndex === -2 && expEtag !== current._etag) || (expIndex !== -2 && expIndex !== current.n))) {
// Where possible, we extract conflicting events from e and/or u in order to avoid another read cycle;
// yielding [] triggers the client to go loading the events itself
Expand Down