fix(pulumi-aws): sync system event bus

Author: brunozoric

packages/api-sync-system/__tests__/sync/createSendDataToEventBridgeOnRequestEnd.test.ts

@@ -75,7 +75,6 @@ describe("createSendDataToEventBridgeOnRequestEnd", () => {
         expect(send).toHaveBeenCalledTimes(1);
     });
 
-    // TODO does not work
     it("should trigger flush on request end and get an unspecified error", async () => {
         const { request } = createMockRequest();
         const { reply } = createMockReply();

packages/api-sync-system/src/sync/handler/Handler.ts

@@ -60,11 +60,11 @@ export class Handler implements IHandler {
         console.log(JSON.stringify({ entries }));
 
         const input: PutEventsCommandInput = {
-            Entries: entries,
+            Entries: entries
             /**
              * If we get to the global event bus usage, we will need to set the EndpointId
              */
-            EndpointId: undefined
+            // EndpointId: undefined
         };
         const command = new PutEventsCommand(input);
 

packages/pulumi-aws/src/apps/syncSystem/SyncSystemEventBus.ts

@@ -24,7 +24,7 @@ export const SyncSystemEventBus = createAppModule({
         });
 
         const eventBusRuleConfig: EventRuleArgs = {
-            eventBusName: eventBus.output.arn,
+            eventBusName: eventBus.output.name,
             eventPattern: JSON.stringify({
                 "detail-type": ["synchronization-input"]
             })
@@ -56,7 +56,7 @@ export const SyncSystemEventBus = createAppModule({
         const eventBusPolicy = app.addResource(aws.sqs.QueuePolicy, {
             name: createSyncResourceName("queuePolicy"),
             config: {
-                queueUrl: sqs.output.id,
+                queueUrl: sqs.output.url,
                 policy: sqs.output.arn.apply(arn => {
                     return JSON.stringify({
                         Version: "2012-10-17",
@@ -65,7 +65,7 @@ export const SyncSystemEventBus = createAppModule({
                                 Effect: "Allow",
                                 Principal: aws.iam.Principals.EventsPrincipal,
                                 Action: "sqs:SendMessage",
-                                Resource: arn,
+                                Resource: [arn, `${arn}/*`],
                                 Condition: {
                                     ArnEquals: {
                                         "aws:SourceArn": eventBusRule.output.arn