169 no buy for you

package.json

@@ -7,7 +7,7 @@
     "update": "npx npm-check-updates --filter /subsquid/ --upgrade && npm i -f",
     "db:migrate": "npx squid-typeorm-migration apply",
     "processor:start": "node lib/processor.js",
-    "query-node:start": "squid-graphql-server --subscriptions --dumb-cache in-memory --dumb-cache-ttl 1000 --dumb-cache-size 100 --dumb-cache-max-age 1000",
+    "query-node:start": "squid-graphql-server --subscriptions --max-root-fields 50 --dumb-cache in-memory --dumb-cache-ttl 1000 --dumb-cache-size 100 --dumb-cache-max-age 1000",
     "test:unit": "mocha -r ts-node/register tests/unit/**.spec.ts"
   },
   "dependencies": {

src/mappings/index.ts

@@ -13,7 +13,7 @@ import { updateCache } from './utils/cache'
 import { burned, isBuyLegalOrElseError, isInteractive, isOwnerOrElseError, isPositiveOrElseError, plsBe, plsNotBe, real, validateInteraction, withMeta } from './utils/consolidator'
 import { create, get } from './utils/entity'
 import { getCreateCollection, getCreateToken, getInteraction, getInteractionWithExtra } from './utils/getters'
-import { emoteId, ensure, eventId, isEmpty } from './utils/helper'
+import { collectionIdFrom, emoteId, ensure, eventId, isEmpty } from './utils/helper'
 import logger, { logError } from './utils/logger'
 import { fetchMetadata } from './utils/metadata'
 import {
@@ -230,8 +230,8 @@ async function buy(context: Context) {
     nft.price = BigInt(0)
     nft.updatedAt = timestamp
 
-    plsBe(real, nft.collection)
-    const collection = ensure<CollectionEntity>(await get<CollectionEntity>(context.store, CollectionEntity, nft.collection.toString()))
+    const collectionId = collectionIdFrom(nft.id)
+    const collection = ensure<CollectionEntity>(await get<CollectionEntity>(context.store, CollectionEntity, collectionId))
     plsBe(real, collection)
     collection.updatedAt = timestamp
 
@@ -261,8 +261,9 @@ async function consume(context: Context) {
     nft.price = BigInt(0)
     nft.burned = true
     nft.updatedAt = timestamp
-    plsBe(real, nft.collection)
-    const collection = ensure<CollectionEntity>(await get<CollectionEntity>(context.store, CollectionEntity, nft.collection.toString()))
+
+    const collectionId = collectionIdFrom(nft.id)
+    const collection = ensure<CollectionEntity>(await get<CollectionEntity>(context.store, CollectionEntity, collectionId))
     plsBe(real, collection)
     collection.updatedAt = timestamp
     collection.supply -= 1

src/mappings/utils/helper.ts

@@ -14,6 +14,11 @@ export const eventId = (id: string, event: RmrkEvent) => `${id}-${event}${nanoid
 
 export const ensureInteraction = ({ id, value: metadata }: RmrkInteraction): RmrkInteraction  => ({ id: trim(id), value: trimAll(metadata) })
 
+export const collectionIdFrom = (nftId: string) => {
+  const [_blockNumber, id, symbol] = nftId.split('-')
+  return `${id}-${symbol}`
+}
+
 export function ensure<T>(value: any): T {
   return value as T
 }