added the Aviato plugin

Author: caffix

engine/plugins/api/aviato/plugin.go

@@ -0,0 +1,63 @@
+// Copyright © by Jeff Foley 2017-2025. All rights reserved.
+// Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.
+// SPDX-License-Identifier: Apache-2.0
+
+package aviato
+
+import (
+	"errors"
+	"time"
+
+	et "github.com/owasp-amass/amass/v4/engine/types"
+	dbt "github.com/owasp-amass/asset-db/types"
+	oam "github.com/owasp-amass/open-asset-model"
+	"github.com/owasp-amass/open-asset-model/general"
+	"golang.org/x/time/rate"
+)
+
+func NewAviato() et.Plugin {
+	limit := rate.Every(3 * time.Second)
+
+	return &aviato{
+		name:   "Aviato",
+		rlimit: rate.NewLimiter(limit, 1),
+		source: &et.Source{
+			Name:       "Aviato",
+			Confidence: 90,
+		},
+	}
+}
+
+func (a *aviato) Name() string {
+	return a.name
+}
+
+func (a *aviato) Start(r et.Registry) error {
+	a.log = r.Log().WithGroup("plugin").With("name", a.name)
+
+	a.log.Info("Plugin started")
+	return nil
+}
+
+func (a *aviato) Stop() {
+	a.log.Info("Plugin stopped")
+}
+
+func (a *aviato) createRelation(session et.Session, obj *dbt.Entity, rel oam.Relation, subject *dbt.Entity, conf int) error {
+	edge, err := session.Cache().CreateEdge(&dbt.Edge{
+		Relation:   rel,
+		FromEntity: obj,
+		ToEntity:   subject,
+	})
+	if err != nil {
+		return err
+	} else if edge == nil {
+		return errors.New("failed to create the edge")
+	}
+
+	_, err = session.Cache().CreateEdgeProperty(edge, &general.SourceProperty{
+		Source:     a.source.Name,
+		Confidence: conf,
+	})
+	return err
+}

engine/plugins/api/aviato/types.go

@@ -0,0 +1,19 @@
+// Copyright © by Jeff Foley 2017-2025. All rights reserved.
+// Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.
+// SPDX-License-Identifier: Apache-2.0
+
+package aviato
+
+import (
+	"log/slog"
+
+	et "github.com/owasp-amass/amass/v4/engine/types"
+	"golang.org/x/time/rate"
+)
+
+type aviato struct {
+	name   string
+	log    *slog.Logger
+	rlimit *rate.Limiter
+	source *et.Source
+}

engine/plugins/load.go

@@ -6,6 +6,7 @@ package plugins
 
 import (
 	"github.com/owasp-amass/amass/v4/engine/plugins/api"
+	"github.com/owasp-amass/amass/v4/engine/plugins/api/aviato"
 	"github.com/owasp-amass/amass/v4/engine/plugins/api/gleif"
 	"github.com/owasp-amass/amass/v4/engine/plugins/api/rdap"
 	"github.com/owasp-amass/amass/v4/engine/plugins/archive"
@@ -36,6 +37,7 @@ var pluginNewFuncs = []func() et.Plugin{
 	api.NewVirusTotal,
 	api.NewZetalytics,
 	archive.NewWayback,
+	aviato.NewAviato,
 	bgptools.NewBGPTools,
 	brute.NewFQDNAlterations,
 	dns.NewDNS,