feat: remove ipfs service (#45)

cmd/cas/main.go

@@ -193,20 +193,6 @@ func main() {
 		logger.Fatalf("error creating status queue: %v", err)
 	}
 
-	// ipfs queue
-	ipfsQueue, err := queue.NewPublisher(
-		serverCtx,
-		sqsClient,
-		queue.PublisherOpts{
-			QueueType:         queue.QueueType_IPFS,
-			VisibilityTimeout: visibilityTimeout,
-			RedrivePolicy:     redrivePolicy,
-		},
-	)
-	if err != nil {
-		logger.Fatalf("error creating ipfs queue: %v", err)
-	}
-
 	// Create utilization gauges for all the queues
 	if err = metricService.QueueGauge(serverCtx, deadLetterQueue.GetName(), queue.NewMonitor(deadLetterQueue.GetUrl(), sqsClient)); err != nil {
 		logger.Fatalf("error creating gauge for dead-letter queue: %v", err)
@@ -227,9 +213,6 @@ func main() {
 	if err = metricService.QueueGauge(serverCtx, statusQueue.GetName(), queue.NewMonitor(statusQueue.GetUrl(), sqsClient)); err != nil {
 		logger.Fatalf("error creating gauge for status queue: %v", err)
 	}
-	if err = metricService.QueueGauge(serverCtx, ipfsQueue.GetName(), queue.NewMonitor(ipfsQueue.GetUrl(), sqsClient)); err != nil {
-		logger.Fatalf("error creating gauge for ipfs queue: %v", err)
-	}
 
 	// Create the queue consumers. These consumers will be responsible for scaling event processing up based on load and
 	// also maintaining backpressure on the queues.
@@ -243,10 +226,6 @@ func main() {
 	statusService := services.NewStatusService(anchorDb, metricService, logger)
 	statusConsumer := queue.NewConsumer(logger, statusQueue, statusService.Status, nil)
 
-	// The IPFS service reads from the IPFS queue and puts or publishes
-	ipfsService := services.NewIpfsService(logger, metricService)
-	ipfsConsumer := queue.NewConsumer(logger, ipfsQueue, ipfsService.Run, nil)
-
 	// The Batching service reads from the Ready queue and posts to the Batch queue
 	anchorBatchSize := models.DefaultAnchorBatchSize
 	if configAnchorBatchSize, found := os.LookupEnv(models.Env_AnchorBatchSize); found {
@@ -307,7 +286,6 @@ func main() {
 		batchWg.Wait()
 
 		statusConsumer.Shutdown()
-		ipfsConsumer.Shutdown()
 		failureConsumer.Shutdown()
 		dlqConsumer.Shutdown()
 
@@ -330,7 +308,6 @@ func main() {
 	dlqConsumer.Start()
 	failureConsumer.Start()
 	statusConsumer.Start()
-	ipfsConsumer.Start()
 	batchingConsumer.Start()
 	validationConsumer.Start()
 

common/aws/queue/utils.go

@@ -25,7 +25,6 @@ const (
 	QueueType_Status   QueueType = "status"
 	QueueType_Failure  QueueType = "failure"
 	QueueType_DLQ      QueueType = "dlq"
-	QueueType_IPFS     QueueType = "ipfs"
 )
 
 const defaultVisibilityTimeout = 5 * time.Minute