anything

anything is a document storage / item management system designed to be flexible about the underlying data schema.

Anyone with an AWS account can setup a user directory in IAM Identity Center, edit a couple environment variables, and deploy (or remove) the system with one command.

Then users can view data, and import/export spreadsheets via a web app. The system is serverless, with provisioned resources billed per use.

Please note this is an example app not intended for production. If you want to use the code in a production app under the terms of the AGPL, you'll need to grab a MUI license or rework the code to remove x-data-grid-premium.

Architecture

• Serverless api run by AWS Lambda functions fronted by API gateway.
• DynamoDB picked for on demand document storage.
• Almost all infrastructure defined in code, except authorisation provider (IAM Identity Center, currently lacks much CloudFormation support).
• Client run on Next.js via the experimental app router (but just exported to a static bundle for hosting via an S3 bucket anyways).
• MUI's x-data-grid powers client data tables. TailwindCSS used for styling with daisyUI on top to simplify basic component styling and add theming support.
• DynamoDB streams incremental updates to live summary dashboard via Lambda, Kinesis Firehose and Athena.

C4 Diagrams

1. System context

C4Context
  %% title System context
  Enterprise_Boundary(net, "Internet") {
    System(anything, "anything<br>item management system", "Allows users to view, import, and export item data")
    Enterprise_Boundary(org, "Organisation") {
      Person(user, "User", "Organisation member with user directory<br>privileges to access anything")
      SystemDb_Ext(userdir, "User directory", "Stores organisation member info,<br>including which users can access anything")
      Person_Ext(admin, "Admin", "Privileges to modify user directory")
      System_Ext(inventory, "Inventories", "Physical item inventories")
      System_Ext(sheets, "Spreadsheets", "Casual collections of inventory item info,<br>other document storage")
    }
  }
  BiRel(user, anything, "Imports/exports sheets<br>and queries items")
  UpdateRelStyle(user, anything, $offsetY="-50", $offsetX="-140")
  BiRel(user, inventory, "Tracks updates<br>and modifies")
  UpdateRelStyle(user, inventory, $offsetY="0", $offsetX="-90")
  BiRel(user, sheets, "Creates<br>and pulls")
  UpdateRelStyle(user, sheets, $offsetY="0", $offsetX="10")
  Rel(admin, userdir, "Edits")
  UpdateRelStyle(admin, userdir, $offsetY="10", $offsetX="0")
  Rel(anything, userdir, "Checks user authentication<br>and authorisation")
  UpdateRelStyle(anything, userdir, $offsetY="-50", $offsetX="-80")
  Rel(userdir, user, "Sends auth<br>related email")
  UpdateRelStyle(userdir, user, $offsetY="20", $offsetX="-30")
  UpdateLayoutConfig($c4ShapeInRow="3", $c4BoundaryInRow="1")

Loading

2. Containers

C4Container
  %% title Containers
  Person(user, User, "Member of user directory<br>with privileges to access anything")
  System_Ext(userdir, "User directory", "IAM Identity Center, Cognito")
  Container_Boundary(anything, "anything item management system") {
    Container(cdn, "Content delivery network", "Cloudfront, S3", "Delivers single page app<br>hosted on S3 bucket to user<br>from a nearby edge location")
    Container(spa, "Single page app", "Next.js, Typescript, React", "Provides item management<br>functionality to users<br>via web browser")
    Container(dash, "Live dashboard", "", "Real time summary stats")
    Container(api, "API", "SAM,<br>API Gateway,<br>Lambda functions", "Interface for app to database<br>")
    ContainerDb(database, "Database", "DynamoDB", "Stores items,<br>collections of items of different types")
    Container(athena, "Queries", "Athena", "")
    Container(stream, "Transform & Stream", "Lambda to Kinesis Firehose", "Pipeline to store DynamoDB streams data<br>into S3 in analytics-friendly format")
    ContainerDb(s3, "Storage bucket", "S3", "Stores items<br>for analytics queries")
  }
  Rel(user, cdn, "Visits hosting domain", "HTTPS")
  UpdateRelStyle(user, cdn, $offsetY="-50", $offsetX="-130")
  Rel(cdn, spa, "Delivers to<br>user's browser")
  UpdateRelStyle(cdn, spa, $offsetY="20", $offsetX="-40")
  Rel(user, spa, "Imports, exports,<br>and views items")
  UpdateRelStyle(user, spa, $offsetY="-40", $offsetX="-45")
  Rel(spa, dash, "Displays live<br>dashboard")
  Rel(spa, api, "Calls", "async HTTPS<br>/ JSON")
  UpdateRelStyle(spa, api, $offsetY="-15" $offsetX="-80")
  UpdateRelStyle(spa, dash, $offsetY="-25" $offsetX="-30")
  Rel(spa, userdir, "Authenticates<br>and gets API credentials")
  UpdateRelStyle(spa, userdir, $offsetY="-50" $offsetX="10")
  Rel(api, database, "Performs CRUD operations", "AWS SDK for JS v3,<br>lib-dynamodb")
  UpdateRelStyle(api, database, $offsetY="45", $offsetX="-40")
  UpdateLayoutConfig($c4ShapeInRow="3", $c4BoundaryInRow="1")
  Rel(database, stream, "Passes updates", "DynamoDB Stream")
  UpdateRelStyle(database, stream, $offsetY="15" $offsetX="10")
  Rel(stream, s3, "Stores", "Lambda,<br>Kinesis Firehose")
  UpdateRelStyle(stream, s3, $offsetY="15" $offsetX="-40")
  Rel(athena, s3, "Queries", "")
  UpdateRelStyle(athena, s3, $offsetY="10" $offsetX="30")
  Rel(dash, athena, "Queries", "")
  UpdateRelStyle(dash, athena, $offsetY="0" $offsetX="10")

Loading

Deployment

Edit the environment variables in .env as appropriate and load using direnv.

Refer to packages/api/README.md and packages/app/README.md for setting up the serverless api and web app.

Note that the data analytics pipeline and dashboard can't be emulated locally and require cloud deployment of resources.

Monorepo structure

This Turborepo includes the following packages and apps:

• api: a Serverless Application Model (SAM) api on AWS
• app: a Next.js app using app router
• infra: Serverless infrastructure on AWS, broken into sub-packages
• logger: a small wrapper around console.log
• utils: some shared code between api and app
• eslint-config-*: ESLint configurations
• tsconfig: tsconfig.json's used throughout the monorepo
• jest-presets: Jest config

A submodule lambda-streams-to-firehose is also included under infra/data. If git didn't fetch it automatically for you, get it using:

git submodule update --init --recursive