fix retry in event triggers

Author: colerogers

src/v2/providers/alerts/alerts.ts

@@ -249,7 +249,7 @@ export function getEndpointAnnotation(
       eventFilters: {
         alerttype: alertType,
       },
-      retry: !!opts.retry,
+      retry: opts.retry || false,
     },
   };
   if (appId) {

src/v2/providers/database.ts

@@ -446,7 +446,7 @@ export function makeEndpoint(
       eventType,
       eventFilters,
       eventFilterPathPatterns,
-      retry: false,
+      retry: opts.retry || false,
     },
   };
 }

src/v2/providers/eventarc.ts

@@ -216,7 +216,7 @@ export function onCustomEventPublished<T = any>(
     eventTrigger: {
       eventType: opts.eventType,
       eventFilters: {},
-      retry: false,
+      retry: opts.retry || false,
       channel,
     },
   };

src/v2/providers/firestore.ts

@@ -426,7 +426,7 @@ export function makeEndpoint(
       eventType,
       eventFilters,
       eventFilterPathPatterns,
-      retry: !!opts.retry,
+      retry: opts.retry || false,
     },
   };
 }

src/v2/providers/pubsub.ts

@@ -324,6 +324,7 @@ export function onMessagePublished<T = any>(
         eventTrigger: {
           eventType: "google.cloud.pubsub.topic.v1.messagePublished",
           resource: `projects/${process.env.GCLOUD_PROJECT}/topics/${topic}`,
+          retry: opts.retry || false,
         },
       };
     },

src/v2/providers/remoteConfig.ts

@@ -145,7 +145,7 @@ export function onConfigUpdated(
     eventTrigger: {
       eventType,
       eventFilters: {},
-      retry: !!optsOrHandler.retry,
+      retry: optsOrHandler.retry || false,
     },
   };
   func.__endpoint = ep;

src/v2/providers/storage.ts

@@ -603,7 +603,7 @@ export function onOperation(
         eventTrigger: {
           eventType,
           eventFilters: { bucket },
-          retry: false,
+          retry: opts.retry || false,
         },
       };
       copyIfPresent(endpoint.eventTrigger, opts, "retry", "retry");

src/v2/providers/tasks.ts

@@ -281,6 +281,7 @@ export function onTaskDispatched<Args = any>(
     convertInvoker
   );
   convertIfPresent(func.__endpoint.taskQueueTrigger, opts, "invoker", "invoker", convertInvoker);
+  copyIfPresent(func.__endpoint.taskQueueTrigger, opts, "retry", "retry")
 
   func.__requiredAPIs = [
     {

src/v2/providers/testLab.ts

@@ -206,7 +206,7 @@ export function onTestMatrixCompleted(
     eventTrigger: {
       eventType,
       eventFilters: {},
-      retry: !!optsOrHandler.retry,
+      retry: optsOrHandler.retry || false,
     },
   };
   func.__endpoint = ep;