Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add jenkins attestor #323

Merged
merged 2 commits into from
Aug 22, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
155 changes: 155 additions & 0 deletions attestation/jenkins/jenkins.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,155 @@
// Copyright 2024 The Witness Contributors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package jenkins

import (
"crypto"
"fmt"
"os"
"strings"

"github.com/in-toto/go-witness/attestation"
"github.com/in-toto/go-witness/cryptoutil"
"github.com/in-toto/go-witness/log"
"github.com/invopop/jsonschema"
)

const (
Name = "jenkins"
Type = "https://witness.dev/attestations/jenkins/v0.1"
RunType = attestation.PreMaterialRunType
)

// This is a hacky way to create a compile time error in case the attestor
// doesn't implement the expected interfaces.
var (
_ attestation.Attestor = &Attestor{}
_ attestation.Subjecter = &Attestor{}
_ attestation.BackReffer = &Attestor{}
_ JenkinsAttestor = &Attestor{}
)

type JenkinsAttestor interface {
// Attestor
Name() string
Type() string
RunType() attestation.RunType
Attest(ctx *attestation.AttestationContext) error
Data() *Attestor

// Subjecter
Subjects() map[string]cryptoutil.DigestSet

// Backreffer
BackRefs() map[string]cryptoutil.DigestSet
}

func init() {
attestation.RegisterAttestation(Name, Type, RunType, func() attestation.Attestor {
return New()
})
}

type ErrNotJenkins struct{}

func (e ErrNotJenkins) Error() string {
return "not in a jenkins ci job"
}

type Attestor struct {
BuildID string `json:"buildid"`
BuildNumber string `json:"buildnumber"`
BuildTag string `json:"buildtag"`
PipelineUrl string `json:"pipelineurl"`
ExecutorNumber string `json:"executornumber"`
JavaHome string `json:"javahome"`
JenkinsUrl string `json:"jenkinsurl"`
JobName string `json:"jobname"`
NodeName string `json:"nodename"`
Workspace string `json:"workspace"`
}

func New() *Attestor {
return &Attestor{}
}

func (a *Attestor) Name() string {
return Name
}

func (a *Attestor) Type() string {
return Type
}

func (a *Attestor) RunType() attestation.RunType {
return RunType
}

func (a *Attestor) Schema() *jsonschema.Schema {
return jsonschema.Reflect(&a)
}

func (a *Attestor) Attest(ctx *attestation.AttestationContext) error {
if _, ok := os.LookupEnv("JENKINS_URL"); !ok {
return ErrNotJenkins{}
}

a.BuildID = os.Getenv("BUILD_ID")
a.BuildNumber = os.Getenv("BUILD_NUMBER")
a.BuildTag = os.Getenv("BUILD_TAG")
a.PipelineUrl = os.Getenv("BUILD_URL")
a.ExecutorNumber = os.Getenv("EXECUTOR_NUMBER")
a.JavaHome = os.Getenv("JAVA_HOME")
a.JenkinsUrl = os.Getenv("JENKINS_URL")
a.JobName = os.Getenv("JOB_NAME")
a.NodeName = os.Getenv("NODE_NAME")
a.Workspace = os.Getenv("WORKSPACE")

return nil
}

func (a *Attestor) Data() *Attestor {
return a
}

func (a *Attestor) Subjects() map[string]cryptoutil.DigestSet {
subjects := make(map[string]cryptoutil.DigestSet)
hashes := []cryptoutil.DigestValue{{Hash: crypto.SHA256}}
if ds, err := cryptoutil.CalculateDigestSetFromBytes([]byte(a.PipelineUrl), hashes); err == nil {
subjects[fmt.Sprintf("pipelineurl:%v", a.PipelineUrl)] = ds
} else {
log.Debugf("(attestation/jenkins) failed to record jenkins pipelineurl subject: %w", err)
}

if ds, err := cryptoutil.CalculateDigestSetFromBytes([]byte(a.JenkinsUrl), hashes); err == nil {
subjects[fmt.Sprintf("jenkinsurl:%v", a.JenkinsUrl)] = ds
} else {
log.Debugf("(attestation/jenkins) failed to record jenkins jenkinsurl subject: %w", err)
}

return subjects
}

