support specify apikey for auth service request

packages/network-support/CHANGELOG.md

@@ -7,6 +7,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [1.1.0] 2024-03-15
+
 ## [1.0.0] 2024-03-07
 
 ## [0.2.0] 2024-01-12
@@ -19,7 +21,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - It's a internal library.
 
-[unreleased]: https://github.com/subquery/network-support/compare/v1.0.0...HEAD
+[unreleased]: https://github.com/subquery/network-support/compare/v1.1.0...HEAD
+[1.1.0]: https://github.com/subquery/network-support/releases/tag/v1.1.0
 [1.0.0]: https://github.com/subquery/network-support/releases/tag/v1.0.0
 [0.2.0]: https://github.com/subquery/network-support/releases/tag/v0.2.0
 [0.1.1]: https://github.com/subquery/network-support/releases/tag/v0.1.1

packages/network-support/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@subql/network-support",
-  "version": "1.0.2",
+  "version": "1.1.0",
   "main": "dist/index.js",
   "author": "SubQuery Pte Limited",
   "license": "Apache-2.0",

packages/network-support/src/orderManager.ts

@@ -28,6 +28,7 @@ export enum ResponseFormat {
 type Options = {
   logger: Logger;
   authUrl: string;
+  apikey?: string;
   fallbackServiceUrl?: string;
   projectId: string;
   projectType: ProjectType;
@@ -56,6 +57,7 @@ export class OrderManager {
   private scoreManager: ScoreManager;
 
   private authUrl: string;
+  private apikey?: string;
   private projectId: string;
   private interval = 300_000;
   private minScore = 0;
@@ -68,6 +70,7 @@ export class OrderManager {
   constructor(options: Options) {
     const {
       authUrl,
+      apikey,
       fallbackServiceUrl,
       projectId,
       logger,
@@ -78,6 +81,7 @@ export class OrderManager {
       timeout = 60000,
     } = options;
     this.authUrl = authUrl;
+    this.apikey = apikey;
     this.projectId = projectId;
     this.projectType = projectType;
     this.logger = logger;
@@ -133,7 +137,7 @@ export class OrderManager {
 
   private async refreshAgreements() {
     try {
-      const orders = await fetchOrders(this.authUrl, this.projectId, this.projectType);
+      const orders = await fetchOrders(this.authUrl, this.projectId, this.projectType, this.apikey);
       if (orders.agreements) {
         this._agreements = orders.agreements;
       }
@@ -199,6 +203,7 @@ export class OrderManager {
             const signedState = await POST<ChannelAuth>(tokenUrl.toString(), {
               deployment: this.projectId,
               channelId,
+              apikey: this.apikey,
             });
 
             this.logger?.debug(`request new state signature for runner ${runner} success`);
@@ -274,7 +279,10 @@ export class OrderManager {
   async syncChannelState(state: ChannelState): Promise<void> {
     try {
       const stateUrl = new URL('/channel/state', this.authUrl);
-      const res = await POST<{ consumerSign: string }>(stateUrl.toString(), state);
+      const res = await POST<{ consumerSign: string }>(stateUrl.toString(), {
+        ...state,
+        apikey: this.apikey,
+      });
 
       if (res.consumerSign) {
         this.logger?.debug(`syncChannelState succeed`);

packages/network-support/src/utils/query.ts

@@ -61,9 +61,17 @@ interface AgreementsResponse {
   plans: FlexPlanOrder[];
 }
 
-export async function fetchOrders(authUrl: string, projectId: string, projectType: ProjectType) {
+export async function fetchOrders(
+  authUrl: string,
+  projectId: string,
+  projectType: ProjectType,
+  apikey?: string
+) {
   try {
     const agreementsURL = new URL(`/orders/${projectType}/${projectId}`, authUrl);
+    if (apikey) {
+      agreementsURL.searchParams.append('apikey', apikey);
+    }
     return await GET<AgreementsResponse>(agreementsURL.toString());
   } catch {
     return { agreements: [], plans: [] };