fix: handle delayed resets by forcefully recording 0s for unreceived …

…events (#144)

receiver/githubactionsreceiver/metric_event_handling.go

@@ -46,11 +46,26 @@ func (m *metricsHandler) eventToMetrics(event *github.WorkflowJobEvent, config *
 		labels = "no labels"
 	}
 
+	now := pcommon.NewTimestampFromTime(time.Now())
+
 	if status, ok := metadata.MapAttributeCiGithubWorkflowJobStatus[event.GetAction()]; ok {
-		curVal, _ := loadFromCache(repo, labels, status)
-		storeInCache(repo, labels, status, curVal+1)
+		curVal, found := loadFromCache(repo, labels, status)
+
+		// If the value was not found in the cache, we record a 0 value for all other possible statuses
+		// so that counter resets are properly handled.
+		if !found {
+			for _, s := range metadata.MapAttributeCiGithubWorkflowJobStatus {
+				if s == status {
+					continue
+				}
 
-		m.mb.RecordWorkflowJobsTotalDataPoint(pcommon.NewTimestampFromTime(time.Now()), curVal+1, repo, labels, status)
+				storeInCache(repo, labels, s, 0)
+				m.mb.RecordWorkflowJobsTotalDataPoint(now, 0, repo, labels, s)
+			}
+		}
+
+		storeInCache(repo, labels, status, curVal+1)
+		m.mb.RecordWorkflowJobsTotalDataPoint(now, curVal+1, repo, labels, status)
 	}
 
 	return m.mb.Emit()