rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Go format

Browse Source 
Signed-off-by: Sacha Al Himdani <sacha@getprobo.com>
This commit is contained in:
Sacha Al Himdani
2026-03-03 11:17:05 +01:00
parent 3c70b1e3eb
commit 21ed4113c3
47 changed files with 112 additions and 119 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/coredata/applicability_statement_order_field.go
View File

@@ -21,8 +21,8 @@ import (
type ApplicabilityStatementOrderField string
const (
ApplicabilityStatementOrderFieldCreatedAt ApplicabilityStatementOrderField = "CREATED_AT"
ApplicabilityStatementOrderFieldControlSectionTitle ApplicabilityStatementOrderField = "CONTROL_SECTION_TITLE"
ApplicabilityStatementOrderFieldCreatedAt ApplicabilityStatementOrderField = "CREATED_AT"
ApplicabilityStatementOrderFieldControlSectionTitle ApplicabilityStatementOrderField = "CONTROL_SECTION_TITLE"
)
func (p ApplicabilityStatementOrderField) Column() string {

2
pkg/coredata/asset_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/asset_vendor.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

4
pkg/coredata/cached_certificate.go
View File

@@ -19,10 +19,10 @@ import (
"fmt"
"time"
"go.probo.inc/probo/pkg/crypto/cipher"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/crypto/cipher"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/continual_improvement_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/control_audit.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/control_snapshot.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

1
pkg/coredata/data_protection_impact_assessment_order_field.go
View File

@@ -43,4 +43,3 @@ func (p *DataProtectionImpactAssessmentOrderField) UnmarshalText(text []byte) er
}
return fmt.Errorf("invalid DataProtectionImpactAssessmentOrderField value: %q", val)
}

1
pkg/coredata/data_protection_impact_assessment_residual_risk.go
View File

@@ -66,4 +66,3 @@ func (p *DataProtectionImpactAssessmentResidualRisk) Scan(value any) error {
func (p DataProtectionImpactAssessmentResidualRisk) Value() (driver.Value, error) {
return p.String(), nil
}

2
pkg/coredata/datum_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/datum_vendor.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

8
pkg/coredata/document_approver.go
View File

@@ -62,11 +62,11 @@ ON CONFLICT (document_id, approver_profile_id) DO NOTHING;
`
args := pgx.StrictNamedArgs{
"document_id": da.DocumentID,
"document_id": da.DocumentID,
"approver_profile_id": da.ApproverProfileID,
"organization_id": da.OrganizationID,
"tenant_id": scope.GetTenantID(),
"created_at": da.CreatedAt,
"organization_id": da.OrganizationID,
"tenant_id": scope.GetTenantID(),
"created_at": da.CreatedAt,
}
_, err := conn.Exec(ctx, q, args)

2
pkg/coredata/nonconformity_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/obligation_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/processing_activity_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

4
pkg/coredata/rights_request_type.go
View File

@@ -22,8 +22,8 @@ import (
type RightsRequestType string
const (
RightsRequestTypeAccess RightsRequestType = "ACCESS"
RightsRequestTypeDeletion RightsRequestType = "DELETION"
RightsRequestTypeAccess RightsRequestType = "ACCESS"
RightsRequestTypeDeletion RightsRequestType = "DELETION"
RightsRequestTypePortability RightsRequestType = "PORTABILITY"
)

2
pkg/coredata/risk_document.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/risk_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/risk_obligation.go
View File

@@ -20,9 +20,9 @@ import (
"maps"
"time"
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/gid"
)
type (

2
pkg/coredata/state_of_applicability_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

1
pkg/coredata/transfer_impact_assessment_order_field.go
View File

@@ -43,4 +43,3 @@ func (p *TransferImpactAssessmentOrderField) UnmarshalText(text []byte) error {
}
return fmt.Errorf("invalid TransferImpactAssessmentOrderField value: %q", val)
}

2
pkg/coredata/vendor_filter.go
View File

@@ -15,8 +15,8 @@
package coredata
import (
"go.probo.inc/probo/pkg/gid"
"github.com/jackc/pgx/v5"
"go.probo.inc/probo/pkg/gid"
)
type (

10
pkg/coredata/webhook_data.go
View File

@@ -29,12 +29,12 @@ import (
type (
WebhookData struct {
ID gid.GID `db:"id"`
OrganizationID gid.GID `db:"organization_id"`
ID gid.GID `db:"id"`
OrganizationID gid.GID `db:"organization_id"`
EventType WebhookEventType `db:"event_type"`
Data json.RawMessage `db:"data"`
CreatedAt time.Time `db:"created_at"`
ProcessedAt *time.Time `db:"processed_at"`
Data json.RawMessage `db:"data"`
CreatedAt time.Time `db:"created_at"`
ProcessedAt *time.Time `db:"processed_at"`
}
WebhookDataList []*WebhookData

22
pkg/coredata/webhook_event.go
View File

@@ -29,12 +29,12 @@ import (
type (
WebhookEvent struct {
ID gid.GID `db:"id"`
WebhookDataID gid.GID `db:"webhook_data_id"`
ID gid.GID `db:"id"`
WebhookDataID gid.GID `db:"webhook_data_id"`
WebhookSubscriptionID gid.GID `db:"webhook_subscription_id"`
Status WebhookEventStatus `db:"status"`
Response json.RawMessage `db:"response"`
CreatedAt time.Time `db:"created_at"`
Status WebhookEventStatus `db:"status"`
Response json.RawMessage `db:"response"`
CreatedAt time.Time `db:"created_at"`
}
WebhookEvents []*WebhookEvent
@@ -143,13 +143,13 @@ VALUES (
`
args := pgx.StrictNamedArgs{
"id": w.ID,
"tenant_id": scope.GetTenantID(),
"webhook_data_id": w.WebhookDataID,
"id": w.ID,
"tenant_id": scope.GetTenantID(),
"webhook_data_id": w.WebhookDataID,
"webhook_subscription_id": w.WebhookSubscriptionID,
"status": w.Status,
"response": w.Response,
"created_at": w.CreatedAt,
"status": w.Status,
"response": w.Response,
"created_at": w.CreatedAt,
}
_, err := conn.Exec(ctx, q, args)

6
pkg/coredata/webhook_event_status.go
View File

@@ -22,9 +22,9 @@ import (
type WebhookEventStatus string
const (
WebhookEventStatusPending WebhookEventStatus = "PENDING"
WebhookEventStatusSucceeded WebhookEventStatus = "SUCCEEDED"
WebhookEventStatusFailed WebhookEventStatus = "FAILED"
WebhookEventStatusPending WebhookEventStatus = "PENDING"
WebhookEventStatusSucceeded WebhookEventStatus = "SUCCEEDED"
WebhookEventStatusFailed WebhookEventStatus = "FAILED"
)
func (s WebhookEventStatus) String() string {

14
pkg/coredata/webhook_subscription.go
View File

@@ -281,14 +281,14 @@ VALUES (
`
args := pgx.StrictNamedArgs{
"tenant_id": scope.GetTenantID(),
"webhook_subscription_id": w.ID,
"organization_id": w.OrganizationID,
"endpoint_url": w.EndpointURL,
"selected_events": w.SelectedEvents,
"tenant_id": scope.GetTenantID(),
"webhook_subscription_id": w.ID,
"organization_id": w.OrganizationID,
"endpoint_url": w.EndpointURL,
"selected_events": w.SelectedEvents,
"encrypted_signing_secret": w.EncryptedSigningSecret,
"created_at": w.CreatedAt,
"updated_at": w.UpdatedAt,
"created_at": w.CreatedAt,
"updated_at": w.UpdatedAt,
}
_, err := conn.Exec(ctx, q, args)

4
pkg/crypto/keys/keys_test.go
View File

@@ -21,9 +21,9 @@ import (
"errors"
"testing"
"go.probo.inc/probo/pkg/crypto/keys"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.probo.inc/probo/pkg/crypto/keys"
)
func TestGenerate(t *testing.T) {
@@ -162,4 +162,4 @@ func BenchmarkGenerate(b *testing.B) {
}
})
}
}
}

2
pkg/crypto/pem/pem_test.go
View File

@@ -31,9 +31,9 @@ import (
"testing"
"time"
"go.probo.inc/probo/pkg/crypto/pem"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.probo.inc/probo/pkg/crypto/pem"
)
func TestEncodeCertificate(t *testing.T) {

2
pkg/esign/certgen.go
View File

@@ -19,9 +19,9 @@ import (
"context"
_ "embed"
"fmt"
"html/template"
"io"
"strings"
"html/template"
"time"
"github.com/digitorus/timestamp"

11
pkg/iam/policy/action_test.go
View File

@@ -166,11 +166,11 @@ func TestActionRegistry_ByService(t *testing.T) {
func TestParseAction(t *testing.T) {
tests := []struct {
action Action
wantSvc string
wantRes string
wantOp string
wantErr bool
action Action
wantSvc string
wantRes string
wantOp string
wantErr bool
}{
{
action: "iam:identity:get",
@@ -217,4 +217,3 @@ func TestParseAction(t *testing.T) {
})
}
}

15
pkg/iam/policy/evaluator_test.go
View File

@@ -203,9 +203,9 @@ func TestEvaluator_Evaluate_MultipleConditions(t *testing.T) {
)
tests := []struct {
name string
ctx ConditionContext
want Decision
name string
ctx ConditionContext
want Decision
}{
{
name: "both conditions satisfied",
@@ -260,10 +260,10 @@ func TestEvaluator_Evaluate_WildcardActions(t *testing.T) {
evaluator := NewEvaluator()
tests := []struct {
name string
policy *Policy
action string
want Decision
name string
policy *Policy
action string
want Decision
}{
{
name: "full wildcard allows everything",
@@ -443,4 +443,3 @@ func TestEvaluationResult_IsAllowed(t *testing.T) {
})
}
}

1
pkg/iam/policy/example_test.go
View File

@@ -204,4 +204,3 @@ func Example_conditionBasedAccess() {
// User update own profile: allow
// User update other profile: no_match
}

1
pkg/iam/policy/matcher.go
View File

@@ -86,4 +86,3 @@ func (m *ActionMatcher) MatchesAny(patterns []string, target string) bool {
}
return false
}

12
pkg/probo/actions.go
View File

@@ -100,13 +100,13 @@ const (
ActionVendorRiskAssessmentList = "core:vendor-risk-assessment:list"
// Framework actions
ActionFrameworkGet = "core:framework:get"
ActionFrameworkList = "core:framework:list"
ActionFrameworkCreate = "core:framework:create"
ActionFrameworkUpdate = "core:framework:update"
ActionFrameworkDelete = "core:framework:delete"
ActionFrameworkGet = "core:framework:get"
ActionFrameworkList = "core:framework:list"
ActionFrameworkCreate = "core:framework:create"
ActionFrameworkUpdate = "core:framework:update"
ActionFrameworkDelete = "core:framework:delete"
ActionFrameworkExport = "core:framework:export"
ActionFrameworkImport = "core:framework:import"
ActionFrameworkImport = "core:framework:import"
// Control actions
ActionControlGet = "core:control:get"

18
pkg/probo/measure_service.go
View File

@@ -386,16 +386,16 @@ func (s MeasureService) Import(
continue
}
controlMeasure := &coredata.ControlMeasure{
ControlID: control.ID,
MeasureID: measure.ID,
OrganizationID: measure.OrganizationID,
CreatedAt: now,
}
controlMeasure := &coredata.ControlMeasure{
ControlID: control.ID,
MeasureID: measure.ID,
OrganizationID: measure.OrganizationID,
CreatedAt: now,
}
if err := controlMeasure.Upsert(ctx, tx, s.svc.scope); err != nil {
return fmt.Errorf("cannot insert control measure: %w", err)
}
if err := controlMeasure.Upsert(ctx, tx, s.svc.scope); err != nil {
return fmt.Errorf("cannot insert control measure: %w", err)
}
}
}

2
pkg/probo/report_service.go
View File

@@ -21,9 +21,9 @@ import (
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/s3"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/coredata"
"go.probo.inc/probo/pkg/gid"
"go.gearno.de/kit/pg"
)
type ReportService struct {

8
pkg/server/api/connect/v1/types/bridge.go
View File

@@ -30,10 +30,10 @@ func NewSCIMBridge(bridge *coredata.SCIMBridge) *SCIMBridge {
ScimConfiguration: &SCIMConfiguration{
ID: bridge.ScimConfigurationID,
},
Connector: connector,
Type: bridge.Type,
Connector: connector,
Type: bridge.Type,
ExcludedUserNames: bridge.ExcludedUserNames,
CreatedAt: bridge.CreatedAt,
UpdatedAt: bridge.UpdatedAt,
CreatedAt: bridge.CreatedAt,
UpdatedAt: bridge.UpdatedAt,
}
}

8
pkg/server/api/console/v1/types/webhook_event.go
View File

@@ -68,10 +68,10 @@ func NewWebhookEvent(we *coredata.WebhookEvent) *WebhookEvent {
}
return &WebhookEvent{
ID: we.ID,
ID: we.ID,
WebhookSubscriptionID: we.WebhookSubscriptionID,
Status: we.Status,
Response: response,
CreatedAt: we.CreatedAt,
Status: we.Status,
Response: response,
CreatedAt: we.CreatedAt,
}
}

2
pkg/server/api/mcp/v1/types/transfer_impact_assessment.go
View File

@@ -47,7 +47,7 @@ func NewListTransferImpactAssessmentsOutput(pg *page.Page[*coredata.TransferImpa
nextCursor = &cursorKey
}
return ListTransferImpactAssessmentsOutput{
NextCursor: nextCursor,
NextCursor: nextCursor,
TransferImpactAssessments: items,
}
}

2
pkg/server/gqlutils/types/pageinfo/pageinfo.go
View File

@@ -15,8 +15,8 @@
package pageinfo
import (
"go.probo.inc/probo/pkg/page"
"go.gearno.de/x/ref"
"go.probo.inc/probo/pkg/page"
)
type PageInfo struct {

4
pkg/slack/sender.go
View File

@@ -20,11 +20,11 @@ import (
"fmt"
"time"
"go.gearno.de/kit/log"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/connector"
"go.probo.inc/probo/pkg/coredata"
"go.probo.inc/probo/pkg/crypto/cipher"
"go.gearno.de/kit/log"
"go.gearno.de/kit/pg"
)
type (

2
pkg/trust/audit_service.go
View File

@@ -18,10 +18,10 @@ import (
"context"
"fmt"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/coredata"
"go.probo.inc/probo/pkg/gid"
"go.probo.inc/probo/pkg/page"
"go.gearno.de/kit/pg"
)
type AuditService struct {

2
pkg/trust/organization_service.go
View File

@@ -22,9 +22,9 @@ import (
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/s3"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/coredata"
"go.probo.inc/probo/pkg/gid"
"go.gearno.de/kit/pg"
)
type OrganizationService struct {

2
pkg/trust/trust_center_reference_service.go
View File

@@ -22,10 +22,10 @@ import (
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/service/s3"
"go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/coredata"
"go.probo.inc/probo/pkg/gid"
"go.probo.inc/probo/pkg/page"
"go.gearno.de/kit/pg"
)
type TrustCenterReferenceService struct {

2
pkg/version/version.go
View File

@@ -125,4 +125,4 @@ func FullVersion() string {
parts = append(parts, fmt.Sprintf("Go: %s", info.GoVersion))
return strings.Join(parts, "\n")
}
}

2
pkg/version/version_test.go
View File

@@ -18,9 +18,9 @@ import (
"strings"
"testing"
"go.probo.inc/probo/pkg/version"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"go.probo.inc/probo/pkg/version"
)
func TestGetBuildInfo(t *testing.T) {

24
pkg/webhook/types/obligation.go
View File

@@ -22,20 +22,20 @@ import (
)
type Obligation struct {
ID gid.GID `json:"id"`
OrganizationID gid.GID `json:"organizationId"`
Area *string `json:"area"`
Source *string `json:"source"`
Requirement *string `json:"requirement"`
ActionsToBeImplemented *string `json:"actionsToBeImplemented"`
Regulator *string `json:"regulator"`
OwnerID gid.GID `json:"ownerId"`
LastReviewDate *time.Time `json:"lastReviewDate"`
DueDate *time.Time `json:"dueDate"`
ID gid.GID `json:"id"`
OrganizationID gid.GID `json:"organizationId"`
Area *string `json:"area"`
Source *string `json:"source"`
Requirement *string `json:"requirement"`
ActionsToBeImplemented *string `json:"actionsToBeImplemented"`
Regulator *string `json:"regulator"`
OwnerID gid.GID `json:"ownerId"`
LastReviewDate *time.Time `json:"lastReviewDate"`
DueDate *time.Time `json:"dueDate"`
Status coredata.ObligationStatus `json:"status"`
Type coredata.ObligationType `json:"type"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
CreatedAt time.Time `json:"createdAt"`
UpdatedAt time.Time `json:"updatedAt"`
}
func NewObligation(o *coredata.Obligation) *Obligation {