package apidApigeeSync

//import (
//	"github.com/30x/apid"
//	"github.com/apigee-labs/transicator/common"
//	. "github.com/onsi/ginkgo"
//	. "github.com/onsi/gomega"
//)
//
//var _ = Describe("api", func() {
//
//	It("should perform all sync phases", func(done Done) {
//
//		apid.Events().ListenFunc(ApigeeSyncEventSelector, func(event apid.Event) {
//			defer GinkgoRecover()
//			if _, ok := event.(*common.Snapshot); ok {
//				if phase > 1 {
//					db := getDB()
//					// verify event data (post snapshot)
//					var count int
//					err := db.QueryRow(`
//							Select count(scp.id)
//							FROM data_scope AS scp
//							INNER JOIN apid_cluster AS ap
//							WHERE scp.apid_cluster_id = ap.id
//						`).Scan(&count)
//					Expect(err).NotTo(HaveOccurred())
//					Expect(count).To(Equal(1))
//				}
//			} else if _, ok := event.(*common.ChangeList); ok {
//				// verify event data (post change)
//				// There should be 2 scopes now
//				//time.Sleep(200 * time.Millisecond)
//				db := getDB()
//				var count int
//				err := db.QueryRow(`
//						SELECT count(scp.id)
//						FROM data_scope AS scp
//						INNER JOIN apid_cluster AS ap
//						WHERE scp.apid_cluster_id = ap.id
//					`).Scan(&count)
//				Expect(err).NotTo(HaveOccurred())
//				Expect(count).To(Equal(2))
//				close(done)
//			} else {
//				Fail("Unexpected event")
//			}
//
//		})
//	})
//})