Migrate createRelationship calls to use currentUser global instead of session

Author: CarsonF

src/components/comments/comment-thread.repository.ts

@@ -6,6 +6,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   merge,
   paginate,
   sorting,
@@ -30,7 +31,7 @@ export class CommentThreadRepository extends DtoRepository(CommentThread) {
         .apply(
           createRelationships(CommentThread, {
             in: { commentThread: ['BaseNode', parent] },
-            out: { creator: ['User', session.userId] },
+            out: { creator: currentUser },
           }),
         )
         .return('node as thread');

src/components/comments/comment.repository.ts

@@ -8,6 +8,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   matchProps,
   merge,
   paginate,
@@ -50,7 +51,7 @@ export class CommentRepository extends DtoRepository(Comment) {
       .apply(
         createRelationships(Comment, {
           in: { comment: variable('thread') },
-          out: { creator: ['User', session.userId] },
+          out: { creator: currentUser },
         }),
       )
       .return<{ id: ID; threadId: ID }>([

src/components/file/file.repository.ts

@@ -27,6 +27,7 @@ import {
   createNode,
   createProperty,
   createRelationships,
+  currentUser,
   matchProps,
   merge,
   paginate,
@@ -379,7 +380,7 @@ export class FileRepository extends CommonRepository {
       .apply(await createNode(Directory, { initialProps }))
       .apply(
         createRelationships(Directory, 'out', {
-          createdBy: ['User', session.userId],
+          createdBy: currentUser,
           parent: ['Directory', parentId],
         }),
       )
@@ -417,7 +418,7 @@ export class FileRepository extends CommonRepository {
       .apply(
         createRelationships(Directory, {
           in: { [relation]: ['BaseNode', resource.id] },
-          out: { createdBy: ['User', session.userId] },
+          out: { createdBy: currentUser },
         }),
       )
       .return<{ id: ID }>('node.id as id');
@@ -458,7 +459,7 @@ export class FileRepository extends CommonRepository {
       .apply(
         createRelationships(File, {
           out: {
-            createdBy: ['User', session.userId],
+            createdBy: currentUser,
             parent: ['Directory', parentId],
           },
           in: {
@@ -501,7 +502,7 @@ export class FileRepository extends CommonRepository {
       )
       .apply(
         createRelationships(FileVersion, 'out', {
-          createdBy: ['User', session.userId],
+          createdBy: currentUser,
           parent: ['File', fileId],
         }),
       )

src/components/periodic-report/periodic-report.repository.ts

@@ -23,6 +23,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   defineSorters,
   deleteBaseNode,
   filter,
@@ -161,7 +162,7 @@ export class PeriodicReportRepository extends DtoRepository<
       .apply(
         createRelationships(File, {
           in: { reportFileNode: variable('report') },
-          out: { createdBy: ['User', input.session.userId] },
+          out: { createdBy: currentUser },
         }),
       )
       .return<{ id: ID; interval: Range<CalendarDate> }>(

src/components/post/post.repository.ts

@@ -8,6 +8,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   matchProps,
   merge,
   paginate,
@@ -37,7 +38,7 @@ export class PostRepository extends DtoRepository<typeof Post, [Session] | []>(
             post: ['BaseNode', input.parentId],
           },
           out: {
-            creator: ['User', session.userId],
+            creator: currentUser,
           },
         }),
       )

src/components/progress-report/media/progress-report-media.repository.ts

@@ -14,6 +14,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   deleteBaseNode,
   filter,
   matchProjectScopedRoles,
@@ -161,7 +162,7 @@ export class ProgressReportMediaRepository extends DtoRepository<
       )
       .apply(
         createRelationships(this.resource, 'out', {
-          creator: ['User', session.userId],
+          creator: currentUser,
         }),
       )
       .apply(

src/components/progress-report/workflow/progress-report-workflow.repository.ts

@@ -15,6 +15,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   merge,
   sorting,
 } from '~/core/database/query';
@@ -97,7 +98,7 @@ export class ProgressReportWorkflowRepository extends DtoRepository(
       .apply(
         createRelationships(WorkflowEvent, {
           in: { workflowEvent: ['ProgressReport', report] },
-          out: { who: ['User', session.userId] },
+          out: { who: currentUser },
         }),
       )
       .apply(this.hydrate())

src/components/project/workflow/project-workflow.neo4j.repository.ts

@@ -12,6 +12,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   INACTIVE,
   merge,
   sorting,
@@ -109,7 +110,7 @@ export class ProjectWorkflowNeo4jRepository
       .apply(
         createRelationships(WorkflowEvent, {
           in: { workflowEvent: ['Project', project] },
-          out: { who: ['Actor', session.userId] },
+          out: { who: currentUser },
         }),
       )
       .apply(this.hydrate())

src/components/prompts/prompt-variant-response.repository.ts

@@ -20,6 +20,7 @@ import {
   ACTIVE,
   createNode,
   createRelationships,
+  currentUser,
   defaultPermanentAfter,
   merge,
   paginate,
@@ -163,7 +164,7 @@ export const PromptVariantResponseRepository = <
               child: ['BaseNode', input.resource],
             },
             out: {
-              creator: ['User', session.userId],
+              creator: currentUser,
             },
           }),
         )
@@ -222,7 +223,7 @@ export const PromptVariantResponseRepository = <
                       child: variable('parent'),
                     },
                     out: {
-                      creator: ['User', session.userId],
+                      creator: currentUser,
                     },
                   }),
                 )