Add IPC example.

Author: ioquatix

examples/ipc/client.rb

@@ -0,0 +1,60 @@
+#!/usr/bin/env async-service
+# frozen_string_literal: true
+
+# This file demonstrates running just the client component
+# Run with: async-service examples/ipc/client.rb
+# (Make sure server.rb is running first)
+
+require 'socket'
+
+# Shared environment for IPC configuration
+environment(:ipc) do
+	# IPC socket path - defaults to service.ipc in current directory
+	ipc_socket_path File.expand_path("service.ipc", Dir.pwd)
+end
+
+class IPCClient < Async::Service::Generic
+	def setup(container)
+		super
+		
+		container.run(count: 1, restart: true) do |instance|
+			socket_path = evaluator.ipc_socket_path
+			
+			Console.info(self) { "IPC Client starting - will connect to #{socket_path}" }
+			instance.ready!
+			
+			while true
+				begin
+					# Connect to server
+					client = UNIXSocket.new(socket_path)
+					Console.info(self) { "Connected to server" }
+					
+					# Read response
+					response = client.readline.chomp
+					puts "📨 Received: #{response}"
+					
+					client.close
+					Console.info(self) { "Connection closed" }
+					
+					# Wait before next connection
+					sleep(2)
+					
+				rescue Errno::ENOENT
+					Console.warn(self) { "Server socket not found at #{socket_path}, retrying..." }
+					sleep(3)
+				rescue Errno::ECONNREFUSED
+					Console.warn(self) { "Connection refused, server may not be ready" }
+					sleep(3)
+				rescue => error
+					Console.error(self, error)
+					sleep(2)
+				end
+			end
+		end
+	end
+end
+
+service "ipc-client" do
+	service_class IPCClient
+	environment :ipc
+end

examples/ipc/server.rb

@@ -0,0 +1,57 @@
+#!/usr/bin/env async-service
+# frozen_string_literal: true
+
+# This file demonstrates running just the server component
+# Run with: async-service examples/ipc/server.rb
+
+require 'socket'
+
+# Shared environment for IPC configuration
+environment(:ipc) do
+	# IPC socket path - defaults to service.ipc in current directory
+	ipc_socket_path File.expand_path("service.ipc", Dir.pwd)
+end
+
+class IPCServer < Async::Service::Generic
+	def setup(container)
+		super
+		
+		container.run(count: 1, restart: true) do |instance|
+			socket_path = evaluator.ipc_socket_path
+			
+			# Clean up any existing socket
+			File.unlink(socket_path) if File.exist?(socket_path)
+			
+			# Create Unix domain socket server
+			server = UNIXServer.new(socket_path)
+			
+			Console.info(self) { "IPC Server listening on #{socket_path}" }
+			instance.ready!
+			
+			begin
+				while true
+					# Accept incoming connections
+					client = server.accept
+					Console.info(self) { "Client connected from PID #{client.peereid[0]}" }
+					
+					# Send greeting with timestamp
+					timestamp = Time.now.strftime("%H:%M:%S")
+					client.write("Hello World at #{timestamp}\n")
+					client.close
+					
+					Console.info(self) { "Sent greeting and closed connection" }
+				end
+			rescue => error
+				Console.error(self, error)
+			ensure
+				server&.close
+				File.unlink(socket_path) if File.exist?(socket_path)
+			end
+		end
+	end
+end
+
+service "ipc-server" do
+	service_class IPCServer
+	environment :ipc
+end