| 859 | } |
| 860 | |
| 861 | function waitForJobSequence(locals, expectedResult) { |
| 862 | describe('The job sequence', function() { |
| 863 | it('should have an id', function(callback) { |
| 864 | sqldb.queryOneRow(sql.select_last_job_sequence, [], (err, result) => { |
| 865 | if (ERR(err, callback)) return; |
| 866 | locals.job_sequence_id = result.rows[0].id; |
| 867 | callback(null); |
| 868 | }); |
| 869 | }); |
| 870 | it('should complete', function(callback) { |
| 871 | var checkComplete = function() { |
| 872 | var params = {job_sequence_id: locals.job_sequence_id}; |
| 873 | sqldb.queryOneRow(sql.select_job_sequence, params, (err, result) => { |
| 874 | if (ERR(err, callback)) return; |
| 875 | locals.job_sequence_status = result.rows[0].status; |
| 876 | if (locals.job_sequence_status == 'Running') { |
| 877 | setTimeout(checkComplete, 10); |
| 878 | } else { |
| 879 | callback(null); |
| 880 | } |
| 881 | }); |
| 882 | }; |
| 883 | setTimeout(checkComplete, 10); |
| 884 | }); |
| 885 | it(`should have result "${expectedResult}"`, function() { |
| 886 | assert.equal(locals.job_sequence_status, expectedResult); |
| 887 | }); |
| 888 | }); |
| 889 | } |