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

// client handles pulling data from syncbase. To be fleshed out when discovery is added.

package client

import (
	"fmt"

	"hearts/img/uistate"
	"v.io/v23/syncbase"
	"v.io/v23/syncbase/nosql"
	_ "v.io/x/ref/runtime/factories/generic"
)

var (
	appName   = "x"
	dbName    = "y"
	tableName = "z"
)

func GetService() syncbase.Service {
	service := syncbase.NewService("users/emshack@google.com/croupier/syncbase")
	return service
}

func WatchData(u *uistate.UIState) (nosql.WatchStream, error) {
	db := u.Service.App(appName).NoSQLDatabase(dbName, nil)
	prefix := ""
	resumeMarker, err := db.GetResumeMarker(u.Ctx)
	if err != nil {
		fmt.Println("RESUMEMARKER ERR: ", err)
	}
	return db.Watch(u.Ctx, tableName, prefix, resumeMarker)
}