More code coverage for notify.

Author: ioquatix

test/async/container/notify/.notify.rb renamed to fixtures/async/container/controllers/notify.rb

@@ -4,6 +4,7 @@
 # Copyright, 2020-2024, by Samuel Williams.
 
 require_relative "client"
+require "socket"
 
 module Async
 	module Container
@@ -31,6 +32,9 @@ def initialize(path)
 					@address = Addrinfo.unix(path, ::Socket::SOCK_DGRAM)
 				end
 
+				# @attribute [String] The path to the UNIX socket used for sending messages to the controller.
+				attr :path
+				
 				# Dump a message in the format requied by `sd_notify`.
 				# @parameter message [Hash] Keys and values should be string convertible objects. Values which are `true`/`false` are converted to `1`/`0` respectively.
 				def dump(message)
@@ -69,7 +73,7 @@ def send(**message)
 				def error!(text, **message)
 					message[:errno] ||= -1
 
-					send(status: text, **message)
+					super
 				end
 			end
 		end

lib/async/container/notify/socket.rb

@@ -51,6 +51,26 @@
 		end
 	end
 
+	with "#send" do
+		it "sends message" do
+			context = server.bind
+			
+			client.send(hello: "world")
+			
+			message = context.receive
+			
+			expect(message).to be == {hello: "world"}
+		end
+		
+		it "fails if the message is too big" do
+			context = server.bind
+			
+			expect do
+				client.send("x" * (subject::Socket::MAXIMUM_MESSAGE_SIZE+1))
+			end.to raise_exception(ArgumentError)
+		end
+	end
+	
 	with "#stopping!" do
 		it "sends stopping message" do
 			context = server.bind

test/async/container/notify.rb

@@ -5,9 +5,10 @@
 # Copyright, 2020, by Olle Jonsson.
 
 require "async/container/controller"
+require "async/container/controllers"
 
 describe Async::Container::Notify::Pipe do
-	let(:notify_script) {File.expand_path(".notify.rb", __dir__)}
+	let(:notify_script) {Async::Container::Controllers.path_for("notify")}
 
 	it "receives notification of child status" do
 		container = Async::Container.new

test/async/container/notify/pipe.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2020-2025, by Samuel Williams.
+# Copyright, 2020, by Olle Jonsson.
+
+require "async/container/notify/socket"
+
+describe Async::Container::Notify::Socket do
+	with ".open!" do
+		it "can open a socket" do
+			socket = subject.open!({subject::NOTIFY_SOCKET => "test"})
+			
+			expect(socket).to have_attributes(path: be == "test")
+		end
+	end
+end