import { Component } from "@angular/core"; import { ActivatedRoute } from "@angular/router"; import { ApiService } from "../shared/api.service"; import { ScalarService } from "../shared/scalar.service"; import { ToasterService } from "angular2-toaster"; import { Integration } from "../shared/models/integration"; @Component({ selector: 'my-riot', templateUrl: './riot.component.html', styleUrls: ['./riot.component.scss'], }) export class RiotComponent { public error: string; public integrations: Integration[] = []; public loading = true; public roomId: string; private scalarToken: string; constructor(private activatedRoute: ActivatedRoute, private api: ApiService, private scalar: ScalarService, private toaster: ToasterService) { let params: any = this.activatedRoute.snapshot.queryParams; if (!params.scalar_token || !params.room_id) this.error = "Missing scalar token or room ID"; else { this.roomId = params.room_id; this.scalarToken = params.scalar_token; this.api.checkScalarToken(params.scalar_token).then(isValid => { if (isValid) this.init(); else this.error = "Invalid scalar token"; }).catch(err => { this.error = "Unable to communicate with Dimension"; console.error(err); }); } } private init() { this.api.getIntegrations(this.roomId, this.scalarToken).then(integrations => { this.integrations = integrations; let promises = integrations.map(b => this.updateIntegrationState(b)); return Promise.all(promises); }).then(() => this.loading = false).catch(err => { this.error = "Unable to communicate with Dimension"; console.error(err); }); } private updateIntegrationState(integration: Integration) { return this.scalar.getMembershipState(this.roomId, integration.userId).then(payload => { integration.isBroken = false; if (!payload.response) { integration.isEnabled = false; return; } integration.isEnabled = (payload.response.membership === 'join' || payload.response.membership === 'invite'); }, (error) => { console.error(error); integration.isEnabled = false; integration.isBroken = true; }); } public updateIntegration(integration: Integration) { let promise = null; if (!integration.isEnabled) { promise = this.api.removeIntegration(this.roomId, integration.userId, this.scalarToken); } else promise = this.scalar.inviteUser(this.roomId, integration.userId); promise .then(() => { if (integration.isEnabled) this.toaster.pop('success', integration.name + " was invited to the room"); else this.toaster.pop('success', integration.name + " was removed from the room"); }) .catch(err => { let errorMessage = "Could not update integration status"; if (err.json) { errorMessage = err.json().error; } else errorMessage = err.response.error.message; integration.isEnabled = !integration.isEnabled; this.toaster.pop("error", errorMessage); }); } }