1 files changed, 67 insertions, 5 deletions
diff --git a/blob.go b/blob.go
index b638c4f..4277127 100644
--- a/blob.go
+++ b/blob.go
@@ -3,23 +3,85 @@ package git
 /*
 #include <git2.h>
 #include <git2/errors.h>
+#include <string.h>
+
+extern int _go_git_blob_create_fromchunks(git_oid *id,
+	git_repository *repo,
+	const char *hintpath,
+	void *payload);
+
 */
 import "C"
 import (
+	"io"
+	"runtime"
 	"unsafe"
 )
 
 type Blob struct {
 	gitObject
+	cast_ptr *C.git_blob
 }
 
-func (v Blob) Size() int64 {
-	return int64(C.git_blob_rawsize(v.ptr))
+func (v *Blob) Size() int64 {
+	return int64(C.git_blob_rawsize(v.cast_ptr))
 }
 
-func (v Blob) Contents() []byte {
-	size := C.int(C.git_blob_rawsize(v.ptr))
-	buffer := unsafe.Pointer(C.git_blob_rawcontent(v.ptr))
+func (v *Blob) Contents() []byte {
+	size := C.int(C.git_blob_rawsize(v.cast_ptr))
+	buffer := unsafe.Pointer(C.git_blob_rawcontent(v.cast_ptr))
 	return C.GoBytes(buffer, size)
 }
 
+func (repo *Repository) CreateBlobFromBuffer(data []byte) (*Oid, error) {
+	runtime.LockOSThread()
+	defer runtime.UnlockOSThread()
+	oid := C.git_oid{}
+	ecode := C.git_blob_create_frombuffer(&oid, repo.ptr, unsafe.Pointer(&data[0]), C.size_t(len(data)))
+	if ecode < 0 {
+		return nil, MakeGitError(ecode)
+	}
+	return newOidFromC(&oid), nil
+}
+
+type BlobChunkCallback func(maxLen int) ([]byte, error)
+
+type BlobCallbackData struct {
+	Callback BlobChunkCallback
+	Error    error
+}
+
+//export blobChunkCb
+func blobChunkCb(buffer *C.char, maxLen C.size_t, payload unsafe.Pointer) int {
+	data := (*BlobCallbackData)(payload)
+	goBuf, err := data.Callback(int(maxLen))
+	if err == io.EOF {
+		return 0
+	} else if err != nil {
+		data.Error = err
+		return -1
+	}
+	C.memcpy(unsafe.Pointer(buffer), unsafe.Pointer(&goBuf[0]), C.size_t(len(goBuf)))
+	return len(goBuf)
+}
+
+func (repo *Repository) CreateBlobFromChunks(hintPath string, callback BlobChunkCallback) (*Oid, error) {
+	runtime.LockOSThread()
+	defer runtime.UnlockOSThread()
+
+	var chintPath *C.char = nil
+	if len(hintPath) > 0 {
+		C.CString(hintPath)
+		defer C.free(unsafe.Pointer(chintPath))
+	}
+	oid := C.git_oid{}
+	payload := &BlobCallbackData{Callback: callback}
+	ecode := C._go_git_blob_create_fromchunks(&oid, repo.ptr, chintPath, unsafe.Pointer(payload))
+	if payload.Error != nil {
+		return nil, payload.Error
+	}
+	if ecode < 0 {
+		return nil, MakeGitError(ecode)
+	}
+	return newOidFromC(&oid), nil
+}