Add AIassistant module

backend/core-api/src/modules/AIassistant/db/definitions/generalSettings.ts

@@ -0,0 +1,31 @@
+import { Document, Model } from 'mongoose';
+
+
+export interface IGeneralSettings {
+ assistantName: string;
+ conversationStarter: string;
+ description: string;
+ promptSuggestions: string[];
+ updatedAt?: Date;
+}
+
+
+export interface IGeneralSettingsDocument extends IGeneralSettings, Document {
+ _id: string;
+ createdAt: Date;
+ updatedAt: Date;
+}
+
+
+export interface IGeneralSettingsModel extends Model<IGeneralSettingsDocument> {
+ getSettings(): Promise<IGeneralSettingsDocument | null>;
+ updateSettings(doc: Partial<IGeneralSettings>): Promise<IGeneralSettingsDocument>;
+}
+
+
+export const generalSettingsFields = {
+ assistantName: { type: String, default: '' },
+ conversationStarter: { type: String, default: '' },
+ description: { type: String, default: '' },
+ promptSuggestions: { type: [String], default: [] },
+};

backend/core-api/src/modules/AIassistant/db/definitions/ragInteractions.ts

@@ -0,0 +1,34 @@
+import { Document } from 'mongoose';
+
+export interface IRagInteraction {
+  question: string;
+  answer: string;
+  sourceDocuments?: string[];
+  userId: string;
+  orgId: string;
+  createdAt: Date;
+  modelUsed?: string;
+  responseTime?: number;
+  tokensUsed?: number;
+  confidenceScore?: number;
+  status: 'success' | 'error' | 'pending';
+  errorMessage?: string;
+}
+
+export interface IRagInteractionDocument extends IRagInteraction, Document {}
+
+// Export the fields as a string
+export const ragInteractionFields = `
+  question: String
+  answer: String
+  sourceDocuments: [String]
+  userId: String
+  orgId: String
+  createdAt: Date
+  modelUsed: String
+  responseTime: Float
+  tokensUsed: Float
+  confidenceScore: Float
+  status: String
+  errorMessage: String
+`;

backend/core-api/src/modules/AIassistant/db/definitions/systemPrompt.ts

@@ -0,0 +1,21 @@
+import { Document, Model } from "mongoose";
+
+export interface ISystemPrompt {
+  prompt: string; // Remove orgId
+  updatedAt?: Date;
+}
+
+export interface ISystemPromptDocument extends ISystemPrompt, Document {
+  _id: string;
+  createdAt: Date;
+  updatedAt: Date;
+}
+
+export interface ISystemPromptModel extends Model<ISystemPromptDocument> {
+  getPrompt(): Promise<ISystemPromptDocument | null>; // Remove orgId parameter
+  updatePrompt(prompt: string): Promise<ISystemPromptDocument>; // Remove orgId parameter
+}
+
+export const systemPromptFields = {
+  prompt: { type: String, default: "" } // Remove orgId field
+};

backend/core-api/src/modules/AIassistant/db/models/GeneralSettings.ts

@@ -0,0 +1,22 @@
+import { Schema, model, Model } from "mongoose";
+import {
+ IGeneralSettingsDocument,
+ IGeneralSettingsModel,
+ generalSettingsFields,
+} from "../definitions/generalSettings";
+
+
+export const GeneralSettingsSchema = new Schema<IGeneralSettingsDocument>(
+ generalSettingsFields,
+ {
+   timestamps: true,
+   collection: 'general_settings'
+ }
+);
+
+
+// Create the model with proper typing
+export const GeneralSettingsModel = model<IGeneralSettingsDocument, IGeneralSettingsModel>(
+ "general_settings",
+ GeneralSettingsSchema
+)

backend/core-api/src/modules/AIassistant/db/models/RagInteractions.ts

