a2bad977a8
* ✨ Add getRepos and getRecords endpoints for bulk fetching * ✨ Fix issues and add tests for get repos and get records * ✨ Use the right lxm * 🐛 Revert changes in lockfile * ✨ Add getAccountInfos in PDS * 🐛 Fix type def for repo and record view detail * ✅ Update snapshots * ✅ Update snapshots * ✨ Consolidate error type for com.atproto and tools.ozone getRecord error type * 🧹 Cleanup * ✅ Update snapshots * ✅ Update snapshots * ✨ Changeset
88 lines
2.2 KiB
TypeScript
88 lines
2.2 KiB
TypeScript
import {
|
|
SeedClient,
|
|
TestNetwork,
|
|
TestOzone,
|
|
basicSeed,
|
|
ModeratorClient,
|
|
} from '@atproto/dev-env'
|
|
import { AtpAgent } from '@atproto/api'
|
|
import {
|
|
REASONOTHER,
|
|
REASONSPAM,
|
|
} from '../src/lexicon/types/com/atproto/moderation/defs'
|
|
import { forSnapshot } from './_util'
|
|
import { ids } from '../src/lexicon/lexicons'
|
|
|
|
describe('admin get multiple repos', () => {
|
|
let network: TestNetwork
|
|
let ozone: TestOzone
|
|
let agent: AtpAgent
|
|
let pdsAgent: AtpAgent
|
|
let sc: SeedClient
|
|
let modClient: ModeratorClient
|
|
|
|
beforeAll(async () => {
|
|
network = await TestNetwork.create({
|
|
dbPostgresSchema: 'ozone_admin_get_repos',
|
|
})
|
|
ozone = network.ozone
|
|
agent = ozone.getClient()
|
|
pdsAgent = network.pds.getClient()
|
|
sc = network.getSeedClient()
|
|
modClient = ozone.getModClient()
|
|
await basicSeed(sc)
|
|
await pdsAgent.com.atproto.server.deactivateAccount(
|
|
{},
|
|
{ encoding: 'application/json', headers: sc.getHeaders(sc.dids.dan) },
|
|
)
|
|
await network.processAll()
|
|
})
|
|
|
|
afterAll(async () => {
|
|
await network.close()
|
|
})
|
|
|
|
beforeAll(async () => {
|
|
await modClient.emitEvent({
|
|
event: { $type: 'tools.ozone.moderation.defs#modEventAcknowledge' },
|
|
subject: {
|
|
$type: 'com.atproto.admin.defs#repoRef',
|
|
did: sc.dids.alice,
|
|
},
|
|
})
|
|
await sc.createReport({
|
|
reportedBy: sc.dids.bob,
|
|
reasonType: REASONSPAM,
|
|
subject: {
|
|
$type: 'com.atproto.admin.defs#repoRef',
|
|
did: sc.dids.alice,
|
|
},
|
|
})
|
|
await sc.createReport({
|
|
reportedBy: sc.dids.carol,
|
|
reasonType: REASONOTHER,
|
|
reason: 'defamation',
|
|
subject: {
|
|
$type: 'com.atproto.admin.defs#repoRef',
|
|
did: sc.dids.alice,
|
|
},
|
|
})
|
|
await modClient.emitEvent({
|
|
event: { $type: 'tools.ozone.moderation.defs#modEventTakedown' },
|
|
subject: {
|
|
$type: 'com.atproto.admin.defs#repoRef',
|
|
did: sc.dids.alice,
|
|
},
|
|
})
|
|
})
|
|
|
|
it('gets multiple repos by did', async () => {
|
|
const { data } = await agent.tools.ozone.moderation.getRepos(
|
|
{ dids: [sc.dids.alice, sc.dids.bob, 'did:web:xyz'] },
|
|
{ headers: await ozone.modHeaders(ids.ToolsOzoneModerationGetRepos) },
|
|
)
|
|
|
|
expect(forSnapshot(data)).toMatchSnapshot()
|
|
})
|
|
})
|