add infra store

src/packages/infra/infra-store.module.ts

@@ -0,0 +1,24 @@
+import { NgModule } from '@angular/core';
+import { StoreModule } from '@ngrx/store';
+import { StoreDevtoolsModule } from '@ngrx/store-devtools';
+import {
+  StoreRouterConnectingModule,
+  RouterStateSerializer,
+} from '@ngrx/router-store';
+import { EffectsModule } from '@ngrx/effects';
+import { combineReducers, ActionReducer, ActionReducerMap, MetaReducer } from '@ngrx/store';
+
+import {
+  REDUCERS,
+  EFFECTS,
+} from './store';
+
+import { MODULE } from './infra.constant';
+
+@NgModule({
+  imports: [
+    StoreModule.forFeature(MODULE.name, REDUCERS),
+    EffectsModule.forFeature(EFFECTS),
+  ],
+})
+export class InfraStoreModule { }

src/packages/infra/infra.constant.ts

@@ -0,0 +1,3 @@
+export const MODULE = {
+    name: 'infra'
+  };

src/packages/infra/infra.module.ts

@@ -3,18 +3,23 @@ import { CommonModule } from '@angular/common';
 
 import { MaterialModule } from 'app/commons/ui/material/material.module';
 
+import { InfraStoreModule } from './infra-store.module';
+
 import { COMPONENTS } from './component';
+import { SERVICES } from './service';
 
 @NgModule({
   imports: [
     CommonModule,
-    MaterialModule
+    MaterialModule,
+    InfraStoreModule
   ],
   declarations: [
     COMPONENTS,
   ],
   exports: [
     COMPONENTS,
+    SERVICES
   ],
 })
 export class InfraModule { }

src/packages/infra/service/index.ts

@@ -0,0 +1,5 @@
+import { InfraService } from './infra.service';
+
+export const SERVICES = [
+    InfraService,
+];

src/packages/infra/service/infra.service.spec.ts

@@ -0,0 +1,15 @@
+import { TestBed, inject } from '@angular/core/testing';
+
+import { InfraService } from './infra.service';
+
+describe('InfraService', () => {
+  beforeEach(() => {
+    TestBed.configureTestingModule({
+      providers: [InfraService]
+    });
+  });
+
+  it('should be created', inject([InfraService], (service: InfraService) => {
+    expect(service).toBeTruthy();
+  }));
+});

src/packages/infra/service/infra.service.ts

@@ -1,32 +1,29 @@
-// import { Injectable } from '@angular/core';
-// import { Observable } from 'rxjs/Observable';
+import { Injectable } from '@angular/core';
+import { Observable } from 'rxjs/Observable';
 
-// import 'rxjs/add/operator/map';
+import 'rxjs/add/operator/map';
 
-// import { RESTService } from 'packages/commons/service/rest.service';
-// import { DomainMember } from 'packages/domain/model';
+import { RESTService } from 'packages/commons/service/rest.service';
 
-// import { Infra } from '../model';
+import { Infra } from '../model';
+import { Page } from '../../../app/commons/model';
+import { Domain } from '../../domain/model';
+import { Probe } from '../../probe/model';
 
-// @Injectable()
-// export class MemberService {
+@Injectable()
+export class InfraService {
 
-//   public constructor(
-//     private restService: RESTService,
-//   ) {
+  public constructor(
+    private restService: RESTService,
+  ) {
 
-//   }
+  }
 
-//   public signin(email: string, password: string): Observable<DomainMember> {
-//     const body = {
-//       signinId: email,
-//       signinPw: password,
-//     };
+  public readByDomain(domain: Domain): Observable<Page> {
+    return this.restService.post<Page>('/account/signin', domain);
+  }
 
-//     return this.restService.post<DomainMember>('/account/signin', body);
-//   }
-
-//   public signup(member: Member): Observable<Infra> {
-//     return this.restService.post<Member>('/account/signup', member);
-//   }
-// }
+  public readByProbe(probe: Probe): Observable<Page> {
+    return this.restService.post<Page>('/account/signup', probe);
+  }
+}

src/packages/infra/store/index.ts

@@ -0,0 +1,37 @@
+import {
+    createSelector,
+    createFeatureSelector,
+    ActionReducerMap,
+  } from '@ngrx/store';
+
+  import { MODULE } from '../infra.constant';
+
+  import * as ReadByDomainStore from './readbydomain';
+
+
+  export interface State {
+    readbydomain: ReadByDomainStore.State;
+  }
+
+  export const REDUCERS = {
+    readbydomain: ReadByDomainStore.reducer,
+  };
+
+  export const EFFECTS = [
+    ReadByDomainStore.Effects,
+  ];
+
+  export const selectInfraState = createFeatureSelector<State>(MODULE.name);
+
+  export const selectInfraReadByDomainState = createSelector(
+    selectInfraState,
+    (state: State) => state.readbydomain
+  );
+
+  export const AuthSelector = new ReadByDomainStore.StateSelector(selectInfraReadByDomainState);
+
+
+  export const selectInfraReadByDomianState = createSelector(
+    selectInfraState,
+    (state: State) => state.readbydomain
+  );

src/packages/infra/store/readbydomain/index.ts

@@ -1,4 +1,4 @@
-// export * from './readbydomain.action';
-// export * from './readbydomain.effect';
-// export * from './readbydomain.reducer';
-// export * from './readbydomain.state';
+export * from './readbydomain.action';
+export * from './readbydomain.effect';
+export * from './readbydomain.reducer';
+export * from './readbydomain.state';

src/packages/infra/store/readbydomain/readbydomain.action.ts