@@ -0,0 +1,67 @@
+// backend/core-api/src/modules/AIassistant/db/models/RagInteractions.ts
+import { Schema, model, models, Document, Model } from 'mongoose';
+import { field, stringField, numberField, dateField } from '../../utils/schemaField';
+import { IRagInteraction } from '../definitions/ragInteractions';
+
+export interface IRagInteractionDocument extends IRagInteraction, Document {}
+
+export interface IRagInteractionModel extends Model<IRagInteractionDocument> {
+  getRagInteraction(_id: string): Promise<IRagInteractionDocument>;
+}
+
+export const ragInteractionSchema = new Schema({
+  question: stringField({ label: 'Question' }),
+  answer: stringField({ label: 'Answer' }),
+  sourceDocuments: field({
+    type: [String],
+    label: 'Source Documents',
+    optional: true
+  }),
+  userId: stringField({ label: 'User ID' }),
+  orgId: stringField({ label: 'Organization ID' }),
+  createdAt: dateField({
+    default: Date.now,
+    label: 'Created at',
+    immutable: true
+  }),
+  modelUsed: stringField({
+    label: 'Model Used',
+    optional: true
+  }),
+  responseTime: numberField({
+    label: 'Response Time (ms)',
+    optional: true,
+    min: 0
+  }),
+  tokensUsed: numberField({
+    label: 'Tokens Used',
+    optional: true,
+    min: 0
+  }),
+  confidenceScore: numberField({
+    label: 'Confidence Score',
+    optional: true,
+    min: 0,
+    max: 1
+  }),
+  status: stringField({
+    label: 'Status',
+    enum: ['success', 'error', 'pending'],
+    default: 'success'
+  }),
+  errorMessage: stringField({
+    label: 'Error Message',
+    optional: true
+  })
+}, {
+  timestamps: true,
+  collection: 'rag_interactions'
+});
+
+// Add indexes for better query performance
+ragInteractionSchema.index({ userId: 1, createdAt: -1 });
+ragInteractionSchema.index({ orgId: 1 });
+ragInteractionSchema.index({ status: 1 });
+
+export const RagInteractions = models.RagInteractions ||
+  model<IRagInteractionDocument, IRagInteractionModel>('rag_interactions', ragInteractionSchema);

backend/core-api/src/modules/AIassistant/db/models/SystemPrompt.ts

@@ -0,0 +1,39 @@
+import { Schema, model, Model } from "mongoose";
+import {
+  ISystemPromptDocument,
+  ISystemPromptModel,
+  systemPromptFields,
+} from "../definitions/systemPrompt";
+
+export const SystemPromptSchema = new Schema<ISystemPromptDocument>(
+  systemPromptFields,
+  {
+    timestamps: true,
+    collection: 'system_prompts'
+  }
+);
+
+SystemPromptSchema.statics.getPrompt = function () {
+  return this.findOne().exec();
+};
+
+SystemPromptSchema.statics.updatePrompt = async function (prompt: string) {
+  const updated = await this.findOneAndUpdate(
+    {},
+    { 
+      prompt, 
+      updatedAt: new Date() 
+    },
+    { 
+      new: true, 
+      upsert: true
+    }
+  ).exec();
+
+  return updated;
+};
+
+export const SystemPromptModel = model<ISystemPromptDocument, ISystemPromptModel>(
+  "system_prompt",
+  SystemPromptSchema
+);

backend/core-api/src/modules/AIassistant/db/models/loadGeneralSettingsClass.ts

@@ -0,0 +1,23 @@
+import { IModels } from '~/connectionResolvers';
+import { GeneralSettingsModel } from './GeneralSettings';
+import { IGeneralSettingsDocument, IGeneralSettingsModel } from '../definitions/generalSettings';
+
+
+export const loadGeneralSettingsClass = (models: IModels) => {
+ class GeneralSettings {
+   // Example static method
+   public static async getSettings(): Promise<IGeneralSettingsDocument | null> {
+     return models.GeneralSettings.findOne({});
+   }
+
+
+   // You can add more static methods here
+ }
+
+
+ // Attach class methods to the existing model's schema
+ GeneralSettingsModel.schema.loadClass(GeneralSettings);
+
+
+ return GeneralSettingsModel;
+};

backend/core-api/src/modules/AIassistant/db/models/loadInteractionClass.ts

