Merge pull request #21 from LNOpenMetrics/dev

utime: adding method to count occurences between timestamps

utime/utime.go

@@ -54,3 +54,19 @@ func FromDecimalUnix(decimalUnix float64) int64 {
 	sec, dec := math.Modf(decimalUnix)
 	return time.Unix(int64(sec), int64(dec*(1e9))).Unix()
 }
+
+// Count the number of occurrence that are inside the following
+func OccurenceInUnixRange(from int64, to int64, step time.Duration) uint64 {
+	count := uint64(0)
+	actual := from
+	for actual < to {
+		actual = increaseTimestampByDuration(actual, step)
+		count++
+	}
+	return count
+}
+
+func increaseTimestampByDuration(timestamp int64, duration time.Duration) int64 {
+	actualTime := time.Unix(timestamp, 0).Add(duration)
+	return actualTime.Unix()
+}

utime/utime_test.go

@@ -49,3 +49,25 @@ func TestSameInRangeMonthsUnixTwo(t *testing.T) {
 		t.Errorf("The two dates are inside the range of 1 month, them should be outside of this range")
 	}
 }
+
+func TestCountOccurenceInOneHour(t *testing.T) {
+	start := time.Now().Unix()
+	end := time.Now().Add(1 * time.Hour).Unix()
+
+	occur := OccurenceInUnixRange(start, end, 30*time.Minute)
+
+	if occur != 2 {
+		t.Errorf("Expected 2 by received %d", occur)
+	}
+}
+
+func TestCountOccurenceInOneDay(t *testing.T) {
+	start := time.Now().Unix()
+	end := time.Now().Add(24 * time.Hour).Unix()
+
+	occur := OccurenceInUnixRange(start, end, 30*time.Minute)
+
+	if occur != 2*24 {
+		t.Errorf("Expected %d but received %d", 2*24, occur)
+	}
+}