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

local provider client rename

Browse source
This commit is contained in:
boufni95 2025-12-19 15:28:38 +00:00
parent 4b6216612f
commit eca39a035f
4 changed files with 19 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/e2e.ts
View file

@ -21,7 +21,7 @@ const start = async () => {
return return
} }
const { mainHandler, local, wizard, adminManager } = keepOn const { mainHandler, localProviderClient, wizard, adminManager } = keepOn
const serverMethods = GetServerMethods(mainHandler) const serverMethods = GetServerMethods(mainHandler)
const nostrSettings = settingsManager.getSettings().nostrRelaySettings const nostrSettings = settingsManager.getSettings().nostrRelaySettings
log("initializing nostr middleware") log("initializing nostr middleware")
@ -33,8 +33,8 @@ const start = async () => {
privateKey: app.privateKey, privateKey: app.privateKey,
publicKey: app.publicKey, publicKey: app.publicKey,
name: app.name, name: app.name,
provider: app.publicKey === local.publicKey ? { provider: app.publicKey === localProviderClient.publicKey ? {
clientId: `client_${local.appId}`, clientId: `client_${localProviderClient.appId}`,
pubkey: settingsManager.getSettings().liquiditySettings.liquidityProviderPub, pubkey: settingsManager.getSettings().liquiditySettings.liquidityProviderPub,
relayUrl: settingsManager.getSettings().liquiditySettings.providerRelayUrl relayUrl: settingsManager.getSettings().liquiditySettings.providerRelayUrl
} : undefined } : undefined
@ -49,7 +49,7 @@ const start = async () => {
log("starting server") log("starting server")
mainHandler.attachNostrSend(Send) mainHandler.attachNostrSend(Send)
mainHandler.StartBeacons() mainHandler.StartBeacons()
const appNprofile = nprofileEncode({ pubkey: local.publicKey, relays: nostrSettings.relays }) const appNprofile = nprofileEncode({ pubkey: localProviderClient.publicKey, relays: nostrSettings.relays })
if (wizard) { if (wizard) {
wizard.AddConnectInfo(appNprofile, nostrSettings.relays) wizard.AddConnectInfo(appNprofile, nostrSettings.relays)
} }

8
src/index.ts
View file

@ -23,7 +23,7 @@ const start = async () => {
return return
} }
const { mainHandler, local, wizard, adminManager } = keepOn const { mainHandler, localProviderClient, wizard, adminManager } = keepOn
const serverMethods = GetServerMethods(mainHandler) const serverMethods = GetServerMethods(mainHandler)
log("initializing nostr middleware") log("initializing nostr middleware")
const relays = settingsManager.getSettings().nostrRelaySettings.relays const relays = settingsManager.getSettings().nostrRelaySettings.relays
@ -34,8 +34,8 @@ const start = async () => {
privateKey: app.privateKey, privateKey: app.privateKey,
publicKey: app.publicKey, publicKey: app.publicKey,
name: app.name, name: app.name,
provider: app.publicKey === local.publicKey ? { provider: app.publicKey === localProviderClient.publicKey ? {
clientId: `client_${local.appId}`, clientId: `client_${localProviderClient.appId}`,
pubkey: settingsManager.getSettings().liquiditySettings.liquidityProviderPub, pubkey: settingsManager.getSettings().liquiditySettings.liquidityProviderPub,
relayUrl: settingsManager.getSettings().liquiditySettings.providerRelayUrl relayUrl: settingsManager.getSettings().liquiditySettings.providerRelayUrl
} : undefined } : undefined
@ -53,7 +53,7 @@ const start = async () => {
mainHandler.attachNostrProcessPing(Ping) mainHandler.attachNostrProcessPing(Ping)
mainHandler.attachNostrReset(Reset) mainHandler.attachNostrReset(Reset)
mainHandler.StartBeacons() mainHandler.StartBeacons()
const appNprofile = nprofileEncode({ pubkey: local.publicKey, relays }) const appNprofile = nprofileEncode({ pubkey: localProviderClient.publicKey, relays })
if (wizard) { if (wizard) {
wizard.AddConnectInfo(appNprofile, relays) wizard.AddConnectInfo(appNprofile, relays)
} }

8
src/services/main/init.ts
View file

@ -63,11 +63,11 @@ export const initMainHandler = async (log: PubLogger, settingsManager: SettingsM
return { privateKey: app.nostr_private_key, publicKey: app.nostr_public_key, appId: app.app_id, name: app.name } return { privateKey: app.nostr_private_key, publicKey: app.nostr_public_key, appId: app.app_id, name: app.name }
} }
})) }))
const local = apps.find(app => defaultNames.includes(app.name)) const localProviderClient = apps.find(app => defaultNames.includes(app.name))
if (!local) { if (!localProviderClient) {
throw new Error("local app not initialized correctly") throw new Error("local app not initialized correctly")
} }
mainHandler.liquidityProvider.setNostrInfo({ localId: `client_${local.appId}`, localPubkey: local.publicKey }) mainHandler.liquidityProvider.setNostrInfo({ localId: `client_${localProviderClient.appId}`, localPubkey: localProviderClient.publicKey })
const stop = await processArgs(mainHandler) const stop = await processArgs(mainHandler)
if (stop) { if (stop) {
return return
@ -77,7 +77,7 @@ export const initMainHandler = async (log: PubLogger, settingsManager: SettingsM
await mainHandler.appUserManager.CleanupInactiveUsers() await mainHandler.appUserManager.CleanupInactiveUsers()
await mainHandler.appUserManager.CleanupNeverActiveUsers() await mainHandler.appUserManager.CleanupNeverActiveUsers()
await mainHandler.paymentManager.watchDog.Start() await mainHandler.paymentManager.watchDog.Start()
return { mainHandler, apps, local, wizard, adminManager } return { mainHandler, apps, localProviderClient, wizard, adminManager }
} }
const processArgs = async (mainHandler: Main) => { const processArgs = async (mainHandler: Main) => {

14
src/tests/setupBootstrapped.ts
View file

@ -20,13 +20,13 @@ export const initBootstrappedInstance = async (T: TestBase) => {
if (!initialized) { if (!initialized) {
throw new Error("failed to initialize bootstrapped main handler") throw new Error("failed to initialize bootstrapped main handler")
} }
const { mainHandler: bootstrapped, local } = initialized const { mainHandler: bootstrapped, localProviderClient } = initialized
T.main.attachNostrSend(async (_, data, r) => { T.main.attachNostrSend(async (_, data, r) => {
if (data.type === 'event') { if (data.type === 'event') {
throw new Error("unsupported event type") throw new Error("unsupported event type")
} }
if (data.pub !== local.publicKey) { if (data.pub !== localProviderClient.publicKey) {
throw new Error("invalid pub " + data.pub + " expected " + local.publicKey) throw new Error("invalid pub " + data.pub + " expected " + localProviderClient.publicKey)
} }
const j = JSON.parse(data.content) as { requestId: string } const j = JSON.parse(data.content) as { requestId: string }
console.log("sending new operation to provider") console.log("sending new operation to provider")
@ -42,7 +42,7 @@ export const initBootstrappedInstance = async (T: TestBase) => {
} }
bootstrapped.liquidityProvider.onEvent(res, data.pub) bootstrapped.liquidityProvider.onEvent(res, data.pub)
}) })
bootstrapped.liquidityProvider.setNostrInfo({ localId: `client_${local.appId}`, localPubkey: local.publicKey }) bootstrapped.liquidityProvider.setNostrInfo({ localId: `client_${localProviderClient.appId}`, localPubkey: localProviderClient.publicKey })
await new Promise<void>(res => { await new Promise<void>(res => {
const interval = setInterval(async () => { const interval = setInterval(async () => {
const canHandle = bootstrapped.liquidityProvider.IsReady() const canHandle = bootstrapped.liquidityProvider.IsReady()
@ -54,10 +54,10 @@ export const initBootstrappedInstance = async (T: TestBase) => {
} }
}, 500) }, 500)
}) })
const bUser = await bootstrapped.applicationManager.AddAppUser(local.appId, { identifier: "user1_bootstrapped", balance: 0, fail_if_exists: true }) const bUser = await bootstrapped.applicationManager.AddAppUser(localProviderClient.appId, { identifier: "user1_bootstrapped", balance: 0, fail_if_exists: true })
const bootstrappedUser: TestUserData = { userId: bUser.info.userId, appUserIdentifier: bUser.identifier, appId: local.appId } const bootstrappedUser: TestUserData = { userId: bUser.info.userId, appUserIdentifier: bUser.identifier, appId: localProviderClient.appId }
return { return {
bootstrapped, local, bootstrappedUser, stop: () => { bootstrapped, localProviderClient, bootstrappedUser, stop: () => {
bootstrapped.Stop() bootstrapped.Stop()
} }
} }