feat(dynamodb): get table connection with read write permissions (#241)

Useful when accessing the table using native clients

dynamodb/dynamodb-types.w

@@ -208,4 +208,5 @@ pub inflight interface IClient {
 
 pub interface ITable extends IClient {
   setStreamConsumer(handler: inflight (StreamRecord): void, options: StreamConsumerOptions?): void;
+  inflight readWriteConnection(): Connection;
 }

dynamodb/dynamodb.sim.w

@@ -228,4 +228,8 @@ pub class Table_sim impl dynamodb_types.ITable {
   pub inflight query(options: dynamodb_types.QueryOptions): dynamodb_types.QueryOutput {
     return this.client.query(options);
   }
+
+  pub inflight readWriteConnection(): dynamodb_types.Connection {
+    return this.connection;
+  }
 }

dynamodb/dynamodb.tf-aws.w

@@ -147,6 +147,11 @@ pub class Table_tfaws impl dynamodb_types.ITable {
           "dynamodb:GetItem",
         );
       }
+      if ops.contains("readWriteConnection") {
+        actions.push(
+          "dynamodb:*",
+        );
+      }
       if ops.length > 0 {
         lambda.addPolicyStatements({
           actions: actions.copy(),
@@ -190,4 +195,8 @@ pub class Table_tfaws impl dynamodb_types.ITable {
   pub inflight query(options: dynamodb_types.QueryOptions): dynamodb_types.QueryOutput {
     return this.client.query(options);
   }
+
+  pub inflight readWriteConnection(): dynamodb_types.Connection {
+    return this.connection;
+  }
 }

dynamodb/dynamodb.w

@@ -61,5 +61,9 @@ pub class Table impl dynamodb_types.ITable {
   pub inflight query(options: dynamodb_types.QueryOptions): dynamodb_types.QueryOutput {
     return this.implementation.query(options);
   }
+
+  pub inflight readWriteConnection(): dynamodb_types.Connection {
+    return this.implementation.readWriteConnection();
+  }
 }
 

dynamodb/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@winglibs/dynamodb",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "description": "DynamoDB library for Wing",
   "author": {
     "name": "Cristian Pallarés",