func (a *Attestor) BackRefs() map[string]cryptoutil.DigestSet {
backRefs := make(map[string]cryptoutil.DigestSet)
for subj, ds := range a.Subjects() {
if strings.HasPrefix(subj, "pipelineurl:") {
backRefs[subj] = ds
break
}
}

return backRefs
}
38 changes: 38 additions & 0 deletions attestation/jenkins/jenkins_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
// Copyright 2024 The Witness Contributors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package jenkins

import (
"testing"

"github.com/stretchr/testify/assert"
)

func TestSubjects(t *testing.T) {
attestor := &Attestor{}

subjects := attestor.Subjects()
assert.NotNil(t, subjects)
assert.Equal(t, 2, len(subjects))

expectedSubjects := []string{"pipelineurl:" + attestor.PipelineUrl, "jenkinsurl:" + attestor.JenkinsUrl}
for _, expectedSubject := range expectedSubjects {
_, ok := subjects[expectedSubject]
assert.True(t, ok, "Expected subject not found: %s", expectedSubject)
}
m := attestor.BackRefs()
assert.NotNil(t, m)
assert.Equal(t, 1, len(m))
}
9 changes: 8 additions & 1 deletion attestation/slsa/slsa.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ import (
"github.com/in-toto/go-witness/attestation/git"
"github.com/in-toto/go-witness/attestation/github"
"github.com/in-toto/go-witness/attestation/gitlab"
"github.com/in-toto/go-witness/attestation/jenkins"
"github.com/in-toto/go-witness/attestation/material"
"github.com/in-toto/go-witness/attestation/oci"
"github.com/in-toto/go-witness/attestation/product"
Expand All @@ -48,6 +49,7 @@ const (
DefaultBuilderId = "https://witness.dev/[email protected]"
GHABuilderId = "https://witness.dev/[email protected]"
GLCBuilderId = "https://witness.dev/[email protected]"
JenkinsBuilderId = "https://witness.dev/[email protected]"
)

// This is a hacky way to create a compile time error in case the attestor
Expand Down Expand Up @@ -185,6 +187,11 @@ func (p *Provenance) Attest(ctx *attestation.AttestationContext) error {
log.Warn("No SHA found in GitLab JWT")
}

case jenkins.Name:
jks := attestor.Attestor.(jenkins.JenkinsAttestor)
p.PbProvenance.RunDetails.Builder.Id = JenkinsBuilderId
p.PbProvenance.RunDetails.Metadata.InvocationId = jks.Data().PipelineUrl

// Material Attestors
case material.Name:
mats := attestor.Attestor.(material.MaterialAttestor).Materials()
Expand Down Expand Up @@ -237,7 +244,7 @@ func (p *Provenance) Attest(ctx *attestation.AttestationContext) error {

// NOTE: We want to warn users that they can use the github and gitlab attestors to enrich their provenance
if p.PbProvenance.RunDetails.Builder.Id == DefaultBuilderId {
log.Warn("No build system attestor invoked. Consider using github or gitlab attestors (if appropriate) to enrich your SLSA provenance")
log.Warn("No build system attestor invoked. Consider using github, gitlab, or jenkins attestors (if appropriate) to enrich your SLSA provenance")
}

var err error
Expand Down
46 changes: 46 additions & 0 deletions attestation/slsa/slsa_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,11 @@ func TestAttest(t *testing.T) {
gl.Data().JWT.Claims["sha"] = "abc123"
gl.Data().PipelineUrl = "https://github.com/testifysec/swf/actions/runs/7879307166"

// Setup Jenkins
jks := attestors.NewTestJenkinsAttestor()
jks.Data().JenkinsUrl = "https://localhost:8000/"
jks.Data().PipelineUrl = "https://github.com/testifysec/swf/actions/runs/7879307166"

// Setup Materials
m := attestors.NewTestMaterialAttestor()

Expand All @@ -135,6 +140,7 @@ func TestAttest(t *testing.T) {
}{
{"github", []attestation.Attestor{e, g, gh, m, c, p, o}, testGHProvJSON},
{"gitlab", []attestation.Attestor{e, g, gl, m, c, p, o}, testGLProvJSON},
{"jenkins", []attestation.Attestor{e, g, jks, m, c, p, o}, testJKSProvJSON},
}

for _, test := range tests {
Expand Down Expand Up @@ -316,3 +322,43 @@ const testGLProvJSON = `{
}
}
}`

const testJKSProvJSON = `{
"build_definition": {
"build_type": "https://witness.dev/[email protected]",
"external_parameters": {
"command": "touch test.txt"
},
"internal_parameters": {
"env": {
"SHELL": "/bin/zsh",
"TERM": "xterm-256color",
"TERM_PROGRAM": "iTerm.app"
}
},
"resolved_dependencies": [
{
"name": "[email protected]:in-toto/witness.git",
"digest": {
"sha1": "abc123"
}
}
]
},
"run_details": {
"builder": {
"id": "https://witness.dev/[email protected]"
},
"metadata": {
"invocation_id": "https://github.com/testifysec/swf/actions/runs/7879307166",
"started_on": {
"seconds": 1711199861,
"nanos": 560152000
},
"finished_on": {
"seconds": 1711199861,
"nanos": 560152000
}
}
}
}`
1 change: 1 addition & 0 deletions imports.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ import (
_ "github.com/in-toto/go-witness/attestation/git"
_ "github.com/in-toto/go-witness/attestation/github"
_ "github.com/in-toto/go-witness/attestation/gitlab"
_ "github.com/in-toto/go-witness/attestation/jenkins"
_ "github.com/in-toto/go-witness/attestation/jwt"
_ "github.com/in-toto/go-witness/attestation/link"
_ "github.com/in-toto/go-witness/attestation/material"
Expand Down
65 changes: 65 additions & 0 deletions internal/attestors/jenkins.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,65 @@
// Copyright 2024 The Witness Contributors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package attestors

import (
"github.com/in-toto/go-witness/attestation"
"github.com/in-toto/go-witness/attestation/jenkins"
"github.com/in-toto/go-witness/cryptoutil"
"github.com/invopop/jsonschema"
)

var _ jenkins.JenkinsAttestor = &TestJenkinsAttestor{}

type TestJenkinsAttestor struct {
jenkinsAtt jenkins.Attestor
}

func NewTestJenkinsAttestor() *TestJenkinsAttestor {
att := jenkins.Attestor{}
return &TestJenkinsAttestor{jenkinsAtt: att}
}

func (t *TestJenkinsAttestor) Name() string {
return t.jenkinsAtt.Name()
}

func (t *TestJenkinsAttestor) Type() string {
return t.jenkinsAtt.Type()
}

func (t *TestJenkinsAttestor) RunType() attestation.RunType {
return t.jenkinsAtt.RunType()
}

func (t *TestJenkinsAttestor) Schema() *jsonschema.Schema {
return jsonschema.Reflect(&t)
}

func (t *TestJenkinsAttestor) Attest(ctx *attestation.AttestationContext) error {
return nil
}

func (t *TestJenkinsAttestor) Data() *jenkins.Attestor {
return &t.jenkinsAtt
}

func (t *TestJenkinsAttestor) Subjects() map[string]cryptoutil.DigestSet {
return nil
}

func (t *TestJenkinsAttestor) BackRefs() map[string]cryptoutil.DigestSet {
return nil
}
Loading
Loading