diff --git a/src/routes/apiRoutes.js b/src/routes/apiRoutes.js
index 5ab0517..0861498 100644
--- a/src/routes/apiRoutes.js
+++ b/src/routes/apiRoutes.js
@@ -3,8 +3,9 @@ const uuid = require("uuid");
 
 const SessionNpubbed = require('../models/SessionNpubbed');
 
-const appInviteService = require('../services/appInviteService')
-const invitedNpubService = require('../services/invitedNpubService')
+const appInviteService = require('../services/appInviteService');
+const invitedNpubService = require('../services/invitedNpubService');
+const sessionService = require('../services/sessionService');
 
 const router = express.Router();
 
@@ -25,16 +26,12 @@ router.post('/session-npubbed', async (req, res) => {
             console.log("Record already exists. No need to create a new one.");
             return res.json({ message: 'SessionNpubbed record already exists' });
         }
-
-
         console.log("No matching record found. Creating a new one...");
 
-        await SessionNpubbed.create({
-            session_npubbed_uuid: uuid.v7(),
-            session_uuid: sessionUuid,
-            npub,
-            created_at: new Date().toISOString()
-        });
+        await sessionService.relateSessionToNpub(
+            sessionUuid,
+            npub
+        );
 
         return res.json({ message: 'SessionNpubbed record created successfully' });
 
diff --git a/src/services/sessionService.js b/src/services/sessionService.js
index 8f280cc..2c23fa3 100644
--- a/src/services/sessionService.js
+++ b/src/services/sessionService.js
@@ -1,4 +1,7 @@
+const uuid = require("uuid");
+
 const Session = require('../models/Session');
+const SessionNpubbed = require('../models/SessionNpubbed');
 
 async function createSession(sessionUuid) {
     await Session.create({
@@ -7,5 +10,14 @@ async function createSession(sessionUuid) {
     });
 }
 
-exports.createSession = createSession;
+async function relateSessionToNpub(sessionUuid, npub) {
+    await SessionNpubbed.create({
+        session_npubbed_uuid: uuid.v7(),
+        session_uuid: sessionUuid,
+        npub,
+        created_at: new Date().toISOString()
+    });
+}
 
+exports.createSession = createSession;
+exports.relateSessionToNpub = relateSessionToNpub;