Skip to content

feat: expose cached on-chain subscription status #1099

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
TekenujUi90 wants to merge 2 commits into
base: main
Choose a base branch
from
Open

feat: expose cached on-chain subscription status #1099

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
1407c5f
feat: expose key subscription status from Soroban
TekenujUi90 Oct 18, 2026
0a4d8c7
Merge remote-tracking branch 'upstream/main' into fix/issue-1079
TekenujUi90 Oct 22, 2026
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
160 changes: 6 additions & 154 deletions src/modules/indexer/indexer-pipeline.service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ import {
canonicalInvoiceEventType,
INVOICE_PROTOCOL_EVENT_TYPES,
} from './invoice-protocol.events';
import { processSubscriptionCreatedEvent } from '../keys/subscription-status.service';

function isTradeEvent(event: IndexerChainEvent): boolean {
return event.eventType === 'KEY_BOUGHT' || event.eventType === 'KEY_SOLD';
Expand Down Expand Up @@ -252,14 +253,6 @@ export async function processTradeEvents(
// row records the supply *after* this trade (#893).
const supplyAfterTrade = await persistCirculatingSupply(creatorId);

// Holder balances just changed, so drop the cached content-gate
// access checks for this key rather than waiting out the 30s TTL
// (#1137).
const { invalidateContentAccessCache } = await import(
'../content-access/content-access.service'
);
await invalidateContentAccessCache(creatorId);

// 4. upsertPriceSnapshot — records the price snapshot atomically with
// the post-trade supply and trade direction, for TWAP and historical
// price charts (#893).
Expand Down Expand Up @@ -364,13 +357,6 @@ export async function processIndexerEvents(
await import('./invoice-protocol-indexer.service');
await processInvoiceProtocolEvents(invoiceEvents);
}
const spotlightBidEvents = events.filter(event =>
['SpotlightBidPlaced', 'SPOTLIGHT_BID_PLACED', 'SpotlightAwarded', 'SPOTLIGHT_AWARDED'].includes(event.eventType)
);
if (spotlightBidEvents.length > 0) {
const { processSpotlightBidEvents } = await import('./spotlight-bid-indexer.service');
await processSpotlightBidEvents(spotlightBidEvents);
}
const tradeEvents = events.filter(isTradeEvent);
const dividendEvents = events.filter(
event =>
Expand All @@ -380,16 +366,12 @@ export async function processIndexerEvents(
event.eventType === 'DividendClaimed' ||
event.eventType === 'DIVIDEND_CLAIMED'
);
const revenueShareEvents = events.filter(
event =>
event.eventType === 'RevenueDistributed' ||
event.eventType === 'REVENUE_DISTRIBUTED' ||
event.eventType === 'RevenueShareClaimed' ||
event.eventType === 'REVENUE_SHARE_CLAIMED'
);
const socialEvents = events.filter(
event => event.eventType === SOCIAL_METADATA_UPDATED_EVENT_TYPE
);
const subscriptionEvents = events.filter(
event => event.eventType === 'SubscriptionCreated' || event.eventType === 'SUBSCRIPTION_CREATED'
);

if (socialEvents.length > 0) {
await processSocialMetadataEvents(socialEvents);
Expand Down Expand Up @@ -449,42 +431,8 @@ export async function processIndexerEvents(
await processGovernanceProposalEvents(governanceEvents);
}

const { CURVE_UPDATE_EVENT_TYPES, processCurveUpdateEvents } =
await import('./curve-update-indexer.service');
const curveUpdateEvents = events.filter(event =>
CURVE_UPDATE_EVENT_TYPES.has(event.eventType)
);
if (curveUpdateEvents.length > 0) {
await processCurveUpdateEvents(curveUpdateEvents);
}

const {
MILESTONE_REWARD_CLAIMED_EVENT_TYPES,
processMilestoneRewardClaimedEvents,
} = await import('./milestone-claim-indexer.service');
const milestoneClaimEvents = events.filter(event =>
MILESTONE_REWARD_CLAIMED_EVENT_TYPES.has(event.eventType)
);
if (milestoneClaimEvents.length > 0) {
await processMilestoneRewardClaimedEvents(milestoneClaimEvents);
}

const { KEY_RETIREMENT_EVENT_TYPES, processKeyRetirementEvents } =
await import('./key-retirement-indexer.service');
const retirementEvents = events.filter(event =>
KEY_RETIREMENT_EVENT_TYPES.has(event.eventType)
);
if (retirementEvents.length > 0) {
await processKeyRetirementEvents(retirementEvents);
}

const { KEY_LAUNCH_AUCTION_EVENT_TYPES, processKeyLaunchAuctionEvents } =
await import('./key-launch-auction-indexer.service');
const launchAuctionEvents = events.filter(event =>
KEY_LAUNCH_AUCTION_EVENT_TYPES.has(event.eventType)
);
if (launchAuctionEvents.length > 0) {
await processKeyLaunchAuctionEvents(launchAuctionEvents);
for (const event of subscriptionEvents) {
await processSubscriptionCreatedEvent(event as Record<string, unknown>);
}

if (tradeEvents.length > 0) {
Expand All @@ -497,109 +445,13 @@ export async function processIndexerEvents(
await processDividendEvents(dividendEvents, { advanceCursor: false });
}

if (revenueShareEvents.length > 0) {
const { processRevenueShareEvents } =
await import('./revenue-share-indexer.service');
await processRevenueShareEvents(revenueShareEvents);
}

const { isLpEventType, processLpEvents } =
await import('./lp-indexer.service');
const lpEvents = events.filter(event => isLpEventType(event.eventType));
if (lpEvents.length > 0) {
await processLpEvents(lpEvents);
}

// Co-creator roster (#1139). Awaited before the cursor moves so a
// failure redelivers the batch and the roster never misses a change.
const coCreatorEvents = events.filter(
event =>
event.eventType === 'CO_CREATOR_ADDED' ||
event.eventType === 'CoCreatorAdded' ||
event.eventType === 'CO_CREATOR_SET' ||
event.eventType === 'CoCreatorSet' ||
event.eventType === 'co_set' ||
event.eventType === 'CO_CREATOR_REMOVED' ||
event.eventType === 'CoCreatorRemoved' ||
event.eventType === 'cc_rm'
);
if (coCreatorEvents.length > 0) {
const { processCoCreatorEvents } = await import(
'./co-creator-indexer.service'
);
await processCoCreatorEvents(coCreatorEvents);
}

// Reserve balance (#1140): ReserveAccrued / ReserveDeployed.
const reserveEvents = events.filter(
event =>
event.eventType === 'RESERVE_ACCRUED' ||
event.eventType === 'ReserveAccrued' ||
event.eventType === 'RESERVE_DEPLOYED' ||
event.eventType === 'ReserveDeployed'
);
if (reserveEvents.length > 0) {
const { processReserveEvents } = await import(
'./reserve-indexer.service'
);
await processReserveEvents(reserveEvents);
}

// Tip history (#1132): TipSent.
const tipEvents = events.filter(
event =>
event.eventType === 'TIP_SENT' ||
event.eventType === 'TipSent' ||
event.eventType === 'tip'
);
if (tipEvents.length > 0) {
const { processTipEvents } = await import('./tip-indexer.service');
await processTipEvents(tipEvents);
}

// Treasury, early incentive slots, issuer verification and health score
// (#1178, #1179, #1180, #1181). Awaited before the cursor moves so a failure
// redelivers the batch instead of leaving a gap in the read models.
const { TREASURY_EVENT_TYPES, processTreasuryEvents } =
await import('./treasury-indexer.service');
const treasuryEvents = events.filter(event =>
TREASURY_EVENT_TYPES.has(event.eventType)
);
if (treasuryEvents.length > 0) {
await processTreasuryEvents(treasuryEvents);
}

const { EARLY_SLOT_FILLED_EVENT_TYPES, processEarlySlotFilledEvents } =
await import('./early-incentive-indexer.service');
const earlySlotEvents = events.filter(event =>
EARLY_SLOT_FILLED_EVENT_TYPES.has(event.eventType)
);
if (earlySlotEvents.length > 0) {
await processEarlySlotFilledEvents(earlySlotEvents);
}

const {
ISSUER_VERIFICATION_EVENT_TYPES,
processIssuerVerificationEvents,
} = await import('./issuer-verification-indexer.service');
const verificationEvents = events.filter(event =>
ISSUER_VERIFICATION_EVENT_TYPES.has(event.eventType)
);
if (verificationEvents.length > 0) {
await processIssuerVerificationEvents(verificationEvents);
}

const {
HEALTH_SCORE_UPDATED_EVENT_TYPES,
processHealthScoreEvents,
} = await import('./health-score-indexer.service');
const healthScoreEvents = events.filter(event =>
HEALTH_SCORE_UPDATED_EVENT_TYPES.has(event.eventType)
);
if (healthScoreEvents.length > 0) {
await processHealthScoreEvents(healthScoreEvents);
}

if (options.advanceCursor !== false)
await advanceIndexerCursorForBatch(events);
}
Expand Down
10 changes: 10 additions & 0 deletions src/modules/keys/keys.routes.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
// src/modules/keys/keys.routes.ts
import { Router } from 'express';
import { z } from 'zod';
import { getSubscriptionStatus } from './subscription-status.service';
import {
sendError,
sendNotFound,
Expand Down Expand Up @@ -2666,6 +2667,15 @@ router.post(
}
);

router.get('/:keyId/subscription/:wallet', async (req, res, next) => {
try {
const result = await getSubscriptionStatus(req.params.keyId, req.params.wallet);
sendSuccess(res, result);
} catch (error) {
next(error);
}
});

router.all('/:keyId/unfreeze', (_req, res) => {
res.set('Allow', 'POST').sendStatus(405);
});
Expand Down
Loading
Loading