add basic vault integration

cmd/migrate.go

@@ -13,7 +13,8 @@ import (
 	"go.uber.org/zap"
 )
 
-func addMigrateCommand(c *cobra.Command, cfg *config.Config) {
+func addMigrateCommand(c *cobra.Command,
+	cfg *config.Config) {
 
 	cmd := &cobra.Command{
 		Use:   "migrate",

generate.go

@@ -26,3 +26,4 @@ package malak
 //go:generate mockgen -source=preferences.go -destination=mocks/preferences.go -package=malak_mocks
 //go:generate mockgen -source=integration.go -destination=mocks/integration.go -package=malak_mocks
 //go:generate mockgen -source=internal/pkg/billing/billing.go -destination=mocks/billing.go -package=malak_mocks
+//go:generate mockgen -source=internal/vault/vault.go -destination=mocks/vault.go -package=malak_mocks

integration.go

@@ -47,8 +47,12 @@ type WorkspaceIntegration struct {
 	IntegrationID uuid.UUID    `json:"integration_id,omitempty"`
 	Integration   *Integration `bun:"rel:belongs-to,join:integration_id=id" json:"integration,omitempty"`
 
+	// IsEnabled - this integration is enabled and data can be fetched
 	IsEnabled bool `json:"is_enabled,omitempty"`
 
+	// IsActive determines if the connection to the integration has been tested and works
+	IsActive bool `json:"is_active,omitempty"`
+
 	CreatedAt time.Time  `bun:",nullzero,notnull,default:current_timestamp" json:"created_at,omitempty"`
 	UpdatedAt time.Time  `bun:",nullzero,notnull,default:current_timestamp" json:"updated_at,omitempty"`
 	DeletedAt *time.Time `bun:",soft_delete,nullzero" json:"-,omitempty"`
@@ -86,5 +90,6 @@ type IntegrationDataPoint struct {
 
 type IntegrationProviderClient interface {
 	Name() IntegrationProvider
+	Ping(context.Context) error
 	io.Closer
 }

internal/datastore/postgres/migrations/20250202140712_add_is_enabled_to_workspace_integrations.down.sql

@@ -0,0 +1 @@
+ALTER TABLE workspace_integrations DROP COLUMN is_active;

internal/datastore/postgres/migrations/20250202140712_add_is_enabled_to_workspace_integrations.up.sql

@@ -0,0 +1 @@
+ALTER TABLE workspace_integrations ADD COLUMN is_active BOOLEAN DEFAULT FALSE;

internal/integrations/paystack.go

@@ -0,0 +1,3 @@
+package integrations
+
+type PaystackClient struct{}

internal/vault/vault.go

@@ -0,0 +1,12 @@
+package vault
+
+import (
+	"context"
+	"io"
+)
+
+type Vault interface {
+	io.Closer
+	Create(context.Context) error
+	Delete(context.Context) error
+}

swagger/docs.go

@@ -3091,7 +3091,12 @@ const docTemplate = `{
                 "integration_id": {
                     "type": "string"
                 },
+                "is_active": {
+                    "description": "IsActive determines if the connection to the integration has been tested and works",
+                    "type": "boolean"
+                },
                 "is_enabled": {
+                    "description": "IsEnabled - this integration is enabled and data can be fetched",
                     "type": "boolean"
                 },
                 "reference": {

swagger/swagger.json

@@ -825,7 +825,12 @@
 					"integration_id": {
 						"type": "string"
 					},
+					"is_active": {
+						"description": "IsActive determines if the connection to the integration has been tested and works",
+						"type": "boolean"
+					},
 					"is_enabled": {
+						"description": "IsEnabled - this integration is enabled and data can be fetched",
 						"type": "boolean"
 					},
 					"reference": {

swagger/swagger.yaml

@@ -567,7 +567,12 @@ components:
           $ref: '#/components/schemas/malak.Integration'
         integration_id:
           type: string
+        is_active:
+          description: IsActive determines if the connection to the integration has
+            been tested and works
+          type: boolean
         is_enabled:
+          description: IsEnabled - this integration is enabled and data can be fetched
           type: boolean
         reference:
           type: string

web/ui/src/client/Api.ts

@@ -352,6 +352,9 @@ export interface MalakWorkspaceIntegration {
   id?: string;
   integration?: MalakIntegration;
   integration_id?: string;
+  /** IsActive determines if the connection to the integration has been tested and works */
+  is_active?: boolean;
+  /** IsEnabled - this integration is enabled and data can be fetched */
   is_enabled?: boolean;
   reference?: string;
   updated_at?: string;