add: get airdrop params endpoint, update: verifier config with allowe…

…d parameters (event_id, selector), use new version of zkverifier kit

config.yaml

@@ -19,6 +19,8 @@ verifier:
   verification_key_path: "./verification_key.json"
   allowed_age: 18
   allowed_citizenships: ["UKR"]
+  allowed_event_id: "event_id"
+  allowed_query_selector: "query_selector"
   # at least one of these should be correct to pass:
   allowed_identity_count: 1
   allowed_identity_timestamp: 1715698750

docs/spec/components/schemas/AirdropParams.yaml

@@ -0,0 +1,26 @@
+allOf:
+  - $ref: '#/components/schemas/AirdropKey'
+  - type: object
+    required:
+      - attributes
+    properties:
+      attributes:
+        type: object
+        required:
+          - event_id
+          - query_selector
+          - started_at
+        properties:
+          event_id:
+            type: string
+            description: Event identifier that is generated during ZKP query creation
+            example: "304351862882731539112827930982999985591702317710421481944329166111111129570"
+          started_at:
+            type: integer
+            format: int64
+            description: Unix timestamp in seconds when airdrop event starts
+            example: 1716381206
+          query_selector:
+            type: string
+            description: Query selector that is used for proof generation
+            example: 123

docs/spec/paths/integrations@airdrop-svc@airdrops@params.yaml

@@ -0,0 +1,17 @@
+get:
+  tags:
+    - Airdrop
+  summary: Get airdrop event parameters
+  description: Get an airdrop parameters for integration.
+  operationId: GetAirdropParams
+  responses:
+    200:
+      content:
+        application/vnd.api+json:
+          schema:
+            type: object
+            required:
+              - data
+            properties:
+              data:
+                $ref: '#/components/schemas/AirdropParams'

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/go-ozzo/ozzo-validation/v4 v4.3.0
 	github.com/iden3/go-rapidsnark/types v0.0.3
 	github.com/rarimo/rarimo-core v0.0.0-20231004143803-6b209428ecbf
-	github.com/rarimo/zkverifier-kit v0.2.1-rc.3
+	github.com/rarimo/zkverifier-kit v0.2.1-rc.5
 	github.com/rubenv/sql-migrate v1.6.1
 	gitlab.com/distributed_lab/ape v1.7.1
 	gitlab.com/distributed_lab/figure/v3 v3.1.4

go.sum

@@ -2106,8 +2106,10 @@ github.com/rarimo/cosmos-sdk v0.46.7 h1:jU2PiWzc+19SF02cXM0O0puKPeH1C6Q6t2lzJ9s1
 github.com/rarimo/cosmos-sdk v0.46.7/go.mod h1:fqKqz39U5IlEFb4nbQ72951myztsDzFKKDtffYJ63nk=
 github.com/rarimo/rarimo-core v0.0.0-20231004143803-6b209428ecbf h1:NvYhOErW0d7ohn2YzGxQYKssrgVrKOvjrKL1OBQgCB4=
 github.com/rarimo/rarimo-core v0.0.0-20231004143803-6b209428ecbf/go.mod h1:Onkd0EJP94hw4dT/2KH7QXRwDG4eIGeaMffSjA1i6/s=
-github.com/rarimo/zkverifier-kit v0.2.1-rc.3 h1:E0cxfFiKL+84zdsQYpJCMdv8FYPvvkK/GVGsgd6Lk30=
-github.com/rarimo/zkverifier-kit v0.2.1-rc.3/go.mod h1:ROaCxusG9WLNwbqlTBKqZCm8tQrNdnwLyRWtS+yxO8o=
+github.com/rarimo/zkverifier-kit v0.2.1-rc.4 h1:ZpCY2toKFroHK6lpttrkZ0wvb27JbZU5L15N8KSfblc=
+github.com/rarimo/zkverifier-kit v0.2.1-rc.4/go.mod h1:3YDg5dTkDRr4IdfaDHGYetopd6gS/2SuwSeseYTWwNw=
+github.com/rarimo/zkverifier-kit v0.2.1-rc.5 h1:NN7iW40q3p6EIfAd7bxF0XdisV8AyrMQJ3g28FUstZw=
+github.com/rarimo/zkverifier-kit v0.2.1-rc.5/go.mod h1:3YDg5dTkDRr4IdfaDHGYetopd6gS/2SuwSeseYTWwNw=
 github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 h1:N/ElC8H3+5XpJzTSTfLsJV/mx9Q9g7kxmchpfZyxgzM=
 github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
 github.com/regen-network/cosmos-proto v0.3.1 h1:rV7iM4SSFAagvy8RiyhiACbWEGotmqzywPxOvwMdxcg=

