Migration

Author: caiquebispoferreira

.vs/WebApplicationBeanstalk/v16/.suo

@@ -4,6 +4,7 @@
 using System.Linq;
 using System.Security.Cryptography.X509Certificates;
 using System.Threading.Tasks;
+using Amazon.DynamoDBv2;
 using Microsoft.AspNetCore.Identity.UI.Pages.Account.Internal;
 using Microsoft.AspNetCore.Mvc;
 using WebApplicationBeanstalk.Models;
@@ -13,7 +14,13 @@ namespace WebApplicationBeanstalk.Controllers
 {
     public class HomeController : Controller
     {
-        AWSServices services = new AWSServices();
+        private IAmazonDynamoDB dynamoDBClient;
+
+        public HomeController(IAmazonDynamoDB dynamoDBClient)
+        {
+            this.dynamoDBClient = dynamoDBClient;
+        }
+
         public IActionResult Index()
         {
             return View();
@@ -27,6 +34,7 @@ public IActionResult RegistrationForm()
         [HttpPost]
         public IActionResult LogIn (string email, string password)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             User user = services.LogIn(email, password).Result;
 
             if (user == null)
@@ -40,9 +48,10 @@ public IActionResult LogIn (string email, string password)
         [HttpGet]
         public IActionResult Movies(string email)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             return View("Movies", new UserXMovies()
             {
-                User = services.GetUser(email),
+                User = services.GetUser(email).Result,
                 Movies = services.GetMovies().Result
             });
         }
@@ -51,16 +60,18 @@ public IActionResult Movies(string email)
         [HttpGet]
         public IActionResult MoviesDetails(string email, string movieId)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             return View("MoviesDetails", new UserXMovie()
             {
-                User = services.GetUser(email),
+                User = services.GetUser(email).Result,
                 Movie = services.GetMovie(movieId,false).Result
             });
         }
 
         [HttpGet]
         public ActionResult DownloadMovie(string Id)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             string Tmp = AppDomain.CurrentDomain.BaseDirectory;
             Movie movie = services.GetMovie(Id, true).Result;
             return PhysicalFile(Tmp + movie.Id + movie.Video.GetType(), "video/avi", movie.Title);
@@ -69,6 +80,7 @@ public ActionResult DownloadMovie(string Id)
         [HttpPost]
         public IActionResult AddComment(string email, string movieId, string comment,int rate)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             services.AddComment(email, movieId, comment, rate);
             return MoviesDetails(email, movieId);
         }
