doneit-web/src/app/services/notifications.service.ts

/* eslint-disable */
/* tslint:disable */
import { EventEmitter, Injectable, NgZone } from '@angular/core';
import { HttpClient, HttpHeaders, HttpParams } from '@angular/common/http';
import { environment } from 'src/environments/environment';
import { StorageService } from 'src/app/services/storage.service';
import { AuthConnstants } from 'src/app/config/auth-constants';
import { Tokenn } from '../models/token.model';
import { AlertController, Platform } from '@ionic/angular';
import { NavigationExtras, Router } from '@angular/router';
import { EventTrigger } from '../services/eventTrigger.service';
import { SessionStore } from '../store/session.service';
import { ActionPerformed, PushNotificationSchema, PushNotifications, Token, } from '@capacitor/push-notifications';
import { notificationObject } from '../models/notifications';
import { v4 as uuidv4 } from 'uuid'
import { Capacitor } from '@capacitor/core';
import { AngularFireMessaging } from '@angular/fire/messaging';
import { Subject } from 'rxjs';
@Injectable({
  providedIn: 'root'
})
export class NotificationsService {

  adding: "intervenient" | "CC" = "intervenient";
  folderId: string;
  DataArray = new Array();


  callbacks: {
    [key: string]: {
      type: notificationObject,
      funx: Function
      id: string
    }
  } = {}

  active = false
  isPushNotificationsAvailable = Capacitor.isPluginAvailable('PushNotifications');
  notificationReceived: EventEmitter<void> = new EventEmitter<void>();

  constructor(
    private http: HttpClient,
    private storageService: StorageService,
    public modalCtrl: AlertController,
    private platform: Platform,
    private router: Router,
    private zone: NgZone,
    private eventtrigger: EventTrigger,
    private afMessaging: AngularFireMessaging,) {

  }

  getTokenByUserIdAndId(user, userID) {
    // const geturl = environment.apiURL + 'notifications/user/' + userID;

    // return this.http.get<Tokenn[]>(`${geturl}`);
  }

  requestPermissions() {

    if (this.platform.is('mobile')) {
      if (!this.isPushNotificationsAvailable) {
        return false
      }
      PushNotifications.requestPermissions().then(result => {
        if (result.receive === 'granted') {
          // Register with Apple / Google to receive push via APNS/FCM
          PushNotifications.register();
        } else {
          // Show some error
        }
      });
    } else {
    }
  }

  getAndpostToken(username) {
    const geturl = environment.apiURL + 'notifications/token';
    if (this.platform.is('mobile')) {
      if (!this.isPushNotificationsAvailable) {
        return false
      }

      PushNotifications.addListener('registration',
        (token: Token) => {
          this.postToken(token.value, geturl)
        }
      );
    } else {
      this.afMessaging.requestToken.subscribe(
        (token) => {
          // Save the token to your server for sending notifications
          console.log('Permission granted! Token:', token);
          this.postToken(token, geturl)
        },
        (error) => {
          console.error('Permission denied:', error);
        }
      );
    }

  }

  postToken(token, geturl) {
    const headers = { 'Authorization': SessionStore.user.BasicAuthKey };
    const body = {
      UserId: SessionStore.user.UserId,
      TokenId: token,
      Status: 1,
      Service: 1
    };
    this.http.post<Tokenn>(`${geturl}`, body, { headers }).subscribe(data => {
      this.active = true
    }, (error) => {

    })
  }

  registrationError() {
    if (!this.isPushNotificationsAvailable) {
      return false
    }

    PushNotifications.addListener('registrationError',
      (error: any) => {
        this.active = false
      }
    );
  }

  onReciveForeground() {

    if(this.platform.is('mobile')) {

      if (!this.isPushNotificationsAvailable) {
        return false
      }
      PushNotifications.addListener('pushNotificationReceived',
        (notification: PushNotificationSchema) => {
          this.active = true
          console.log('NOtification Listener', notification)
          this.storenotification(notification)
          this.eventtrigger.publishSomeData({
            notification: "recive"
          })
        }
      );

    } else {
      this.afMessaging.messages.subscribe((notification) => {
        this.storenotification(notification)
        this.notificationReceived.emit();
          this.eventtrigger.publishSomeData({
            notification: "recive"
          })
        // Handle the received message, e.g., show a notification
      });
    }
  }

