v23/syncbase/resolver.go

// Copyright 2015 The Vanadium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// +build java android

package syncbase

import (
	"runtime"

	"v.io/v23/context"
	"v.io/v23/syncbase"

	jutil "v.io/x/jni/util"
	jcontext "v.io/x/jni/v23/context"
)

// GoResolver converts a provided Java ConflictResolver into a Go
// ConflictResolver.
func GoResolver(env jutil.Env, jResolver jutil.Object) syncbase.ConflictResolver {
	if jResolver.IsNull() {
		return nil
	}
	// Reference Java resolver; it will be de-referenced when the Go resolver
	// created below is garbage-collected (through the finalizer callback we
	// setup just below).
	jResolver = jutil.NewGlobalRef(env, jResolver)
	resolver := &jniResolver{
		jResolver: jResolver,
	}
	runtime.SetFinalizer(resolver, func(r *jniResolver) {
		env, freeFunc := jutil.GetEnv()
		defer freeFunc()
		jutil.DeleteGlobalRef(env, r.jResolver)
	})
	return resolver
}

type jniResolver struct {
	jResolver jutil.Object
}

func (r *jniResolver) OnConflict(ctx *context.T, conflict *syncbase.Conflict) syncbase.Resolution {
	env, freeFunc := jutil.GetEnv()
	defer freeFunc()
	jContext, err := jcontext.JavaContext(env, ctx, nil)
	if err != nil {
		panic("Couldn't create Java context: " + err.Error())
	}
	jConflict, err := jutil.JVomCopy(env, *conflict, jConflictClass)
	if err != nil {
		panic("Couldn't create Java Conflict object: " + err.Error())
	}
	contextSign := jutil.ClassSign("io.v.v23.context.VContext")
	conflictSign := jutil.ClassSign("io.v.v23.syncbase.Conflict")
	resolutionSign := jutil.ClassSign("io.v.v23.syncbase.Resolution")
	jResolution, err := jutil.CallObjectMethod(env, r.jResolver, "onConflict", []jutil.Sign{contextSign, conflictSign}, resolutionSign, jContext, jConflict)
	if err != nil {
		panic("Error invoking Java ConflictResolver: " + err.Error())
	}
	var resolution syncbase.Resolution
	if err := jutil.GoVomCopy(env, jResolution, jResolutionClass, &resolution); err != nil {
		panic("Couldn't create Go Resolution: " + err.Error())
	}
	return resolution
}