@@ -77,6 +89,7 @@ public IActionResult AddComment(string email, string movieId, string comment,int
         [HttpPost]
         public IActionResult AddUser (User user)
         {
+            AWSServices services = new AWSServices(dynamoDBClient);
             if (ModelState.IsValid)
             {
                 User newUser =  services.Register(user).Result;

Controllers/HomeController.cs

@@ -12,26 +12,27 @@ namespace WebApplicationBeanstalk.Service
 {
     public class AWSServices
     {
-        AmazonDynamoDBClient Client;
-        DynamoDBContext Context;
         string Tmp = AppDomain.CurrentDomain.BaseDirectory;
-        RegionEndpoint BucketRegion = RegionEndpoint.USWest1;
+        RegionEndpoint Region = RegionEndpoint.CACentral1;
 
-        public AWSServices()
+        IAmazonDynamoDB dynamoDBClient { get; set; }
+
+        public AWSServices(IAmazonDynamoDB dynamoDBClient)
         {
-            Client = new AmazonDynamoDBClient(BucketRegion);
-            Context = new DynamoDBContext(Client);
+            this.dynamoDBClient = dynamoDBClient;
             CreateTable();
         }
         public async Task<User> Register(User user)
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
             await Context.SaveAsync(user, default(System.Threading.CancellationToken));
             User newUser = await Context.LoadAsync<User>(user.Email, default(System.Threading.CancellationToken));
             return user;
         }
 
         public async Task<User> LogIn(String email, String password)
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
             User userDB = await Context.LoadAsync<User>(email);
             if (userDB != null)
             {
@@ -45,39 +46,52 @@ public async Task<User> LogIn(String email, String password)
 
         public async Task<List<Movie>> GetMovies()
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
+
             var conditions = new List<ScanCondition>();
             List<Movie> movies= await Context.ScanAsync<Movie>(conditions).GetRemainingAsync();
             foreach(Movie movie in movies)
-                movie.Cover.DownloadTo(Tmp + movie.Id + movie.Cover.GetType());
+            {
+                //movie.Cover.DownloadTo(Tmp + movie.Id + movie.Cover.GetType());
+            }
+                
             return movies;
         }
 
         public async Task<Movie> GetMovie(string Id, Boolean WithVideo)
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
+
             Movie movie = await Context.LoadAsync<Movie>(Id, default(System.Threading.CancellationToken));
-            movie.Cover.DownloadTo(Tmp + movie.Id + movie.Cover.GetType());
+            //movie.Cover.DownloadTo(Tmp + movie.Id + movie.Cover.GetType());
             if (WithVideo)
-                movie.Video.DownloadTo(Tmp + movie.Id + movie.Video.GetType());
+            {
+                //movie.Video.DownloadTo(Tmp + movie.Id + movie.Video.GetType());
+            }
             return movie;
         }
 
         public async Task<Movie> UploadMovie(String bucketName, String Title, String VideoPath, String CoverPath)
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
+
             Movie movie = new Movie();
             movie.Id = System.Guid.NewGuid().ToString();
             movie.Title = Title;
-            movie.Cover = S3Link.Create(Context, bucketName, movie.Id + "1", BucketRegion);
-            movie.Video = S3Link.Create(Context, bucketName, movie.Id + "2", BucketRegion);
+            movie.Cover = S3Link.Create(Context, bucketName, movie.Id + "1", Region);
+            movie.Video = S3Link.Create(Context, bucketName, movie.Id + "2", Region);
 
-            movie.Cover.UploadFrom(CoverPath);
-            movie.Video.UploadFrom(VideoPath);
+            //movie.Cover.UploadFrom(CoverPath);
+            //movie.Video.UploadFrom(VideoPath);
 
             await Context.SaveAsync<Movie>(movie);
             return await GetMovie(movie.Id,false);
         }
 
         public async void AddComment(string email,string Id, String comment, int rate)
         {
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
+
             Movie movie = await GetMovie(Id, false);
             movie.Ratings.Add(new Rating()
             {
@@ -90,20 +104,23 @@ public async void AddComment(string email,string Id, String comment, int rate)
             await Context.SaveAsync<Movie>(movie);
         }
 
-        public User GetUser(string email)
+        public async Task<User> GetUser(string email)
         {
-            return Context.Load<User>(email);
+            DynamoDBContext Context = new DynamoDBContext(dynamoDBClient);
+
+            return await Context.LoadAsync<User>(email);
         }
 
 
         public void CreateTable()
         {
             String tableName = "User";
-            List<string> currentTables = Client.ListTables().TableNames;
+            Task<ListTablesResponse> table = dynamoDBClient.ListTablesAsync();
+            List<string> currentTables = table.Result.TableNames;
             bool tablesAdded = false;
             if (!currentTables.Contains(tableName))
             {
-                Client.CreateTableAsync(new CreateTableRequest
+                dynamoDBClient.CreateTableAsync(new CreateTableRequest
                 {
                     TableName = tableName,
                     ProvisionedThroughput = new ProvisionedThroughput { ReadCapacityUnits = 3, WriteCapacityUnits = 1 },
@@ -121,7 +138,7 @@ public void CreateTable()
                     },
                 });
 
-                Client.CreateTableAsync(new CreateTableRequest
+                dynamoDBClient.CreateTableAsync(new CreateTableRequest
                 {
                     TableName = "Movie",
                     ProvisionedThroughput = new ProvisionedThroughput { ReadCapacityUnits = 3, WriteCapacityUnits = 1 },
@@ -149,7 +166,7 @@ public void CreateTable()
                     allActive = true;
                     Thread.Sleep(TimeSpan.FromSeconds(5));
 
-                    TableStatus tableStatus = GetTableStatus(Client, tableName);
+                    TableStatus tableStatus = GetTableStatus(tableName);
                     if (!object.Equals(tableStatus, TableStatus.ACTIVE))
                         allActive = false;
 
@@ -158,11 +175,12 @@ public void CreateTable()
         }
 
 
-        private static TableStatus GetTableStatus(AmazonDynamoDBClient client, string tableName)
+        private TableStatus GetTableStatus(string tableName)
         {
             try
             {
-                var table = client.DescribeTable(new DescribeTableRequest { TableName = tableName }).Table;
+                Task<DescribeTableResponse> tableResp = dynamoDBClient.DescribeTableAsync(new DescribeTableRequest { TableName = tableName });
+                TableDescription table = tableResp.Result.Table;
                 return (table == null) ? null : table.TableStatus;
             }
             catch (AmazonDynamoDBException db)

Service/AWSServices.cs

@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
+using Amazon.DynamoDBv2;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Http;
@@ -30,8 +31,10 @@ public void ConfigureServices(IServiceCollection services)
                 options.MinimumSameSitePolicy = SameSiteMode.None;
             });
 
-
-            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
+                        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
+            services.AddDefaultAWSOptions(Configuration.GetAWSOptions());
+            //   services.AddAWSService<IAmazonS3>();
+            services.AddAWSService<IAmazonDynamoDB>();
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

Startup.cs

@@ -5,7 +5,10 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="AWSSDK" Version="2.3.55.2" />
+    <PackageReference Include="AWSSDK.Core" Version="3.5.1.29" />
+    <PackageReference Include="AWSSDK.DynamoDBv2" Version="3.5.1.7" />
+    <PackageReference Include="AWSSDK.Extensions.NETCore.Setup" Version="3.3.101" />
+    <PackageReference Include="AWSSDK.S3" Version="3.5.3.7" />
     <PackageReference Include="Microsoft.AspNetCore" Version="2.1.7" />
     <PackageReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="2.1.3" />

WebApplicationBeanstalk.csproj

@@ -1,8 +1,12 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Warning"
+    "Logging": {
+        "LogLevel": {
+            "Default": "Warning"
+        }
+    },
+    "AllowedHosts": "*",
+    "AWS": {
+        "Profile": "default",
+        "Region": "us-west-2"
     }
-  },
-  "AllowedHosts": "*"
 }

appsettings.json

@@ -25,6 +25,7 @@
       "WebApplicationBeanstalk/1.0.0": {
         "dependencies": {
           "AWSSDK.Core": "3.5.1.29",
+          "AWSSDK.DynamoDBv2": "3.5.1.7",
           "AWSSDK.Extensions.NETCore.Setup": "3.3.101",
           "AWSSDK.S3": "3.5.3.7",
           "Microsoft.AspNetCore": "2.1.7",
@@ -61,6 +62,20 @@
           "lib/netstandard2.0/AWSSDK.Core.dll": {}
         }
       },
+      "AWSSDK.DynamoDBv2/3.5.1.7": {
+        "dependencies": {
+          "AWSSDK.Core": "3.5.1.29"
+        },
+        "runtime": {
+          "lib/netstandard2.0/AWSSDK.DynamoDBv2.dll": {
+            "assemblyVersion": "3.3.0.0",
+            "fileVersion": "3.5.1.7"
+          }
+        },
+        "compile": {
+          "lib/netstandard2.0/AWSSDK.DynamoDBv2.dll": {}
+        }
+      },
       "AWSSDK.Extensions.NETCore.Setup/3.3.101": {
         "dependencies": {
           "AWSSDK.Core": "3.5.1.29",
@@ -3732,6 +3747,13 @@
       "path": "awssdk.core/3.5.1.29",
       "hashPath": "awssdk.core.3.5.1.29.nupkg.sha512"
     },
+    "AWSSDK.DynamoDBv2/3.5.1.7": {
+      "type": "package",
+      "serviceable": true,
+      "sha512": "sha512-KWn440NkYevyp0UVloZnhhTxfYypqwQmIlrrjBnYeChhYg9oGQIPxmP3a9KNTOyLZMXc8lbJrxcJm/DpnR3xwA==",
+      "path": "awssdk.dynamodbv2/3.5.1.7",
+      "hashPath": "awssdk.dynamodbv2.3.5.1.7.nupkg.sha512"
+    },
     "AWSSDK.Extensions.NETCore.Setup/3.3.101": {
       "type": "package",
       "serviceable": true,

bin/Debug/netcoreapp2.1/WebApplicationBeanstalk.Views.dll

@@ -1,8 +1,12 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Warning"
+    "Logging": {
+        "LogLevel": {
+            "Default": "Warning"
+        }
+    },
+    "AllowedHosts": "*",
+    "AWS": {
+        "Profile": "default",
+        "Region": "us-west-2"
     }
-  },
-  "AllowedHosts": "*"
 }