describe "ResourceService", -> describe "start stop", -> it 'should work', -> resource = new Resource("testResource", '/v1/test_resource') resource_service = new ResourceService('testResource', [resource]) resource_service.start() .then(-> resource_service.stop() ) describe "show", -> it 'should work', -> resource_name = random_resource() resource_path = "/v1/#{resource_name}" resource = new Resource(resource_name, resource_path) resource.show = (payload) -> return { body: {"hello": "world"} } resource.show.public = true service_name = random_service() resource_service = new ResourceService(service_name, [resource]) service = new ResourceService('testService') bb.all([service.start(), resource_service.start()]) .then( -> service.send_request_to_service(service_name, {verb: "GET", path: resource_path}) ) .then( (body) -> expect(body.body.hello).to.equal "world" expect(body.status_code).to.equal 200 ) .then( -> service.send_request_to_resource({verb: "GET", path: resource_path}) ) .then( (body) -> expect(body.body.hello).to.equal "world" expect(body.status_code).to.equal 200 ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) it 'should route to the right resource', -> resource1_name = random_resource() resource1_path = "/v1/#{resource1_name}" resource1 = new Resource(resource1_name, resource1_path) resource1.show = (payload) -> return { body: {"iam": "resource1"} } resource1.show.public = true resource2_name = random_resource() resource2_path = "/v1/#{resource2_name}" resource2 = new Resource(resource2_name, resource2_path) resource2.show = (payload) -> return { body: {"iam": "resource2"} } resource2.show.public = true service_name = random_service() resource_service = new ResourceService(service_name, [resource1, resource2]) service = new ResourceService('testService') bb.all([service.start(), resource_service.start()]) .then( -> req1 = service.send_request_to_resource({verb: "GET", path: resource1_path}) req2 = service.send_request_to_resource({verb: "GET", path: resource2_path}) req3 = service.send_request_to_resource({verb: "GET", path: "#{resource1_path}/"}) req4 = service.send_request_to_resource({verb: "GET", path: "#{resource1_path}/identifier"}) req5 = service.send_request_to_resource({verb: "GET", path: "#{resource1_path}/identifier/ksecond"}) bb.all([req1, req2, req3, req4, req5]) ) .then((resps) -> [resp1, resp2, resp3, resp4, resp5 ] = resps expect(resp1.body.iam).to.equal "resource1" expect(resp1.status_code).to.equal 200 expect(resp2.body.iam).to.equal "resource2" expect(resp2.status_code).to.equal 200 expect(resp3.body.iam).to.equal "resource1" expect(resp3.status_code).to.equal 200 expect(resp4.body.iam).to.equal "resource1" expect(resp4.status_code).to.equal 200 expect(resp5.body.iam).to.equal "resource1" expect(resp5.status_code).to.equal 200 ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) it 'should route to the resources at different levels', -> resource1_name = random_resource() resource1_path = "/#{resource1_name}" resource1 = new Resource(resource1_name, resource1_path) resource1.show = (payload) -> return { body: {"iam": "level_1"} } resource1.show.public = true resource2_path = "/v1/#{resource1_name}" resource2 = new Resource(random_resource(), resource2_path) resource2.show = (payload) -> return { body: {"iam": "level_2"} } resource2.show.public = true service_name = random_service() resource_service = new ResourceService(service_name, [resource1, resource2]) service = new ResourceService('testService') bb.all([service.start(), resource_service.start()]) .then( -> req1 = service.send_request_to_resource({verb: "GET", path: resource1_path}) req2 = service.send_request_to_resource({verb: "GET", path: resource2_path}) bb.all([req1, req2]) ) .then((resps) -> [resp1, resp2 ] = resps expect(resp1.body.iam).to.equal "level_1" expect(resp1.status_code).to.equal 200 expect(resp2.body.iam).to.equal "level_2" expect(resp2.status_code).to.equal 200 ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) it 'should throw error if sending to resource that is not there', -> resource1_name = random_resource() resource1_path = "/v1/#{resource1_name}" resource1 = new Resource(resource1_name, resource1_path) resource1.show = (payload) -> return { body: {"iam": "resource1"} } resource1.show.public = true service_name = random_service() resource_service = new ResourceService(service_name, [resource1]) service = new ResourceService('testService') bb.all([service.start(), resource_service.start()]) .then( -> badreq1 = service.send_request_to_resource({verb: "GET", path: "#{resource1_name}"}) .then( -> throw "SHOULD NOT GET HERE" ) .catch(ResourceService.MessageNotDeliveredError, (err) -> ) badreq2 = service.send_request_to_resource({verb: "GET", path: "/v2/#{resource1_name}"}) .then( -> throw "SHOULD NOT GET HERE" ) .catch(ResourceService.MessageNotDeliveredError, (err) -> ) badreq3 = service.send_request_to_resource({verb: "GET", path: "/prefix#{resource1_path}"}) .then( -> throw "SHOULD NOT GET HERE" ) .catch(ResourceService.MessageNotDeliveredError, (err) -> ) badreq4 = service.send_request_to_resource({verb: "GET", path: "/v1/"}) .then( -> throw "SHOULD NOT GET HERE" ) .catch(ResourceService.MessageNotDeliveredError, (err) -> ) bb.all([badreq1, badreq2, badreq3, badreq4]) ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) it 'should authenticate for a resource name', -> resource1_name = random_resource() resource1_path = "/v1/#{resource1_name}" resource1 = new Resource(resource1_name, resource1_path) resource1.show = (payload) -> return { body: {"iam": "resource1"} } service_name = random_service() resource_service = new ResourceService(service_name, [resource1]) service = new ResourceService('testService') bb.all([service.start(), resource_service.start()]) .then( -> set_session = resource_service.session_client.set_session('goodsession', { caller_id: 'goodcaller' caller_version: 1 permissions: resources: {"#{resource1_name}": {'show': 'allow'}} }) set_caller = resource_service.session_client.set_caller('goodcaller', { version: 1 }) bb.all([set_session, set_caller]) ) .then( -> unatuh_req = service.send_request_to_resource({ verb: "GET", path: resource1_path headers: {"x-session-id": 'badsession'} }) .then( (body) -> expect(body.status_code).to.equal 403 ) atuh_req = service.send_request_to_resource({ verb: "GET", path: resource1_path headers: {"x-session-id": 'goodsession'} }) .then( (body) -> expect(body.status_code).to.equal 200 ) bb.all([unatuh_req, atuh_req]) ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) it 'caller version should match cached version' describe "logging", -> it 'should log 2 (inbound and outbound) messages', -> service = new ResourceService('testService') logging_messages = 0 logging_service = new Service('test.logging', {}, (req) -> logging_messages += 1 ) resource = new Resource( "resource" "/v1/test_resource" ) resource.show = (payload) -> return {body: {"hello": "world"}} resource.show.public = true resource_service = new ResourceService('testResource', [resource], logging_endpoint: 'test.logging') bb.all([logging_service.start(), service.start(), resource_service.start()]) .then( -> service.send_request_to_resource({verb: "GET", path: "/v1/test_resource"}) .delay(20) ) .then( (body) -> expect(logging_messages).to.equal(2) ) .finally(-> bb.all([logging_service.stop(), service.stop(), resource_service.stop()]) ) it 'should be able to add additional logging data to the logged events', -> service = new ResourceService('testService') log_message = null logging_service = new Service('test.logging', {}, (payload) -> log_message = JSON.parse(payload.body).data.response.log ) resource = new Resource( "resource" "/v1/test_resource" ) resource.show = (payload) -> return { body: { "hello": "world" } log: { message: "log message" } } resource.show.public = true resource_service = new ResourceService('testResource', [resource], logging_endpoint: 'test.logging') bb.all([logging_service.start(), service.start(), resource_service.start()]) .then( -> service.send_request_to_resource({verb: "GET", path: "/v1/test_resource"}) .delay(100) ) .then( (body) -> expect(log_message.message).to.equal "log message" ) .finally(-> bb.all([logging_service.stop(), service.stop(), resource_service.stop()]) ) describe 'unhappy', -> describe 'platfrom.error', -> it "unauthenticated", -> service = new ResourceService('testService') resource = new Resource("test_resource", '/v1/test_resource') resource.show.public = false resource_service = new ResourceService('testResource', [resource]) bb.all([service.start(), resource_service.start()]) .then( -> service.send_request_to_resource({verb: "GET", path: "/v1/test_resource"}) ) .then( (body) -> expect(body.status_code).to.equal 403 ) .finally(-> bb.all([service.stop(), resource_service.stop()]) ) describe 'service.error', -> it "should return 405 if not implemented method", -> service = new ResourceService('testService') resource = new Resource("test_resource", '/v1/test_resource') resource.show.public = true resource_service = new ResourceService('testResource', [resource]) bb.all([service.start(), resource_service.start()]) .then( -> service.send_request_to_resource({verb: "GET", path: "/v1/test_resource"}) ) .then( (body) -> expect(body.status_code).to.equal 405 ) .finally(-> bb.all([service.stop(), resource_service.stop()]) )