smartmirror-shared
  1. Injectables
  2. MirrorService

File

src/services/mirror.service.ts

Description

MirrorService class for interacting with the remote mirror collection.

Constructor

constructor(service: SmartMirrorService, socket: SocketService)
Defined in src/services/mirror.service.ts:25

Creates the MirrorService

Parameters :
  • service

    Injected internal http service for interacting with SmartMirror Api

Methods

Public watchUpdates
watchUpdates(id: void)
Defined in src/services/mirror.service.ts:39

Watches for Mirror setting updates

Parameters :
  • id

    of the mirror to listen for mirror updates

Returns : Observable<>
Public watchControlRequest
watchControlRequest(id: void)
Defined in src/services/mirror.service.ts:52

Watches for control request

Parameters :
  • id

    of the mirror to listen for control request

Returns : Observable<>
Public getAll
getAll()
Defined in src/services/mirror.service.ts:65

Gets all Mirrors for authenticated User

Returns : Observable<>
Public getById
getById(id: void)
Defined in src/services/mirror.service.ts:74

Gets the mirror with the given id

Parameters :
  • id

    The id of the mirror to request

Returns : Observable<>
Public update
update(mirror: Mirror)
Defined in src/services/mirror.service.ts:83

Updates the given mirror of the authenticated user

Parameters :
  • mirror

    The mirror to update

Returns : Observable<void>
Public deleteById
deleteById(id: void)
Defined in src/services/mirror.service.ts:93

Deletes the mirror with the given id of the authenticated user

Parameters :
  • id

    The mirror id to delete

Returns : Observable<void>

Properties

Private api
api:
Default value : /mirrors
Defined in src/services/mirror.service.ts:23

relative url to the mirrors api
Private watching
watching:
Default value : false
Defined in src/services/mirror.service.ts:25
 
import {Injectable} from "@angular/core";
import {Observable} from "rxjs";
import {Mirror} from "../models/mirror";
import "rxjs/add/operator/catch";
import "rxjs/add/operator/map";
import {SmartMirrorService} from "./smartmirror.service";
import {SocketService} from "./socket.service";
import {ControlRequest} from "../models/control-request";

/**
 * MirrorService class for interacting with the remote mirror collection.
 */
@Injectable()
export class MirrorService {
    /**
     * relative url to the mirrors api
     * @type {string}
     */
    private api = '/mirrors';

    private watching = false;

    /**
     * Creates the MirrorService
     * @param service Injected internal http service for interacting with SmartMirror Api
     */
    constructor(private service: SmartMirrorService,
                private socket: SocketService) {
    }

    /**
     * Watches for Mirror setting updates
     * @param id of the mirror to listen for mirror updates
     */
    public watchUpdates(id: string): Observable<Mirror> {
        if (!this.watching) {
            this.socket.connect(id);
            this.watching = true;
        }

        return this.socket.watch<Mirror>("update");
    }

    /**
     * Watches for control request
     * @param id of the mirror to listen for control request
     */
    public watchControlRequest(id: string): Observable<ControlRequest> {
        if (!this.watching) {
            this.socket.connect(id);
            this.watching = true;
        }

        return this.socket.watch<ControlRequest>("action");
    }

    /**
     * Gets all Mirrors for authenticated User
     * @return {Observable<R>}
     */
    public getAll(): Observable<Array<Mirror>> {
        return this.service.get(this.api).map(res => <Array<Mirror>>res.json());
    }

    /**
     * Gets the mirror with the given id
     * @param id The id of the mirror to request
     * @return {Observable<R>}
     */
    public getById(id: string): Observable<Mirror> {
        return this.service.get(this.api + '/' + id).map(res => <Mirror>res.json());
    }

    /**
     * Updates the given mirror of the authenticated user
     * @param mirror The mirror to update
     * @return {Observable<R>}
     */
    public update(mirror: Mirror): Observable<void> {
        return this.service.put(this.api, mirror).map(()=> {
        });
    }

    /**
     * Deletes the mirror with the given id of the authenticated user
     * @param id The mirror id to delete
     * @return {Observable<R>}
     */
    public deleteById(id: string): Observable<void> {
        return this.service.delete(this.api + '/' + id).map(()=> {
        });
    }

}

results matching ""

    No results matching ""