Add hashGlobs query to state service

cmd/state-svc/internal/resolver/resolver.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/json"
 	"os"
+	"path/filepath"
 	"runtime/debug"
 	"sort"
 	"strconv"
@@ -20,6 +21,7 @@ import (
 	"github.com/ActiveState/cli/internal/constants"
 	"github.com/ActiveState/cli/internal/errs"
 	"github.com/ActiveState/cli/internal/graph"
+	"github.com/ActiveState/cli/internal/hash"
 	"github.com/ActiveState/cli/internal/logging"
 	configMediator "github.com/ActiveState/cli/internal/mediators/config"
 	"github.com/ActiveState/cli/internal/multilog"
@@ -36,6 +38,7 @@ type Resolver struct {
 	updatePoller   *poller.Poller
 	authPoller     *poller.Poller
 	projectIDCache *projectcache.ID
+	fileHasher     *hash.FileHasher
 	an             *sync.Client
 	anForClient    *sync.Client // Use separate client for events sent through service so we don't contaminate one with the other
 	rtwatch        *rtwatcher.Watcher
@@ -81,6 +84,7 @@ func New(cfg *config.Instance, an *sync.Client, auth *authentication.Auth) (*Res
 		pollUpdate,
 		pollAuth,
 		projectcache.NewID(),
+		hash.NewFileHasher(),
 		an,
 		anForClient,
 		rtwatcher.New(cfg, anForClient),
@@ -263,6 +267,8 @@ func (r *Resolver) GetProcessesInUse(ctx context.Context, execDir string) ([]*gr
 }
 
 func (r *Resolver) GetJwt(ctx context.Context) (*graph.Jwt, error) {
+	defer func() { handlePanics(recover(), debug.Stack()) }()
+
 	if err := r.auth.MaybeRenew(); err != nil {
 		return nil, errs.Wrap(err, "Could not renew auth token")
 	}
@@ -296,6 +302,21 @@ func (r *Resolver) GetJwt(ctx context.Context) (*graph.Jwt, error) {
 	return jwt, nil
 }
 
+func (r *Resolver) HashGlobs(ctx context.Context, globs []string) (string, error) {
+	defer func() { handlePanics(recover(), debug.Stack()) }()
+
+	var files []string
+	for _, glob := range globs {
+		matches, err := filepath.Glob(glob)
+		if err != nil {
+			return "", errs.Wrap(err, "Could not match glob: %s", glob)
+		}
+		files = append(files, matches...)
+	}
+
+	return r.fileHasher.HashFiles(files)
+}
+
 func handlePanics(recovered interface{}, stack []byte) {
 	if recovered != nil {
 		multilog.Error("Panic: %v", recovered)