Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 5 additions & 6 deletions apps/web/app/profile/[address]/page.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import {
shortenAddress,
} from "@/lib/format";
import {
getReputationMetrics,
getReputationView,
type ReputationMetrics,
} from "@/lib/reputation";
import { connectWallet, getConnectedWalletAddress } from "@/lib/stellar";
Expand Down Expand Up @@ -51,16 +51,15 @@ export default function PublicProfilePage() {

async function loadProfile() {
try {
const [profileData, nextFreelancerRep, nextClientRep] = await Promise.all([
const [profileData, reputationView] = await Promise.all([
api.users.getProfile(address),
getReputationMetrics(address, "freelancer"),
getReputationMetrics(address, "client"),
getReputationView(address),
]);

if (!active) return;
setProfile(profileData);
setFreelancerRep(nextFreelancerRep);
setClientRep(nextClientRep);
setFreelancerRep(reputationView.freelancer);
setClientRep(reputationView.client);
setDisplayName(profileData.display_name ?? "");
setHeadline(profileData.headline);
setBio(profileData.bio);
Expand Down
7 changes: 4 additions & 3 deletions apps/web/hooks/use-live-job-workspace.ts
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import {
} from "@/lib/api";
import {
getReputationMetrics,
getReputationView,
type ReputationMetrics,
} from "@/lib/reputation";

Expand Down Expand Up @@ -65,14 +66,14 @@ export function useLiveJobWorkspace(jobId: string): LiveJobWorkspace {
setDeliverables(nextDeliverables);
setDispute(nextDispute);

const [nextClientRep, nextFreelancerRep] = await Promise.all([
getReputationMetrics(nextJob.client_address, "client"),
const [nextClientView, nextFreelancerRep] = await Promise.all([
getReputationView(nextJob.client_address),
nextJob.freelancer_address
? getReputationMetrics(nextJob.freelancer_address, "freelancer")
: Promise.resolve(null),
]);

setClientReputation(nextClientRep);
setClientReputation(nextClientView.client);
setFreelancerReputation(nextFreelancerRep);
setError(null);
} catch (loadError) {
Expand Down
85 changes: 63 additions & 22 deletions apps/web/lib/reputation.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import {
Keypair,
Networks,
TransactionBuilder,
nativeToScVal,
scValToNative,
} from "@stellar/stellar-sdk";
import { Server as SorobanServer } from "@stellar/stellar-sdk/rpc";
Expand All @@ -31,6 +30,26 @@ export interface ReputationMetrics {
averageStars: number;
}

export interface ReputationViewMetrics {
client: ReputationMetrics;
freelancer: ReputationMetrics;
}

interface ContractReputationScore {
address: string;
role: string;
score: number | string | bigint;
total_jobs: number | string | bigint;
total_points: number | string | bigint;
reviews: number | string | bigint;
}

interface ContractReputationView {
address: string;
client: ContractReputationScore;
freelancer: ContractReputationScore;
}

function normalizeNumber(value: unknown): number {
if (typeof value === "number") return value;
if (typeof value === "bigint") return Number(value);
Expand All @@ -50,12 +69,33 @@ function fallbackMetrics(): ReputationMetrics {
};
}

export async function getReputationMetrics(
address: string,
role: ReputationRole,
): Promise<ReputationMetrics> {
function fallbackView(): ReputationViewMetrics {
return {
client: fallbackMetrics(),
freelancer: fallbackMetrics(),
};
}

function metricsFromScore(score: ContractReputationScore): ReputationMetrics {
const scoreBps = normalizeNumber(score.score);
const totalJobs = normalizeNumber(score.total_jobs);
const totalPoints = normalizeNumber(score.total_points);
const reviews = normalizeNumber(score.reviews);
const averageStars = reviews > 0 ? totalPoints / reviews : toStarRating(scoreBps);

return {
scoreBps,
totalJobs,
totalPoints,
reviews,
starRating: toStarRating(scoreBps),
averageStars,
};
}

export async function getReputationView(address: string): Promise<ReputationViewMetrics> {
if (!REPUTATION_CONTRACT_ID) {
return fallbackMetrics();
return fallbackView();
}

try {
Expand All @@ -69,9 +109,8 @@ export async function getReputationMetrics(
})
.addOperation(
contract.call(
"get_public_metrics",
"query_reputation",
Address.fromString(address).toScVal(),
nativeToScVal(role, { type: "symbol" }),
),
)
.setTimeout(30)
Expand All @@ -80,24 +119,26 @@ export async function getReputationMetrics(
const simulation = await rpc.simulateTransaction(tx);
const raw =
"result" in simulation && simulation.result?.retval
? (scValToNative(simulation.result.retval) as unknown[])
: [];
? (scValToNative(simulation.result.retval) as ContractReputationView)
: null;

const scoreBps = normalizeNumber(raw[0]);
const totalJobs = normalizeNumber(raw[1]);
const totalPoints = normalizeNumber(raw[2]);
const reviews = normalizeNumber(raw[3]);
const averageStars = reviews > 0 ? totalPoints / reviews : toStarRating(scoreBps);
if (!raw) {
return fallbackView();
}

return {
scoreBps,
totalJobs,
totalPoints,
reviews,
starRating: toStarRating(scoreBps),
averageStars,
client: metricsFromScore(raw.client),
freelancer: metricsFromScore(raw.freelancer),
};
} catch {
return fallbackMetrics();
return fallbackView();
}
}

export async function getReputationMetrics(
address: string,
role: ReputationRole,
): Promise<ReputationMetrics> {
const view = await getReputationView(address);
return role === "client" ? view.client : view.freelancer;
}
Loading
Loading