update notifications

Author: The-DevBlog

devblog/devblog/Controllers/AccountsController.cs

@@ -18,11 +18,13 @@ public class AccountsController : ControllerBase
         public SignInManager<User> _signInMgr { get; }
         public UserManager<User> _userMgr { get; }
         public IConfiguration _config;
+        private readonly INotificationService _notifications;
         private readonly IUsernameService _username;
         private readonly IEmailService _email;
 
-        public AccountsController(SignInManager<User> signInMgr, UserManager<User> usermgr, IConfiguration config, IUsernameService username, IEmailService email)
+        public AccountsController(INotificationService notifications, SignInManager<User> signInMgr, UserManager<User> usermgr, IConfiguration config, IUsernameService username, IEmailService email)
         {
+            _notifications = notifications;
             _userMgr = usermgr;
             _signInMgr = signInMgr;
             _config = config;
@@ -78,13 +80,6 @@ public async Task<List<UserInfo>> GetUsers()
             return users;
         }
 
-        public class UserInfo
-        {
-            public string? UserName { get; set; }
-            public string? Email { get; set; }
-            public bool Subscribed { get; set; }
-        }
-
         /// <summary>
         /// Delete an account
         /// </summary>
@@ -99,7 +94,8 @@ public async Task<IActionResult> DeleteAccount()
 
             if (user != null)
             {
-                // sign current user out and delete account
+                // sign current user out and delete account & notifications
+                await _notifications.DeleteAllForUser(username);
                 await _signInMgr.SignOutAsync();
                 await _userMgr.DeleteAsync(user);
                 return Ok();
@@ -116,6 +112,7 @@ public async Task AdminDeleteAccount(string username)
 
             if (user != null)
             {
+                await _notifications.DeleteAllForUser(username);
                 await _userMgr.DeleteAsync(user);
             }
         }
@@ -264,5 +261,12 @@ private async Task<List<Claim>> GenerateClaims(User user)
 
             return claims;
         }
+
+        public class UserInfo
+        {
+            public string? UserName { get; set; }
+            public string? Email { get; set; }
+            public bool Subscribed { get; set; }
+        }
     }
 }

devblog/devblog/Interfaces/INotificationService.cs

@@ -26,5 +26,11 @@ public interface INotificationService
         /// </summary>
         /// <param name="postId"></param>
         Task DeleteAllForPost(int postId);
+
+        /// <summary>
+        /// Delete all notifications for a specified user
+        /// </summary>
+        /// <param name="username"></param>
+        Task DeleteAllForUser(string username);
     }
 }

devblog/devblog/Services/NotificationService.cs

@@ -45,7 +45,7 @@ public async Task Create(int PostId)
         /// <returns>List<Notification></returns>
         public async Task<List<Notification>> Get(string userName)
         {
-            var notifications = await _db.Notification.Where(n => n.UserName == userName).ToListAsync();
+            var notifications = await _db.Notification.Where(n => n.UserName.ToLower() == userName.ToLower()).ToListAsync();
             return notifications;
         }
 
@@ -69,5 +69,16 @@ public async Task DeleteAllForPost(int postId)
             notifications.ForEach(n => _db.Remove(n));
             await _db.SaveChangesAsync();
         }
+
+        /// <summary>
+        /// Delete all notifications for a specified user
+        /// </summary>
+        /// <param name="username"></param>
+        public async Task DeleteAllForUser(string username)
+        {
+            var notifications = await _db.Notification.Where(n => n.UserName.ToLower() == username.ToLower()).ToListAsync();
+            notifications.ForEach(n => _db.Remove(n));
+            await _db.SaveChangesAsync();
+        }
     }
 }

devblog/devblog/client/src/helpers.rs

@@ -48,6 +48,10 @@ pub fn on_click(
     });
 }
 
+pub fn clear_user_data(dispatch: Dispatch<Store>) {
+    dispatch.reduce(|_| Store::default().into());
+}
+
 pub fn set_user_data(dispatch: Dispatch<Store>, store: Store) {
     dispatch.reduce_mut(move |s| {
         s.token = store.token;
@@ -86,6 +90,7 @@ pub fn on_submit(
             if let Some(res) = api.fetch(Some(hdrs), body, Method::POST).await {
                 if res.status() == 200 {
                     let obj: Store = serde_json::from_str(&res.text().await.unwrap()).unwrap();
+                    log!("FIX ME");
                     set_user_data(dispatch, obj);
                     nav.push(&Route::Home);
                 }

devblog/devblog/client/src/pages/sign_out.rs

@@ -14,8 +14,14 @@ pub fn sign_out() -> Html {
     let nav = use_navigator().unwrap();
     let (_, dispatch) = use_store::<Store>();
 
+    let sign_out = {
+        helpers::clear_user_data(dispatch.clone());
+        helpers::on_submit(&user, nav, Rc::new(Api::SignOut), dispatch)
+    };
+
     html! {
-            <form class={style} onsubmit={helpers::on_submit(&user, nav, Rc::new(Api::SignOut), dispatch)}>
+            // <form class={style} onsubmit={helpers::on_submit(&user, nav, Rc::new(Api::SignOut), dispatch)}>
+            <form class={style} onsubmit={sign_out}>
                 <button class="logout">{"Logout"}</button>
             </form>
     }