feat(ghost): Implement Tag, Author and Page models; add advanced filtering, search, bulk operations, image upload, related-posts, update tests and bump dependencies
This commit is contained in:
@@ -1,5 +1,8 @@
|
||||
import * as plugins from './ghost.plugins.js';
|
||||
import { Post, type IPostOptions } from './classes.post.js';
|
||||
import { Post, type IPost, type ITag, type IAuthor } from './classes.post.js';
|
||||
import { Author } from './classes.author.js';
|
||||
import { Tag } from './classes.tag.js';
|
||||
import { Page, type IPage } from './classes.page.js';
|
||||
|
||||
export interface IGhostConstructorOptions {
|
||||
baseUrl: string;
|
||||
@@ -28,10 +31,38 @@ export class Ghost {
|
||||
});
|
||||
}
|
||||
|
||||
public async getPosts(limit: number = 1000): Promise<Post[]> {
|
||||
public async getPosts(optionsArg?: {
|
||||
limit?: number;
|
||||
tag?: string;
|
||||
author?: string;
|
||||
featured?: boolean;
|
||||
filter?: string;
|
||||
}): Promise<Post[]> {
|
||||
try {
|
||||
const postsData = await this.contentApi.posts.browse({ limit, include: 'tags,authors' });
|
||||
return postsData.map((postData: IPostOptions) => new Post(this, postData));
|
||||
const limit = optionsArg?.limit || 1000;
|
||||
const filters: string[] = [];
|
||||
|
||||
if (optionsArg?.tag) {
|
||||
filters.push(`tag:${optionsArg.tag}`);
|
||||
}
|
||||
if (optionsArg?.author) {
|
||||
filters.push(`author:${optionsArg.author}`);
|
||||
}
|
||||
if (optionsArg?.featured !== undefined) {
|
||||
filters.push(`featured:${optionsArg.featured}`);
|
||||
}
|
||||
if (optionsArg?.filter) {
|
||||
filters.push(optionsArg.filter);
|
||||
}
|
||||
|
||||
const filterString = filters.length > 0 ? filters.join('+') : undefined;
|
||||
|
||||
const postsData = await this.contentApi.posts.browse({
|
||||
limit,
|
||||
include: 'tags,authors',
|
||||
...(filterString && { filter: filterString })
|
||||
});
|
||||
return postsData.map((postData: IPost) => new Post(this, postData));
|
||||
} catch (error) {
|
||||
console.error('Error fetching posts:', error);
|
||||
throw error;
|
||||
@@ -48,7 +79,7 @@ export class Ghost {
|
||||
}
|
||||
}
|
||||
|
||||
public async createPost(postData: IPostOptions): Promise<Post> {
|
||||
public async createPost(postData: IPost): Promise<Post> {
|
||||
try {
|
||||
const createdPostData = await this.adminApi.posts.add(postData);
|
||||
return new Post(createdPostData, this.adminApi);
|
||||
@@ -65,4 +96,213 @@ export class Ghost {
|
||||
);
|
||||
return new Post(this, postData);
|
||||
}
|
||||
|
||||
public async getTags(optionsArg?: { filter?: string; limit?: number }): Promise<ITag[]> {
|
||||
try {
|
||||
const limit = optionsArg?.limit || 1000;
|
||||
const tagsData = await this.contentApi.tags.browse({ limit });
|
||||
|
||||
if (optionsArg?.filter) {
|
||||
const matcher = new plugins.smartmatch.SmartMatch(optionsArg.filter);
|
||||
return tagsData.filter((tag: ITag) => matcher.match(tag.slug));
|
||||
}
|
||||
|
||||
return tagsData;
|
||||
} catch (error) {
|
||||
console.error('Error fetching tags:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getTagById(id: string): Promise<Tag> {
|
||||
try {
|
||||
const tagData = await this.contentApi.tags.read({ id });
|
||||
return new Tag(this, tagData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching tag with id ${id}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getTagBySlug(slug: string): Promise<Tag> {
|
||||
try {
|
||||
const tagData = await this.contentApi.tags.read({ slug });
|
||||
return new Tag(this, tagData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching tag with slug ${slug}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async createTag(tagData: Partial<ITag>): Promise<Tag> {
|
||||
try {
|
||||
const createdTagData = await this.adminApi.tags.add(tagData);
|
||||
return new Tag(this, createdTagData);
|
||||
} catch (error) {
|
||||
console.error('Error creating tag:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getAuthors(optionsArg?: { filter?: string; limit?: number }): Promise<Author[]> {
|
||||
try {
|
||||
const limit = optionsArg?.limit || 1000;
|
||||
const authorsData = await this.contentApi.authors.browse({ limit });
|
||||
|
||||
if (optionsArg?.filter) {
|
||||
const matcher = new plugins.smartmatch.SmartMatch(optionsArg.filter);
|
||||
return authorsData
|
||||
.filter((author: IAuthor) => matcher.match(author.slug))
|
||||
.map((author: IAuthor) => new Author(this, author));
|
||||
}
|
||||
|
||||
return authorsData.map((author: IAuthor) => new Author(this, author));
|
||||
} catch (error) {
|
||||
console.error('Error fetching authors:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getAuthorById(id: string): Promise<Author> {
|
||||
try {
|
||||
const authorData = await this.contentApi.authors.read({ id });
|
||||
return new Author(this, authorData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching author with id ${id}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getAuthorBySlug(slug: string): Promise<Author> {
|
||||
try {
|
||||
const authorData = await this.contentApi.authors.read({ slug });
|
||||
return new Author(this, authorData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching author with slug ${slug}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getPages(optionsArg?: { limit?: number; filter?: string }): Promise<Page[]> {
|
||||
try {
|
||||
const limit = optionsArg?.limit || 1000;
|
||||
const pagesData = await this.contentApi.pages.browse({ limit, include: 'tags,authors' });
|
||||
|
||||
if (optionsArg?.filter) {
|
||||
const matcher = new plugins.smartmatch.SmartMatch(optionsArg.filter);
|
||||
return pagesData
|
||||
.filter((page: IPage) => matcher.match(page.slug))
|
||||
.map((page: IPage) => new Page(this, page));
|
||||
}
|
||||
|
||||
return pagesData.map((pageData: IPage) => new Page(this, pageData));
|
||||
} catch (error) {
|
||||
console.error('Error fetching pages:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getPageById(id: string): Promise<Page> {
|
||||
try {
|
||||
const pageData = await this.contentApi.pages.read({ id });
|
||||
return new Page(this, pageData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching page with id ${id}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getPageBySlug(slug: string): Promise<Page> {
|
||||
try {
|
||||
const pageData = await this.contentApi.pages.read({ slug });
|
||||
return new Page(this, pageData);
|
||||
} catch (error) {
|
||||
console.error(`Error fetching page with slug ${slug}:`, error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async createPage(pageData: Partial<IPage>): Promise<Page> {
|
||||
try {
|
||||
const createdPageData = await this.adminApi.pages.add(pageData);
|
||||
return new Page(this, createdPageData);
|
||||
} catch (error) {
|
||||
console.error('Error creating page:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async searchPosts(query: string, optionsArg?: { limit?: number }): Promise<Post[]> {
|
||||
try {
|
||||
const limit = optionsArg?.limit || 100;
|
||||
const postsData = await this.contentApi.posts.browse({
|
||||
limit,
|
||||
filter: `title:~'${query}'`,
|
||||
include: 'tags,authors'
|
||||
});
|
||||
return postsData.map((postData: IPost) => new Post(this, postData));
|
||||
} catch (error) {
|
||||
console.error('Error searching posts:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async uploadImage(filePath: string): Promise<string> {
|
||||
try {
|
||||
const result = await this.adminApi.images.upload({ file: filePath });
|
||||
return result.url;
|
||||
} catch (error) {
|
||||
console.error('Error uploading image:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async bulkUpdatePosts(postIds: string[], updates: Partial<IPost>): Promise<Post[]> {
|
||||
try {
|
||||
const updatePromises = postIds.map(async (id) => {
|
||||
const post = await this.getPostById(id);
|
||||
return post.update({ ...post.postData, ...updates, id });
|
||||
});
|
||||
return await Promise.all(updatePromises);
|
||||
} catch (error) {
|
||||
console.error('Error bulk updating posts:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async bulkDeletePosts(postIds: string[]): Promise<void> {
|
||||
try {
|
||||
const deletePromises = postIds.map(async (id) => {
|
||||
const post = await this.getPostById(id);
|
||||
return post.delete();
|
||||
});
|
||||
await Promise.all(deletePromises);
|
||||
} catch (error) {
|
||||
console.error('Error bulk deleting posts:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
public async getRelatedPosts(postId: string, limit: number = 5): Promise<Post[]> {
|
||||
try {
|
||||
const post = await this.getPostById(postId);
|
||||
const tags = post.postData.tags;
|
||||
|
||||
if (!tags || !Array.isArray(tags) || tags.length === 0) {
|
||||
return [];
|
||||
}
|
||||
|
||||
const tagSlugs = tags.map(tag => tag.slug).join(',');
|
||||
const postsData = await this.contentApi.posts.browse({
|
||||
limit,
|
||||
filter: `tag:[${tagSlugs}]+id:-${postId}`,
|
||||
include: 'tags,authors'
|
||||
});
|
||||
|
||||
return postsData.map((postData: IPost) => new Post(this, postData));
|
||||
} catch (error) {
|
||||
console.error('Error fetching related posts:', error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user