Skip to content

Commit cc8efdd

Browse files
committed
update
1 parent f73bca9 commit cc8efdd

49 files changed

Lines changed: 49 additions & 47 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

go/src/kilo/sku_fmt/json.go

Lines changed: 40 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -15,101 +15,103 @@ import (
1515
)
1616

1717
type Json struct {
18-
BlobString string `json:"blob-string"`
1918
BlobSha string `json:"blob-sha"`
19+
BlobString string `json:"blob-string"`
20+
Date string `json:"date"`
2021
Description string `json:"description"`
21-
Tags []string `json:"tags"`
22+
Dormant bool `json:"dormant"`
2223
ObjectId string `json:"object-id"`
2324
Sha string `json:"sha"`
24-
Type string `json:"type"`
25+
Tags []string `json:"tags"`
2526
Tai string `json:"tai"`
26-
Date string `json:"date"`
27+
Type string `json:"type"`
2728
}
2829

29-
func (j *Json) FromStringAndMetadata(
30-
k string,
31-
m *object_metadata.Metadata,
32-
s env_repo.Env,
30+
func (json *Json) FromStringAndMetadata(
31+
objectId string,
32+
metadata *object_metadata.Metadata,
33+
envRepo env_repo.Env,
3334
) (err error) {
34-
var r sha.ReadCloser
35+
var readCloser sha.ReadCloser
3536

36-
if r, err = s.BlobReader(&m.Blob); err != nil {
37+
if readCloser, err = envRepo.BlobReader(&metadata.Blob); err != nil {
3738
err = errors.Wrap(err)
3839
return
3940
}
4041

41-
defer errors.DeferredCloser(&err, r)
42+
defer errors.DeferredCloser(&err, readCloser)
4243

43-
var out strings.Builder
44+
var blobStringBuilder strings.Builder
4445

45-
if _, err = io.Copy(&out, r); err != nil {
46+
if _, err = io.Copy(&blobStringBuilder, readCloser); err != nil {
4647
err = errors.Wrap(err)
4748
return
4849
}
4950

50-
j.BlobString = out.String()
51-
j.BlobSha = m.Blob.String()
52-
j.Description = m.Description.String()
53-
j.Tags = quiter.Strings(m.GetTags())
54-
j.ObjectId = k
55-
j.Sha = m.SelfMetadataWithoutTai.String()
56-
j.Tai = m.Tai.String()
57-
j.Date = m.Tai.Format(string_format_writer.StringFormatDateTime)
58-
j.Type = m.Type.String()
51+
json.BlobSha = metadata.Blob.String()
52+
json.BlobString = blobStringBuilder.String()
53+
json.Date = metadata.Tai.Format(string_format_writer.StringFormatDateTime)
54+
json.Description = metadata.Description.String()
55+
json.Dormant = metadata.Cache.Dormant.Bool()
56+
json.ObjectId = objectId
57+
json.Sha = metadata.SelfMetadataWithoutTai.String()
58+
json.Tags = quiter.Strings(metadata.GetTags())
59+
json.Tai = metadata.Tai.String()
60+
json.Type = metadata.Type.String()
5961
// TODO add support for "preview"
6062

6163
return
6264
}
6365

64-
func (j *Json) FromTransacted(
65-
sk *sku.Transacted,
66-
s env_repo.Env,
66+
func (json *Json) FromTransacted(
67+
object *sku.Transacted,
68+
envRepo env_repo.Env,
6769
) (err error) {
68-
return j.FromStringAndMetadata(sk.ObjectId.String(), sk.GetMetadata(), s)
70+
return json.FromStringAndMetadata(object.ObjectId.String(), object.GetMetadata(), envRepo)
6971
}
7072

71-
func (j *Json) ToTransacted(sk *sku.Transacted, s env_repo.Env) (err error) {
72-
var w sha.WriteCloser
73+
func (json *Json) ToTransacted(object *sku.Transacted, envRepo env_repo.Env) (err error) {
74+
var writeCloser sha.WriteCloser
7375

74-
if w, err = s.BlobWriter(); err != nil {
76+
if writeCloser, err = envRepo.BlobWriter(); err != nil {
7577
err = errors.Wrap(err)
7678
return
7779
}
7880

79-
defer errors.DeferredCloser(&err, w)
81+
defer errors.DeferredCloser(&err, writeCloser)
8082

81-
if _, err = io.Copy(w, strings.NewReader(j.BlobString)); err != nil {
83+
if _, err = io.Copy(writeCloser, strings.NewReader(json.BlobString)); err != nil {
8284
err = errors.Wrap(err)
8385
return
8486
}
8587

8688
// TODO-P1 support states of blob vs blob sha
87-
sk.SetBlobSha(w.GetShaLike())
89+
object.SetBlobSha(writeCloser.GetShaLike())
8890

89-
if err = sk.ObjectId.Set(j.ObjectId); err != nil {
91+
if err = object.ObjectId.Set(json.ObjectId); err != nil {
9092
err = errors.Wrap(err)
9193
return
9294
}
9395

94-
if err = sk.Metadata.Type.Set(j.Type); err != nil {
96+
if err = object.Metadata.Type.Set(json.Type); err != nil {
9597
err = errors.Wrap(err)
9698
return
9799
}
98100

99-
if err = sk.Metadata.Description.Set(j.Description); err != nil {
101+
if err = object.Metadata.Description.Set(json.Description); err != nil {
100102
err = errors.Wrap(err)
101103
return
102104
}
103105

104106
var es ids.TagSet
105107

106-
if es, err = ids.MakeTagSetStrings(j.Tags...); err != nil {
108+
if es, err = ids.MakeTagSetStrings(json.Tags...); err != nil {
107109
err = errors.Wrap(err)
108110
return
109111
}
110112

111-
sk.Metadata.SetTags(es)
112-
sk.Metadata.GenerateExpandedTags()
113+
object.Metadata.SetTags(es)
114+
object.Metadata.GenerateExpandedTags()
113115

114116
return
115117
}

go/src/november/local_working_copy/formatter_value.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -397,15 +397,15 @@ func (repo *Repo) MakeFormatFunc(
397397
case "json":
398398
enc := json.NewEncoder(writer)
399399

400-
output = func(o *sku.Transacted) (err error) {
401-
var j sku_fmt.Json
400+
output = func(object *sku.Transacted) (err error) {
401+
var jsonRepresentation sku_fmt.Json
402402

403-
if err = j.FromTransacted(o, repo.GetStore().GetEnvRepo()); err != nil {
403+
if err = jsonRepresentation.FromTransacted(object, repo.GetStore().GetEnvRepo()); err != nil {
404404
err = errors.Wrap(err)
405405
return
406406
}
407407

408-
if err = enc.Encode(j); err != nil {
408+
if err = enc.Encode(jsonRepresentation); err != nil {
409409
err = errors.Wrap(err)
410410
return
411411
}
0 Bytes
Binary file not shown.
0 Bytes
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.

0 commit comments

Comments
 (0)