ghostfolio/apps/client/src/app/components/admin-users/admin-users.component.ts

import {
  UserDetailDialogParams,
  UserDetailDialogResult
} from '@ghostfolio/client/components/user-detail-dialog/interfaces/interfaces';
import { GfUserDetailDialogComponent } from '@ghostfolio/client/components/user-detail-dialog/user-detail-dialog.component';
import { ImpersonationStorageService } from '@ghostfolio/client/services/impersonation-storage.service';
import { UserService } from '@ghostfolio/client/services/user/user.service';
import { DEFAULT_LOCALE, DEFAULT_PAGE_SIZE } from '@ghostfolio/common/config';
import { ConfirmationDialogType } from '@ghostfolio/common/enums';
import {
  canDeleteUser,
  getCountryName,
  getDateFnsLocale,
  getDateFormatString,
  getEmojiFlag
} from '@ghostfolio/common/helper';
import {
  AdminUsersResponse,
  InfoItem,
  User
} from '@ghostfolio/common/interfaces';
import { hasPermission, permissions } from '@ghostfolio/common/permissions';
import { internalRoutes } from '@ghostfolio/common/routes/routes';
import { NotificationService } from '@ghostfolio/ui/notifications';
import { GfPremiumIndicatorComponent } from '@ghostfolio/ui/premium-indicator';
import { AdminService, DataService } from '@ghostfolio/ui/services';
import { GfValueComponent } from '@ghostfolio/ui/value';

import { CommonModule } from '@angular/common';
import {
  ChangeDetectionStrategy,
  ChangeDetectorRef,
  Component,
  computed,
  DestroyRef,
  inject,
  OnInit,
  viewChild
} from '@angular/core';
import { takeUntilDestroyed } from '@angular/core/rxjs-interop';
import { MatButtonModule } from '@angular/material/button';
import { MatDialog } from '@angular/material/dialog';
import { MatMenuModule } from '@angular/material/menu';
import {
  MatPaginator,
  MatPaginatorModule,
  PageEvent
} from '@angular/material/paginator';
import { MatTableDataSource, MatTableModule } from '@angular/material/table';
import { ActivatedRoute, Router, RouterModule } from '@angular/router';
import { IonIcon } from '@ionic/angular/standalone';
import {
  differenceInSeconds,
  formatDistanceToNowStrict,
  parseISO
} from 'date-fns';
import { addIcons } from 'ionicons';
import {
  contractOutline,
  ellipsisHorizontal,
  keyOutline,
  personOutline,
  trashOutline
} from 'ionicons/icons';
import ms from 'ms';
import { DeviceDetectorService } from 'ngx-device-detector';
import { NgxSkeletonLoaderModule } from 'ngx-skeleton-loader';
import { interval } from 'rxjs';
import { switchMap, tap } from 'rxjs/operators';

@Component({
  changeDetection: ChangeDetectionStrategy.OnPush,
  imports: [
    CommonModule,
    GfPremiumIndicatorComponent,
    GfValueComponent,
    IonIcon,
    MatButtonModule,
    MatMenuModule,
    MatPaginatorModule,
    MatTableModule,
    NgxSkeletonLoaderModule,
    RouterModule
  ],
  selector: 'gf-admin-users',
  styleUrls: ['./admin-users.scss'],
  templateUrl: './admin-users.html'
})
export class GfAdminUsersComponent implements OnInit {
  protected dataSource = new MatTableDataSource<
    AdminUsersResponse['users'][0]
  >();
  protected defaultDateFormat: string;
  protected displayedColumns: string[] = [];
  protected readonly canDeleteUser = canDeleteUser;
  protected readonly getCountryName = getCountryName;
  protected readonly getEmojiFlag = getEmojiFlag;
  protected hasPermissionForSubscription: boolean;
  protected hasPermissionToImpersonateAllUsers: boolean;
  protected info: InfoItem;
  protected isLoading = false;
  protected readonly pageSize = DEFAULT_PAGE_SIZE;
  protected readonly routerLinkAdminControlUsers =
    internalRoutes.adminControl.subRoutes.users.routerLink;
  protected totalItems = 0;
  protected user: User;

  private readonly deviceType = computed(
    () => this.deviceDetectorService.deviceInfo().deviceType
  );
  private readonly paginator = viewChild.required(MatPaginator);

  private readonly adminService = inject(AdminService);
  private readonly changeDetectorRef = inject(ChangeDetectorRef);
  private readonly dataService = inject(DataService);
  private readonly destroyRef = inject(DestroyRef);
  private readonly deviceDetectorService = inject(DeviceDetectorService);
  private readonly dialog = inject(MatDialog);
  private readonly impersonationStorageService = inject(
    ImpersonationStorageService
  );
  private readonly notificationService = inject(NotificationService);
  private readonly route = inject(ActivatedRoute);
  private readonly router = inject(Router);
  private readonly userService = inject(UserService);

