feat: added the ability to manuall refresh a module

internal/bitbucketserver/client.go

@@ -127,7 +127,12 @@ func (g *TokenClient) ListTags(ctx context.Context, opts vcs.ListTagsOptions) ([
 	response, err := g.client.DefaultApi.GetTags(
 		owner,
 		name,
-		map[string]interface{}{"filterText": opts.Prefix},
+		map[string]interface{}{
+			"filterText": opts.Prefix,
+			"orderBy":    "MODIFICATION",
+			"start":      0,
+			"limit":      1000,
+		},
 	)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get tags: %w", err)

internal/http/html/paths/gen.go

@@ -328,6 +328,7 @@ var specs = []controllerSpec{
 			{
 				Name:           "module",
 				controllerType: resourcePath,
+				actions:        []action{{name: "refresh", collection: false}},
 			},
 		},
 	},

internal/http/html/static/templates/content/module_get.tmpl

@@ -80,5 +80,9 @@
     <form id="module-delete-button" action="{{ deleteModulePath .Module.ID }}" method="POST">
       <button class="btn-danger" onclick="return confirm('Are you sure you want to delete?')">Delete module</button>
     </form>
+
+    <form id="module-refresh-button" action="{{ refreshModulePath .Module.ID }}" method="POST">
+      <button class="btn" onclick="return confirm('Are you sure you want to refresh?')">Refresh module</button>
+    </form>
   </div>
 {{ end }}

internal/module/service.go

@@ -315,6 +315,78 @@ func (s *Service) DeleteModule(ctx context.Context, id string) (*Module, error)
 	return module, nil
 }
 
+func (s *Service) RefreshModule(ctx context.Context, id string) (*Module, error) {
+	module, err := s.db.getModuleByID(ctx, id)
+	if err != nil {
+		return nil, err
+	}
+
+	_, err = s.organization.CanAccess(ctx, rbac.CreateModuleVersionAction, module.Organization)
+	if err != nil {
+		return nil, err
+	}
+
+	client, err := s.vcsproviders.GetVCSClient(ctx, module.Connection.VCSProviderID)
+	if err != nil {
+		return nil, err
+	}
+
+	tags, err := client.ListTags(ctx, vcs.ListTagsOptions{
+		Repo: module.Connection.Repo,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	exists := map[string]bool{}
+	for _, tag := range tags {
+		_, version, found := strings.Cut(tag, "/")
+		finalVersion := strings.TrimPrefix(version, "v")
+
+		if found {
+			exists[finalVersion] = true
+		}
+	}
+
+	for _, tag := range tags {
+		// tags/<version> -> <version>
+		_, version, found := strings.Cut(tag, "/")
+		if !found {
+			return nil, fmt.Errorf("malformed git ref: %s", tag)
+		}
+		// skip tags that are not semantic versions
+		if !semver.IsValid(version) {
+			continue
+		}
+
+		finalVersion := strings.TrimPrefix(version, "v")
+
+		// if it already exists then continue
+		if _, ok := exists[finalVersion]; ok {
+			continue
+		}
+
+		err := s.PublishVersion(ctx, PublishVersionOptions{
+			ModuleID: module.ID,
+			// strip off v prefix if it has one
+			Version: finalVersion,
+			Ref:     tag,
+			Repo:    Repo(module.Connection.Repo),
+			Client:  client,
+		})
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	module, err = s.db.getModuleByID(ctx, id)
+	if err != nil {
+		return nil, err
+	}
+
+	return module, nil
+}
+
 func (s *Service) CreateVersion(ctx context.Context, opts CreateModuleVersionOptions) (*ModuleVersion, error) {
 	module, err := s.db.getModuleByID(ctx, opts.ModuleID)
 	if err != nil {

internal/module/web.go

@@ -46,6 +46,7 @@ type (
 		ListModules(context.Context, ListModulesOptions) ([]*Module, error)
 		PublishModule(context.Context, PublishOptions) (*Module, error)
 		DeleteModule(ctx context.Context, id string) (*Module, error)
+		RefreshModule(ctx context.Context, id string) (*Module, error)
 	}
 
 	// vcsprovidersClient provides web handlers with access to vcs providers
@@ -66,6 +67,7 @@ func (h *webHandlers) addHandlers(r *mux.Router) {
 	r.HandleFunc("/organizations/{organization_name}/modules/create", h.publish).Methods("POST")
 	r.HandleFunc("/modules/{module_id}", h.get).Methods("GET")
 	r.HandleFunc("/modules/{module_id}/delete", h.delete).Methods("POST")
+	r.HandleFunc("/modules/{module_id}/refresh", h.refresh).Methods("POST")
 }
 
 func (h *webHandlers) list(w http.ResponseWriter, r *http.Request) {
@@ -165,6 +167,25 @@ func (h *webHandlers) get(w http.ResponseWriter, r *http.Request) {
 	})
 }
 
+func (h *webHandlers) refresh(w http.ResponseWriter, r *http.Request) {
+	var params struct {
+		ID string `schema:"module_id,required"`
+	}
+	if err := decode.All(&params, r); err != nil {
+		h.Error(w, err.Error(), http.StatusUnprocessableEntity)
+		return
+	}
+
+	module, err := h.client.RefreshModule(r.Context(), params.ID)
+	if err != nil {
+		h.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	html.FlashSuccess(w, "refreshed module: "+module.Name)
+	http.Redirect(w, r, paths.Module(module.ID), http.StatusFound)
+}
+
 func (h *webHandlers) new(w http.ResponseWriter, r *http.Request) {
 	var params struct {
 		Step newModuleStep `schema:"step"`