mirror of
https://github.com/pulsar-edit/pulsar.git
synced 2024-11-10 10:17:11 +03:00
110 lines
3.7 KiB
CoffeeScript
110 lines
3.7 KiB
CoffeeScript
Task = require '../src/task'
|
|
Grim = require 'grim'
|
|
|
|
describe "Task", ->
|
|
describe "@once(taskPath, args..., callback)", ->
|
|
it "terminates the process after it completes", ->
|
|
handlerResult = null
|
|
task = Task.once require.resolve('./fixtures/task-spec-handler'), (result) ->
|
|
handlerResult = result
|
|
|
|
processErrored = false
|
|
childProcess = task.childProcess
|
|
spyOn(childProcess, 'kill').andCallThrough()
|
|
task.childProcess.on 'error', -> processErrored = true
|
|
|
|
waitsFor ->
|
|
handlerResult?
|
|
|
|
runs ->
|
|
expect(handlerResult).toBe 'hello'
|
|
expect(childProcess.kill).toHaveBeenCalled()
|
|
expect(processErrored).toBe false
|
|
|
|
it "calls listeners registered with ::on when events are emitted in the task", ->
|
|
task = new Task(require.resolve('./fixtures/task-spec-handler'))
|
|
|
|
eventSpy = jasmine.createSpy('eventSpy')
|
|
task.on("some-event", eventSpy)
|
|
|
|
waitsFor (done) -> task.start(done)
|
|
|
|
runs ->
|
|
expect(eventSpy).toHaveBeenCalledWith(1, 2, 3)
|
|
|
|
it "unregisters listeners when the Disposable returned by ::on is disposed", ->
|
|
task = new Task(require.resolve('./fixtures/task-spec-handler'))
|
|
|
|
eventSpy = jasmine.createSpy('eventSpy')
|
|
disposable = task.on("some-event", eventSpy)
|
|
disposable.dispose()
|
|
|
|
waitsFor (done) -> task.start(done)
|
|
|
|
runs ->
|
|
expect(eventSpy).not.toHaveBeenCalled()
|
|
|
|
it "reports deprecations in tasks", ->
|
|
jasmine.snapshotDeprecations()
|
|
handlerPath = require.resolve('./fixtures/task-handler-with-deprecations')
|
|
task = new Task(handlerPath)
|
|
|
|
waitsFor (done) -> task.start(done)
|
|
|
|
runs ->
|
|
deprecations = Grim.getDeprecations()
|
|
expect(deprecations.length).toBe 1
|
|
expect(deprecations[0].getStacks()[0][1].fileName).toBe handlerPath
|
|
jasmine.restoreDeprecationsSnapshot()
|
|
|
|
it "adds data listeners to standard out and error to report output", ->
|
|
task = new Task(require.resolve('./fixtures/task-spec-handler'))
|
|
{stdout, stderr} = task.childProcess
|
|
|
|
task.start()
|
|
task.start()
|
|
expect(stdout.listeners('data').length).toBe 1
|
|
expect(stderr.listeners('data').length).toBe 1
|
|
|
|
task.terminate()
|
|
expect(stdout.listeners('data').length).toBe 0
|
|
expect(stderr.listeners('data').length).toBe 0
|
|
|
|
it "does not throw an error for forked processes missing stdout/stderr", ->
|
|
spyOn(require('child_process'), 'fork').andCallFake ->
|
|
Events = require 'events'
|
|
fakeProcess = new Events()
|
|
fakeProcess.send = ->
|
|
fakeProcess.kill = ->
|
|
fakeProcess
|
|
|
|
task = new Task(require.resolve('./fixtures/task-spec-handler'))
|
|
expect(-> task.start()).not.toThrow()
|
|
expect(-> task.terminate()).not.toThrow()
|
|
|
|
describe "::cancel()", ->
|
|
it "dispatches 'task:cancelled' when invoked on an active task", ->
|
|
task = new Task(require.resolve('./fixtures/task-spec-handler'))
|
|
cancelledEventSpy = jasmine.createSpy('eventSpy')
|
|
task.on('task:cancelled', cancelledEventSpy)
|
|
completedEventSpy = jasmine.createSpy('eventSpy')
|
|
task.on('task:completed', completedEventSpy)
|
|
|
|
expect(task.cancel()).toBe(true)
|
|
expect(cancelledEventSpy).toHaveBeenCalled()
|
|
expect(completedEventSpy).not.toHaveBeenCalled()
|
|
|
|
it "does not dispatch 'task:cancelled' when invoked on an inactive task", ->
|
|
handlerResult = null
|
|
task = Task.once require.resolve('./fixtures/task-spec-handler'), (result) ->
|
|
handlerResult = result
|
|
|
|
waitsFor ->
|
|
handlerResult?
|
|
|
|
runs ->
|
|
cancelledEventSpy = jasmine.createSpy('eventSpy')
|
|
task.on('task:cancelled', cancelledEventSpy)
|
|
expect(task.cancel()).toBe(false)
|
|
expect(cancelledEventSpy).not.toHaveBeenCalled()
|