// 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 syncbased

import (
	"unsafe"

	"v.io/x/ref/services/syncbase/server"
	"v.io/v23"

	jrpc "v.io/x/jni/impl/google/rpc"
	jutil "v.io/x/jni/util"
	jcontext "v.io/x/jni/v23/context"
	jaccess "v.io/x/jni/v23/security/access"
)

// #include "jni.h"
import "C"

var (
	permissionsSign = jutil.ClassSign("io.v.v23.security.access.Permissions")
	listenSpecSign  = jutil.ClassSign("io.v.v23.rpc.ListenSpec")
	contextSign     = jutil.ClassSign("io.v.v23.context.VContext")
	syncbaseStorageEngineSign = jutil.ClassSign("io.v.v23.syncbase.SyncbaseStorageEngine")

	jSystemClass jutil.Class
	jVClass jutil.Class
)

func Init(env jutil.Env) error {
	var err error
	jSystemClass, err = jutil.JFindClass(env, "java/lang/System")
	if err != nil {
		return err
	}
	jVClass, err = jutil.JFindClass(env, "io/v/v23/V")
	if err != nil {
		return err
	}
	return nil
}

//export Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeInit
func Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeInit(jenv *C.JNIEnv, jSyncbaseServerClass C.jclass) {
	env := jutil.WrapEnv(jenv)
	if err := Init(env); err != nil {
		jutil.JThrowV(env, err)
		return
	}
}

//export Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeStart
func Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeStart(jenv *C.JNIEnv, jSyncbaseServerClass C.jclass, jContext C.jobject, jSyncbaseServerParams C.jobject) C.jobject {
	env := jutil.WrapEnv(jenv)
	jCtx := jutil.WrapObject(jContext)
	jParams := jutil.WrapObject(jSyncbaseServerParams)

	// Read and translate all of the server params.
	jPerms, err := jutil.CallObjectMethod(env, jParams, "getPermissions", nil, permissionsSign)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	perms, err := jaccess.GoPermissions(env, jPerms)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	jListenSpec, err := jutil.CallObjectMethod(env, jParams, "getListenSpec", nil, listenSpecSign)
	if err != nil {
		jutil.JThrowV(env, err)

		return nil
	}
	if jListenSpec.IsNull() {
		jListenSpec, err = jutil.CallStaticObjectMethod(env, jVClass, "getListenSpec", []jutil.Sign{contextSign}, listenSpecSign, jCtx)
		if err != nil {
			jutil.JThrowV(env, err)
			return nil
		}
	}
	listenSpec, err := jrpc.GoListenSpec(env, jListenSpec)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	name, err := jutil.CallStringMethod(env, jParams, "getName", nil)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	rootDir, err := jutil.CallStringMethod(env, jParams, "getStorageRootDir", nil)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	if rootDir == "" {
		rootDir, err = jutil.CallStaticStringMethod(env, jSystemClass, "getProperty", []jutil.Sign{jutil.StringSign}, "java.io.tmpdir")
		if err != nil {
			jutil.JThrowV(env, err)
			return nil
		}
	}
	jEngine, err := jutil.CallObjectMethod(env, jParams, "getStorageEngine", nil, syncbaseStorageEngineSign)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	engine, err := GoStorageEngine(env, jEngine)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}

	// Start the server.
	ctx, err := jcontext.GoContext(env, jCtx)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	s, err := v23.NewServer(ctx)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	_, err = s.Listen(listenSpec)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	service, err := server.NewService(ctx, nil, server.ServiceOptions{
		Perms:   perms,
		RootDir: rootDir,
		Engine:  engine,
	})
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	dispatcher := server.NewDispatcher(service)
	if err := s.ServeDispatcher(name, dispatcher); err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	jServer, err := jrpc.JavaServer(env, s)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	return C.jobject(unsafe.Pointer(jServer))
}