zoriya/Aeris
1
0
Fork 0
mirror of https://github.com/zoriya/Aeris.git synced 2026-06-01 18:35:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'feat/reddit-worker' of github.com:AnonymusRaccoon/Aeris into feat/reddit-worker

Browse Source
This commit is contained in:
Zoe Roux
2022-03-06 19:46:33 +01:00
parent e4e724cc91 8bbb379a1f
commit 12b6c78f3f
1 changed files with 23 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/src/services/reddit.ts
+23 -31
View File
@@ -53,47 +53,39 @@ export class Reddit extends BaseService {
@reaction(ReactionType.ReplyToPost, ['post_id', 'reply_body'])
async commentPost(params: any): Promise<PipelineEnv> {
return this._client.getSubmission(params['post_id']).
then((response) => {
return response.reply(params['reply_body']).then((res) => {
return {
SUB_NAME: response.subreddit.name,
SUB_ID: response.subreddit.id,
POST_ID: response.id,
REPLY_ID: res.id
};
})
let fetchedSubmission: Submission = this._client.getSubmission(params['post_id']);
return fetchedSubmission.reply(params['reply_body']).then((res) => {
return {
SUB_NAME: fetchedSubmission.subreddit.name,
SUB_ID: fetchedSubmission.subreddit.id,
POST_ID: params['post_id'],
REPLY_ID: res.id
};
});
}
@reaction(ReactionType.Upvote, ['post_id'])
async upvotePost(params: any): Promise<PipelineEnv> {
return this._client.getSubmission(params['post_id']).
then((response) => {
return response.upvote().then((res) => {
return {
SUB_NAME: response.subreddit.name,
SUB_ID: response.subreddit.id,
POST_ID: response.id,
UPVOTE_COUNT: res.ups
};
});
return this._client.getSubmission(params['post_id']).upvote().then((res) => {
return {
SUB_NAME: res.subreddit.name,
SUB_ID: res.subreddit.id,
POST_ID: params['post_id'],
UPVOTE_COUNT: res.ups
};
});
}
@reaction(ReactionType.Downvote, ['post_id'])
async downvotePost(params: any): Promise<PipelineEnv> {
return this._client.getSubmission(params['post_id']).
then((response) => {
return response.downvote().then((res) => {
return {
SUB_NAME: response.subreddit.name,
SUB_ID: response.subreddit.id,
POST_ID: response.id,
DOWNVOTE_COUNT: res.downs
};
});
return this._client.getSubmission(params['post_id']).downvote().then((res) => {
return {
SUB_NAME: res.subreddit.name,
SUB_ID: res.subreddit.id,
POST_ID: res.id,
DOWNVOTE_COUNT: res.downs
};
});
}
}