Add search API for packages in snapshots

api/router.go

@@ -50,6 +50,7 @@ func Router(c *ctx.AptlyContext) http.Handler {
 		root.POST("/snapshots", apiSnapshotsCreateEmpty)
 		root.PUT("/snapshots/:name", apiSnapshotsRename)
 		root.GET("/snapshots/:name", apiSnapshotsShow)
+		root.GET("/snapshots/:name/packages", apiSnapshotsSearchPackages)
 		root.DELETE("/snapshots/:name", apiSnapshotsDrop)
 		root.POST("/snapshots/:name/diff/:withSnapshot", apiSnapshotsDiff)
 	}

api/snapshot.go

@@ -2,8 +2,10 @@ package api
 
 import (
 	"fmt"
+	"sort"
 	"github.com/gin-gonic/gin"
 	"github.com/smira/aptly/deb"
+	"github.com/smira/aptly/query"
 )
 
 // GET /api/snapshots
@@ -318,3 +320,78 @@ func apiSnapshotsDiff(c *gin.Context) {
 
 	c.JSON(200, result)
 }
+
+// GET /api/snapshots/:name/packages
+func apiSnapshotsSearchPackages(c *gin.Context) {
+	collection := context.CollectionFactory().SnapshotCollection()
+	collection.RLock()
+	defer collection.RUnlock()
+
+	snapshot, err := collection.ByName(c.Params.ByName("name"))
+	if err != nil {
+		c.Fail(404, err)
+		return
+	}
+
+	err = collection.LoadComplete(snapshot)
+	if err != nil {
+		c.Fail(400, err)
+		return
+	}
+
+	reflist := snapshot.RefList()
+	result := []*deb.Package{}
+
+	list, err := deb.NewPackageListFromRefList(reflist, context.CollectionFactory().PackageCollection(), context.Progress())
+	if err != nil {
+		c.Fail(400, err)
+		return
+	}
+
+	queryS := c.Request.URL.Query().Get("q")
+	if queryS != "" {
+		q, err := query.Parse(c.Request.URL.Query().Get("q"))
+		if err != nil {
+			c.Fail(401, err)
+			return
+		}
+
+		withDeps := c.Request.URL.Query().Get("withDeps") == "1"
+		architecturesList := []string{}
+
+		if withDeps {
+			if len(context.ArchitecturesList()) > 0 {
+				architecturesList = context.ArchitecturesList()
+			} else {
+				architecturesList = list.Architectures(false)
+			}
+
+			sort.Strings(architecturesList)
+
+			if len(architecturesList) == 0 {
+				c.Fail(400, fmt.Errorf("unable to determine list of architectures, please specify explicitly"))
+				return
+			}
+		}
+
+		list.PrepareIndex()
+
+		packages, err := list.Filter([]deb.PackageQuery{q}, withDeps,
+			nil, context.DependencyOptions(), architecturesList)
+		if err != nil {
+			c.Fail(400, fmt.Errorf("unable to search: %s", err))
+		}
+
+		packages.ForEach(func(p *deb.Package) error {
+			result = append(result, p)
+			return nil
+		})
+	} else {
+		list.ForEach(func(p *deb.Package) error {
+			result = append(result, p)
+			return nil
+		})
+	}
+
+	c.JSON(200, result)
+}