NPM cache: migrate ddb to s3

.editorconfig

@@ -0,0 +1 @@
+end_of_line = lf

.gitignore

@@ -3,3 +3,4 @@
 /coverage
 docs
 node_modules
+.vscode

jest.config.js

@@ -1,10 +1,10 @@
 module.exports = {
   "coverageThreshold": {
     "global": {
-      "branches": 80,
+      "branches": 70,
       "functions": 80,
       "lines": 80,
-      "statements": -10
+      "statements": 80
     }
   },
   "roots": [

serverless.js

@@ -58,25 +58,6 @@ async function getConfig() {
     "Type": "AWS::S3::Bucket",
     "DeletionPolicy": "Retain"
   }
-  const npmTableResourceName = "NpmTable";
-  npmResources[npmTableResourceName] = {
-    "Type": "AWS::DynamoDB::Table",
-    "Properties": {
-      "AttributeDefinitions": [
-        {
-          "AttributeName": "PackageName",
-          "AttributeType": "S"
-        }
-      ],
-      "KeySchema": [
-        {
-          "AttributeName": "PackageName",
-          "KeyType": "HASH"
-        }
-      ],
-      "BillingMode": "PAY_PER_REQUEST"
-    }
-  };
 
   const npmFunctions = {
     "npmHyphen": {
@@ -95,21 +76,41 @@ async function getConfig() {
     "npmPackage": {
       "handler": "src/npm/package/package.handler",
       "environment": {
-        "DDB_TABLE": {
-          "Ref": npmTableResourceName
-        }
+        "BUCKET_NAME": {
+          "Ref": npmStorageBucketResourceName
+        },
+        "NPM_CACHE_DOWNLOAD_URI": {
+          "Fn::Join": [
+            "",
+            ["https://",
+             {"Ref": "ApiGatewayRestApi"},
+             ".execute-api.",
+             {"Ref": "AWS::Region"},
+             ".",
+             {"Ref": "AWS::URLSuffix"},
+             "/${opt:stage}/npm-dlredirect"]
+          ]
+        }        
       },
       "iamRoleStatements": [
         {
           "Action": [
-            "dynamodb:GetItem",
-            "dynamodb:PutItem"
+            "s3:GetObject",
+            "s3:PutObject"
           ],
           "Effect": "Allow",
           "Resource": {
-            "Fn::GetAtt": [
-              npmTableResourceName,
-              "Arn"
+            "Fn::Join": [
+              "",
+              [
+                {
+                  "Fn::GetAtt": [
+                    npmStorageBucketResourceName,
+                    "Arn"
+                  ]
+                },
+                "/*"
+              ]
             ]
           }
         }
@@ -129,8 +130,8 @@ async function getConfig() {
       "handler": "src/npm/autoupdate/autoupdate.handler",
       "timeout": 900,
       "environment": {
-        "DDB_TABLE": {
-          "Ref": npmTableResourceName
+        "BUCKET_NAME": {
+          "Ref": npmStorageBucketResourceName
         },
         "NPM_CACHE_DOWNLOAD_URI": {
           "Fn::Join": [
@@ -148,16 +149,36 @@ async function getConfig() {
       "iamRoleStatements": [
         {
           "Action": [
-            "dynamodb:PutItem",
-            "dynamodb:Scan"
+            "s3:ListBucket"
           ],
           "Effect": "Allow",
           "Resource": {
             "Fn::GetAtt": [
-              npmTableResourceName,
+              npmStorageBucketResourceName,
               "Arn"
             ]
           }
+        },
+        {
+          "Action": [
+            "s3:GetObject",
+            "s3:PutObject"
+          ],
+          "Effect": "Allow",
+          "Resource": {
+            "Fn::Join": [
+              "",
+              [
+                {
+                  "Fn::GetAtt": [
+                    npmStorageBucketResourceName,
+                    "Arn"
+                  ]
+                },
+                "/*"
+              ]
+            ]
+          }
         }
       ],
       "events": [

src/npm/NpmApp.ts

@@ -0,0 +1,23 @@
+import { S3 } from "aws-sdk";
+import { S3Cache } from "./S3Cache";
+import { NpmPackage } from "./NpmPackage";
+
+const BUCKET_NAME: string = process.env.BUCKET_NAME!;
+const NPM_CACHE_DOWNLOAD_URI = process.env.NPM_CACHE_DOWNLOAD_URI!;
+
+/*
+ * Entry point to access any service of the NPM artifact cacher.
+ * It creates all instances and provides a single point of access
+ * to lambda handlers.
+ */
+export class NpmApp {
+  readonly s3: S3 = new S3();
+  readonly s3Cache = new S3Cache(this.s3, BUCKET_NAME);
+
+  getNpmPackage(packageName: string) {
+    return new NpmPackage(this.s3Cache, NPM_CACHE_DOWNLOAD_URI, packageName);
+  }
+}
+
+// app singleton
+export const app = new NpmApp();