Skip to content
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

Notifications/qa fixes #256

Merged
merged 10 commits into from
Nov 28, 2023
Merged

Notifications/qa fixes #256

Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
21fc5b0
fix: :bug: unitialized access video posted + misc
Nov 22, 2023
2a6df5d
feat: :zap: batch channel verification
Nov 24, 2023
44a38a1
fix: :zap: remove non necessary import
Nov 27, 2023
31b637a
feat: :sparkles: batch suspend channel and pLimits promises
Nov 27, 2023
e1ea9eb
Merge branch 'orion_notifications' into notifications/qa-fixes
Nov 27, 2023
fa2073f
fix: :bug: typegraphql return type
Nov 28, 2023
cb6b0d2
Notifications/qa fixes (#255)
Nov 27, 2023
447a268
fix: :art: import
Nov 28, 2023
79f0787
Merge branch 'orion_notifications' into notifications/qa-fixes
Nov 28, 2023
45d999e
style: :lipstick: format
Nov 28, 2023
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
12 changes: 5 additions & 7 deletions src/server-extension/resolvers/ChannelsResolver/index.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -340,7 +340,7 @@ export class ChannelsResolver {
})
}

@Mutation(() => SuspendChannelResult)
@Mutation(() => [SuspendChannelResult])
@UseMiddleware(OperatorOnly())
async suspendChannels(
@Args() { channelIds }: SuspendChannelArgs
Expand Down Expand Up @@ -395,10 +395,9 @@ export class ChannelsResolver {
}

const limit = pLimit(5) // Limit to 5 concurrent promises
const existingChannels = channels.filter((channel) => channel)
return await Promise.all(
channels
.filter((channel) => channel)
.map((channel) => limit(async () => await suspendChannel(channel)))
existingChannels.map((channel) => limit(async () => await suspendChannel(channel)))
)
})
}
Expand Down Expand Up @@ -528,10 +527,9 @@ export const verifyChannelService = async (em: EntityManager, channelIds: string
}

const limit = pLimit(5) // Limit to 5 concurrent promises
const existingChannels = channels.filter((channel) => channel)
return await Promise.all(
channels
.filter((channel) => channel)
.map((channel) => limit(async () => await verifyChannel(channel)))
existingChannels.map((channel) => limit(async () => await verifyChannel(channel)))
)
})
}
Loading