From 2dec0538e4cad32b7142365e4d03df44349535e3 Mon Sep 17 00:00:00 2001
From: Nicolas Baglivo <nicolas.baglivo@gmail.com>
Date: Sat, 3 Jun 2023 12:08:53 +0200
Subject: [PATCH] app (user) networw create: reuse logic to reconnect
 connections

---
 src/lib/network/connection/changeState.ts | 2 +-
 src/lib/network/create.ts                 | 6 ++----
 2 files changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/lib/network/connection/changeState.ts b/src/lib/network/connection/changeState.ts
index 5a833f6e..ae829fc9 100644
--- 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
index 784ea759..24a32626 100644
--- 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 }