diff --git a/CHANGELOG.md b/CHANGELOG.md index e69de29bb..7fabc8933 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -0,0 +1 @@ +- Expose retry configuration in v2 RTDB trigger (#1588) diff --git a/spec/v2/providers/database.spec.ts b/spec/v2/providers/database.spec.ts index c5e16f747..9eabf61ca 100644 --- a/spec/v2/providers/database.spec.ts +++ b/spec/v2/providers/database.spec.ts @@ -280,6 +280,40 @@ describe("database", () => { }, }); }); + + it("should supply retry", () => { + const func = database.onChangedOperation( + database.writtenEventType, + { + ref: "/foo/{path=**}/{bar}/", + instance: "my-instance", + region: "us-central1", + cpu: "gcf_gen1", + minInstances: 2, + retry: true, + }, + () => 2 + ); + + expect(func.__endpoint).to.deep.equal({ + ...MINIMAL_V2_ENDPOINT, + platform: "gcfv2", + cpu: "gcf_gen1", + minInstances: 2, + region: ["us-central1"], + labels: {}, + eventTrigger: { + eventType: database.writtenEventType, + eventFilters: { + instance: "my-instance", + }, + eventFilterPathPatterns: { + ref: "foo/{path=**}/{bar}", + }, + retry: true, + }, + }); + }); }); describe("onOperation", () => { diff --git a/src/v2/providers/database.ts b/src/v2/providers/database.ts index 50400bdcf..8bccbc59b 100644 --- a/src/v2/providers/database.ts +++ b/src/v2/providers/database.ts @@ -447,7 +447,7 @@ export function makeEndpoint( eventType, eventFilters, eventFilterPathPatterns, - retry: false, + retry: opts.retry ?? false, }, }; }