Merge pull request #3 from kubearchive/github-ci

feat: CI via GitHub Actions

.github/workflows/ci.yml

@@ -0,0 +1,29 @@
+name: ci/github
+
+on: 
+  pull_request:
+    branches: [ main ]
+  push:
+    branches: [ main ]
+
+permissions:
+  contents: read
+
+jobs:
+  unit:
+    runs-on: ubuntu-latest
+    steps:
+    - name: Check out code
+      uses: actions/checkout@v4
+    - name: Install Go
+      uses: actions/setup-go@v4
+      with:
+        go-version: 1.20.x
+        cache: true
+        check-latest: true
+    - name: Lint
+      run: make lint
+    - name: Build
+      run: make build
+    - name: Test
+      run: make test

cmd/main.go

@@ -59,7 +59,8 @@ func main() {
 	flag.BoolVar(&enableLeaderElection, "leader-elect", false,
 		"Enable leader election for controller manager. "+
 			"Enabling this will ensure there is only one active controller manager.")
-	flag.StringVar(&eventsSource, "events-source-uri-ref", "locahost", "Source of the CloudEvent as a URI reference. The source plus ID of a CloudEvent should be uniquely identifiable.")
+	flag.StringVar(&eventsSource, "events-source-uri-ref", "locahost",
+		"Source of the CloudEvent as a URI reference. The source plus ID of a CloudEvent should be uniquely identifiable.")
 	flag.StringVar(&eventsTargetAddr, "events-target-address", ":8082", "The target address to send CloudEvents to.")
 	opts := &zap.Options{
 		Development: true,

internal/controller/job_controller.go

@@ -58,7 +58,11 @@ func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.R
 	eventCtx := cloudevents.ContextWithTarget(ctx, r.EventsTarget)
 
 	job := &batchv1.Job{}
-	event := r.newEvent(req.NamespacedName)
+	event, err := r.newEvent(req.NamespacedName)
+	if err != nil {
+		log.Error(err, "failed to create event")
+		return ctrl.Result{}, err
+	}
 	if err := r.Get(ctx, req.NamespacedName, job); err != nil {
 		// If not found, return error for requeue
 		if !errors.IsNotFound(err) {
@@ -76,17 +80,17 @@ func (r *JobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.R
 	return ctrl.Result{}, nil
 }
 
-func (r *JobReconciler) newEvent(key types.NamespacedName) cloudevents.Event {
+func (r *JobReconciler) newEvent(key types.NamespacedName) (cloudevents.Event, error) {
 	event := cloudevents.NewEvent()
 	event.SetSource(r.EventsSource)
 	event.SetType("dynowatch.kubearchive.dev")
-	event.SetData(cloudevents.ApplicationJSON, map[string]string{
+	err := event.SetData(cloudevents.ApplicationJSON, map[string]string{
 		"kind":       "Job",
 		"apiVersion": "batch/v1",
 		"namespace":  key.Namespace,
 		"name":       key.Name,
 	})
-	return event
+	return event, err
 }
 
 // SetupWithManager sets up the controller with the Manager.