upload (#576)

[bytom/vapor.git] / toolbar / osssync / sync / oss.go

diff --git a/toolbar/osssync/sync/oss.go b/toolbar/osssync/sync/oss.go
new file mode 100644 (file)
index 0000000..c89d862
--- /dev/null
+++ b/toolbar/osssync/sync/oss.go
@@ -0,0 +1,31 @@
+package sync
+
+import (
+       "bytes"
+       "io/ioutil"
+
+       "github.com/aliyun/aliyun-oss-go-sdk/oss"
+)
+
+// PutObjByteArr upload Byte Array object
+func (b *BlockKeeper) PutObjByteArr(objectName string, objectValue []byte) error {
+       objectAcl := oss.ObjectACL(oss.ACLPublicRead)
+       return b.OssBucket.PutObject(objectName, bytes.NewReader(objectValue), objectAcl)
+}
+
+// GetObjToData download object to stream
+func (b *BlockKeeper) GetObjToData(objectName string) ([]byte, error) {
+       body, err := b.OssBucket.GetObject(objectName)
+       if err != nil {
+               return nil, err
+       }
+
+       defer body.Close()
+
+       data, err := ioutil.ReadAll(body)
+       if err != nil {
+               return nil, err
+       }
+
+       return data, err
+}