logan/Emmelia-Link-Flayer-Rewrite
1
0
Fork 0
Code Issues 6 Pull Requests Packages Projects 2 Releases Wiki Activity

Compare commits

base: logan:d372bcd8afa204a3cae5b7f5d94036b92c0f0de6
Branches Tags
logan:main logan:feature/#6-add-stable-diffusion logan:dev
...
compare: logan:f840d754ac4140bab4105cc95adee4404100753c
Branches Tags
logan:main logan:feature/#6-add-stable-diffusion logan:dev

2 Commits
d372bcd8af ... f840d754ac

Author SHA1 Message Date
Logan Cusano
f840d754ac Merge branch 'main' of git.vpn.cusano.net:logan/Emmelia-Link-Flayer-Rewrite 2023-03-12 15:54:52 -04:00
Logan Cusano
cb8dfca8dd Return the source title from record promises 2023-03-12 15:54:22 -04:00
1 changed files with 5 additions and 6 deletions
Expand all files Collapse all files

11
libCore.js
View File

@@ -140,7 +140,7 @@ exports.updateFeeds = (client) => {
if (!sendResults) { if (!sendResults) {
log.ERROR("No sending results from sending a post: ", sendResults, existingRecord, post); log.ERROR("No sending results from sending a post: ", sendResults, existingRecord, post);
return recordReject(); return recordReject("No sending results from sending a post");
} }
log.DEBUG("Saving post to database: ", sendResults, post.title, source.channel_id); log.DEBUG("Saving post to database: ", sendResults, post.title, source.channel_id);
@@ -150,7 +150,7 @@ exports.updateFeeds = (client) => {
if (saveResults) { if (saveResults) {
log.DEBUG("Saved results: ", saveResults); log.DEBUG("Saved results: ", saveResults);
return recordResolve(); return recordResolve("Saved results", saveResults);
} }
}); });
}) })
@@ -165,7 +165,7 @@ exports.updateFeeds = (client) => {
} }
Promise.all(recordPromiseArray).then((values) => { Promise.all(recordPromiseArray).then((values) => {
log.DEBUG("All posts finished for: ", source.title, values); log.DEBUG("All posts finished for: ", source.title, values);
return resolve(); return resolve(source.title);
}); });
}); });
})) }))
@@ -174,9 +174,8 @@ exports.updateFeeds = (client) => {
// Wait for all connections to finish then close the temp connections // Wait for all connections to finish then close the temp connections
Promise.all(sourcePromiseArray).then((values) => { Promise.all(sourcePromiseArray).then((values) => {
log.DEBUG("Closing temp connections: ", values); log.DEBUG("All sources finished, closing temp connections: ", values);
tempFeedStorage.closeConnection(); tempConnection.end();
tempPostStorage.closeConnection();
}); });
}); });
} }