This commit is contained in:
@@ -1,5 +1,37 @@
|
|||||||
import gleam/io
|
import gleam/io
|
||||||
|
import ipc
|
||||||
|
|
||||||
pub fn main() -> Nil {
|
pub fn main() -> Nil {
|
||||||
io.println("Hello from musicplayer!")
|
let socket_path = "/tmp/musicplayer.sock"
|
||||||
|
|
||||||
|
case ipc.connect(socket_path) {
|
||||||
|
Error(err) -> io.println("Failed to connect to socket: " <> err.reason)
|
||||||
|
Ok(socket) -> {
|
||||||
|
io.println("connected")
|
||||||
|
|
||||||
|
let messages = ["hello, \n", "world!\n"]
|
||||||
|
|
||||||
|
messages |> send_messages(socket, _)
|
||||||
|
|
||||||
|
io.println("closing")
|
||||||
|
ipc.close(socket)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn send_messages(socket: ipc.Socket, messages: List(String)) -> Nil {
|
||||||
|
case messages {
|
||||||
|
[] -> Nil
|
||||||
|
[message, ..rest] -> {
|
||||||
|
send_message(socket, message)
|
||||||
|
send_messages(socket, rest)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn send_message(socket: ipc.Socket, message: String) -> Nil {
|
||||||
|
case ipc.send(socket, message) {
|
||||||
|
Error(err) -> io.println("Failed to send message to socket: " <> err.reason)
|
||||||
|
Ok(_) -> io.println("Sent message to socket")
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user