Merge branch 'main' into issue-52

.github/CODEOWNERS

@@ -0,0 +1,9 @@
+/api/ @numary/core
+/cmd/ @numary/core
+/config/ @numary/core
+/core/ @numary/core
+/ledger/ @numary/core
+*.go @numary/core
+
+/.devcontainer @flemzord
+/.github @flemzord

.github/labeler.yml

@@ -0,0 +1,23 @@
+'@domain/core':
+  - core/*
+  - core/**/*
+
+'@domain/api':
+  - api/*
+  - api/**/*
+
+'@domain/ledger':
+  - ledger/*
+  - ledger/**/*
+
+'@domain/storage':
+  - storage/*
+  - storage/**/*
+
+'@domain/cmd':
+  - cmd/*
+  - cmd/**/*
+
+'@domain/ci':
+  - .github/*
+  - .github/**/*

.github/workflows/pr_open_target.yml

@@ -0,0 +1,12 @@
+name: "Pull Request Labeler"
+on:
+  - pull_request_target
+  - pull_request
+
+jobs:
+  Triage:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/labeler@v3
+        with:
+          repo-token: "${{ secrets.GITHUB_TOKEN }}"

api/http.go

@@ -89,10 +89,11 @@ func NewHttpAPI(lc fx.Lifecycle, resolver *ledger.Resolver) *HttpAPI {
 
 	r.GET("/:ledger/transactions", func(c *gin.Context) {
 		l, _ := c.Get("ledger")
+		ref := c.Query("reference")
 
 		cursor, err := l.(*ledger.Ledger).FindTransactions(
 			query.After(c.Query("after")),
-			query.Account(c.Query("account")),
+			query.Reference(ref),
 		)
 
 		c.JSON(200, gin.H{

ledger/query/query.go

@@ -80,3 +80,9 @@ func Destination(v string) func(*Query) {
 		q.Params["destination"] = v
 	}
 }
+
+func Reference(v string) func(*Query) {
+	return func(q *Query) {
+		q.Params["reference"] = v
+	}
+}

storage/postgres/transactions.go

@@ -143,6 +143,12 @@ func (s *PGStore) FindTransactions(q query.Query) (query.Cursor, error) {
 		))
 	}
 
+	if q.HasParam("reference") {
+		in.Where(
+			in.Equal("reference", q.Params["reference"]),
+		)
+	}
+
 	sb := sqlbuilder.NewSelectBuilder()
 	sb.Select(
 		"t.id",

storage/sqlite/transactions.go

@@ -34,6 +34,12 @@ func (s *SQLiteStore) FindTransactions(q query.Query) (query.Cursor, error) {
 		))
 	}
 
+	if q.HasParam("reference") {
+		in.Where(
+			in.Equal("reference", q.Params["reference"]),
+		)
+	}
+
 	sb := sqlbuilder.NewSelectBuilder()
 	sb.Select(
 		"t.id",