lemmy-js-client/src/http.ts

417 lines
11 KiB
TypeScript
Raw Normal View History

2020-08-20 03:51:57 +00:00
import fetch from 'node-fetch';
import {
2020-12-20 17:33:14 +00:00
CommentResponse,
CreateComment,
CreateCommentLike,
DeleteComment,
EditComment,
GetComments,
GetCommentsResponse,
MarkCommentAsRead,
RemoveComment,
SaveComment,
} from './interfaces/api/comment';
import {
AddModToCommunity,
AddModToCommunityResponse,
BanFromCommunity,
BanFromCommunityResponse,
CommunityJoin,
CommunityJoinResponse,
CommunityResponse,
CreateCommunity,
DeleteCommunity,
EditCommunity,
FollowCommunity,
GetCommunity,
GetCommunityResponse,
GetFollowedCommunities,
GetFollowedCommunitiesResponse,
ListCommunities,
ListCommunitiesResponse,
RemoveCommunity,
TransferCommunity,
} from './interfaces/api/community';
import {
CreatePost,
CreatePostLike,
DeletePost,
EditPost,
GetPost,
GetPostResponse,
GetPosts,
GetPostsResponse,
LockPost,
PostJoin,
PostJoinResponse,
PostResponse,
RemovePost,
SavePost,
StickyPost,
} from './interfaces/api/post';
import {
CreateSite,
EditSite,
GetModlog,
GetModlogResponse,
GetSite,
GetSiteConfig,
GetSiteConfigResponse,
2020-12-20 17:33:14 +00:00
GetSiteResponse,
ListCategoriesResponse,
2020-12-20 17:33:14 +00:00
SaveSiteConfig,
Search,
SearchResponse,
2020-12-20 17:33:14 +00:00
SiteResponse,
TransferSite,
} from './interfaces/api/site';
import {
AddAdmin,
AddAdminResponse,
2020-12-20 17:33:14 +00:00
BanUser,
BanUserResponse,
CreatePrivateMessage,
DeleteAccount,
DeletePrivateMessage,
EditPrivateMessage,
GetCaptchaResponse,
2020-12-20 17:33:14 +00:00
GetPrivateMessages,
GetReplies,
GetRepliesResponse,
GetUserDetails,
GetUserDetailsResponse,
GetUserMentions,
GetUserMentionsResponse,
2020-12-20 17:33:14 +00:00
Login,
LoginResponse,
MarkAllAsRead,
MarkPrivateMessageAsRead,
MarkUserMentionAsRead,
PasswordChange,
PasswordReset,
PasswordResetResponse,
PrivateMessageResponse,
PrivateMessagesResponse,
2020-12-20 17:33:14 +00:00
Register,
SaveUserSettings,
UserJoin,
UserJoinResponse,
UserMentionResponse,
} from './interfaces/api/user';
enum HttpType {
Get = 'GET',
Post = 'POST',
Put = 'PUT',
}
export class LemmyHttp {
private baseUrl: string;
private headers: { [key: string]: string } = {};
constructor(baseUrl: string, headers?: { [key: string]: string }) {
this.baseUrl = baseUrl;
if (headers) {
this.headers = headers;
}
}
2020-12-20 17:33:14 +00:00
async getSite(form: GetSite): Promise<GetSiteResponse> {
return this.wrapper(HttpType.Get, '/site', form);
}
2020-12-20 17:33:14 +00:00
async createSite(form: CreateSite): Promise<SiteResponse> {
return this.wrapper(HttpType.Post, '/site', form);
}
2020-12-20 17:33:14 +00:00
async editSite(form: EditSite): Promise<SiteResponse> {
return this.wrapper(HttpType.Put, '/site', form);
}
2020-12-20 17:33:14 +00:00
async transferSite(form: TransferSite): Promise<GetSiteResponse> {
return this.wrapper(HttpType.Post, '/site/transfer', form);
}
async getSiteConfig(form: GetSiteConfig): Promise<GetSiteConfigResponse> {
return this.wrapper(HttpType.Get, '/site/config', form);
}
2020-12-20 17:33:14 +00:00
async saveSiteConfig(form: SaveSiteConfig): Promise<GetSiteConfigResponse> {
return this.wrapper(HttpType.Put, '/site/config', form);
}
async listCategories(): Promise<ListCategoriesResponse> {
return this.wrapper(HttpType.Get, '/categories', {});
}
2020-12-20 17:33:14 +00:00
async getModlog(form: GetModlog): Promise<GetModlogResponse> {
return this.wrapper(HttpType.Get, '/modlog', form);
}
2020-12-20 17:33:14 +00:00
async search(form: Search): Promise<SearchResponse> {
return this.wrapper(HttpType.Get, '/search', form);
}
2020-12-20 17:33:14 +00:00
async createCommunity(form: CreateCommunity): Promise<CommunityResponse> {
return this.wrapper(HttpType.Post, '/community', form);
}
2020-12-20 17:33:14 +00:00
async getCommunity(form: GetCommunity): Promise<GetCommunityResponse> {
return this.wrapper(HttpType.Get, '/community', form);
}
2020-12-20 17:33:14 +00:00
async editCommunity(form: EditCommunity): Promise<CommunityResponse> {
return this.wrapper(HttpType.Put, '/community', form);
}
async listCommunities(
2020-12-20 17:33:14 +00:00
form: ListCommunities
): Promise<ListCommunitiesResponse> {
return this.wrapper(HttpType.Get, '/community/list', form);
}
2020-12-20 17:33:14 +00:00
async followCommunity(form: FollowCommunity): Promise<CommunityResponse> {
return this.wrapper(HttpType.Post, '/community/follow', form);
}
2020-12-20 17:33:14 +00:00
async deleteCommunity(form: DeleteCommunity): Promise<CommunityResponse> {
return this.wrapper(HttpType.Post, '/community/delete', form);
}
2020-12-20 17:33:14 +00:00
async removeCommunity(form: RemoveCommunity): Promise<CommunityResponse> {
return this.wrapper(HttpType.Post, '/community/remove', form);
}
async transferCommunity(
2020-12-20 17:33:14 +00:00
form: TransferCommunity
): Promise<GetCommunityResponse> {
return this.wrapper(HttpType.Post, '/community/transfer', form);
}
async banFromCommunity(
2020-12-20 17:33:14 +00:00
form: BanFromCommunity
): Promise<BanFromCommunityResponse> {
return this.wrapper(HttpType.Post, '/community/ban_user', form);
}
async addModToCommunity(
2020-12-20 17:33:14 +00:00
form: AddModToCommunity
): Promise<AddModToCommunityResponse> {
return this.wrapper(HttpType.Post, '/community/mod', form);
}
2020-12-20 17:33:14 +00:00
async createPost(form: CreatePost): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post', form);
}
2020-12-20 17:33:14 +00:00
async getPost(form: GetPost): Promise<GetPostResponse> {
return this.wrapper(HttpType.Get, '/post', form);
}
2020-12-20 17:33:14 +00:00
async editPost(form: EditPost): Promise<PostResponse> {
return this.wrapper(HttpType.Put, '/post', form);
}
2020-12-20 17:33:14 +00:00
async deletePost(form: DeletePost): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post/delete', form);
}
2020-12-20 17:33:14 +00:00
async removePost(form: RemovePost): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post/remove', form);
}
2020-12-20 17:33:14 +00:00
async lockPost(form: LockPost): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post/lock', form);
}
2020-12-20 17:33:14 +00:00
async stickyPost(form: StickyPost): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post/sticky', form);
}
2020-12-20 17:33:14 +00:00
async getPosts(form: GetPosts): Promise<GetPostsResponse> {
return this.wrapper(HttpType.Get, '/post/list', form);
}
2020-12-20 17:33:14 +00:00
async likePost(form: CreatePostLike): Promise<PostResponse> {
return this.wrapper(HttpType.Post, '/post/like', form);
}
2020-12-20 17:33:14 +00:00
async savePost(form: SavePost): Promise<PostResponse> {
return this.wrapper(HttpType.Put, '/post/save', form);
}
2020-12-20 17:33:14 +00:00
async createComment(form: CreateComment): Promise<CommentResponse> {
return this.wrapper(HttpType.Post, '/comment', form);
}
2020-12-20 17:33:14 +00:00
async editComment(form: EditComment): Promise<CommentResponse> {
return this.wrapper(HttpType.Put, '/comment', form);
}
2020-12-20 17:33:14 +00:00
async deleteComment(form: DeleteComment): Promise<CommentResponse> {
return this.wrapper(HttpType.Post, '/comment/delete', form);
}
2020-12-20 17:33:14 +00:00
async removeComment(form: RemoveComment): Promise<CommentResponse> {
return this.wrapper(HttpType.Post, '/comment/remove', form);
}
2020-12-20 17:33:14 +00:00
async markCommentAsRead(form: MarkCommentAsRead): Promise<CommentResponse> {
return this.wrapper(HttpType.Post, '/comment/mark_as_read', form);
}
2020-12-20 17:33:14 +00:00
async likeComment(form: CreateCommentLike): Promise<CommentResponse> {
return this.wrapper(HttpType.Post, '/comment/like', form);
}
2020-12-20 17:33:14 +00:00
async saveComment(form: SaveComment): Promise<CommentResponse> {
return this.wrapper(HttpType.Put, '/comment/save', form);
}
2020-12-20 17:33:14 +00:00
async getComments(form: GetComments): Promise<GetCommentsResponse> {
return this.wrapper(HttpType.Get, '/comment/list', form);
}
async getPrivateMessages(
2020-12-20 17:33:14 +00:00
form: GetPrivateMessages
): Promise<PrivateMessagesResponse> {
return this.wrapper(HttpType.Get, '/private_message/list', form);
}
async createPrivateMessage(
2020-12-20 17:33:14 +00:00
form: CreatePrivateMessage
): Promise<PrivateMessageResponse> {
return this.wrapper(HttpType.Post, '/private_message', form);
}
async editPrivateMessage(
2020-12-20 17:33:14 +00:00
form: EditPrivateMessage
): Promise<PrivateMessageResponse> {
return this.wrapper(HttpType.Put, '/private_message', form);
}
async deletePrivateMessage(
2020-12-20 17:33:14 +00:00
form: DeletePrivateMessage
): Promise<PrivateMessageResponse> {
return this.wrapper(HttpType.Post, '/private_message/delete', form);
}
async markPrivateMessageAsRead(
2020-12-20 17:33:14 +00:00
form: MarkPrivateMessageAsRead
): Promise<PrivateMessageResponse> {
return this.wrapper(HttpType.Post, '/private_message/mark_as_read', form);
}
2020-12-20 17:33:14 +00:00
async register(form: Register): Promise<LoginResponse> {
return this.wrapper(HttpType.Post, '/user/register', form);
}
2020-12-20 17:33:14 +00:00
async login(form: Login): Promise<LoginResponse> {
return this.wrapper(HttpType.Post, '/user/login', form);
}
2020-12-20 17:33:14 +00:00
async getUserDetails(form: GetUserDetails): Promise<GetUserDetailsResponse> {
return this.wrapper(HttpType.Get, '/user', form);
}
async getUserMentions(
2020-12-20 17:33:14 +00:00
form: GetUserMentions
): Promise<GetUserMentionsResponse> {
return this.wrapper(HttpType.Get, '/user/mention', form);
}
async markUserMentionAsRead(
2020-12-20 17:33:14 +00:00
form: MarkUserMentionAsRead
): Promise<UserMentionResponse> {
return this.wrapper(HttpType.Post, '/user/mention/mark_as_read', form);
}
2020-12-20 17:33:14 +00:00
async getReplies(form: GetReplies): Promise<GetRepliesResponse> {
return this.wrapper(HttpType.Get, '/user/replies', form);
}
async getFollowedCommunities(
2020-12-20 17:33:14 +00:00
form: GetFollowedCommunities
): Promise<GetFollowedCommunitiesResponse> {
return this.wrapper(HttpType.Get, '/user/followed_communities', form);
}
2020-12-20 17:33:14 +00:00
async userJoin(form: UserJoin): Promise<UserJoinResponse> {
return this.wrapper(HttpType.Post, '/user/join', form);
}
2020-12-20 17:33:14 +00:00
async postJoin(form: PostJoin): Promise<PostJoinResponse> {
2020-09-13 13:49:35 +00:00
return this.wrapper(HttpType.Post, '/post/join', form);
}
2020-12-20 17:33:14 +00:00
async communityJoin(form: CommunityJoin): Promise<CommunityJoinResponse> {
2020-09-13 13:49:35 +00:00
return this.wrapper(HttpType.Post, '/community/join', form);
}
2020-12-20 17:33:14 +00:00
async banUser(form: BanUser): Promise<BanUserResponse> {
return this.wrapper(HttpType.Post, '/user/ban', form);
}
async getCaptcha(): Promise<GetCaptchaResponse> {
return this.wrapper(HttpType.Get, '/user/get_captcha', {});
}
2020-12-20 17:33:14 +00:00
async deleteAccount(form: DeleteAccount): Promise<LoginResponse> {
return this.wrapper(HttpType.Post, '/user/delete_account', form);
}
2020-12-20 17:33:14 +00:00
async passwordReset(form: PasswordReset): Promise<PasswordResetResponse> {
return this.wrapper(HttpType.Post, '/user/password_reset', form);
}
2020-12-20 17:33:14 +00:00
async passwordChange(form: PasswordChange): Promise<LoginResponse> {
return this.wrapper(HttpType.Post, '/user/password_change', form);
}
2020-12-20 17:33:14 +00:00
async markAllAsRead(form: MarkAllAsRead): Promise<LoginResponse> {
return this.wrapper(HttpType.Post, '/user/mark_all_as_read', form);
}
2020-12-20 17:33:14 +00:00
async saveUserSettings(form: SaveUserSettings): Promise<LoginResponse> {
return this.wrapper(HttpType.Put, '/user/save_user_settings', form);
}
2020-12-20 17:33:14 +00:00
async addAdmin(form: AddAdmin): Promise<AddAdminResponse> {
return this.wrapper(HttpType.Post, '/admin/add', form);
}
private buildFullUrl(endpoint: string): string {
return `${this.baseUrl}${endpoint}`;
}
private async wrapper<ResponseType, MessageType>(
type_: HttpType,
endpoint: string,
form: MessageType
): Promise<ResponseType> {
if (type_ == HttpType.Get) {
2020-08-20 03:51:57 +00:00
let getUrl = `${this.buildFullUrl(endpoint)}?${encodeGetParams(form)}`;
return fetch(getUrl, {
method: 'GET',
headers: this.headers,
}).then(d => d.json());
} else {
return fetch(this.buildFullUrl(endpoint), {
method: type_,
headers: {
'Content-Type': 'application/json',
...this.headers,
},
body: JSON.stringify(form),
}).then(d => d.json());
}
}
}
function encodeGetParams(p: any): string {
return Object.entries(p)
.map(kv => kv.map(encodeURIComponent).join('='))
.join('&');
}