✨ integration-test

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "go.buildTags": "-tags integration", 
+}

Makefile

@@ -17,6 +17,10 @@ test:
 		go test ./... -timeout 10s -race; \
 	fi
 
+.PHONY: integration-test
+integration-test:
+	go test -timeout 5s -tags=integration ./... 
+
 ## builds the service
 .PHONY: service
 service:
@@ -84,6 +88,10 @@ dev/logs:
 dev/stop:
 	docker-compose stop
 
+## Access the container
+dev:
+	@$(devrun) bash
+
 ## Display help for all targets
 .PHONY: help
 help:

cmd/newsletter/main.go

@@ -28,5 +28,14 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	fmt.Println("PING")
+
+	fmt.Println("Connected to MongoDB!")
+
+	collection := client.Database("newsletter").Collection("newsletter")
+	res, err := collection.InsertOne(ctx, map[string]string{"name": "pi", "value": "3.14159"})
+	if err != nil {
+		panic(err)
+	}
+	id := res.InsertedID
+	fmt.Println(id)
 }

mongodb/db.go

@@ -0,0 +1,28 @@
+// Package mongodb provides a MongoDB connection.
+package mongodb
+
+import (
+	"context"
+
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
+)
+
+// Config is the configuration for the MongoDB connection.
+type Config struct {
+	URI string
+}
+
+// Connect connects to the MongoDB instance.
+func Connect(ctx context.Context, cfg Config) (*mongo.Client, error) {
+	client, err := mongo.Connect(ctx, options.Client().ApplyURI(cfg.URI))
+	if err != nil {
+		return nil, err
+	}
+	err = client.Ping(ctx, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	return client, nil
+}

mongodb/db_test.go

@@ -0,0 +1,51 @@
+//go:build integration
+// +build integration
+
+package mongodb
+
+import (
+	"context"
+	"testing"
+
+	"go.mongodb.org/mongo-driver/mongo"
+)
+
+func setup(ctx context.Context, t testing.TB) (*mongo.Collection, func()) {
+	client, err := Connect(ctx, Config{
+		URI: "mongodb://root:root@mongodb:27017",
+	})
+
+	if err != nil {
+		panic(err)
+	}
+
+	randCollection := t.Name()
+
+	collection := client.Database("test").Collection(randCollection)
+
+	teardown := func() {
+		err = collection.Drop(ctx)
+		if err != nil {
+			panic(err)
+		}
+	}
+
+	return collection, teardown
+}
+
+func TestConnect(t *testing.T) {
+	collection, teardown := setup(context.Background(), t)
+
+	defer teardown()
+
+	resp, err := collection.InsertOne(context.Background(), map[string]string{"name": "pi", "value": "3.14159"})
+
+	if err != nil {
+		t.Fatal(err)
+	}
+	t.Log(resp.InsertedID)
+
+	result := collection.FindOne(context.Background(), map[string]string{"name": "pi", "value": "3.14159"})
+	t.Log(result.Raw())
+
+}

scrape_test.go

@@ -0,0 +1,11 @@
+package newsletter
+
+import (
+	"fmt"
+	"testing"
+)
+
+func TestFake(t *testing.T) {
+	fmt.Println("This test shouldn't fail")
+	t.Log("This test shouldn't fail")
+}