  public constructor() {
    this.info = this.dataService.fetchInfo();

    this.hasPermissionForSubscription = hasPermission(
      this.info?.globalPermissions,
      permissions.enableSubscription
    );

    if (this.hasPermissionForSubscription) {
      this.displayedColumns = [
        'user',
        'country',
        'registration',
        'accounts',
        'activities',
        'engagementPerDay',
        'dailyApiRequests',
        'lastRequest',
        'actions'
      ];
    } else {
      this.displayedColumns = [
        'user',
        'registration',
        'accounts',
        'activities',
        'actions'
      ];
    }

    this.userService.stateChanged
      .pipe(
        takeUntilDestroyed(this.destroyRef),
        tap((state) => {
          if (state?.user) {
            this.user = state.user;

            this.defaultDateFormat = getDateFormatString(
              this.user.settings.locale
            );

            this.hasPermissionToImpersonateAllUsers = hasPermission(
              this.user.permissions,
              permissions.impersonateAllUsers
            );

            this.changeDetectorRef.markForCheck();
          }
        }),
        switchMap(() => this.route.paramMap)
      )
      .subscribe((params) => {
        const userId = params.get('userId');

        if (userId) {
          this.openUserDetailDialog(userId);
        }
      });

    addIcons({
      contractOutline,
      ellipsisHorizontal,
      keyOutline,
      personOutline,
      trashOutline
    });
  }

  public ngOnInit() {
    this.fetchUsers();

    interval(ms('30 seconds'))
      .pipe(takeUntilDestroyed(this.destroyRef))
      .subscribe(() => {
        this.fetchUsers({
          pageIndex: this.paginator().pageIndex,
          showLoading: false
        });

        this.changeDetectorRef.markForCheck();
      });
  }

  protected formatDistanceToNow(aDateString: string) {
    if (aDateString) {
      const distanceString = formatDistanceToNowStrict(parseISO(aDateString), {
        addSuffix: true,
        locale: getDateFnsLocale(this.user?.settings?.language)
      });

      return Math.abs(differenceInSeconds(parseISO(aDateString), new Date())) <
        60
        ? $localize`just now`
        : distanceString;
    }

    return '';
  }

  protected onChangePage(page: PageEvent) {
    this.fetchUsers({
      pageIndex: page.pageIndex
    });
  }

  protected onDeleteUser(aId: string) {
    this.notificationService.confirm({
      confirmFn: () => {
        this.dataService
          .deleteUser(aId)
          .pipe(takeUntilDestroyed(this.destroyRef))
          .subscribe(() => {
            this.router.navigate(['..'], { relativeTo: this.route });
          });
      },
      confirmType: ConfirmationDialogType.Warn,
      discardFn: () => {
        this.router.navigate(['..'], { relativeTo: this.route });
      },
      title: $localize`Do you really want to delete this user?`
    });
  }

  protected onGenerateAccessToken(aUserId: string) {
    this.notificationService.confirm({
      confirmFn: () => {
        this.dataService
          .updateUserAccessToken(aUserId)
          .pipe(takeUntilDestroyed(this.destroyRef))
          .subscribe(({ accessToken }) => {
            this.notificationService.alert({
              discardFn: () => {
                if (aUserId === this.user.id) {
                  this.userService.signOut();

                  document.location.href = `/${document.documentElement.lang}`;
                }
              },
              message: accessToken,
              title: $localize`Security token`
            });
          });
      },
      confirmType: ConfirmationDialogType.Warn,
      title: $localize`Do you really want to generate a new security token for this user?`
    });
  }

  protected onImpersonateUser(aId: string) {
    if (aId) {
      this.impersonationStorageService.setId(aId);
    } else {
      this.impersonationStorageService.removeId();
    }

    window.location.reload();
  }

  protected onOpenUserDetailDialog(userId: string) {
    this.router.navigate(
      internalRoutes.adminControl.subRoutes.users.routerLink.concat(userId)
    );
  }

  private fetchUsers({
    pageIndex = 0,
    showLoading = true
  }: { pageIndex?: number; showLoading?: boolean } = {}) {
    if (showLoading) {
      this.isLoading = true;
    }

    if (pageIndex === 0 && this.paginator()) {
      this.paginator().pageIndex = 0;
    }

    this.adminService
      .fetchUsers({
        skip: pageIndex * this.pageSize,
        take: this.pageSize
      })
      .pipe(takeUntilDestroyed(this.destroyRef))
      .subscribe(({ count, users }) => {
        this.dataSource.data = users;
        this.totalItems = count;

        this.isLoading = false;

        this.changeDetectorRef.markForCheck();
      });
  }

  private openUserDetailDialog(aUserId: string) {
    const dialogRef = this.dialog.open<
      GfUserDetailDialogComponent,
      UserDetailDialogParams,
      UserDetailDialogResult
    >(GfUserDetailDialogComponent, {
      autoFocus: false,
      data: {
        currentUserId: this.user?.id,
        deviceType: this.deviceType(),
        hasPermissionForSubscription: this.hasPermissionForSubscription,
        locale: this.user?.settings?.locale ?? DEFAULT_LOCALE,
        userId: aUserId
      } satisfies UserDetailDialogParams,
      height: this.deviceType() === 'mobile' ? '98vh' : '60vh',
      width: this.deviceType() === 'mobile' ? '100vw' : '50rem'
    });

    dialogRef
      .afterClosed()
      .pipe(takeUntilDestroyed(this.destroyRef))
      .subscribe((data) => {
        if (data?.action === 'delete' && data?.userId) {
          this.onDeleteUser(data.userId);
        } else {
          this.router.navigate(
            internalRoutes.adminControl.subRoutes.users.routerLink
          );
        }
      });
  }
}