add tests, profile changes

Author: tompscanlan

package-lock.json

@@ -52,6 +52,7 @@
   },
   "dependencies": {
     "@atproto/api": "^0.13.31",
+    "@atproto/identity": "^0.4.7",
     "@atproto/jwk-jose": "^0.1.2",
     "@atproto/oauth-client-node": "^0.2.3",
     "@aws-sdk/client-s3": "3.651.1",

package.json

@@ -7,12 +7,18 @@ import {
   Param,
   Req,
   Logger,
+  HttpException,
+  HttpStatus,
+  NotFoundException,
 } from '@nestjs/common';
 import { BlueskyService } from './bluesky.service';
 import { JWTAuthGuard } from '../auth/auth.guard';
 import { ApiTags, ApiOperation, ApiBearerAuth } from '@nestjs/swagger';
 import { UserEntity } from '../user/infrastructure/persistence/relational/entities/user.entity';
 import { AuthUser } from '../core/decorators/auth-user.decorator';
+import { RoleEnum } from '../role/role.enum';
+import { Public } from '../auth/decorators/public.decorator';
+import { UserService } from '../user/user.service';
 
 @ApiTags('Bluesky')
 @Controller('bluesky')
@@ -21,7 +27,10 @@ import { AuthUser } from '../core/decorators/auth-user.decorator';
 export class BlueskyController {
   private readonly logger = new Logger(BlueskyController.name);
 
-  constructor(private readonly blueskyService: BlueskyService) {}
+  constructor(
+    private readonly blueskyService: BlueskyService,
+    private readonly userService: UserService,
+  ) {}
 
   @Post('connect')
   @ApiOperation({ summary: 'Enable Bluesky event source' })
@@ -41,9 +50,108 @@ export class BlueskyController {
     return this.blueskyService.getConnectionStatus(user);
   }
 
+  @Get('profile')
+  @ApiOperation({
+    summary: 'Get enhanced ATProtocol profile for the current user',
+  })
+  async getCurrentUserProfile(@AuthUser() user: UserEntity, @Req() req) {
+    try {
+      if (
+        !user.preferences?.bluesky?.did &&
+        !user.preferences?.bluesky?.handle
+      ) {
+        return {
+          connected: false,
+          message: 'No ATProtocol account connected',
+        };
+      }
+
+      return await this.blueskyService.getEnhancedProfile(user, req.tenantId);
+    } catch (error) {
+      this.logger.error('Error fetching current user ATProtocol profile', {
+        error: error.message,
+        stack: error.stack,
+        userId: user.id,
+      });
+
+      throw new HttpException(
+        error.message || 'Failed to fetch profile',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
+
+  @Public()
+  @Get('profile/:identifier')
+  @ApiOperation({ summary: 'Get public ATProtocol profile by DID or handle' })
+  async getPublicProfile(@Param('identifier') identifier: string) {
+    try {
+      this.logger.debug(`Public profile lookup for: ${identifier}`);
+      return await this.blueskyService.getPublicProfile(identifier);
+    } catch (error) {
+      this.logger.error('Error fetching public ATProtocol profile', {
+        error: error.message,
+        stack: error.stack,
+        identifier,
+      });
+
+      throw new HttpException(
+        error.message || 'Failed to fetch profile',
+        HttpStatus.NOT_FOUND,
+      );
+    }
+  }
+
+  @Get('user-profile/:slug')
+  @ApiOperation({
+    summary: 'Get ATProtocol profile for a specific OpenMeet user by slug',
+  })
+  async getUserProfile(
+    @Param('slug') slug: string,
+    @Req() req,
+    @AuthUser() currentUser: UserEntity,
+  ) {
+    try {
+      const user = await this.userService.findBySlug(slug, req.tenantId);
+
+      if (!user) {
+        throw new NotFoundException(`User with slug ${slug} not found`);
+      }
+
+      // Only allow viewing full profile details if admin or the user themselves
+      const isAdmin = currentUser.role?.name === RoleEnum.Admin;
+      const isSelf = currentUser.id === user.id;
+
+      if (!isAdmin && !isSelf) {
+        return {
+          message: 'User profile basics only',
+          // Return minimal public info
+          handle: user.preferences?.bluesky?.handle,
+          connected: !!user.preferences?.bluesky?.connected,
+        };
+      }
+
+      return await this.blueskyService.getEnhancedProfile(user, req.tenantId);
+    } catch (error) {
+      this.logger.error('Error fetching ATProtocol profile for user', {
+        error: error.message,
+        stack: error.stack,
+        slug,
+      });
+
+      if (error instanceof NotFoundException) {
+        throw error;
+      }
+
+      throw new HttpException(
+        error.message || 'Failed to fetch profile',
+        HttpStatus.INTERNAL_SERVER_ERROR,
+      );
+    }
+  }
+
   @Get('events/:did')
   @ApiOperation({ summary: 'List Bluesky events' })
-  @UseGuards(JWTAuthGuard)
   async listEvents(@Req() req, @Param('did') did: string) {
     return await this.blueskyService.listEvents(did, req.tenantId);
   }
@@ -61,4 +169,28 @@ export class BlueskyController {
       req.tenantId,
     );
   }
+
+  @Post('session/reset/:did')
+  @ApiOperation({ summary: 'Reset a Bluesky session' })
+  async resetSession(
+    @Param('did') did: string,
+    @Req() req,
+    @AuthUser() user: UserEntity,
+  ) {
+    this.logger.log(`Request to reset Bluesky session for DID: ${did}`);
+
+    // Check if user owns this DID or has admin permissions
+    const isOwner = user.preferences?.bluesky?.did === did;
+    const isAdmin = user.role?.name === RoleEnum.Admin;
+
+    if (!isOwner && !isAdmin) {
+      return {
+        success: false,
+        message: 'You do not have permission to reset this session',
+      };
+    }
+
+    // Use the service method to reset the session
+    return await this.blueskyService.resetSession(did, req.tenantId);
+  }
 }