remove redundant pds routing options
This commit is contained in:
+5
-10
@@ -177,16 +177,11 @@ export async function post(
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await pdsClient.call(
|
await pdsClient.call(com.atproto.repo.applyWrites, {
|
||||||
com.atproto.repo.applyWrites,
|
repo: did,
|
||||||
{
|
writes: writes,
|
||||||
repo: did,
|
validate: true,
|
||||||
writes: writes,
|
})
|
||||||
validate: true,
|
|
||||||
},
|
|
||||||
// service: null strips the appview proxy header - this must hit the account host (PDS)
|
|
||||||
{service: null},
|
|
||||||
)
|
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
const e = err as Error
|
const e = err as Error
|
||||||
logger.error(`Failed to create post`, {
|
logger.error(`Failed to create post`, {
|
||||||
|
|||||||
@@ -40,16 +40,11 @@ export async function getServiceAuthToken({
|
|||||||
}
|
}
|
||||||
resolvedAud = pdsAud
|
resolvedAud = pdsAud
|
||||||
}
|
}
|
||||||
const {token} = await client.call(
|
const {token} = await client.call(com.atproto.server.getServiceAuth, {
|
||||||
com.atproto.server.getServiceAuth,
|
aud: resolvedAud,
|
||||||
{
|
lxm,
|
||||||
aud: resolvedAud,
|
exp,
|
||||||
lxm,
|
})
|
||||||
exp,
|
|
||||||
},
|
|
||||||
// service: null strips the appview proxy header - this must hit the account host (PDS)
|
|
||||||
{service: null},
|
|
||||||
)
|
|
||||||
return token
|
return token
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -37,15 +37,10 @@ export async function bulkWriteFollows(
|
|||||||
|
|
||||||
const chunks = chunk(followWrites, 50)
|
const chunks = chunk(followWrites, 50)
|
||||||
for (const chunk of chunks) {
|
for (const chunk of chunks) {
|
||||||
await pdsClient.call(
|
await pdsClient.call(com.atproto.repo.applyWrites, {
|
||||||
com.atproto.repo.applyWrites,
|
repo: did,
|
||||||
{
|
writes: chunk,
|
||||||
repo: did,
|
})
|
||||||
writes: chunk,
|
|
||||||
},
|
|
||||||
// service: null strips the appview proxy header - this must hit the account host (PDS)
|
|
||||||
{service: null},
|
|
||||||
)
|
|
||||||
}
|
}
|
||||||
await whenFollowsIndexed(appviewClient, did, res => !!res.follows.length)
|
await whenFollowsIndexed(appviewClient, did, res => !!res.follows.length)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user