feat: added fetchUserSettings for
This commit is contained in:
@@ -220,4 +220,10 @@ export const BUG_TEAM_ENV_GUARD_NO_ENV_ID =
|
|||||||
* User settings update failed
|
* User settings update failed
|
||||||
* (UserSettingsService)
|
* (UserSettingsService)
|
||||||
*/
|
*/
|
||||||
export const USER_SETTINGS_UPDATE_FAILED = 'user_settings/update_failed' as const;
|
export const USER_SETTINGS_UPDATE_FAILED = 'user_settings/update_failed' as const;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* User settings not found
|
||||||
|
* (UserSettingsService)
|
||||||
|
*/
|
||||||
|
export const USER_SETTINGS_NOT_FOUND = 'user_settings/not_found' as const;
|
||||||
|
|||||||
@@ -1,11 +1,17 @@
|
|||||||
import { Module } from '@nestjs/common';
|
import { Module } from '@nestjs/common';
|
||||||
import { PrismaModule } from 'src/prisma/prisma.module';
|
import { PrismaModule } from 'src/prisma/prisma.module';
|
||||||
import { PubSubModule } from 'src/pubsub/pubsub.module';
|
import { PubSubModule } from 'src/pubsub/pubsub.module';
|
||||||
|
import { UserModule } from 'src/user/user.module';
|
||||||
import { UserSettingsResolver } from './user-settings.resolver';
|
import { UserSettingsResolver } from './user-settings.resolver';
|
||||||
import { UserSettingsService } from './user-settings.service';
|
import { UserSettingsService } from './user-settings.service';
|
||||||
|
import { UserSettingsUserResolver } from './user.resolver';
|
||||||
|
|
||||||
@Module({
|
@Module({
|
||||||
imports: [PrismaModule, PubSubModule],
|
imports: [PrismaModule, PubSubModule, UserModule],
|
||||||
providers: [UserSettingsResolver, UserSettingsService],
|
providers: [
|
||||||
|
UserSettingsResolver,
|
||||||
|
UserSettingsService,
|
||||||
|
UserSettingsUserResolver,
|
||||||
|
],
|
||||||
})
|
})
|
||||||
export class UserSettingsModule {}
|
export class UserSettingsModule {}
|
||||||
|
|||||||
@@ -5,7 +5,10 @@ import { User } from 'src/user/user.model';
|
|||||||
import * as E from 'fp-ts/Either';
|
import * as E from 'fp-ts/Either';
|
||||||
import { stringToJson } from 'src/utils';
|
import { stringToJson } from 'src/utils';
|
||||||
import { UserSettings } from './user-settings.model';
|
import { UserSettings } from './user-settings.model';
|
||||||
import { USER_SETTINGS_UPDATE_FAILED } from 'src/errors';
|
import {
|
||||||
|
USER_SETTINGS_NOT_FOUND,
|
||||||
|
USER_SETTINGS_UPDATE_FAILED,
|
||||||
|
} from 'src/errors';
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class UserSettingsService {
|
export class UserSettingsService {
|
||||||
@@ -14,6 +17,26 @@ export class UserSettingsService {
|
|||||||
private readonly pubsub: PubSubService,
|
private readonly pubsub: PubSubService,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
|
async fetchUserSettings(user: User) {
|
||||||
|
try {
|
||||||
|
const dbUserSettings = await this.prisma.userSettings.findUnique({
|
||||||
|
where: { userUid: user.uid },
|
||||||
|
rejectOnNotFound: true,
|
||||||
|
});
|
||||||
|
|
||||||
|
const userSettings: UserSettings = {
|
||||||
|
id: dbUserSettings.id,
|
||||||
|
userUid: dbUserSettings.userUid,
|
||||||
|
properties: JSON.stringify(dbUserSettings.properties),
|
||||||
|
updatedOn: dbUserSettings.updatedOn,
|
||||||
|
};
|
||||||
|
|
||||||
|
return E.right(userSettings);
|
||||||
|
} catch (e) {
|
||||||
|
return E.left(USER_SETTINGS_NOT_FOUND);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async createUserSettings(user: User, properties: string) {
|
async createUserSettings(user: User, properties: string) {
|
||||||
const jsonProperties = stringToJson(properties);
|
const jsonProperties = stringToJson(properties);
|
||||||
if (E.isLeft(jsonProperties)) return E.left(jsonProperties.left);
|
if (E.isLeft(jsonProperties)) return E.left(jsonProperties.left);
|
||||||
|
|||||||
@@ -0,0 +1,21 @@
|
|||||||
|
import { Parent, ResolveField, Resolver } from '@nestjs/graphql';
|
||||||
|
import { User } from 'src/user/user.model';
|
||||||
|
import { UserSettings } from './user-settings.model';
|
||||||
|
import { UserSettingsService } from './user-settings.service';
|
||||||
|
import * as E from 'fp-ts/Either';
|
||||||
|
import { throwErr } from 'src/utils';
|
||||||
|
|
||||||
|
@Resolver(() => User)
|
||||||
|
export class UserSettingsUserResolver {
|
||||||
|
constructor(private readonly userSettingsService: UserSettingsService) {}
|
||||||
|
|
||||||
|
@ResolveField(() => UserSettings, {
|
||||||
|
description: 'Returns user settings',
|
||||||
|
})
|
||||||
|
async settings(@Parent() user: User): Promise<UserSettings | string> {
|
||||||
|
const userSettings = await this.userSettingsService.fetchUserSettings(user);
|
||||||
|
|
||||||
|
if (E.isLeft(userSettings)) throwErr(userSettings.left);
|
||||||
|
return userSettings.right;
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user