Toggle utilizing signed API URLs from AirseekerRegistry (#452)

bdrhn9 · web-flow · commit 35265e21832f · 2025-03-05T01:04:26.000+03:00
* Toggle utilizing signed API URLs from AirseekerRegistry

* Standardize capitalization of "Signed API" throughout the docs and code

* Update introduction
diff --git a/README.md b/README.md
@@ -1,9 +1,9 @@
 # airseeker-v2
 
-> A service powering data feeds using the [signed API](https://github.com/api3dao/signed-api).
+> A service powering data feeds using the [Signed API](https://github.com/api3dao/signed-api).
 
-The Airseeker is a rework of the [original Airseeker](https://github.com/api3dao/airseeker). The Airseeker v2 is
-simplified and only works with signed APIs.
+Airseeker v2 is a streamlined redesign of the [original Airseeker](https://github.com/api3dao/airseeker-v1), focused
+exclusively on working with Signed APIs for improved efficiency and simplicity.
 
 ## Getting started
 
diff --git a/airseeker_v2_pipeline.drawio b/airseeker_v2_pipeline.drawio
@@ -19,7 +19,7 @@
                 <mxCell id="ci7EG28U3f9VGxeywyoC-39" value="for each&lt;br&gt;in parallel" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="ci7EG28U3f9VGxeywyoC-34" target="ci7EG28U3f9VGxeywyoC-38" edge="1">
                     <mxGeometry relative="1" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-34" value="Get all active Airnode addresses and their respective signed API URLs." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-34" value="Get all active Airnode addresses and their respective Signed API URLs." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="480" y="800" width="240" height="80" as="geometry"/>
                 </mxCell>
                 <mxCell id="ci7EG28U3f9VGxeywyoC-35" value="State" style="ellipse;whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
@@ -28,7 +28,7 @@
                 <mxCell id="ci7EG28U3f9VGxeywyoC-41" value="for all&lt;br&gt;responses" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="ci7EG28U3f9VGxeywyoC-38" target="ci7EG28U3f9VGxeywyoC-40" edge="1">
                     <mxGeometry relative="1" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-38" value="Call signed API URLs in parallel." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-38" value="Call Signed API URLs in parallel." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="880" y="800" width="240" height="80" as="geometry"/>
                 </mxCell>
                 <mxCell id="ci7EG28U3f9VGxeywyoC-47" value="for all valid&lt;br&gt;responses" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="ci7EG28U3f9VGxeywyoC-40" target="ci7EG28U3f9VGxeywyoC-44" edge="1">
@@ -96,13 +96,13 @@
                 <mxCell id="ci7EG28U3f9VGxeywyoC-59" value="Chain" style="rhombus;whiteSpace=wrap;html=1;rounded=1;glass=0;strokeWidth=1;shadow=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="1360" y="1639" width="80" height="80" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-61" value="Call signed API URLs in parallel." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-61" value="Call Signed API URLs in parallel." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="890" y="810" width="240" height="80" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-62" value="Call signed API URL." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-62" value="Call Signed API URL." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="900" y="820" width="240" height="80" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-69" value="Persist the Airnode addresses, template IDs, signed API URLs and on-chain values for these data feeds." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-69" value="Persist the Airnode addresses, template IDs, Signed API URLs and on-chain values for these data feeds." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="1680" y="1479" width="240" height="80" as="geometry"/>
                 </mxCell>
                 <mxCell id="ci7EG28U3f9VGxeywyoC-74" value="write to" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;exitX=0.5;exitY=1;exitDx=0;exitDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="ci7EG28U3f9VGxeywyoC-69" target="ci7EG28U3f9VGxeywyoC-75" edge="1">
@@ -121,7 +121,7 @@
                 <mxCell id="ci7EG28U3f9VGxeywyoC-78" value="" style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="1290" y="1490" width="240" height="80" as="geometry"/>
                 </mxCell>
-                <mxCell id="ci7EG28U3f9VGxeywyoC-79" value="Fetch the rest of the active data feed batches together with Airnode address, template ID(s), signed API URLs and on-chain values." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
+                <mxCell id="ci7EG28U3f9VGxeywyoC-79" value="Fetch the rest of the active data feed batches together with Airnode address, template ID(s), Signed API URLs and on-chain values." style="rounded=1;whiteSpace=wrap;html=1;fontSize=12;glass=0;strokeWidth=1;shadow=0;align=center;" parent="WIyWlLk6GJQsqaUBKTNV-1" vertex="1">
                     <mxGeometry x="1300" y="1499" width="240" height="80" as="geometry"/>
                 </mxCell>
                 <mxCell id="ci7EG28U3f9VGxeywyoC-89" value="if there is any data feed&lt;br&gt;to be updated" style="edgeStyle=orthogonalEdgeStyle;rounded=0;orthogonalLoop=1;jettySize=auto;html=1;entryX=0;entryY=0.5;entryDx=0;entryDy=0;" parent="WIyWlLk6GJQsqaUBKTNV-1" source="ci7EG28U3f9VGxeywyoC-86" target="ci7EG28U3f9VGxeywyoC-88" edge="1">
diff --git a/airseeker_v2_pipeline.drawio.svg b/airseeker_v2_pipeline.drawio.svg
diff --git a/config/airseeker.example.json b/config/airseeker.example.json
@@ -29,6 +29,7 @@
   "individualBeaconUpdateSettings": null,
   "signedDataFetchInterval": 10,
   "signedApiUrls": [],
+  "useSignedApiUrlsFromContract": true,
   "walletDerivationScheme": { "type": "managed" },
   "stage": "dev",
   "version": "3.11.0"
diff --git a/config/configuration.md b/config/configuration.md
@@ -255,11 +255,23 @@ only rely on the RPC provider for gas limit estimation and will skip an update i
 
 ### `signedDataFetchInterval`
 
-The fetch interval in seconds between retrievals of signed API data.
+The fetch interval in seconds between retrievals of Signed API data.
 
 ### `signedApiUrls`
 
-A list of signed API URLs to call along with URLs fetched from the chain.
+A list of Signed API URLs to call along with URLs fetched from the chain.
+
+### `useSignedApiUrlsFromContract` _(optional)_
+
+A boolean flag that determines whether to use Signed API URLs from the AirseekerRegistry contract. When set to `true`,
+Airseeker will use both the URLs from the configuration and from the contract. When set to `false`, only the URLs from
+the configuration will be used.
+
+```jsonc
+"useSignedApiUrlsFromContract": true,
+```
+
+Defaults to `true`.
 
 ### `walletDerivationScheme`
 
diff --git a/local-test-configuration/README.md b/local-test-configuration/README.md
@@ -5,7 +5,7 @@ is the setup:
 
 - Use 2 Airnode feeds with Nodary API and reasonable fetch limits. Each Airnode feed has a different Airnode mnemonic to
   mimic a different API. One of the APIs is delayed so that the beacons have different values.
-- Use 2 signed APIs and each Airnode feed pushes to a separate Signed API.
+- Use 2 Signed APIs and each Airnode feed pushes to a separate Signed API.
 - We run Airseeker only on Hardhat network for setup simplicity. Initially, I wanted to have a Polygon testnet as well,
   but gave up on that idea for now. The setup can be easily extended to run on any chain, just by not starting Hardhat
   network and using a different RPCs.
@@ -72,7 +72,7 @@ also required for the monitoring page.
 The `AIRSEEKER_MNEMONIC` needs to be URI encoded via `encodeURIComponent` in JS. For example,
 `test%20test%20test%20test%20test%20test%20test%20test%20test%20test%20test%20junk`.
 
-The page constantly polls the chain and respective signed APIs and compares the on-chain and off-chain values. If the
+The page constantly polls the chain and respective Signed APIs and compares the on-chain and off-chain values. If the
 deviation exceeds the treshold, the value is marked bold and should be updated by Airseeker shortly.
 
 - Run the Airseeker:
diff --git a/local-test-configuration/airseeker/airseeker.example.json b/local-test-configuration/airseeker/airseeker.example.json
@@ -32,6 +32,7 @@
   },
   "signedDataFetchInterval": 10,
   "signedApiUrls": [],
+  "useSignedApiUrlsFromContract": true,
   "walletDerivationScheme": { "type": "managed" },
   "stage": "dev",
   "version": "3.1.0"
diff --git a/local-test-configuration/monitoring/index.html b/local-test-configuration/monitoring/index.html
@@ -9,7 +9,7 @@
   <body>
     <h1>Airseeker monitoring</h1>
     <p>
-      Uses a fixed (static) configuration to fetch on-chain values of active data feeds and signed API data and computes
+      Uses a fixed (static) configuration to fetch on-chain values of active data feeds and Signed API data and computes
       the deviation treshold.
     </p>
 
diff --git a/local-test-configuration/scripts/initialize-chain.ts b/local-test-configuration/scripts/initialize-chain.ts
@@ -212,8 +212,8 @@ export const deploy = async (funderWallet: ethers.NonceManager, provider: ethers
 
   // Set active dAPIs
   const apiTreeValues = [
-    [airnodeFeed1Wallet.address, joinUrl(airnodeFeed1.signedApis[0].url, 'default')], // NOTE: Airnode feed pushes to the "/" of the signed API, but we need to query it additional path.
-    [airnodeFeed2Wallet.address, joinUrl(airnodeFeed2.signedApis[0].url, 'default')], // NOTE: Airnode feed pushes to the "/" of the signed API, but we need to query it additional path.
+    [airnodeFeed1Wallet.address, joinUrl(airnodeFeed1.signedApis[0].url, 'default')], // NOTE: Airnode feed pushes to the "/" of the Signed API, but we need to query it additional path.
+    [airnodeFeed2Wallet.address, joinUrl(airnodeFeed2.signedApis[0].url, 'default')], // NOTE: Airnode feed pushes to the "/" of the Signed API, but we need to query it additional path.
   ] as const;
   for (const [airnode, url] of apiTreeValues) {
     const setSignedApiUrlTx = await airseekerRegistry.connect(deployerAndManager).setSignedApiUrl(airnode, url);
diff --git a/src/config/schema.ts b/src/config/schema.ts
@@ -195,6 +195,7 @@ export const configSchema = z
     stage: z
       .string()
       .regex(/^[\da-z-]{1,256}$/, 'Only lowercase letters, numbers and hyphens are allowed (max 256 characters)'),
+    useSignedApiUrlsFromContract: z.boolean().default(true),
     version: z.string().refine((version) => version === packageVersion, 'Invalid Airseeker version'),
     walletDerivationScheme: walletDerivationSchemeSchema,
   })
diff --git a/src/data-fetcher-loop/data-fetcher-loop.test.ts b/src/data-fetcher-loop/data-fetcher-loop.test.ts
@@ -9,6 +9,8 @@ import * as dataFetcherLoopModule from './data-fetcher-loop';
 import * as signedDataStateModule from './signed-data-state';
 import * as signedDataVerifierPoolModule from './signed-data-verifier-pool';
 
+jest.setTimeout(10_000); // Default Jest timeout is 5s which is not enough for staggering two Signed API calls with signedDataFetchInterval 10s
+
 describe(dataFetcherLoopModule.runDataFetcher.name, () => {
   beforeEach(() => {
     initializeState();
@@ -31,8 +33,6 @@ describe(dataFetcherLoopModule.runDataFetcher.name, () => {
   });
 
   it('saves signed data for active data feeds', async () => {
-    const saveSignedDataSpy = jest.spyOn(signedDataStateModule, 'saveSignedData');
-
     jest.spyOn(commonsModule, 'executeRequest').mockResolvedValue({
       success: true,
       errorData: undefined,
@@ -71,11 +71,12 @@ describe(dataFetcherLoopModule.runDataFetcher.name, () => {
     jest.spyOn(signedDataStateModule, 'isSignedDataFresh').mockReturnValue(true);
     jest.spyOn(signedDataVerifierPoolModule, 'getVerifier').mockResolvedValue(createMockSignedDataVerifier());
     jest.spyOn(logger, 'info');
+    jest.spyOn(signedDataStateModule, 'saveSignedData');
 
     await expect(dataFetcherLoopModule.runDataFetcher()).resolves.toBeDefined();
 
     expect(commonsModule.executeRequest).toHaveBeenCalledTimes(1);
-    expect(saveSignedDataSpy).toHaveBeenCalledTimes(1);
+    expect(signedDataStateModule.saveSignedData).toHaveBeenCalledTimes(1);
     expect(dataFetcherLoopModule.callSignedApi).toHaveBeenNthCalledWith(
       1,
       'http://127.0.0.1:8090/0xC04575A2773Da9Cd23853A69694e02111b2c4182',
@@ -117,6 +118,76 @@ describe(dataFetcherLoopModule.runDataFetcher.name, () => {
       })
     );
   });
+
+  it('respects useSignedApiUrlsFromContract flag when set to false', async () => {
+    updateState((draft) => {
+      draft.config.useSignedApiUrlsFromContract = false;
+      draft.signedApiUrlsFromContract = {
+        '31337': { hardhat: ['http://127.0.0.1:8091/0xContractProvidedAirnode'] },
+      };
+    });
+
+    const callSignedApiSpy = jest.spyOn(dataFetcherLoopModule, 'callSignedApi').mockResolvedValue(null);
+    jest.spyOn(signedDataStateModule, 'isSignedDataFresh').mockReturnValue(true);
+    jest.spyOn(signedDataStateModule, 'saveSignedData').mockResolvedValue(0);
+    jest.spyOn(signedDataStateModule, 'purgeOldSignedData').mockImplementation();
+    jest.spyOn(signedDataVerifierPoolModule, 'getVerifier').mockResolvedValue(createMockSignedDataVerifier());
+    jest.spyOn(logger, 'info');
+    jest.spyOn(logger, 'debug');
+
+    await expect(dataFetcherLoopModule.runDataFetcher()).resolves.toBeDefined();
+
+    expect(callSignedApiSpy).toHaveBeenCalledTimes(1);
+    expect(callSignedApiSpy).toHaveBeenCalledWith(
+      'http://127.0.0.1:8090/0xC04575A2773Da9Cd23853A69694e02111b2c4182',
+      10_000
+    );
+    expect(callSignedApiSpy).not.toHaveBeenCalledWith('http://127.0.0.1:8091/0xContractProvidedAirnode', 10_000);
+
+    expect(logger.debug).toHaveBeenCalledWith(
+      'Signed API URLs.',
+      expect.objectContaining({
+        useSignedApiUrlsFromContract: false,
+      })
+    );
+
+    expect(logger.info).toHaveBeenCalledWith('Started data fetcher loop.', expect.objectContaining({ urlCount: 1 }));
+  });
+
+  it('respects useSignedApiUrlsFromContract flag when set to true', async () => {
+    updateState((draft) => {
+      draft.config.useSignedApiUrlsFromContract = true;
+      draft.signedApiUrlsFromContract = {
+        '31337': { hardhat: ['http://127.0.0.1:8091/0xContractProvidedAirnode'] },
+      };
+    });
+
+    const callSignedApiSpy = jest.spyOn(dataFetcherLoopModule, 'callSignedApi').mockResolvedValue(null);
+    jest.spyOn(signedDataStateModule, 'isSignedDataFresh').mockReturnValue(true);
+    jest.spyOn(signedDataStateModule, 'saveSignedData').mockResolvedValue(0);
+    jest.spyOn(signedDataStateModule, 'purgeOldSignedData').mockImplementation();
+    jest.spyOn(signedDataVerifierPoolModule, 'getVerifier').mockResolvedValue(createMockSignedDataVerifier());
+    jest.spyOn(logger, 'info');
+    jest.spyOn(logger, 'debug');
+
+    await expect(dataFetcherLoopModule.runDataFetcher()).resolves.toBeDefined();
+
+    expect(callSignedApiSpy).toHaveBeenCalledTimes(2);
+    expect(callSignedApiSpy).toHaveBeenCalledWith(
+      'http://127.0.0.1:8090/0xC04575A2773Da9Cd23853A69694e02111b2c4182',
+      10_000
+    );
+    expect(callSignedApiSpy).toHaveBeenCalledWith('http://127.0.0.1:8091/0xContractProvidedAirnode', 10_000);
+
+    expect(logger.debug).toHaveBeenCalledWith(
+      'Signed API URLs.',
+      expect.objectContaining({
+        useSignedApiUrlsFromContract: true,
+      })
+    );
+
+    expect(logger.info).toHaveBeenCalledWith('Started data fetcher loop.', expect.objectContaining({ urlCount: 2 }));
+  });
 });
 
 describe(dataFetcherLoopModule.callSignedApi.name, () => {
@@ -141,7 +212,7 @@ describe(dataFetcherLoopModule.callSignedApi.name, () => {
     await expect(dataFetcherLoopModule.callSignedApi('some-url', 10_000)).resolves.toBeNull();
 
     expect(logger.warn).toHaveBeenCalledTimes(1);
-    expect(logger.warn).toHaveBeenCalledWith('Failed to parse signed API response.', {
+    expect(logger.warn).toHaveBeenCalledWith('Failed to parse Signed API response.', {
       url: 'some-url',
       errors: JSON.stringify([
         {
diff --git a/src/data-fetcher-loop/data-fetcher-loop.ts b/src/data-fetcher-loop/data-fetcher-loop.ts
@@ -44,7 +44,7 @@ export const callSignedApi = async (url: string, timeout: number): Promise<Signe
   });
 
   if (!executionResult.success) {
-    logger.warn('Failed to fetch data from signed API.', {
+    logger.warn('Failed to fetch data from Signed API.', {
       url,
       ...executionResult.errorData,
       statusCode: executionResult.statusCode,
@@ -54,7 +54,7 @@ export const callSignedApi = async (url: string, timeout: number): Promise<Signe
 
   const parseResult = signedApiResponseSchema.safeParse(executionResult.data);
   if (!parseResult.success) {
-    logger.warn('Failed to parse signed API response.', {
+    logger.warn('Failed to parse Signed API response.', {
       url,
       errors: JSON.stringify(parseResult.error.errors).slice(0, 1000),
     });
@@ -68,7 +68,7 @@ export const runDataFetcher = async () => {
   return logger.runWithContext({ dataFetcherCoordinatorId: generateRandomId() }, async () => {
     const state = getState();
     const {
-      config: { signedDataFetchInterval },
+      config: { signedDataFetchInterval, useSignedApiUrlsFromContract },
       signedApiUrlsFromConfig,
       signedApiUrlsFromContract,
       activeDataFeedBeaconIds,
@@ -91,9 +91,16 @@ export const runDataFetcher = async () => {
     );
 
     // Better to log the non-decomposed object to see which URL comes from which chain-provider group.
-    logger.debug('Signed API URLs.', { signedApiUrlsFromConfig, signedApiUrlsFromContract });
+    logger.debug('Signed API URLs.', {
+      signedApiUrlsFromConfig,
+      signedApiUrlsFromContract,
+      useSignedApiUrlsFromContract,
+    });
     const urls = uniq(
-      [...Object.values(signedApiUrlsFromConfig), ...Object.values(signedApiUrlsFromContract)]
+      (useSignedApiUrlsFromContract
+        ? [...Object.values(signedApiUrlsFromConfig), ...Object.values(signedApiUrlsFromContract)]
+        : Object.values(signedApiUrlsFromConfig)
+      )
         .map((urlsPerProvider) => Object.values(urlsPerProvider))
         .flat(2) // eslint-disable-line unicorn/no-magic-array-flat-depth
     );
diff --git a/src/update-feeds-loops/pending-transaction-info.ts b/src/update-feeds-loops/pending-transaction-info.ts
@@ -85,7 +85,7 @@ export const updatePendingTransactionsInfo = (
     if (!updatableFeed && pendingTransactionInfo) {
       // NOTE: A data feed may stop needing an update for two reasons:
       //  1. It has been updated by some other transaction. This could have been done by this Airseeker or some backup.
-      //  2. As a natural price shift in signed API data.
+      //  2. As a natural price shift in Signed API data.
       //
       // We can't differentiate between these cases unless we check recent update transactions, which we don't want to
       // do.
diff --git a/src/update-feeds-loops/update-feeds-loops.ts b/src/update-feeds-loops/update-feeds-loops.ts
diff --git a/test/fixtures/mock-config.ts b/test/fixtures/mock-config.ts
