test them consumers, boy
	
		
			
	
		
	
	
		
	
		
			All checks were successful
		
		
	
	
		
			
				
	
				continuous-integration/drone/push Build is passing
				
			
		
		
	
	
				
					
				
			
		
			All checks were successful
		
		
	
	continuous-integration/drone/push Build is passing
				
			This commit is contained in:
		
							
								
								
									
										14
									
								
								test.py
									
									
									
									
									
								
							
							
						
						
									
										14
									
								
								test.py
									
									
									
									
									
								
							@@ -58,7 +58,7 @@ def test_send_message(mocker):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_discoveravailableconsumers(httpserver):
 | 
					def test_discoveravailableconsumers(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -74,7 +74,7 @@ def test_discoveravailableconsumers(httpserver):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_isconsumeravailable(httpserver):
 | 
					def test_isconsumeravailable(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -102,7 +102,7 @@ def test_isconsumeravailable(httpserver):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_checkconsumer(httpserver):
 | 
					def test_checkconsumer(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -138,7 +138,7 @@ def test_setcurrentconsumer():
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_learnconsumerlist(httpserver):
 | 
					def test_learnconsumerlist(httpserver):
 | 
				
			||||||
    httpserver.expect_request(
 | 
					    httpserver.expect_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -166,7 +166,7 @@ def test_getcurrentconsumer(mocker):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_checkcurrentconsumer(httpserver):
 | 
					def test_checkcurrentconsumer(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -184,7 +184,7 @@ def test_checkcurrentconsumer(httpserver):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_updateconsumer(httpserver):
 | 
					def test_updateconsumer(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
@@ -203,7 +203,7 @@ def test_updateconsumer(httpserver):
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
def test_updateconsumerlist(httpserver):
 | 
					def test_updateconsumerlist(httpserver):
 | 
				
			||||||
    httpserver.expect_oneshot_request(
 | 
					    httpserver.expect_oneshot_request(
 | 
				
			||||||
        uri="/consumer",
 | 
					        uri="/consumers",
 | 
				
			||||||
        method='GET',
 | 
					        method='GET',
 | 
				
			||||||
        data="").respond_with_json(
 | 
					        data="").respond_with_json(
 | 
				
			||||||
        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
					        ["10.69.42.1", "10.10.10.10", "10.20.30.40"])
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user