liebus

liebus

How to store "message history" & list of ChatRoom participants (using join/leave functions)?

Hi. I am learning Elixir recently, decided to make a small simple project “Chat Room” for myself to learn some OTP. Please help to implement “message history” (to store 100 messages for example) and list of chat room participants (using join/leave functions).

I do not understand clearly how I can send a message that is stored in the history of the last 100 messages and broadcast to chat members (I know I need to use pid but all other stuff is unclear)

I made some type of pseudocode for ‘Message’ & ‘Room’ modules (and I need ‘User’ module too as I understand) but I have a big troubles with structs - how and where to define them correctly and how integrate them into my existing code
Message:

%Message{from: "username", message: "hello world"}

Room:

%Room{
  users: [%User{name: "user1", pid: PID }],
  history: [%Message{from: "username", message: "hello world"} ... ],
  name: "room name"
}

And some pseudocode callback

  # def handle_call(:chat_history, {FromPid, _Ref}, %Room{history: history, users: users} = room) do
  #   users
  #   |> Enum.map(&(&1.pid))
  #   |> then(fn pids -> FromPid in pids end)
  #   |> case do
  #      true ->  {:reply, history, room}
  #      false -> {:reply, {:error, "not a chat member"}, room}
  # end

Thx for help, this is my code:
server.ex

Summary
defmodule Chat.Server do
  use GenServer

  #Client
  def start_link() do
    GenServer.start_link(__MODULE__, [])
  end

  def send_message(pid, message) do # send_message
    GenServer.cast(pid, message)
  end

  def get_messages(pid) do # get list of messages ref to pid
    GenServer.call(pid, :get_messages) # :get_messages - 1st arg of handle_call func
  end

  def remove_message(pid, message) do
    GenServer.cast(pid, {:remove, message}) # :remove will pattern match with callback
  end

  def stop(pid) do
    GenServer.stop(pid, :normal, :infinity) # pid, shutdown reason(:normal - default), timeout(:infinity - default)
  end
  
  def init(list) do
    {:ok, list}
  end

  def terminate(_reason, list) do
    IO.puts("All messages are done")
    IO.inspect(list)
    :ok
  end

  def handle_cast({:remove, message}, list) do # pm ':remove' with tuple in remove_message
    updated_list = Enum.reject(list, fn(i) -> i == message end)
    {:noreply, updated_list}
  end

  def handle_cast(message, list) do
    updated_list = [message|list]
    {:noreply, updated_list}
  end

  def handle_call(:get_messages, _from, list) do # testing (atom, 2 elem tuple - colors PID, existing state of message list)
    {:reply, list, list}
  end
end

Marked As Solved

RudManusachi

RudManusachi

Hi, @liebus!
May be you could try to think of the behavior of the application:
For example:

  • messages are stored in the Chat.Server
  • users can read them from there
  • users can join the Chat.Server and then they will get “notified” about new messages
  • users could store a number of unread messages associated with a chat

Then model the interface first.. (without implementation.. just as in TDD)

For example:
Say Chat.Server holds the list of users and the list of messages.

{:ok, chat} = Chat.Server.start_link()   # chat is a pid of Chat.Server

{:ok, alice} = User.new(name: "Alice") # alice and bob are pids of Users
{:ok, bob} = User.new(name: "Bob")

:ok = Chat.Server.join(chat, alice)
:ok = Chat.Server.join(chat, bob)

# check the list of users
users = Chat.Server.list_users(chat)

# assure that both Alice and Bob are there
alice in users == true
bob in users == true

# send a message from Alice
Chat.Server.send_message(chat, "Hi, there", from: alice)

# check that Bob got an unread message
%{chat => 1} = User.unread_messages(bob)

So Chat.Server’s initial state might look like %{users: [], messages: []}
Chat.Server.join/2 would update that state adding user to the list.
every Chat.Server.send_message/3 will add message to the list and also broadcast a “notification” to all users, except the user that message came from.

User is also represented as a process that holds a map with chats and the number of unread messages. So that when it receives a notification from a Chat.Server it increments it.

BTW, it would be good if you convert that example to ExUnit test case :wink: and keep adding your testing examples and just run mix test to make sure it all works as expected =)

In more realistic scenario when multiple users interact with single Chat.Server fetching the list of users and the list of messages - you would want to move those lists to the DB that provides with concurrent access and keep Chat.Server as an interface to that DB. I think that might be a good example to learn a little bit of :ets :slightly_smiling_face:

Where Next?

Popular in Questions Top

hariharasudhan94
lets say i have a sample like a = 20; b = 10; if (a > b) do {:ok, "a"} end if (a < b) do {:ok, b} end if (a == b) do {:ok, "equa...
New
albydarned
Hello all! I am typing this post from my new MacBook Pro with the M1 chip. I’m loving it so far, and will probably use it as my daily dr...
New
greenz1
I have a phoenix application from which a user can download multiple(5-6) files of size 1MB. I couldn’t find anything related to sending ...
New
ovidiubadita
Hey all, I discovered Elixir and I love it. I always wanted to learn a functional programming and I intended to go for Haskell, but afte...
New
Fl4m3Ph03n1x
About me? ( if you have nothing better to do than reading about some random guy in the internet :stuck_out_tongue: ) Hello all, this is ...
New
stefanluptak
Hello everybody, usually, I use a 29" ultra-wide monitor for VSCode which can easily accomodate explorer (files panel) + file with code ...
New
LegitStack
I’m trying to make a websocket server in Phoenix or raw Elixir. I heard about gun, I think I could use cowboy, but since I’m not that sma...
New
dblack
I’ve got an issue with an app and I’ve no idea of how to troubleshoot it. I’m hoping someone here might have seen something similar. I p...
New
rms.mrcs
Hi, I need to transform a list of numbers into a map where the keys are the indexes and the values are the original values of the list. ...
New
romenigld
I am trying to run a deploy with docker and I successfully runned with this command: docker build -t romenigld/blog-prod . but when I t...
New

Other popular topics Top

hariharasudhan94
lets say i have a sample like a = 20; b = 10; if (a > b) do {:ok, "a"} end if (a < b) do {:ok, b} end if (a == b) do {:ok, "equa...
New
lastday4you
I wanted to check elixir version in phoenix because i found that my elixir is 1.5 but when i use Enum.chunk_by it said the function is un...
New
TunkShif
This post is an instruction guide to help you setup your Neovim for Elixir development from scratch. It includes general information on h...
274 41989 114
New
Nvim
Anybody knows a comprehensive comparison of Django and Phoenix, thanks for the help. Where are they similar? Where do they differ the m...
New
Patoshizzle
After calling mix ecto.create I get this error: 17:00:32.162 [error] GenServer #PID<0.412.0> terminating ** (Postgrex.Error) FATAL...
New
jononomo
I am trying to figure out how Mix knows whether the environment is test, dev, or prod – where is this set? Thanks.
New
AngeloChecked
What learn first? Rust or Elixir Hi Elixir community! I’m here because i want learn a new language. I’m a junior developer and mainly i ...
New
jay1
Why is it that the mnesia database isn’t the most preferred database for use in Elixir/Phoenix?
New
sergio_101
I am VERY much an elixir newbie. I have taken one elixir course and one phoenix course on Udemy. During that course, I saw the instructor...
New
nobody
Hi! In PHP: $_SERVER[‘SERVER_ADDR’] - in Elixir? Searched the docs for ip address and the web, no good results. Thanks!
New

We're in Beta

About us Mission Statement