Skip to content

Commit 365cbb9

Browse files
committed
fix(dsfs): fix adjustments to meta prior to commit message generation
bad copy-paste meant that "next" meta object wasn't being examined for "path" or "qri" keys
1 parent 8174996 commit 365cbb9

File tree

17 files changed

+27
-161
lines changed

17 files changed

+27
-161
lines changed

api/datasets_test.go

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -429,8 +429,6 @@ func TestGetZip(t *testing.T) {
429429
t.Fatalf("expected status code 200, got %d", gotStatusCode)
430430
}
431431

432-
// ioutil.WriteFile("testdata/cities/exported_2.zip", []byte(gotBodyString), 0644)
433-
434432
// Compare the API response to the expected zip file
435433
expectBytes, err := ioutil.ReadFile("testdata/cities/exported.zip")
436434
if err != nil {
@@ -467,12 +465,8 @@ func TestDatasetGet(t *testing.T) {
467465

468466
actualStatusCode, actualBody := APICall("/get/peer/test_ds", dsHandler.GetHandler)
469467
assertStatusCode(t, "get dataset", actualStatusCode, 200)
470-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestGetDataset.test_ds.json")
471468
got := datasetJSONResponse(t, actualBody)
472-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
473-
t.Errorf("output mismatch (-want +got):\n%s", diff)
474-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestGetDataset.test_ds.json", got)
475-
}
469+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestDatasetGet.test_ds.json", got)
476470

477471
// Get csv body using "body.csv" suffix
478472
actualStatusCode, actualBody = APICall("/get/peer/test_ds/body.csv", dsHandler.GetHandler)
File renamed without changes.

base/dsfs/body_test.go

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,7 @@ import (
44
"bytes"
55
"context"
66
"io/ioutil"
7-
"os"
87
"testing"
9-
10-
"github.com/qri-io/qfs"
118
)
129

1310
func TestLoadBody(t *testing.T) {
@@ -17,10 +14,6 @@ func TestLoadBody(t *testing.T) {
1714
t.Fatalf("error creating test filestore: %s", err.Error())
1815
}
1916

20-
t.Logf("%v", datasets)
21-
v, _ := fs.(*qfs.MemFS).Print()
22-
ioutil.WriteFile("/Users/b5/Desktop/memfs_contents", []byte(v), os.ModePerm)
23-
2417
ds, err := LoadDataset(ctx, fs, datasets["cities"])
2518
if err != nil {
2619
t.Fatalf("error loading dataset: %s", err.Error())

base/dsfs/commit.go

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,8 @@ const (
3232
BodyDefault = BodyAction("default")
3333
// BodySame means that the bodies are the same, no need to compare
3434
BodySame = BodyAction("same")
35-
// BodyTooBig means the body is too big to compare, and should be assumed to have changed
35+
// BodyTooBig means the body is too big to directly compare, and should use
36+
// some other method
3637
BodyTooBig = BodyAction("too_big")
3738
)
3839

@@ -261,11 +262,13 @@ func generateCommitDescriptions(ctx context.Context, fs qfs.Filesystem, ds, prev
261262
if prevMeta, ok := prevData["meta"]; ok {
262263
if prevObject, ok := prevMeta.(map[string]interface{}); ok {
263264
delete(prevObject, "path")
265+
delete(prevObject, "qri")
264266
}
265267
}
266-
if nextMeta, ok := prevData["meta"]; ok {
268+
if nextMeta, ok := nextData["meta"]; ok {
267269
if nextObject, ok := nextMeta.(map[string]interface{}); ok {
268270
delete(nextObject, "path")
271+
delete(nextObject, "qri")
269272
}
270273
}
271274

base/dsfs/compute_fields.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,6 @@ func (cff *computeFieldsFile) StatsComponent() (*dataset.Stats, error) {
151151
}, nil
152152
}
153153

154-
// , store cafs.Filestore, ds, prev *dataset.Dataset, bodyR io.Reader, pk crypto.PrivKey, sw SaveSwitches, done chan error
155154
func (cff *computeFieldsFile) handleRows(ctx context.Context) {
156155
var (
157156
batchBuf *dsio.EntryBuffer

base/dsfs/dataset.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,8 @@ func CreateDataset(
141141
ctx context.Context,
142142
source qfs.Filesystem,
143143
destination qfs.Filesystem,
144-
ds, prev *dataset.Dataset,
144+
ds *dataset.Dataset,
145+
prev *dataset.Dataset,
145146
pk crypto.PrivKey,
146147
sw SaveSwitches,
147148
) (string, error) {

base/dsfs/dataset_test.go

Lines changed: 1 addition & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,7 @@ func TestWriteDataset(t *testing.T) {
432432

433433
if ref.Transform != nil {
434434
if ref.Transform.IsEmpty() {
435-
t.Errorf("expected stored dataset.Transform to populated")
435+
t.Errorf("expected stored dataset.Transform to be populated")
436436
}
437437
ds.Transform.Assign(dataset.NewTransformRef(ref.Transform.Path))
438438
}
@@ -1047,41 +1047,3 @@ func BenchmarkValidateJSON(b *testing.B) {
10471047
})
10481048
}
10491049
}
1050-
1051-
// func BenchmarkPrepareDataset1000000Rows(b *testing.B) {
1052-
// ctx := context.Background()
1053-
// _, ds := GenerateDataset(b, 1000000, "csv")
1054-
// fs := qfs.NewMemFS()
1055-
// info := testPeers.GetTestPeerInfo(10)
1056-
// privKey := info.PrivKey
1057-
1058-
// for i := 0; i < b.N; i++ {
1059-
// f, err := ioutil.TempFile("", "benchmark_prepare_dataset")
1060-
// if err != nil {
1061-
// b.Fatal(err)
1062-
// }
1063-
1064-
// prepareDataset(ctx, fs, ds, nil, privKey, f, SaveSwitches{})
1065-
1066-
// os.RemoveAll(f.Name())
1067-
// }
1068-
// }
1069-
1070-
// func BenchmarkPrepareDataset5000000Rows(b *testing.B) {
1071-
// ctx := context.Background()
1072-
// _, ds := GenerateDataset(b, 5000000, "csv")
1073-
// fs := qfs.NewMemFS()
1074-
// info := testPeers.GetTestPeerInfo(10)
1075-
// privKey := info.PrivKey
1076-
1077-
// for i := 0; i < b.N; i++ {
1078-
// f, err := ioutil.TempFile("", "benchmark_prepare_dataset")
1079-
// if err != nil {
1080-
// b.Fatal(err)
1081-
// }
1082-
1083-
// prepareDataset(ctx, fs, ds, nil, privKey, f, SaveSwitches{})
1084-
1085-
// os.RemoveAll(f.Name())
1086-
// }
1087-
// }

base/dsfs/doc.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,3 @@ import (
66
)
77

88
var log = logger.Logger("dsfs")
9-
10-
func init() {
11-
// logger.SetLogLevel("dsfs", "debug")
12-
// logger.SetLogLevel("qfs", "debug")
13-
}

base/remove.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -103,10 +103,6 @@ func RemoveNVersionsFromStore(ctx context.Context, r repo.Repo, curr dsref.Ref,
103103
// Decrement our counter. If counter was -1, this loop will continue forever, until a
104104
// blank PreviousPath is found.
105105
i--
106-
// unpin dataset, ignoring "not pinned" errors
107-
// if err = UnpinDataset(ctx, r, dest.Path); err != nil && !strings.Contains(err.Error(), "not pinned") {
108-
// return nil, err
109-
// }
110106

111107
if err = r.Filesystem().Delete(ctx, dest.Path); err != nil {
112108
return nil, err

cmd/cmd_test.go

Lines changed: 7 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -223,11 +223,7 @@ func TestSaveThenOverrideMetaComponent(t *testing.T) {
223223
got := run.MustLoadDataset(t, dsPath)
224224

225225
// This dataset is ds_ten.yaml, with the meta replaced by meta_override.yaml.
226-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveThenOverrideMetaComponent.json")
227-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
228-
t.Errorf("dataset (-want +got):\n%s", diff)
229-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveThenOverrideMetaComponent.json", got)
230-
}
226+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveThenOverrideMetaComponent.json", got)
231227
}
232228

233229
// Test save with a body, then adding a meta
@@ -248,11 +244,7 @@ func TestSaveWithBodyThenAddMetaComponent(t *testing.T) {
248244
got := run.MustLoadDataset(t, dsPath)
249245

250246
// This version has a commit message about the meta being added
251-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveWithBodyThenAddMetaComponent.json")
252-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
253-
t.Errorf("dataset (-want +got):\n%s", diff)
254-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveWithBodyThenAddMetaComponent.json", got)
255-
}
247+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveWithBodyThenAddMetaComponent.json", got)
256248
}
257249

258250
// Test save with a body, then adding a meta
@@ -273,11 +265,7 @@ func TestSaveWithBodyThenAddMetaAndSmallBodyChange(t *testing.T) {
273265
got := run.MustLoadDataset(t, dsPath)
274266

275267
// This version has a commit message about the meta being added and body changing
276-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveWithBodyThenAddMetaAndSmallBodyChange.json")
277-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
278-
t.Errorf("dataset (-want +got):\n%s", diff)
279-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveWithBodyThenAddMetaAndSmallBodyChange.json", got)
280-
}
268+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveWithBodyThenAddMetaAndSmallBodyChange.json", got)
281269
}
282270

283271
// Test that saving with two components at once will merge them together.
@@ -299,11 +287,7 @@ func TestSaveTwoComponents(t *testing.T) {
299287

300288
// This dataset is ds_ten.yaml, with the meta replaced by meta_override ("different title") and
301289
// the structure replaced by structure_override (lazyQuotes: false && title: "name").
302-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveTwoComponents.json")
303-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
304-
t.Errorf("dataset (-want +got):\n%s", diff)
305-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveTwoComponents.json", got)
306-
}
290+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveTwoComponents.json", got)
307291
}
308292

309293
// Test that save can override just the transform
@@ -324,11 +308,7 @@ func TestSaveThenOverrideTransform(t *testing.T) {
324308
got := run.MustLoadDataset(t, dsPath)
325309

326310
// This dataset is ds_ten.yaml, with an added transform section
327-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveThenOverrideTransform.json")
328-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
329-
t.Errorf("dataset (-want +got):\n%s", diff)
330-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveThenOverrideTransform.json", got)
331-
}
311+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveThenOverrideTransform.json", got)
332312
}
333313

334314
// Test that save can override just the viz
@@ -349,11 +329,7 @@ func TestSaveThenOverrideViz(t *testing.T) {
349329
got := run.MustLoadDataset(t, dsPath)
350330

351331
// This dataset is ds_ten.yaml, with an added viz section
352-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveThenOverrideViz.json")
353-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
354-
t.Errorf("dataset (-want +got):\n%s", diff)
355-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveThenOverrideViz.json", got)
356-
}
332+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveThenOverrideViz.json", got)
357333
}
358334

359335
// Test that save can combine a meta compoent, and a transform, and a viz
@@ -374,11 +350,7 @@ func TestSaveThenOverrideMetaAndTransformAndViz(t *testing.T) {
374350
got := run.MustLoadDataset(t, dsPath)
375351

376352
// This dataset is ds_ten.yaml, with an added meta component, and transform, and viz
377-
expect := dstest.LoadGoldenFile(t, "testdata/expect/TestSaveThenOverrideMetaAndTransformAndViz.json")
378-
if diff := dstest.CompareDatasets(expect, got); diff != "" {
379-
t.Errorf("dataset (-want +got):\n%s", diff)
380-
dstest.UpdateGoldenFileIfEnvVarSet("testdata/expect/TestSaveThenOverrideMetaAndTransformAndViz.json", got)
381-
}
353+
dstest.CompareGoldenDatasetAndUpdateIfEnvVarSet(t, "testdata/expect/TestSaveThenOverrideMetaAndTransformAndViz.json", got)
382354
}
383355

384356
// Test that saving a full dataset with a component at the same time is an error

0 commit comments

Comments
 (0)