chore(): improved interceptor

internal/core/repos/alias.go

@@ -4,6 +4,7 @@ import (
 	"go.breu.io/quantm/internal/core/repos/activities"
 	"go.breu.io/quantm/internal/core/repos/defs"
 	"go.breu.io/quantm/internal/core/repos/fns"
+	"go.breu.io/quantm/internal/core/repos/nomad"
 	"go.breu.io/quantm/internal/core/repos/states"
 	"go.breu.io/quantm/internal/core/repos/workflows"
 )
@@ -38,6 +39,10 @@ var (
 	RepoWorkflowOptions = defs.RepoWorkflowOptions
 )
 
+var (
+	NomadHandler = nomad.NewRepoServiceHandler
+)
+
 const (
 	SignalPush = defs.SignalPush
 	SignalRef  = defs.SignalRef

internal/core/repos/nomad/repos.go

@@ -1,4 +1,4 @@
-package reposnmd
+package nomad
 
 import (
 	"context"
@@ -8,7 +8,7 @@ import (
 	"google.golang.org/protobuf/types/known/emptypb"
 
 	"go.breu.io/quantm/internal/auth"
-	reposcast "go.breu.io/quantm/internal/core/repos/cast"
+	"go.breu.io/quantm/internal/core/repos/cast"
 	"go.breu.io/quantm/internal/db"
 	"go.breu.io/quantm/internal/erratic"
 	corev1 "go.breu.io/quantm/internal/proto/ctrlplane/core/v1"
@@ -31,7 +31,7 @@ func (s *RepoService) ListRepos(
 		return nil, erratic.NewDatabaseError(erratic.CoreModule).Wrap(err)
 	}
 
-	protos := reposcast.RepoExtendedListToProto(rows)
+	protos := cast.RepoExtendedListToProto(rows)
 
 	return connect.NewResponse(&corev1.ListReposResponse{Repos: protos}), nil
 }

internal/hooks/github/alias.go

@@ -3,6 +3,7 @@ package github
 import (
 	"go.breu.io/quantm/internal/hooks/github/activities"
 	"go.breu.io/quantm/internal/hooks/github/config"
+	"go.breu.io/quantm/internal/hooks/github/nomad"
 	"go.breu.io/quantm/internal/hooks/github/web"
 	"go.breu.io/quantm/internal/hooks/github/workflows"
 )
@@ -30,4 +31,6 @@ var (
 	PushWorkflow        = workflows.Push
 	PullRequestWorkflow = workflows.PullRequest
 	SyncReposWorkflow   = workflows.SyncRepos
+
+	NomadHandler = nomad.NewGithubServiceHandler
 )

internal/hooks/slack/alias.go

@@ -3,6 +3,7 @@ package slack
 import (
 	"go.breu.io/quantm/internal/hooks/slack/activities"
 	"go.breu.io/quantm/internal/hooks/slack/config"
+	"go.breu.io/quantm/internal/hooks/slack/nomad"
 )
 
 type (
@@ -14,4 +15,6 @@ type (
 var (
 	WithConfig = config.WithConfig
 	Configure  = config.Instance
+
+	NomadHandler = nomad.NewSlackServiceHandler
 )

internal/nomad/intercepts/recover.go

@@ -0,0 +1,12 @@
+package intercepts
+
+import (
+	"context"
+	"net/http"
+
+	"connectrpc.com/connect"
+)
+
+func Recover(ctx context.Context, spec connect.Spec, header http.Header, req any) error {
+	return nil
+}

internal/observe/intercepts/logger.go → internal/nomad/intercepts/request_logger.go

@@ -53,7 +53,7 @@ func RequestLogger() connect.UnaryInterceptorFunc {
 					fields = append(fields, "internal_error", qerr.Unwrap().Error())
 				}
 
-				slog.Error(procedure, fields...)
+				slog.Warn(procedure, fields...)
 
 				err = qerr.ToConnectError()
 			} else {

internal/nomad/server/default.go

@@ -4,10 +4,10 @@ import (
 	"connectrpc.com/connect"
 
 	"go.breu.io/quantm/internal/auth"
-	reposnmd "go.breu.io/quantm/internal/core/repos/nomad"
-	githubnmd "go.breu.io/quantm/internal/hooks/github/nomad"
-	slacknmd "go.breu.io/quantm/internal/hooks/slack/nomad"
-	"go.breu.io/quantm/internal/observe"
+	"go.breu.io/quantm/internal/core/repos"
+	"go.breu.io/quantm/internal/hooks/github"
+	"go.breu.io/quantm/internal/hooks/slack"
+	"go.breu.io/quantm/internal/nomad/intercepts"
 )
 
 // DefaultServer creates a new Nomad server instance with the provided options.
@@ -19,7 +19,7 @@ func DefaultServer(opts ...Option) *Server {
 	// -- config/interceptors --
 
 	interceptors := []connect.Interceptor{
-		observe.NomadRequestLogger(),
+		intercepts.RequestLogger(),
 	}
 
 	// -- config/handlers --
@@ -38,13 +38,13 @@ func DefaultServer(opts ...Option) *Server {
 	options = append(options, connect.WithInterceptors(auth.NomadInterceptor()))
 
 	// -- core/repos --
-	srv.add(reposnmd.NewRepoServiceHandler(options...))
+	srv.add(repos.NomadHandler(options...))
 
 	// -- hooks/github --
-	srv.add(githubnmd.NewGithubServiceHandler(options...))
+	srv.add(github.NomadHandler(options...))
 
 	// -- hooks/slack --
-	srv.add(slacknmd.NewSlackServiceHandler(options...))
+	srv.add(slack.NomadHandler(options...))
 
 	return srv
 }