[webhook] index a list of predefined attributes

webhook/attribute.go

@@ -2,11 +2,15 @@ package webhook
 
 import (
 	"fmt"
+	"slices"
 
 	"github.com/starlinglab/integrity-v2/aa"
 	"github.com/starlinglab/integrity-v2/util"
 )
 
+// list of attributes that should be indexed as string
+var indexedStringKeys []string = []string{"file_name", "asset_origin_id"}
+
 // ParseMapToAttributes parses a map and a file stat map
 // to a slice of attributes for POSTing to the AA server
 // It also reads the encryption keys from the filesystem,
@@ -30,6 +34,8 @@ func ParseMapToAttributes(cid string, attrMap map[string]any, fileAttributes map
 				}
 				attributes = append(attributes, aa.PostKV{Key: pKey, Value: pValue, EncKey: encKey})
 			}
+		} else if slices.Contains(indexedStringKeys, key) {
+			attributes = append(attributes, aa.PostKV{Key: key, Value: value, Type: "str"})
 		} else {
 			attributes = append(attributes, aa.PostKV{Key: key, Value: value})
 		}

webhook/webhook.go

@@ -179,7 +179,7 @@ func handleGenericFileUpload(w http.ResponseWriter, r *http.Request) {
 		writeJsonResponse(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})
 		return
 	}
-	err = aa.SetAttestations(cid, false, attributes)
+	err = aa.SetAttestations(cid, true, attributes)
 	if err != nil {
 		fmt.Println("Error setting attestations:", err)
 		writeJsonResponse(w, http.StatusInternalServerError, map[string]string{"error": err.Error()})