refactor: Create src folder

PedroChaparro · PedroChaparro · commit df9c4d6b2fee · 2024-01-06T09:59:50.000-05:00
diff --git a/main.go b/main.go
@@ -1,7 +1,7 @@
 package main
 
 import (
-	"github.com/upb-code-labs/tests-microservice/infrastructure/rabbitmq"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure/rabbitmq"
 )
 
 func main() {
diff --git a/src/application/submissions-use-cases.go b/src/application/submissions-use-cases.go
@@ -1,11 +1,11 @@
 package application
 
 import (
-	"github.com/upb-code-labs/tests-microservice/domain/definitions"
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
-	"github.com/upb-code-labs/tests-microservice/domain/entities"
-	"github.com/upb-code-labs/tests-microservice/infrastructure/static_files"
-	"github.com/upb-code-labs/tests-microservice/utils"
+	"github.com/upb-code-labs/tests-microservice/src/domain/definitions"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/domain/entities"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure/static_files"
+	"github.com/upb-code-labs/tests-microservice/src/utils"
 )
 
 type SubmissionsUseCases struct{}
diff --git a/src/domain/definitions/archives_manager.go b/src/domain/definitions/archives_manager.go
diff --git a/src/domain/definitions/language-tests-runner.go b/src/domain/definitions/language-tests-runner.go
@@ -1,7 +1,7 @@
 package definitions
 
 import (
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
 )
 
 type LanguageTestsRunner interface {
diff --git a/src/domain/definitions/submission-status-updates-queue-manager.go b/src/domain/definitions/submission-status-updates-queue-manager.go
@@ -1,6 +1,6 @@
 package definitions
 
-import "github.com/upb-code-labs/tests-microservice/domain/dtos"
+import "github.com/upb-code-labs/tests-microservice/src/domain/dtos"
 
 type SubmissionStatusUpdatesQueueManager interface {
 	QueueUpdate(updateDTO *dtos.SubmissionStatusUpdateDTO) error
diff --git a/src/domain/dtos/dtos.go b/src/domain/dtos/dtos.go
diff --git a/src/domain/entities/entities.go b/src/domain/entities/entities.go
diff --git a/src/infrastructure/environment.go b/src/infrastructure/environment.go
diff --git a/src/infrastructure/implementations/archives_manager.go b/src/infrastructure/implementations/archives_manager.go
diff --git a/src/infrastructure/implementations/java-tests-runner.go b/src/infrastructure/implementations/java-tests-runner.go
@@ -11,8 +11,8 @@ import (
 	"strings"
 	"time"
 
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
-	"github.com/upb-code-labs/tests-microservice/infrastructure"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure"
 )
 
 type JavaTestsRunner struct{}
diff --git a/src/infrastructure/rabbitmq/connection.go b/src/infrastructure/rabbitmq/connection.go
@@ -4,7 +4,7 @@ import (
 	"log"
 
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/upb-code-labs/tests-microservice/infrastructure"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure"
 )
 
 var rabbitMQChannel *amqp.Channel
diff --git a/src/infrastructure/rabbitmq/submission-queue.go b/src/infrastructure/rabbitmq/submission-queue.go
@@ -5,10 +5,10 @@ import (
 	"log"
 
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/upb-code-labs/tests-microservice/application"
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
-	"github.com/upb-code-labs/tests-microservice/domain/entities"
-	"github.com/upb-code-labs/tests-microservice/utils"
+	"github.com/upb-code-labs/tests-microservice/src/application"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/domain/entities"
+	"github.com/upb-code-labs/tests-microservice/src/utils"
 )
 
 type SubmissionQueueMgr struct {
@@ -131,6 +131,9 @@ func (manager *SubmissionQueueMgr) processSubmission(msg amqp.Delivery) {
 		return
 	}
 
+	// Log message to console
+	log.Println("[RabbitMQ]: Received submission status update", submissionWork.SubmissionUUID)
+
 	// Send submission status update
 	statusDTO := &dtos.SubmissionStatusUpdateDTO{
 		SubmissionUUID:   submissionWork.SubmissionUUID,
diff --git a/src/infrastructure/rabbitmq/submission-status-updates-queue.go b/src/infrastructure/rabbitmq/submission-status-updates-queue.go
@@ -7,7 +7,7 @@ import (
 	"time"
 
 	amqp "github.com/rabbitmq/amqp091-go"
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
 )
 
 type SubmissionStatusUpdatesQueueMgr struct {
diff --git a/src/infrastructure/static_files/handler.go b/src/infrastructure/static_files/handler.go
@@ -8,8 +8,8 @@ import (
 	"io"
 	"net/http"
 
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
-	"github.com/upb-code-labs/tests-microservice/infrastructure"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure"
 )
 
 type StaticFilesManager struct{}
diff --git a/src/utils/utils.go b/src/utils/utils.go
@@ -3,9 +3,9 @@ package utils
 import (
 	"errors"
 
-	"github.com/upb-code-labs/tests-microservice/domain/definitions"
-	"github.com/upb-code-labs/tests-microservice/domain/dtos"
-	"github.com/upb-code-labs/tests-microservice/infrastructure/implementations"
+	"github.com/upb-code-labs/tests-microservice/src/domain/definitions"
+	"github.com/upb-code-labs/tests-microservice/src/domain/dtos"
+	"github.com/upb-code-labs/tests-microservice/src/infrastructure/implementations"
 )
 
 func GetTestRunnerByLanguageUUID(languageUUID string) (runner definitions.LanguageTestsRunner, err error) {

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`package main`
`2`	`2`
`3`	`3`	`import (`
`4`		`- "github.com/upb-code-labs/tests-microservice/infrastructure/rabbitmq"`
	`4`	`+ "github.com/upb-code-labs/tests-microservice/src/infrastructure/rabbitmq"`
`5`	`5`	`)`
`6`	`6`
`7`	`7`	`func main() {`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`package definitions`
`2`	`2`
`3`	`3`	`import (`
`4`		`- "github.com/upb-code-labs/tests-microservice/domain/dtos"`
	`4`	`+ "github.com/upb-code-labs/tests-microservice/src/domain/dtos"`
`5`	`5`	`)`
`6`	`6`
`7`	`7`	`type LanguageTestsRunner interface {`
Original file line number	Diff line number	Diff line change
`@@ -11,8 +11,8 @@ import (`
`11`	`11`	`"strings"`
`12`	`12`	`"time"`
`13`	`13`
`14`		`- "github.com/upb-code-labs/tests-microservice/domain/dtos"`
`15`		`- "github.com/upb-code-labs/tests-microservice/infrastructure"`
	`14`	`+ "github.com/upb-code-labs/tests-microservice/src/domain/dtos"`
	`15`	`+ "github.com/upb-code-labs/tests-microservice/src/infrastructure"`
`16`	`16`	`)`
`17`	`17`
`18`	`18`	`type JavaTestsRunner struct{}`
Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ import (`
`4`	`4`	`"log"`
`5`	`5`
`6`	`6`	`amqp "github.com/rabbitmq/amqp091-go"`
`7`		`- "github.com/upb-code-labs/tests-microservice/infrastructure"`
	`7`	`+ "github.com/upb-code-labs/tests-microservice/src/infrastructure"`
`8`	`8`	`)`
`9`	`9`
`10`	`10`	`var rabbitMQChannel *amqp.Channel`
Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@ import (`
`7`	`7`	`"time"`
`8`	`8`
`9`	`9`	`amqp "github.com/rabbitmq/amqp091-go"`
`10`		`- "github.com/upb-code-labs/tests-microservice/domain/dtos"`
	`10`	`+ "github.com/upb-code-labs/tests-microservice/src/domain/dtos"`
`11`	`11`	`)`
`12`	`12`
`13`	`13`	`type SubmissionStatusUpdatesQueueMgr struct {`
Original file line number	Diff line number	Diff line change
`@@ -8,8 +8,8 @@ import (`
`8`	`8`	`"io"`
`9`	`9`	`"net/http"`
`10`	`10`
`11`		`- "github.com/upb-code-labs/tests-microservice/domain/dtos"`
`12`		`- "github.com/upb-code-labs/tests-microservice/infrastructure"`
	`11`	`+ "github.com/upb-code-labs/tests-microservice/src/domain/dtos"`
	`12`	`+ "github.com/upb-code-labs/tests-microservice/src/infrastructure"`
`13`	`13`	`)`
`14`	`14`
`15`	`15`	`type StaticFilesManager struct{}`