DebaucheryLibrarian/ripunzel
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Storing pHash. Fixed RedGIFs user agent.

Browse Source
This commit is contained in:
ThePendulum
2023-03-12 22:39:00 +01:00
parent b811ebe2ef
commit 8a978cb803
15 changed files with 852 additions and 94 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sources/getPosts.js
View File

@@ -2,8 +2,8 @@
const Promise = require('bluebird');
const getIndex = require('./getIndex.js');
const curateUser = require('../curate/user.js');
const getIndex = require('./getIndex');
const curateUser = require('../curate/user');
const logger = require('../logger')(__filename);
const limiter = require('../limiter').reddit;
@@ -23,7 +23,7 @@ async function getUser(username, reddit) {
}
}
const getPostsWrap = reddit => function getPosts(postIds, userPosts = {}) {
const getPostsWrap = (reddit) => function getPosts(postIds, userPosts = {}) {
return Promise.reduce(postIds, (accUserPosts, postId) => Promise.resolve().then(async () => {
const post = await limiter.schedule(async () => reddit.getSubmission(postId).fetch());

10
src/sources/getUserPosts.js
View File

@@ -2,9 +2,9 @@
const Promise = require('bluebird');
const getIndex = require('./getIndex.js');
const getArchivePostIds = require('../archives/getArchivePostIds.js');
const curateUser = require('../curate/user.js');
const getIndex = require('./getIndex');
const getArchivePostIds = require('../archives/getArchivePostIds');
const curateUser = require('../curate/user');
const logger = require('../logger')(__filename);
const limiter = require('../limiter').reddit;
@@ -46,9 +46,9 @@ async function getPosts(username, reddit, args) {
}
async function getArchivedPosts(username, posts, reddit) {
const postIds = await getArchivePostIds(username, posts.map(post => post.id));
const postIds = await getArchivePostIds(username, posts.map((post) => post.id));
return Promise.all(postIds.map(postId => limiter.schedule(async () => reddit.getSubmission(postId).fetch())));
return Promise.all(postIds.map((postId) => limiter.schedule(async () => reddit.getSubmission(postId).fetch())));
}
function getUserPostsWrap(reddit, args) {