Skip to content

Commit

Permalink
Merge pull request #23 from CraigRBrown/StepFilter
Browse files Browse the repository at this point in the history
Do not skip hour 23 when using hour step
  • Loading branch information
jcoutch committed Sep 16, 2020
2 parents 98a0fd8 + a454eed commit b0125cc
Show file tree
Hide file tree
Showing 2 changed files with 118 additions and 1 deletion.
117 changes: 117 additions & 0 deletions NCrontab.Advanced.Tests/CronInstanceTests.cs
Expand Up @@ -644,6 +644,123 @@ public void NoNextInstanceTest()
Assert.IsFalse(stopWatch.ElapsedMilliseconds > 250, string.Format("Elapsed time should not exceed 250ms (was {0} ms)", stopWatch.ElapsedMilliseconds));
}

[TestMethod]
public void EveryHour()
{
var cron = CrontabSchedule.Parse("0 * * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start,start.AddDays(2)))
{
currentTime = currentTime.AddHours(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EveryMinute()
{
var cron = CrontabSchedule.Parse("* * * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddHours(2)))
{
currentTime = currentTime.AddMinutes(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EverySecond()
{
var cron = CrontabSchedule.Parse("* * * * * *", CronStringFormat.WithSeconds);
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddMinutes(2)))
{
currentTime = currentTime.AddSeconds(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EveryHour_Step()
{
var cron = CrontabSchedule.Parse("0 0/1 * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddDays(2)))
{
currentTime = currentTime.AddHours(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EveryMinute_Step()
{
var cron = CrontabSchedule.Parse("0/1 * * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddHours(2)))
{
currentTime = currentTime.AddMinutes(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EverySecond_Step()
{
var cron = CrontabSchedule.Parse("0/1 * * * * *", CronStringFormat.WithSeconds);
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddMinutes(2)))
{
currentTime = currentTime.AddSeconds(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EveryHour_Range()
{
var cron = CrontabSchedule.Parse("0 0-23 * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddDays(2)))
{
currentTime = currentTime.AddHours(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EveryMinute_Range()
{
var cron = CrontabSchedule.Parse("0-59 * * * *");
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddHours(2)))
{
currentTime = currentTime.AddMinutes(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

[TestMethod]
public void EverySecond_Range()
{
var cron = CrontabSchedule.Parse("0-59 * * * * *", CronStringFormat.WithSeconds);
var start = DateTime.Today.ToUniversalTime();
var currentTime = start;
foreach (var nextOccurrence in cron.GetNextOccurrences(start, start.AddMinutes(2)))
{
currentTime = currentTime.AddSeconds(1);
Assert.AreEqual(currentTime, nextOccurrence);
}
}

static void CronCall(string startTimeString, string cronExpression, string nextTimeString, CronStringFormat format)
{
var schedule = CrontabSchedule.Parse(cronExpression, format);
Expand Down
2 changes: 1 addition & 1 deletion NCrontab.Advanced/Filters/StepFilter.cs
Expand Up @@ -100,7 +100,7 @@ private bool IsMatch(int evalValue)
while (newValue < max && !IsMatch(newValue.Value))
newValue++;

if (newValue >= max) newValue = null;
if (newValue > max) newValue = null;

return newValue;
}
Expand Down

0 comments on commit b0125cc

Please sign in to comment.