Merge pull request #403 from SalleeMatthew:Add-Account-Removal

Add Account Removal

Author: smile0711

api/db/migrations/20260415085031_object_instance_member_id_nullable.ts

@@ -0,0 +1,29 @@
+import { Knex } from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+  await knex.schema.alterTable('object_instance', table => {
+    table.dropForeign(['member_id']);
+  });
+
+  await knex.schema.alterTable('object_instance', table => {
+    table.integer('member_id').unsigned().nullable().alter();
+  });
+
+  await knex.schema.alterTable('object_instance', table => {
+    table.foreign('member_id').references('member.id');
+  });
+}
+
+export async function down(knex: Knex): Promise<void> {
+  await knex.schema.alterTable('object_instance', table => {
+    table.dropForeign(['member_id']);
+  });
+
+  await knex.schema.alterTable('object_instance', table => {
+    table.integer('member_id').unsigned().notNullable().alter();
+  });
+
+  await knex.schema.alterTable('object_instance', table => {
+    table.foreign('member_id').references('member.id');
+  });
+}

api/db/migrations/20260418001708_object_member_id_nullable.ts

@@ -0,0 +1,30 @@
+import { Knex } from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+  await knex.schema.alterTable('object', table => {
+    table.dropForeign(['member_id']);
+  });
+
+  await knex.schema.alterTable('object', table => {
+    table.integer('member_id').unsigned().nullable().alter();
+  });
+
+  await knex.schema.alterTable('object', table => {
+    table.foreign('member_id').references('member.id');
+  });
+}
+
+export async function down(knex: Knex): Promise<void> {
+  await knex.schema.alterTable('object', table => {
+    table.dropForeign(['member_id']);
+  });
+
+  await knex.schema.alterTable('object', table => {
+    table.integer('member_id').unsigned().notNullable().alter();
+  });
+
+  await knex.schema.alterTable('object', table => {
+    table.foreign('member_id').references('member.id');
+  });
+}
+

api/src/controllers/avatar.controller.ts

@@ -38,6 +38,17 @@ class AvatarController {
     }
   }
 
+  public async removeAllAvatars(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.avatarService.removeAllAvatars(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error remvoing avatars.'});
+    }
+  }
+
    public async add(request, response: Response): Promise<void> {
     let fileExtension;
     const { apitoken } = request.headers;

api/src/controllers/club.controller.ts

@@ -246,6 +246,17 @@ class ClubController {
     }
   }
 
+  public async removeAccount(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.clubService.removeAccount(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error moving objects.'});
+    }
+  }
+
   public async searchClubs(request: Request, response: Response): Promise<void> {
     const session = this.memberService.decryptSession(request, response);
     if (!session) {

api/src/controllers/home.controller.ts

@@ -30,7 +30,7 @@ class HomeController {
 
       const { username } = request.params;
 
-      if(username) {
+      if(username && username !== 'undefined') {
         const user = await this.memberService.find({
           username: username,
         });

api/src/controllers/inbox.controller.ts

@@ -309,6 +309,17 @@ class InboxController {
       });
     }
   }
+
+  public async removeAllMessages(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.inboxService.removeAllMessages(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error removing inbox messages.'});
+    }
+  }
 
   public async deleteInboxMessage(request: Request, response: Response): Promise<void> {
     const placeId = Number.parseInt(request.body.place_id);

api/src/controllers/member.controller.ts

@@ -191,6 +191,20 @@ class MemberController {
     }
   }
 
+  public async removeAccount(request: Request, response: Response): Promise<void> {
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    const { id } = session;
+    try {
+      await this.memberService.removeAccount(id);
+      response.status(200).json({ message: 'success' });
+    } catch (error) {
+      response.status(400).json({
+        error: 'Error Removing Account',
+      });
+    }
+  }
+
   /** isBanned results based on member status
    * 1 = active
    * 0 = banned

api/src/controllers/message.controller.ts

@@ -87,6 +87,17 @@ class MessageController {
     }
   }
 
+public async removeAllMessages(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.messageService.removeAllMessages(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error remvoing messages.'});
+    }
+  }
+
   /** delete a message from the chat **/
   public async deleteMessage(request: Request, response: Response): Promise<void> {
     const { apitoken } = request.headers;

api/src/controllers/messageboard.controller.ts

@@ -119,6 +119,17 @@ class MessageboardController {
       });
     }
   }
+
+  public async removeAllMessages(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.messageboardService.removeAllMessages(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error removing messageboard messages.'});
+    }
+  }
 
   public async getMessageboardMessages(request: Request, response: Response): Promise<void> {
     const placeId = Number.parseInt(request.body.place_id);

api/src/controllers/object-instance.controller.ts

@@ -235,6 +235,47 @@ class ObjectInstanceController {
     }
   }
 
+  public async moveAllObjects(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      await this.objectInstanceService.moveAllObjects(session.id);
+      response.status(200).json({ status: 'success' });
+    } catch {
+      response.status(400).json({error: 'Error moving objects.'});
+    }
+  }
+
+  public async updateObjectOwner(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      const username = request.body.username;
+      const objects = request.body.id;
+      const userId = await this.memberService.getMemberId(username);
+      if(!userId){
+        throw new Error('Username not found.')
+      }
+      for (const obj of objects) {
+        await this.objectInstanceService.updateObjectOwner(obj, userId[0].id);
+      }
+      response.status(200).json({ status: 'success' });
+    } catch (error) {
+      response.status(400).json({error: error});
+    }
+  }
+
+  public async seizedObjects(request: Request, response: Response):  Promise<void>{
+    const session = this.memberService.decryptSession(request, response);
+    if (!session) return;
+    try {
+      const seizedObjects = await this.objectInstanceService.seizedObjects();
+      response.status(200).json({ objects: seizedObjects });
+    } catch {
+      response.status(400).json({error: 'Error moving objects.'});
+    }
+  }
+
   public async pickUpObjectInstance(request: Request, response: Response): Promise<void> {
     const session = this.memberService.decryptSession(request, response);
     if (!session) return;