MojioSDK = require '../../src/nodejs/sdk/MojioSDK' MojioRestSDK = require '../../src/nodejs/sdk/MojioRestSDK' should = require('should') async = require('async') nock = require 'nock' describe 'Node Mojio Fluent Rest SDK GET calls', -> user = null mojio = null vehicle = null client_id = 'cacc0d94-b6b4-4da7-9983-3991de197038' client_secret = '427d5794-5021-4274-a6e8-a38d5d83bf99' call = null timeout = 50 callback_url = "http://localhost:3000/callback" authorization = { client_id: client_id, client_secret: client_secret redirect_uri: 'http://localhost:3000/callback' username: 'testing' password: 'Test123!' scope: 'full' grant_type: 'password' } options = { sdk: MojioRestSDK, environment: 'staging' accountsURL: 'accounts.moj.io' apiURL: 'api.moj.io' pushURL: 'push.moj.io' client_id: authorization.client_id, client_secret: authorization.client_secret, # styles: [MojioPromiseStyle] } if options.environment != '' testAccountsURL = 'https://'+options.environment+'-'+options.accountsURL testApiURL = 'https://'+options.environment+'-'+options.apiURL else testAccountsURL = 'https://'+options.accountsURL testApiURL = 'https://'+options.apiURL beforeEach () -> user = null mojio = null vehicle = null it 'can GET a resource or list of resources, secondary resource, or history by ids or no query', (testComplete) -> setupTokenNock = () -> if (process.env.FUNCTIONAL_TESTS=='true') timeout = 3000 return {done: () ->} else call = nock(testAccountsURL) .post("/oauth2/token", authorization) .reply((uri, requestBody, cb) -> cb(null, [200, { id: 4, access_token:"token"}]) return ) return call setupAuthorizeNock = () -> if (process.env.FUNCTIONAL_TESTS=='true') timeout = 3000 return {done: () ->} else call = nock(testAccountsURL) .post("/oauth2/token", authorization) .reply((uri, requestBody, cb) -> cb(null, [200, { id: 2, access_token:"token"}]) return ) return call setupNock = (api, verb, version, primary_, pid_, secondary_, sid_, _tertiary, tid_) -> if (process.env.FUNCTIONAL_TESTS=='true') timeout = 3000 return {done: () ->} else test = { pid: pid_ sid: sid_ tid: tid_ secondary: secondary_ primary: primary_ tertiary: _tertiary } pathFilter = (path) -> parts = path.split('/') idRegex = /\b[A-F0-9]{8}(?:-[A-F0-9]{4}){3}-[A-F0-9]{12}\b/ parts = parts[1...parts.length] versionValid = parts[0] is version parts = parts[1...parts.length] if parts.length == 1 # # /primary valid = parts[0] is test.primary else if parts.length == 2 # /primary/[id] valid = parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) else if parts.length == 3 # /primary/[id]/secondary valid = parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) and parts[2] is test.secondary else if parts.length == 4 and test.sid? # /primary/[pid]/secondary/[sid] valid = (parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) and parts[2] is test.secondary and (parts[3].match(idRegex) or parts[3] is ""+test.sid)) else if parts.length == 4 and !test.sid? # /primary/[pid]/secondary/tertiary valid = (parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) and parts[2] is test.secondary and parts[3] is test.tertiary) else if parts.length == 5 # /primary/[id]/secondary/[id]/tertiary valid = (parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) and parts[2] is test.secondary and (parts[3].match(idRegex) or parts[3] == ""+test.sid) and parts[4] is test.tertiary) else if parts.length == 6 # /primary/[id]/secondary/[id]/tertiary/id valid = (parts[0] is test.primary and (parts[1].match(idRegex) or parts[1] == ""+test.pid) and parts[2] is test.secondary and (parts[3].match(idRegex) or parts[3] == ""+test.sid) and parts[4] is test.tertiary and (parts[5].match(idRegex) or parts[5] == ""+test.tid)) if valid and versionValid return '/true' else return '/false' nock.removeInterceptor({hostname:api}) call = nock(api).filteringPath(pathFilter)[verb]('/true') .reply((uri, requestBody, cb) -> cb(null, [200, { id: 3, message: "hi"}]) return ) return call testErrorResult = (error, result) -> console.log("ERROR: "+error.statusMessage+" content:"+error.content) if error? (error==null).should.be.true (result!=null).should.be.true sdk = new MojioSDK(options) execute = (test, doneOne) -> async.series([ # todo encrypted password (cb) -> setupAuthorizeNock() sdk .token(authorization.redirect_uri) .credentials(authorization.username, authorization.password) .scope(['full']) .callback((error, result) -> if (error) console.log('Access Token Error'+" url:"+sdk.url()) cb(error, result) else setupTokenNock() sdk.token().parse(result).callback((error, result) -> token = result cb(error, result) ) ) # , # (cb) -> # console.log("mock the user") # sdk.mock().user({}).callback( # (error, result) -> user = result; cb(error, result)) # , # (cb) -> # console.log("mock the mojio") # # sdk.mojio({UserId: user.id, Imei: "9991234567891234"}) # .mock().callback((error, result) -> mojio = result; cb(error, result)) # , # (cb) -> # console.log("mock the vehicle") # sdk.mock().vehicle({MojioId: mojio.id, UserId: user.id, Speed: 80}).callback( # ((error, result) -> vehicle = result; cb(error, result))) , (cb) -> # console.log("run the test") test(cb) # execute a test. ] , # callback when the series is done or in error. (error, results) -> console.log(error) if error? (error==null).should.be.true # todo:: test results for correctness. (results!=null).should.be.true # test results content to be the observed entitiy doneOne() return ) # @.timeout(5000) docall = (item, finishedOne) -> # if item.primary == 'Trips' and item.secondary == 'History' and item.tertiary == 'Locations' # finish = done # else # finish = (() ->) execute( (cb) -> if (item.tertiary?) setupNock(testApiURL, 'get', 'v2', item.primary, item.pid, item.secondary, null, item.tertiary, null) sdk.get()[item.primary](item.pid)[item.secondary]()[item.tertiary]() .callback((error, result) -> testErrorResult(error, result) cb(null, result) ) else if (item.secondary?) if item.sid? setupNock(testApiURL, 'get', 'v2', item.primary, item.pid, item.secondary, item.sid, null, null) sdk.get()[item.primary](item.pid)[item.secondary](item.sid) .callback((error, result) -> testErrorResult(error, result) cb(null, result) ) else if item.pid? setupNock(testApiURL, 'get', 'v2', item.primary, item.pid, item.secondary, null, null, null) sdk.get()[item.primary](item.pid)[item.secondary]() .callback((error, result) -> testErrorResult(error, result) cb(null, result) ) else if item.pid? setupNock(testApiURL, 'get', 'v2', item.primary, item.pid, null, null, null, null) sdk.get()[item.primary](item.pid) .callback((error, result) -> testErrorResult(error, result) cb(null, result) ) else if (item.primary == 'me') setupNock(testApiURL, 'get', 'v2', item.primary, null, null, null, null, null) sdk.me().callback((error, result) -> testErrorResult(error, result) cb(null, result) ) return else setupNock(testApiURL, 'get', 'v2', item.primary, null, null, null, null, null) sdk.get()[item.primary]() .callback((error, result) -> testErrorResult(error, result) cb(null, result) ) , finishedOne ) return calls = [] calls.push((callback) -> docall({primary:'me'}, (error, result) -> console.log("me: done"+result) callback(error,result) ) ) entities = ['Vehicles', 'Mojios', 'Users', 'Apps', 'Groups', 'Trips'] secondaries = ['Tags', 'Permissions'] i=1 for entity in entities calls.push((callback) -> docall({primary:entity}, (error, result) -> console.log(""+entity+": done"+result) callback(error,result) ) ) calls.push((callback) -> docall({primary:entity, pid: i++}, (error, result) -> console.log(""+entity+"/"+": done"+result) callback(error,result) ) ) for secondaryEntity in secondaries calls.push((callback) -> docall({primary:entity, pid: i++, secondary: secondaryEntity}, (error, result) -> console.log(""+entity+"/"+": done"+result) callback(error,result) ) ) # TODO: primary/id/secondary/id fix. # calls.push((callback) -> # execute({primary:entity, pid: i++, secondary: secondaryEntity, sid: i++}, (error, result) -> # console.log(""+entity+"/"+": done"+result) # callback(error,result) # ) # ) entities2 = ['Vehicles', 'Trips'] secondaries2 = ['History'] tertiary2 = ['States','Locations'] for entity in entities2 for secondaryEntity in secondaries2 for tertiaryEntity in tertiary2 calls.push((callback) -> docall({ primary:entity,pid: i++,secondary: secondaryEntity,sid: null, tertiary: tertiaryEntity, tid: null}, (error, result) -> console.log(""+entity+"/"+": done"+result) callback(error,result) ) ) async.series(calls, (error, result) -> console.log(error) if error? (error==null).should.be.true testComplete() return ) # setupPostPutNock = (api, verb, version, primary_, pid_, secondary_, data_) -> # if (process.env.FUNCTIONAL_TESTS=='true') # timeout = 3000 # return {done: () ->} # else # check = { # pid: pid_ # data: data_ # secondary: secondary_ # primary: primary_ # } # call = nock(api).filteringPath((path) -> # parts = path.split('/') # idRegex = /\b[A-F0-9]{8}(?:-[A-F0-9]{4}){3}-[A-F0-9]{12}\b/ # parts = parts[1...parts.length] # versionValid = parts[0] is version # parts = parts[1...parts.length] # if parts.length == 1 # /primary & [data] # valid = parts[0] is check.primary # else if parts.length == 3 # /primary/[id]/secondary & [data] # valid = parts[0] is check.primary and (parts[1].match(idRegex) or parts[1] == ""+check.pid) and # parts[2] is check.secondary # # if valid and versionValid # return '/true' #'/'+check.primary+'/'+check.pid+'/'+check.secondary # else # return '/false' # )[verb]('/true', check.data) #'/'+check.primary+'/'+check.pid+'/'+check.secondary, check.data) # .reply((uri, requestBody, cb) -> # cb(null, [200, { id: 1, name: "name"}])) # return null # # it 'can POST and PUT entities and get a resource or secondary resource by ids or lists', (done) -> ## @.timeout(5000) # # docall = (verb, entity, pid=null, secondary=null, data = null) -> # if entity == 'Trips' and secondary == 'Permissions' and verb == 'put' # finish = done # else # finish = (() ->) # execute( # (cb) -> # if (secondary?) # call = setupPostPutNock(testApiURL, verb, 'v2', entity, pid, secondary, data) # sdk[verb]()[entity](pid)[secondary](data).callback((error, result) -> # testErrorResult(error, result) # cb(null, result) # ) # else # call = setupPostPutNock(testApiURL, verb, 'v2', entity, null, null, data) # sdk[verb]()[entity](data).callback((error, result) -> # testErrorResult(error, result) # cb(null, result) # ) # # , finish # ) # entities = ['Mojios', 'Vehicles', 'Users', 'Apps', 'Groups', 'Trips'] # secondaries = ['Tags', 'Permissions', 'Images', 'Details'] # for entity in entities # docall('post',entity, null, null, {name: 'name'+entity}) # docall('put',entity, null, null, {name: 'name'+entity}) # for secondaryEntity in secondaries # docall('post',entity,1,secondaryEntity, {name: 'name/'+entity+'/1/'+secondaryEntity}) # docall('put',entity,1,secondaryEntity, {name: 'name/'+entity+'/1/'+secondaryEntity}) # it 'can create share and revoke a vehicle', (done) -> # @.timeout(5000) # execute( # (cb) -> # sdk.share().vehicle(vehicle).with(user).access("write").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.revoke().vehicle(vehicle).from(user).callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # , done # ) # it 'can create share and revoke a list of vehicles', (done) -> # @.timeout(5000) # execute( # (cb) -> # sdk.share().vehicles([vehicle]).with(user).access("read").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.revoke().vehicles([vehicle]).from(user).access("read").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # , done # ) # it "can create share and revoke a vehicle's fields", (done) -> # @.timeout(5000) # execute( # (cb) -> # sdk.share().vehicle(vehicle).fields(['location', 'speed']).with(user).access("read").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.revoke().vehicle(vehicle).from(user).access("read").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # , done # ) # it 'can create group add/remove users', (done) -> # @.timeout(5000) # execute( # (cb) -> # sdk.create().group({name: "blah"}).with([user]).callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # (error, result) -> # group = result # ) # # sdk.group("blah").add(user).callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.add(user).into().group("blah").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.remove(user).outof().group("blah").callback((error, result) -> # testErrorResult(error, result) # # todo: test validity of vehicle # cb(null, result) # ) # sdk.create().mojio({imei: "123981392131"}) # attach to current user. # , done # )