Skip to content

Implement Push Publisher #27

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
GoodluckH wants to merge 11 commits into
base: develop
Choose a base branch
from
Open

Implement Push Publisher #27

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
05da33d
Modifies configs for preparation
GoodluckH Jul 15, 2022
b2c2186
Reorg api files
GoodluckH Jul 15, 2022
200a8c3
Define task related types and reorg types folder
GoodluckH Jul 15, 2022
a1c86d6
Define and setup views
GoodluckH Jul 15, 2022
3885bd8
Conform old codes to newly defined types
GoodluckH Jul 15, 2022
743bc68
Fix type and lint errors in old files
GoodluckH Jul 15, 2022
97e8c80
Implement Push Publisher
GoodluckH Jul 15, 2022
b8614c0
fixup! Implement Push Publisher
GoodluckH Jul 18, 2022
7eccaf2
fixup! Implement Push Publisher
GoodluckH Jul 18, 2022
5d964f5
fixup! Modifies configs for preparation
GoodluckH Jul 19, 2022
c4018d2
fixup! Define task related types and reorg types folder
GoodluckH Jul 19, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion src/publishers/push.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,9 @@ const RETRY_LIMIT = 5
*/
export const runPushPublisher = async (): Promise<number> => {
for await (const doc of viewToStream(async params =>
dbTasks.view('tasks_publishing', 'tasks_publishing', params)
Promise.resolve(
dbTasks.view('tasks_publishing', 'tasks_publishing', params)
)
)) {
const clean: TaskDoc = asTaskDoc(doc)
const currentTask = clean.doc
Expand Down Expand Up @@ -81,6 +83,7 @@ export const runPushPublisher = async (): Promise<number> => {
const canExecute = (task: Task): boolean => {
return (
task.action.inProgress == null &&
Comment thread
GoodluckH marked this conversation as resolved.
Outdated
task.action.type === 'push' &&
task.action.repeat == null &&
task.action.inProgress === false
)
Expand Down