1 files changed, 86 insertions, 0 deletions
diff --git a/spec/test3_spec.lua b/spec/test3_spec.lua
new file mode 100644
index 0000000..e30a0ca
--- /dev/null
+++ b/spec/test3_spec.lua
@@ -0,0 +1,86 @@
+
+function rungame()
+	f = io.popen("bin\\client\\bin\\brokengine_client.exe spec/headless","r")
+	d = f:read("*all")
+	f:close()
+	return d
+end
+
+function runboth()
+	--print("Running both")
+	f1 = io.popen("bin\\server\\bin\\brokengine_server.exe spec/server","r")
+	f2 = io.popen("bin\\client\\bin\\brokengine_client.exe spec/headless","r")
+	--print("Both ran...")
+	d1 = f1:read("*all")
+	d2 = f2:read("*all")
+	--print("Both read all")
+	f1:close()
+	f2:close()
+	--print("returning")
+	return d1, d2
+end
+
+function writegame(...)
+	f = io.open("spec/headless/init.lua","w")
+	data = {"GAME.crashy()"}
+	for _,v in pairs({...}) do
+		data[#data + 1] = v
+	end
+	data[#data + 1] = "\nGAME.exit()\n"
+	f:write(table.concat(data,"\n"))
+	f:close()
+end
+
+function writeserver(...)
+	f = io.open("spec/server/init.lua","w")
+	data = {...}
+	data[#data + 1] = "\nGAME.exit()\n"
+	f:write(table.concat(data,"\n"))
+	f:close()
+end
+
+function assert_game_runs()
+	test.is_not_nil(rungame():find("\nGoodbye\n$"))
+end
+function assert_both_run()
+	local a,b = runboth()
+	assert.is_not_nil(a:find("\nGoodbye\n$"))
+	assert.is_not_nil(b:find("\nGoodbye\n$"))
+end
+describe("networking",function()
+	it("should communicate with PAIR sockets",function()
+		writeserver([[
+			local has_ponged = false
+			local socket  = net.newsocket(net.PAIR)
+			socket:bind("tcp://127.0.0.1:5555")
+			function socket:receive(stream)
+				print("Socket receive triggered")
+				has_ponged = true
+				local message = stream:readstring()
+				assert(message == "ping")
+				socket:send(function(stream2)
+					stream2:writestring("pong")
+				end)
+			end
+			function GAME.tick()
+				if has_ponged then
+					GAME.exit()
+				end
+			end
+		]])
+		--print("writing game...")
+		writegame([[
+			local socket = net.newsocket(net.PAIR)
+			socket:connect("tcp://127.0.0.1:5555")
+			function socket:receive(stream)
+				local message = stream:readstring()
+				assert(message == "pong")
+			end
+			socket:send(function(stream)
+				stream:writestring("ping")
+			end)
+		]])
+		--print("asserting both run...")
+		assert_both_run()
+	end)
+end)