import { ActivatedRoute } from '@angular/router';
import { Directive, OnInit, HostListener, ElementRef, Input, Inject } from '@angular/core';
import { CsGroupAddableBloc } from '@project-sunbird/client-services/blocs';
import { filter } from 'rxjs/operators';
import { ResourceService } from './../../services/resource/resource.service';
import { NavigationHelperService } from '../../services/navigation-helper/navigation-helper.service';
import { ToasterService } from '../../services/toaster/toaster.service';
import * as _ from 'lodash-es';
import { takeUntil } from 'rxjs/operators';
import { Subject } from 'rxjs';
import { CsGroupService } from '@project-sunbird/client-services/services/group/interface';
import { CsModule } from '@project-sunbird/client-services';
import { TelemetryService } from '@sunbird/telemetry';
import { SELECT_ACTIVITY } from '../../../groups/interfaces/telemetryConstants';
import { ActivityDashboardService } from '../../services';
// import { sessionKeys } from '../../../../modules/groups';


// tslint:disable-next-line:only-arrow-functions
export function csGroupServiceFactory() {
  if (CsModule.instance.isInitialised) {
    return CsModule.instance.groupService;
  }
  return undefined;
}

@Directive({
  selector: '[appAddToGroup]',
  providers: [{ provide: 'CS_GROUP_SERVICE', useFactory: csGroupServiceFactory}]
})
export class AddToGroupDirective implements OnInit {

  @Input() pageId: string;
  @Input() identifier: string;
  unsubscribe$ = new Subject<void>();
  groupAddableBlocData: any;
  constructor(
    private ref: ElementRef,
    public navigationHelperService: NavigationHelperService,
    public toasterService: ToasterService,
    public resourceService: ResourceService,
    @Inject('CS_GROUP_SERVICE')
    private csGroupService: CsGroupService,
    private activatedRoute: ActivatedRoute,
    private telemetryService: TelemetryService,
    // private groupService: GroupsService,
    public activityDashboardService: ActivityDashboardService) { }

  @HostListener('click', ['$event'])
  clickEvent(event) {
    this.addActivityToGroup();
  }

  ngOnInit() {
    CsGroupAddableBloc.instance.state$.pipe(takeUntil(this.unsubscribe$)).subscribe(data => {
      this.groupAddableBlocData = data; //|| JSON.parse(sessionStorage.getItem(sessionKeys.GROUPADDABLEBLOCDATA));
    });
    if (CsGroupAddableBloc.instance.initialised) {
      CsGroupAddableBloc.instance.state$.pipe(
        takeUntil(this.unsubscribe$),
        filter((state) => state && state.pageIds.includes(this.pageId))
      ).subscribe(data => {
        (this.ref.nativeElement as HTMLButtonElement).style.display = data ? 'block' : 'none';
      });
    }
    (this.ref.nativeElement as HTMLButtonElement).style.display = this.activityDashboardService.isActivityAdded ? 'none' : 'block';
  }

  addActivityToGroup() {
    this.sendInteractData('add-to-group-button', {type: SELECT_ACTIVITY});
    const isActivityAdded = _.find(_.get(this.groupAddableBlocData, 'params.groupData.activities'), {id: this.identifier});
    if ( _.isEmpty(isActivityAdded)) {
      const request = {
        activities: [{ id: this.identifier, type: _.get(this.groupAddableBlocData, 'params.contentType') }]
      };
        this.csGroupService.addActivities(_.get(this.groupAddableBlocData, 'groupId'), request).subscribe(response => {
        this.goBack();
        if (_.get(response, 'error.activities[0].errorCode') === 'EXCEEDED_ACTIVITY_MAX_LIMIT') {
          this.showErrorMsg(this.resourceService.messages.groups.emsg.m003);
          this.sendInteractData('exceeded-activity-max-limit', {type: 'max-limit'}, {activities_count:
            (_.get(this.groupAddableBlocData, 'params.groupData.activities')).length});
        } else {
          this.toasterService.success(this.resourceService.messages.imsg.activityAddedSuccess);
        }

      }, error => {
        console.error('Error while adding activity to the group', error);
        this.goBack();
        this.toasterService.error(this.resourceService.messages.stmsg.activityAddFail);
      });
    } else {
      this.goBack();
      isActivityAdded ? this.showErrorMsg(this.resourceService.messages.emsg.activityAddedToGroup) :
      this.showErrorMsg(this.resourceService.messages.emsg.noAdminRole);
    }
  }

  sendInteractData(id, edata, extra?) {
    console.log('nc,mvbdf', this.activatedRoute);
    const data = {
      context: {
        env: 'groups',
        cdata: [
        {
          type: 'Group',
          id: _.get(this.activatedRoute.snapshot, 'params.groupId') || _.get(this.activatedRoute.snapshot, 'queryParams.groupId') ||
          _.get(this.groupAddableBlocData, 'groupId')
        },
        {
          type: 'Activity',
          id: this.identifier,
        }
      ]
      },
      edata: {
        id: id,
        type: edata.type || 'CLICK',
        pageid: this.pageId
      },
      object: {
        type: _.get(this.groupAddableBlocData, 'params.contentType'),
        id: this.identifier,
        ver: '1.0'
      }
    };
    if (extra) {
      data.edata['extra'] = extra;
    }

    this.telemetryService.interact(data);
  }

  showErrorMsg(msg) {
    this.toasterService.error(msg);
  }

  goBack() {
    this.navigationHelperService.navigateToLastUrl();
  }
}