@@ -0,0 +1,36 @@
+import { Action } from '@ngrx/store';
+
+import { ErrorResponse } from 'packages/commons/service/error-response';
+
+import { Infra } from '../../model';
+import { Page } from '../../../../app/commons/model';
+
+export enum ActionType {
+    Readbydomain = '[infra.readbydomain] Readbydomain',
+    ReadbydomainSuccess = '[infra.readbydomain] ReadbydomainSuccess',
+    ReadbydomainFailure = '[infra.readbydomain] ReadbydomainFailure',
+}
+
+export class Readbydomain implements Action {
+  readonly type = ActionType.Readbydomain;
+
+  constructor(public payload: Infra) {}
+}
+
+export class ReadbydomainSuccess implements Action {
+  readonly type = ActionType.ReadbydomainSuccess;
+
+  constructor(public payload: Page) {}
+}
+
+export class ReadbydomainFailure implements Action {
+  readonly type = ActionType.ReadbydomainFailure;
+
+  constructor(public payload: ErrorResponse) {}
+}
+
+export type Actions =
+  | Readbydomain
+  | ReadbydomainSuccess
+  | ReadbydomainFailure
+;

src/packages/infra/store/readbydomain/readbydomain.effect.spec.ts

@@ -0,0 +1,15 @@
+import { TestBed, inject } from '@angular/core/testing';
+
+import { Effects } from './readbydomain.effect';
+
+describe('Signup.Effects', () => {
+  beforeEach(() => {
+    TestBed.configureTestingModule({
+      providers: [Effects]
+    });
+  });
+
+  it('should be created', inject([Effects], (effects: Effects) => {
+    expect(effects).toBeTruthy();
+  }));
+});

src/packages/infra/store/readbydomain/readbydomain.effect.ts

@@ -0,0 +1,54 @@
+import { Injectable } from '@angular/core';
+import { Router } from '@angular/router';
+
+import { Effect, Actions, ofType } from '@ngrx/effects';
+import { Action } from '@ngrx/store';
+
+import { Observable } from 'rxjs/Observable';
+import { of } from 'rxjs/observable/of';
+
+import 'rxjs/add/operator/catch';
+import 'rxjs/add/operator/do';
+import 'rxjs/add/operator/exhaustMap';
+import 'rxjs/add/operator/map';
+import 'rxjs/add/operator/take';
+
+import { ErrorResponse } from 'packages/commons/service/error-response';
+
+import { Infra } from '../../model';
+import { InfraService } from '../../service/infra.service';
+
+import {
+  Readbydomain,
+  ReadbydomainSuccess,
+  ReadbydomainFailure,
+  ActionType,
+} from './readbydomain.action';
+import { Domain } from 'packages/domain/model';
+
+@Injectable()
+export class Effects {
+
+  constructor(
+    private actions$: Actions,
+    private infraService: InfraService,
+    private router: Router
+  ) { }
+
+  @Effect()
+  readbydomain$: Observable<Action> = this.actions$
+    .ofType(ActionType.Readbydomain)
+    .map((action: Readbydomain) => action.payload)
+    .exhaustMap(member =>
+      this.infraService
+        .readByDomain(member)
+        .map(_member => new ReadbydomainSuccess(_member))
+        .catch(error => of(new ReadbydomainFailure(error)))
+    );
+
+  @Effect({ dispatch: false })
+  readbydomainSuccess$ = this.actions$
+    .ofType(ActionType.ReadbydomainSuccess)
+    .do(() => this.router.navigate(['/']));
+
+}

src/packages/infra/store/readbydomain/readbydomain.reducer.ts

@@ -0,0 +1,39 @@
+import { Actions, ActionType } from './readbydomain.action';
+
+import { State, initialState } from './readbydomain.state';
+
+import { Infra } from '../../model';
+
+export function reducer(state = initialState, action: Actions): State {
+  switch (action.type) {
+    case ActionType.Readbydomain: {
+      return {
+        ...state,
+        error: null,
+        isPending: true
+      };
+    }
+
+    case ActionType.ReadbydomainSuccess: {
+      return {
+        ...state,
+        error: null,
+        isPending: false,
+        infraList: action.payload.content
+      };
+    }
+
+    case ActionType.ReadbydomainFailure: {
+      return {
+        ...state,
+        error: action.payload,
+        isPending: false,
+        infraList: null
+      };
+    }
+
+    default: {
+      return state;
+    }
+  }
+}

src/packages/infra/store/readbydomain/readbydomain.state.ts

@@ -1,20 +1,31 @@
-import { ErrorResponse } from 'packages/commons/service/error-response';
+import {
+  createSelector,
+  MemoizedSelector,
+} from '@ngrx/store';
 
+import { ErrorResponse } from 'packages/commons/service/error-response';
 import { Infra } from '../../model';
 import { Page } from '../../../../app/commons/model';
 
 export interface State {
+  isSignin: boolean;
   error: ErrorResponse | null;
   isPending: boolean;
-  infraList: Infra[] | null;
+  infraList: Page | null;
 }
 
 export const initialState: State = {
+  isSignin: false,
   error: null,
   isPending: false,
   infraList: null,
 };
 
-export const getInfraList = (state: State) => state.infraList;
-export const getError = (state: State) => state.error;
-export const isPending = (state: State) => state.isPending;
+export class StateSelector {
+  public constructor(private _selector: MemoizedSelector<any, any>) {
+  }
+
+  public getInfraList = createSelector(this._selector, (state: State) => state.infraList);
+  public getError = createSelector(this._selector, (state: State) => state.error);
+  public isPending = createSelector(this._selector, (state: State) => state.isPending);
+}