Provide Neo4j currentUser "global" from SessionHost

Author: CarsonF

src/core/database/database.service.ts

@@ -17,6 +17,7 @@ import {
   type UnwrapSecured,
 } from '~/common';
 import { AbortError, retry, type RetryOptions } from '~/common/retry';
+import { SessionHost } from '../../components/authentication/session.host';
 import { ConfigService } from '../config/config.service';
 import { ILogger, Logger } from '../logger';
 import { ShutdownHook } from '../shutdown.hook';
@@ -63,6 +64,7 @@ export class DatabaseService {
   constructor(
     private readonly db: Connection,
     private readonly config: ConfigService,
+    private readonly sessionHost: SessionHost,
     private readonly shutdown$: ShutdownHook,
     @Logger('database:service') private readonly logger: ILogger,
   ) {}
@@ -122,6 +124,7 @@ export class DatabaseService {
     parameters?: Record<string, any>,
   ): Query<Result> {
     const q = this.db.query() as Query<Result>;
+    q.params.addParam(this.sessionHost.current$.value?.userId, 'currentUser');
     if (query) {
       q.raw(query, parameters);
     }

src/core/database/query/matching.ts

@@ -1,6 +1,12 @@
-import { node, type Query, relation } from 'cypher-query-builder';
+import {
+  node,
+  type NodePattern,
+  type Query,
+  relation,
+} from 'cypher-query-builder';
 import { uniq } from 'lodash';
 import { DateTime } from 'luxon';
+import { type Tagged } from 'type-fest';
 import {
   type ID,
   isIdLike,
@@ -13,11 +19,17 @@ import {
 import { variable } from '../query-augmentation/condition-variables';
 import { apoc, collect, listConcat, merge } from './cypher-functions';
 
-export const requestingUser = (session: Session | ID) => {
+export const currentUser = node('currentUser', 'User', {
+  id: variable('$currentUser'),
+}) as Tagged<NodePattern, 'CurrentUser'>;
+
+export const requestingUser = (session?: Session | ID) => {
   const n = node('requestingUser', 'User', {
-    id: variable('$requestingUser'),
+    id: variable(session ? '$requestingUser' : '$currentUser'),
   });
-  n.addParam(isIdLike(session) ? session : session.userId, 'requestingUser');
+  if (session) {
+    n.addParam(isIdLike(session) ? session : session.userId, 'requestingUser');
+  }
   return n;
 };