Skip to content
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

fix: add indexes for reverse domainId relations #292

Merged
merged 2 commits into from
Feb 20, 2025
Merged

fix: add indexes for reverse domainId relations #292

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
d9c1681
fix: add indexes for reverse domainId relations
shrugs Feb 20, 2025
41b9538
fix: primary and compound indexes for events
shrugs Feb 20, 2025
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
131 changes: 79 additions & 52 deletions packages/ponder-schema/src/ponder.schema.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -110,25 +110,31 @@ export const accountRelations = relations(account, ({ many }) => ({
* Resolver
*/

export const resolver = onchainTable("resolvers", (t) => ({
// The unique identifier for this resolver, which is a concatenation of the domain namehash and the resolver address
id: t.text().primaryKey(),
// The domain that this resolver is associated with
domainId: t.hex("domain_id").notNull(),
// The address of the resolver contract
address: t.hex().notNull().$type<Address>(),

// The current value of the 'addr' record for this resolver, as determined by the associated events
addrId: t.hex("addr_id"),
// The content hash for this resolver, in binary format
contentHash: t.text("content_hash"),
// The set of observed text record keys for this resolver
// NOTE: we avoid .notNull.default([]) to match subgraph behavior
texts: t.text().array(),
// The set of observed SLIP-44 coin types for this resolver
// NOTE: we avoid .notNull.default([]) to match subgraph behavior
coinTypes: t.bigint().array(),
}));
export const resolver = onchainTable(
"resolvers",
(t) => ({
// The unique identifier for this resolver, which is a concatenation of the domain namehash and the resolver address
id: t.text().primaryKey(),
// The domain that this resolver is associated with
domainId: t.hex("domain_id").notNull(),
// The address of the resolver contract
address: t.hex().notNull().$type<Address>(),

// The current value of the 'addr' record for this resolver, as determined by the associated events
addrId: t.hex("addr_id"),
// The content hash for this resolver, in binary format
contentHash: t.text("content_hash"),
// The set of observed text record keys for this resolver
// NOTE: we avoid .notNull.default([]) to match subgraph behavior
texts: t.text().array(),
// The set of observed SLIP-44 coin types for this resolver
// NOTE: we avoid .notNull.default([]) to match subgraph behavior
coinTypes: t.bigint().array(),
}),
(t) => ({
idx: index().on(t.domainId),
}),
);

export const resolverRelations = relations(resolver, ({ one, many }) => ({
addr: one(account, { fields: [resolver.addrId], references: [account.id] }),
Expand All @@ -151,22 +157,28 @@ export const resolverRelations = relations(resolver, ({ one, many }) => ({
* Registration
*/

export const registration = onchainTable("registrations", (t) => ({
// The unique identifier of the registration
id: t.hex().primaryKey(),
// The domain name associated with the registration
domainId: t.hex("domain_id").notNull(),
// The registration date of the domain
registrationDate: t.bigint("registration_date").notNull(),
// The expiry date of the domain
expiryDate: t.bigint("expiry_date").notNull(),
// The cost associated with the domain registration
cost: t.bigint(),
// The account that registered the domain
registrantId: t.hex("registrant_id").notNull(),
// The human-readable label name associated with the domain registration
labelName: t.text(),
}));
export const registration = onchainTable(
"registrations",
(t) => ({
// The unique identifier of the registration
id: t.hex().primaryKey(),
// The domain name associated with the registration
domainId: t.hex("domain_id").notNull(),
// The registration date of the domain
registrationDate: t.bigint("registration_date").notNull(),
// The expiry date of the domain
expiryDate: t.bigint("expiry_date").notNull(),
// The cost associated with the domain registration
cost: t.bigint(),
// The account that registered the domain
registrantId: t.hex("registrant_id").notNull(),
// The human-readable label name associated with the domain registration
labelName: t.text(),
}),
(t) => ({
idx: index().on(t.domainId),
}),
);

export const registrationRelations = relations(registration, ({ one, many }) => ({
domain: one(domain, {
Expand All @@ -188,20 +200,26 @@ export const registrationRelations = relations(registration, ({ one, many }) =>
* Wrapped Domain
*/

export const wrappedDomain = onchainTable("wrapped_domains", (t) => ({
// The unique identifier for each instance of the WrappedDomain entity
id: t.hex().primaryKey(),
// The domain that is wrapped by this WrappedDomain
domainId: t.hex("domain_id").notNull(),
// The expiry date of the wrapped domain
expiryDate: t.bigint("expiry_date").notNull(),
// The number of fuses remaining on the wrapped domain
fuses: t.integer().notNull(),
// The account that owns this WrappedDomain
ownerId: t.hex("owner_id").notNull(),
// The name of the wrapped domain
name: t.text(),
}));
export const wrappedDomain = onchainTable(
"wrapped_domains",
(t) => ({
// The unique identifier for each instance of the WrappedDomain entity
id: t.hex().primaryKey(),
// The domain that is wrapped by this WrappedDomain
domainId: t.hex("domain_id").notNull(),
// The expiry date of the wrapped domain
expiryDate: t.bigint("expiry_date").notNull(),
// The number of fuses remaining on the wrapped domain
fuses: t.integer().notNull(),
// The account that owns this WrappedDomain
ownerId: t.hex("owner_id").notNull(),
// The name of the wrapped domain
name: t.text(),
}),
(t) => ({
idx: index().on(t.domainId),
}),
);

export const wrappedDomainRelations = relations(wrappedDomain, ({ one }) => ({
domain: one(domain, {
Expand Down Expand Up @@ -230,7 +248,10 @@ const domainEvent = (t: any) => ({
});

const domainEventIndex = (t: any) => ({
idx: index().on(t.domainId, t.id),
// primary reverse lookup
idx: index().on(t.domainId),
// sorting index
idx_compound: index().on(t.domainId, t.id),
});

// Domain Event Entities
Expand Down Expand Up @@ -328,7 +349,10 @@ const registrationEvent = (t: any) => ({
});

const registrationEventIndex = (t: any) => ({
idx: index().on(t.registrationId, t.id),
// primary reverse lookup
idx: index().on(t.registrationId),
// sorting index
idx_compound: index().on(t.registrationId, t.id),
});

export const nameRegistered = onchainTable(
Expand Down Expand Up @@ -367,7 +391,10 @@ const resolverEvent = (t: any) => ({
});

const resolverEventIndex = (t: any) => ({
idx: index().on(t.resolverId, t.id),
// primary reverse lookup
idx: index().on(t.resolverId),
// sorting index
idx_compound: index().on(t.resolverId, t.id),
});

export const addrChanged = onchainTable(
Expand Down