Angular 2调用初始化API

Question

我有一个角度服务，我试图调用一个API来获取基于localStorage ID的用户数据。由于某种原因，API甚至没有被调用。有人可以帮忙吗？我调用的getUser（）函数的构造函数...

这里是我的代码：

import { Injectable, OnInit } from '@angular/core'; 
import { Router }  from '@angular/router'; 
import { Http, Headers } from '@angular/http'; 
import {Subject} from "../../node_modules/rxjs/src/Subject"; 
import {Observable} from "../../node_modules/rxjs/src/Observable"; 
import {AuthService} from "./auth.service"; 


@Injectable() 
export class UserService{ 

    userData:any; 
    user:Subject<any>; 
    user$:Observable<any>; 
    loggedIn = new Subject<boolean>(); 
    loggedIn$:Observable<any>; 


    constructor(private http:Http, public authService:AuthService, public router:Router) { 

    this.user = new Subject(); 
    this.user$ = this.user.asObservable(); 
    this.loggedIn = new Subject(); 
    this.loggedIn$ = this.loggedIn.asObservable(); 
    this.getUser().subscribe(); 




    } 

    getUser(){ 

if(localStorage['_id'] && localStorage['jwt']){ 

    let headers = new Headers(); 
    //headers.append('Content-Type', 'application/json'); 

    headers.append('x-access-token', localStorage['jwt']); 
    console.log('We have a user ID! Lets try to get a user!'); 
    return this.http 
    .get('/api/accounts/' + localStorage['_id'], {headers : headers}) 
    .map(res => res.json()) 
    .map((res) => { 
     return res; 
    }, (error) => console.log('There was an error', error)); 
} 

}

} 

    createAccount(user) { 
    user.assessment = { 

     1: {id: "1", answer: "", subs: []}, 
     2: {id: "2", answer: "", subs: []}, 
     3: {id: "3", answer: "", subs: []}, 
     4: {id: "4", answer: "", subs: []}, 
     5: {id: "5", answer: "", subs: []}, 
     6: {id: "6", answer: "", subs: []}, 
     7: {id: "7", answer: "", subs: []}, 
     8: {id: "8", answer: "", subs: []}, 
     9: {id: "9", answer: "", subs: []}, 
     10: {id: "10", answer: "", subs: []}, 
     11: {id: "11", answer: "", subs: []}, 
     12: {id: "12", answer: "", subs: []}, 
     13: {id: "13", answer: "", subs: []}, 
     14: {id: "14", answer: "", subs: []}, 
     15: {id: "15", answer: "", subs: []} 

    }; 
    console.log('Attempting to create an account with', user); 
    let headers = new Headers(); 
    headers.append('Content-Type', 'application/json'); 

    return this.http 
     .post(
     '/api/accounts', 
     JSON.stringify(user), 
     {headers} 
    ) 
     .map(res => res.json()) 
     .map((res) => { 
     if (res['account']) { 
      this.loggedIn.next(true); 
      this.userData = res["account"]; 
      //this.user$ = res; 
      //this.user.next('test'); 
      return res; 
     } 
     }); 
    } 

    login(user) { 

    console.log('Loggin you in...'); 
    let headers = new Headers(); 
    headers.append('Content-Type', 'application/json'); 

    return this.http 
     .post(
     '/api/authenticate', 
     JSON.stringify(user), 
     {headers} 
    ) 
     .map(res => res.json()) 
     .map((res) => { 
     console.log('Login Result:', res); 

      localStorage.setItem('jwt', res.token); 
      localStorage.setItem('_id', res.user[0]._id); 
      //set user service info... 
      this.loggedIn.next(true); 
      this.userData = res.user[0]; 
      this.user.next(res.user[0]); 
      return res; 
     }); 
    } 


    logout() { 
    localStorage.removeItem('jwt'); 
    this.loggedIn.next(false); 
    } 

} 

Answer 1

观测量没有做任何事情没有.subscribe(...)或.toPromise()。

要么你直接做内getUser()像

getUser(){ 

    if(localStorage['_id'] && localStorage['jwt']){ 

     let headers = new Headers(); 
     headers.append('Content-Type', 'application/json'); 

     console.log('We have a user ID! Lets try to get a user!'); 
     this.http 
     .get('/api/accounts/' + localStorage['_id'], {headers}) 
     .map(res => res.json()) 
     .subscribe((res) => { 
      console.log('User restrieved!', res); 
     }, (error) => console.log('There was an error', error)); 
    } 
} 

或者你叫它

constructor(private http:Http, public authService:AuthService, public router:Router) { 

    this.user = new Subject(); 
    this.user$ = this.user.asObservable(); 
    this.loggedIn = new Subject(); 
    this.loggedIn$ = this.loggedIn.asObservable(); 
    this.getUser().subscribe(); 
    } 

你可能也想这样做接收的用户信息的东西。目前除了被打印到控制台之外，接收到的数据没有任何变化。