fix: remove check if source exists
All checks were successful
Gitea Build Check / Build (push) Successful in 9m47s
All checks were successful
Gitea Build Check / Build (push) Successful in 9m47s
This commit is contained in:
parent
521c11ee2e
commit
0b800ff423
@ -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
|
||||
|
Reference in New Issue
Block a user