0.0.535

deep-foundation · Sep 17, 2024 · e937a28 · e937a28
1 parent b74db8c
commit e937a28
Show file tree

Hide file tree

Showing 4 changed files with 1,468 additions and 124 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -130,6 +130,8 @@ services:
     extra_hosts: ['host.docker.internal:host-gateway']
     environment:
       - 'NEXT_PUBLIC_GRAPHQL_URL=${NEXT_PUBLIC_GQL_PATH}'
+      - 'SECRET=${DEEPLINKS_HASURA_SECRET}'
+      - 'DEEPLINKS=${DOCKER_DEEPLINKS_URL}'
     logging:
       driver: "json-file"
       options:

diff --git a/imports/client.tsx b/imports/client.tsx
@@ -539,7 +539,7 @@ export interface DeepClientInstance<L extends Link<Id> = Link<Id>> {
 
   one(exp: Exp<'links'> | Id): Promise<L>;
   select<TTable extends 'links'|'numbers'|'strings'|'objects'|'can'|'selectors'|'tree'|'handlers', LL = L>(exp: Exp<TTable>, options?: ReadOptions<TTable>): Promise<DeepClientResult<LL[] | number>>;
-  subscribe<TTable extends 'links'|'numbers'|'strings'|'objects'|'can'|'selectors'|'tree'|'handlers', LL = L>(exp: Exp<TTable>, options?: ReadOptions<TTable>): Observable<LL[] | number>;
+  subscribe<TTable extends 'links'|'numbers'|'strings'|'objects'|'can'|'selectors'|'tree'|'handlers', LL = L>(exp: Exp<TTable>, options?: ReadOptions<TTable>): Observable<DeepClientResult<LL[] | number>>;
 
   insert<TTable extends 'links'|'numbers'|'strings'|'objects', LL = L>(objects: InsertObjects<TTable> , options?: WriteOptions<TTable>):Promise<DeepClientResult<{ id }[]>>;
 
@@ -1255,7 +1255,7 @@ export class DeepClient<L extends Link<Id> = Link<Id>> implements DeepClientInst
    * deep.subscribe({ up: { link_id: deep.linkId } }).subscribe({ next: (links) => {}, error: (err) => {} });
    * ```
    */
-  subscribe<TTable extends 'links'|'numbers'|'strings'|'objects'|'can'|'selectors'|'tree'|'handlers', LL = L>(exp: Exp<TTable>, options?: ReadOptions<TTable>): Observable<LL[]> {
+  subscribe<TTable extends 'links'|'numbers'|'strings'|'objects'|'can'|'selectors'|'tree'|'handlers', LL = L>(exp: Exp<TTable>, options?: ReadOptions<TTable>): Observable<DeepClientResult<LL[] | number>> {
     if (!exp) return new Observable((observer) => observer.error('!exp'));
     const aggregate = options?.aggregate;
     const queryData = this._generateQuery(exp, { ...options, subscription: true });