pezkuwichain/pwap
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pwap.git synced 2026-04-22 05:37:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: staking score 3-state model and noter integration

Browse Source
This commit is contained in:
Kurdistan Tech Ministry
2026-02-17 01:32:54 +03:00
parent 56fe67f747
commit 226e997723
4 changed files with 268 additions and 155 deletions
Download Patch File Download Diff File Expand all files Collapse all files
shared/lib/scores.ts
+24 -5
View File
@@ -25,6 +25,7 @@ export interface UserScores {
export interface StakingScoreStatus {
isTracking: boolean;
hasCachedData: boolean; // Whether noter has submitted staking data
startBlock: number | null;
currentBlock: number;
durationBlocks: number;
@@ -188,28 +189,46 @@ export async function getStakingScoreStatus(
): Promise<StakingScoreStatus> {
try {
if (!peopleApi?.query?.stakingScore?.stakingStartBlock) {
return { isTracking: false, startBlock: null, currentBlock: 0, durationBlocks: 0 };
return { isTracking: false, hasCachedData: false, startBlock: null, currentBlock: 0, durationBlocks: 0 };
}
const startBlockResult = await peopleApi.query.stakingScore.stakingStartBlock(address);
const currentBlock = Number((await peopleApi.query.system.number()).toString());
if (startBlockResult.isEmpty || startBlockResult.isNone) {
return { isTracking: false, startBlock: null, currentBlock, durationBlocks: 0 };
return { isTracking: false, hasCachedData: false, startBlock: null, currentBlock, durationBlocks: 0 };
}
const startBlock = Number(startBlockResult.toString());
const durationBlocks = currentBlock - startBlock;
// Check if noter has submitted cached staking data
let hasCachedData = false;
if (peopleApi.query.stakingScore.cachedStakingDetails) {
try {
const [relayResult, assetHubResult] = await Promise.all([
peopleApi.query.stakingScore.cachedStakingDetails(address, 'RelayChain')
.catch(() => ({ isSome: false, isEmpty: true })),
peopleApi.query.stakingScore.cachedStakingDetails(address, 'AssetHub')
.catch(() => ({ isSome: false, isEmpty: true })),
]);
hasCachedData = (relayResult.isSome || !relayResult.isEmpty) ||
(assetHubResult.isSome || !assetHubResult.isEmpty);
} catch {
hasCachedData = false;
}
}
return {
isTracking: true,
hasCachedData,
startBlock,
currentBlock,
durationBlocks
};
} catch (error) {
console.error('Error fetching staking score status:', error);
return { isTracking: false, startBlock: null, currentBlock: 0, durationBlocks: 0 };
return { isTracking: false, hasCachedData: false, startBlock: null, currentBlock: 0, durationBlocks: 0 };
}
}
@@ -217,8 +236,8 @@ export async function getStakingScoreStatus(
* Start staking score tracking
* Calls: stakingScore.startScoreTracking()
*
* Called on People Chain. Requires staking data to be available via
* cachedStakingDetails (pushed from Asset Hub via XCM).
* Called on People Chain. No stake requirement - user opts in, then a
* noter-authorized account submits staking data via receive_staking_details().
*/
export async function startScoreTracking(
peopleApi: ApiPromise,
shared/lib/staking.ts
+72 -37
View File
@@ -40,6 +40,7 @@ export interface StakingInfo {
stakingScore: number | null;
stakingDuration: number | null; // Duration in blocks
hasStartedScoreTracking: boolean;
hasCachedStakingData: boolean; // Whether noter has submitted staking data to People Chain
isValidator: boolean;
pezRewards: PezRewardInfo | null; // PEZ rewards information
}
@@ -236,9 +237,10 @@ export async function getStakingInfo(
let stakingScore: number | null = null;
let stakingDuration: number | null = null;
let hasStartedScoreTracking = false;
let hasCachedStakingData = false;
try {
// stakingScore pallet is on People Chain - uses cached staking data from Asset Hub via XCM
// stakingScore pallet is on People Chain - uses cached staking data submitted by noter
const scoreApi = peopleApi || api;
if (scoreApi.query.stakingScore && scoreApi.query.stakingScore.stakingStartBlock) {
// Check if user has started score tracking
@@ -252,47 +254,79 @@ export async function getStakingInfo(
const durationInBlocks = currentBlock - startBlock;
stakingDuration = durationInBlocks;
// Calculate amount-based score (20-50 points)
const stakedHEZ = ledger ? parseFloat(formatBalance(ledger.total)) : 0;
let amountScore = 20; // Default
// Check if noter has submitted cached staking data to People Chain
// CachedStakingDetails is a DoubleMap: (AccountId, StakingSource) -> StakingDetails
// StakingSource: RelayChain = 0, AssetHub = 1
// StakingDetails: { staked_amount, nominations_count, unlocking_chunks_count }
let totalCachedStakeWei = BigInt(0);
if (scoreApi.query.stakingScore.cachedStakingDetails) {
try {
const [relayResult, assetHubResult] = await Promise.all([
scoreApi.query.stakingScore.cachedStakingDetails(address, 'RelayChain')
.catch(() => null),
scoreApi.query.stakingScore.cachedStakingDetails(address, 'AssetHub')
.catch(() => null),
]);
if (stakedHEZ <= 100) {
amountScore = 20;
} else if (stakedHEZ <= 250) {
amountScore = 30;
} else if (stakedHEZ <= 750) {
amountScore = 40;
} else {
amountScore = 50; // 751+ HEZ
if (relayResult && !relayResult.isEmpty && relayResult.isSome) {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
const json = (relayResult.unwrap() as any).toJSON() as any;
totalCachedStakeWei += BigInt(json.stakedAmount ?? json.staked_amount ?? '0');
hasCachedStakingData = true;
}
if (assetHubResult && !assetHubResult.isEmpty && assetHubResult.isSome) {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
const json = (assetHubResult.unwrap() as any).toJSON() as any;
totalCachedStakeWei += BigInt(json.stakedAmount ?? json.staked_amount ?? '0');
hasCachedStakingData = true;
}
} catch {
hasCachedStakingData = false;
}
}
// Calculate duration multiplier
const MONTH_IN_BLOCKS = 30 * 24 * 60 * 10; // 432,000 blocks (~30 days, 6s per block)
let durationMultiplier = 1.0;
if (hasCachedStakingData) {
// Use cached stake from People Chain (matches on-chain pallet calculation)
const stakedHEZ = Number(totalCachedStakeWei / BigInt(10 ** 12));
let amountScore = 20; // Default
if (durationInBlocks >= 12 * MONTH_IN_BLOCKS) {
durationMultiplier = 2.0; // 12+ months
} else if (durationInBlocks >= 6 * MONTH_IN_BLOCKS) {
durationMultiplier = 1.7; // 6-11 months
} else if (durationInBlocks >= 3 * MONTH_IN_BLOCKS) {
durationMultiplier = 1.4; // 3-5 months
} else if (durationInBlocks >= MONTH_IN_BLOCKS) {
durationMultiplier = 1.2; // 1-2 months
} else {
durationMultiplier = 1.0; // < 1 month
if (stakedHEZ <= 100) {
amountScore = 20;
} else if (stakedHEZ <= 250) {
amountScore = 30;
} else if (stakedHEZ <= 750) {
amountScore = 40;
} else {
amountScore = 50; // 751+ HEZ
}
// Calculate duration multiplier
const MONTH_IN_BLOCKS = 30 * 24 * 60 * 10; // 432,000 blocks (~30 days, 6s per block)
let durationMultiplier = 1.0;
if (durationInBlocks >= 12 * MONTH_IN_BLOCKS) {
durationMultiplier = 2.0; // 12+ months
} else if (durationInBlocks >= 6 * MONTH_IN_BLOCKS) {
durationMultiplier = 1.7; // 6-11 months
} else if (durationInBlocks >= 3 * MONTH_IN_BLOCKS) {
durationMultiplier = 1.4; // 3-5 months
} else if (durationInBlocks >= MONTH_IN_BLOCKS) {
durationMultiplier = 1.2; // 1-2 months
} else {
durationMultiplier = 1.0; // < 1 month
}
// Final score calculation (max 100)
stakingScore = Math.min(100, Math.floor(amountScore * durationMultiplier));
console.log('Staking score calculated:', {
stakedHEZ,
amountScore,
durationInBlocks,
durationMultiplier,
finalScore: stakingScore
});
}
// Final score calculation (max 100)
// This MUST match the pallet's integer math: amount_score * multiplier_numerator / multiplier_denominator
stakingScore = Math.min(100, Math.floor(amountScore * durationMultiplier));
console.log('Staking score calculated:', {
stakedHEZ,
amountScore,
durationInBlocks,
durationMultiplier,
finalScore: stakingScore
});
}
}
} catch (error) {
@@ -315,6 +349,7 @@ export async function getStakingInfo(
stakingScore,
stakingDuration,
hasStartedScoreTracking,
hasCachedStakingData,
isValidator,
pezRewards
};