From 43336a43eb2a0ae62334fa3fac05dc612fba46ac Mon Sep 17 00:00:00 2001
From: Janelle Tavares <janelletavares@users.noreply.github.com>
Date: Tue, 1 Mar 2022 15:39:12 -0800
Subject: [PATCH] feat(apps): Apps create command with feature flag (#262)

* feat(apps): Apps create command with feature flag
---
 cmd/meroxa/builder/builder.go                 |   2 +-
 cmd/meroxa/global/client.go                   |   2 +-
 cmd/meroxa/global/config.go                   |   2 +-
 cmd/meroxa/global/global.go                   |   2 +-
 cmd/meroxa/global/logger.go                   |   2 +-
 cmd/meroxa/global/metrics.go                  |   2 +-
 cmd/meroxa/global/metrics_test.go             |   2 +-
 cmd/meroxa/main.go                            |   2 +-
 cmd/meroxa/root/api/api.go                    |   2 +-
 cmd/meroxa/root/api/api_test.go               |   2 +-
 cmd/meroxa/root/apps/apps.go                  |  13 +-
 cmd/meroxa/root/apps/create.go                | 130 +++++++++
 cmd/meroxa/root/apps/create_test.go           | 251 ++++++++++++++++++
 cmd/meroxa/root/apps/remove.go                |   2 +-
 cmd/meroxa/root/apps/remove_test.go           |   2 +-
 cmd/meroxa/root/auth/auth.go                  |   2 +-
 cmd/meroxa/root/auth/login.go                 |   2 +-
 cmd/meroxa/root/auth/logout.go                |   2 +-
 cmd/meroxa/root/auth/whoami.go                |   2 +-
 cmd/meroxa/root/billing/billing.go            |   2 +-
 cmd/meroxa/root/config/config.go              |   2 +-
 cmd/meroxa/root/config/describe.go            |   2 +-
 cmd/meroxa/root/config/describe_test.go       |   2 +-
 cmd/meroxa/root/connectors/connect.go         |   2 +-
 cmd/meroxa/root/connectors/connect_test.go    |   2 +-
 cmd/meroxa/root/connectors/connectors.go      |   2 +-
 cmd/meroxa/root/connectors/create.go          |   2 +-
 cmd/meroxa/root/connectors/create_test.go     |   2 +-
 cmd/meroxa/root/connectors/describe.go        |   2 +-
 cmd/meroxa/root/connectors/describe_test.go   |   2 +-
 cmd/meroxa/root/connectors/list.go            |   2 +-
 cmd/meroxa/root/connectors/list_test.go       |   2 +-
 cmd/meroxa/root/connectors/logs.go            |   2 +-
 cmd/meroxa/root/connectors/logs_test.go       |   2 +-
 cmd/meroxa/root/connectors/remove.go          |   2 +-
 cmd/meroxa/root/connectors/remove_test.go     |   2 +-
 cmd/meroxa/root/connectors/update.go          |   2 +-
 cmd/meroxa/root/connectors/update_test.go     |   2 +-
 cmd/meroxa/root/endpoints/create.go           |   2 +-
 cmd/meroxa/root/endpoints/create_test.go      |   2 +-
 cmd/meroxa/root/endpoints/describe.go         |   2 +-
 cmd/meroxa/root/endpoints/describe_test.go    |   2 +-
 cmd/meroxa/root/endpoints/endpoints.go        |   2 +-
 cmd/meroxa/root/endpoints/list.go             |   2 +-
 cmd/meroxa/root/endpoints/list_test.go        |   2 +-
 cmd/meroxa/root/endpoints/remove.go           |   2 +-
 cmd/meroxa/root/endpoints/remove_test.go      |   2 +-
 cmd/meroxa/root/environments/create.go        |   2 +-
 cmd/meroxa/root/environments/create_test.go   |   2 +-
 cmd/meroxa/root/environments/describe.go      |   2 +-
 cmd/meroxa/root/environments/describe_test.go |   2 +-
 cmd/meroxa/root/environments/environments.go  |   2 +-
 cmd/meroxa/root/environments/list.go          |   2 +-
 cmd/meroxa/root/environments/list_test.go     |   2 +-
 cmd/meroxa/root/environments/remove.go        |   2 +-
 cmd/meroxa/root/environments/remove_test.go   |   2 +-
 cmd/meroxa/root/environments/repair.go        |   2 +-
 cmd/meroxa/root/environments/repair_test.go   |   2 +-
 cmd/meroxa/root/environments/update.go        |   2 +-
 cmd/meroxa/root/environments/update_test.go   |   2 +-
 cmd/meroxa/root/login/login.go                |   2 +-
 cmd/meroxa/root/logout/logout.go              |   2 +-
 cmd/meroxa/root/open/open.go                  |   2 +-
 cmd/meroxa/root/open/open_billing.go          |   2 +-
 cmd/meroxa/root/pipelines/create.go           |   2 +-
 cmd/meroxa/root/pipelines/create_test.go      |   2 +-
 cmd/meroxa/root/pipelines/describe.go         |   2 +-
 cmd/meroxa/root/pipelines/describe_test.go    |   2 +-
 cmd/meroxa/root/pipelines/list.go             |   2 +-
 cmd/meroxa/root/pipelines/list_test.go        |   2 +-
 cmd/meroxa/root/pipelines/pipelines.go        |   2 +-
 cmd/meroxa/root/pipelines/remove.go           |   2 +-
 cmd/meroxa/root/pipelines/remove_test.go      |   2 +-
 cmd/meroxa/root/pipelines/update.go           |   2 +-
 cmd/meroxa/root/pipelines/update_test.go      |   2 +-
 cmd/meroxa/root/resources/create.go           |   2 +-
 cmd/meroxa/root/resources/describe.go         |   2 +-
 cmd/meroxa/root/resources/describe_test.go    |   2 +-
 cmd/meroxa/root/resources/list.go             |   2 +-
 cmd/meroxa/root/resources/list_test.go        |   2 +-
 cmd/meroxa/root/resources/remove.go           |   2 +-
 cmd/meroxa/root/resources/remove_test.go      |   2 +-
 cmd/meroxa/root/resources/resources.go        |   2 +-
 .../root/resources/rotate_tunnel_key.go       |   2 +-
 cmd/meroxa/root/resources/update.go           |   2 +-
 cmd/meroxa/root/resources/update_test.go      |   2 +-
 cmd/meroxa/root/resources/validate.go         |   2 +-
 cmd/meroxa/root/root.go                       |   2 +-
 cmd/meroxa/root/transforms/list.go            |   2 +-
 cmd/meroxa/root/transforms/list_test.go       |   2 +-
 cmd/meroxa/root/transforms/transforms.go      |   2 +-
 cmd/meroxa/root/version/version.go            |   2 +-
 cmd/meroxa/root/whoami/whoami.go              |   2 +-
 config/config.go                              |   2 +-
 config/in_memory.go                           |   2 +-
 95 files changed, 484 insertions(+), 94 deletions(-)
 create mode 100644 cmd/meroxa/root/apps/create.go
 create mode 100644 cmd/meroxa/root/apps/create_test.go

diff --git a/cmd/meroxa/builder/builder.go b/cmd/meroxa/builder/builder.go
index f4b66269a..62271740d 100644
--- a/cmd/meroxa/builder/builder.go
+++ b/cmd/meroxa/builder/builder.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/client.go b/cmd/meroxa/global/client.go
index b63aeaeaf..d2c104bfc 100644
--- a/cmd/meroxa/global/client.go
+++ b/cmd/meroxa/global/client.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/config.go b/cmd/meroxa/global/config.go
index 1e29ce374..0244c9657 100644
--- a/cmd/meroxa/global/config.go
+++ b/cmd/meroxa/global/config.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/global.go b/cmd/meroxa/global/global.go
index ba195e388..790adcc5e 100644
--- a/cmd/meroxa/global/global.go
+++ b/cmd/meroxa/global/global.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/logger.go b/cmd/meroxa/global/logger.go
index 33461b6da..85dbe2e21 100644
--- a/cmd/meroxa/global/logger.go
+++ b/cmd/meroxa/global/logger.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/metrics.go b/cmd/meroxa/global/metrics.go
index d7528b8ce..51154fc0c 100644
--- a/cmd/meroxa/global/metrics.go
+++ b/cmd/meroxa/global/metrics.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/global/metrics_test.go b/cmd/meroxa/global/metrics_test.go
index 013dd9838..6adda97b8 100644
--- a/cmd/meroxa/global/metrics_test.go
+++ b/cmd/meroxa/global/metrics_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/main.go b/cmd/meroxa/main.go
index 504ec2abe..0e9bc7da1 100644
--- a/cmd/meroxa/main.go
+++ b/cmd/meroxa/main.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/api/api.go b/cmd/meroxa/root/api/api.go
index 52ca8e34c..7ad683f69 100644
--- a/cmd/meroxa/root/api/api.go
+++ b/cmd/meroxa/root/api/api.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/api/api_test.go b/cmd/meroxa/root/api/api_test.go
index 522612517..3ab6b1ead 100644
--- a/cmd/meroxa/root/api/api_test.go
+++ b/cmd/meroxa/root/api/api_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/apps/apps.go b/cmd/meroxa/root/apps/apps.go
index a8162aa7b..df2da1d5a 100644
--- a/cmd/meroxa/root/apps/apps.go
+++ b/cmd/meroxa/root/apps/apps.go
@@ -17,8 +17,11 @@ limitations under the License.
 package apps
 
 import (
-	"github.com/meroxa/cli/cmd/meroxa/builder"
+	"fmt"
+
 	"github.com/spf13/cobra"
+
+	"github.com/meroxa/cli/cmd/meroxa/builder"
 )
 
 type Apps struct{}
@@ -34,6 +37,7 @@ var (
 	_ builder.CommandWithAliases     = (*Apps)(nil)
 	_ builder.CommandWithSubCommands = (*Apps)(nil)
 	_ builder.CommandWithHidden      = (*Apps)(nil)
+	_ builder.CommandWithFeatureFlag = (*Apps)(nil)
 )
 
 func (*Apps) Aliases() []string {
@@ -54,11 +58,16 @@ func (*Apps) Docs() builder.Docs {
 	}
 }
 
+func (*Apps) FeatureFlag() (string, error) {
+	return "turbine", fmt.Errorf("no access to the Meroxa Data Applications feature")
+}
+
 func (*Apps) SubCommands() []*cobra.Command {
 	return []*cobra.Command{
+		builder.BuildCobraCommand(&Create{}),
 		builder.BuildCobraCommand(&Deploy{}),
 		builder.BuildCobraCommand(&Init{}),
-		builder.BuildCobraCommand(&Run{}),
 		builder.BuildCobraCommand(&Remove{}),
+		builder.BuildCobraCommand(&Run{}),
 	}
 }
diff --git a/cmd/meroxa/root/apps/create.go b/cmd/meroxa/root/apps/create.go
new file mode 100644
index 000000000..ece7a61a2
--- /dev/null
+++ b/cmd/meroxa/root/apps/create.go
@@ -0,0 +1,130 @@
+/*
+Copyright © 2022 Meroxa Inc
+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 apps
+
+import (
+	"context"
+	"errors"
+	"fmt"
+
+	turbineCLI "github.com/meroxa/cli/cmd/meroxa/turbine_cli"
+
+	"github.com/meroxa/cli/cmd/meroxa/builder"
+	"github.com/meroxa/cli/log"
+	"github.com/meroxa/meroxa-go/pkg/meroxa"
+)
+
+var (
+	_ builder.CommandWithDocs    = (*Create)(nil)
+	_ builder.CommandWithArgs    = (*Create)(nil)
+	_ builder.CommandWithFlags   = (*Create)(nil)
+	_ builder.CommandWithClient  = (*Create)(nil)
+	_ builder.CommandWithLogger  = (*Create)(nil)
+	_ builder.CommandWithExecute = (*Create)(nil)
+)
+
+type createApplicationClient interface {
+	CreateApplication(ctx context.Context, input *meroxa.CreateApplicationInput) (*meroxa.Application, error)
+}
+
+type Create struct {
+	client createApplicationClient
+	logger log.Logger
+
+	args struct {
+		Name string
+	}
+
+	flags struct {
+		Path string `long:"path" usage:"path where app was initialized to read its language from app.json (required unless specifying --lang)"`
+		Lang string `long:"lang" short:"l" usage:"language to use (required unless specifying --path)"`
+	}
+}
+
+func (c *Create) Logger(logger log.Logger) {
+	c.logger = logger
+}
+
+func (c *Create) Client(client meroxa.Client) {
+	c.client = client
+}
+
+func (c *Create) Flags() []builder.Flag {
+	return builder.BuildFlags(&c.flags)
+}
+
+func (c *Create) ParseArgs(args []string) error {
+	if len(args) < 1 {
+		return errors.New("requires an application name")
+	}
+	c.args.Name = args[0]
+	return nil
+}
+
+func (c *Create) getLang(ctx context.Context) (string, error) {
+	if path := c.flags.Path; path != "" {
+		lang, err := turbineCLI.GetLangFromAppJSON(path)
+		if err != nil {
+			return lang, err
+		}
+		if c.flags.Lang != "" && c.flags.Lang != lang {
+			c.logger.Info(ctx, "Ignoring language flag.")
+		}
+		return lang, nil
+	}
+
+	return c.flags.Lang, nil
+}
+
+func (c *Create) Execute(ctx context.Context) error {
+	if c.flags.Lang == "" && c.flags.Path == "" {
+		return fmt.Errorf("language is required either using --path ~/turbine/my-app or --lang. Type `meroxa help apps create` for more information") //nolint:lll
+	}
+
+	lang, err := c.getLang(ctx)
+	if err != nil {
+		return err
+	}
+
+	input := meroxa.CreateApplicationInput{
+		Name:     c.args.Name,
+		Language: lang,
+	}
+
+	c.logger.Infof(ctx, "Creating application %q with language %q...", input.Name, lang)
+
+	res, err := c.client.CreateApplication(ctx, &input)
+	if err != nil {
+		return err
+	}
+
+	c.logger.Infof(ctx, "Application %q successfully created!", res.Name)
+	c.logger.JSON(ctx, res)
+
+	return nil
+}
+
+func (c *Create) Usage() string {
+	return "create NAME"
+}
+
+func (c *Create) Docs() builder.Docs {
+	return builder.Docs{
+		Short: "Create a Meroxa Data Application",
+		Long: "You'll be able to use this application for consequent build via `meroxa apps deploy`. You'll need to specify " +
+			"language used either via `--lang` or specifying with `--path` the location of your app.json which should contain the desired language.",
+		Example: "meroxa apps create my-app --language golang\n" +
+			"meroxa apps create my-app --path ~/turbine/my-app",
+	}
+}
diff --git a/cmd/meroxa/root/apps/create_test.go b/cmd/meroxa/root/apps/create_test.go
new file mode 100644
index 000000000..1c87c60f5
--- /dev/null
+++ b/cmd/meroxa/root/apps/create_test.go
@@ -0,0 +1,251 @@
+package apps
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"os"
+	"reflect"
+	"testing"
+
+	"github.com/golang/mock/gomock"
+
+	"github.com/meroxa/cli/cmd/meroxa/builder"
+	"github.com/meroxa/cli/log"
+	"github.com/meroxa/cli/utils"
+	"github.com/meroxa/meroxa-go/pkg/meroxa"
+	"github.com/meroxa/meroxa-go/pkg/mock"
+	turbine "github.com/meroxa/turbine/init"
+)
+
+func TestCreateApplicationArgs(t *testing.T) {
+	tests := []struct {
+		args []string
+		err  error
+		name string
+	}{
+		{args: nil, err: errors.New("requires an application name"), name: ""},
+		{args: []string{"application-name"}, err: nil, name: "application-name"},
+	}
+
+	for _, tt := range tests {
+		cc := &Create{}
+		err := cc.ParseArgs(tt.args)
+
+		if err != nil && tt.err.Error() != err.Error() {
+			t.Fatalf("expected \"%s\" got \"%s\"", tt.err, err)
+		}
+
+		if tt.name != cc.args.Name {
+			t.Fatalf("expected \"%s\" got \"%s\"", tt.name, cc.args.Name)
+		}
+	}
+}
+
+func TestCreateApplicationFlags(t *testing.T) {
+	expectedFlags := []struct {
+		name      string
+		required  bool
+		shorthand string
+		hidden    bool
+	}{
+		{name: "path", required: false},
+		{name: "lang", required: false, shorthand: "l"},
+	}
+
+	c := builder.BuildCobraCommand(&Create{})
+
+	for _, f := range expectedFlags {
+		cf := c.Flags().Lookup(f.name)
+		if cf == nil {
+			t.Fatalf("expected flag \"%s\" to be present", f.name)
+		} else {
+			if f.shorthand != cf.Shorthand {
+				t.Fatalf("expected shorthand \"%s\" got \"%s\" for flag \"%s\"", f.shorthand, cf.Shorthand, f.name)
+			}
+
+			if f.required && !utils.IsFlagRequired(cf) {
+				t.Fatalf("expected flag \"%s\" to be required", f.name)
+			}
+
+			if cf.Hidden != f.hidden {
+				if cf.Hidden {
+					t.Fatalf("expected flag \"%s\" not to be hidden", f.name)
+				} else {
+					t.Fatalf("expected flag \"%s\" to be hidden", f.name)
+				}
+			}
+		}
+	}
+}
+
+func TestCreateApplicationExecutionNoLangNoPath(t *testing.T) {
+	ctx := context.Background()
+	ctrl := gomock.NewController(t)
+	client := mock.NewMockClient(ctrl)
+	logger := log.NewTestLogger()
+	name := "my-application"
+
+	c := &Create{
+		client: client,
+		logger: logger,
+	}
+
+	c.args.Name = name
+	err := c.Execute(ctx)
+
+	expectedError := "language is required either using --path ~/turbine/my-app or --lang. Type `meroxa help apps create` for more information"
+	if err != nil && err.Error() != expectedError {
+		t.Fatalf("not expected error, got \"%s\"", err.Error())
+	}
+}
+
+const tempAppDir = "test-app"
+
+func TestCreateApplicationExecutionWithAppJSON(t *testing.T) {
+	ctx := context.Background()
+	ctrl := gomock.NewController(t)
+	client := mock.NewMockClient(ctrl)
+	logger := log.NewTestLogger()
+	name := "my-application"
+	lang := GoLang
+
+	ai := &meroxa.CreateApplicationInput{
+		Name:     name,
+		Language: lang,
+	}
+
+	a := &meroxa.Application{
+		Name:     name,
+		Language: lang,
+	}
+
+	client.
+		EXPECT().
+		CreateApplication(
+			ctx,
+			ai,
+		).
+		Return(a, nil)
+
+	c := &Create{
+		client: client,
+		logger: logger,
+	}
+
+	path, err := initApp(name)
+	defer func() {
+		_ = os.RemoveAll(tempAppDir)
+	}()
+	if err != nil {
+		t.Fatalf("not expected error, got \"%s\"", err.Error())
+	}
+
+	c.args.Name = ai.Name
+	c.flags.Path = path
+
+	err = c.Execute(ctx)
+
+	if err != nil {
+		t.Fatalf("not expected error, got \"%s\"", err.Error())
+	}
+
+	gotLeveledOutput := logger.LeveledOutput()
+	wantLeveledOutput := fmt.Sprintf(`Creating application %q with language %q...
+Application %q successfully created!
+`, name, lang, name)
+
+	if gotLeveledOutput != wantLeveledOutput {
+		t.Fatalf("expected output:\n%s\ngot:\n%s", wantLeveledOutput, gotLeveledOutput)
+	}
+
+	gotJSONOutput := logger.JSONOutput()
+	var gotApplication meroxa.Application
+	err = json.Unmarshal([]byte(gotJSONOutput), &gotApplication)
+	if err != nil {
+		t.Fatalf("not expected error, got %q", err.Error())
+	}
+
+	if !reflect.DeepEqual(gotApplication, *a) {
+		t.Fatalf("expected \"%v\", got \"%v\"", *a, gotApplication)
+	}
+}
+
+func initApp(name string) (string, error) {
+	if err := os.Mkdir(tempAppDir, 0700); err != nil {
+		return "", err
+	}
+
+	if err := turbine.Init(tempAppDir, name); err != nil {
+		return "", err
+	}
+
+	cwd, err := os.Getwd()
+	if err != nil {
+		return "", err
+	}
+
+	return fmt.Sprintf("%s/%s/%s", cwd, tempAppDir, name), nil
+}
+
+func TestCreateApplicationExecutionWithLang(t *testing.T) {
+	ctx := context.Background()
+	ctrl := gomock.NewController(t)
+	client := mock.NewMockClient(ctrl)
+	logger := log.NewTestLogger()
+	name := "my-application"
+	lang := GoLang
+
+	ai := &meroxa.CreateApplicationInput{
+		Name:     name,
+		Language: lang,
+	}
+
+	a := &meroxa.Application{
+		Name:     name,
+		Language: lang,
+	}
+
+	client.
+		EXPECT().
+		CreateApplication(
+			ctx,
+			ai,
+		).
+		Return(a, nil)
+
+	c := &Create{
+		client: client,
+		logger: logger,
+	}
+
+	c.args.Name = ai.Name
+	c.flags.Lang = lang
+
+	err := c.Execute(ctx)
+
+	if err != nil {
+		t.Fatalf("not expected error, got \"%s\"", err.Error())
+	}
+
+	gotLeveledOutput := logger.LeveledOutput()
+	wantLeveledOutput := fmt.Sprintf(`Creating application %q with language %q...
+Application %q successfully created!
+`, name, lang, name)
+
+	if gotLeveledOutput != wantLeveledOutput {
+		t.Fatalf("expected output:\n%s\ngot:\n%s", wantLeveledOutput, gotLeveledOutput)
+	}
+
+	gotJSONOutput := logger.JSONOutput()
+	var gotApplication meroxa.Application
+	err = json.Unmarshal([]byte(gotJSONOutput), &gotApplication)
+	if err != nil {
+		t.Fatalf("not expected error, got %q", err.Error())
+	}
+
+	if !reflect.DeepEqual(gotApplication, *a) {
+		t.Fatalf("expected \"%v\", got \"%v\"", *a, gotApplication)
+	}
+}
diff --git a/cmd/meroxa/root/apps/remove.go b/cmd/meroxa/root/apps/remove.go
index f02259318..232a562e0 100644
--- a/cmd/meroxa/root/apps/remove.go
+++ b/cmd/meroxa/root/apps/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/apps/remove_test.go b/cmd/meroxa/root/apps/remove_test.go
index 825038c0b..1aced83d8 100644
--- a/cmd/meroxa/root/apps/remove_test.go
+++ b/cmd/meroxa/root/apps/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/auth/auth.go b/cmd/meroxa/root/auth/auth.go
index c850b5e20..d0fd55d87 100644
--- a/cmd/meroxa/root/auth/auth.go
+++ b/cmd/meroxa/root/auth/auth.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/auth/login.go b/cmd/meroxa/root/auth/login.go
index 64d5df2e3..818e2e1aa 100644
--- a/cmd/meroxa/root/auth/login.go
+++ b/cmd/meroxa/root/auth/login.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/auth/logout.go b/cmd/meroxa/root/auth/logout.go
index f682eb06f..a7e9fc18d 100644
--- a/cmd/meroxa/root/auth/logout.go
+++ b/cmd/meroxa/root/auth/logout.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/auth/whoami.go b/cmd/meroxa/root/auth/whoami.go
index a793243f7..ea76ab96d 100644
--- a/cmd/meroxa/root/auth/whoami.go
+++ b/cmd/meroxa/root/auth/whoami.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/billing/billing.go b/cmd/meroxa/root/billing/billing.go
index 5a09d8e8e..39c49573c 100644
--- a/cmd/meroxa/root/billing/billing.go
+++ b/cmd/meroxa/root/billing/billing.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/config/config.go b/cmd/meroxa/root/config/config.go
index 82c890fb9..ba2067d29 100644
--- a/cmd/meroxa/root/config/config.go
+++ b/cmd/meroxa/root/config/config.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/config/describe.go b/cmd/meroxa/root/config/describe.go
index de80ab515..c280be422 100644
--- a/cmd/meroxa/root/config/describe.go
+++ b/cmd/meroxa/root/config/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/config/describe_test.go b/cmd/meroxa/root/config/describe_test.go
index 7c8ce72fc..0dbd6d56a 100644
--- a/cmd/meroxa/root/config/describe_test.go
+++ b/cmd/meroxa/root/config/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/connect.go b/cmd/meroxa/root/connectors/connect.go
index df2d4812f..71beeecd0 100644
--- a/cmd/meroxa/root/connectors/connect.go
+++ b/cmd/meroxa/root/connectors/connect.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/connect_test.go b/cmd/meroxa/root/connectors/connect_test.go
index 2c30287d4..f685337e6 100644
--- a/cmd/meroxa/root/connectors/connect_test.go
+++ b/cmd/meroxa/root/connectors/connect_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/connectors.go b/cmd/meroxa/root/connectors/connectors.go
index 93212a0cc..6a1e3daae 100644
--- a/cmd/meroxa/root/connectors/connectors.go
+++ b/cmd/meroxa/root/connectors/connectors.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/create.go b/cmd/meroxa/root/connectors/create.go
index 94a675333..4e358e02c 100644
--- a/cmd/meroxa/root/connectors/create.go
+++ b/cmd/meroxa/root/connectors/create.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/create_test.go b/cmd/meroxa/root/connectors/create_test.go
index c4fc90784..f5530fd92 100644
--- a/cmd/meroxa/root/connectors/create_test.go
+++ b/cmd/meroxa/root/connectors/create_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/describe.go b/cmd/meroxa/root/connectors/describe.go
index 36b11188c..86f6aa182 100644
--- a/cmd/meroxa/root/connectors/describe.go
+++ b/cmd/meroxa/root/connectors/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/describe_test.go b/cmd/meroxa/root/connectors/describe_test.go
index 9be159c7a..c823907b1 100644
--- a/cmd/meroxa/root/connectors/describe_test.go
+++ b/cmd/meroxa/root/connectors/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/list.go b/cmd/meroxa/root/connectors/list.go
index e76b0eb03..aeb8f62f9 100644
--- a/cmd/meroxa/root/connectors/list.go
+++ b/cmd/meroxa/root/connectors/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/list_test.go b/cmd/meroxa/root/connectors/list_test.go
index 14b7d44da..c31451421 100644
--- a/cmd/meroxa/root/connectors/list_test.go
+++ b/cmd/meroxa/root/connectors/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/logs.go b/cmd/meroxa/root/connectors/logs.go
index e043975a4..087e9b72a 100644
--- a/cmd/meroxa/root/connectors/logs.go
+++ b/cmd/meroxa/root/connectors/logs.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/logs_test.go b/cmd/meroxa/root/connectors/logs_test.go
index 3f818216e..c0fbfbf77 100644
--- a/cmd/meroxa/root/connectors/logs_test.go
+++ b/cmd/meroxa/root/connectors/logs_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/remove.go b/cmd/meroxa/root/connectors/remove.go
index cc025b7a5..49e4de913 100644
--- a/cmd/meroxa/root/connectors/remove.go
+++ b/cmd/meroxa/root/connectors/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/remove_test.go b/cmd/meroxa/root/connectors/remove_test.go
index 5ead37c9b..1aa2594b4 100644
--- a/cmd/meroxa/root/connectors/remove_test.go
+++ b/cmd/meroxa/root/connectors/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/update.go b/cmd/meroxa/root/connectors/update.go
index 22a46b581..5e19c083d 100644
--- a/cmd/meroxa/root/connectors/update.go
+++ b/cmd/meroxa/root/connectors/update.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/connectors/update_test.go b/cmd/meroxa/root/connectors/update_test.go
index a18fb546b..466c83943 100644
--- a/cmd/meroxa/root/connectors/update_test.go
+++ b/cmd/meroxa/root/connectors/update_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/create.go b/cmd/meroxa/root/endpoints/create.go
index ee8415eca..2c5aea9ca 100644
--- a/cmd/meroxa/root/endpoints/create.go
+++ b/cmd/meroxa/root/endpoints/create.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/create_test.go b/cmd/meroxa/root/endpoints/create_test.go
index ca000ccff..165d2cf9e 100644
--- a/cmd/meroxa/root/endpoints/create_test.go
+++ b/cmd/meroxa/root/endpoints/create_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/describe.go b/cmd/meroxa/root/endpoints/describe.go
index 0f31062d2..fad71f2a3 100644
--- a/cmd/meroxa/root/endpoints/describe.go
+++ b/cmd/meroxa/root/endpoints/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/describe_test.go b/cmd/meroxa/root/endpoints/describe_test.go
index 8cc858321..26a7704e6 100644
--- a/cmd/meroxa/root/endpoints/describe_test.go
+++ b/cmd/meroxa/root/endpoints/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/endpoints.go b/cmd/meroxa/root/endpoints/endpoints.go
index 536f9cc93..0cfe968af 100644
--- a/cmd/meroxa/root/endpoints/endpoints.go
+++ b/cmd/meroxa/root/endpoints/endpoints.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/list.go b/cmd/meroxa/root/endpoints/list.go
index 2cb87012d..97fc54d84 100644
--- a/cmd/meroxa/root/endpoints/list.go
+++ b/cmd/meroxa/root/endpoints/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/list_test.go b/cmd/meroxa/root/endpoints/list_test.go
index 8fb8cef35..bfbad6a08 100644
--- a/cmd/meroxa/root/endpoints/list_test.go
+++ b/cmd/meroxa/root/endpoints/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/remove.go b/cmd/meroxa/root/endpoints/remove.go
index 6581ef895..83d632e9e 100644
--- a/cmd/meroxa/root/endpoints/remove.go
+++ b/cmd/meroxa/root/endpoints/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/endpoints/remove_test.go b/cmd/meroxa/root/endpoints/remove_test.go
index b9fa8736c..46afbbc7d 100644
--- a/cmd/meroxa/root/endpoints/remove_test.go
+++ b/cmd/meroxa/root/endpoints/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/create.go b/cmd/meroxa/root/environments/create.go
index b2dd0832c..2fbee1241 100644
--- a/cmd/meroxa/root/environments/create.go
+++ b/cmd/meroxa/root/environments/create.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 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
diff --git a/cmd/meroxa/root/environments/create_test.go b/cmd/meroxa/root/environments/create_test.go
index 30bd3d091..3e07d5195 100644
--- a/cmd/meroxa/root/environments/create_test.go
+++ b/cmd/meroxa/root/environments/create_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/describe.go b/cmd/meroxa/root/environments/describe.go
index 7fe955d27..64716707a 100644
--- a/cmd/meroxa/root/environments/describe.go
+++ b/cmd/meroxa/root/environments/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/describe_test.go b/cmd/meroxa/root/environments/describe_test.go
index 41dd725a1..baf25d5e1 100644
--- a/cmd/meroxa/root/environments/describe_test.go
+++ b/cmd/meroxa/root/environments/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/environments.go b/cmd/meroxa/root/environments/environments.go
index fc3ccce18..7edabe358 100644
--- a/cmd/meroxa/root/environments/environments.go
+++ b/cmd/meroxa/root/environments/environments.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/list.go b/cmd/meroxa/root/environments/list.go
index 38dd0f810..840b2021c 100644
--- a/cmd/meroxa/root/environments/list.go
+++ b/cmd/meroxa/root/environments/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/list_test.go b/cmd/meroxa/root/environments/list_test.go
index c1c75c345..8baee340a 100644
--- a/cmd/meroxa/root/environments/list_test.go
+++ b/cmd/meroxa/root/environments/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/remove.go b/cmd/meroxa/root/environments/remove.go
index 588b007bb..ca3552ea1 100644
--- a/cmd/meroxa/root/environments/remove.go
+++ b/cmd/meroxa/root/environments/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/remove_test.go b/cmd/meroxa/root/environments/remove_test.go
index 878800eac..9f1cb918b 100644
--- a/cmd/meroxa/root/environments/remove_test.go
+++ b/cmd/meroxa/root/environments/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/repair.go b/cmd/meroxa/root/environments/repair.go
index 72c53a30e..eb5b49cd5 100644
--- a/cmd/meroxa/root/environments/repair.go
+++ b/cmd/meroxa/root/environments/repair.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 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
diff --git a/cmd/meroxa/root/environments/repair_test.go b/cmd/meroxa/root/environments/repair_test.go
index c415cb826..4c59f6ec6 100644
--- a/cmd/meroxa/root/environments/repair_test.go
+++ b/cmd/meroxa/root/environments/repair_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/update.go b/cmd/meroxa/root/environments/update.go
index 205ab19c3..c1b35a562 100644
--- a/cmd/meroxa/root/environments/update.go
+++ b/cmd/meroxa/root/environments/update.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/environments/update_test.go b/cmd/meroxa/root/environments/update_test.go
index db27cbfd4..5868f82b1 100644
--- a/cmd/meroxa/root/environments/update_test.go
+++ b/cmd/meroxa/root/environments/update_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/login/login.go b/cmd/meroxa/root/login/login.go
index 9461dc512..8728708b1 100644
--- a/cmd/meroxa/root/login/login.go
+++ b/cmd/meroxa/root/login/login.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/logout/logout.go b/cmd/meroxa/root/logout/logout.go
index 6fcd567fb..18cd13f94 100644
--- a/cmd/meroxa/root/logout/logout.go
+++ b/cmd/meroxa/root/logout/logout.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/open/open.go b/cmd/meroxa/root/open/open.go
index aa5306efa..20360815d 100644
--- a/cmd/meroxa/root/open/open.go
+++ b/cmd/meroxa/root/open/open.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/open/open_billing.go b/cmd/meroxa/root/open/open_billing.go
index 02e9c56a2..a0cf35fb4 100644
--- a/cmd/meroxa/root/open/open_billing.go
+++ b/cmd/meroxa/root/open/open_billing.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/create.go b/cmd/meroxa/root/pipelines/create.go
index 10f35dcdf..873eb93e7 100644
--- a/cmd/meroxa/root/pipelines/create.go
+++ b/cmd/meroxa/root/pipelines/create.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/create_test.go b/cmd/meroxa/root/pipelines/create_test.go
index 5e004e157..f24e73803 100644
--- a/cmd/meroxa/root/pipelines/create_test.go
+++ b/cmd/meroxa/root/pipelines/create_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/describe.go b/cmd/meroxa/root/pipelines/describe.go
index 75397df55..e17b144a6 100644
--- a/cmd/meroxa/root/pipelines/describe.go
+++ b/cmd/meroxa/root/pipelines/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/describe_test.go b/cmd/meroxa/root/pipelines/describe_test.go
index 752dabcd7..c6576e741 100644
--- a/cmd/meroxa/root/pipelines/describe_test.go
+++ b/cmd/meroxa/root/pipelines/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/list.go b/cmd/meroxa/root/pipelines/list.go
index 88bf49532..e1cf9bc89 100644
--- a/cmd/meroxa/root/pipelines/list.go
+++ b/cmd/meroxa/root/pipelines/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/list_test.go b/cmd/meroxa/root/pipelines/list_test.go
index 6f1623383..a58c9ef98 100644
--- a/cmd/meroxa/root/pipelines/list_test.go
+++ b/cmd/meroxa/root/pipelines/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/pipelines.go b/cmd/meroxa/root/pipelines/pipelines.go
index b4ccdf9b0..4e9013e4b 100644
--- a/cmd/meroxa/root/pipelines/pipelines.go
+++ b/cmd/meroxa/root/pipelines/pipelines.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/remove.go b/cmd/meroxa/root/pipelines/remove.go
index b0c12d035..9207af57e 100644
--- a/cmd/meroxa/root/pipelines/remove.go
+++ b/cmd/meroxa/root/pipelines/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/remove_test.go b/cmd/meroxa/root/pipelines/remove_test.go
index 3ac3fdb47..4dea27a70 100644
--- a/cmd/meroxa/root/pipelines/remove_test.go
+++ b/cmd/meroxa/root/pipelines/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/update.go b/cmd/meroxa/root/pipelines/update.go
index 91c01ccad..5f48fac01 100644
--- a/cmd/meroxa/root/pipelines/update.go
+++ b/cmd/meroxa/root/pipelines/update.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/pipelines/update_test.go b/cmd/meroxa/root/pipelines/update_test.go
index afacc6dca..fa1b5940c 100644
--- a/cmd/meroxa/root/pipelines/update_test.go
+++ b/cmd/meroxa/root/pipelines/update_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/create.go b/cmd/meroxa/root/resources/create.go
index 0791e54f5..291204dff 100644
--- a/cmd/meroxa/root/resources/create.go
+++ b/cmd/meroxa/root/resources/create.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/describe.go b/cmd/meroxa/root/resources/describe.go
index 796ebb92f..dd9b3e250 100644
--- a/cmd/meroxa/root/resources/describe.go
+++ b/cmd/meroxa/root/resources/describe.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/describe_test.go b/cmd/meroxa/root/resources/describe_test.go
index 25ac8bbd6..98e4c4843 100644
--- a/cmd/meroxa/root/resources/describe_test.go
+++ b/cmd/meroxa/root/resources/describe_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/list.go b/cmd/meroxa/root/resources/list.go
index 66d8a6a5a..3577ddda2 100644
--- a/cmd/meroxa/root/resources/list.go
+++ b/cmd/meroxa/root/resources/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/list_test.go b/cmd/meroxa/root/resources/list_test.go
index 5e92ce4e1..95ae2ccae 100644
--- a/cmd/meroxa/root/resources/list_test.go
+++ b/cmd/meroxa/root/resources/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/remove.go b/cmd/meroxa/root/resources/remove.go
index ac0fbac8b..7f1991a8d 100644
--- a/cmd/meroxa/root/resources/remove.go
+++ b/cmd/meroxa/root/resources/remove.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/remove_test.go b/cmd/meroxa/root/resources/remove_test.go
index fdf3e05e9..4de3d95a6 100644
--- a/cmd/meroxa/root/resources/remove_test.go
+++ b/cmd/meroxa/root/resources/remove_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/resources.go b/cmd/meroxa/root/resources/resources.go
index 216225740..1922bae46 100644
--- a/cmd/meroxa/root/resources/resources.go
+++ b/cmd/meroxa/root/resources/resources.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/rotate_tunnel_key.go b/cmd/meroxa/root/resources/rotate_tunnel_key.go
index 307fd4965..c6556b511 100644
--- a/cmd/meroxa/root/resources/rotate_tunnel_key.go
+++ b/cmd/meroxa/root/resources/rotate_tunnel_key.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/update.go b/cmd/meroxa/root/resources/update.go
index b7e77de56..088c1e4c2 100644
--- a/cmd/meroxa/root/resources/update.go
+++ b/cmd/meroxa/root/resources/update.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/update_test.go b/cmd/meroxa/root/resources/update_test.go
index 66964d2d6..802594172 100644
--- a/cmd/meroxa/root/resources/update_test.go
+++ b/cmd/meroxa/root/resources/update_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/resources/validate.go b/cmd/meroxa/root/resources/validate.go
index 4953e8d93..31a598cad 100644
--- a/cmd/meroxa/root/resources/validate.go
+++ b/cmd/meroxa/root/resources/validate.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/root.go b/cmd/meroxa/root/root.go
index d859cd966..1dc7518ee 100644
--- a/cmd/meroxa/root/root.go
+++ b/cmd/meroxa/root/root.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/transforms/list.go b/cmd/meroxa/root/transforms/list.go
index 25d64e769..b39ff24b7 100644
--- a/cmd/meroxa/root/transforms/list.go
+++ b/cmd/meroxa/root/transforms/list.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/transforms/list_test.go b/cmd/meroxa/root/transforms/list_test.go
index 73797a957..1be697fd5 100644
--- a/cmd/meroxa/root/transforms/list_test.go
+++ b/cmd/meroxa/root/transforms/list_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/transforms/transforms.go b/cmd/meroxa/root/transforms/transforms.go
index ed3f13269..bdae95c14 100644
--- a/cmd/meroxa/root/transforms/transforms.go
+++ b/cmd/meroxa/root/transforms/transforms.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/version/version.go b/cmd/meroxa/root/version/version.go
index 8fed7b70b..ac74bec78 100644
--- a/cmd/meroxa/root/version/version.go
+++ b/cmd/meroxa/root/version/version.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/cmd/meroxa/root/whoami/whoami.go b/cmd/meroxa/root/whoami/whoami.go
index 5a19429bd..8521c5999 100644
--- a/cmd/meroxa/root/whoami/whoami.go
+++ b/cmd/meroxa/root/whoami/whoami.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/config/config.go b/config/config.go
index c274ae1fe..56f232185 100644
--- a/config/config.go
+++ b/config/config.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/config/in_memory.go b/config/in_memory.go
index 8da827081..1a7e776da 100644
--- a/config/in_memory.go
+++ b/config/in_memory.go
@@ -1,5 +1,5 @@
 /*
-Copyright © 2021 Meroxa Inc
+Copyright © 2022 Meroxa Inc
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.