fix: support FTs with missing metadata but correct token data

jest.config.js

@@ -176,10 +176,7 @@ module.exports = {
   transform: {},
 
   // An array of regexp pattern strings that are matched against all source file paths, matched files will skip transformation
-  // transformIgnorePatterns: [
-  //   "/node_modules/",
-  //   "\\.pnp\\.[^\\/]+$"
-  // ],
+  transformIgnorePatterns: ["./dist/.+\\.js"]
 
   // An array of regexp pattern strings that are matched against all modules before the module loader will automatically return a mock for them
   // unmockedModulePathPatterns: undefined,

src/token-processor/queue/job/process-token-job.ts

@@ -114,7 +114,19 @@ export class ProcessTokenJob extends Job {
 
     let metadataLocales: DbMetadataLocaleInsertBundle[] | undefined;
     if (uri) {
-      metadataLocales = await fetchAllMetadataLocalesFromBaseUri(uri, token);
+      try {
+        metadataLocales = await fetchAllMetadataLocalesFromBaseUri(uri, token);
+      } catch (error) {
+        // If the fetch error is retryable, rethrow for job retry. If it's not but we don't have any
+        // data to display otherwise, rethrow so we can mark the job as failed/invalid.
+        if (error instanceof RetryableJobError || !(name || symbol || fDecimals || fTotalSupply)) {
+          throw error;
+        }
+        logger.warn(
+          error,
+          `ProcessTokenJob ${this.description()} metadata fetch failed for ${uri}, continuing with contract data`
+        );
+      }
     }
 
     const tokenValues: DbProcessedTokenUpdateBundle = {

tests/process-token-job.test.ts

@@ -112,6 +112,83 @@ describe('ProcessTokenJob', () => {
       expect(token?.decimals).toBe(6);
       expect(token?.total_supply).toBe(1997500000000n);
     });
+
+    test('keeps contract FT info if metadata fetch fails', async () => {
+      const agent = new MockAgent();
+      agent.disableNetConnect();
+      const interceptor = agent.get(
+        `http://${ENV.STACKS_NODE_RPC_HOST}:${ENV.STACKS_NODE_RPC_PORT}`
+      );
+      interceptor
+        .intercept({
+          path: '/v2/contracts/call-read/ABCD/test-ft/get-name',
+          method: 'POST',
+        })
+        .reply(200, {
+          okay: true,
+          result: cvToHex(stringUtf8CV('FooToken')),
+        });
+      interceptor
+        .intercept({
+          path: '/v2/contracts/call-read/ABCD/test-ft/get-token-uri',
+          method: 'POST',
+        })
+        .reply(200, {
+          okay: true,
+          result: cvToHex(stringUtf8CV('http://m.io/{id}.json')),
+        });
+      interceptor
+        .intercept({
+          path: '/v2/contracts/call-read/ABCD/test-ft/get-symbol',
+          method: 'POST',
+        })
+        .reply(200, {
+          okay: true,
+          result: cvToHex(stringUtf8CV('FOO')),
+        });
+      interceptor
+        .intercept({
+          path: '/v2/contracts/call-read/ABCD/test-ft/get-decimals',
+          method: 'POST',
+        })
+        .reply(200, {
+          okay: true,
+          result: cvToHex(uintCV(6)),
+        });
+      interceptor
+        .intercept({
+          path: '/v2/contracts/call-read/ABCD/test-ft/get-total-supply',
+          method: 'POST',
+        })
+        .reply(200, {
+          okay: true,
+          result: cvToHex(uintCV(1997500000000)),
+        });
+      agent
+        .get('http://m.io')
+        .intercept({
+          path: '/1.json',
+          method: 'GET',
+        })
+        .reply(500, { message: 'server error' })
+        .persist();
+      setGlobalDispatcher(agent);
+
+      const processor = new ProcessTokenJob({ db, job: tokenJob });
+      await processor.work();
+
+      const token = await db.getToken({ id: 1 });
+      expect(token).not.toBeUndefined();
+      expect(token?.name).toBe('FooToken');
+      expect(token?.symbol).toBe('FOO');
+      expect(token?.decimals).toBe(6);
+      expect(token?.total_supply).toBe(1997500000000n);
+      const bundle = await db.getTokenMetadataBundle({
+        contractPrincipal: 'ABCD.test-ft',
+        tokenNumber: 1,
+      });
+      expect(bundle?.metadataLocale).toBeUndefined();
+    });
   });
 
   describe('NFT', () => {