feat: feature flag system

.github/workflows/deploy.yml

@@ -19,9 +19,6 @@ jobs:
       - name: TruffleHog OSS
         uses: trufflesecurity/trufflehog@main
         with:
-          path: ./
-          base: ${{ github.event.repository.default_branch }}
-          head: HEAD
           extra_args: --debug --only-verified
 
   ci:

.github/workflows/pr.yml

@@ -19,9 +19,6 @@ jobs:
       - name: TruffleHog OSS
         uses: trufflesecurity/trufflehog@main
         with:
-          path: ./
-          base: ${{ github.event.repository.default_branch }}
-          head: HEAD
           extra_args: --debug --only-verified
 
   ci:

analytics/analytics.go

@@ -2,7 +2,6 @@ package analytics
 
 import (
 	"github.com/allegro/bigcache/v3"
-	"github.com/getsentry/sentry-go"
 	"github.com/jmoiron/sqlx"
 	tb "gopkg.in/telebot.v3"
 )
@@ -12,7 +11,6 @@ import (
 type Dependency struct {
 	Memory   *bigcache.BigCache
 	Bot      *tb.Bot
-	Logger   *sentry.Client
 	DB       *sqlx.DB
 	TeknumID string
 }

analytics/server/server.go

@@ -2,16 +2,13 @@
 
 import (
 	"errors"
-	"net"
 	"net/http"
-	"os"
 	"time"
 
 	"github.com/teknologi-umum/captcha/analytics"
 	"github.com/teknologi-umum/captcha/shared"
 
 	"github.com/allegro/bigcache/v3"
-	"github.com/getsentry/sentry-go"
 	sentryhttp "github.com/getsentry/sentry-go/http"
 	"github.com/go-chi/chi/v5"
 	"github.com/jmoiron/sqlx"
@@ -25,7 +22,6 @@
 type Dependency struct {
 	DB          *sqlx.DB
 	Memory      *bigcache.BigCache
-	Logger      *sentry.Client
 	Mongo       *mongo.Client
 	MongoDBName string
 }
@@ -58,12 +54,12 @@
 // Config is the configuration struct for the server package.
 // Only the Port field is optional. It will be set to 8080 if not set.
 type Config struct {
-	DB          *sqlx.DB
-	Mongo       *mongo.Client
-	MongoDBName string
-	Memory      *bigcache.BigCache
-	Logger      *sentry.Client
-	Port        string
+	DB               *sqlx.DB
+	Mongo            *mongo.Client
+	MongoDBName      string
+	Memory           *bigcache.BigCache
+	Environment      string
+	ListeningAddress string
 }
 
 // New creates and runs an HTTP server instance for fetching analytics data
@@ -72,26 +68,25 @@
 // Requires 3 parameter that should be sent from the main goroutine.
 func New(config Config) *http.Server {
 	// Give default port
-	if config.Port == "" {
-		config.Port = "8080"
+	if config.ListeningAddress == "" {
+		config.ListeningAddress = ":8080"
 	}
 
 	deps := &Dependency{
 		DB:          config.DB,
 		Memory:      config.Memory,
-		Logger:      config.Logger,
 		Mongo:       config.Mongo,
 		MongoDBName: config.MongoDBName,
 	}
 
 	secureMiddleware := secure.New(secure.Options{
 		BrowserXssFilter:   true,
 		ContentTypeNosniff: true,
-		SSLRedirect:        os.Getenv("ENV") == "production",
-		IsDevelopment:      os.Getenv("ENV") == "development",
+		SSLRedirect:        config.Environment == "production",
+		IsDevelopment:      config.Environment == "development",
 	})
 	corsMiddleware := cors.New(cors.Options{
-		Debug:          os.Getenv("ENV") == "development",
+		Debug:          config.Environment == "development",
 		AllowedOrigins: []string{},
 		AllowedMethods: []string{"GET", "OPTIONS"},
 	})
@@ -114,6 +109,11 @@
 	})
 
 	r.Get("/users", func(w http.ResponseWriter, r *http.Request) {
+		if deps.DB == nil {
+			w.WriteHeader(http.StatusNotFound)
+			return
+		}
+
 		data, err := deps.GetAll(r.Context())
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
@@ -140,6 +140,10 @@
 	})
 
 	r.Get("/hourly", func(w http.ResponseWriter, r *http.Request) {
+		if deps.DB == nil {
+			w.WriteHeader(http.StatusNotFound)
+			return
+		}
 		data, err := deps.GetHourly(r.Context())
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
@@ -166,6 +170,10 @@
 	})
 
 	r.Get("/total", func(w http.ResponseWriter, r *http.Request) {
+		if deps.DB == nil {
+			w.WriteHeader(http.StatusNotFound)
+			return
+		}
 		data, err := deps.GetTotal(r.Context())
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
@@ -192,6 +200,10 @@
 	})
 
 	r.Get("/dukun", func(w http.ResponseWriter, r *http.Request) {
+		if deps.Mongo == nil {
+			w.WriteHeader(http.StatusNotFound)
+			return
+		}
 		data, err := deps.GetDukunPoints(r.Context())
 		if err != nil {
 			w.WriteHeader(http.StatusInternalServerError)
@@ -219,7 +231,7 @@
 
 	return &http.Server{
 		Handler:           r,
-		Addr:              net.JoinHostPort("", config.Port),
+		Addr:              config.ListeningAddress,
 		ReadTimeout:       time.Minute,
 		WriteTimeout:      time.Minute,
 		ReadHeaderTimeout: time.Minute,

ascii/ascii.go

@@ -7,15 +7,13 @@ import (
 	"github.com/teknologi-umum/captcha/shared"
 	"github.com/teknologi-umum/captcha/utils"
 
-	"github.com/getsentry/sentry-go"
 	tb "gopkg.in/telebot.v3"
 )
 
 // Dependencies contains dependency injection struct
 // to be used for the Ascii package.
 type Dependencies struct {
-	Bot    *tb.Bot
-	Logger *sentry.Client
+	Bot *tb.Bot
 }
 
 // Ascii simply sends ASCII art message for fun.

badwords/badwords.go

@@ -2,8 +2,6 @@ package badwords
 
 import (
 	"context"
-	"os"
-	"strings"
 
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
@@ -14,6 +12,7 @@ import (
 type Dependency struct {
 	Mongo       *mongo.Client
 	MongoDBName string
+	AdminIDs    []string
 }
 
 // AddBadWords will add a new word into the MongoDB database.
@@ -29,7 +28,7 @@ func (d *Dependency) AddBadWord(ctx context.Context, word string) error {
 // Authenticate will check if the user is allowed to add a new
 // badword into the database.
 func (d *Dependency) Authenticate(id string) bool {
-	admins := strings.Split(os.Getenv("ADMIN_ID"), ",")
+	admins := d.AdminIDs
 
 	for _, admin := range admins {
 		if admin == id {

badwords/badwords_test.go

@@ -42,6 +42,7 @@ func TestMain(m *testing.M) {
 	dependency = &badwords.Dependency{
 		Mongo:       db,
 		MongoDBName: dbName,
+		AdminIDs:    []string{"30", "40", "50", "60"},
 	}
 
 	exitCode := m.Run()
@@ -64,11 +65,6 @@ func TestMain(m *testing.M) {
 }
 
 func TestAuthenticate(t *testing.T) {
-	err := os.Setenv("ADMIN_ID", "30,40,50,60")
-	if err != nil {
-		t.Fatal(err)
-	}
-
 	ok := dependency.Authenticate("30")
 	if !ok {
 		t.Errorf("failed to authenticate with the value of %d", 30)

captcha/captcha.go

@@ -4,7 +4,6 @@ import (
 	"github.com/teknologi-umum/captcha/analytics"
 
 	"github.com/allegro/bigcache/v3"
-	"github.com/getsentry/sentry-go"
 	tb "gopkg.in/telebot.v3"
 )
 
@@ -13,7 +12,6 @@ import (
 type Dependencies struct {
 	Memory    *bigcache.BigCache
 	Bot       *tb.Bot
-	Logger    *sentry.Client
 	Analytics *analytics.Dependency
 	TeknumID  string
 }