internal/config/verifier.go

@@ -8,14 +8,25 @@ import (
 	"gitlab.com/distributed_lab/kit/kv"
 )
 
-const proofEventIDValue = "304358862882731539112827930982999386691702727710421481944329166126417129570"
+type GlobalParams struct {
+	EventID       string
+	QuerySelector string
+	AirdropStart  int64
+}
+
+type Verifierer struct {
+	Params     GlobalParams
+	ZkVerifier *zk.Verifier
+}
 
-func (c *Config) Verifier() *zk.Verifier {
+func (c *Config) Verifier() *Verifierer {
 	return c.verifier.Do(func() interface{} {
 		var cfg struct {
 			VerificationKeyPath      string   `fig:"verification_key_path,required"`
 			AllowedAge               int      `fig:"allowed_age,required"`
 			AllowedCitizenships      []string `fig:"allowed_citizenships,required"`
+			AllowedQuerySelector     string   `fig:"allowed_query_selector,required"`
+			AllowedEventID           string   `fig:"allowed_event_id,required"`
 			AllowedIdentityCount     int64    `fig:"allowed_identity_count,required"`
 			AllowedIdentityTimestamp int64    `fig:"allowed_identity_timestamp,required"`
 		}
@@ -33,8 +44,9 @@ func (c *Config) Verifier() *zk.Verifier {
 			zk.WithVerificationKeyFile(cfg.VerificationKeyPath),
 			zk.WithCitizenships(cfg.AllowedCitizenships...),
 			zk.WithAgeAbove(cfg.AllowedAge),
-			zk.WithEventID(proofEventIDValue),
-			zk.WithRootVerifier(c.ProvideVerifier()),
+			zk.WithProofSelectorValue(cfg.AllowedQuerySelector),
+			zk.WithEventID(cfg.AllowedEventID),
+			zk.WithIdentityVerifier(c.ProvideVerifier()),
 			zk.WithIdentitiesCounter(cfg.AllowedIdentityCount),
 			zk.WithIdentitiesCreationTimestampLimit(cfg.AllowedIdentityTimestamp),
 		)
@@ -43,6 +55,13 @@ func (c *Config) Verifier() *zk.Verifier {
 			panic(fmt.Errorf("failed to initialize passport verifier: %w", err))
 		}
 
-		return v
-	}).(*zk.Verifier)
+		return &Verifierer{
+			ZkVerifier: v,
+			Params: GlobalParams{
+				AirdropStart:  cfg.AllowedIdentityTimestamp,
+				EventID:       cfg.AllowedEventID,
+				QuerySelector: cfg.AllowedQuerySelector,
+			},
+		}
+	}).(*Verifierer)
 }

internal/service/handlers/ctx.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 
+	"github.com/rarimo/airdrop-svc/internal/config"
 	"github.com/rarimo/airdrop-svc/internal/data"
 	zk "github.com/rarimo/zkverifier-kit"
 	"gitlab.com/distributed_lab/logan/v3"
