sync

Documentation

Index

• Variables

Variables

var SyncCommand = cli.Command{
	Name: "sync",
	Action: func(c *cli.Context) error {
		ctx := c.Context

		dc, err := deploy.ConfigFromContext(ctx)
		if err != nil {
			return err
		}
		o, err := dc.LoadOutput(ctx)
		if err != nil {
			return err
		}

		cfg, err := cfaws.ConfigFromContextOrDefault(ctx)
		if err != nil {
			return err
		}

		if o.IdpSyncFunctionName == "" {
			return clierr.New("The sync function name is not yet available. You may need to update your deployment to use this feature.")
		}
		si := spinner.New(spinner.CharSets[14], 100*time.Millisecond)
		si.Suffix = " invoking IDP sync lambda function"
		si.Writer = os.Stderr
		si.Start()

		lambdaClient := lambda.NewFromConfig(cfg)
		res, err := lambdaClient.Invoke(ctx, &lambda.InvokeInput{
			FunctionName:   &o.IdpSyncFunctionName,
			InvocationType: types.InvocationTypeRequestResponse,
			Payload:        []byte("{}"),
		})
		si.Stop()
		if err != nil {
			return err
		}
		b, err := json.Marshal(res)
		if err != nil {
			return err
		}
		clio.Debugf("idp sync lamda invoke response: %s", string(b))
		if res.FunctionError != nil {
			return fmt.Errorf("user and group sync failed with lambda execution error: %s", *res.FunctionError)
		} else if res.StatusCode == 200 {
			idp := dc.Deployment.Parameters.IdentityProviderType
			if idp == "" {
				idp = identitysync.IDPTypeCognito
			}
			clio.Successf("Successfully synced users and groups using %s", idp)
		} else {
			return fmt.Errorf("user and group sync failed with lambda invoke status code: %d", res.StatusCode)
		}
		return nil
	}}