technocloud-public/nginx-unit
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Tests: added tests for Ruby stream IO.close().

Browse Source
This commit is contained in:
Andrei Zeliankou
2022-05-13 15:43:57 +01:00
parent 5883a2670f
commit de0a0beb83
3 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/ruby/errors_write/config.ru
View File

@@ -1,5 +1,7 @@
app = Proc.new do |env| app = Proc.new do |env|
env['rack.errors'].write('Error in application') env['rack.errors'].write('Error in application')
env['rack.errors'].flush
env['rack.errors'].close
['200', {'Content-Length' => '0'}, ['']] ['200', {'Content-Length' => '0'}, ['']]
end end

1
test/ruby/input_gets/config.ru
View File

@@ -1,5 +1,6 @@
app = Proc.new do |env| app = Proc.new do |env|
body = env['rack.input'].gets body = env['rack.input'].gets
env['rack.input'].close
['200', { ['200', {
'Content-Length' => body.length.to_s 'Content-Length' => body.length.to_s
}, [body]] }, [body]]

12
test/test_ruby_application.py
View File

@@ -173,7 +173,7 @@ class TestRubyApplication(TestApplicationRuby):
def test_ruby_application_errors_puts(self): def test_ruby_application_errors_puts(self):
self.load('errors_puts') self.load('errors_puts')
self.get() assert self.get()['status'] == 200
assert ( assert (
self.wait_for_record(r'\[error\].+Error in application') is not None self.wait_for_record(r'\[error\].+Error in application') is not None
@@ -182,7 +182,7 @@ class TestRubyApplication(TestApplicationRuby):
def test_ruby_application_errors_puts_int(self): def test_ruby_application_errors_puts_int(self):
self.load('errors_puts_int') self.load('errors_puts_int')
self.get() assert self.get()['status'] == 200
assert ( assert (
self.wait_for_record(r'\[error\].+1234567890') is not None self.wait_for_record(r'\[error\].+1234567890') is not None
@@ -191,8 +191,7 @@ class TestRubyApplication(TestApplicationRuby):
def test_ruby_application_errors_write(self): def test_ruby_application_errors_write(self):
self.load('errors_write') self.load('errors_write')
self.get() assert self.get()['status'] == 200
assert ( assert (
self.wait_for_record(r'\[error\].+Error in application') is not None self.wait_for_record(r'\[error\].+Error in application') is not None
), 'errors write' ), 'errors write'
@@ -205,8 +204,7 @@ class TestRubyApplication(TestApplicationRuby):
def test_ruby_application_errors_write_int(self): def test_ruby_application_errors_write_int(self):
self.load('errors_write_int') self.load('errors_write_int')
self.get() assert self.get()['status'] == 200
assert ( assert (
self.wait_for_record(r'\[error\].+1234567890') is not None self.wait_for_record(r'\[error\].+1234567890') is not None
), 'errors write int' ), 'errors write int'
@@ -214,7 +212,7 @@ class TestRubyApplication(TestApplicationRuby):
def test_ruby_application_at_exit(self): def test_ruby_application_at_exit(self):
self.load('at_exit') self.load('at_exit')
self.get() assert self.get()['status'] == 200
assert 'success' in self.conf({"listeners": {}, "applications": {}}) assert 'success' in self.conf({"listeners": {}, "applications": {}})