comments

registry/internal/core/ordering.go

@@ -5,13 +5,14 @@ import (
 	"eCommerce/registry/internal/api/requests"
 	"eCommerce/registry/internal/models"
 	"errors"
+	"time"
+
 	"github.com/segmentio/kafka-go"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 	"go.mongodb.org/mongo-driver/mongo"
 	"go.mongodb.org/mongo-driver/mongo/options"
 	"go.uber.org/zap"
-	"time"
 )
 
 type PurchaseController interface {
@@ -46,7 +47,7 @@ func (p *Purchaser) Order(userId primitive.ObjectID, r *requests.OrderRequest) (
 	order := new(models.Order)
 	order.UserId = userId
 	order.Status = models.OrderPending
-	order.Timestamp = time.Now().UTC()
+	order.Timestamp = time.Now().UTC() // Здесь есть некоторая проблема. Можешь порассуждать?
 	order.Items = r.Items
 	order.Updates = []models.OrderUpdate{
 		{

registry/internal/core/registry.go

@@ -7,15 +7,16 @@ import (
 	"eCommerce/registry/internal/models"
 	"encoding/json"
 	"errors"
+	"io/ioutil"
+	"net/http"
+	"time"
+
 	"github.com/segmentio/kafka-go"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 	"go.mongodb.org/mongo-driver/mongo"
 	"go.mongodb.org/mongo-driver/mongo/options"
 	"go.uber.org/zap"
-	"io/ioutil"
-	"net/http"
-	"time"
 )
 
 type RegistryController interface {
@@ -183,6 +184,7 @@ func Identity(r *http.Request) (*models.Identity, error) {
 		return identity, nil
 	}
 
+	// А можешь пояснить, зачем столько вариантов?
 	return nil, errors.New(`no identity`)
 }
 

registry/internal/data/order_repository.go

@@ -3,18 +3,19 @@ package data
 import (
 	"context"
 	"eCommerce/registry/internal/models"
+	"time"
+
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 	"go.mongodb.org/mongo-driver/mongo"
 	"go.mongodb.org/mongo-driver/mongo/options"
-	"time"
 )
 
 type RegistryRepository interface {
 	FindOrderId(id primitive.ObjectID) (*models.Order, error)
 	UpdateOrder(id primitive.ObjectID, updates []bson.E) (*models.Order, error)
 	UpdateOrderStatus(id primitive.ObjectID, status models.OrderStatus) (*models.Order, error)
-	Commit() error
+	Commit() error // Искал, куда ты хотел вставить этот метод, но не нашёл в коде)
 }
 
 type MongoRegistryRepository struct {