// Check if a user has a role

​

let firstUser = {

  name: 'Susan',

  sites: [

    {company: 'ABC Co', role: 'admin'},

    {company: 'XYZ Co', role: 'reader'}

  ]

};

​

let user = new Rx.BehaviorSubject(firstUser);

​

function authorized(authRoles) {

    // check if the current user has one of the authorizedRoles roles

    return this.user

      .do(user => console.log("auth1: Checking user: ",JSON.stringify(user)))

      .flatMap( user => user.sites )

//       .do(res => console.log("Mapped user roles: ",res))

      .first( site => authRoles.indexOf(site.role) !== -1 ) // only return when a role matches

      .do( res => console.log('First: ',res))

      .map( res => true)

}

​

authorized(['writer','admin','reader']).subscribe(res =>{

  console.log("1: isAuthorized?: ",res);

}, err => {

  console.log("1: ERROR: User is not authorized!");

}, () => {

  console.log("1: Authorized check completed!");

});

​

authorized(['writer','foo']).subscribe(res =>{

  console.log("2: isAuthorized?: ",res);

}, err => {

  console.log("2: ERROR: User is not authorized!");

}, () => {

  console.log("2: Authorized check completed!");

});

​

​

//

// Pretend that fetchedUser is fetched in a safer/more sane way

​

// fetch the user and set it

let fetchedUser;

user.subscribe(user => fetchedUser = user);

​

function authorized2(authRoles) {

    // check if the current user has one of the authorizedRoles roles

    return Rx.Observable.of(this.fetchedUser.sites)

      .do(sites => console.log("auth2: Checking users sites: ",sites))

      .flatMap( sites => sites )

      .do(res => console.log("Mapped user roles: ",res))

      .first( site => authRoles.indexOf(site.role) !== -1 ) // only return when a role matches

      .do( res => console.log('First: ',res))

      .map( res => true)

}

​

​

authorized2(['writer','admin','reader']).subscribe(res =>{

  console.log("3: isAuthorized?: ",res);

}, err => {

  console.log("3: ERROR: User is not authorized!");

}, () => {

  console.log("3: Authorized check completed!");

});

​

authorized2(['writer','foo']).subscribe(res =>{

  console.log("4: isAuthorized?: ",res);

}, err => {

  console.log("4: ERROR: User is not authorized!");

}, () => {

  console.log("4: Authorized check completed!");

});

​