/*-
 * ============LICENSE_START=======================================================
 * SDC
 * ================================================================================
 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
 * ================================================================================
 * 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.
 * ============LICENSE_END=========================================================
 */

import {Injectable, Inject} from "@angular/core";
import {Observable} from "rxjs/Observable";
import {HttpService} from "./http.service";
import {SdcConfigToken, ISdcConfig} from "../config/sdc-config.config";
import {PolicyInstance, PolicyTargetsRequest} from '../../models/graph/zones/policy-instance';
import {IZoneInstanceAssignment} from "../../models/graph/zones/zone-instance";
import {IZoneService} from "../../models/graph/zones/zone";
import {TargetUiObject} from "../../models/ui-models/ui-target-object";
import {TargetOrMemberType} from "../../utils/constants";


@Injectable()
export class PoliciesService implements IZoneService {
    protected baseUrl;

    private mapApiDirections = {
        'RESOURCE': 'resources',
        'SERVICE': 'services'
    }

    constructor(private http:HttpService, @Inject(SdcConfigToken) sdcConfig:ISdcConfig) {
        this.baseUrl = sdcConfig.api.root;
    }

    public createPolicyInstance(topologyTemplateType:string, topologyTemplateId:string, policyType:string) {
        return this.http.post(this.baseUrl + '/v1/catalog/' + this.mapApiDirections[topologyTemplateType.toUpperCase()] + '/' + topologyTemplateId + '/policies/' + policyType, {}).map(resp => {
            return resp.json();
        });
    }

    public addPolicyTarget(topologyTemplateType:string, topologyTemplateId:string, policy:PolicyInstance, targetId:string, targetType:TargetOrMemberType) {
        let _targets:Array<string>;
        let _members:Array<string>;

        if (targetType === TargetOrMemberType.COMPONENT_INSTANCES) {
            _targets = angular.copy(policy.targets.COMPONENT_INSTANCES);
            _targets.push(targetId);
        } else if (targetType === TargetOrMemberType.GROUPS) {
            _members = angular.copy(policy.targets.GROUPS);
            _members.push(targetId);
        }
        let policyTargetRequest:PolicyTargetsRequest = new PolicyTargetsRequest(_members, _targets);
        return this.updatePolicyTargets(topologyTemplateType, topologyTemplateId, policy.uniqueId, policyTargetRequest);
    }

    public deletePolicyTarget(topologyTemplateType:string, topologyTemplateId:string, policy:PolicyInstance, targetId:string, targetType:TargetOrMemberType): Observable<PolicyInstance> {
        let _targets:Array<string> = angular.copy(policy.targets.COMPONENT_INSTANCES);
        let _members:Array<string> = angular.copy(policy.targets.GROUPS);
        if (targetType === TargetOrMemberType.COMPONENT_INSTANCES) {
            _targets = _.without(_targets, targetId);
        } else if (targetType === TargetOrMemberType.GROUPS) {
            _members = _.without(_members, targetId);
        }
        let policyTargetRequest:PolicyTargetsRequest = new PolicyTargetsRequest(_members, _targets);
        return this.updatePolicyTargets(topologyTemplateType, topologyTemplateId, policy.uniqueId, policyTargetRequest);
    }

    public updatePolicyTargets(topologyTemplateType:string, topologyTemplateId:string, policyId:string, targets:PolicyTargetsRequest): Observable<PolicyInstance> {
        return this.http.post(this.baseUrl + '/v1/catalog/' + this.mapApiDirections[topologyTemplateType.toUpperCase()] + '/' + topologyTemplateId + '/policies/' + policyId + '/targets', targets.requestItems)
            .map(response => new PolicyInstance(response.json()));
    }

    public updateTargets(topologyTemplateType:string, topologyTemplateId:string, policyId:string, targets:Array<TargetUiObject>):Observable<PolicyInstance> {
        let instances:Array<string> = _.filter(targets, (target:TargetUiObject)=> {
            return target.type === TargetOrMemberType.COMPONENT_INSTANCES;
        }).map(target => target.uniqueId);

        let groups:Array<string> = _.filter(targets, (target:TargetUiObject)=> {
            return target.type === TargetOrMemberType.GROUPS;
        }).map(target => target.uniqueId);

        let policyTargetRequest:PolicyTargetsRequest = new PolicyTargetsRequest(groups, instances);
        return this.updatePolicyTargets(topologyTemplateType, topologyTemplateId, policyId, policyTargetRequest);
    }

    public getSpecificPolicy(topologyTemplateType:string, topologyTemplateId:string, policyId:string):Observable<PolicyInstance> {
        return this.http.get(this.baseUrl + '/v1/catalog/' + this.mapApiDirections[topologyTemplateType.toUpperCase()] + '/' + topologyTemplateId + '/policies/' + policyId)
            .map(res => {
                return new PolicyInstance(res.json());
            });
    }

    public updateName(topologyTemplateType:string, topologyTemplateId:string, policyId:string, newName:string):Observable<any> {
        return this.http.put(this.baseUrl + '/v1/catalog/' + this.mapApiDirections[topologyTemplateType.toUpperCase()] + '/' + topologyTemplateId + '/policies/' + policyId, {name: newName}).map(res => {
            return res.json();
        });
    };

    public deletePolicy(topologyTemplateType:string, topologyTemplateId:string, policyId:string) {
        return this.http.delete(this.baseUrl + '/v1/catalog/' + this.mapApiDirections[topologyTemplateType.toUpperCase()] + '/' + topologyTemplateId + '/policies/' + policyId).map(resp => {
            return resp.json();
        });
    };

    public updateZoneInstanceAssignments(topologyTemplateType:string, topologyTemplateId:string, policyId:string, targets:Array<IZoneInstanceAssignment>):Observable<PolicyInstance>{
        return this.updateTargets(topologyTemplateType, topologyTemplateId, policyId, targets);
    };

    public deleteZoneInstance(topologyTemplateType:string, topologyTemplateId:string, policyId:string):Observable<any> {
        return this.deletePolicy(topologyTemplateType, topologyTemplateId, policyId);
    };

}