app (user) networw create: reuse logic to reconnect connections

olivorocksrotated · Jun 3, 2023 · 2dec053 · 2dec053
1 parent bd28eb7
commit 2dec053
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/src/lib/network/connection/changeState.ts b/src/lib/network/connection/changeState.ts
@@ -9,7 +9,7 @@ import { createServerActionSuccessResponse } from '@/lib/errors/server';
 import { getServerSession } from '../../auth/session';
 import prisma from '../../prisma';
 
-async function changeConnectionState(connectionId: string, newActiveState: boolean) {
+export async function changeConnectionState(connectionId: string, newActiveState: boolean) {
     const { user } = await getServerSession();
     await prisma.networkConnection.update({
         where: {

diff --git a/src/lib/network/create.ts b/src/lib/network/create.ts
@@ -7,6 +7,7 @@ import { z } from 'zod';
 import { getServerSession } from '../auth/session';
 import { createServerActionErrorResponse, createServerActionSuccessResponse, unknownServerError } from '../errors/server';
 import prisma from '../prisma';
+import { changeConnectionState } from './connection/changeState';
 
 const errors: { [errorId: string]: { type: string, message: string } } = {
     NoConnectionWithYourself: { type: 'NoConnectionWithYourself', message: 'It is not possible to create a connection with yourself' },
@@ -43,10 +44,7 @@ export const createConnectionAction = zact(z.object({
             }
 
             if (existingConnection && !existingConnection.active) {
-                await prisma.networkConnection.update({
-                    where: { id: existingConnection.id },
-                    data: { active: true }
-                });
+                await changeConnectionState(existingConnection.id, true);
             } else {
                 await prisma.networkConnection.create({
                     data: { requesterId: user.id, acceptorId: acceptorUser.id }