aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

Remove unneded follows init

Browse source
This commit is contained in:
Daniel Lugo 2021-09-17 16:02:45 -04:00
parent 7696450896
commit ee9ba63a8c
1 changed files with 0 additions and 70 deletions
Download patch file Download diff file Expand all files Collapse all files

70
services/gunDB/Mediator/index.js
View file

@ -14,7 +14,6 @@ require('gun/lib/open')
require('gun/lib/load')
//@ts-ignore
const { encryptedEmit, encryptedOn } = require('../../../utils/ECC/socket')
const Key = require('../contact-api/key')
/** @type {import('../contact-api/SimpleGUN').ISEA} */
// @ts-ignore
@ -328,29 +327,6 @@ const authenticate = async (alias, pass, __user) => {
// clock skew
await new Promise(res => setTimeout(res, 2000))
await /** @type {Promise<void>} */ (new Promise((res, rej) => {
_user.get(Key.FOLLOWS).put(
{
unused: null
},
ack => {
if (ack.err && typeof ack.err !== 'number') {
rej(
new Error(
`Error initializing follows: ${JSON.stringify(
ack.err,
null,
4
)}`
)
)
} else {
res()
}
}
)
}))
return ack.sea.pub
} else {
throw new Error('Unknown error.')
@ -367,29 +343,6 @@ const authenticate = async (alias, pass, __user) => {
// clock skew
await new Promise(res => setTimeout(res, 2000))
await /** @type {Promise<void>} */ (new Promise((res, rej) => {
_user.get(Key.FOLLOWS).put(
{
unused: null
},
ack => {
if (ack.err && typeof ack.err !== 'number') {
rej(
new Error(
`Error initializing follows: ${JSON.stringify(
ack.err,
null,
4
)}`
)
)
} else {
res()
}
}
)
}))
// move this to a subscription; implement off() ? todo
API.Jobs.onOrders(_user, gun, mySEA)
API.Jobs.lastSeenNode(_user)
@ -424,29 +377,6 @@ const authenticate = async (alias, pass, __user) => {
await new Promise(res => setTimeout(res, 5000))
await /** @type {Promise<void>} */ (new Promise((res, rej) => {
_user.get(Key.FOLLOWS).put(
{
unused: null
},
ack => {
if (ack.err && typeof ack.err !== 'number') {
rej(
new Error(
`Error initializing follows: ${JSON.stringify(
ack.err,
null,
4
)}`
)
)
} else {
res()
}
}
)
}))
API.Jobs.onOrders(_user, gun, mySEA)
API.Jobs.lastSeenNode(_user)