diff --git a/pkg/plug/server.go b/pkg/plug/server.go index 5fb1a57..14b41da 100644 --- a/pkg/plug/server.go +++ b/pkg/plug/server.go @@ -3,12 +3,10 @@ package plug import ( "context" "fmt" - "github.com/pkg/errors" "log" "net" "git.anthrove.art/Anthrove/otter-space-sdk/v3/pkg/database" - otterError "git.anthrove.art/Anthrove/otter-space-sdk/v3/pkg/error" "git.anthrove.art/Anthrove/otter-space-sdk/v3/pkg/models" "github.com/golang/protobuf/ptypes/timestamp" @@ -50,16 +48,9 @@ func (p *Plug) Listen() error { var err error var source models.Source - newDBerr := func() error { - return &otterError.Database{Reason: otterError.NoDataFound} - } - - noDataFoundError := newDBerr() - source, err = database.GetSourceByDomain(p.ctx, p.source.Domain) if err != nil { - - if errors.Is(err, noDataFoundError) { + if err.Error() == "Database error: NoDataFound" { log.Printf("Initalizing source!") source, err = database.CreateSource(p.ctx, p.source) if err != nil {