6adecb5db1
refs https://github.com/TryGhost/Team/issues/1563 - Check if we have multiple newsletters in the members-events-fetcher - Pass the resulting value to the `parse-member-event` helper - Pass the value to the activity feed table and table-row components
124 lines
3.7 KiB
JavaScript
124 lines
3.7 KiB
JavaScript
import moment from 'moment';
|
|
import {Resource} from 'ember-could-get-used-to-this';
|
|
import {TrackedArray} from 'tracked-built-ins';
|
|
import {action} from '@ember/object';
|
|
import {inject as service} from '@ember/service';
|
|
import {task} from 'ember-concurrency';
|
|
import {tracked} from '@glimmer/tracking';
|
|
|
|
export default class MembersEventsFetcher extends Resource {
|
|
@service ajax;
|
|
@service ghostPaths;
|
|
@service store;
|
|
|
|
@tracked data = new TrackedArray([]);
|
|
@tracked isLoading = false;
|
|
@tracked isError = false;
|
|
@tracked errorMessage = null;
|
|
@tracked hasReachedEnd = false;
|
|
|
|
/**
|
|
* Keep track whether we have multiple newsletters (required for parsing events)
|
|
*/
|
|
@tracked hasMultipleNewsletters = null;
|
|
|
|
cursor = null;
|
|
|
|
get value() {
|
|
return {
|
|
isLoading: this.isLoading,
|
|
isError: this.isError,
|
|
errorMessage: this.errorMessage,
|
|
data: this.data,
|
|
loadNextPage: this.loadNextPage,
|
|
hasReachedEnd: this.hasReachedEnd,
|
|
hasMultipleNewsletters: this.hasMultipleNewsletters
|
|
};
|
|
}
|
|
|
|
async setup() {
|
|
this.cursor = moment.utc().format('YYYY-MM-DD HH:mm:ss');
|
|
let filter = `data.created_at:<'${this.cursor}'`;
|
|
|
|
if (this.args.named.filter) {
|
|
filter += `+${this.args.named.filter}`;
|
|
}
|
|
|
|
// Can't get this working with Promise.all, somehow results in an infinite loop
|
|
await this.loadEventsTask.perform({filter});
|
|
await this.loadMultipleNewslettersTask.perform();
|
|
}
|
|
|
|
@action
|
|
loadNextPage() {
|
|
// NOTE: assumes data is always ordered by created_at desc
|
|
const lastEvent = this.data[this.data.length - 1];
|
|
|
|
if (!lastEvent?.data?.created_at) {
|
|
this.hasReachedEnd = true;
|
|
return;
|
|
}
|
|
|
|
const cursor = moment.utc(lastEvent.data.created_at).format('YYYY-MM-DD HH:mm:ss');
|
|
|
|
if (cursor === this.cursor) {
|
|
this.hasReachedEnd = true;
|
|
return;
|
|
}
|
|
|
|
this.cursor = cursor;
|
|
let filter = `data.created_at:<'${this.cursor}'`;
|
|
|
|
if (this.args.named.filter) {
|
|
filter += `+${this.args.named.filter}`;
|
|
}
|
|
|
|
this.loadEventsTask.perform({filter});
|
|
}
|
|
|
|
/**
|
|
* We need to know whether we have multiple newsletters so we can hide/show the newsletter name
|
|
*/
|
|
@task
|
|
*loadMultipleNewslettersTask() {
|
|
try {
|
|
const res = yield this.store.query('newsletter', {filter: 'status:active', include: 'none', limit: 1});
|
|
const newsletterCount = res.meta.pagination.total;
|
|
this.hasMultipleNewsletters = newsletterCount > 1;
|
|
} catch (e) {
|
|
// Default to true (harms the least)
|
|
this.hasMultipleNewsletters = true;
|
|
console.error(e); // eslint-disable-line
|
|
}
|
|
}
|
|
|
|
@task
|
|
*loadEventsTask(queryParams) {
|
|
try {
|
|
this.isLoading = true;
|
|
|
|
const url = this.ghostPaths.url.api('members/events');
|
|
const data = Object.assign({}, queryParams, {limit: this.args.named.pageSize});
|
|
const {events} = yield this.ajax.request(url, {data});
|
|
|
|
if (events.length < data.limit) {
|
|
this.hasReachedEnd = true;
|
|
}
|
|
|
|
this.data.push(...events);
|
|
} catch (e) {
|
|
this.isError = true;
|
|
|
|
const errorMessage = e.payload?.errors?.[0]?.message;
|
|
if (errorMessage) {
|
|
this.errorMessage = errorMessage;
|
|
}
|
|
|
|
// TODO: log to Sentry
|
|
console.error(e); // eslint-disable-line
|
|
} finally {
|
|
this.isLoading = false;
|
|
}
|
|
}
|
|
}
|