From 0b800ff423cbe6bef64a46737f62868ac6ac4b57 Mon Sep 17 00:00:00 2001 From: SoXX Date: Mon, 8 Jul 2024 21:08:37 +0200 Subject: [PATCH] fix: remove check if source exists --- pkg/plug/server.go | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/pkg/plug/server.go b/pkg/plug/server.go index 8f9ac15..d77d7ec 100644 --- a/pkg/plug/server.go +++ b/pkg/plug/server.go @@ -38,19 +38,12 @@ func NewPlug(ctx context.Context, address string, port string, source models.Sou func (p *Plug) Listen() error { var err error - plugSource, err := p.database.GetSourceByDomain(p.ctx, models.AnthroveSourceDomain(p.source.Domain)) + log.Printf("initilazing source!") + err = p.database.CreateSource(p.ctx, &p.source) if err != nil { return err } - if plugSource == nil { - log.Printf("no source found for domain %s, initilazing source!", p.source.Domain) - err := p.database.CreateSource(p.ctx, &p.source) - if err != nil { - return err - } - } - lis, err := net.Listen("tcp", fmt.Sprintf("%s:%s", p.address, p.port)) if err != nil { return err