45 lines
1.3 KiB
TypeScript
45 lines
1.3 KiB
TypeScript
|
import { Injectable } from '@angular/core';
|
||
|
|
import { ApiService } from '../providers/api-service';
|
||
|
|
import { AngularFireMessaging } from '@angular/fire/messaging';
|
||
|
|
import { BehaviorSubject } from 'rxjs';
|
||
|
|
|
||
|
|
@Injectable()
|
||
|
|
|
||
|
|
export class MessagingService {
|
||
|
|
currentMessage = new BehaviorSubject(null);
|
||
|
|
|
||
|
|
constructor(
|
||
|
|
private angularFireMessaging: AngularFireMessaging,
|
||
|
|
private api: ApiService
|
||
|
|
) {
|
||
|
|
this.angularFireMessaging.messages.subscribe((_messaging: AngularFireMessaging) => {
|
||
|
|
_messaging.onMessage = _messaging.onMessage.bind(_messaging);
|
||
|
|
_messaging.onTokenRefresh = _messaging.onTokenRefresh.bind(_messaging);
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
requestPermission() {
|
||
|
|
this.angularFireMessaging.requestToken.subscribe((token) => {
|
||
|
|
console.log("Device token: " + token);
|
||
|
|
return
|
||
|
|
this.api.addDeviceToken(token).subscribe(
|
||
|
|
result => {
|
||
|
|
console.log("Device registered successfully!");
|
||
|
|
},
|
||
|
|
error => {
|
||
|
|
console.error("Device could not be registered!", error._body);
|
||
|
|
}
|
||
|
|
);
|
||
|
|
}, (err) => {
|
||
|
|
console.error('Unable to get permission to notify.', err);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
receiveMessage() {
|
||
|
|
this.angularFireMessaging.messages.subscribe((payload) => {
|
||
|
|
console.log("new message received. ", payload);
|
||
|
|
this.currentMessage.next(payload);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|