Chuck Driesler
102 lines
3.8 KiB
TypeScript
102 lines
3.8 KiB
TypeScript
/* eslint-disable no-restricted-imports */
|
|
import '../bootstrap.js'
|
|
import { logger } from '@/observability/logging'
|
|
import { getServerInfoFactory } from '@/modules/core/repositories/server'
|
|
import {
|
|
findEmailFactory,
|
|
createUserEmailFactory,
|
|
ensureNoPrimaryEmailForUserFactory
|
|
} from '@/modules/core/repositories/userEmails'
|
|
import {
|
|
getUserFactory,
|
|
storeUserFactory,
|
|
countAdminUsersFactory,
|
|
storeUserAclFactory
|
|
} from '@/modules/core/repositories/users'
|
|
import { validateAndCreateUserEmailFactory } from '@/modules/core/services/userEmails'
|
|
import { createUserFactory } from '@/modules/core/services/users/management'
|
|
import { deleteOldAndInsertNewVerificationFactory } from '@/modules/emails/repositories'
|
|
import { renderEmail } from '@/modules/emails/services/emailRendering'
|
|
import { sendEmail } from '@/modules/emails/services/sending'
|
|
import { requestNewEmailVerificationFactory } from '@/modules/emails/services/verification/request'
|
|
import {
|
|
deleteServerOnlyInvitesFactory,
|
|
updateAllInviteTargetsFactory
|
|
} from '@/modules/serverinvites/repositories/serverInvites'
|
|
import { finalizeInvitedServerRegistrationFactory } from '@/modules/serverinvites/services/processing'
|
|
import axios from 'axios'
|
|
import { asMultiregionalOperation } from '@/modules/shared/command.js'
|
|
import { getAllRegisteredDbs } from '@/modules/multiregion/utils/dbSelector.js'
|
|
|
|
const main = async () => {
|
|
const userInputs: Array<Parameters<ReturnType<typeof createUserFactory>>[0]> = (
|
|
await axios.get('https://randomuser.me/api/?results=250')
|
|
).data.results.map(
|
|
(user: {
|
|
name: { first: string; last: string }
|
|
email: string
|
|
login: { password: string }
|
|
}) => {
|
|
return {
|
|
name: `${user.name.first} ${user.name.last}`,
|
|
email: user.email,
|
|
password: `${user.login.password}${user.login.password}`
|
|
}
|
|
}
|
|
)
|
|
|
|
await Promise.all(
|
|
userInputs.map(async (userInput) =>
|
|
asMultiregionalOperation(
|
|
async ({ mainDb, allDbs, emit }) => {
|
|
const createUser = createUserFactory({
|
|
getServerInfo: getServerInfoFactory({ db: mainDb }),
|
|
findEmail: findEmailFactory({ db: mainDb }),
|
|
storeUser: async (...params) => {
|
|
const [user] = await Promise.all(
|
|
allDbs.map((db) => storeUserFactory({ db })(...params))
|
|
)
|
|
|
|
return user
|
|
},
|
|
countAdminUsers: countAdminUsersFactory({ db: mainDb }),
|
|
storeUserAcl: storeUserAclFactory({ db: mainDb }),
|
|
validateAndCreateUserEmail: validateAndCreateUserEmailFactory({
|
|
createUserEmail: createUserEmailFactory({ db: mainDb }),
|
|
ensureNoPrimaryEmailForUser: ensureNoPrimaryEmailForUserFactory({
|
|
db: mainDb
|
|
}),
|
|
findEmail: findEmailFactory({ db: mainDb }),
|
|
updateEmailInvites: finalizeInvitedServerRegistrationFactory({
|
|
deleteServerOnlyInvites: deleteServerOnlyInvitesFactory({ db: mainDb }),
|
|
updateAllInviteTargets: updateAllInviteTargetsFactory({ db: mainDb })
|
|
}),
|
|
requestNewEmailVerification: requestNewEmailVerificationFactory({
|
|
findEmail: findEmailFactory({ db: mainDb }),
|
|
getUser: getUserFactory({ db: mainDb }),
|
|
getServerInfo: getServerInfoFactory({ db: mainDb }),
|
|
deleteOldAndInsertNewVerification:
|
|
deleteOldAndInsertNewVerificationFactory({ db: mainDb }),
|
|
renderEmail,
|
|
sendEmail
|
|
})
|
|
}),
|
|
emitEvent: emit
|
|
})
|
|
|
|
return await createUser(userInput)
|
|
},
|
|
{
|
|
logger,
|
|
name: 'seedUsers',
|
|
dbs: await getAllRegisteredDbs()
|
|
}
|
|
)
|
|
)
|
|
)
|
|
}
|
|
|
|
void main()
|
|
.then(() => logger.info('created'))
|
|
.catch((e) => logger.error(e, 'failed'))
|