Barretthousen
/
barretthousen
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Activity

cleanup
ci.vdhsn.com/push Build is failing Details

feat/kafka
Adam Veldhousen 2023-06-11 22:53:58 -05:00
parent bf6e10a856
commit 865a8c670d
Signed by: adam
GPG Key ID: 6DB29003C6DD1E4B
2 changed files with 2 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/runner/internal/domain/logic.go
View File

@ -32,7 +32,6 @@ func RegisterAuctionFinder(finder UpcomingAuctionFinder) {
type (
Domain struct {
Storage
// CatalogService
}
CompleteScrapeJobStatus struct {
@ -46,10 +45,6 @@ type (
GetJobs(context.Context) ([]ScrapeJob, error)
}
CatalogService interface {
UpdateUpcomingAuction(context.Context, catalog.Auction) (catalog.AuctionCreatedEvent, error)
}
KafkaProducer interface {
io.Closer
SendMessageJSON(map[string]string, interface{}) error
@ -125,6 +120,7 @@ func (domain *Domain) executeScrapeJob(finder UpcomingAuctionFinder, jobID int)
if p, err = kafka.NewProducer("runner.sync_results"); err != nil {
return
}
defer p.Close()
count := 0
total := 0
@ -144,17 +140,6 @@ func (domain *Domain) executeScrapeJob(finder UpcomingAuctionFinder, jobID int)
}
count++
// ace, err := domain.CatalogService.UpdateUpcomingAuction(ctx, auction)
// if err != nil {
// kernel.TraceLog.Printf("could not import upcoming auction: %s", err.Error())
// fmt.Fprintf(errs, "{ \"AuctionFingerprint\": \"%s\", \"error\": \"%s\" }\n", ace.Fingerprint, err.Error())
// continue
// }
// if !ace.Duplicate {
// count++
// }
}
if err := errGroup.Wait(); err != nil {

10
src/runner/main.go
View File

@ -6,7 +6,6 @@ import (
"flag"
"fmt"
capi "git.vdhsn.com/barretthousen/barretthousen/src/catalog/api"
"git.vdhsn.com/barretthousen/barretthousen/src/lib/kernel"
"git.vdhsn.com/barretthousen/barretthousen/src/runner/internal"
"git.vdhsn.com/barretthousen/barretthousen/src/runner/internal/data"
@ -93,16 +92,9 @@ func (app *runnerApp) Start(ctx context.Context) error {
return err
}
if err = ioc.Provide(func(conn grpc.ClientConnInterface) domain.CatalogService {
return capi.NewCatalogServiceClient(conn)
}); err != nil {
return err
}
if err = ioc.Provide(func(css domain.CatalogService, rs domain.Storage) *domain.Domain {
if err = ioc.Provide(func(rs domain.Storage) *domain.Domain {
return &domain.Domain{
Storage: rs,
// CatalogService: css,
}
}); err != nil {
return err