How to use ReadArchive method of lib Package

Best K6 code snippet using lib.ReadArchive

archive_test.go

Source:archive_test.go Github

copy

Full Screen

...145 buf := bytes.NewBuffer(nil)146 require.NoError(t, arc1.Write(buf))147 arc1Filesystems := arc1.Filesystems148 arc1.Filesystems = nil149 arc2, err := ReadArchive(buf)150 require.NoError(t, err)151 arc2Filesystems := arc2.Filesystems152 arc2.Filesystems = nil153 arc2.Filename = ""154 arc2.Pwd = ""155 assert.Equal(t, arc1, arc2)156 diffMapFilesystems(t, arc1Filesystems, arc2Filesystems)157 })158 t.Run("Anonymized", func(t *testing.T) {159 testdata := []struct {160 Pwd, PwdNormAnon string161 }{162 {"/home/myname", "/home/nobody"},163 {filepath.FromSlash("/C:/Users/Administrator"), "/C/Users/nobody"},164 }165 for _, entry := range testdata {166 arc1 := &Archive{167 Type: "js",168 Options: Options{169 VUs: null.IntFrom(12345),170 SystemTags: &stats.DefaultSystemTagSet,171 },172 FilenameURL: &url.URL{Scheme: "file", Path: fmt.Sprintf("%s/a.js", entry.Pwd)},173 K6Version: consts.Version,174 Data: []byte(`// a contents`),175 PwdURL: &url.URL{Scheme: "file", Path: entry.Pwd},176 Filesystems: map[string]afero.Fs{177 "file": makeMemMapFs(t, map[string][]byte{178 fmt.Sprintf("%s/a.js", entry.Pwd): []byte(`// a contents`),179 fmt.Sprintf("%s/b.js", entry.Pwd): []byte(`// b contents`),180 fmt.Sprintf("%s/file1.txt", entry.Pwd): []byte(`hi!`),181 fmt.Sprintf("%s/file2.txt", entry.Pwd): []byte(`bye!`),182 }),183 "https": makeMemMapFs(t, map[string][]byte{184 "/cdnjs.com/libraries/Faker": []byte(`// faker contents`),185 "/github.com/loadimpact/k6/README.md": []byte(`README`),186 }),187 },188 }189 arc1Anon := &Archive{190 Type: "js",191 Options: Options{192 VUs: null.IntFrom(12345),193 SystemTags: &stats.DefaultSystemTagSet,194 },195 FilenameURL: &url.URL{Scheme: "file", Path: fmt.Sprintf("%s/a.js", entry.PwdNormAnon)},196 K6Version: consts.Version,197 Data: []byte(`// a contents`),198 PwdURL: &url.URL{Scheme: "file", Path: entry.PwdNormAnon},199 Filesystems: map[string]afero.Fs{200 "file": makeMemMapFs(t, map[string][]byte{201 fmt.Sprintf("%s/a.js", entry.PwdNormAnon): []byte(`// a contents`),202 fmt.Sprintf("%s/b.js", entry.PwdNormAnon): []byte(`// b contents`),203 fmt.Sprintf("%s/file1.txt", entry.PwdNormAnon): []byte(`hi!`),204 fmt.Sprintf("%s/file2.txt", entry.PwdNormAnon): []byte(`bye!`),205 }),206 "https": makeMemMapFs(t, map[string][]byte{207 "/cdnjs.com/libraries/Faker": []byte(`// faker contents`),208 "/github.com/loadimpact/k6/README.md": []byte(`README`),209 }),210 },211 }212 buf := bytes.NewBuffer(nil)213 require.NoError(t, arc1.Write(buf))214 arc1Filesystems := arc1Anon.Filesystems215 arc1Anon.Filesystems = nil216 arc2, err := ReadArchive(buf)217 assert.NoError(t, err)218 arc2.Filename = ""219 arc2.Pwd = ""220 arc2Filesystems := arc2.Filesystems221 arc2.Filesystems = nil222 assert.Equal(t, arc1Anon, arc2)223 diffMapFilesystems(t, arc1Filesystems, arc2Filesystems)224 }225 })226}227func TestArchiveJSONEscape(t *testing.T) {228 t.Parallel()229 arc := &Archive{}230 arc.Filename = "test<.js"231 b, err := arc.json()232 assert.NoError(t, err)233 assert.Contains(t, string(b), "test<.js")234}235func TestUsingCacheFromCacheOnReadFs(t *testing.T) {236 var base = afero.NewMemMapFs()237 var cached = afero.NewMemMapFs()238 // we specifically have different contents in both places239 require.NoError(t, afero.WriteFile(base, "/wrong", []byte(`ooops`), 0644))240 require.NoError(t, afero.WriteFile(cached, "/correct", []byte(`test`), 0644))241 arc := &Archive{242 Type: "js",243 FilenameURL: &url.URL{Scheme: "file", Path: "/correct"},244 K6Version: consts.Version,245 Data: []byte(`test`),246 PwdURL: &url.URL{Scheme: "file", Path: "/"},247 Filesystems: map[string]afero.Fs{248 "file": fsext.NewCacheOnReadFs(base, cached, 0),249 },250 }251 buf := bytes.NewBuffer(nil)252 require.NoError(t, arc.Write(buf))253 newArc, err := ReadArchive(buf)254 require.NoError(t, err)255 data, err := afero.ReadFile(newArc.Filesystems["file"], "/correct")256 require.NoError(t, err)257 require.Equal(t, string(data), "test")258 data, err = afero.ReadFile(newArc.Filesystems["file"], "/wrong")259 require.Error(t, err)260 require.Nil(t, data)261}262func TestArchiveWithDataNotInFS(t *testing.T) {263 t.Parallel()264 arc := &Archive{265 Type: "js",266 FilenameURL: &url.URL{Scheme: "file", Path: "/script"},267 K6Version: consts.Version,268 Data: []byte(`test`),269 PwdURL: &url.URL{Scheme: "file", Path: "/"},270 Filesystems: nil,271 }272 buf := bytes.NewBuffer(nil)273 err := arc.Write(buf)274 require.Error(t, err)275 require.Contains(t, err.Error(), "the main script wasn't present in the cached filesystem")276}277func TestMalformedMetadata(t *testing.T) {278 var fs = afero.NewMemMapFs()279 require.NoError(t, afero.WriteFile(fs, "/metadata.json", []byte("{,}"), 0644))280 var b, err = dumpMemMapFsToBuf(fs)281 require.NoError(t, err)282 _, err = ReadArchive(b)283 require.Error(t, err)284 require.Equal(t, err.Error(), `invalid character ',' looking for beginning of object key string`)285}286func TestStrangePaths(t *testing.T) {287 var pathsToChange = []string{288 `/path/with spaces/a.js`,289 `/path/with spaces/a.js`,290 `/path/with日本語/b.js`,291 `/path/with spaces and 日本語/file1.txt`,292 }293 for _, pathToChange := range pathsToChange {294 otherMap := make(map[string][]byte, len(pathsToChange))295 for _, other := range pathsToChange {296 otherMap[other] = []byte(`// ` + other + ` contents`)297 }298 arc1 := &Archive{299 Type: "js",300 K6Version: consts.Version,301 Options: Options{302 VUs: null.IntFrom(12345),303 SystemTags: &stats.DefaultSystemTagSet,304 },305 FilenameURL: &url.URL{Scheme: "file", Path: pathToChange},306 Data: []byte(`// ` + pathToChange + ` contents`),307 PwdURL: &url.URL{Scheme: "file", Path: path.Dir(pathToChange)},308 Filesystems: map[string]afero.Fs{309 "file": makeMemMapFs(t, otherMap),310 },311 }312 buf := bytes.NewBuffer(nil)313 require.NoError(t, arc1.Write(buf), pathToChange)314 arc1Filesystems := arc1.Filesystems315 arc1.Filesystems = nil316 arc2, err := ReadArchive(buf)317 require.NoError(t, err, pathToChange)318 arc2Filesystems := arc2.Filesystems319 arc2.Filesystems = nil320 arc2.Filename = ""321 arc2.Pwd = ""322 assert.Equal(t, arc1, arc2, pathToChange)323 arc1Filesystems["https"] = afero.NewMemMapFs()324 diffMapFilesystems(t, arc1Filesystems, arc2Filesystems)325 }326}327func TestStdinArchive(t *testing.T) {328 var fs = afero.NewMemMapFs()329 // we specifically have different contents in both places330 require.NoError(t, afero.WriteFile(fs, "/-", []byte(`test`), 0644))331 arc := &Archive{332 Type: "js",333 FilenameURL: &url.URL{Scheme: "file", Path: "/-"},334 K6Version: consts.Version,335 Data: []byte(`test`),336 PwdURL: &url.URL{Scheme: "file", Path: "/"},337 Filesystems: map[string]afero.Fs{338 "file": fs,339 },340 }341 buf := bytes.NewBuffer(nil)342 require.NoError(t, arc.Write(buf))343 newArc, err := ReadArchive(buf)344 require.NoError(t, err)345 data, err := afero.ReadFile(newArc.Filesystems["file"], "/-")346 require.NoError(t, err)347 require.Equal(t, string(data), "test")348}...

Full Screen

Full Screen

ReadArchive

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 lib.ReadArchive()4 fmt.Println("Done")5}6import (7func ReadArchive() {8 r, err := zip.OpenReader("test.zip")9 if err != nil {10 fmt.Println(err)11 }12 defer r.Close()13 for _, f := range r.File {14 fpath := filepath.Join("test", f.Name)15 if !strings.HasPrefix(fpath, filepath.Clean("test")+"/") {16 fmt.Println(fpath)17 }18 if f.FileInfo().IsDir() {19 os.MkdirAll(fpath, os.ModePerm)20 }21 if err = os.MkdirAll(filepath.Dir(fpath), os.ModePerm); err != nil {22 fmt.Println(err)23 }24 outFile, err := os.OpenFile(fpath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, f.Mode())25 if err != nil {26 fmt.Println(err)27 }28 rc, err := f.Open()29 if err != nil {30 fmt.Println(err)31 }32 _, err = io.Copy(outFile, rc)33 outFile.Close()34 rc.Close()35 if err != nil {36 fmt.Println(err)37 }38 }39}

Full Screen

Full Screen

ReadArchive

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 cfg, err := goconfig.LoadConfigFile("config.ini")4 if err != nil {5 fmt.Println(err)6 }7 path, err := cfg.GetValue("archive", "path")8 if err != nil {9 fmt.Println(err)10 }11 name, err := cfg.GetValue("archive", "name")12 if err != nil {13 fmt.Println(err)14 }15 archivePath, err := cfg.GetValue("archive", "archivePath")16 if err != nil {17 fmt.Println(err)18 }19 archiveName, err := cfg.GetValue("archive", "archiveName")20 if err != nil {21 fmt.Println(err)22 }23 archiveFormat, err := cfg.GetValue("archive", "archiveFormat")24 if err != nil {25 fmt.Println(err)26 }27 location, err := cfg.GetValue("archive", "location")28 if err != nil {29 fmt.Println(err)30 }31 password, err := cfg.GetValue("archive", "password")32 if err != nil {33 fmt.Println(err)34 }35 size, err := cfg.GetValue("archive", "size")36 if err != nil {37 fmt.Println(err)38 }39 count, err := cfg.GetValue("archive", "count")40 if err != nil {41 fmt.Println(err)42 }43 size, err = cfg.GetValue("archive", "size")44 if err != nil {45 fmt.Println(err)46 }47 count, err = cfg.GetValue("archive", "count")48 if err != nil {49 fmt.Println(err)50 }51 size, err = cfg.GetValue("archive", "size")52 if err != nil {53 fmt.Println(err)54 }

Full Screen

Full Screen

ReadArchive

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 archive, err := gzip.ReadArchive("archive.tar.gz")4 if err != nil {5 panic(err)6 }7 for _, file := range archive.Files() {8 fmt.Println(file.Name())9 }10 err = archive.Extract("file.txt", "newfile.txt")11 if err != nil {12 panic(err)13 }14}

