small updates such as additional logging

Author: caffix

engine/plugins/api/gleif/fuzzy.go

@@ -34,7 +34,7 @@ func (fc *fuzzyCompletions) check(e *et.Event) error {
 	}
 
 	since, err := support.TTLStartTime(e.Session.Config(),
-		string(oam.Organization), string(oam.Organization), fc.plugin.name)
+		string(oam.Organization), string(oam.Identifier), fc.plugin.name)
 	if err != nil {
 		return err
 	}
@@ -115,10 +115,12 @@ func (fc *fuzzyCompletions) query(e *et.Event, orgent *dbt.Entity) *dbt.Entity {
 				} `json:"relationships"`
 			} `json:"data"`
 		}
-		if err := json.Unmarshal([]byte(resp.Body), &result); err != nil || len(result.Data) == 0 {
+		if err := json.Unmarshal([]byte(resp.Body), &result); err != nil {
 			msg := fmt.Sprintf("Failed to unmarshal the LEI record for %s: %s", o.Name, err)
 			e.Session.Log().Error(msg, slog.Group("plugin", "name", fc.plugin.name, "handler", fc.name))
 			return nil
+		} else if len(result.Data) == 0 {
+			return nil
 		}
 
 		var names []string

engine/plugins/api/gleif/org_lei.go

@@ -99,7 +99,12 @@ func (g *gleif) updateOrgFromLEIRecord(e *et.Event, orgent *dbt.Entity, lei *lei
 	_ = g.addIdentifiersToOrg(e, orgent, general.MarketIDCode, lei.Attributes.MIC, conf)
 	_ = g.addIdentifiersToOrg(e, orgent, general.OpenCorpID, []string{lei.Attributes.OCID}, conf)
 	_ = g.addIdentifiersToOrg(e, orgent, general.SPGlobalCompanyID, lei.Attributes.SPGlobal, conf)
-	_, _ = e.Session.Cache().CreateEntity(orgent)
+
+	// update the Organization
+	if _, err := e.Session.Cache().CreateEntity(orgent); err != nil {
+		msg := fmt.Sprintf("failed to update the Organization asset for %s: %s", o.Name, err)
+		e.Session.Log().Error(msg, slog.Group("plugin", "name", g.name, "handler", g.name))
+	}
 }
 
 func (g *gleif) addAddress(e *et.Event, orgent *dbt.Entity, rel oam.Relation, addr string, conf int) error {