API-сервис становится неопределенным в наблюдаемом - PullRequest
Новая
       26

API-сервис становится неопределенным в наблюдаемом

0 голосов
/ 07 февраля 2019

Ниже мой app.component.js для моего углового 6 ионного 4 приложения.У меня есть наблюдаемое, которое запускает вызов службы API для проверки новых уведомлений каждые 2 минуты.Первый звонок срабатывает успешно, после этого я получаю сообщение об ошибке can't find listModel of undefined, ссылаясь на мою строку await this.api.listModel('Notification'.Почему это становится неопределенным?Что я могу сделать, чтобы обойти проблему? 

...
import { LoadingService } from './loading.service';
import { apiService } from './...-api.service';
...

@Component({
  selector: 'app-root',
  templateUrl: 'app.component.html',
  styleUrls: ['./app.component.scss'],
})
export class AppComponent {
  public appPages = [
    {
      title: 'Home',
      url: '/notifications',
      icon: 'notifications'
    },
  ...
  public title = 'Places';
  public addrKeys: string[];
  public addr: object;
  public hasUnactionedNotification: any = false;
  public notificationObservable: any;
  public account: any;
  public initials: any;

  constructor(
    private platform: Platform,
    private api: apiService,
    ...
  ) {
    this.initializeApp();
    this.initializeNotifAndInitials();
  }

  ...

  async initializeNotifAndInitials() {
    this.refreshNotifications();
    this.account = await this.accountService.getAccount();
    this.initials = this.account.firstName != null ? this.account.firstName.charAt(0) + this.account.lastName.charAt(0) : '';
    this.notificationObservable = interval(0.5 * 60 * 1000);
    this.notificationObservable.subscribe(this.refreshNotifications);
  }

  async refreshNotifications() {
    let notifications = await this.api.listModel('Notification', null, null, {
      page: 0,
      size: 15
    });
    this.hasUnactionedNotification = !!_.filter(notifications, {
      isActioned: false
    }).length;
    //boot out users who are no longer logged in
    this.account = await this.accountService.getAccount();
    if (!this.account) {
       this.router.navigateByUrl('/login');
    }
  }

}

Вот сервисный вызов API 

import { Injectable } from '@angular/core';
import { Observable, of, throwError } from 'rxjs';
import { HttpClient, HttpHeaders, HttpErrorResponse, HttpParams } from '@angular/common/http';
import { catchError, tap, map } from 'rxjs/operators';
import { SessionService } from './session.service';
import { environment } from '../environments/environment';
import * as _ from 'lodash';
import * as moment from 'moment-timezone';

@Injectable({
  providedIn: 'root'
})
export class FinaeoApiService {
  pageSize: any = 20;

  constructor(
    private http: HttpClient,
    private sessionService: SessionService,
  ) { }

    async listModel(modelName, modelId, secondModelName, opts) {
    const options = await this.getRequestOptions();
    let params = <any> {
      page: _.get(opts, 'page', 0),
      size: _.get(opts, 'size', this.pageSize),
    };
    if (modelId === null && secondModelName === null) {
      params.disableCompany = _.get(opts, 'disableCompany', false);
    };
    if (!_.isEmpty(opts.filters)) {
      let filters = [];
      _.each(opts.filters, filter => {
        filters.push(`${filter.attribute},${filter.action}:${filter.value}`);
      });
      params.filter = filters.join(',');
    }
    if (!_.isEmpty(opts.sort)) {
      params.sort = opts.sort.join(',');
    }
    options.params = new HttpParams({
      fromObject: params
    });
    if (modelId === null && secondModelName === null) {
      return this.http.get(`${environment.apiUrl}/${modelName.toLowerCase()}`, options).toPromise().then(this.extractData).catch(this.handleError);
    } else {
      return this.http.get(`${environment.apiUrl}/${modelName.toLowerCase()}/${modelId}/${secondModelName.toLowerCase()}`, options).toPromise().then(this.extractData).catch(this.handleError);
    }
  }

error

1 Ответ

0 голосов
/ 07 февраля 2019

Я думаю, что проблема в том, что вам нужно .bind(this)

т.е.: 

this.notificationObservable.subscribe(this.refreshNotifications.bind(this));

, но лично мне не нравится этот синтаксис, я бы предпочел перейти на 

this.notificationObservable.subscribe(() => this.refreshNotifications());
...