diff --git a/src/app/community/community.module.ts b/src/app/community/community.module.ts
index e44ac38..2bc425d 100644
--- a/src/app/community/community.module.ts
+++ b/src/app/community/community.module.ts
@@ -17,11 +17,12 @@ import {ConfigurationService} from '../openaireLibrary/utils/configuration/confi
import {FreeGuard} from '../openaireLibrary/login/freeGuard.guard';
import {PreviousRouteRecorder} from '../openaireLibrary/utils/piwik/previousRouteRecorder.guard';
+import {SubscribeModule} from '../utils/subscribe/subscribe.module';
@NgModule({
imports: [
CommonModule, FormsModule, RouterModule,
- CommunityRoutingModule
+ CommunityRoutingModule, SubscribeModule
],
declarations: [
CommunityComponent, ResultsComponent
diff --git a/src/app/utils/subscribe/subscribe.component.ts b/src/app/utils/subscribe/subscribe.component.ts
new file mode 100644
index 0000000..1975d07
--- /dev/null
+++ b/src/app/utils/subscribe/subscribe.component.ts
@@ -0,0 +1,82 @@
+import { Component, Input } from '@angular/core';
+import { Location } from '@angular/common';
+import {ActivatedRoute} from '@angular/router';
+import { EnvProperties} from '../../openaireLibrary/utils/properties/env-properties';
+
+import {SubscribeService} from './subscribe.service';
+import {Session} from '../../openaireLibrary/login/utils/helper.class';
+@Component({
+ selector: 'subscribe',
+ template: `
+
+
+ `
+})
+
+export class SubscribeComponent {
+ // @Input() showSubscribe:boolean = true;
+ @Input() showNumbers:boolean;
+ @Input() communityId:string;
+
+
+ subscribed:boolean = null;
+ properties:EnvProperties;
+ constructor (private route: ActivatedRoute,
+ private _subscribeService: SubscribeService
+ ) {
+ }
+
+ public ngOnInit() {
+ this.route.data
+ .subscribe((data: { envSpecific: EnvProperties }) => {
+ this.properties = data.envSpecific;
+ console.log("subscribe "+ this.communityId);
+ var email = Session.getUserEmail();
+ if(email == null){
+ this.subscribed = false;
+ }else{
+ //this.properties.adminToolsAPIURL
+ this._subscribeService.isSubscribedToCommunity(this.communityId, email,this.properties.adminToolsAPIURL).subscribe (
+ res => {
+ this.subscribed = res;
+ });
+ }
+ });
+
+ }
+
+ subscribe(){
+ var email = Session.getUserEmail();
+ if(email == null){
+ this.subscribed = false;
+ }else{
+ //this.properties.adminToolsAPIURL
+ this._subscribeService.subscribeToCommunity(this.communityId, email, this.properties.adminToolsAPIURL).subscribe (
+ res => {
+ console.log(res);
+ if(!this.subscribed){
+ this.subscribed = true;
+ }
+ });
+ }
+ }
+
+ unsubscribe(){
+ var email = Session.getUserEmail();
+ if(email == null){
+ this.subscribed = false;
+ }else{
+ //this.properties.adminToolsAPIURL
+ this._subscribeService.unSubscribeToCommunity(this.communityId, email,"http://scoobydoo.di.uoa.gr:8080/uoa-admin-tools/").subscribe (
+ res => {
+ console.log(res);
+ if(this.subscribed){
+ this.subscribed = false;
+ }
+ });
+ }
+ }
+}
diff --git a/src/app/utils/subscribe/subscribe.module.ts b/src/app/utils/subscribe/subscribe.module.ts
new file mode 100644
index 0000000..bf5bed0
--- /dev/null
+++ b/src/app/utils/subscribe/subscribe.module.ts
@@ -0,0 +1,22 @@
+import { NgModule} from '@angular/core';
+import { CommonModule } from '@angular/common';
+import { RouterModule } from '@angular/router';
+
+import { SubscribeService } from './subscribe.service';
+import {SubscribeComponent} from './subscribe.component';
+
+@NgModule({
+ imports: [
+ CommonModule, RouterModule
+ ],
+ declarations: [
+ SubscribeComponent
+ ],
+ providers:[
+ SubscribeService
+ ],
+ exports: [
+ SubscribeComponent
+ ]
+})
+export class SubscribeModule { }
diff --git a/src/app/utils/subscribe/subscribe.service.ts b/src/app/utils/subscribe/subscribe.service.ts
new file mode 100644
index 0000000..75c7ee3
--- /dev/null
+++ b/src/app/utils/subscribe/subscribe.service.ts
@@ -0,0 +1,55 @@
+import { Injectable } from '@angular/core';
+import { Http, Response, Headers, RequestOptions } from '@angular/http';
+import { Observable } from 'rxjs/Rx';
+import {COOKIE} from "../../openaireLibrary/login/utils/helper.class"
+
+
+@Injectable()
+export class SubscribeService {
+
+ constructor(private http:Http) {
+ }
+ getCommunitySubscribers(pid:string, url:string){
+ return this.http.get(url+"/community/"+pid+"/subscribers")
+ .map(res =>
res.json()).do(res => {console.log(res)}).do(res => {console.log(res)});
+ }
+
+ isSubscribedToCommunity(pid:string, email:string, url:string){
+ return this.http.get(url+"/community/"+pid+"/subscribers")
+ .map(res => ((res =="")?{}: res.json()))
+
+ .map(res => {
+ if(res.subscribers && res.subscribers != null){
+
+ for(var i =0; i< res.subscribers.length; i++ ){
+ if(res.subscribers[i]!=null && res.subscribers[i].email == email){
+ return true;
+ }
+ }
+ }
+ return false;
+
+ }).do(res => {console.log("Response is "+res)});
+ }
+ subscribeToCommunity(pid:string, email:string, url:string){
+ var subscriber = {"email":email};
+ return this.http.post(url+"/community/"+pid+"/subscribers", JSON.stringify(subscriber), this.getAuthOptionsWithBody())
+ .map(res => res.json())
+ .do(res => {console.log("Response is "+res)});
+ }
+ unSubscribeToCommunity(pid:string, email:string, url:string){
+
+ return this.http.post(url+"/community/"+pid+"/subscribers/delete", JSON.stringify([email]), this.getAuthOptionsWithBody())
+ .map(res => res.json())
+ .do(res => {console.log("Response is "+res)});
+ }
+
+ public getAuthOptionsWithBody():RequestOptions{
+ let headers = new Headers();
+ headers.append('Content-Type', 'application/json');
+ headers.append('X-XSRF-TOKEN', COOKIE.getCookie(COOKIE.cookieName_id));
+ let options = new RequestOptions({ headers: headers, withCredentials:true });
+ return options;
+ }
+
+}