@@ -16,6 +17,7 @@ const (
 	airdropsQCtxKey
 	airdropAmountCtxKey
 	verifierCtxKey
+	airdropParamsCtxKey
 )
 
 func CtxLog(entry *logan.Entry) func(context.Context) context.Context {
@@ -48,6 +50,16 @@ func AirdropAmount(r *http.Request) string {
 	return r.Context().Value(airdropAmountCtxKey).(string)
 }
 
+func CtxAirdropParams(amount config.GlobalParams) func(context.Context) context.Context {
+	return func(ctx context.Context) context.Context {
+		return context.WithValue(ctx, airdropParamsCtxKey, amount)
+	}
+}
+
+func AirdropParams(r *http.Request) config.GlobalParams {
+	return r.Context().Value(airdropParamsCtxKey).(config.GlobalParams)
+}
+
 func CtxVerifier(entry *zk.Verifier) func(context.Context) context.Context {
 	return func(ctx context.Context) context.Context {
 		return context.WithValue(ctx, verifierCtxKey, entry)

internal/service/handlers/get_airdrop_params.go

@@ -0,0 +1,23 @@
+package handlers
+
+import (
+	"net/http"
+
+	"github.com/rarimo/airdrop-svc/resources"
+	"gitlab.com/distributed_lab/ape"
+)
+
+func GetAirdropParams(w http.ResponseWriter, r *http.Request) {
+	ape.Render(w, resources.AirdropParamsResponse{
+		Data: resources.AirdropParams{
+			Key: resources.Key{
+				Type: resources.AIRDROP,
+			},
+			Attributes: resources.AirdropParamsAttributes{
+				EventId:       AirdropParams(r).EventID,
+				StartedAt:     AirdropParams(r).AirdropStart,
+				QuerySelector: AirdropParams(r).QuerySelector,
+			},
+		},
+	})
+}

internal/service/router.go

@@ -19,14 +19,16 @@ func Run(ctx context.Context, cfg *config.Config) {
 		ape.LoganMiddleware(cfg.Log()),
 		ape.CtxMiddleware(
 			handlers.CtxLog(cfg.Log()),
-			handlers.CtxVerifier(cfg.Verifier()),
+			handlers.CtxVerifier(cfg.Verifier().ZkVerifier),
 			handlers.CtxAirdropAmount(cfg.Broadcaster().AirdropCoins.String()),
+			handlers.CtxAirdropParams(cfg.Verifier().Params),
 		),
 		handlers.DBCloneMiddleware(cfg.DB()),
 	)
 	r.Route("/integrations/airdrop-svc/airdrops", func(r chi.Router) {
 		r.Post("/", handlers.CreateAirdrop)
 		r.Get("/{nullifier}", handlers.GetAirdrop)
+		r.Get("/params", handlers.GetAirdropParams)
 	})
 
 	cfg.Log().Info("Service started")

resources/model_airdrop_params.go

@@ -0,0 +1,43 @@
+/*
+ * GENERATED. Do not modify. Your changes might be overwritten!
+ */
+
+package resources
+
+import "encoding/json"
+
+type AirdropParams struct {
+	Key
+	Attributes AirdropParamsAttributes `json:"attributes"`
+}
+type AirdropParamsResponse struct {
+	Data     AirdropParams `json:"data"`
+	Included Included      `json:"included"`
+}
+
+type AirdropParamsListResponse struct {
+	Data     []AirdropParams `json:"data"`
+	Included Included        `json:"included"`
+	Links    *Links          `json:"links"`
+	Meta     json.RawMessage `json:"meta,omitempty"`
+}
+
+func (r *AirdropParamsListResponse) PutMeta(v interface{}) (err error) {
+	r.Meta, err = json.Marshal(v)
+	return err
+}
+
+func (r *AirdropParamsListResponse) GetMeta(out interface{}) error {
+	return json.Unmarshal(r.Meta, out)
+}
+
+// MustAirdropParams - returns AirdropParams from include collection.
+// if entry with specified key does not exist - returns nil
+// if entry with specified key exists but type or ID mismatches - panics
+func (c *Included) MustAirdropParams(key Key) *AirdropParams {
+	var airdropParams AirdropParams
+	if c.tryFindEntry(key, &airdropParams) {
+		return &airdropParams
+	}
+	return nil
+}

resources/model_airdrop_params_attributes.go

@@ -0,0 +1,14 @@
+/*
+ * GENERATED. Do not modify. Your changes might be overwritten!
+ */
+
+package resources
+
+type AirdropParamsAttributes struct {
+	// Event identifier that is generated during ZKP query creation
+	EventId string `json:"event_id"`
+	// Query selector that is used for proof generation
+	QuerySelector string `json:"query_selector"`
+	// Unix timestamp in seconds when airdrop event starts
+	StartedAt int64 `json:"started_at"`
+}