Skip to content

Commit

Permalink
fix(nrplus): gateway now scans on its own
Browse files Browse the repository at this point in the history
  • Loading branch information
coderbyheart committed Mar 22, 2024
1 parent 0065a28 commit 0f125f4
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 82 deletions.
1 change: 0 additions & 1 deletion cdk/BackendLambdas.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ type BackendLambdas = {
onNewNetworkSurvey: PackedLambda
onNetworkSurveyLocated: PackedLambda
parseSinkMessages: PackedLambda
nrplusGatewayScan: PackedLambda
updatesToLwM2M: PackedLambda
publishLwM2MShadowsToJSON: PackedLambda
memfault: PackedLambda
Expand Down
1 change: 0 additions & 1 deletion cdk/backend.ts
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,6 @@ new BackendApp({
onNewNetworkSurvey: await pack('onNewNetworkSurvey'),
onNetworkSurveyLocated: await pack('onNetworkSurveyLocated'),
parseSinkMessages: await pack('parseSinkMessages'),
nrplusGatewayScan: await pack('nrplusGatewayScan'),
updatesToLwM2M: await pack('updatesToLwM2M'),
memfault: await pack('memfault'),
memfaultPollForReboots: await pack('memfaultPollForReboots'),
Expand Down
43 changes: 0 additions & 43 deletions cdk/resources/NRPlusGateway.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,5 @@
import { Duration, Stack } from 'aws-cdk-lib'
import IAM from 'aws-cdk-lib/aws-iam'
import Events from 'aws-cdk-lib/aws-events'
import EventsTargets from 'aws-cdk-lib/aws-events-targets'
import Iot from 'aws-cdk-lib/aws-iot'
import Kinesis, { StreamMode } from 'aws-cdk-lib/aws-kinesis'
import Lambda, { StartingPosition } from 'aws-cdk-lib/aws-lambda'
Expand All @@ -18,7 +16,6 @@ export class NRPlusGateway extends Construct {
}: {
lambdaSources: {
parseSinkMessages: PackedLambda
nrplusGatewayScan: PackedLambda
}
},
) {
Expand Down Expand Up @@ -108,45 +105,5 @@ export class NRPlusGateway extends Construct {
parallelizationFactor: 1,
}),
)

// Trigger scan message periodically
const nrplusGatewayScanFn = new Lambda.Function(
this,
'nrplusGatewayScanFn',
{
handler: lambdaSources.nrplusGatewayScan.handler,
architecture: Lambda.Architecture.ARM_64,
runtime: Lambda.Runtime.NODEJS_20_X,
timeout: Duration.minutes(15),
memorySize: 1792,
code: Lambda.Code.fromAsset(
lambdaSources.nrplusGatewayScan.lambdaZipFile,
),
description:
'Periodically trigger scan in sink to sync with relay, required to communicate reliably with relay and relay-connected clients',
environment: {
VERSION: this.node.tryGetContext('version'),
},
initialPolicy: [
new IAM.PolicyStatement({
actions: ['iot:ListThings', 'iot:Publish'],
resources: ['*'],
}),
],
...new LambdaLogGroup(this, 'nrplusGatewayScanFnLogs'),
},
)

const rule = new Events.Rule(this, 'Rule', {
schedule: Events.Schedule.expression('rate(1 minute)'),
description: `Invoke the summary lambda`,
enabled: true,
targets: [new EventsTargets.LambdaFunction(nrplusGatewayScanFn)],
})

nrplusGatewayScanFn.addPermission('InvokeByEvents', {
principal: new IAM.ServicePrincipal('events.amazonaws.com'),
sourceArn: rule.ruleArn,
})
}
}
37 changes: 0 additions & 37 deletions lambda/nrplusGatewayScan.ts

This file was deleted.

0 comments on commit 0f125f4

Please sign in to comment.