diff options
Diffstat (limited to 'src/screens/Onboarding/util.ts')
-rw-r--r-- | src/screens/Onboarding/util.ts | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/screens/Onboarding/util.ts b/src/screens/Onboarding/util.ts index b9ecc4b98..14750f34c 100644 --- a/src/screens/Onboarding/util.ts +++ b/src/screens/Onboarding/util.ts @@ -4,6 +4,7 @@ import { BskyAgent, } from '@atproto/api' import {TID} from '@atproto/common-web' +import chunk from 'lodash.chunk' import {until} from '#/lib/async/until' @@ -29,10 +30,13 @@ export async function bulkWriteFollows(agent: BskyAgent, dids: string[]) { value: r, })) - await agent.com.atproto.repo.applyWrites({ - repo: session.did, - writes: followWrites, - }) + const chunks = chunk(followWrites, 50) + for (const chunk of chunks) { + await agent.com.atproto.repo.applyWrites({ + repo: session.did, + writes: chunk, + }) + } await whenFollowsIndexed(agent, session.did, res => !!res.data.follows.length) const followUris = new Map() |