http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/datatype.actions.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/datatype.actions.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/datatype.actions.ts deleted file mode 100755 index 5543a7a..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/datatype.actions.ts +++ /dev/null @@ -1,122 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Action } from '@ngrx/store'; -import { AsterixDBQueryMessage, Datatype } from '../models/asterixDB.model'; - -/* -* Definition of Datatypes Actions -*/ -export const SELECT_DATATYPES = '[Datatype Collection] Select Datatypes'; -export const SELECT_DATATYPES_SUCCESS = '[Datatype Collection] Select Datatypes Success'; -export const SELECT_DATATYPES_FAIL = '[Datatype Collection] Select Datatypes Fail'; -export const CREATE_DATATYPE = '[Datatype Collection] Create Datatypes'; -export const CREATE_DATATYPE_SUCCESS = '[Datatype Collection] Create Datatypes Success'; -export const CREATE_DATATYPE_FAIL = '[Datatype Collection] Create Datatypes Fail'; -export const UPDATE_DATATYPE = '[Datatype Collection] Update Datatype'; -export const UPDATE_DATATYPE_SUCCESS = '[Datatype Collection] Update Datatype Success'; -export const UPDATE_DATATYPE_FAIL = '[Datatype Collection] Update Datatype Fail'; -export const DROP_DATATYPE = '[Datatype Collection] Drop Datatypes'; -export const DROP_DATATYPE_SUCCESS = '[Datatype Collection] Drop Datatypes Success'; -export const DROP_DATATYPE_FAIL = '[Datatype Collection] Drop Datatypes Fail'; - -/* -* Select Datatypes -*/ -export class SelectDatatypes implements Action { - readonly type = SELECT_DATATYPES; - constructor(public payload: string) {} -} - -export class SelectDatatypesSuccess implements Action { - readonly type = SELECT_DATATYPES_SUCCESS; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -export class SelectDatatypesFail implements Action { - readonly type = SELECT_DATATYPES_FAIL; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -/* -* Create Datatype -*/ -export class CreateDatatype implements Action { - readonly type = CREATE_DATATYPE; - constructor(public payload: string) {} -} - -export class CreateDatatypeSuccess implements Action { - readonly type = CREATE_DATATYPE_SUCCESS; - constructor(public payload: Datatype[]) {} -} - -export class CreateDatatypeFail implements Action { - readonly type = CREATE_DATATYPE_FAIL; - constructor(public payload: Datatype) {} -} - -/* -* Update Datatype -*/ -export class UpdateDatatype implements Action { - readonly type = UPDATE_DATATYPE; - constructor(public payload: Datatype) {} -} - -export class UpdateDatatypeSuccess implements Action { - readonly type = UPDATE_DATATYPE_SUCCESS; - constructor(public payload: Datatype[]) {} -} - -export class UpdateDatatypeFail implements Action { - readonly type = UPDATE_DATATYPE_FAIL; - constructor(public payload: Datatype) {} -} - -/* -* Drop Datatype -*/ -export class DropDatatype implements Action { - readonly type = DROP_DATATYPE; - - constructor(public payload: string) {} -} - -export class DropDatatypeSuccess implements Action { - readonly type = DROP_DATATYPE_SUCCESS; - - constructor(public payload: Datatype[]) {} -} - -export class DropDatatypeFail implements Action { - readonly type = DROP_DATATYPE_FAIL; - - constructor(public payload: Datatype) {} -} - -/* -* Exports of datastypes actions -*/ -export type All = SelectDatatypes | - SelectDatatypesSuccess | - SelectDatatypesFail | - CreateDatatype | - CreateDatatypeSuccess | - CreateDatatypeFail | - UpdateDatatype | - UpdateDatatypeSuccess | - UpdateDatatypeFail | - DropDatatype | - DropDatatypeSuccess | - DropDatatypeFail;
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/dataverse.actions.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/dataverse.actions.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/dataverse.actions.ts deleted file mode 100755 index dc33c0a..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/dataverse.actions.ts +++ /dev/null @@ -1,119 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Action } from '@ngrx/store'; -import { AsterixDBQueryMessage, Dataverse } from '../models/asterixDB.model'; - -/* -* Definition of Dataverses Actions -*/ -export const SELECT_DATAVERSES = '[Dataverse Collection] Select Dataverses'; -export const SELECT_DATAVERSES_SUCCESS = '[Dataverse Collection] Select Dataverses Success'; -export const SELECT_DATAVERSES_FAIL = '[Dataverse Collection] Select Dataverses Fail'; -export const CREATE_DATAVERSE = '[Dataverse Collection] Create Dataverse'; -export const CREATE_DATAVERSE_SUCCESS = '[Dataverse Collection] Create Dataverse Success'; -export const CREATE_DATAVERSE_FAIL = '[Dataverse Collection] Create Dataverse Fail'; -export const UPDATE_DATAVERSE = '[Dataverse Collection] Update Dataverse'; -export const UPDATE_DATAVERSE_SUCCESS = '[Dataverse Collection] Update Dataverse Success'; -export const UPDATE_DATAVERSE_FAIL = '[Dataverse Collection] Update Dataverse Fail'; -export const DROP_DATAVERSE = '[Dataverse Collection] Drop Dataverses'; -export const DROP_DATAVERSE_SUCCESS = '[Dataverse Collection] Drop Dataverses Success'; -export const DROP_DATAVERSE_FAIL = '[Dataverse Collection] Drop Dataverses Fail'; - -/* -* Select Dataverses -*/ -export class SelectDataverses implements Action { - readonly type = SELECT_DATAVERSES; - constructor(public payload: string) {} -} - -export class SelectDataversesSuccess implements Action { - readonly type = SELECT_DATAVERSES_SUCCESS; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -export class SelectDataversesFail implements Action { - readonly type = SELECT_DATAVERSES_FAIL; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -/* -* Create Dataverse -*/ -export class CreateDataverse implements Action { - readonly type = CREATE_DATAVERSE; - constructor(public payload: string) {} -} - -export class CreateDataverseSuccess implements Action { - readonly type = CREATE_DATAVERSE_SUCCESS; - constructor(public payload: Dataverse[]) {} -} - -export class CreateDataverseFail implements Action { - readonly type = CREATE_DATAVERSE_FAIL; - constructor(public payload: Dataverse) {} -} - -/* -* Update Dataverse -*/ -export class UpdateDataverse implements Action { - readonly type = UPDATE_DATAVERSE; - constructor(public payload: Dataverse) {} -} - -export class UpdateDataverseSuccess implements Action { - readonly type = UPDATE_DATAVERSE_SUCCESS; - constructor(public payload: Dataverse[]) {} -} - -export class UpdateDataverseFail implements Action { - readonly type = UPDATE_DATAVERSE_FAIL; - constructor(public payload: Dataverse) {} -} - -/* -* Drop Dataverse -*/ -export class DropDataverse implements Action { - readonly type = DROP_DATAVERSE; - constructor(public payload: string) {} -} - -export class DropDataverseSuccess implements Action { - readonly type = DROP_DATAVERSE_SUCCESS; - constructor(public payload: Dataverse[]) {} -} - -export class DropDataverseFail implements Action { - readonly type = DROP_DATAVERSE_FAIL; - constructor(public payload: Dataverse) {} -} - -/* -* Exports of datasverses actions -*/ -export type All = SelectDataverses | - SelectDataversesSuccess | - SelectDataversesFail | - CreateDataverse | - CreateDataverseSuccess | - CreateDataverseFail | - UpdateDataverse | - UpdateDataverseSuccess | - UpdateDataverseFail | - DropDataverse | - DropDataverseSuccess | - DropDataverseFail; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/index.actions.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/index.actions.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/index.actions.ts deleted file mode 100755 index 1304644..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/index.actions.ts +++ /dev/null @@ -1,119 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Action } from '@ngrx/store'; -import { Index } from '../models/asterixDB.model'; - -/* -* Definition of Index Actions -*/ -export const SELECT_INDEXES = '[Index Collection] Select Indexes'; -export const SELECT_INDEXES_SUCCESS = '[Index Collection] Select Indexes Success'; -export const SELECT_INDEXES_FAIL = '[Index Collection] Select Indexes Fail'; -export const CREATE_INDEX = '[Index Collection] Create Index'; -export const CREATE_INDEX_SUCCESS = '[Index Collection] Create Index Success'; -export const CREATE_INDEX_FAIL = '[Index Collection] Create Index Fail'; -export const UPDATE_INDEX = '[Index Collection] Update Index'; -export const UPDATE_INDEX_SUCCESS = '[Index Collection] Update Index Success'; -export const UPDATE_INDEX_FAIL = '[Index Collection] Update Index Fail'; -export const DROP_INDEX = '[Index Collection] Drop Indexes'; -export const DROP_INDEX_SUCCESS = '[Index Collection] Drop Indexes Success'; -export const DROP_INDEX_FAIL = '[Index Collection] Drop Indexes Fail'; - -/* -* Select Indexes -*/ -export class SelectIndexes implements Action { - readonly type = SELECT_INDEXES; - constructor(public payload: string) {} -} - -export class SelectIndexesSuccess implements Action { - readonly type = SELECT_INDEXES_SUCCESS; - constructor(public payload: Index[]) {} -} - -export class SelectIndexesFail implements Action { - readonly type = SELECT_INDEXES_FAIL; - constructor(public payload: Index[]) {} -} - -/* -* Create Index -*/ -export class CreateIndex implements Action { - readonly type = CREATE_INDEX; - constructor(public payload: string) {} -} - -export class CreateIndexSuccess implements Action { - readonly type = CREATE_INDEX_SUCCESS; - constructor(public payload: Index[]) {} -} - -export class CreateIndexFail implements Action { - readonly type = CREATE_INDEX_FAIL; - constructor(public payload: Index) {} -} - -/* -* Update Index -*/ -export class UpdateIndex implements Action { - readonly type = UPDATE_INDEX; - constructor(public payload: Index) {} -} - -export class UpdateIndexSuccess implements Action { - readonly type = UPDATE_INDEX_SUCCESS; - constructor(public payload: Index[]) {} -} - -export class UpdateIndexFail implements Action { - readonly type = UPDATE_INDEX_FAIL; - constructor(public payload: Index) {} -} - -/* -* Remove Index -*/ -export class DropIndex implements Action { - readonly type = DROP_INDEX; - constructor(public payload: string) {} -} - -export class DropIndexSuccess implements Action { - readonly type = DROP_INDEX_SUCCESS; - constructor(public payload: Index[]) {} -} - -export class DropIndexFail implements Action { - readonly type = DROP_INDEX_FAIL; - constructor(public payload: Index) {} -} - -/* -* Exports of indexes actions -*/ -export type All = SelectIndexes | - SelectIndexesSuccess | - SelectIndexesFail | - CreateIndex | - CreateIndexSuccess | - CreateIndexFail | - UpdateIndex | - UpdateIndexSuccess | - UpdateIndexFail | - DropIndex | - DropIndexSuccess | - DropIndexFail; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/metadata.actions.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/metadata.actions.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/metadata.actions.ts deleted file mode 100755 index 4a3c125..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/metadata.actions.ts +++ /dev/null @@ -1,46 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Action } from '@ngrx/store'; - -/* -* Definition of Metadata Tree Actions -*/ -export const UPDATE_METADATA_TREE = '[Metadata Tree Query] UPDATE Metadata tree'; -export const UPDATE_METADATA_TREE_SUCCESS = '[Metadata Tree Query] UPDATE Metadata tree Success'; -export const UPDATE_METADATA_TREE_FAIL = '[Metadata Tree Query] UPDATE Metadata tree Fail'; - -/* -* Construct Metadata Tree Actions -*/ -export class UpdateMetadataTree implements Action { - readonly type = UPDATE_METADATA_TREE - constructor() {} -} - -export class UpdateMetadataTreeSuccess implements Action { - readonly type = UPDATE_METADATA_TREE_SUCCESS; - constructor(public payload: any) {} -} - -export class UpdateMetadataTreeFail implements Action { - readonly type = UPDATE_METADATA_TREE_FAIL; - constructor(public payload: any) {} -} - -/* -* Exports of Metatada Tree actions -*/ -export type All = UpdateMetadataTree | - UpdateMetadataTreeSuccess | - UpdateMetadataTreeFail; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/query.actions.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/query.actions.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/query.actions.ts deleted file mode 100755 index 866b3e9..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/actions/query.actions.ts +++ /dev/null @@ -1,71 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Action } from '@ngrx/store'; -import { AsterixDBQueryMessage } from '../models/asterixDB.model'; - -/* -* Definition of SQL++ Actions -*/ -export const EXECUTE_QUERY = '[Query] Execute SQL++ Query'; -export const EXECUTE_QUERY_SUCCESS = '[Query] Execute SQL++ Query Success'; -export const EXECUTE_QUERY_FAIL = '[Query] Execute SQL++ Query Fail'; -export const EXECUTE_METADATA_QUERY = '[Query] Execute Metadata SQL++ Query'; -export const EXECUTE_METADATA_QUERY_SUCCESS = '[Query] Execute Metadata SQL++ Query Success'; -export const EXECUTE_METADATA_QUERY_FAIL = '[Query] Execute Metadata SQL++ Query Fail'; - -/* -* Execute SQL++ Query -*/ -export class ExecuteQuery implements Action { - readonly type = EXECUTE_QUERY; - constructor(public payload: string) {} // the AsterixDB Query String -} - -export class ExecuteQuerySuccess implements Action { - readonly type = EXECUTE_QUERY_SUCCESS; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -export class ExecuteQueryFail implements Action { - readonly type = EXECUTE_QUERY_FAIL; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -/* -* Execute Metadata SQL++ Query -*/ -export class ExecuteMetadataQuery implements Action { - readonly type = EXECUTE_METADATA_QUERY; - constructor(public payload: string) {} // the AsterixDB Query String -} - -export class ExecuteMetadataQuerySuccess implements Action { - readonly type = EXECUTE_METADATA_QUERY_SUCCESS; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -export class ExecuteMetadataQueryFail implements Action { - readonly type = EXECUTE_METADATA_QUERY_FAIL; - constructor(public payload: AsterixDBQueryMessage[]) {} -} - -/* -* Exports of SQL++ actions -*/ -export type All = ExecuteQuery | - ExecuteQuerySuccess | - ExecuteQueryFail | - ExecuteMetadataQuery | - ExecuteMetadataQuerySuccess | - ExecuteMetadataQueryFail; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataset.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataset.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataset.effects.ts deleted file mode 100755 index b5624a4..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataset.effects.ts +++ /dev/null @@ -1,65 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Action } from '@ngrx/store'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import * as datasetActions from '../actions/dataset.actions'; -import { SQLService } from '../services/async-query.service'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = datasetActions.All - -@Injectable() -export class DatasetEffects { - constructor(private actions: Actions, - private sqlService: SQLService) {} - - /* Effect to load a collection of all Datasets from AsterixDB - */ - @Effect() - selectDatasets$: Observable<Action> = this.actions - .ofType(datasetActions.SELECT_DATASETS) - .switchMap(query => { - return this.sqlService.selectDatasets() - .map(dataset => new datasetActions.SelectDatasetsSuccess(dataset)) - .catch(err => of(new datasetActions.SelectDatasetsFail(err))); - }); - - /* Effect to create a Datasets from AsterixDB - */ - @Effect() - createDatasets$: Observable<Action> = this.actions - .ofType(datasetActions.CREATE_DATASET) - .switchMap(dataset => { - return this.sqlService.createDataset((dataset as any).payload) - .map(dataset => new datasetActions.CreateDatasetSuccess(dataset)) - .catch(err => of(new datasetActions.CreateDatasetFail(err))); - }); - - /* Effect to drop a Datasets from AsterixDB - */ - @Effect() - dropDatasets$: Observable<Action> = this.actions - .ofType(datasetActions.DROP_DATASET) - .switchMap(dataset => { - console.log((dataset as any).payload) - return this.sqlService.dropDataset((dataset as any).payload) - .map(dataset => new datasetActions.DropDatasetSuccess(dataset)) - .catch(err => of(new datasetActions.DropDatasetFail(err))); - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/datatype.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/datatype.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/datatype.effects.ts deleted file mode 100755 index 4fa187f..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/datatype.effects.ts +++ /dev/null @@ -1,63 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import * as datatypeActions from '../actions/datatype.actions'; -import { SQLService } from '../services/async-query.service'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = datatypeActions.All - -@Injectable() -export class DatatypeEffects { - constructor(private actions: Actions, - private sqlService: SQLService) {} - - /* Effect to load a collection of all Datatypes from AsterixDB - */ - @Effect() - selectDatatypes$: Observable<Action> = this.actions - .ofType(datatypeActions.SELECT_DATATYPES) - .switchMap(query => { - return this.sqlService.selectDatatypes() - .map(datatype => new datatypeActions.SelectDatatypesSuccess(datatype)) - .catch(err => of(new datatypeActions.SelectDatatypesFail(err))); - }); - - /* Effect to create a Datatype from AsterixDB - */ - @Effect() - createDatatypes$: Observable<Action> = this.actions - .ofType(datatypeActions.CREATE_DATATYPE) - .switchMap(datatype => { - return this.sqlService.createDatatype((datatype as any).payload) - .map(datatype => new datatypeActions.CreateDatatypeSuccess(datatype)) - .catch(err => of(new datatypeActions.CreateDatatypeFail(err))); - }); - - /* Effect to drop a Datatype from AsterixDB - */ - @Effect() - dropDatatypes$: Observable<Action> = this.actions - .ofType(datatypeActions.DROP_DATATYPE) - .switchMap(datatype => { - return this.sqlService.dropDatatype((datatype as any).payload) - .map(datatype => new datatypeActions.DropDatatypeSuccess(datatype)) - .catch(err => of(new datatypeActions.DropDatatypeFail(err))); - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataverse.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataverse.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataverse.effects.ts deleted file mode 100755 index d917420..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/dataverse.effects.ts +++ /dev/null @@ -1,63 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import * as dataverseActions from '../actions/dataverse.actions'; -import { SQLService } from '../services/async-query.service'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = dataverseActions.All - -@Injectable() -export class DataverseEffects { - constructor(private actions: Actions, - private sqlService: SQLService) {} - - /* Effect to load a collection of all Dataverses from AsterixDB - */ - @Effect() - selectDataverses$: Observable<Action> = this.actions - .ofType(dataverseActions.SELECT_DATAVERSES) - .switchMap(query => { - return this.sqlService.selectDataverses() - .map(dataverse => new dataverseActions.SelectDataversesSuccess(dataverse)) - .catch(err => of(new dataverseActions.SelectDataversesFail(err))); - }); - - /* Effect to create Dataverse from AsterixDB - */ - @Effect() - createDataverses$: Observable<Action> = this.actions - .ofType(dataverseActions.CREATE_DATAVERSE) - .switchMap(dataverseName => { - return this.sqlService.createDataverse((dataverseName as any).payload) - .map(dataverse => new dataverseActions.CreateDataverseSuccess(dataverse)) - .catch(err => of(new dataverseActions.CreateDataverseFail(err))); - }); - - /* Effect to drop a Dataverse from AsterixDB - */ - @Effect() - dropDataverses$: Observable<Action> = this.actions - .ofType(dataverseActions.DROP_DATAVERSE) - .switchMap(dataverseName => { - return this.sqlService.dropDataverse((dataverseName as any).payload) - .map(dataverse => new dataverseActions.DropDataverseSuccess(dataverse)) - .catch(err => of(new dataverseActions.DropDataverseFail(err))); - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/index.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/index.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/index.effects.ts deleted file mode 100755 index 8491392..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/index.effects.ts +++ /dev/null @@ -1,63 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import * as indexActions from '../actions/index.actions'; -import { SQLService } from '../services/async-query.service'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = indexActions.All - -@Injectable() -export class IndexEffects { - constructor(private actions: Actions, - private sqlService: SQLService) {} - - /* Effect to load a collection of all Index from AsterixDB - */ - @Effect() - selectIndexes$: Observable<Action> = this.actions - .ofType(indexActions.SELECT_INDEXES) - .switchMap(query => { - return this.sqlService.selectIndexes() - .map(index => new indexActions.SelectIndexesSuccess(index)) - .catch(err => of(new indexActions.SelectIndexesFail(err))); - }); - - /* Effect to create a Index - */ - @Effect() - createIndexes$: Observable<Action> = this.actions - .ofType(indexActions.CREATE_INDEX) - .switchMap(index => { - return this.sqlService.createIndex((index as any).payload) - .map(index => new indexActions.CreateIndexSuccess(index)) - .catch(err => of(new indexActions.CreateIndexFail(err))); - }); - - /* Effect to drop a Index - */ - @Effect() - dropIndexes$: Observable<Action> = this.actions - .ofType(indexActions.DROP_INDEX) - .switchMap(index => { - return this.sqlService.dropIndex((index as any).payload) - .map(index => new indexActions.DropIndexSuccess(index)) - .catch(err => of(new indexActions.DropIndexFail(err))); - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/metadata.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/metadata.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/metadata.effects.ts deleted file mode 100755 index ddcdb27..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/metadata.effects.ts +++ /dev/null @@ -1,41 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Action } from '@ngrx/store'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import { MetadataService } from '../services/async-metadata.service'; -import * as metadataActions from '../actions/metadata.actions'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = metadataActions.All - -@Injectable() -export class MetadataEffects { - constructor(private actions: Actions, - private metadataService: MetadataService) {} - - /* Effect to update and retrieve the Metadata Tree - */ - @Effect() - calculateDBTree$: Observable<Action> = this.actions - .ofType(metadataActions.UPDATE_METADATA_TREE) - .switchMap(() => { - return this.metadataService.getMetadataTree() - .map(tree => new metadataActions.UpdateMetadataTreeSuccess(tree)) - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/query.effects.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/query.effects.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/query.effects.ts deleted file mode 100755 index cb78255..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/effects/query.effects.ts +++ /dev/null @@ -1,53 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Action } from '@ngrx/store'; -import { Effect, Actions } from '@ngrx/effects'; -import { Observable } from 'rxjs/Observable'; -import { of } from 'rxjs/observable/of'; -import { SQLService } from '../services/async-query.service'; -import * as sqlQueryActions from '../actions/query.actions'; -import 'rxjs/add/operator/map'; -import 'rxjs/add/operator/switchMap'; -import 'rxjs/add/operator/catch'; - -export type Action = sqlQueryActions.All - -@Injectable() -export class SQLQueryEffects { - constructor(private actions: Actions, - private sqlService: SQLService) {} - - /* Effect to Execute an SQL++ Query against the AsterixDB - */ - @Effect() - executeQuery$: Observable<Action> = this.actions - .ofType(sqlQueryActions.EXECUTE_QUERY) - .switchMap(query => { - return this.sqlService.executeSQLQuery((query as any).payload) - .map(sqlQueryResult => new sqlQueryActions.ExecuteQuerySuccess(sqlQueryResult)) - .catch(sqlQueryError => of(new sqlQueryActions.ExecuteQueryFail(sqlQueryError))); - }); - - /* Effect to Execute an SQL++ Metadata Query against the AsterixDB - */ - @Effect() - executeMetadataQuery$: Observable<Action> = this.actions - .ofType(sqlQueryActions.EXECUTE_METADATA_QUERY) - .switchMap(query => { - return this.sqlService.executeSQLQuery((query as any).payload) - .map(sqlMetadataQueryResult => new sqlQueryActions.ExecuteMetadataQuerySuccess(sqlMetadataQueryResult)) - .catch(sqlMetadataQueryError => of(new sqlQueryActions.ExecuteMetadataQueryFail(sqlMetadataQueryError))); - }); -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/models/asterixDB.model.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/models/asterixDB.model.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/models/asterixDB.model.ts deleted file mode 100755 index bbdabe2..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/models/asterixDB.model.ts +++ /dev/null @@ -1,112 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -/* -* Interfaces representing AsterixDB data model structures. -*/ - -export interface Dataverse { - dataFormat: string; - dataverseName: string; - pendingOp: string; - timeStamp: string; -}; - -export interface ResultsM { - dataFormat: string; - dataverseName: string; - pendingOp: string; - timeStamp: string; -}; - -export interface Dataset { - compactionPolicy: string; - compactionPolicyProperties: CompactionPolicyProperties[]; - datasetId: string; - datasetName: string; - datasetType:string; - datatypeDataverseName: string; - datatypeName: string; - dataverseName: string; - groupName:string; - hints: string[]; - internalDetails: InternalDetails; - pendingOp: string; - timestamp: string; -}; - -export interface CompactionPolicyProperties { - name: string; - value: string; -}; - -export interface InternalDetails { - autogenerated: string; - fileStructure: string; - partitioningKey: string; - partitioningStrategy: string; - primaryKey: string[]; -}; - -// Message format coming back from AsterixDB REST API -export interface AsterixDBQueryMessage { - metrics: Metrics; - requestId: string; - results: any[]; - signature: string; - status: string; -}; - -export interface Metrics { - elapsedTime: string; - executionTime: string; - resultCount: string; - resultSize: string; -}; - -// Datatype Data Model comming from AsterixDB REST API -export interface Datatype { - datatypeName: string; - dataverseName: string; - derived: DatatypeDerived; - timeStamp: string; -}; - -export interface DatatypeDerived { - isAnonymous: boolean; - record: DatatypeDerivedRecord; - tag: string; -}; - -export interface DatatypeDerivedRecord { - Fields: DatatypeDerivedRecordField[]; - isOpen: boolean; -}; - -export interface DatatypeDerivedRecordField { - fieldName: string; - fieldType: "string"; - isNullable: boolean; -} - -// Index Data Model comming from AsterixDB REST API -export interface Index { - dataverseName: string; - datasetName: string; - indexName: string; - indexStructure: string; - searchKey: string[]; - isPrimary: boolean; - timestamp: string; - pendingOp: string; -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/keys.pipe.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/keys.pipe.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/keys.pipe.ts deleted file mode 100755 index 77cac5a..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/keys.pipe.ts +++ /dev/null @@ -1,25 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { PipeTransform, Pipe } from '@angular/core'; - -@Pipe({name: 'keys'}) -export class KeysPipe implements PipeTransform { - transform(value, args:string[]) : any { - let keys = []; - for (let key in value) { - keys.push(key); - } - return keys; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectArrayType.pipe.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectArrayType.pipe.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectArrayType.pipe.ts deleted file mode 100755 index 220b53c..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectArrayType.pipe.ts +++ /dev/null @@ -1,23 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -// Detecting if an object is an array -import { PipeTransform, Pipe } from '@angular/core'; - -@Pipe({name: 'isObjectArray'}) -export class ObjectArrayTypePipe implements PipeTransform { - transform(value, args:string[]) : any { - return value && (value.constructor.toString().indexOf("Array") != -1) - && value[0] && (value[0].constructor.toString().indexOf("Object") != -1); - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectType.pipe.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectType.pipe.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectType.pipe.ts deleted file mode 100755 index 5b8f795..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/pipes/objectType.pipe.ts +++ /dev/null @@ -1,21 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { PipeTransform, Pipe } from '@angular/core'; - -@Pipe({name: 'isObject'}) -export class ObjectTypePipe implements PipeTransform { - transform(value, args:string[]) : any { - return value && (value.constructor.toString().indexOf("Object") != -1); - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/app.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/app.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/app.reducer.ts deleted file mode 100755 index 01c65ac..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/app.reducer.ts +++ /dev/null @@ -1,73 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { AsterixDBQueryMessage } from '../models/asterixDB.model'; -import * as appActions from '../actions/app.actions'; - -export type Action = appActions.All; - -/* -** Interfaces for app state in store/state -*/ -export interface State { - loading: boolean, - loaded: boolean, - success: boolean, - sqlQueryString: string, - sqlQueryResult: AsterixDBQueryMessage[], - sqlQueryError: AsterixDBQueryMessage[], - sqlMetadataQueryString: string, - sqlMetadataQueryResult: AsterixDBQueryMessage[], - sqlMetadataQueryError: AsterixDBQueryMessage[] -}; - -const initialState: State = { - loading: false, - loaded: false, - success: false, - sqlQueryString: "", - sqlQueryResult: [], - sqlQueryError: [], - sqlMetadataQueryString: "", - sqlMetadataQueryResult: [], - sqlMetadataQueryError: [], -}; - -/* -** Reducer function for app state in store/state -*/ -export function appReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the load state to true, and clear previous results - * to signaling that a EXECUTE a SQL++ Query is ongoing - */ - case appActions.APP_MODE_CHANGE: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: false, - sqlQueryString: action.payload, - sqlQueryResult: [], - sqlQueryError: [] - }); - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataset.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataset.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataset.reducer.ts deleted file mode 100755 index 25d09b9..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataset.reducer.ts +++ /dev/null @@ -1,177 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Dataset } from '../models/asterixDB.model'; -import * as DatasetAction from '../actions/dataset.actions'; - -export type Action = DatasetAction.All; - -/* -** Interfaces for datasets in store/state -*/ -export interface State { - loaded: boolean, - loading: boolean, - datasets: any[], - createDataset: any[], - createDatasetError: any[], - createDatasetSuccess: boolean, - createDatasetFailed: boolean, - dropDataset: any[], - dropDatasetError: any[], - dropDatasetSuccess: boolean, - dropDatasetFailed: boolean, - guideSelectsDataset: string, -}; - -const initialState: State = { - loaded: false, - loading: false, - datasets: [], - createDataset: [], - createDatasetError: [], - createDatasetSuccess: false, - createDatasetFailed: false, - dropDataset: [], - dropDatasetError: [], - dropDatasetSuccess: false, - dropDatasetFailed: false, - guideSelectsDataset: "" -}; - -/* -** Reducer function for datasets in store/state -*/ -export function datasetReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the selected dataset state to true to signaling - * UI from metadata guide - */ - case DatasetAction.GUIDE_SELECT_DATASET: { - return Object.assign({}, state, { guideSelectsDataset: action.payload }); - } - - /* - * Change the load state to true to signaling - * that a SELECT Query is ongoing - */ - case DatasetAction.SELECT_DATASETS: { - return Object.assign({}, state, { loading: true }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a SELECT Query is success and there is datasets available in the - * store - */ - case DatasetAction.SELECT_DATASETS_SUCCESS: { - return Object.assign({}, state, { - loaded: true, - loading: false, - datasets: action.payload - }) - } - - /* - * Change the load state to true to signaling - * that a CREATE a Dataset Query is ongoing - */ - case DatasetAction.CREATE_DATASET: { - return Object.assign({}, state, { - createDataset: [], - createDatasetError: [], - createDatasetSuccess: false, - createDatasetFailed: false, - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Dataset Query is success and there is datasets available in the - * store - */ - case DatasetAction.CREATE_DATASET_SUCCESS: { - return Object.assign({}, state, { - createDataset: action.payload, - createDatasetName: action.payload, - createDatasetError: [], - createDatasetSuccess: true, - createDatasetFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Dataset Query is failed and there is an error message available in the - * store - */ - case DatasetAction.CREATE_DATASET_FAIL: { - return Object.assign({}, state, { - createDataset: [], - createDatasetError: action.payload, - createDatasetSuccess: false, - createDatasetFailed: true - }) - } - - /* - * Change the load state to true to signaling - * that a DROP a Dataset Query is ongoing - */ - case DatasetAction.DROP_DATASET: { - return Object.assign({}, state, { - dropDataset: [], - dropDatasetError: [], - dropDatasetName: action.payload, - dropDatasetSuccess: false, - dropDatasetFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Dataset Query is success and there is datasets available in the - * store - */ - case DatasetAction.DROP_DATASET_SUCCESS: { - return Object.assign({}, state, { - dropDataset: action.payload, - dropDatasetError: [], - dropDatasetSuccess: true, - dropDatasetFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Dataset Query is failed and there is an error message available in the - * store - */ - case DatasetAction.DROP_DATASET_FAIL: { - return Object.assign({}, state, { - dropDataset: [], - dropDatasetError: action.payload, - dropDatasetSuccess: false, - dropDatasetFailed: true - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/datatype.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/datatype.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/datatype.reducer.ts deleted file mode 100755 index 1036fdb..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/datatype.reducer.ts +++ /dev/null @@ -1,167 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Datatype } from '../models/asterixDB.model'; -import * as DatatypeAction from '../actions/datatype.actions'; - -export type Action = DatatypeAction.All; - -/* -** Interfaces for datatype in store/state -*/ -export interface State { - loaded: boolean, - loading: boolean, - datatypes: Datatype[], - createDatatype: any[], - createDatatypeError: any[], - createDatatypeSuccess: boolean, - createDatatypeFailed: boolean, - dropDatatype: any[], - dropDatatypeError: any[], - dropDatatypeSuccess: boolean, - dropDatatypeFailed: boolean -}; - -const initialState: State = { - loaded: false, - loading: false, - datatypes: [], - createDatatype: [], - createDatatypeError: [], - createDatatypeSuccess: false, - createDatatypeFailed: false, - dropDatatype: [], - dropDatatypeError: [], - dropDatatypeSuccess: false, - dropDatatypeFailed: false -}; - -/* -** Reducer function for datatypes in store/state -*/ -export function datatypeReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the load state to true to signaling - * that a SELECT Query is ongoing - */ - case DatatypeAction.SELECT_DATATYPES: { - return Object.assign({}, state, { loading: true }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a SELECT Query is success and there is datatypes available in the - * store - */ - case DatatypeAction.SELECT_DATATYPES_SUCCESS: { - return Object.assign({}, state, { - loaded: true, - loading: false, - datatypes: action.payload - }) - } - - /* - * Change the load state to true to signaling - * that a CREATE a Datatype Query is ongoing - */ - case DatatypeAction.CREATE_DATATYPE: { - return Object.assign({}, state, { - createDatatype: [], - createDatatypeName: action.payload, - createDatatypeError: [], - createDatatypeSuccess: false, - createDatatypeFailed: false, - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Datatype Query is success and there is datasets available in the - * store - */ - case DatatypeAction.CREATE_DATATYPE_SUCCESS: { - return Object.assign({}, state, { - createDatatype: action.payload, - createDatatypeError: [], - createDatatypeSuccess: true, - createDatatypeFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Datatype Query is failed and there is an error message available in the - * store - */ - case DatatypeAction.CREATE_DATATYPE_FAIL: { - return Object.assign({}, state, { - createDatatype: [], - createDatatypeError: action.payload, - createDatatypeSuccess: false, - createDatatypeFailed: true - }) - } - - /* - * Change the load state to true to signaling - * that a DROP a Datatype Query is ongoing - */ - case DatatypeAction.DROP_DATATYPE: { - return Object.assign({}, state, { - dropDatatype: [], - dropDatatypeName: action.payload, - dropDatatypeError: [], - dropDatatypeSuccess: false, - dropDatatypeFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Datatype Query is success and there is datasets available in the - * store - */ - case DatatypeAction.DROP_DATATYPE_SUCCESS: { - return Object.assign({}, state, { - dropDatatype: action.payload, - dropDatatypeError: [], - dropDatatypeSuccess: true, - dropDatatypeFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Datatype Query is failed and there is an error message available in the - * store - */ - case DatatypeAction.DROP_DATATYPE_FAIL: { - return Object.assign({}, state, { - dropDatatype: [], - dropDatatypeError: action.payload, - dropDatatypeSuccess: false, - dropDatatypeFailed: true - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataverse.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataverse.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataverse.reducer.ts deleted file mode 100755 index 7ac78ea..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/dataverse.reducer.ts +++ /dev/null @@ -1,171 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Dataverse } from '../models/asterixDB.model'; -import * as DataverseAction from '../actions/dataverse.actions'; - -export type Action = DataverseAction.All; - -/* -** Interfaces for dataverses in store/state -*/ -export interface State { - loaded: boolean, - loading: boolean, - dataverses: any[], - createDataverse: any[], - createDataverseName: string, - createDataverseError: any[], - createDataverseSuccess: boolean, - createDataverseFailed: boolean - dropDataverse: any[], - dropDataverseName: string; - dropDataverseError: any[], - dropDataverseSuccess: boolean, - dropDataverseFailed: boolean -}; - -const initialState: State = { - loaded: false, - loading: false, - dataverses: [], - createDataverse: [], - createDataverseName: "", - createDataverseError: [], - createDataverseSuccess: false, - createDataverseFailed: false, - dropDataverse: [], - dropDataverseName: "", - dropDataverseError: [], - dropDataverseSuccess: false, - dropDataverseFailed: false -}; - -/* -** Reducer function for dataverses in store/state -*/ -export function dataverseReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the load state to true to signaling - * that a SELECT Query is ongoing - */ - case DataverseAction.SELECT_DATAVERSES: { - return Object.assign({}, state, { loading: true }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a SELECT Query is success and there is dataverses available in the - * store - */ - case DataverseAction.SELECT_DATAVERSES_SUCCESS: { - return Object.assign({}, state, { - loaded: true, - loading: false, - dataverses: action.payload // _.sortBy(_.values(action.payload), 'dataverseName') - }) - } - - /* - * Change the load state to true to signaling - * that a CREATE a Dataset Query is ongoing - */ - case DataverseAction.CREATE_DATAVERSE: { - return Object.assign({}, state, { - createDataverse: [], - createDataverseName: action.payload, - createDataverseError: [], - createDataverseSuccess: false, - createDataverseFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Dataverse Query is success and there is a success message available in the - * store - */ - case DataverseAction.CREATE_DATAVERSE_SUCCESS: { - return Object.assign({}, state, { - createDataverse: action.payload, - createDataverseError: [], - createDataverseSuccess: true, - createDataverseFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Dataverse Query is failed and there is an error message available in the - * store - */ - case DataverseAction.CREATE_DATAVERSE_FAIL: { - return Object.assign({}, state, { - createDataverse: [], - createDataverseError: action.payload, - createDataverseSuccess: false, - createDataverseFailed: true - }) - } - - /* - * Change the load state to true to signaling - * that a DROP a Dataverse Query is ongoing - */ - case DataverseAction.DROP_DATAVERSE: { - return Object.assign({}, state, { - dropDataverse: [], - dropDataverseName: action.payload, - dropDataverseError: [], - dropDataverseSuccess: false, - dropDataverseFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Dataverse Query is success and there is success message available in the - * store - */ - case DataverseAction.DROP_DATAVERSE_SUCCESS: { - return Object.assign({}, state, { - dropDataverse: action.payload, - dropDataverseError: [], - dropDataverseSuccess: true, - dropDataverseFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Dataverse Query is failed and there is an error message available in the - * store - */ - case DataverseAction.DROP_DATAVERSE_FAIL: { - return Object.assign({}, state, { - dropDataverse: [], - dropDataverseError: action.payload, - dropDataverseSuccess: false, - dropDataverseFailed: true - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.reducer.ts deleted file mode 100755 index 792abc7..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.reducer.ts +++ /dev/null @@ -1,167 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Index } from '../models/asterixDB.model'; -import * as IndexAction from '../actions/index.actions'; - -export type Action = IndexAction.All; - -/* -** Interfaces for indexes in store/state -*/ -export interface State { - loaded: boolean, - loading: boolean, - indexes: Index[], - createIndex: any[], - createIndexError: any[], - createIndexSuccess: boolean, - createIndexFailed: boolean, - dropIndex: any[], - dropIndexError: any[], - dropIndexSuccess: boolean, - dropIndexFailed: boolean -}; - -const initialState: State = { - loaded: false, - loading: false, - indexes: [], - createIndex: [], - createIndexError: [], - createIndexSuccess: false, - createIndexFailed: false, - dropIndex: [], - dropIndexError: [], - dropIndexSuccess: false, - dropIndexFailed: false -}; - -/* -** Reducer function for indexes in store/state -*/ -export function indexReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the load state to true to signaling - * that a SELECT Query is ongoing - */ - case IndexAction.SELECT_INDEXES: { - return Object.assign({}, state, { loading: true }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a SELECT Query is success and there is indexes available in the - * store - */ - case IndexAction.SELECT_INDEXES_SUCCESS: { - return Object.assign({}, state, { - loaded: true, - loading: false, - indexes: action.payload - }) - } - - /* - * Change the load state to true to signaling - * that a CREATE a Index Query is ongoing - */ - case IndexAction.CREATE_INDEX: { - return Object.assign({}, state, { - createIndex: [], - createIndexName: action.payload, - createIndexError: [], - createIndexSuccess: false, - createIndexFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Index Query is success and there is datasets available in the - * store - */ - case IndexAction.CREATE_INDEX_SUCCESS: { - return Object.assign({}, state, { - createIndex: [], - createIndexError: [], - createIndexSuccess: true, - createIndexFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a CREATE a Index Query is success and there is datasets available in the - * store - */ - case IndexAction.CREATE_INDEX_SUCCESS: { - return Object.assign({}, state, { - createIndex: action.payload, - createIndexError: [], - createIndexSuccess: false, - createIndexFailed: true - }) - } - - /* - * Change the load state to true to signaling - * that a DROP a Index Query is ongoing - */ - case IndexAction.DROP_INDEX: { - return Object.assign({}, state, { - dropIndex: [], - dropIndexError: [], - dropIndexName: action.payload, - dropIndexSuccess: false, - dropIndexFailed: false - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Index Query is success and there is datasets available in the - * store - */ - case IndexAction.DROP_INDEX_SUCCESS: { - return Object.assign({}, state, { - dropIndex: action.payload, - dropIndexError: [], - dropIndexSuccess: true, - dropIndexFailed: false - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a DROP a Index Query is failed and there is an error message available in the - * store - */ - case IndexAction.DROP_INDEX_FAIL: { - return Object.assign({}, state, { - dropIndex: [], - dropIndexError: action.payload, - dropIndexSuccess: false, - dropIndexFailed: true - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.ts deleted file mode 100755 index 1965d8c..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/index.ts +++ /dev/null @@ -1,49 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { ActionReducer } from '@ngrx/store'; -import * as fromDataverse from './dataverse.reducer'; -import * as fromDataset from './dataset.reducer'; -import * as fromDatatype from './datatype.reducer'; -import * as fromIndex from './index.reducer'; -import * as fromQuery from './query.reducer'; -import * as fromQueryMetadata from './query-metadata.reducer'; -import * as fromMetadata from './metadata.reducer'; -import * as fromAppState from './app.reducer'; - -/* -** Global Interfaces store/state -*/ -export interface ModelState { - dataverse: fromDataverse.State, - dataset: fromDataset.State, - datatype: fromDatatype.State, - index: fromIndex.State, - sqlQuery: fromQuery.State, - sqlMetadataQuery: fromQueryMetadata.State, - metadata: fromMetadata.State, - appState: fromAppState.State, -} - -/* -** Global Reducers configuration -*/ -export const reducers = { - dataverse: fromDataverse.dataverseReducer, - dataset: fromDataset.datasetReducer, - datatype: fromDatatype.datatypeReducer, - index: fromIndex.indexReducer, - sqlQuery: fromQuery.sqlReducer, - sqlMetadataQuery: fromQueryMetadata.sqlMetadataReducer, - metadata: fromMetadata.metadataTreeReducer -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/metadata.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/metadata.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/metadata.reducer.ts deleted file mode 100755 index 52b88f2..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/metadata.reducer.ts +++ /dev/null @@ -1,56 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import * as metadataTreeActions from '../actions/metadata.actions'; - -export type Action = metadataTreeActions.All; - -/* -** Interfaces for the metadata tree in store/state -*/ -export interface State { - tree: any[], - loading: boolean, - loaded: boolean, -}; - -const initialState: State = { - tree: [], - loading: false, - loaded: false -}; - -export function metadataTreeReducer(state = initialState, action: Action) { - switch (action.type) { - case metadataTreeActions.UPDATE_METADATA_TREE: { - return Object.assign({}, state, { - tree: [], - loading: true, - loaded: false - }); - } - - case metadataTreeActions.UPDATE_METADATA_TREE_SUCCESS: { - return Object.assign({}, state, { - tree: [...state.tree, action.payload], - loading: false, - loaded: true - }); - } - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query-metadata.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query-metadata.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query-metadata.reducer.ts deleted file mode 100755 index e360e95..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query-metadata.reducer.ts +++ /dev/null @@ -1,96 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { AsterixDBQueryMessage } from '../models/asterixDB.model'; -import * as sqlQueryActions from '../actions/query.actions'; - -export type Action = sqlQueryActions.All; - -/* -** Interfaces for sql++ queries in store/state -*/ -export interface State { - loading: boolean, - loaded: boolean, - success: boolean, - sqlQueryMetadataString: string, - sqlQueryMetadataResult: AsterixDBQueryMessage[], - sqlQueryMetadataError: AsterixDBQueryMessage[] -}; - -const initialState: State = { - loading: false, - loaded: false, - success: false, - sqlQueryMetadataString: "", - sqlQueryMetadataResult: [], - sqlQueryMetadataError: [], -}; - -/* -** Reducer function for sql++ queries in store/state -*/ -export function sqlMetadataReducer(state = initialState, action: Action) { - switch (action.type) { - /* - * Change the load state to true, and clear previous results - * to signaling that a METADATA EXECUTE a SQL++ Query is ongoing - */ - case sqlQueryActions.EXECUTE_METADATA_QUERY: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: false, - sqlQueryMetadataString: action.payload, - sqlQueryMetadataResult: [], - sqlQueryMetadataError: [] - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a METADATA EXECUTE Query is success and there is data available in the - * store - */ - case sqlQueryActions.EXECUTE_METADATA_QUERY_SUCCESS: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: true, - sqlQueryMetadataResult: action.payload, - sqlQueryMetadataError: [] - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a METADATA EXECUTE Query is failed and there is error data available in the - * store - */ - case sqlQueryActions.EXECUTE_METADATA_QUERY_FAIL: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: false, - sqlQueryMetadataResult: [], - sqlQueryMetadataError: action.payload - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query.reducer.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query.reducer.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query.reducer.ts deleted file mode 100755 index 5c8ad08..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/reducers/query.reducer.ts +++ /dev/null @@ -1,97 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { AsterixDBQueryMessage } from '../models/asterixDB.model'; -import * as sqlQueryActions from '../actions/query.actions'; - -export type Action = sqlQueryActions.All; - -/* -** Interfaces for sql++ queries in store/state -*/ -export interface State { - loading: boolean, - loaded: boolean, - success: boolean, - sqlQueryString: string, - sqlQueryResult: AsterixDBQueryMessage[], - sqlQueryError: AsterixDBQueryMessage[] -}; - -const initialState: State = { - loading: false, - loaded: false, - success: false, - sqlQueryString: "", - sqlQueryResult: [], - sqlQueryError: [] -}; - -/* -** Reducer function for sql++ queries in store/state -*/ -export function sqlReducer(state = initialState, action: Action) { - switch (action.type) { - - /* - * Change the load state to true, and clear previous results - * to signaling that a EXECUTE a SQL++ Query is ongoing - */ - case sqlQueryActions.EXECUTE_QUERY: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: false, - sqlQueryString: action.payload, - sqlQueryResult: [], - sqlQueryError: [] - }); - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a EXECUTE Query is success and there is data available in the - * store - */ - case sqlQueryActions.EXECUTE_QUERY_SUCCESS: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: true, - sqlQueryResult: action.payload, - sqlQueryError: [] - }) - } - - /* - * Change the load state to false, and loaded to true to signaling - * that a EXECUTE Query is failed and there is error data available in the - * store - */ - case sqlQueryActions.EXECUTE_QUERY_FAIL: { - return Object.assign({}, state, { - loading: false, - loaded: true, - success: false, - sqlQueryResult: [], - sqlQueryError: action.payload - }) - } - - /* - * Just returns the current store/state object - */ - default: - return state; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/app-core.service.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/app-core.service.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/app-core.service.ts deleted file mode 100755 index ed38c26..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/app-core.service.ts +++ /dev/null @@ -1,38 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable } from '@angular/core'; -import { Store } from '@ngrx/store'; -import * as dataverseActions from '../../shared/actions/dataverse.actions' -import * as datasetActions from '../../shared/actions/dataset.actions' -import * as datatypesActions from '../../shared/actions/datatype.actions' -import * as indexesActions from '../../shared/actions/index.actions' -import * as metadataActions from '../../shared/actions/metadata.actions' - -/* -* Main application service to initialize, -* load, set App status and initial data, and synchronize app level functionality -*/ -@Injectable() -export class AppCoreService { - /* - * Initialize and load metadata store structures - */ - constructor(private store: Store<any>) { - console.log('AsterixDB Web Console Core Service') - this.store.dispatch(new dataverseActions.SelectDataverses('-')); - this.store.dispatch(new datasetActions.SelectDatasets('-')); - this.store.dispatch(new datatypesActions.SelectDatatypes('-')); - this.store.dispatch(new indexesActions.SelectIndexes('-')); - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7e8dbe3/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/async-metadata.service.ts ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/async-metadata.service.ts b/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/async-metadata.service.ts deleted file mode 100755 index 8492a54..0000000 --- a/asterixdb/asterix-app/src/main/resources/dashboard/src/app/shared/services/async-metadata.service.ts +++ /dev/null @@ -1,120 +0,0 @@ -/* -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -import { Injectable, ApplicationRef } from '@angular/core'; -import { Store } from '@ngrx/store'; -import { Observable } from "rxjs/Observable"; -import 'rxjs/add/operator/map'; -import 'rxjs/add/observable/from'; -import * as dataverseActions from '../../shared/actions/dataverse.actions' -import * as datasetActions from '../../shared/actions/dataset.actions' -import * as datatypesActions from '../../shared/actions/datatype.actions' -import * as indexesActions from '../../shared/actions/index.actions' -import * as metadataActions from '../../shared/actions/metadata.actions' - -/* - Metadata service watch any changes in Dataverses, Datasets, Datatypes, indexes - state in store and builds a tree state structure with datasets->dataverse->datatype->index relationship -*/ -@Injectable() -export class MetadataService { - - /* Arrays to expose updated dataverses, datasets, datatypes, - indexes collections*/ - dv = []; - ds = []; - dt = []; - idx = []; - - /* - * contructor will initialize the store state watchers - */ - constructor(private store: Store<any>, private ref: ApplicationRef ) { - - /* Watching changes in dataverse collection */ - this.store.select(s => s.dataverse.dataverses).subscribe((data: any) => { - if (data.results) { - this.dv = [] - for (let i = 0; i < data.results.length; i++) { - let node = { id: 0, DataverseName: "", Datasets:[] } - node.id = i - node.DataverseName = data.results[i]['DataverseName'] - this.dv.push(node) - } - this.updateMetadataTree(); - } - }) - - /* Watching changes in datasets collections */ - this.store.select(s => s.dataset.datasets).subscribe((data: any) => { - if (data.results) { - this.ds = data.results; - this.updateMetadataTree(); - } - }) - - /* Watching changes in datatypes collections */ - this.store.select(s => s.datatype.datatypes).subscribe((data: any) => { - if (data.results) { - this.dt = data.results; - this.updateMetadataTree(); - } - }) - - /* Watching changes in index collections */ - this.store.select(s => s.index.indexes).subscribe((data: any) => { - if (data.results) { - this.idx = data.results; - this.updateMetadataTree(); - } - }) - } - - /* - * convenience function to update and return the metadata tree. - */ - getMetadataTree(): Observable<any[]> { - return Observable.from(this.dv); - } - - updateMetadataTree() { - for (let i = 0; i < this.dv.length; i++) { - // Filling datasets - this.dv[i]['Datasets'] = []; - for (let j = 0; j < this.ds.length; j++) { - if (this.ds[j]['DataverseName'] === this.dv[i]['DataverseName']){ - - // Filling datatypes, there is one datatype per dataset - this.ds[j]['Datatype'] = []; - for (let k = 0; k < this.dt.length; k++) { - if (this.dt[k]['DatatypeName'] === this.ds[j]['DatatypeName']){ - this.ds[j]['Datatype'] = this.dt[k]; // push(this.dt[k]) - } - } - - // Filling indexes - this.ds[j]['Indexes'] = []; - for (let l = 0; l < this.idx.length; l++) { - if (this.idx[l]['DatasetName'] === this.ds[j]['DatasetName']){ - this.ds[j]['Indexes'].push(this.idx[l]) - } - } - - this.dv[i]['Datasets'].push(this.ds[j]) - } - } - } - - this.store.dispatch(new metadataActions.UpdateMetadataTree()); - } -}
