// FIXME: Update this file to be type safe and remove this and next line // @ts-strict-ignore import { Component, EventEmitter, Input, OnDestroy, OnInit, Output } from "@angular/core"; import { FormBuilder } from "@angular/forms"; import { BehaviorSubject, map, skip, Subject, takeUntil, withLatestFrom } from "rxjs"; import { AccountService } from "@bitwarden/common/auth/abstractions/account.service"; import { UserId } from "@bitwarden/common/types/guid"; import { CredentialGeneratorService, Generators, SubaddressGenerationOptions, } from "@bitwarden/generator-core"; import { completeOnAccountSwitch } from "./util"; /** Options group for plus-addressed emails */ @Component({ selector: "tools-subaddress-settings", templateUrl: "subaddress-settings.component.html", }) export class SubaddressSettingsComponent implements OnInit, OnDestroy { /** Instantiates the component * @param accountService queries user availability * @param generatorService settings and policy logic * @param formBuilder reactive form controls */ constructor( private formBuilder: FormBuilder, private generatorService: CredentialGeneratorService, private accountService: AccountService, ) {} /** Binds the component to a specific user's settings. * When this input is not provided, the form binds to the active * user */ @Input() userId: UserId | null; /** Emits settings updates and completes if the settings become unavailable. * @remarks this does not emit the initial settings. If you would like * to receive live settings updates including the initial update, * use `CredentialGeneratorService.settings$(...)` instead. */ @Output() readonly onUpdated = new EventEmitter(); /** The template's control bindings */ protected settings = this.formBuilder.group({ subaddressEmail: [Generators.subaddress.settings.initial.subaddressEmail], }); async ngOnInit() { const singleUserId$ = this.singleUserId$(); const settings = await this.generatorService.settings(Generators.subaddress, { singleUserId$ }); settings.pipe(takeUntil(this.destroyed$)).subscribe((s) => { this.settings.patchValue(s, { emitEvent: false }); }); // the first emission is the current value; subsequent emissions are updates settings.pipe(skip(1), takeUntil(this.destroyed$)).subscribe(this.onUpdated); this.saveSettings .pipe( withLatestFrom(this.settings.valueChanges), map(([, settings]) => settings), takeUntil(this.destroyed$), ) .subscribe(settings); } private saveSettings = new Subject(); save(site: string = "component api call") { this.saveSettings.next(site); } private singleUserId$() { // FIXME: this branch should probably scan for the user and make sure // the account is unlocked if (this.userId) { return new BehaviorSubject(this.userId as UserId).asObservable(); } return this.accountService.activeAccount$.pipe( completeOnAccountSwitch(), takeUntil(this.destroyed$), ); } private readonly destroyed$ = new Subject(); ngOnDestroy(): void { this.destroyed$.next(); this.destroyed$.complete(); } }