import {Component, Input, OnDestroy, OnInit} from "@angular/core"; import {AbstractControl, FormBuilder, FormGroup, ValidationErrors, ValidatorFn, Validators} from "@angular/forms"; import {Subscriber} from "rxjs"; import {StringUtils} from "../../utils/string-utils.class"; import {Email} from "../../utils/email/email"; import {Body} from "../../utils/email/body"; import {CommunityService} from "../../connect/community/community.service"; import {Composer} from "../../utils/email/composer"; import {Session, User} from "../../login/utils/helper.class"; import {EmailService} from "../../utils/email/email.service"; import {properties} from "../../../../environments/environment"; import {CommunityInfo} from "../../connect/community/communityInfo"; import {NotificationHandler} from "../../utils/notification-handler"; @Component({ selector: 'subscriber-invite', template: `
Separate emails with commas
{{body.signature}} {{body.fromMessage}}... {{body.fromMessage}} {{body.fromName}}
www.openaire.eu
` }) export class SubscriberInviteComponent implements OnInit, OnDestroy { @Input() public user: User; public community: CommunityInfo; public inviteForm: FormGroup; public email: Email; public body: Body; public validators: ValidatorFn[] = [Validators.email]; public loading: boolean = true; private subscriptions: any[] = []; constructor(private fb: FormBuilder, private emailService: EmailService, private communityService: CommunityService) { } ngOnInit() { this.reset(); } ngOnDestroy() { this.unsubscribe(); } unsubscribe() { this.subscriptions.forEach(subscription => { if(subscription instanceof Subscriber) { subscription.unsubscribe(); } }); } reset() { this.unsubscribe(); this.inviteForm = this.fb.group({ name: this.fb.control('', Validators.required), recipients: this.fb.array([], Validators.required), message: this.fb.control('', Validators.required) }); this.subscriptions.push(this.communityService.getCommunityAsObservable().subscribe(community => { this.community = community; if(this.community) { this.inviteForm.get('name').setValue(this.user.fullname); this.body = Composer.initializeInvitationsBody(community.communityId, community.title, this.user.fullname); this.email = Composer.initializeInvitationsEmail(community.title); this.inviteForm.get('message').setValue(this.body.paragraphs); } })); if(!this.isManager) { this.loading = false; } } invite() { this.loading = true; this.body.paragraphs = this.inviteForm.getRawValue().message; this.email.body = Composer.formatEmailBodyForInvitation(this.body); this.email.recipients = this.inviteForm.get('recipients').value; this.subscriptions.push(this.emailService.sendEmail(properties, this.email).subscribe(res => { if(res['success']) { NotificationHandler.rise('Invitation to join has been sent'); } else { NotificationHandler.rise('An error has occurred. Please try again later', 'danger'); } this.reset(); this.loading = false; },error => { NotificationHandler.rise('An error has occurred. Please try again later', 'danger'); this.reset(); this.loading = false; })); } get isManager() { return Session.isPortalAdministrator(this.user) || Session.isCurator('community', this.user) || Session.isManager('community', this.community.communityId, this.user); } get valid() { return !this.loading && this.inviteForm && this.inviteForm.valid; } }