Nuvion IQ

function generateSessionReference(entityId) {
  const timestamp = Date.now();
  return `${entityId}_${timestamp}`;
}

// Usage
const sessionRef = generateSessionReference(user.entity_id);

const MAX_MESSAGE_LENGTH = 240;

function validateMessage(message) {
  if (message.length > MAX_MESSAGE_LENGTH) {
    throw new Error(`Message too long. Maximum ${MAX_MESSAGE_LENGTH} characters.`);
  }
  return message.trim();
}

const IQSession = {
  current: null,
  
  async start(message, contextCode) {
    const response = await createSession({
      session_reference: generateSessionReference(user.entity_id),
      message,
      context_code: contextCode
    });
    this.current = response.data;
    return this.current;
  },
  
  async sendMessage(message) {
    if (!this.current) throw new Error('No active session');
    
    const response = await sendMessage({
      session_reference: this.current.session_reference,
      message
    });
    this.current = response.data;
    return this.current;
  },
  
  async refresh() {
    if (!this.current) throw new Error('No active session');
    
    const response = await getSession(this.current.session_reference);
    this.current = response.data;
    return this.current;
  },
  
  isReady() {
    return this.current?.status === 'ready' && 
           this.current?.context?.data?.ready === true;
  },
  
  isProcessing() {
    return this.current?.status === 'processing';
  },
  
  getPayload() {
    if (!this.isReady()) return null;
    return this.current.context.data;
  }
};

async function sendMessageWithPolling(message) {
  // Send message
  let session = await IQSession.sendMessage(message);
  
  // If still processing, poll for completion
  if (session.status === 'processing') {
    await new Promise(resolve => setTimeout(resolve, 1000));
    session = await IQSession.refresh();
  }
  
  return session;
}

async function executeReadyAction() {
  if (!IQSession.isReady()) return;
  
  const { endpoint, method, payload } = IQSession.getPayload();
  
  try {
    const response = await apiClient.request({
      method,
      url: endpoint,
      data: payload
    });
    
    // Optionally inform the AI of success
    await IQSession.sendMessage(
      `Great! The ${IQSession.current.context.data.context_code} action completed successfully.`
    );
    
    return response.data;
  } catch (error) {
    // Optionally inform the AI of failure
    await IQSession.sendMessage(
      `There was an issue: ${error.message}. Can we try again?`
    );
    throw error;
  }
}