Function ExtractAccounts

backend/plugins/tapd/tasks/account_extractor.go:38–66

(taskCtx plugin.SubTaskContext)

}

func ExtractAccounts(taskCtx plugin.SubTaskContext) errors.Error {
	rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_USER_TABLE)
	extractor, err := api.NewApiExtractor(api.ApiExtractorArgs{
		RawDataSubTaskArgs: *rawDataSubTaskArgs,
		Extract: func(row *api.RawData) ([]interface{}, errors.Error) {
			var userRes struct {
				UserWorkspace models.TapdAccount
			}
			err := errors.Convert(json.Unmarshal(row.Data, &userRes))
			if err != nil {
				return nil, err
			}
			toolL := models.TapdAccount{
				ConnectionId: data.Options.ConnectionId,
				User:         userRes.UserWorkspace.User,
				Name:         userRes.UserWorkspace.Name,
			}
			return []interface{}{
				&toolL,
			}, nil
		},
	})

	if err != nil {
		return err
	}

	return extractor.Execute()
}