@@ -0,0 +1,20 @@
+import { IModels } from '~/connectionResolvers';
+import { ragInteractionSchema } from './RagInteractions';
+import { IRagInteractionDocument, IRagInteraction } from '../definitions/ragInteractions';
+
+export const loadRagInteractionClass = (models: IModels) => {
+  class RagInteraction {
+    public static async getRagInteraction(_id: string) {
+      const ragInteraction = await models.RagInteractions.findOne({ _id });
+
+      if (!ragInteraction) {
+        throw new Error('RagInteraction not found');
+      }
+
+      return ragInteraction;
+    }
+  }
+
+  ragInteractionSchema.loadClass(RagInteraction);
+  return ragInteractionSchema;
+};

backend/core-api/src/modules/AIassistant/docker-compose.dev.yml

@@ -0,0 +1,17 @@
+version: '3.8'
+
+services:
+  rag-service:
+    build: ./rag-service
+    ports:
+      - "8000:8000"
+    env_file:
+      - ./rag-service/.env
+    volumes:
+      - ./rag-service/src:/app/src
+    restart: unless-stopped
+    environment:
+      - OPENAI_API_KEY=${OPENAI_API_KEY}
+      - EMBEDDING_MODEL=${EMBEDDING_MODEL}
+      - LLM_MODEL=${LLM_MODEL}
+      - ALLOWED_ORIGINS=http://localhost:3000,http://localhost:3001

backend/core-api/src/modules/AIassistant/general.ts

@@ -0,0 +1,37 @@
+import { Router, Request, Response } from "express";
+const router: Router = Router();
+
+// in-memory store
+let generalSettings = {
+  assistantName: "Sparkles AI",
+  conversationStarter: "How can I help you today?",
+  description:
+    "Get quick answers and insights about your customers and sales pipeline.",
+  promptSuggestions: [
+    "Summarize the last 10 conversations from Team Inbox",
+    "List all open leads assigned to me",
+    "Answer customer FAQs quickly",
+  ],
+};
+
+// ✅ GET route (fixed)
+router.get("/ai-assistant/general/:orgId", (req: Request, res: Response) => {
+  res.json(generalSettings);
+});
+
+// ✅ POST route (already in your file, just make sure it updates generalSettings)
+router.post("/ai-assistant/general/:orgId", (req: Request, res: Response) => {
+  const { assistantName, conversationStarter, description, promptSuggestions } =
+    req.body;
+
+  generalSettings = {
+    assistantName,
+    conversationStarter,
+    description,
+    promptSuggestions,
+  };
+
+  res.json({ success: true, settings: generalSettings });
+});
+
+export default router;

backend/core-api/src/modules/AIassistant/graphql/generalSchema.ts

@@ -0,0 +1,27 @@
+import { generalSettingsFields } from "../db/definitions/generalSettings";
+
+export const generaltypes = () => [
+`
+type GeneralSettings {
+  _id: String!
+  ${generalSettingsFields}
+  updatedAt: String
+}
+
+input GeneralSettingsInput {
+  assistantName: String
+  conversationStarter: String
+  description: String
+  promptSuggestions: [String]
+}
+
+extend type Query {
+  getGeneralSettings: GeneralSettings
+}
+
+
+extend type Mutation {
+  updateGeneralSettings(input: GeneralSettingsInput!): GeneralSettings
+}
+`
+];

backend/core-api/src/modules/AIassistant/graphql/resolvers/generalMutations.ts

@@ -0,0 +1,38 @@
+import { IGeneralSettingsDocument } from "../../db/definitions/generalSettings";
+import { GeneralSettingsModel } from "../../db/models/GeneralSettings";
+
+
+
+
+export interface GeneralSettingsMutationResolvers {
+updateGeneralSettings: (
+  _parent: any,
+  args: { input: Partial<IGeneralSettingsDocument> }
+) => Promise<IGeneralSettingsDocument>;
+}
+
+
+
+
+export const generalMutations: GeneralSettingsMutationResolvers = {
+updateGeneralSettings: async (
+  _parent: any,
+  { input }: { input: Partial<IGeneralSettingsDocument> }
+): Promise<IGeneralSettingsDocument> => {
+  const existingSettings = await GeneralSettingsModel.findOne().exec();
+
+
+
+
+  if (existingSettings) {
+    Object.assign(existingSettings, input, { updatedAt: new Date() });
+    return await existingSettings.save();
+  } else {
+    const newSettings = new GeneralSettingsModel({
+      ...input,
+      updatedAt: new Date(),
+    });
+    return await newSettings.save();
+  }
+},
+};