iframe-proxy | Sunbelt Computer Software

History

executable file

65 lines (57 loc) · 1.63 KB

Raw

package cli

import (

"context"

"go.keploy.io/server/v3/utils"

"github.com/spf13/cobra"

"go.keploy.io/server/v3/config"

replaySvc "go.keploy.io/server/v3/pkg/service/replay"

"go.uber.org/zap"

)

func init() {

}

func Test(ctx context.Context, logger *zap.Logger, _ *config.Config, serviceFactory ServiceFactory, cmdConfigurator CmdConfigurator) *cobra.Command {

var testCmd = &cobra.Command{

Use: "test",

Short: "run the recorded testcases and execute assertions",

Example: `keploy test -c "/path/to/user/app" --delay 6`,

PreRunE: func(cmd *cobra.Command, _ []string) error {

return cmdConfigurator.Validate(ctx, cmd)

RunE: func(cmd *cobra.Command, _ []string) error {

svc, err := serviceFactory.GetService(ctx, cmd.Name())

if err != nil {

utils.LogError(logger, err, "failed to get service", zap.String("command", cmd.Name()))

return nil

}

var replay replaySvc.Service

var ok bool

if replay, ok = svc.(replaySvc.Service); !ok {

utils.LogError(logger, nil, "service doesn't satisfy replay service interface")

return nil

}

// defering the stop function to stop keploy in case of any error in test or in case of context cancellation

defer func() {

select {

case <-ctx.Done():

break

default:

utils.ExecCancel()

}

}()

err = replay.Start(ctx)

if err != nil {

if ctx.Err() != context.Canceled {

utils.LogError(logger, err, "failed to replay")

}

return nil

}

err := cmdConfigurator.AddFlags(testCmd)

if err != nil {

utils.LogError(logger, err, "failed to add test flags")

return nil

}

return testCmd

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

Uh oh!

FilesExpand file tree

test.go

Latest commit

History

test.go

File metadata and controls