fix(protocol): provideChannel (#354)

No-Trade-No-Life · Dec 11, 2023 · 0fdc28d · 0fdc28d
1 parent 1ee3db8
commit 0fdc28d
Show file tree

Hide file tree

Showing 4 changed files with 32 additions and 12 deletions.
diff --git a/apps/general-realtime-data-source/src/index.ts b/apps/general-realtime-data-source/src/index.ts
@@ -1,4 +1,4 @@
-import { encodePath } from '@yuants/data-model';
+import { encodePath, formatTime } from '@yuants/data-model';
 import { IPeriod, Terminal } from '@yuants/protocol';
 import Ajv from 'ajv';
 import { JSONSchema7 } from 'json-schema';
@@ -99,7 +99,7 @@ const subscribePeriods = (product_id: string, period_in_sec: number) => {
     mergeMap((mapProductIdToGSRList) => {
       const gsrList = mapProductIdToGSRList[product_id];
       if (!gsrList) {
-        console.error(new Date(), `Cannot find gsrList for ${product_id}`);
+        console.error(formatTime(Date.now()), `Cannot find gsrList for ${product_id}`);
         return EMPTY;
       }
       return of(gsrList);
@@ -108,7 +108,7 @@ const subscribePeriods = (product_id: string, period_in_sec: number) => {
       from(gsrList).pipe(
         map((gsr) =>
           term.consumeChannel<IPeriod[]>(
-            encodePath('Period', gsr.specific_datasource_id, product_id, period_in_sec),
+            encodePath('Period', gsr.specific_datasource_id, gsr.specific_product_id, period_in_sec),
           ),
         ),
         toArray(),
@@ -158,7 +158,7 @@ const subscribePeriods = (product_id: string, period_in_sec: number) => {
     }),
     tap((periods) => {
       console.info(
-        new Date(),
+        formatTime(Date.now()),
         `SubscribePeriods`,
         JSON.stringify({
           product_id,

diff --git a/common/changes/@yuants/app-general-realtime-data-source/2023-12-11-12-58.json b/common/changes/@yuants/app-general-realtime-data-source/2023-12-11-12-58.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@yuants/app-general-realtime-data-source",
+      "comment": "fix provideChannel",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@yuants/app-general-realtime-data-source"
+}
diff --git a/common/changes/@yuants/protocol/2023-12-11-12-58.json b/common/changes/@yuants/protocol/2023-12-11-12-58.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@yuants/protocol",
+      "comment": "fix provideChannel",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@yuants/protocol"
+}
diff --git a/libraries/protocol/src/terminal.ts b/libraries/protocol/src/terminal.ts
@@ -518,14 +518,14 @@ export class Terminal {
             from(terminalInfo.subscriptions?.[this.terminalInfo.terminal_id] ?? []).pipe(
               filter((channel_id) => validate(channel_id)),
               map((channel_id) => ({ consumer_terminal_id: terminalInfo.terminal_id, channel_id })),
-              groupBy((x) => x.channel_id),
-              mergeMap((group) =>
-                group.pipe(
-                  map((x) => x.consumer_terminal_id),
-                  toArray(),
-                  map((arr) => [group.key, arr] as [string, string[]]),
-                ),
-              ),
+            ),
+          ),
+          groupBy((x) => x.channel_id),
+          mergeMap((group) =>
+            group.pipe(
+              map((x) => x.consumer_terminal_id),
+              toArray(),
+              map((arr) => [group.key, arr] as [string, string[]]),
             ),
           ),
           toArray(),