_ = require 'underscore' {generateTempId, isTempId} = require '../../src/flux/models/utils' NylasAPI = require '../../src/flux/nylas-api' Task = require '../../src/flux/tasks/task' Actions = require '../../src/flux/actions' Message = require '../../src/flux/models/message' Account = require '../../src/flux/models/account' Contact = require '../../src/flux/models/contact' {APIError} = require '../../src/flux/errors' DatabaseStore = require '../../src/flux/stores/database-store' TaskQueue = require '../../src/flux/stores/task-queue' SyncbackDraftTask = require '../../src/flux/tasks/syncback-draft' inboxError = message: "No draft with public id bvn4aydxuyqlbmzowh4wraysg", type: "invalid_request_error" testError = (opts) -> new APIError error:null response:{statusCode: 404} body:inboxError requestOptions: opts testData = to: [new Contact(name: "Ben Gotow", email: "ben@nylas.com")] from: [new Contact(name: "Evan Morikawa", email: "evan@nylas.com")] date: new Date draft: true subject: "Test" accountId: "abc123" body: '123' localDraft = new Message _.extend {}, testData, {id: "local-id"} remoteDraft = new Message _.extend {}, testData, {id: "remoteid1234"} describe "SyncbackDraftTask", -> beforeEach -> spyOn(DatabaseStore, "findByLocalId").andCallFake (klass, localId) -> if localId is "localDraftId" then Promise.resolve(localDraft) else if localId is "remoteDraftId" then Promise.resolve(remoteDraft) else if localId is "missingDraftId" then Promise.resolve() spyOn(DatabaseStore, 'findBy').andCallFake (klass, matchers) -> if klass is Account Promise.resolve(new Account(id: 'abc123')) spyOn(DatabaseStore, "persistModel").andCallFake -> Promise.resolve() spyOn(DatabaseStore, "swapModel").andCallFake -> Promise.resolve() describe "performRemote", -> beforeEach -> spyOn(NylasAPI, 'makeRequest').andCallFake (opts) -> Promise.resolve(remoteDraft.toJSON()) it "does nothing if no draft can be found in the db", -> task = new SyncbackDraftTask("missingDraftId") waitsForPromise => task.performRemote().then -> expect(NylasAPI.makeRequest).not.toHaveBeenCalled() it "should start an API request with the Message JSON", -> task = new SyncbackDraftTask("localDraftId") waitsForPromise => task.performRemote().then -> expect(NylasAPI.makeRequest).toHaveBeenCalled() reqBody = NylasAPI.makeRequest.mostRecentCall.args[0].body expect(reqBody.subject).toEqual testData.subject expect(reqBody.body).toEqual testData.body it "should do a PUT when the draft has already been saved", -> task = new SyncbackDraftTask("remoteDraftId") waitsForPromise => task.performRemote().then -> expect(NylasAPI.makeRequest).toHaveBeenCalled() options = NylasAPI.makeRequest.mostRecentCall.args[0] expect(options.path).toBe("/drafts/remoteid1234") expect(options.accountId).toBe("abc123") expect(options.method).toBe('PUT') it "should do a POST when the draft is unsaved", -> task = new SyncbackDraftTask("localDraftId") waitsForPromise => task.performRemote().then -> expect(NylasAPI.makeRequest).toHaveBeenCalled() options = NylasAPI.makeRequest.mostRecentCall.args[0] expect(options.path).toBe("/drafts") expect(options.accountId).toBe("abc123") expect(options.method).toBe('POST') it "should pass returnsModel:false so that the draft can be manually removed/added to the database, accounting for its ID change", -> task = new SyncbackDraftTask("localDraftId") waitsForPromise => task.performRemote().then -> expect(NylasAPI.makeRequest).toHaveBeenCalled() options = NylasAPI.makeRequest.mostRecentCall.args[0] expect(options.returnsModel).toBe(false) it "should swap the ids if we got a new one from the DB", -> task = new SyncbackDraftTask("localDraftId") waitsForPromise => task.performRemote().then -> expect(DatabaseStore.swapModel).toHaveBeenCalled() expect(DatabaseStore.persistModel).not.toHaveBeenCalled() it "should not swap the ids if we're using a persisted one", -> task = new SyncbackDraftTask("remoteDraftId") waitsForPromise => task.performRemote().then -> expect(DatabaseStore.swapModel).not.toHaveBeenCalled() expect(DatabaseStore.persistModel).toHaveBeenCalled() describe "When the api throws a 404 error", -> beforeEach -> spyOn(NylasAPI, "makeRequest").andCallFake (opts) -> Promise.reject(testError(opts)) it "resets the id", -> task = new SyncbackDraftTask("remoteDraftId") taskStatus = null task.performRemote().then (status) => taskStatus = status waitsFor -> DatabaseStore.swapModel.calls.length > 0 runs -> newDraft = DatabaseStore.swapModel.mostRecentCall.args[0].newModel expect(isTempId(newDraft.id)).toBe true expect(taskStatus).toBe(Task.Status.Retry)