Add Buck Build + Test Capabilities

cmd/listttps_test.go

@@ -17,13 +17,12 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package cmd_test
+package cmd
 
 import (
 	"path/filepath"
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/cmd"
 	"github.com/stretchr/testify/require"
 )
 
@@ -41,7 +40,7 @@ func TestListTTPs(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			rc := cmd.BuildRootCommand(nil)
+			rc := BuildRootCommand(nil)
 			rc.SetArgs([]string{"list", "ttps", "-c", testConfigFilePath})
 			err := rc.Execute()
 			if tc.wantError {

cmd/run_test.go

@@ -17,14 +17,14 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package cmd_test
+package cmd
 
 import (
 	"bytes"
 	"path/filepath"
+
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/cmd"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
@@ -128,7 +128,7 @@ func TestRun(t *testing.T) {
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
 			var stdoutBuf, stderrBuf bytes.Buffer
-			rc := cmd.BuildRootCommand(&cmd.Config{
+			rc := BuildRootCommand(&Config{
 				Stdout: &stdoutBuf,
 				Stderr: &stderrBuf,
 			})

pkg/args/spec_test.go

@@ -17,12 +17,11 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package args_test
+package args
 
 import (
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/pkg/args"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
@@ -31,14 +30,14 @@ func TestValidateArgs(t *testing.T) {
 
 	testCases := []struct {
 		name           string
-		specs          []args.Spec
+		specs          []Spec
 		argKvStrs      []string
 		expectedResult map[string]any
 		wantError      bool
 	}{
 		{
 			name: "Parse String and Integer Arguments",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -59,7 +58,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Parse String and Integer Argument (Default Value)",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -80,7 +79,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Handle Extra Equals",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -100,7 +99,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Invalid Inputs (no '=')",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -116,7 +115,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Invalid Inputs (Missing Required Argument)",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -131,7 +130,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Argument Name Not In Specs",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -147,7 +146,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Duplicate Name in Specs",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -162,7 +161,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Wrong Type (string instead of int)",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name: "alpha",
 				},
@@ -179,7 +178,7 @@ func TestValidateArgs(t *testing.T) {
 		},
 		{
 			name: "Default Value Wrong Type (string instead of int)",
-			specs: []args.Spec{
+			specs: []Spec{
 				{
 					Name:    "alpha",
 					Type:    "int",
@@ -195,7 +194,7 @@ func TestValidateArgs(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			args, err := args.ParseAndValidate(tc.specs, tc.argKvStrs)
+			args, err := ParseAndValidate(tc.specs, tc.argKvStrs)
 			if tc.wantError {
 				require.Error(t, err)
 				return

pkg/blocks/basicstep_test.go

@@ -17,13 +17,11 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package blocks_test
+package blocks
 
 import (
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/pkg/blocks"
-
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"gopkg.in/yaml.v3"
@@ -65,7 +63,7 @@ steps:
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			var ttps blocks.TTP
+			var ttps TTP
 			err := yaml.Unmarshal([]byte(tc.content), &ttps)
 			if tc.wantError {
 				assert.Error(t, err)
@@ -85,9 +83,9 @@ outputs:
   first:
     filters:
     - json_path: foo.bar`
-	var s blocks.BasicStep
-	execCtx := blocks.TTPExecutionContext{
-		Cfg: blocks.TTPExecutionConfig{
+	var s BasicStep
+	execCtx := TTPExecutionContext{
+		Cfg: TTPExecutionConfig{
 			Args: map[string]any{
 				"myarg": "baz",
 			},

pkg/blocks/common_test.go

@@ -17,7 +17,7 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package blocks_test
+package blocks
 
 import (
 	"io/fs"
@@ -27,7 +27,6 @@ import (
 	"strings"
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/pkg/blocks"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -78,7 +77,7 @@ func TestFetchAbs(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			result, err := blocks.FetchAbs(tc.inputPath, tc.inputWorkdir)
+			result, err := FetchAbs(tc.inputPath, tc.inputWorkdir)
 
 			if tc.expectError {
 				assert.Error(t, err)
@@ -161,7 +160,7 @@ func TestFindFilePath(t *testing.T) {
 
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
-			result, err := blocks.FindFilePath(tc.inputPath, tc.inputWorkdir, tc.fsStat)
+			result, err := FindFilePath(tc.inputPath, tc.inputWorkdir, tc.fsStat)
 
 			if tc.expectError {
 				assert.Error(t, err)
@@ -213,7 +212,7 @@ func TestFetchEnv(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			result := blocks.FetchEnv(tt.environ)
+			result := FetchEnv(tt.environ)
 			sort.Strings(result)
 			sort.Strings(tt.expected)
 

pkg/blocks/context_test.go

@@ -17,31 +17,30 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package blocks_test
+package blocks
 
 import (
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/pkg/blocks"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
 
 func TestExpandVariablesStepResults(t *testing.T) {
 	// build the test fixture used across all cases
-	stepResults := blocks.NewStepResultsRecord()
-	stepResults.ByName["first_step"] = &blocks.ExecutionResult{
-		ActResult: blocks.ActResult{
+	stepResults := NewStepResultsRecord()
+	stepResults.ByName["first_step"] = &ExecutionResult{
+		ActResult: ActResult{
 			Stdout: "hello",
 		},
 	}
-	stepResults.ByName["second_step"] = &blocks.ExecutionResult{
-		ActResult: blocks.ActResult{
+	stepResults.ByName["second_step"] = &ExecutionResult{
+		ActResult: ActResult{
 			Stdout: "world",
 		},
 	}
-	stepResults.ByName["third_step"] = &blocks.ExecutionResult{
-		ActResult: blocks.ActResult{
+	stepResults.ByName["third_step"] = &ExecutionResult{
+		ActResult: ActResult{
 			Stdout: `{"foo":{"bar":"baz"}}`,
 			Outputs: map[string]string{
 				"myresult": "baz",
@@ -51,8 +50,8 @@ func TestExpandVariablesStepResults(t *testing.T) {
 	stepResults.ByIndex = append(stepResults.ByIndex, stepResults.ByName["first_step"])
 	stepResults.ByIndex = append(stepResults.ByIndex, stepResults.ByName["second_step"])
 	stepResults.ByIndex = append(stepResults.ByIndex, stepResults.ByName["third_step"])
-	execCtx := blocks.TTPExecutionContext{
-		Cfg: blocks.TTPExecutionConfig{
+	execCtx := TTPExecutionContext{
+		Cfg: TTPExecutionConfig{
 			Args: map[string]any{
 				"arg1": "myarg1",
 				"arg2": "myarg2",

pkg/blocks/createfile_test.go

@@ -17,13 +17,12 @@ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 */
 
-package blocks_test
+package blocks
 
 import (
 	"os"
 	"testing"
 
-	"github.com/facebookincubator/ttpforge/pkg/blocks"
 	"github.com/facebookincubator/ttpforge/pkg/testutils"
 	"github.com/spf13/afero"
 	"github.com/stretchr/testify/assert"
@@ -34,30 +33,30 @@ func TestCreateFileExecute(t *testing.T) {
 	testCases := []struct {
 		name               string
 		description        string
-		step               *blocks.CreateFileStep
+		step               *CreateFileStep
 		fsysContents       map[string][]byte
 		expectExecuteError bool
 	}{
 		{
 			name:        "Create Valid File",
 			description: "Create a single unremarkable file",
-			step: &blocks.CreateFileStep{
+			step: &CreateFileStep{
 				Path:     "valid-file.txt",
 				Contents: "hello world",
 			},
 		},
 		{
 			name:        "Nested Directories",
 			description: "Afero should handle this under the hood",
-			step: &blocks.CreateFileStep{
+			step: &CreateFileStep{
 				Path:     "/directory/does/not/exist",
 				Contents: "should still work",
 			},
 		},
 		{
 			name:        "Already Exists (No Overwrite)",
 			description: "Should fail because file already exists",
-			step: &blocks.CreateFileStep{
+			step: &CreateFileStep{
 				Path:     "already-exists.txt",
 				Contents: "will fail",
 			},
@@ -69,7 +68,7 @@ func TestCreateFileExecute(t *testing.T) {
 		{
 			name:        "Already Exists (With Overwrite)",
 			description: "Should succeed and overwrite existing file",
-			step: &blocks.CreateFileStep{
+			step: &CreateFileStep{
 				Path:      "already-exists.txt",
 				Contents:  "will succeed",
 				Overwrite: true,
@@ -81,7 +80,7 @@ func TestCreateFileExecute(t *testing.T) {
 		{
 			name:        "Set Permissions Manually",
 			description: "Make the file read-only",
-			step: &blocks.CreateFileStep{
+			step: &CreateFileStep{
 				Path:     "make-read-only",
 				Contents: "very-read-only",
 				Mode:     0400,
@@ -101,7 +100,7 @@ func TestCreateFileExecute(t *testing.T) {
 			}
 
 			// execute and check error
-			var execCtx blocks.TTPExecutionContext
+			var execCtx TTPExecutionContext
 			_, err := tc.step.Execute(execCtx)
 			if tc.expectExecuteError {
 				require.Error(t, err)