list users api impl

Author: coderookie1994

src/Microstack.API/Abstractions/IUserService.cs

@@ -10,5 +10,6 @@ public interface IUserService
     {
         public Task<IList<Profile>> GetProfiles(string userId);
         public Task PersistProfile(string userId, Profile profile);
+        Task<IReadOnlyList<string>> GetUsers();
     }
 }

src/Microstack.API/Controllers/UsersController.cs

@@ -20,6 +20,9 @@ public UsersController(IUserService userService)
             _userService = userService;
         }
 
+        [HttpGet]
+        public async Task<IActionResult> Get() => Ok(await _userService.GetUsers());
+
         [HttpGet("{userId}")]
         public async Task<IActionResult> Get(string userId)
         {

src/Microstack.API/Services/UserService.cs

@@ -24,6 +24,11 @@ public async Task<IList<Profile>> GetProfiles(string userId)
             return profiles.MapFromPersistenceModel();
         }
 
+        public Task<IReadOnlyList<string>> GetUsers()
+        {
+            return _persistenceProvider.GetUsers();
+        }
+
         public async Task PersistProfile(string userId, Profile profile)
         {
             await _persistenceProvider.PersistProfile(userId, profile.MapToRepositoryModel());

src/Microstack.CLI/Commands/SubCommands/Users.cs

@@ -36,15 +36,6 @@ public class Users : BaseCommand
             ValueName = "UserId")]
         public string UserId { get; set; }
 
-        [Option(
-            CommandOptionType.NoValue,
-            Description = "List user profiles",
-            LongName = "profiles",
-            ShortName = "p",
-            ShowInHelpText = true
-            )]
-        public bool ShowProfiles { get; set; }
-
         [Option(
             CommandOptionType.SingleValue,
             Description = "Add API Url",
@@ -84,32 +75,44 @@ protected override async Task<int> OnExecute(CommandLineApplication app)
 
             if (!string.IsNullOrWhiteSpace(UserId))
             {
-                if (ShowProfiles)
+
+                using (var client = new HttpClient())
                 {
-                    using (var client = new HttpClient())
+                    client.BaseAddress = new Uri(settings);
+                    try
+                    {
+                        var response = await (await client.GetAsync($"/api/users/{UserId}")).Content.ReadAsStringAsync();
+                        var formattedJson = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(response), Formatting.Indented);
+                        OuputToConsole(formattedJson);
+                        return 0;
+                    }
+                    catch (Exception ex)
                     {
-                        client.BaseAddress = new Uri(settings);
-                        try
-                        {
-                            var response = await (await client.GetAsync($"/api/users/{UserId}")).Content.ReadAsStringAsync();
-                            var formattedJson = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(response), Formatting.Indented);
-                            OuputToConsole(formattedJson);
-                            return 0;
-                        }
-                        catch (Exception ex)
-                        {
-                            OutputError($"Error occurred while connecting to api {ex.Message}");
-                            return 1;
-                        }
+                        OutputError($"Error occurred while connecting to api {ex.Message}");
+                        return 1;
                     }
                 }
-                else
+            }
+            if (All)
+            {
+                using (var client = new HttpClient())
                 {
-                    app.ShowHelp();
-                    return 1;
+                    client.BaseAddress = new Uri(settings);
+                    try
+                    {
+                        var response = await (await client.GetAsync($"/api/users")).Content.ReadAsStringAsync();
+                        var formattedJson = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(response), Formatting.Indented);
+                        OuputToConsole(formattedJson);
+                        return 0;
+                    }
+                    catch (Exception ex)
+                    {
+                        OutputError($"Error occurred while connecting to api {ex.Message}");
+                        return 1;
+                    }
                 }
             }
-
+            
             app.ShowHelp();
             return 0;
         }

src/Microstack.Repository/Abstractions/IPersistenceProvider.cs

@@ -10,5 +10,6 @@ public interface IPersistenceProvider
     {
         Task<List<Profile>> GetProfilesForUser(string userId);
         Task PersistProfile(string userId, Profile profile);
+        Task<IReadOnlyList<string>> GetUsers();
     }
 }

src/Microstack.Repository/Providers/MongoProvider.cs

@@ -34,5 +34,12 @@ public async Task PersistProfile(string userId, Profile profile)
 
             await userProfiles.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true });
         }
+
+        public async Task<IReadOnlyList<string>> GetUsers()
+        {
+            var userProfiles = _database.GetCollection<User>("user.profiles");
+            var users = await (userProfiles.Find(FilterDefinition<User>.Empty).Project(f => f.UserId).ToListAsync());
+            return users;
+        }
     }
 }