jamesseanwright

resource "aws_api_gateway_rest_api" "api" {
  name = "iot-events"
}

resource "aws_api_gateway_model" "event" {
  rest_api_id = aws_api_gateway_rest_api.api.id
  name = "event"
  description = "Event information sent from a device"
  content_type = "application/json"

jamesseanwright

locals {
  function_name = replace(var.name, "-", "_")
}

resource "aws_ecr_repository" "lambda_repo" {
  name = var.name

  # TODO: these provisioners will only run when the
  # repo is created for the first time. Find a better
  # way to build and push containers as code changes.

jamesseanwright

terraform {
  required_providers {
    mongodbatlas = {
      source  = "mongodb/mongodbatlas"
      version = "0.9.1"
    }

    random = {
      source  = "hashicorp/random"
      version = "3.1.0"

jamesseanwright

resource "aws_vpc" "iot_events" {
  cidr_block = "10.0.0.0/16"

  tags = {
    Name = "iot-events"
  }
}

resource "aws_subnet" "subnet_a" {
  vpc_id = aws_vpc.iot_events.id

jamesseanwright

terraform {
  required_providers {
    aws = {
      source  = "hashicorp/aws"
      version = "3.49.0"
    }
  }

  required_version = "~> 1.0.0"
}

jamesseanwright

$ curl -XGET \
  -H "Content-Type: application/json" \
  "http://localhost:8080/events?deviceID=8f188304-e7b3-4a16-a243-b9470468478a&eventType=temp_celcius&date=$(date -u +%F)"

jamesseanwright

'use strict';

function invoke(r) {
  var payload = {
    body: r.requestText,
    queryStringParameters: r.args,
  };

  r.subrequest('/integration', {
    method: 'POST',

jamesseanwright

load_module /usr/lib/nginx/modules/ngx_http_js_module.so;

events {}

http {
  js_import integration.js;

  map $downstream_method $handler_host {
    POST "add-event";
    GET "get-events";

jamesseanwright

version: '3'

services:
  get-events:
    build:
      context: ./handlers
      args:
        handler: get-events
    environment:
      MONGODB_URI: mongodb://db:27017

jamesseanwright

'use strict';

const { getDBConnection, createRes } = require('../common');

exports.handler = async ({ queryStringParameters }) => {
  const connection = await getDBConnection();
  const { deviceID, date, eventType } = queryStringParameters;

  try {
    const events = await connection