106 lines
3.0 KiB
TypeScript
106 lines
3.0 KiB
TypeScript
//https://github.com/AndrewPoyntz/time-ago-pipe/issues/6#issuecomment-313726956
|
|
|
|
import { Pipe, PipeTransform, NgZone } from "@angular/core";
|
|
import { Observable, Observer } from 'rxjs';
|
|
|
|
interface processOutput {
|
|
text: string; // Convert timestamp to string
|
|
timeToUpdate: number; // Time until update in milliseconds
|
|
}
|
|
|
|
@Pipe({
|
|
name: 'timeAgo',
|
|
pure: true
|
|
})
|
|
export class TimeAgoPipe implements PipeTransform {
|
|
|
|
constructor(private ngZone: NgZone) { }
|
|
|
|
private process = (timestamp: number): processOutput => {
|
|
let text: string;
|
|
let timeToUpdate: number;
|
|
|
|
const now = new Date();
|
|
|
|
// Time ago in milliseconds
|
|
const timeAgo: number = now.getTime() - timestamp;
|
|
|
|
const seconds = timeAgo / 1000;
|
|
const minutes = seconds / 60;
|
|
const hours = minutes / 60;
|
|
const days = hours / 24;
|
|
// const months = days / 30.416;
|
|
const years = days / 365;
|
|
|
|
if (seconds <= 59) {
|
|
text = Math.round(seconds) + 's';
|
|
} else if (minutes <= 59) {
|
|
text = Math.round(minutes) + 'm';
|
|
} else if (hours <= 23) {
|
|
text = Math.round(hours) + 'h';
|
|
} else if (days < 365) {
|
|
text = Math.round(days) + 'd';
|
|
} else {
|
|
text = Math.round(years) + 'y';
|
|
}
|
|
|
|
if (minutes < 1) {
|
|
// update every 2 secs
|
|
timeToUpdate = 2 * 1000;
|
|
} else if (hours < 1) {
|
|
// update every 30 secs
|
|
timeToUpdate = 30 * 1000;
|
|
} else if (days < 1) {
|
|
// update every 5 mins
|
|
timeToUpdate = 300 * 1000;
|
|
} else {
|
|
// update every hour
|
|
timeToUpdate = 3600 * 1000;
|
|
}
|
|
|
|
return {
|
|
text,
|
|
timeToUpdate
|
|
};
|
|
}
|
|
|
|
public transform = (value: string | Date): Observable<string> => {
|
|
let d: Date;
|
|
if (value instanceof Date) {
|
|
d = value;
|
|
}
|
|
else {
|
|
d = new Date(value);
|
|
}
|
|
// time value in milliseconds
|
|
const timestamp = d.getTime();
|
|
|
|
let timeoutID: any;
|
|
|
|
return Observable.create((observer: Observer<string>) => {
|
|
let latestText = '';
|
|
|
|
// Repeatedly set new timeouts for new update checks.
|
|
const registerUpdate = () => {
|
|
const processOutput = this.process(timestamp);
|
|
if (processOutput.text !== latestText) {
|
|
latestText = processOutput.text;
|
|
this.ngZone.run(() => {
|
|
observer.next(latestText);
|
|
});
|
|
}
|
|
timeoutID = setTimeout(registerUpdate, processOutput.timeToUpdate);
|
|
};
|
|
|
|
this.ngZone.runOutsideAngular(registerUpdate);
|
|
|
|
// Return teardown function
|
|
const teardownFunction = () => {
|
|
if (timeoutID) {
|
|
clearTimeout(timeoutID);
|
|
}
|
|
};
|
|
return teardownFunction;
|
|
});
|
|
}
|
|
} |