alexrudall · September 25, 2025 02:25 · Tronerta · Jul 16, 2023 · Shaher-11 · Jul 20, 2023
diff --git a/#instructions.md b/#instructions.md
diff --git a/20230427131800_create_chats.rb b/20230427131800_create_chats.rb
 # db/migrate/20230427131800_create_chats.rb
 class CreateChats < ActiveRecord::Migration[7.0]
  def change
    create_table :chats do |t|
      t.belongs_to :user, null: false, foreign_key: true

      t.timestamps
    end
  end
 end
diff --git a/20230427131900_create_messages.rb b/20230427131900_create_messages.rb
 # db/migrate/20230427131900_create_messages.rb
 class CreateMessages < ActiveRecord::Migration[7.0]
  def change
    create_table :messages do |t|
      t.references :chat, null: false, foreign_key: true
      t.integer :role, null: false, default: 0
      t.string :content, null: false

      t.timestamps
    end
  end
 end
diff --git a/chat.rb b/chat.rb
 # app/models/chat.rb
 class Chat < ApplicationRecord
  belongs_to :user
  has_many :messages, dependent: :destroy
 end
diff --git a/chats_controller.rb b/chats_controller.rb
 # app/controllers/chats_controller.rb
 class ChatsController < ApplicationController
  before_action :authenticate_user!
  before_action :set_chat, only: %i[show]

  def show
    respond_with(@chat)
  end

  def create
    @chat = Chat.create(user: current_user)
    respond_with(@chat)
  end

  private

  def set_chat
    @chat = Chat.find(params[:id])
  end
 end
diff --git a/get_ai_response.rb b/get_ai_response.rb
 # app/jobs/get_ai_response.rb
 class GetAiResponse < SidekiqJob
  def perform(chat_id)
    chat = Chat.find(chat_id)
    call_openai(chat: chat)
  end

  private

  def call_openai(chat:)
    message = chat.messages.create(role: "assistant", content: "")
    message.broadcast_created

    OpenAI::Client.new.chat(
      parameters: {
        model: "gpt-3.5-turbo",
        messages: Message.for_openai(chat.messages),
        temperature: 0.1,
        stream: stream_proc(message: message)
      }
    )
  end

  def stream_proc(message:)
    proc do |chunk, _bytesize|
      new_content = chunk.dig("choices", 0, "delta", "content")
      message.update(content: message.content + new_content) if new_content
    end
  end
 end
diff --git a/message.rb b/message.rb
 # app/models/message.rb
 class Message < ApplicationRecord
  include ActionView::RecordIdentifier

  enum role: { system: 0, assistant: 10, user: 20 }

  belongs_to :chat

  after_create_commit -> { broadcast_created }
  after_update_commit -> { broadcast_updated }

  def broadcast_created
    broadcast_append_later_to(
      "#{dom_id(chat)}_messages",
      partial: "messages/message",
      locals: { message: self, scroll_to: true },
      target: "#{dom_id(chat)}_messages"
    )
  end

  def broadcast_updated
    broadcast_append_to(
      "#{dom_id(chat)}_messages",
      partial: "messages/message",
      locals: { message: self, scroll_to: true },
      target: "#{dom_id(chat)}_messages"
    )
  end

  def self.for_openai(messages)
    messages.map { |message| { role: message.role, content: message.content } }
  end
 end
diff --git a/messages_controller.rb b/messages_controller.rb
 # app/controllers/messages_controller.rb
 class MessagesController < ApplicationController
  include ActionView::RecordIdentifier

  before_action :authenticate_user!

  def create
    @message = Message.create(message_params.merge(chat_id: params[:chat_id], role: "user"))

    GetAiResponse.perform_async(@message.chat_id)

    respond_to do |format|
      format.turbo_stream
    end
  end

  private

  def message_params
    params.require(:message).permit(:content)
  end
 end
	# db/migrate/20230427131800_create_chats.rb
	class CreateChats < ActiveRecord::Migration[7.0]
	def change
	create_table :chats do \|t\|
	t.belongs_to :user, null: false, foreign_key: true

	t.timestamps
	end
	end
	end
	# db/migrate/20230427131900_create_messages.rb
	class CreateMessages < ActiveRecord::Migration[7.0]
	def change
	create_table :messages do \|t\|
	t.references :chat, null: false, foreign_key: true
	t.integer :role, null: false, default: 0
	t.string :content, null: false

	t.timestamps
	end
	end
	end
	# app/models/chat.rb
	class Chat < ApplicationRecord
	belongs_to :user
	has_many :messages, dependent: :destroy
	end
	# app/controllers/chats_controller.rb
	class ChatsController < ApplicationController
	before_action :authenticate_user!
	before_action :set_chat, only: %i[show]

	def show
	respond_with(@chat)
	end

	def create
	@chat = Chat.create(user: current_user)
	respond_with(@chat)
	end

	private

	def set_chat
	@chat = Chat.find(params[:id])
	end
	end
	# app/jobs/get_ai_response.rb
	class GetAiResponse < SidekiqJob
	def perform(chat_id)
	chat = Chat.find(chat_id)
	call_openai(chat: chat)
	end

	private

	def call_openai(chat:)
	message = chat.messages.create(role: "assistant", content: "")
	message.broadcast_created

	OpenAI::Client.new.chat(
	parameters: {
	model: "gpt-3.5-turbo",
	messages: Message.for_openai(chat.messages),
	temperature: 0.1,
	stream: stream_proc(message: message)
	}
	)
	end

	def stream_proc(message:)
	proc do \|chunk, _bytesize\|
	new_content = chunk.dig("choices", 0, "delta", "content")
	message.update(content: message.content + new_content) if new_content
	end
	end
	end
	# app/models/message.rb
	class Message < ApplicationRecord
	include ActionView::RecordIdentifier

	enum role: { system: 0, assistant: 10, user: 20 }

	belongs_to :chat

	after_create_commit -> { broadcast_created }
	after_update_commit -> { broadcast_updated }

	def broadcast_created
	broadcast_append_later_to(
	"#{dom_id(chat)}_messages",
	partial: "messages/message",
	locals: { message: self, scroll_to: true },
	target: "#{dom_id(chat)}_messages"
	)
	end

	def broadcast_updated
	broadcast_append_to(
	"#{dom_id(chat)}_messages",
	partial: "messages/message",
	locals: { message: self, scroll_to: true },
	target: "#{dom_id(chat)}_messages"
	)
	end

	def self.for_openai(messages)
	messages.map { \|message\| { role: message.role, content: message.content } }
	end
	end
	# app/controllers/messages_controller.rb
	class MessagesController < ApplicationController
	include ActionView::RecordIdentifier

	before_action :authenticate_user!

	def create
	@message = Message.create(message_params.merge(chat_id: params[:chat_id], role: "user"))

	GetAiResponse.perform_async(@message.chat_id)

	respond_to do \|format\|
	format.turbo_stream
	end
	end

	private

	def message_params
	params.require(:message).permit(:content)
	end
	end