457 lines
19 KiB
JavaScript
457 lines
19 KiB
JavaScript
function newGovernanceUserProfileSpace() {
|
|
const MODULE_NAME = 'User Profile Space'
|
|
|
|
let thisObject = {
|
|
githubStars: undefined,
|
|
githubWatchers: undefined,
|
|
githubForks: undefined,
|
|
container: undefined,
|
|
physics: physics,
|
|
draw: draw,
|
|
getContainer: getContainer,
|
|
reset: reset,
|
|
finalize: finalize,
|
|
initialize: initialize
|
|
}
|
|
|
|
let waitingForResponses = 0
|
|
const BSC_SCAN_RATE_LIMIT_DELAY = 6000
|
|
let reputationByAddress = new Map()
|
|
|
|
return thisObject
|
|
|
|
function initialize() {
|
|
/*
|
|
If the workspace is not related to governance, then we exit the Intialize Function
|
|
*/
|
|
let governanceProject = UI.projects.foundations.spaces.designSpace.workspace.getProjectHeadByNodeType('Governance Project')
|
|
if (governanceProject === undefined) { return }
|
|
/*
|
|
Here we will run the distribution process, that in turn will run all the programs.
|
|
*/
|
|
UI.projects.governance.functionLibraries.distributionProcess.initialize()
|
|
/*
|
|
Here we will get a list of all github usernames who have a star or fork and are watching the
|
|
Superalgos Repository. This will later be used to know which user profiles are participating
|
|
at the Github Program.
|
|
*/
|
|
thisObject.githubStars = new Map()
|
|
thisObject.githubWatchers = new Map()
|
|
thisObject.githubForks = new Map()
|
|
|
|
thisObject.container = newContainer()
|
|
thisObject.container.initialize(MODULE_NAME)
|
|
thisObject.container.isDraggeable = false
|
|
|
|
/*
|
|
We are going to collapse all User rootNodes to save processing resources at the UI
|
|
*/
|
|
let rootNodes = UI.projects.foundations.spaces.designSpace.workspace.workspaceNode.rootNodes
|
|
|
|
for (let i = 0; i < rootNodes.length; i++) {
|
|
let rootNode = rootNodes[i]
|
|
if (rootNode.payload.floatingObject.isCollapsed !== true) {
|
|
rootNode.payload.floatingObject.collapseToggle()
|
|
}
|
|
}
|
|
let userProfiles = UI.projects.foundations.spaces.designSpace.workspace.getHierarchyHeadsByNodeType('User Profile')
|
|
/*
|
|
Here we will change the Y position of all profiles so that they are all at the same level.
|
|
*/
|
|
const SPACE_WIDTH = UI.projects.foundations.spaces.floatingSpace.container.frame.width
|
|
const SPACE_HEIGHT = UI.projects.foundations.spaces.floatingSpace.container.frame.height
|
|
|
|
const X_STEP = SPACE_WIDTH / (userProfiles.length + 1)
|
|
const Y_STEP = 3000
|
|
|
|
const Y_LEVEL = SPACE_HEIGHT * 0.425
|
|
let xOffset = X_STEP
|
|
let yOffset = 0
|
|
|
|
for (let i = 0; i < userProfiles.length; i++) {
|
|
userProfiles[i].payload.floatingObject.container.frame.position.x = xOffset
|
|
xOffset = xOffset + X_STEP
|
|
}
|
|
for (let i = 0; i < userProfiles.length; i++) {
|
|
switch (true) {
|
|
case (yOffset === 0): {
|
|
yOffset = Y_STEP
|
|
break
|
|
}
|
|
case (yOffset === Y_STEP): {
|
|
yOffset = Y_STEP * 2
|
|
break
|
|
}
|
|
case (yOffset === Y_STEP * 2): {
|
|
yOffset = Y_STEP * 1 + 1
|
|
break
|
|
}
|
|
case (yOffset === Y_STEP * 1 + 1): {
|
|
yOffset = Y_STEP * 0 + 1
|
|
break
|
|
}
|
|
case (yOffset === Y_STEP * 0 + 1): {
|
|
yOffset = -Y_STEP
|
|
break
|
|
}
|
|
case (yOffset === -Y_STEP): {
|
|
yOffset = 0
|
|
break
|
|
}
|
|
}
|
|
userProfiles[i].payload.floatingObject.container.frame.position.y = Y_LEVEL + yOffset
|
|
}
|
|
|
|
for (let i = 0; i < userProfiles.length; i++) {
|
|
let userProfile = userProfiles[i]
|
|
if (userProfile.payload.floatingObject.isCollapsed !== true) {
|
|
userProfile.payload.floatingObject.collapseToggle()
|
|
}
|
|
}
|
|
/*
|
|
Here we will setup the Reputation for each profile.
|
|
*/
|
|
|
|
waitingForResponses++
|
|
getTreasuryAccountTransactions()
|
|
|
|
function getTreasuryAccountTransactions() {
|
|
const url = "https://api.bscscan.com/api?module=account&action=tokentx&address=" + UI.projects.governance.globals.saToken.SA_TOKEN_BSC_TREASURY_ACCOUNT_ADDRESS + "&startblock=0"
|
|
|
|
fetch(url).then(function (response) {
|
|
return response.json();
|
|
}).then(function (data) {
|
|
|
|
let tokenTransfers = data.result
|
|
for (let i = 0; i < tokenTransfers.length; i++) {
|
|
let transfer = tokenTransfers[i]
|
|
|
|
if (transfer.contractAddress !== UI.projects.governance.globals.saToken.SA_TOKEN_BSC_CONTRACT_ADDRESS) { continue }
|
|
if (transfer.from !== UI.projects.governance.globals.saToken.SA_TOKEN_BSC_TREASURY_ACCOUNT_ADDRESS) { continue }
|
|
|
|
if (transfer.to === '0x9F25cc5f3e70b907269CebbB45D812313b3e9143'.toLowerCase()) {
|
|
console.log(JSON.stringify(transfer))
|
|
}
|
|
let currentReputation = Number(transfer.value) / UI.projects.governance.globals.saToken.SA_TOKEN_BSC_DECIMAL_FACTOR
|
|
let previousReputation = reputationByAddress.get(transfer.to.toLowerCase())
|
|
let newReputation = previousReputation | 0 + currentReputation
|
|
reputationByAddress.set(transfer.to.toLowerCase(), newReputation)
|
|
}
|
|
console.log('[INFO] tokenTransfers = ' + JSON.stringify(tokenTransfers))
|
|
if (tokenTransfers.length > 9000) {
|
|
console.log('[WARN] The total amount of BSC SA Token transfers is above 9000. After 10k this method will need pagination or otherwise users will not get their reputation calculated correctly.')
|
|
} else {
|
|
console.log('[INFO] ' + tokenTransfers.length + ' reputation trasactions found at the blockchain. ')
|
|
}
|
|
waitingForResponses--
|
|
}).catch(function (err) {
|
|
const message = err.message + ' - ' + 'Can not access BSC SCAN servers.'
|
|
console.log(message)
|
|
waitingForResponses--
|
|
});
|
|
}
|
|
|
|
/* Find the Github Username and Token in order to activate the Github Program */
|
|
|
|
let apisNode = UI.projects.foundations.spaces.designSpace.workspace.getHierarchyHeadByNodeType('APIs')
|
|
if (apisNode === undefined) {
|
|
console.log('[WARN] Github Program Disabled because the Github Credentials are not present at this workspace. APIs node not found.')
|
|
return
|
|
}
|
|
if (apisNode.githubAPI === undefined) {
|
|
console.log('[WARN] Github Program Disabled because the Github Credentials are not present at this workspace. Github API node not found.')
|
|
return
|
|
}
|
|
|
|
let config = JSON.parse(apisNode.githubAPI.config)
|
|
if (config.username === undefined || config.username === "") {
|
|
console.log('[WARN] Github Program Disabled because the Github Credentials are not present at this workspace. Github Username not configured.')
|
|
return
|
|
}
|
|
if (config.token === undefined || config.token === "") {
|
|
console.log('[WARN] Github Program Disabled because the Github Credentials are not present at this workspace. Github Token not configured.')
|
|
return
|
|
}
|
|
/*
|
|
Here we will help setup the Github Programs...
|
|
*/
|
|
requestStars()
|
|
|
|
function requestStars() {
|
|
|
|
let params = {
|
|
method: 'getGithubStars',
|
|
repository: 'Superalgos',
|
|
username: config.username,
|
|
token: config.token
|
|
}
|
|
|
|
let url = 'GOV' // We will access the default Client GOV endpoint.
|
|
|
|
httpRequest(JSON.stringify(params), url, onResponse)
|
|
|
|
function onResponse(err, data) {
|
|
|
|
/* Lets check the result of the call through the http interface */
|
|
if (err.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call via HTTP Interface failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
return
|
|
}
|
|
|
|
let response = JSON.parse(data)
|
|
|
|
/* Lets check the result of the method call */
|
|
if (response.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call to Client Github Server failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
console.log('[ERROR] response = ' + JSON.stringify(response))
|
|
return
|
|
}
|
|
|
|
/* Successful Call */
|
|
|
|
let githubStarsArray = response.githubListArray
|
|
|
|
for (let i = 0; i < githubStarsArray.length; i++) {
|
|
let githubUsername = githubStarsArray[i]
|
|
thisObject.githubStars.set(githubUsername, 1)
|
|
}
|
|
|
|
requestWatchers()
|
|
}
|
|
}
|
|
|
|
function requestWatchers() {
|
|
|
|
let params = {
|
|
method: 'getGithubWatchers',
|
|
repository: 'Superalgos',
|
|
username: config.username,
|
|
token: config.token
|
|
}
|
|
|
|
let url = 'GOV' // We will access the default Client GOV endpoint.
|
|
|
|
httpRequest(JSON.stringify(params), url, onResponse)
|
|
|
|
function onResponse(err, data) {
|
|
|
|
/* Lets check the result of the call through the http interface */
|
|
if (err.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call via HTTP Interface failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
return
|
|
}
|
|
|
|
let response = JSON.parse(data)
|
|
|
|
/* Lets check the result of the method call */
|
|
if (response.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call to Client Github Server failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
console.log('[ERROR] response = ' + JSON.stringify(response))
|
|
return
|
|
}
|
|
|
|
/* Successful Call */
|
|
|
|
let githubWatchersArray = response.githubListArray
|
|
|
|
for (let i = 0; i < githubWatchersArray.length; i++) {
|
|
let githubUsername = githubWatchersArray[i]
|
|
thisObject.githubWatchers.set(githubUsername, 1)
|
|
}
|
|
|
|
requestForks()
|
|
}
|
|
}
|
|
|
|
function requestForks() {
|
|
|
|
let params = {
|
|
method: 'getGithubForks',
|
|
repository: 'Superalgos',
|
|
username: config.username,
|
|
token: config.token
|
|
}
|
|
|
|
let url = 'GOV' // We will access the default Client GOV endpoint.
|
|
|
|
httpRequest(JSON.stringify(params), url, onResponse)
|
|
|
|
function onResponse(err, data) {
|
|
|
|
/* Lets check the result of the call through the http interface */
|
|
if (err.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call via HTTP Interface failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
return
|
|
}
|
|
|
|
let response = JSON.parse(data)
|
|
|
|
/* Lets check the result of the method call */
|
|
if (response.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
console.log('[ERROR] Call to Client Github Server failed. err.stack = ' + err.stack)
|
|
console.log('[ERROR] params = ' + JSON.stringify(params))
|
|
console.log('[ERROR] response = ' + JSON.stringify(response))
|
|
return
|
|
}
|
|
|
|
/* Successful Call */
|
|
|
|
let githubForksArray = response.githubListArray
|
|
|
|
for (let i = 0; i < githubForksArray.length; i++) {
|
|
let githubUsername = githubForksArray[i]
|
|
thisObject.githubForks.set(githubUsername, 1)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function finalize() {
|
|
|
|
UI.projects.governance.functionLibraries.distributionProcess.finalize()
|
|
|
|
thisObject.githubStars = undefined
|
|
thisObject.githubWatchers = undefined
|
|
thisObject.githubForks = undefined
|
|
|
|
if (thisObject.container !== undefined) {
|
|
thisObject.container.finalize()
|
|
thisObject.container = undefined
|
|
}
|
|
}
|
|
|
|
function reset() {
|
|
finalize()
|
|
initialize()
|
|
}
|
|
|
|
function getContainer(point) {
|
|
|
|
return undefined // since this space does not draw anything we return here
|
|
|
|
if (thisObject.container.frame.isThisPointHere(point, true) === true) {
|
|
thisObject.container.space = MODULE_NAME
|
|
return thisObject.container
|
|
} else {
|
|
return undefined
|
|
}
|
|
}
|
|
|
|
function physics() {
|
|
|
|
if (UI.projects.foundations.spaces.designSpace.workspace === undefined) { return }
|
|
/*
|
|
If the workspace is not related to governance, then we exit the Intialize Function
|
|
*/
|
|
let governanceProject = UI.projects.foundations.spaces.designSpace.workspace.getProjectHeadByNodeType('Governance Project')
|
|
if (governanceProject === undefined) { return }
|
|
/*
|
|
Load the user profiles with Token Power.
|
|
*/
|
|
let userProfiles = UI.projects.foundations.spaces.designSpace.workspace.getHierarchyHeadsByNodeType('User Profile')
|
|
if (waitingForResponses !== 0) { return }
|
|
/*
|
|
We will get all the user Profiles tokens from the blockchain, making a call
|
|
every 5 seconds so as not to exceed the rate limit.
|
|
*/
|
|
for (let i = 0; i < userProfiles.length; i++) {
|
|
let userProfile = userProfiles[i]
|
|
if (userProfile.payload === undefined) { continue }
|
|
|
|
if (userProfile.payload.blockchainTokens === undefined) {
|
|
getBlockchainAccount(userProfile)
|
|
return
|
|
}
|
|
}
|
|
|
|
function getBlockchainAccount(userProfile) {
|
|
let signature = UI.projects.foundations.utilities.nodeConfig.loadConfigProperty(userProfile.payload, 'signature')
|
|
if (signature === undefined || signature === "") { return }
|
|
|
|
let request = {
|
|
url: 'WEB3',
|
|
params: {
|
|
method: "recoverAddress",
|
|
signature: JSON.stringify(signature)
|
|
}
|
|
}
|
|
|
|
httpRequest(JSON.stringify(request.params), request.url, onResponse)
|
|
|
|
function onResponse(err, data) {
|
|
/* Lets check the result of the call through the http interface */
|
|
if (err.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
userProfile.payload.uiObject.setErrorMessage(
|
|
'Call via HTTP Interface failed.',
|
|
UI.projects.governance.globals.designer.SET_ERROR_COUNTER_FACTOR
|
|
)
|
|
return
|
|
}
|
|
|
|
let response = JSON.parse(data)
|
|
|
|
/* Lets check the result of the method call */
|
|
if (response.result !== GLOBAL.DEFAULT_OK_RESPONSE.result) {
|
|
userProfile.payload.uiObject.setErrorMessage(
|
|
'Call to WEB3 Server failed. ' + response.error,
|
|
UI.projects.governance.globals.designer.SET_ERROR_COUNTER_FACTOR
|
|
)
|
|
console.log('Call to WEB3 Server failed. ' + response.error)
|
|
return
|
|
}
|
|
|
|
let blockchainAccount = response.address
|
|
userProfile.payload.blockchainAccount = blockchainAccount
|
|
if (
|
|
blockchainAccount !== undefined &&
|
|
blockchainAccount !== "" &&
|
|
userProfile.payload.blockchainTokens === undefined
|
|
) {
|
|
waitingForResponses++
|
|
userProfile.payload.blockchainTokens = 0 // We need to set this value here so that the next call to BSCSCAN is not done more than once.
|
|
setTimeout(getBlockchainTokens, BSC_SCAN_RATE_LIMIT_DELAY, userProfile, blockchainAccount)
|
|
}
|
|
}
|
|
}
|
|
|
|
function getBlockchainTokens(userProfile, blockchainAccount) {
|
|
console.log('User Profile Name: ', userProfile.name, 'blockchainAccount: ', blockchainAccount)
|
|
const url = "https://api.bscscan.com/api?module=account&action=tokenbalance&contractaddress=" + UI.projects.governance.globals.saToken.SA_TOKEN_BSC_CONTRACT_ADDRESS + "&address=" + blockchainAccount + "&tag=latest&apikey=YourApiKeyToken"
|
|
|
|
fetch(url).then(function (response) {
|
|
return response.json();
|
|
}).then(function (data) {
|
|
console.log(data)
|
|
if (data.result === "Max rate limit reached, please use API Key for higher rate limit") {
|
|
userProfile.payload.blockchainTokens = undefined // This enables this profile to query the blockchain again.
|
|
} else {
|
|
userProfile.payload.uiObject.setInfoMessage(data,
|
|
UI.projects.governance.globals.designer.SET_INFO_COUNTER_FACTOR
|
|
)
|
|
userProfile.payload.blockchainTokens = Number(data.result) / 1000000000000000000
|
|
userProfile.payload.reputation = Math.min(reputationByAddress.get(blockchainAccount.toLowerCase()) | 0, userProfile.payload.blockchainTokens)
|
|
}
|
|
waitingForResponses--
|
|
}).catch(function (err) {
|
|
const message = err.message + ' - ' + 'Can not access BSC SCAN servers.'
|
|
console.log(message)
|
|
if (userProfile.payload !== undefined) {
|
|
userProfile.payload.uiObject.setErrorMessage(message,
|
|
UI.projects.governance.globals.designer.SET_ERROR_COUNTER_FACTOR
|
|
)
|
|
}
|
|
waitingForResponses--
|
|
});
|
|
}
|
|
}
|
|
|
|
function draw() {
|
|
|
|
}
|
|
}
|