  storenotification(notification) {
    console.log('Store Notification ',notification)
    this.storageService.get("Notifications").then((store) => {

      store.push(notification)
      this.storageService.store("Notifications", store)
    }).catch((error) => {
      if (!error) {
        this.storageService.store("Notifications", [notification])
      }
    })
  }

  onReciveBackground() {
    if (!this.isPushNotificationsAvailable) {
      return false
    }

    PushNotifications.addListener('pushNotificationActionPerformed',
      (notification: ActionPerformed) => {
        this.active = true
        console.log('NOtification Listener Backgroud', notification)
        /*  this.DataArray.push(notification.notification)
         
         this.storageService.store("Notifications", this.DataArray)
         this.eventtrigger.publishSomeData({
           notification: "recive"
         }) */
        this.notificatinsRoutes(notification)
        // this.runNotificationCallback(notification)
      }
    );
  }

  ChatSendMessageNotification(userID, title, bodymsg, roomId) {
    const geturl = environment.apiURL + `notifications/sendbyUsername`;

    const headers = { 'Authorization': SessionStore.user.BasicAuthKey };
    const message = {
      "Service": "chat",
      "IdObject": roomId
    }
    let id = 437
    this.http.post<Tokenn>(geturl + `?username=${userID}&title=${title}&body=${bodymsg}`, message, { headers }).subscribe(data => {
      this.active = true
    }, (error) => {

    })
  }

  ChatSendMessageNotificationGrup(usersID, title, bodymsg, roomId) {
    const geturl = environment.apiURL + `notifications/sendByUsernames`;

    const headers = { 'Authorization': SessionStore.user.BasicAuthKey };
    const message = {
      "Users": usersID,
      "NotificationData": {
        "Service": "chat",
        "IdObject": roomId
      }
    }

    this.http.post<Tokenn>(geturl + `?title=${title}&body=${bodymsg}`, message, { headers }).subscribe(data => {
      this.active = true
    }, (error) => {

    })
  }

  tempClearArray(data) {
    this.DataArray = new Array;
  }


  notificatinsRoutes = (notification) => {



    if (notification.notification.data.Service === "agenda" && notification.notification.data.IdObject.length > 10) {

      this.zone.run(() => this.router.navigate(['/home/agenda', notification.notification.data.IdObject, 'agenda']));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "expediente") {
      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/expediente', notification.notification.data.IdObject, 'gabinete-digital']));
    }
    else if (notification.notification.data.Service === "agenda" && notification.notification.data.Object === "event-list") {
      //this.zone.run(() => this.router.navigate(['/home/gabinete-digital/event-list/approve-event',IdObject, 'agenda']));
      this.zone.run(() => this.router.navigate(['/home/agenda/event-list/approve-event', notification.notification.data.IdObject, 'agenda']));

    } else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "despachos") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/despachos', notification.notification.data.IdObject, 'gabinete-digital'], { replaceUrl: true }));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "parecer") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/pedidos', notification.notification.data.IdObject, 'gabinete-digital']));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "deferimento") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/pedidos', notification.notification.data.IdObject, 'gabinete-digital']));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "despachos-pr") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/despachos-pr', notification.notification.data.IdObject, 'gabinete-digital']));
    }
    else if (notification.notification.data.Service === "accoes" && notification.notification.data.Object === "accao") {
      this.zone.run(() => this.router.navigate(['/home/publications', notification.notification.data.IdObject]));
    }
    else if (notification.notification.data.Service === "accoes" && notification.notification.data.Object === "publicacao") {
      this.zone.run(() => this.router.navigate(['/home/publications/view-publications', notification.notification.data.FolderId, notification.data.IdObject]));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "diplomas") {
      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/diplomas', notification.notification.data.IdObject, 'gabinete-digital']));
    }
    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "diplomas-assinar") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/diplomas-assinar', notification.notification.data.IdObject, 'gabinete-digital']));
    }

    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "diploma-revisao") {

      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/diplomas', notification.notification.data.IdObject, 'gabinete-digital']));
    }

    else if (notification.notification.data.Service === "gabinete-digital" && notification.notification.data.Object === "expedientes-pr") {
      this.zone.run(() => this.router.navigate(['/home/gabinete-digital/expedientes-pr', notification.notification.data.IdObject, 'gabinete-digital']));
    } else if (notification.notification.data.Service === "chat") {
      let navigationExtras: NavigationExtras = { queryParams: { "roomId": notification.notification.data.IdObject, } };
      this.zone.run(() => this.router.navigate(['/home/chat'], navigationExtras));
    }

  }

}