Skip to content
This repository has been archived by the owner on Dec 26, 2022. It is now read-only.

create topic subscriptions on consuming side #25

Merged
merged 3 commits into from
Jun 25, 2019
Merged

create topic subscriptions on consuming side #25

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
0a5826c
create topic subscriptions on consuming side
Jun 25, 2019
0e121c5
remove double quotes
Jun 25, 2019
cfb18f9
load .env
Jun 25, 2019
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
1 change: 1 addition & 0 deletions grapl-cdk/.gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
cdk.out/
33 changes: 23 additions & 10 deletions grapl-cdk/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -453,7 +453,7 @@ class SysmonSubgraphGenerator extends cdk.Stack {
const service = new Service(this, 'sysmon-subgraph-generator', environment);

service.readsFrom(reads_from);
subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));
service.publishesToBucket(writes_to);
}
}
Expand All @@ -475,11 +475,25 @@ class GenericSubgraphGenerator extends cdk.Stack {
const service = new Service(this, 'generic-subgraph-generator', environment);

service.readsFrom(reads_from);
subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));

addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));

service.publishesToBucket(writes_to);
}
}

function addSubscription(scope, topic, subscription) {
const config = subscription.bind(topic);

new sns.Subscription(scope, 'Subscription', {
topic: topic,
endpoint: config.endpoint,
filterPolicy: config.filterPolicy,
protocol: config.protocol,
rawMessageDelivery: config.rawMessageDelivery
});
}


class NodeIdentityMapper extends cdk.Stack {

Expand All @@ -500,7 +514,7 @@ class NodeIdentityMapper extends cdk.Stack {

service.readsFrom(reads_from);

subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));

service.event_handler.connections.allowToAnyIPv4(ec2.Port.tcp(443), 'Allow outbound to S3');
service.event_retry_handler.connections.allowToAnyIPv4(ec2.Port.tcp(443), 'Allow outbound to S3');
Expand Down Expand Up @@ -530,7 +544,7 @@ class NodeIdentifier extends cdk.Stack {

history_db.allowReadWrite(service);
service.publishesToBucket(writes_to);
subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));
service.event_handler.connections.allowToAnyIPv4(ec2.Port.tcp(443), 'Allow outbound to S3');
service.event_retry_handler.connections.allowToAnyIPv4(ec2.Port.tcp(443), 'Allow outbound to S3');

Expand Down Expand Up @@ -563,7 +577,7 @@ class GraphMerger extends cdk.Stack {
service.readsFrom(reads_from);
service.publishesToTopic(publishes_to);

subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));
//
// service.event_handler.connections
// .allowToAnyIPv4(new ec2.Port({
Expand Down Expand Up @@ -594,12 +608,12 @@ class AnalyzerDispatch extends cdk.Stack {
};

const service = new Service(this, 'analyzer-dispatcher', environment, vpc);
;

service.publishesToBucket(writes_to);
// We need the List capability to find each of the analyzers
service.readsFrom(reads_from, true);

subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));

service.event_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
service.event_retry_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
Expand Down Expand Up @@ -658,8 +672,7 @@ class AnalyzerExecutor extends cdk.Stack {
service.event_handler.addToRolePolicy(policy);
service.event_retry_handler.addToRolePolicy(policy);


subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));

service.event_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
service.event_retry_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
Expand Down Expand Up @@ -696,7 +709,7 @@ class EngagementCreator extends cdk.Stack {
service.readsFrom(reads_from);
service.publishesToTopic(publishes_to);

subscribes_to.addSubscription(new snsSubs.SqsSubscription(service.queues.queue));
addSubscription(this, subscribes_to, new snsSubs.SqsSubscription(service.queues.queue));

service.event_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
service.event_retry_handler.connections.allowToAnyIPv4(ec2.Port.allTcp(), 'Allow outbound to S3');
Expand Down
3 changes: 1 addition & 2 deletions grapl-cdk/package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
"@aws-cdk/core": "^0.36.0",
"@types/node": "^10.14.6",
"aws-cdk": "^0.36.0",
"node-env-file": "^0.1.8",
"@aws-cdk/aws-cloudmap": "latest"
"node-env-file": "^0.1.8"
}
}