mirror of
https://github.com/IT4Change/Ocelot-Social.git
synced 2026-01-20 20:01:22 +00:00
132c12a7d3
We had this error in our neo4j pod recently: ``` 2019-12-02 08:29:42.680+0000 ERROR Unable to schedule bolt session 'bolt-1018230' for execution since there are no available threads to serve it at the moment. You can retry at a later time or consider increasing max thread pool size for bolt connector(s). 2019-12-02 08:29:42.680+0000 ERROR Unable to schedule bolt session 'bolt-1018224' for execution since there are no available threads to serve it at the moment. You can retry at a later time or consider increasing max thread pool size for bolt connector(s). 2019-12-02 08:29:42.681+0000 ERROR Unable to schedule bolt session 'bolt-1018352' for execution since there are no available threads to serve it at the moment. You can retry at a later time or consider increasing max thread pool size for bolt connector(s). 2019-12-02 08:29:42.682+0000 ERROR Unable to schedule bolt session 'bolt-1018243' for execution since there are no available threads to serve it at the moment. You can retry at a later time or consider increasing max thread pool size for bolt connector(s). ``` Apparently the default is 400 threads. So we must have a leak somewhere.
40 lines
1.3 KiB
JavaScript
40 lines
1.3 KiB
JavaScript
import uuid from 'uuid/v4'
|
|
import bcrypt from 'bcryptjs'
|
|
import createPasswordReset from './helpers/createPasswordReset'
|
|
|
|
export default {
|
|
Mutation: {
|
|
requestPasswordReset: async (_parent, { email }, { driver }) => {
|
|
const nonce = uuid().substring(0, 6)
|
|
return createPasswordReset({ driver, nonce, email })
|
|
},
|
|
resetPassword: async (_parent, { email, nonce, newPassword }, { driver }) => {
|
|
const stillValid = new Date()
|
|
stillValid.setDate(stillValid.getDate() - 1)
|
|
const encryptedNewPassword = await bcrypt.hashSync(newPassword, 10)
|
|
const cypher = `
|
|
MATCH (pr:PasswordReset {nonce: $nonce})
|
|
MATCH (e:EmailAddress {email: $email})<-[:PRIMARY_EMAIL]-(u:User)-[:REQUESTED]->(pr)
|
|
WHERE duration.between(pr.issuedAt, datetime()).days <= 0 AND pr.usedAt IS NULL
|
|
SET pr.usedAt = datetime()
|
|
SET u.encryptedPassword = $encryptedNewPassword
|
|
RETURN pr
|
|
`
|
|
const session = driver.session()
|
|
try {
|
|
const transactionRes = await session.run(cypher, {
|
|
stillValid,
|
|
email,
|
|
nonce,
|
|
encryptedNewPassword,
|
|
})
|
|
const [reset] = transactionRes.records.map(record => record.get('pr'))
|
|
const response = !!(reset && reset.properties.usedAt)
|
|
return response
|
|
} finally {
|
|
session.close()
|
|
}
|
|
},
|
|
},
|
|
}
|