Service Integration

Let‘s call the Recommendation Service to show user interests from the bookstore Web Service.

Move service/recommendation/domain/model/interest.go to domain/model/interest.go.

Update import paths in these files:

• service/recommendation/application/consumer/interest.go
• service/recommendation/application/executor/interest_operator.go
• service/recommendation/domain/gateway/interest_manager.go
• service/recommendation/infrastructure/database/mongo.go

Add config items in service/web/infrastructure/config/config.go:

@@ -32,4 +32,5 @@ type MQConfig struct {
 // RemoteServiceConfig is the configuration of remote services.
 type RemoteServiceConfig struct {
        TrendURL string `json:"trend_url" yaml:"trend_url"`
+       RecURL   string `json:"rec_url" yaml:"rec_url"`
 }

Put in config values in service/web/config.yml:

@@ -10,3 +10,4 @@ mq:
   topic: "lr-book-searches"
 remote:
   trend_url: "http://localhost:8081/trends"
+  rec_url: "http://localhost:8082/recommendations?uid="

Tune service/web/application/executor/book_operator.go:

@@ -61,3 +61,12 @@ func (o *BookOperator) GetTrends(ctx context.Context, trendURL string) ([]*model
        }
        return trends, nil
 }
+
+// GetInterests gets a list of user interests from the remote service
+func (o *BookOperator) GetInterests(ctx context.Context, interestURL string) ([]*model.Interest, error) {
+       var interests []*model.Interest
+       if err := remote.HttpFetch(ctx, interestURL, &interests); err != nil {
+               return nil, err
+       }
+       return interests, nil
+}

Integrate the recommendation service results in service/web/adapter/router.go:

@@ -75,12 +75,18 @@ func (r *RestHandler) indexPage(c *gin.Context) {
                log.Printf("Failed to get trends: %v", err)
                trends = make([]*model.Trend, 0)
        }
+       interests, err := r.bookOperator.GetInterests(c, r.remoteConfig.RecURL+userID)
+       if err != nil {
+               log.Printf("Failed to get interests: %v", err)
+               interests = make([]*model.Interest, 0)
+       }
        // Render the HTML template named "index.html"
        c.HTML(http.StatusOK, "index.html", gin.H{
-               "title":  "LiteRank Book Store",
-               "books":  books,
-               "trends": trends,
-               "q":      q,
+               "title":           "LiteRank Book Store",
+               "books":           books,
+               "trends":          trends,
+               "recommendations": interests,
+               "q":               q,
        })
 }

Render the recommendations in service/web/adapter/templates/index.html:

@@ -57,17 +57,13 @@
         <!-- Recommended for You Section -->
         <div>
             <h2 class="text-2xl font-bold mb-4">Recommended for You</h2>
-            <div class="grid grid-cols-2 gap-4 font-mono">
-                <!-- Recommended items can be dynamically generated here -->
-                <div class="bg-white p-2 rounded-md border-gray-300 shadow">
-                    Recommended Book 1
-                </div>
-                <div class="bg-white p-2 rounded-md border-gray-300 shadow">
-                    Recommended Book 2
-                </div>
-                <div class="bg-white p-2 rounded-md border-gray-300 shadow">
-                    Recommended Book 3
-                </div>
+            <div class="grid grid-cols-4 gap-2 font-mono">
+                {{range .recommendations}}
+                    <div class="bg-white p-4 rounded-md border-gray-300 shadow mt-2">
+                        <div class="text-lg font-bold">{{.Title}}</div>
+                        <span class="font-serif italic text-sm">{{.Author}}</span>
+                    </div>
+                {{end}}
             </div>
         </div>
     </div>

Make sure you have the trend and recommendation services running and restart your web service, you should see something like this on the index page.

Both services are integrated! Awesome🎉!