mirror of
https://github.com/bpatrik/pigallery2.git
synced 2024-12-16 11:37:13 +02:00
118 lines
3.4 KiB
TypeScript
118 lines
3.4 KiB
TypeScript
import {Injectable} from "@angular/core";
|
|
import {NetworkService} from "../model/network/network.service";
|
|
import {ContentWrapper} from "../../../common/entities/ConentWrapper";
|
|
import {DirectoryDTO} from "../../../common/entities/DirectoryDTO";
|
|
import {SearchTypes} from "../../../common/entities/AutoCompleteItem";
|
|
import {GalleryCacheService} from "./cache.gallery.service";
|
|
import {BehaviorSubject} from "rxjs/BehaviorSubject";
|
|
import {SharingDTO} from "../../../common/entities/SharingDTO";
|
|
import {Config} from "../../../common/config/public/Config";
|
|
import {ShareService} from "./share.service";
|
|
|
|
@Injectable()
|
|
export class GalleryService {
|
|
|
|
public content: BehaviorSubject<ContentWrapper>;
|
|
private lastDirectory: DirectoryDTO;
|
|
private searchId: any;
|
|
|
|
constructor(private networkService: NetworkService,
|
|
private galleryCacheService: GalleryCacheService,
|
|
private _shareService: ShareService) {
|
|
this.content = new BehaviorSubject<ContentWrapper>(new ContentWrapper());
|
|
}
|
|
|
|
lastRequest: { directory: string } = {
|
|
directory: null
|
|
};
|
|
|
|
public async getDirectory(directoryName: string): Promise<ContentWrapper> {
|
|
const content = new ContentWrapper();
|
|
|
|
content.directory = this.galleryCacheService.getDirectory(directoryName);
|
|
content.searchResult = null;
|
|
|
|
this.content.next(content);
|
|
this.lastRequest.directory = directoryName;
|
|
|
|
let cw: ContentWrapper = null;
|
|
if (Config.Client.Sharing.enabled == true) {
|
|
if (this._shareService.isSharing()) {
|
|
cw = await this.networkService.getJson<ContentWrapper>("/gallery/content/" + directoryName + "?sk=" + this._shareService.getSharingKey());
|
|
}
|
|
}
|
|
|
|
if (cw == null) {
|
|
cw = await this.networkService.getJson<ContentWrapper>("/gallery/content/" + directoryName);
|
|
}
|
|
|
|
if (!cw) {
|
|
return;
|
|
}
|
|
|
|
this.galleryCacheService.setDirectory(cw.directory); //save it before adding references
|
|
|
|
if (this.lastRequest.directory != directoryName) {
|
|
return;
|
|
}
|
|
|
|
|
|
DirectoryDTO.addReferences(cw.directory);
|
|
|
|
|
|
this.lastDirectory = cw.directory;
|
|
this.content.next(cw);
|
|
|
|
|
|
return cw;
|
|
|
|
}
|
|
|
|
//TODO: cache
|
|
public async search(text: string, type?: SearchTypes): Promise<ContentWrapper> {
|
|
clearTimeout(this.searchId);
|
|
if (text === null || text === '' || text.trim() == ".") {
|
|
return null
|
|
}
|
|
|
|
let queryString = "/search/" + text;
|
|
if (type) {
|
|
queryString += "?type=" + type;
|
|
}
|
|
const cw: ContentWrapper = await this.networkService.getJson<ContentWrapper>(queryString);
|
|
this.content.next(cw);
|
|
return cw;
|
|
}
|
|
|
|
//TODO: cache (together with normal search)
|
|
public async instantSearch(text: string): Promise<ContentWrapper> {
|
|
if (text === null || text === '' || text.trim() == ".") {
|
|
const content = new ContentWrapper();
|
|
content.directory = this.lastDirectory;
|
|
content.searchResult = null;
|
|
this.content.next(content);
|
|
clearTimeout(this.searchId);
|
|
return null
|
|
}
|
|
|
|
if (this.searchId != null) {
|
|
clearTimeout(this.searchId);
|
|
|
|
}
|
|
this.searchId = setTimeout(() => {
|
|
this.search(text);
|
|
this.searchId = null;
|
|
}, 3000); //TODO: set timeout to config
|
|
|
|
const cw = await this.networkService.getJson<ContentWrapper>("/instant-search/" + text);
|
|
this.content.next(cw);
|
|
return cw;
|
|
|
|
}
|
|
|
|
public async getSharing(sharingKey: string): Promise<SharingDTO> {
|
|
return this.networkService.getJson<SharingDTO>("/share/" + sharingKey);
|
|
}
|
|
|
|
}
|