Full Screen

Full Screen

ReadArchive

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 fmt.Println("Hello World")4 lib.ReadArchive()5}6import (7func ReadArchive() {8 fmt.Println("Read Archive")9}10import "fmt"11func main() {12 fmt.Println("Hello World")13}14set PATH=%PATH%;C:\Go\bin15import "fmt"16func main() {17 fmt.Println("Hello World")18}

Full Screen

Full Screen

ReadArchive

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 fmt.Println("Hello, playground")4 lib.ReadArchive()5}6import (7func ReadArchive() {8 fmt.Println("Reading archive")9 tarball, err := os.Open("test.tar.gz")10 if err != nil {11 log.Fatal(err)12 }13 defer tarball.Close()14 gzipReader, err := gzip.NewReader(tarball)15 if err != nil {16 log.Fatal(err)17 }18 defer gzipReader.Close()19 tarReader := tar.NewReader(gzipReader)20 for {21 header, err := tarReader.Next()22 if err == io.EOF {23 }24 if err != nil {25 log.Fatal(err)26 }27 fmt.Printf("%s (%v)28", header.Name, header.FileInfo().IsDir())29 }30}31test.txt (false)32test/ (true)33test/test2.txt (false)34test/test3.txt (false)35test/test4.txt (false)36import (37func main() {38 fmt.Println("Hello, playground")39 lib.WriteArchive()40}41import (

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run K6 automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful