Skip to content

Commit

Permalink
Merge pull request #62 from threefoldtech/fixes
Browse files Browse the repository at this point in the history
fix: public config node & contract resources
  • Loading branch information
DylanVerstraete authored Sep 20, 2022
2 parents f416e97 + b4985ab commit 56fcb75
Show file tree
Hide file tree
Showing 2 changed files with 21 additions and 17 deletions.
8 changes: 4 additions & 4 deletions src/mappings/contracts.ts
Original file line number Diff line number Diff line change
Expand Up @@ -305,10 +305,10 @@ export async function contractUpdateUsedResources(ctx: EventHandlerContext) {

const savedContractResources = await ctx.store.get(ContractResources, { where: { contract: savedContract } })
if (savedContractResources) {
contractUsedResources.cru = usedResources.used.cru
contractUsedResources.sru = usedResources.used.sru
contractUsedResources.hru = usedResources.used.hru
contractUsedResources.mru = usedResources.used.mru
savedContractResources.cru = usedResources.used.cru
savedContractResources.sru = usedResources.used.sru
savedContractResources.hru = usedResources.used.hru
savedContractResources.mru = usedResources.used.mru
await ctx.store.save<ContractResources>(savedContractResources)

savedContract.resourcesUsed = savedContractResources
Expand Down
30 changes: 17 additions & 13 deletions src/mappings/nodes.ts
Original file line number Diff line number Diff line change
Expand Up @@ -342,26 +342,30 @@ export async function nodePublicConfigStored(ctx: EventHandlerContext) {

} else if (storedEvent.isV105) {
nodeID = storedEvent.asV105[0]
config = storedEvent.asV105[1]
let pubconfig = storedEvent.asV105[1]

const savedNode = await ctx.store.get(Node, { where: { nodeID: nodeID } })
if (!savedNode) return

let publicConfig = await ctx.store.get(PublicConfig, { where: { node: savedNode } })
let savedPubConfig = await ctx.store.get(PublicConfig, { where: { node: savedNode } })

if (!publicConfig) {
publicConfig = new PublicConfig()
publicConfig.id = ctx.event.id
publicConfig.node = savedNode
if (!savedPubConfig) {
savedPubConfig = new PublicConfig()
savedPubConfig.id = ctx.event.id
savedPubConfig.node = savedNode
}

publicConfig.ipv4 = config?.ip4.ip.toString()
publicConfig.ipv6 = config?.ip6?.ip.toString()
publicConfig.gw4 = config?.ip4.gw.toString()
publicConfig.gw6 = config?.ip6?.gw.toString()
publicConfig.domain = config?.domain ? config.domain.toString() : ''

await ctx.store.save<PublicConfig>(publicConfig)
if (!pubconfig) {
await ctx.store.remove<PublicConfig>(savedPubConfig)
} else {
savedPubConfig.ipv4 = pubconfig?.ip4.ip.toString()
savedPubConfig.ipv6 = pubconfig?.ip6?.ip.toString()
savedPubConfig.gw4 = pubconfig?.ip4.gw.toString()
savedPubConfig.gw6 = pubconfig?.ip6?.gw.toString()
savedPubConfig.domain = pubconfig?.domain ? pubconfig.domain.toString() : ''

await ctx.store.save<PublicConfig>(savedPubConfig)
}
}
}

Expand Down

0 comments on commit 56fcb75

Please sign in to comment.