Revision 50883
Added by Myrto Koukouli about 6 years ago
broker.service.ts | ||
---|---|---|
26 | 26 |
|
27 | 27 |
constructor(private http: Http) { } |
28 | 28 |
|
29 |
advancedShowEvents(page: number,searchParams: AdvQueryObject): Observable<EventsPage>{ |
|
30 |
let url = `${this.apiUrl}advancedShowEvents/${page}/10`;
|
|
29 |
advancedShowEvents(page: number,size: number,searchParams: AdvQueryObject): Observable<EventsPage>{
|
|
30 |
let url = `${this.apiUrl}advancedShowEvents/${page}/${size}`;
|
|
31 | 31 |
console.log(`knocking on: ${url}`); |
32 | 32 |
let body = searchParams; |
33 | 33 |
console.log(`sending ${JSON.stringify(body)}`); |
... | ... | |
55 | 55 |
.catch(this.handleError); |
56 | 56 |
} |
57 | 57 |
|
58 |
getNotificationsBySubscriptionId(subId: string, page: number): Observable<EventsPage> { |
|
59 |
let url = `${this.apiUrl}getNotificationsBySubscriptionId/${subId}/${page}/100`;
|
|
58 |
getNotificationsBySubscriptionId(subId: string, page: number, size: number): Observable<EventsPage> {
|
|
59 |
let url = `${this.apiUrl}getNotificationsBySubscriptionId/${subId}/${page}/${size}`;
|
|
60 | 60 |
console.log(`knocking on: ${url}`); |
61 | 61 |
return this.http.get(url) |
62 | 62 |
.map( res => <EventsPage>res.json()) |
... | ... | |
79 | 79 |
.catch(this.handleError); |
80 | 80 |
} |
81 | 81 |
|
82 |
/* |
|
83 |
NOT WORKING AND PROBABLY NOT NEEDED |
|
84 |
getSubscriptionsOfUser(userEmail): Observable<Subscription[]> {} |
|
85 |
*/ |
|
82 |
getSubscriptionsOfUser(userEmail: string): Observable<Map<string, Subscription>> { |
|
83 |
let url = `${this.apiUrl}getSubscriptionsOfUser/${userEmail}/`; |
|
84 |
console.log(`knocking on: ${url}`); |
|
85 |
return this.http.get(url) |
|
86 |
.map( res => <Map<string,Subscription>>res.json()) |
|
87 |
.catch(this.handleError); |
|
88 |
} |
|
86 | 89 |
|
87 | 90 |
getTopicsForDataSource(name: string): Observable<BrowseEntry[]> { |
88 | 91 |
let url = `${this.apiUrl}getTopicsForDatasource/${name}`; |
... | ... | |
106 | 109 |
subscribeToEvent(sub: OpenaireSubscription): Observable<string>{ |
107 | 110 |
let url = `${this.apiUrl}subscribe`; |
108 | 111 |
console.log(`knocking on: ${url}`); |
109 |
let body = JSON.stringify(sub); |
|
110 | 112 |
httpOptions.withCredentials = true; |
111 |
return this.http.post(url,body,httpOptions)
|
|
112 |
.map( res => res.json())
|
|
113 |
return this.http.post(url,sub,httpOptions)
|
|
114 |
.map( res => res.status.toString())
|
|
113 | 115 |
.catch(this.handleError); |
114 | 116 |
} |
115 | 117 |
|
Also available in: Unified diff
finished subscriptions and notifications